Add Domains

application/Domain/DomainModel.php

@@ -0,0 +1,133 @@
+<?php
+
+class DomainModel {
+    public $inwxRoId;
+    public $domain;
+    public $period;
+    public $crDate;
+    public $exDate;
+    public $reDate;
+    public $upDate;
+    public $transferLock;
+    public $status;
+    public $authCode;
+    public $registrant;
+    public $admin;
+    public $tech;
+    public $billing;
+    public $ns;
+    public $pleskId;
+    public $pleskHostingType;
+    public $pleskCreated;
+
+
+    public function __construct($data = []) {
+        foreach ($data as $field => $value) {
+            if (property_exists(get_called_class(), $field)) {
+                $this->$field = $value;
+            }
+        }
+    }
+
+    public static function importDomains($domains): array {
+        $db = FronkDB::singleton();
+
+        $db->query("TRUNCATE TABLE `Domain`");
+
+        $sql = /** @lang text */
+            "INSERT INTO `Domain` (`inwxRoId`, `domain`, `period`, `crDate`, `exDate`, `reDate`, `upDate`, `transferLock`, `status`, `authCode`, `registrant`, `admin`, `tech`, `billing`, `ns`, `pleskId`, `pleskHostingType`, `pleskCreated`) VALUES ";
+        $values = [];
+        foreach ($domains as $domain) {
+            $valueStr ="(" .
+                $domain['roId'] . ", '" .
+                $domain['domain'] . "', '" .
+                $domain['period'] . "', " .
+                $domain['crDate']['timestamp'] . ", " .
+                $domain['exDate']['timestamp'] . ", " .
+                $domain['reDate']['timestamp'] . ", " .
+                $domain['upDate']['timestamp'] . ", " .
+                ($domain['transferLock'] ? 1 : 0) . ", '" .
+                $domain['status'] . "', '" .
+                $domain['authCode'] . "', " .
+                $domain['registrant'] . ", " .
+                $domain['admin'] . ", " .
+                $domain['tech'] . ", " .
+                $domain['billing'] . ", '" .
+                implode(", ", $domain['ns']) . "', ";
+
+            // Check if 'pleskId' is set
+            if (isset($domain['plesk']) && is_array($domain['plesk'])) {
+                $valueStr .= $domain['plesk']['id'] . ", ";
+                $valueStr .= "'" . $domain['plesk']['hosting_type'] . "', ";
+                $valueStr .= $domain['plesk']['created'];
+            } else {
+                $valueStr .= "NULL, NULL, NULL";
+            }
+
+            $values[] = $valueStr . ")";
+        }
+        $sql .= implode(", ", $values);
+        $db->query($sql);
+        return [
+            "message" => "Imported " . count($domains) . " domains."
+        ];
+    }
+
+    /**
+     * Generate SQL Filter condition (space separated) for a given column.
+     *
+     * @param string|null $filterValue The filter value to match against.
+     * @param string $columnName The name of the column in the database table.
+     * @return string The SQL condition generated based on the filter value and column name.
+     */
+    public static function generateFilterCondition(?string $filterValue, string $columnName): string {
+        $sql = "";
+        if (!empty($filterValue)) {
+            $filterItems = explode(" ", $filterValue);
+            foreach ($filterItems as $item) {
+                $sql .= " AND `$columnName` LIKE '%" . $item . "%'";
+            }
+        }
+
+        return $sql;
+    }
+
+    public static function getSqlFilter($filters): string {
+        $sql = isset($filters['crDate']) ? self::generateFilterCondition($filters['domain'], "domain") : "";
+        $sql .= isset($filters['crDate']) ? " AND `crDate` = " . $filters['crDate'] : "";
+        $sql .= isset($filters['exDate']) ? " AND `exDate` = " . $filters['exDate'] : "";
+        $sql .= isset($filters['reDate']) ? " AND `reDate` = " . $filters['reDate'] : "";
+        $sql .= isset($filters['upDate']) ? " AND `upDate` = " . $filters['upDate'] : "";
+        $sql .= isset($filters['status']) ? " AND `status` = '" . $filters['status'] . "'" : "";
+        $sql .= isset($filters['transferLock']) && $filters['transferLock'] == 1 ? " AND `transferLock` = true" : "";
+        $sql .= isset($filters['authCode']) ? self::generateFilterCondition($filters['authCode'], "authCode") : "";
+        $sql .= isset($filters['registrant']) && $filters['registrant'] !== 'all' ? " AND `registrant` = " . $filters['registrant'] : "";
+        $sql .= isset($filters['admin']) && $filters['admin'] !== 'all' ? " AND `admin` = " . $filters['admin'] : "";
+        $sql .= isset($filters['tech']) && $filters['tech'] !== 'all' ? " AND `tech` = " . $filters['tech'] : "";
+        $sql .= isset($filters['billing']) && $filters['billing'] !== 'all' ? " AND `billing` = " . $filters['billing'] : "";
+        $sql .= isset($filters['ns']) ? self::generateFilterCondition($filters['ns'], "ns") : "";
+        return $sql;
+
+    }
+
+    public static function getAllDomains($filters, $limit = null, $offset = 0): array {
+        $db = FronkDB::singleton();
+        $sql = "SELECT * FROM `Domain` WHERE 1 " . self::getSqlFilter($filters);
+        $sql .= $limit === null ? "" : " LIMIT " . $limit . " OFFSET " . $offset;
+
+        $result = $db->query($sql);
+        $rows = [];
+        while ($row = $result->fetch_assoc()) {
+            $rows[] = new DomainModel($row);
+        }
+
+        return $rows;
+    }
+
+    public static function countDomains($filters) {
+        $db = FronkDB::singleton();
+        $sql = "SELECT COUNT(*) as `total_rows` FROM `Domain` WHERE 1 " . self::getSqlFilter($filters);
+        $result = $db->query($sql);
+        return $result->fetch_assoc()['total_rows'];
+    }
+}