devsofttech_hms_ci4/app/Models/IpdModel.php

<?php

namespace App\Models;

use CodeIgniter\Model;

class IpdModel extends Model
{
    protected $table = 'ipd_master';

    public function insertIpd(array $data): int
    {
        $master = $data['master'] ?? [];
        if (empty($master['p_id'])) {
            return 0;
        }

        $existing = $this->db->table('ipd_master')
            ->where('ipd_status', 0)
            ->where('p_id', $master['p_id'])
            ->get()
            ->getResult();

        if (! empty($existing)) {
            return (int) $existing[0]->id;
        }

        $userSignature = $this->getUserSignature();

        $inserted = $this->db->table('ipd_master')->insert($master);
        if (! $inserted) {
            return 0;
        }

        $insertId = (int) $this->db->insertID();

        $countRow = $this->db->table('ipd_master')
            ->select('count(*) as xtimes')
            ->where('id <=', $insertId)
            ->where('p_id', $master['p_id'])
            ->get()
            ->getRow();

        $times = (int) ($countRow->xtimes ?? 0);

        $pid = str_pad(substr((string) $insertId, -7, 7), 7, '0', STR_PAD_LEFT);
        $pid = 'A' . date('ym') . $pid;

        $this->db->table('ipd_master')
            ->where('id', $insertId)
            ->update([
                'ipd_code' => $pid,
                'ipd_times' => $times,
            ]);

        $docList = $data['doc_list'] ?? [];
        if (! empty($docList)) {
            foreach ($docList as $docId) {
                $docPayload = $this->filterTableDataByExistingColumns('ipd_master_doc_list', [
                    'doc_id' => $docId,
                    'ipd_id' => $insertId,
                    'log' => 'Insert By :' . $userSignature,
                ]);

                if (! empty($docPayload)) {
                    $this->db->table('ipd_master_doc_list')->insert($docPayload);
                }
            }
        }

        return $insertId;
    }

    public function addIpdDoc(array $docData): int
    {
        $docData = $this->filterTableDataByExistingColumns('ipd_master_doc_list', $docData);
        if (empty($docData)) {
            return 0;
        }

        $inserted = $this->db->table('ipd_master_doc_list')->insert($docData);

        return $inserted ? (int) $this->db->insertID() : 0;
    }

    public function removeIpdDoc(int $ipdDocId): int
    {
        $row = $this->db->table('ipd_master_doc_list')
            ->where('id', $ipdDocId)
            ->get()
            ->getRowArray();

        if (empty($row)) {
            return 0;
        }

        $user = $this->getUserIdentity();
        $row['update_by_id'] = $user['id'];
        $row['update_by'] = $user['name'] . '[' . date('Y-m-d H:i:s') . ']';

        $inserted = $this->db->table('ipd_master_doc_list_delete')->insert($row);
        if (! $inserted) {
            return 0;
        }

        $this->db->table('ipd_master_doc_list')
            ->where('id', $ipdDocId)
            ->delete();

        return 1;
    }

    public function replaceIpdDoctors(int $ipdId, array $doctorIds): void
    {
        $ipdId = (int) $ipdId;
        if ($ipdId <= 0 || ! $this->db->tableExists('ipd_master_doc_list')) {
            return;
        }

        $doctorIds = array_values(array_unique(array_filter(array_map('intval', $doctorIds), static fn ($id) => $id > 0)));

        $existingRows = $this->db->table('ipd_master_doc_list')
            ->select('id, doc_id')
            ->where('ipd_id', $ipdId)
            ->get()
            ->getResultArray();

        $existingDoctorIds = [];
        foreach ($existingRows as $row) {
            $docId = (int) ($row['doc_id'] ?? 0);
            $rowId = (int) ($row['id'] ?? 0);
            if ($docId <= 0 || $rowId <= 0) {
                continue;
            }

            $existingDoctorIds[] = $docId;
            if (! in_array($docId, $doctorIds, true)) {
                $this->removeIpdDoc($rowId);
            }
        }

        $userSignature = $this->getUserSignature();
        foreach ($doctorIds as $docId) {
            if (in_array($docId, $existingDoctorIds, true)) {
                continue;
            }

            $this->addIpdDoc([
                'ipd_id' => $ipdId,
                'doc_id' => $docId,
                'log' => 'Insert By :' . $userSignature,
            ]);
        }
    }

    private function filterTableDataByExistingColumns(string $table, array $data): array
    {
        if (! $this->db->tableExists($table)) {
            return [];
        }

        $fields = $this->db->getFieldNames($table) ?? [];
        if (empty($fields)) {
            return $data;
        }

        return array_intersect_key($data, array_flip($fields));
    }

    public function bedAssign(array $data): int
    {
        $ipdId = (int) ($data['ipd_id'] ?? 0);
        $bedId = (int) ($data['bed_id'] ?? 0);
        $fromDate = (string) ($data['Fdate'] ?? date('Y-m-d H:i:s'));
        $toDate = (string) ($data['TDate'] ?? $fromDate);

        if ($ipdId <= 0 || $bedId <= 0) {
            return 0;
        }

        $insertId = 0;

        if ($this->db->tableExists('bed_assignment_history')) {
            $wardId = null;
            if ($this->db->tableExists('bed_master') && in_array('ward_id', $this->db->getFieldNames('bed_master') ?? [], true)) {
                $bedRow = $this->db->table('bed_master')
                    ->select('ward_id')
                    ->where('id', $bedId)
                    ->get()
                    ->getRowArray();
                $wardId = isset($bedRow['ward_id']) ? (int) $bedRow['ward_id'] : null;
            }

            $assignedBy = (int) ($this->getUserIdentity()['id'] ?? 0);

            // Prepare insert data with optional fields
            $insertData = [
                'ipd_id' => $ipdId,
                'bed_id' => $bedId,
                'assignment_type' => $data['assignment_type'] ?? 'admission',
                'assigned_date' => $fromDate,
                'discharged_date' => $toDate,
                'assigned_by' => $assignedBy > 0 ? $assignedBy : null,
                'ward_id' => $wardId,
            ];

            // Add transfer-specific fields if provided
            if (isset($data['transfer_reason']) && !empty($data['transfer_reason'])) {
                $insertData['transfer_reason'] = $data['transfer_reason'];
            }
            if (isset($data['transfer_from_bed_id']) && $data['transfer_from_bed_id'] > 0) {
                $insertData['transfer_from_bed_id'] = (int) $data['transfer_from_bed_id'];
            }
            if (isset($data['remarks']) && !empty($data['remarks'])) {
                $insertData['remarks'] = $data['remarks'];
            }

            // If this is a transfer, mark previous bed assignment as released
            if (($data['assignment_type'] ?? 'admission') === 'transfer') {
                $this->db->table('bed_assignment_history')
                    ->where('ipd_id', $ipdId)
                    ->where('released_date IS NULL')
                    ->update([
                        'released_date' => $fromDate,
                        'release_reason' => 'Transferred to another bed',
                    ]);
            }

            $inserted = $this->db->table('bed_assignment_history')->insert($insertData);

            if (! $inserted) {
                return 0;
            }

            $insertId = (int) $this->db->insertID();
        } elseif ($this->db->tableExists('ipd_bed_assign')) {
            $inserted = $this->db->table('ipd_bed_assign')->insert([
                'ipd_id' => $ipdId,
                'Fdate' => $fromDate,
                'TDate' => $toDate,
                'bed_id' => $bedId,
            ]);

            if (! $inserted) {
                return 0;
            }

            $insertId = (int) $this->db->insertID();
        } else {
            return 0;
        }

        // Update bed_master table (new system)
        if ($this->db->tableExists('bed_master')) {
            $bedFields = $this->db->getFieldNames('bed_master') ?? [];
            
            // Release any previous bed assigned to this IPD
            if (in_array('current_ipd_id', $bedFields) && in_array('bed_status', $bedFields)) {
                $this->db->table('bed_master')
                    ->where('current_ipd_id', $ipdId)
                    ->update([
                        'current_ipd_id' => null,
                        'bed_status' => 'available'
                    ]);
            }
            
            // Assign new bed
            $bedUpdate = [];
            if (in_array('bed_status', $bedFields)) {
                $bedUpdate['bed_status'] = 'occupied';
            }
            if (in_array('current_ipd_id', $bedFields)) {
                $bedUpdate['current_ipd_id'] = $ipdId;
            }
            
            if (!empty($bedUpdate)) {
                $this->db->table('bed_master')
                    ->where('id', $bedId)
                    ->update($bedUpdate);
            }
        }
        
        // Legacy hc_bed_master support (if needed for backward compatibility)
        if ($this->db->tableExists('hc_bed_master') && in_array('bed_used_p_id', $this->db->getFieldNames('hc_bed_master') ?? [], true)) {
            $this->db->table('hc_bed_master')
                ->where('bed_used_p_id', $ipdId)
                ->update(['bed_used_p_id' => 0]);

            $this->db->table('hc_bed_master')
                ->where('id', $bedId)
                ->update(['bed_used_p_id' => $ipdId]);
        }

        return $insertId;
    }

    public function releaseBed(int $ipdId): void
    {
        if ($ipdId <= 0) {
            return;
        }

        // Release bed in bed_master table (new system)
        if ($this->db->tableExists('bed_master')) {
            $bedFields = $this->db->getFieldNames('bed_master') ?? [];
            $bedUpdate = [];
            
            if (in_array('bed_status', $bedFields)) {
                $bedUpdate['bed_status'] = 'available';
            }
            if (in_array('current_ipd_id', $bedFields)) {
                $bedUpdate['current_ipd_id'] = null;
            }
            
            if (!empty($bedUpdate)) {
                $this->db->table('bed_master')
                    ->where('current_ipd_id', $ipdId)
                    ->update($bedUpdate);
            }
        }
        
        // Legacy hc_bed_master support (if needed for backward compatibility)
        if ($this->db->tableExists('hc_bed_master') && in_array('bed_used_p_id', $this->db->getFieldNames('hc_bed_master') ?? [], true)) {
            $this->db->table('hc_bed_master')
                ->where('bed_used_p_id', $ipdId)
                ->update(['bed_used_p_id' => 0]);
        }

        // Update bed_assignment_history to mark beds as released
        if ($this->db->tableExists('bed_assignment_history') && in_array('released_date', $this->db->getFieldNames('bed_assignment_history') ?? [], true)) {
            $this->db->table('bed_assignment_history')
                ->where('ipd_id', $ipdId)
                ->where('released_date IS NULL')
                ->update([
                    'released_date' => date('Y-m-d H:i:s'),
                    'release_reason' => 'Patient Discharged',
                ]);
        }
    }

    public function calculateIPD(int $ipdNo): void
    {
        $packageRow = $this->db->table('ipd_package')
            ->select('sum(package_Amount) as total_pakage_amt, count(*) as no_package')
            ->where('ipd_id', $ipdNo)
            ->get()
            ->getRow();
        $totalPackageAmt = (float) ($packageRow->total_pakage_amt ?? 0);
        $noPackage = (int) ($packageRow->no_package ?? 0);

        $itemsBuilder = $this->db->table('ipd_invoice_item')
            ->select('sum(item_amount) as total_items')
            ->where('ipd_id', $ipdNo);
        if ($noPackage > 0) {
            $itemsBuilder->where('package_id', 0);
        }
        $itemsRow = $itemsBuilder->get()->getRow();
        $ipdItemsTotal = (float) ($itemsRow->total_items ?? 0);

        $chargeRow = $this->db->table('invoice_master')
            ->select('sum(total_amount) as total_opd_charge')
            ->where('payment_status', 1)
            ->where('ipd_include', 1)
            ->where('invoice_status', 1)
            ->where('ipd_id', $ipdNo)
            ->get()
            ->getRow();
        $totalChargeAmount = (float) ($chargeRow->total_opd_charge ?? 0);

        $medicalRow = $this->db->table('invoice_med_master inv')
            ->select(
                'sum(if(inv.ipd_credit = 1 and inv.ipd_credit_type = 1, inv.net_amount, 0)) as tot_medical_amt,'
                . 'sum(if(inv.ipd_credit = 1 and inv.ipd_credit_type = 0, inv.net_amount, 0)) as tot_medical_package_bill,'
                . 'sum(if(inv.ipd_credit = 0, inv.net_amount, 0)) as cash_med_amount',
                false
            )
            ->where('inv.ipd_id', $ipdNo)
            ->get()
            ->getRow();
        $totalMedicalAmt = (float) ($medicalRow->tot_medical_amt ?? 0);
        $totalMedicalPackageAmt = (float) ($medicalRow->tot_medical_package_bill ?? 0);
        $cashMedicalAmt = (float) ($medicalRow->cash_med_amount ?? 0);

        $ipdRow = $this->db->table('ipd_master')
            ->select('Discount,Discount2,Discount3,chargeamount1,chargeamount2')
            ->where('id', $ipdNo)
            ->get()
            ->getRow();
        $discount1 = (float) ($ipdRow->Discount ?? 0);
        $discount2 = (float) ($ipdRow->Discount2 ?? 0);
        $discount3 = (float) ($ipdRow->Discount3 ?? 0);
        $charge1 = (float) ($ipdRow->chargeamount1 ?? 0);
        $charge2 = (float) ($ipdRow->chargeamount2 ?? 0);

        $totalCharges = $totalChargeAmount + $totalPackageAmt + $ipdItemsTotal;
        $grossAmount = $totalCharges + round($totalMedicalAmt, 0);
        $totalDiscount = $discount1 + $discount2 + $discount3;
        $totalExtraCharge = $charge1 + $charge2;
        $netAmount = ($grossAmount + $totalExtraCharge) - $totalDiscount;

        $payRow = $this->db->table('payment_history')
            ->select('sum(if(credit_debit = 0, amount, amount * -1)) as total_paid', false)
            ->where('payof_type', 4)
            ->where('payof_id', $ipdNo)
            ->get()
            ->getRow();
        $totalPaid = (float) ($payRow->total_paid ?? 0);

        $medPayRow = $this->db->table('payment_history_medical')
            ->select('sum(if(credit_debit = 0, amount, amount * -1)) as total_med_paid', false)
            ->where('Customerof_type', 2)
            ->where('ipd_id', $ipdNo)
            ->get()
            ->getRow();
        $totalMedPaid = (float) ($medPayRow->total_med_paid ?? 0);

        $balance = $netAmount - $totalPaid;

        $this->db->table('ipd_master')
            ->where('id', $ipdNo)
            ->update([
                'charge_amount' => $totalCharges,
                'gross_amount' => $grossAmount,
                'package_charge_amount' => $totalPackageAmt,
                'med_amount' => $totalMedicalAmt,
                'package_med_amount' => $totalMedicalPackageAmt,
                'cash_med_amount' => $cashMedicalAmt,
                'med_paid' => $totalMedPaid,
                'total_paid_amount' => $totalPaid,
                'net_amount' => $netAmount,
                'balance_amount' => $balance,
            ]);

        $balanceRow = $this->db->table('ipd_master')
            ->select('payable_by_tpa,discount_by_hospital,discount_by_hospital_2,discount_for_tpa')
            ->where('id', $ipdNo)
            ->get()
            ->getRow();

        $payableByTpa = (float) ($balanceRow->payable_by_tpa ?? 0);
        $discountByHospital = (float) ($balanceRow->discount_by_hospital ?? 0);
        $discountByHospital2 = (float) ($balanceRow->discount_by_hospital_2 ?? 0);
        $discountForTpa = (float) ($balanceRow->discount_for_tpa ?? 0);

        $balanceAfterDiscount = $balance - $payableByTpa - $discountByHospital - $discountByHospital2 - $discountForTpa;

        $this->db->table('ipd_master')
            ->where('id', $ipdNo)
            ->update([
                'balance_discount_after' => $balanceAfterDiscount,
            ]);
    }

    public function updateIpd(array $data, int $id): void
    {
        $row = $this->db->table('ipd_master')
            ->where('id', $id)
            ->get()
            ->getRowArray();

        if (! empty($row)) {
            $userSignature = $this->getUserSignature();
            $oldLog = ($row['log'] ?? '') === '' ? ' ' : (string) $row['log'];

            $changeData = compare_arrays($row, $data);
            if (strlen($changeData) > 0) {
                $data['log'] = $oldLog . PHP_EOL . $changeData . 'Update By :' . $userSignature;
            }
        }

        $this->db->table('ipd_master')
            ->where('id', $id)
            ->update($data);
    }

    public function insertIpdItem(array $data): int
    {
        $inserted = $this->db->table('ipd_invoice_item')->insert($data);

        return $inserted ? (int) $this->db->insertID() : 0;
    }

    public function updateIpdItem(array $data, int $id): void
    {
        $row = $this->db->table('ipd_invoice_item')
            ->where('id', $id)
            ->get()
            ->getRowArray();

        if (! empty($row)) {
            $userSignature = $this->getUserSignature();
            $oldLog = ($row['log'] ?? '') === '' ? ' ' : (string) $row['log'];

            $changeData = compare_arrays($row, $data);
            if (strlen($changeData) > 0) {
                $data['log'] = $oldLog . PHP_EOL . $changeData . 'Update By :' . $userSignature;
            }
        }

        $this->db->table('ipd_invoice_item')
            ->where('id', $id)
            ->update($data);
    }

    public function deleteIpdInvoiceItem(int $id): int
    {
        $row = $this->db->table('ipd_invoice_item')
            ->where('id', $id)
            ->get()
            ->getRowArray();

        if (empty($row)) {
            return 0;
        }

        $nursingChargeId = $this->extractNursingChargeIdFromComment((string) ($row['comment'] ?? ''));
        if ($nursingChargeId > 0 && $this->db->tableExists('nursing_ipd_charges')) {
            $nursingFields = $this->db->getFieldNames('nursing_ipd_charges');
            $nursingUpdate = [];
            if (in_array('include_in_bill', $nursingFields, true)) {
                $nursingUpdate['include_in_bill'] = 0;
            }
            if (in_array('updated_by', $nursingFields, true)) {
                $user = $this->getUserIdentity();
                $nursingUpdate['updated_by'] = $user['name'] . ' [' . $user['id'] . '] D:' . date('Y-m-d H:i:s');
            }
            if (! empty($nursingUpdate)) {
                $this->db->table('nursing_ipd_charges')
                    ->where('charge_id', $nursingChargeId)
                    ->update($nursingUpdate);
            }
        }

        $user = $this->getUserIdentity();
        $row['update_by_id'] = $user['id'];
        $row['update_by'] = $user['name'];
        $row['update_action'] = '1';

        // Keep only columns that exist in the audit table to avoid schema drift failures.
        $auditTableFields = $this->db->getFieldNames('ipd_invoice_item_update');
        if (! empty($auditTableFields)) {
            $row = array_intersect_key($row, array_flip($auditTableFields));
        }

        $inserted = $this->db->table('ipd_invoice_item_update')->insert($row);
        if (! $inserted) {
            return 0;
        }

        $this->db->table('ipd_invoice_item')
            ->where('id', $id)
            ->delete();

        if ($this->db->affectedRows() < 1) {
            return 0;
        }

        return 1;
    }

    public function insertPackage(array $data): int
    {
        $inserted = $this->db->table('ipd_package')->insert($data);

        return $inserted ? (int) $this->db->insertID() : 0;
    }

    public function updatePackage(array $data, int $id): void
    {
        $this->db->table('ipd_package')
            ->where('id', $id)
            ->update($data);
    }

    public function deletePackage(int $id): int
    {
        $row = $this->db->table('ipd_package')
            ->where('id', $id)
            ->get()
            ->getRowArray();

        if (empty($row)) {
            return 0;
        }

        $user = $this->getUserIdentity();
        $row['update_by_id'] = $user['id'];
        $row['update_by_action'] = $user['name'] . ' D:' . date('d-m-Y h:i:s');
        $row['update_action'] = '1';

        $inserted = $this->db->table('ipd_package_update')->insert($row);
        if (! $inserted) {
            return 0;
        }

        $this->db->table('ipd_package')
            ->where('id', $id)
            ->delete();

        return 1;
    }

    public function insertReferIpd(array $data): int
    {
        $inserted = $this->db->table('ipd_refer')->insert($data);

        return $inserted ? (int) $this->db->insertID() : 0;
    }

    public function removeReferIpd(int $id): int
    {
        $row = $this->db->table('ipd_refer')
            ->where('id', $id)
            ->get()
            ->getRowArray();

        if (empty($row)) {
            return 0;
        }

        $user = $this->getUserIdentity();
        $row['update_by_id'] = $user['id'];
        $row['update_by_action'] = $user['name'] . ' D:' . date('d-m-Y h:i:s');
        $row['update_action'] = '1';

        $inserted = $this->db->table('ipd_refer_update')->insert($row);
        if (! $inserted) {
            return 0;
        }

        $this->db->table('ipd_refer')
            ->where('id', $id)
            ->delete();

        return 1;
    }

    private function getUserIdentity(): array
    {
        $userId = 0;
        $userName = 'system';

        if (function_exists('auth')) {
            $user = auth()->user();
            if ($user) {
                $userId = (int) ($user->id ?? 0);
                $userName = (string) ($user->username ?? $user->email ?? 'user');
            }
        }

        return [
            'id' => $userId,
            'name' => $userName,
        ];
    }

    private function extractNursingChargeIdFromComment(string $comment): int
    {
        if ($comment === '') {
            return 0;
        }

        if (preg_match('/\[NURSING_CHARGE_ID:(\d+)\]/', $comment, $matches) !== 1) {
            return 0;
        }

        return (int) ($matches[1] ?? 0);
    }

    private function getUserSignature(): string
    {
        $user = $this->getUserIdentity();

        return $user['id'] . '[' . $user['name'] . ']' . date('Y-m-d H:i:s');
    }
}