clqms-be/app/Controllers/Patient.php

<?php
namespace App\Controllers;

use CodeIgniter\API\ResponseTrait;
use CodeIgniter\Controller;
use CodeIgniter\Database\RawSql;

class Patient extends Controller {
    use ResponseTrait;

    public function __construct() {
        $this->db = \Config\Database::connect();
    }

    // OK - Done
    public function index() {
        try {
            $InternalPID = $this->request->getVar('InternalPID');
            $PatientID = $this->request->getVar('PatientID');
            $Name = $this->request->getVar('Name');
            $Birthdate = $this->request->getVar('Birthdate');
            $qname = "LOWER(CONCAT_WS(' ', IFNULL(Prefix,''), IFNULL(NameFirst,''), IFNULL(NameMiddle,''), IFNULL(NameLast,''), IFNULL(NameMaiden,''), IFNULL(Suffix,'')))";
            $builder = $this->db->table('patient');
            $builder->select("InternalPID, PatientID, $qname as FullName, Gender, Birthdate, EmailAddress1 as Email, MobilePhone");
            if ($Name !== null) { 
                $sql    = $qname;
                $rawSql = new RawSql($sql);
                $builder->like($rawSql, $Name, 'both');
            }
            if ($InternalPID !== null) { $builder->where('InternalPID', $InternalPID); }
            if ($PatientID !== null) { $builder->like('PatientID', $PatientID, 'both'); }
            if ($Birthdate !== null) { $builder->where('Birthdate', $Birthdate); }

            $filteredPatients = $builder->get()->getResultArray();

            // Data pasien tidak ada mengembalikan - success 200
            if (empty($filteredPatients)) {
                return $this->respond([
                    'status' => 'success',
                    'message' => 'No patient records found matching the criteria.',
                    'data' => []
                ], 200);
            }

            // Data pasien ditemukan dan mengembalikan - success 200 
            return $this->respond([
                        'status' => 'success',
                        'message'=> "Patients fetched successfully",
                        'data'   => $filteredPatients,
                    ], 200);

        } catch (\Exception $e) {
            
            // Error Server Mengembalikan 500
            return $this->failServerError('Something went wrong.'.$e->getMessage());
        }
    }

    // OK - Done
    public function show($InternalPID = null) {

        try {

            // $builder = $this->db->table('patient');
            // $patient = $builder->join('patidt', 'patidt.InternalPID = patient.InternalPID', 'left')
            //                    ->where('patient.InternalPID', ((int) $InternalPID))
            //                    ->get()->getRowArray();
            $patient = $this->db->table('patient')
                        ->where('InternalPID', (int) $InternalPID)
                        ->get()
                        ->getRowArray();


            // Data pasien tidak ada mengembalikan - success 200
            if (empty($patient)) {
                return $this->respond([
                    'status' => 'success',
                    'message' => 'Patient with ID ' . $InternalPID . ' not found.',
                    'data' => [],
                ], 200);
            
            } else {

                $patient["Age"] = $this->calculateAgeFromBirthdate($patient["Birthdate"]);
                $patient["Birthdate"] = date("d-m-Y", strtotime($patient["Birthdate"]));
                
                if ($patient['LinkTo'] != null) {
                    
                    $ids = explode(',', $patient['LinkTo']); // dari string jadi array
                    $patientLinkTo = $this->db->table('patient')
                            ->select('InternalPID, PatientID')
                            ->whereIn('InternalPID', $ids)
                            ->get()
                            ->getResultArray();
                    $patient["LinkTo"] = $patientLinkTo == [] ? null : $patientLinkTo[0];
                }

                $patidt = $this->db->table('patidt')
                            ->select('IdentifierType, Identifier')
                            ->where('InternalPID', (int) $InternalPID)
                            ->get()
                            ->getResultArray();
                $patient['Identity'] = $patidt == [] ? null : $patidt;
            }

            // Data pasien ditemukan dan mengembalikan - success 200 
            return $this->respond([
                        'status' => 'success',
                        'message'=> "Patient Show Successfully",
                        'data'   => $patient,
                    ], 200);

        } catch (\Exception $e) {

            // Error Server Mengembalikan 500
            return $this->failServerError('Something went wrong'.$e->getMessage());
        }

    }

    // OK - Done
    public function create() {
        try {
            $input = $this->request->getJSON(true);

            $LinkTo = null;
            if (!empty($input['LinkTo'])) {
                $ids = []; // Temporary
                foreach ($input['LinkTo'] as $row) {
                    $ids[] = $row['InternalPID'];
                }
                $LinkTo = implode(',', $ids);
            }

            // =========================
            // 1. Data untuk tabel patient
            // =========================
            $dataPatient = [
                "PatientID"        => $input['PatientID'] ?? null,
                "AlternatePID"     => $input['AlternatePID'] ?? null,
                "Prefix"           => $input['Prefix'] ?? null,
                "NameFirst"        => $input['NameFirst'] ?? null,
                "NameMiddle"       => $input['NameMiddle'] ?? null,
                "NameMaiden"       => $input['NameMaiden'] ?? null,
                "NameLast"         => $input['NameLast'] ?? null,
                "Suffix"           => $input['Suffix'] ?? null,
                "NameAlias"        => $input['NameAlias'] ?? null,
                "Gender"           => isset($input['Gender']) ? (int) $input['Gender'] : null,
                "PlaceOfBirth"     => $input['PlaceOfBirth'] ?? null,
                "Birthdate"        => $input['Birthdate'] ?: null,
                "Street_1"         => $input['Street_1'] ?? null,
                "Street_2"         => $input['Street_2'] ?? null,
                "Street_3"         => $input['Street_3'] ?? null,
                "City"             => $input['City'] ?? null,
                "Province"         => $input['Province'] ?? null,
                "ZIP"              => $input['ZIP'] ?? null,
                "EmailAddress1"    => $input['EmailAddress1'] ?? null,
                "EmailAddress2"    => $input['EmailAddress2'] ?? null,
                "Phone"            => $input['Phone'] ?? null,
                "MobilePhone"      => $input['MobilePhone'] ?? null,
                "RaceID"           => isset($input['RaceID']) ? (int) $input['RaceID'] : null,
                "IntCountryID"     => isset($input['IntCountryID']) ? (int) $input['IntCountryID'] : null,
                "MaritalStatus"    => $input['MaritalStatus'] ?? null,
                "ReligionID"       => isset($input['ReligionID']) ? (int) $input['ReligionID'] : null,
                "EthnicID"         => isset($input['EthnicID']) ? (int) $input['EthnicID'] : null,
                "Citizenship"      => $input['Citizenship'] ?? null,
                "DeathIndicator"   => isset($input['DeathIndicator']) ? (int) $input['DeathIndicator'] : null,
                'DeathDateTime'    => $input['DeathDateTime'] ?: null,
                "CreateDate"       => date('Y-m-d H:i:s'),
                "DelDate"          => null,
                "LinkTo"           => $LinkTo
                // Mother
                // AccountNumber
            ];

            $rulesDataPatient = [
                'PatientID'      => 'required|is_unique[patient.PatientID]|max_length[50]',
                'AlternatePID'   => 'permit_empty|max_length[50]',
                'NameFirst'      => 'required|min_length[1]|max_length[255]',
                'EmailAddress1'  => 'required|is_unique[patient.EmailAddress1]',
                'DeathIndicator' => 'required',
                'Gender'         => 'required'
            ];

            $dataPatidt = [
                "IdentifierType" => $input['IdentifierType'] ?? null,
                "Identifier"     => $input['Identifier'] ?? null,
                "CreateDate"     => date('Y-m-d H:i:s'),
            ];

            $rulesDataPatidt = [
                'Identifier' => 'required|is_unique[patidt.Identifier]',
            ];

            // =========================
            // Validasi semua sebelum insert
            // =========================
            if (!$this->validateData($dataPatient, $rulesDataPatient)) {
                return $this->respond([
                    'status'  => 'error',
                    'message' => 'Validation failed (patient)',
                    'errors'  => $this->validator->getErrors()
                ], 400);
            }

            if (!$this->validateData($dataPatidt, $rulesDataPatidt)) {
                return $this->respond([
                    'status'  => 'error',
                    'message' => 'Validation failed (patidt)',
                    'errors'  => $this->validator->getErrors()
                ], 400);
            }

            // =========================
            // Mulai transaksi
            // =========================
            $this->db->transStart();

            $this->db->table('patient')->insert($dataPatient);
            $newInternalPatientId = $this->db->insertID();

            $dbError = $this->db->error();
            if (!empty($dbError['message'])) {
                $this->db->transRollback();
                return $this->failServerError('Insert patient failed: ' . $dbError['message']);
            }

            $dataPatidt['InternalPID'] = $newInternalPatientId;
            $this->db->table('patidt')->insert($dataPatidt);

            $this->db->transComplete();

            if ($this->db->transStatus() === false) {
                $dbError = $this->db->error(); 
                return $this->failServerError(
                    'Failed to create patient data (transaction rolled back): ' . ($dbError['message'] ?? 'Unknown database error')
                );
            }

            return $this->respondCreated([
                'status'  => 'success',
                'message' => 'Patient created successfully',
                'data'    => $newInternalPatientId
            ], 201);

        } catch (\Exception $e) {
            $this->db->transRollback();
            return $this->failServerError('Something went wrong: ' . $e->getMessage());
        }
    }


    // OK - Done
    public function update($InternalPID = null) {

        try {

            $InternalPID = (int) $InternalPID;

            $input = $this->request->getJSON(true);

            $dataPatient = [
                "PatientID"        => $input['PatientID'] ?? null,
                "AlternatePID"     => $input['AlternatePID'] ?? null,
                "Prefix"           => $input['Prefix'] ?? null,
                "NameFirst"        => $input['NameFirst'] ?? null,
                "NameMiddle"       => $input['NameMiddle'] ?? null,
                "NameMaiden"       => $input['NameMaiden'] ?? null,
                "NameLast"         => $input['NameLast'] ?? null,
                "Suffix"           => $input['Suffix'] ?? null,
                "NameAlias"        => $input['NameAlias'] ?? null,
                "Gender"           => isset($input['Gender']) ? (int) $input['Gender'] : null,
                "PlaceOfBirth"     => $input['PlaceOfBirth'] ?? null,
                "Birthdate"        => $input['Birthdate'] ?: null,
                "Street_1"         => $input['Street_1'] ?? null,
                "Street_2"         => $input['Street_2'] ?? null,
                "Street_3"         => $input['Street_3'] ?? null,
                "City"             => $input['City'] ?? null,
                "Province"         => $input['Province'] ?? null,
                "ZIP"              => $input['ZIP'] ?? null,
                "EmailAddress1"    => $input['EmailAddress1'] ?? null,
                "EmailAddress2"    => $input['EmailAddress2'] ?? null,
                "Phone"            => $input['Phone'] ?? null,
                "MobilePhone"      => $input['MobilePhone'] ?? null,
                "RaceID"           => isset($input['RaceID']) ? (int) $input['RaceID'] : null,
                "IntCountryID"     => isset($input['IntCountryID']) ? (int) $input['IntCountryID'] : null,
                "MaritalStatus"    => $input['MaritalStatus'] ?? null,
                "ReligionID"       => isset($input['ReligionID']) ? (int) $input['ReligionID'] : null,
                "EthnicID"         => isset($input['EthnicID']) ? (int) $input['EthnicID'] : null,
                "Citizenship"      => $input['Citizenship'] ?? null,
                "DeathIndicator"   => isset($input['DeathIndicator']) ? (int) $input['DeathIndicator'] : null,
                'DeathDateTime'    => $input['DeathDateTime'] ?: null,
                "CreateDate"       => date('Y-m-d H:i:s'),
                "DelDate"          => null,
                // Linkto
                // Mother
                // AccountNumber
            ];

            $rulesDataPatient = [
                'PatientID'      => 'required|is_unique[patient.PatientID]|max_length[50]',
                'AlternatePID'   => 'permit_empty|max_length[50]',
                'NameFirst'      => 'required|min_length[1]|max_length[255]',
                'EmailAddress1'  => 'required|is_unique[patient.EmailAddress1]',
                'DeathIndicator' => 'required',
                'Gender'         => 'required'
            ];

            $dataPatidt = [
                "IdentifierType" => $input['IdentifierType'] ?? null,
                "Identifier"     => $input['Identifier'] ?? null,
                "CreateDate"     => date('Y-m-d H:i:s'),
            ];

            $rulesDataPatidt = [
                'Identifier' => 'required|is_unique[patidt.Identifier]',
            ];
            
            $existingPatient = $this->db->table('patient')->where('InternalPID', $InternalPID)->get()->getRowArray();
            
            // Mengembalikan 404
            if (empty($existingPatient)) {
                return $this->failNotFound('Patient with ID ' . $InternalPID . ' not found.');
            }

            // Request dari client tidak valid atau tidak bisa diproses oleh server - 400
            if (!$this->validateData($dataPatient, $rules)) {
                return $this->failValidationErrors($this->validator->getErrors());
            }

            $allowedUpdateFields = [
                'NameFirst', 'NameLast', 'NameMiddle', 
                'PatientID', 'AlternatePID', 'Birthdate', 'PlaceOfBirth',
                'Street_1', 'Street_2', 'Street_3', 'City', 'Province', 'ZIP',
                'EmailAddress1', 'EmailAddress2', 'Phone', 'MobilePhone', 'Mother', 'AccountNumber'
            ];

            $datas = [];
            foreach ($allowedUpdateFields as $field) {
                if (isset($dataPatient[$field])) {
                    $datas[$field] = $dataPatient[$field];
                }
            }

            if (empty($dataPatient)) {
                return $this->failValidationError('No data provided for update.');
            }

            $this->db->table('patient')->where('InternalPID', $InternalPID)->update($dataPatient);

            // Sukses & Insert = 201 - Kirim data patient ID
            return $this->respondCreated([
                'status' => 'success',
                'message' => 'Patient updated successfully',
                'data'  => $dataPatient
            ], 201);

        } catch (\Exception $e) {
            // Error Server = 500
            return $this->failServerError('Something went wrong '.$e->getMessage());
        } 
    }

    // OK - Done
    public function delete($InternalPID = null) {

        try {

            $InternalPID = (int) $InternalPID;
        
            if (!$InternalPID) {
                return $this->failValidationError('Patient ID is required.');
            }

            // Cari data pasien
            $patient = $this->db->table('patient')->where('InternalPID', $InternalPID)->get()->getRow();

            if (!$patient) {
                return $this->failNotFound("Patient ID with {$InternalPID} not found.");
            }

            // Update kolom DelDate sebagai soft delete
            $this->db->table('patient')->where('InternalPID', $InternalPID)->update(['DelDate' => date('Y-m-d H:i:s')]);

            // Mengembalikan 200
            return $this->respondDeleted([
                'status' => 'success',
                'message' => "Patient ID with {$InternalPID} deleted successfully."
            ]);
 
        } catch (\Exception $e) {
            return $this->failServerError("Internal server error: " . $e->getMessage());
        }
    }

    private function calculateAgeFromBirthdate($birthdate) {
        $dob = new \DateTime($birthdate);
        $today = new \DateTime();
        $diff = $today->diff($dob);

        $formattedAge = "";
        if ($diff->y > 0){
            $formattedAge .= "{$diff->y} Tahun ";
        }
        if ($diff->m > 0){
            $formattedAge .= "{$diff->m} Bulan ";
        }
        if ($diff->d > 0){
            $formattedAge .= "{$diff->d} Hari ";
        }

        return $formattedAge;
    }

}