<?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;
    }

    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);

            $inserted = $this->db->table('bed_assignment_history')->insert([
                'ipd_id' => $ipdId,
                'bed_id' => $bedId,
                'assignment_type' => 'admission',
                'assigned_date' => $fromDate,
                'discharged_date' => $toDate,
                'assigned_by' => $assignedBy > 0 ? $assignedBy : null,
                'ward_id' => $wardId,
            ]);

            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;
        }

        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]);
        }

        if ($this->db->tableExists('bed_master') && in_array('bed_status', $this->db->getFieldNames('bed_master') ?? [], true)) {
            $this->db->table('bed_master')
                ->where('id', $bedId)
                ->update(['bed_status' => 'occupied']);
        }

        return $insertId;
    }

    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');
    }
}