thetool/application/Workorder/WorkorderModel.php

<?php
// WorkorderModel.php

class WorkorderModel extends TTCrudBaseModel
{
    public int $id;
    public int $preorderId;
    public ?int $companyId;
    public ?int $civilEngineeringCompanyId;
    public ?int $originalCompanyId;
    public ?int $clusterId;
    public string $status;
    public ?int $assignmentDate;
    public ?int $deadlineDate;
    public ?int $appointmentDate;
    public ?string $additionalInfo;
    public int $create;
    public int $createBy;

    private static function buildWhereClause(array $filters, array $allowedCampaignIds): string
    {
        if (empty($allowedCampaignIds)) return " WHERE 1=0";

        $sql = Helper::generateFilterCondition(array_map('intval', $allowedCampaignIds), 'p.preordercampaign_id');

        if (empty($filters['status'])) {
            $sql .= " AND w.status NOT IN ('completed', 'cancelled')";
        } else {
            $sql .= Helper::generateFilterCondition($filters['status'], 'w.status', true);
        }

        if (!empty($filters['id'])) $sql .= Helper::generateFilterCondition($filters['id'], 'w.id', true);
        if (!empty($filters['preordercampaign_id'])) $sql .= Helper::generateFilterCondition($filters['preordercampaign_id'], 'p.preordercampaign_id');
        if (!empty($filters['companyName'])) $sql .= Helper::generateFilterCondition($filters['companyName'], 'c.name');
        if (!empty($filters['netOwnerId'])) $sql .= Helper::generateFilterCondition($filters['netOwnerId'], 'n.owner_id');
        if (!empty($filters['networkOwnerName'])) $sql .= Helper::generateFilterCondition($filters['networkOwnerName'], 'owner_addr.company');
        if (!empty($filters['deadlineDate'])) $sql .= Helper::generateFilterCondition($filters['deadlineDate'], 'w.deadlineDate');
        if (!empty($filters['preorderInfo'])) {
            $searchColumns = "p.firstname|p.lastname|p.company|p.oaid|p.street|p.housenumber|p.zip|p.city|str.name|ort.name|w.additionalInfo";
            $sql .= Helper::generateFilterCondition($filters['preorderInfo'], $searchColumns);
        }
        if (!empty($filters['rimo_fcp_name'])) $sql .= Helper::generateFilterCondition($filters['rimo_fcp_name'], "hn.rimo_fcp_name");
        if (!empty($filters['additionalInfo'])) $sql .= Helper::generateFilterCondition($filters['additionalInfo'], 'w.additionalInfo');

        return "WHERE " . ltrim(trim($sql), 'AND');
    }

    public static function getAdminWorkorders(array $filters, ?int $limit, int $offset, array $order, array $allowedCampaignIds): array
    {
        $db = self::getDB();
        $fronkDbName = FRONKDB_DBNAME;
        $addressDbName = defined('ADDRESSDB_DBNAME') ? ADDRESSDB_DBNAME : 'addressdb';

        $sql = "
            SELECT
                w.id, w.status, w.deadlineDate, w.appointmentDate, w.companyId, w.additionalInfo, p.preordercampaign_id, hn.rimo_fcp_name,
                n.owner_id as tenantId, p.ucode, CONCAT_WS(' ', p.firstname, p.lastname) as customerName,
                p.company as customerCompany, p.oaid, IFNULL(c_civil.name, c.name) as companyName, str.name as street, hn.hausnummer,
                hn.stiege, we.bezeichner as apartment, plz.plz, ort.name as city,
                n.owner_id as netOwnerId
            FROM `$fronkDbName`.`Workorder` w
            JOIN `$fronkDbName`.`Preorder` p ON w.preorderId = p.id
            LEFT JOIN `$fronkDbName`.`Preordercampaign` pc ON p.preordercampaign_id = pc.id
            LEFT JOIN `$fronkDbName`.`Network` n ON pc.network_id = n.id
            LEFT JOIN `$fronkDbName`.`WorkorderCompany` c ON w.companyId = c.id
            LEFT JOIN `$fronkDbName`.`WorkorderCompany` c_civil ON w.civilEngineeringCompanyId = c_civil.id
            LEFT JOIN `$addressDbName`.`Hausnummer` hn ON p.adb_hausnummer_id = hn.id
            LEFT JOIN `$addressDbName`.`Strasse` str ON hn.strasse_id = str.id
            LEFT JOIN `$addressDbName`.`Plz` plz ON hn.plz_id = plz.id
            LEFT JOIN `$addressDbName`.`Ortschaft` ort ON hn.ortschaft_id = ort.id
            LEFT JOIN `$addressDbName`.`Wohneinheit` we ON p.adb_wohneinheit_id = we.id
        ";

        $sql .= self::buildWhereClause($filters, $allowedCampaignIds);

        $orderBy = "";
        if (!empty($order['key'])) {
            $sortableColumns = ['id', 'status', 'deadlineDate', 'companyName', 'rimo_fcp_name', 'additionalInfo'];
            if (in_array($order['key'], $sortableColumns)) {
                $sortOrder = (strtoupper($order['order']) === 'DESC') ? 'DESC' : 'ASC';
                $orderBy = " ORDER BY " . $db->real_escape_string($order['key']) . " " . $sortOrder;
            }
        }
        if (empty($orderBy)) $orderBy = " ORDER BY CASE WHEN w.deadlineDate IS NULL THEN 1 ELSE 0 END, w.deadlineDate ASC";

        $sql .= $orderBy;

        if ($limit !== null) $sql .= " LIMIT " . intval($limit) . " OFFSET " . intval($offset);
        $result = $db->query($sql);
        return $result ? $result->fetch_all(MYSQLI_ASSOC) : [];
    }

    public static function countAdminWorkorders(array $filters, array $allowedCampaignIds): int
    {
        $db = self::getDB();
        $fronkDbName = FRONKDB_DBNAME;
        $addressDbName = defined('ADDRESSDB_DBNAME') ? ADDRESSDB_DBNAME : 'addressdb';
        $sql = "
            SELECT COUNT(w.id) as count FROM `$fronkDbName`.`Workorder` w
            JOIN `$fronkDbName`.`Preorder` p ON w.preorderId = p.id
            LEFT JOIN `$fronkDbName`.`WorkorderCompany` c ON w.companyId = c.id
            LEFT JOIN `$fronkDbName`.`WorkorderCompany` c_civil ON w.civilEngineeringCompanyId = c_civil.id
            LEFT JOIN `$fronkDbName`.`Preordercampaign` pc ON p.preordercampaign_id = pc.id
            LEFT JOIN `$fronkDbName`.`Network` n ON pc.network_id = n.id
            LEFT JOIN `$addressDbName`.`Hausnummer` hn ON p.adb_hausnummer_id = hn.id
            LEFT JOIN `$addressDbName`.`Strasse` str ON hn.strasse_id = str.id
            LEFT JOIN `$addressDbName`.`Plz` plz ON hn.plz_id = plz.id
            LEFT JOIN `$addressDbName`.`Ortschaft` ort ON hn.ortschaft_id = ort.id
        ";
        $sql .= self::buildWhereClause($filters, $allowedCampaignIds);
        $result = $db->query($sql);
        return $result ? $result->fetch_assoc()['count'] : 0;
    }

    private static function buildCompanyWhereClause(array $filters, int $companyId): string
    {
        $sql = "(w.companyId = " . $companyId . " OR w.civilEngineeringCompanyId = " . $companyId . ")";
        $sql .= " AND w.status NOT IN ('completed', 'cancelled')";
        if (!empty($filters['id'])) $sql .= Helper::generateFilterCondition($filters['id'], 'w.id', true);
        if (!empty($filters['status'])) $sql .= Helper::generateFilterCondition($filters['status'], 'w.status');
        if (!empty($filters['deadlineDate'])) $sql .= Helper::generateFilterCondition($filters['deadlineDate'], 'w.deadlineDate');
        if (!empty($filters['networkOwnerName'])) $sql .= Helper::generateFilterCondition($filters['networkOwnerName'], 'owner_addr.company');
        if (!empty($filters['appointmentDate'])) $sql .= Helper::generateFilterCondition($filters['appointmentDate'], 'w.appointmentDate');
        if (!empty($filters['preorderInfo'])) {
            $searchColumns = "p.firstname|p.lastname|p.company|p.oaid|p.street|p.housenumber|p.zip|p.city|str.name|ort.name|p.phone|p.email|w.additionalInfo";
            $sql .= Helper::generateFilterCondition($filters['preorderInfo'], $searchColumns);
        }
        if (!empty($filters['rimo_fcp_name'])) $sql .= Helper::generateFilterCondition($filters['rimo_fcp_name'], "hn.rimo_fcp_name");
        if (!empty($filters['additionalInfo'])) $sql .= Helper::generateFilterCondition($filters['additionalInfo'], 'w.additionalInfo');
        return "WHERE " . $sql;
    }

    public static function getCompanyWorkorders(array $filters, ?int $limit, int $offset, array $order, int $companyId): array
    {
        $db = self::getDB();
        $fronkDbName = FRONKDB_DBNAME;
        $addressDbName = defined('ADDRESSDB_DBNAME') ? ADDRESSDB_DBNAME : 'addressdb';
        $sql = "
            SELECT w.id, w.status, w.deadlineDate, w.appointmentDate, w.additionalInfo, hn.rimo_fcp_name,
                owner_addr.company as networkOwnerName,
                CONCAT_WS(' ', p.firstname, p.lastname) as customerName, p.company as customerCompany, p.oaid,
                p.phone, p.email, str.name as street, hn.hausnummer, hn.stiege, we.bezeichner as apartment, plz.plz, ort.name as city
            FROM `$fronkDbName`.`Workorder` w
            JOIN `$fronkDbName`.`Preorder` p ON w.preorderId = p.id
            LEFT JOIN `$fronkDbName`.`Preordercampaign` pc ON p.preordercampaign_id = pc.id
            LEFT JOIN `$fronkDbName`.`Network` n ON pc.network_id = n.id
            LEFT JOIN `$fronkDbName`.`Address` owner_addr ON n.owner_id = owner_addr.id
            LEFT JOIN `$addressDbName`.`Hausnummer` hn ON p.adb_hausnummer_id = hn.id
            LEFT JOIN `$addressDbName`.`Strasse` str ON hn.strasse_id = str.id
            LEFT JOIN `$addressDbName`.`Plz` plz ON hn.plz_id = plz.id
            LEFT JOIN `$addressDbName`.`Ortschaft` ort ON hn.ortschaft_id = ort.id
            LEFT JOIN `$addressDbName`.`Wohneinheit` we ON p.adb_wohneinheit_id = we.id
        ";
        $sql .= self::buildCompanyWhereClause($filters, $companyId);

        $orderBy = "";
        if (!empty($order['key'])) {
            $sortableColumns = ['id', 'status', 'deadlineDate', 'appointmentDate', 'additionalInfo'];
            if (in_array($order['key'], $sortableColumns)) {
                $sortOrder = (strtoupper($order['order']) === 'DESC') ? 'DESC' : 'ASC';
                $orderBy = " ORDER BY " . $db->real_escape_string($order['key']) . " " . $sortOrder;
            }
        }
        if (empty($orderBy)) $orderBy = " ORDER BY CASE WHEN w.deadlineDate IS NULL THEN 1 ELSE 0 END, w.deadlineDate ASC";

        $sql .= $orderBy;

        if ($limit !== null) $sql .= " LIMIT " . intval($limit) . " OFFSET " . intval($offset);

        $result = $db->query($sql);
        return $result ? $result->fetch_all(MYSQLI_ASSOC) : [];
    }

    public static function countCompanyWorkorders(array $filters, int $companyId): int
    {
        $db = self::getDB();
        $fronkDbName = FRONKDB_DBNAME;
        $addressDbName = defined('ADDRESSDB_DBNAME') ? ADDRESSDB_DBNAME : 'addressdb';
        $sql = "
            SELECT COUNT(w.id) as count FROM `$fronkDbName`.`Workorder` w
            JOIN `$fronkDbName`.`Preorder` p ON w.preorderId = p.id
            LEFT JOIN `$addressDbName`.`Hausnummer` hn ON p.adb_hausnummer_id = hn.id
            LEFT JOIN `$fronkDbName`.`Preordercampaign` pc ON p.preordercampaign_id = pc.id
            LEFT JOIN `$fronkDbName`.`Network` n ON pc.network_id = n.id
            LEFT JOIN `$fronkDbName`.`Address` owner_addr ON n.owner_id = owner_addr.id
            LEFT JOIN `$addressDbName`.`Strasse` str ON hn.strasse_id = str.id
            LEFT JOIN `$addressDbName`.`Plz` plz ON hn.plz_id = plz.id
            LEFT JOIN `$addressDbName`.`Ortschaft` ort ON hn.ortschaft_id = ort.id
        ";
        $sql .= self::buildCompanyWhereClause($filters, $companyId);
        $result = $db->query($sql);
        return $result ? $result->fetch_assoc()['count'] : 0;
    }
}