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 {
            $PatientID = $this->request->getVar('PatientID');
            $AlternatePID = $this->request->getVar('AlternatePID');
            $Prefix = $this->request->getVar('Prefix');
            $name = $this->request->getVar('Name');
            $Suffix = $this->request->getVar('Suffix');
            $BirthDate = $this->request->getVar('BirthDate');
            $startDate = $this->request->getVar('StartDate');
            $endDate = $this->request->getVar('EndDate');

            $builder = $this->db->table('patient');
            
            if ($name !== null) { 
                $sql    = "LOWER(CONCAT_WS(' ', IFNULL(prefix,''), IFNULL(name_first,''), IFNULL(name_middle,''), IFNULL(name_last,''), IFNULL(name_maiden,''), IFNULL(suffix,'')))";
                $rawSql = new RawSql($sql);
                $builder->like($rawSql, $name, 'both');
            }
            if ($PatientID !== null) { $builder->where('PatientID', $pat_num); }
            if ($AlternatePID !== null) { $builder->where('AlternatePID', $pat_altnum); }
            if ($BirthDate !== null) { $builder->where('BirthDate', $pat_dob); }
            /*
            if ($startDate !== null || $endDate !== null) { 
                $builder->join('requests', 'pat_id=patients.pat_id','left');
                if ($start_date !== null) { $builder->where('requests.req_date >=', $start_date . ' 00:00:00'); }
                if ($end_date !== null) { $builder->where('requests.req_date <=', $end_date . ' 23:59:00'); }
            }
            */

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

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

            $data = [
                "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"        => 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"         => null,
                "City"             => $input['City'] ?? null,
                "Province"         => $input['Province'] ?? null,
                "ZIP"              => $input['ZIP'] ?? null,
                "CountryID"        => isset($input['CountryID']) ? (int) $input['CountryID'] : null,
                "Emailaddress1"    => $input['Emailaddress1'] ?? null,
                "Emailaddress2"    => $input['Emailaddress2'] ?? null,
                "Phone"            => $input['Phone'] ?? null,
                "Mobilephone"      => $input['Mobilephone'] ?? null,
                "Mother"           => $input['Mother'] ?? null,
                "AccountNumber"    => isset($input['AccountNumber']) ? (int) $input['AccountNumber'] : null,
                "RaceID"           => isset($input['RaceID']) ? (int) $input['RaceID'] : 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,
                "LinkTo"           => $input['LinkTo'] ?? null,
                "CreateDate"       => date('Y-m-d H:i:s'),
                "DelDate"          => null,

                // Field tambahan dari struktur sebelumnya (bisa dihapus jika tidak dipakai)
                "PatientComment"   => $input['PatientComment'] ?? null,
                "IdentityIDType"   => $input['IdentityIDType'] ?? null,
                "IdentityID"       => $input['IdentityID'] ?? null
            ];

            $rules = [
                'PatientID' => 'required|is_unique[patient.PatientID]|max_length[50]',
                'NameFirst' => 'required|min_length[3]|max_length[255]',
                'NameMiddle' => 'permit_empty',
                'NameMaiden' => 'permit_empty',
                'NameLast' => 'permit_empty',
                'AlternatePID' => 'permit_empty|max_length[50]',
                'Street_1' => 'permit_empty',
                'Street_2' => 'permit_empty',
                'Street_3' => 'permit_empty',
                'City' => 'permit_empty',
            ];

            // Request dari client tidak valid atau tidak bisa diproses oleh server - 400
            if (!$this->validateData($data, $rules)) {
                return $this->respond([
                    'status' => 'error',
                    'message' => 'Validation failed',
                    'errors' => $this->validator->getErrors()
                ], 400);
            }

            $this->db->table('patient')->insert($data);
            $newPatientId = $this->db->insertID();

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

        } catch (\Exception $e) {

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

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

        try {

            $InternalPID = (int) $InternalPID;

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

            $data = [
                "InternalPID"      => $input['InternalPID'] ?? null,
                "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"        => 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"         => null,
                "City"             => $input['City'] ?? null,
                "Province"         => $input['Province'] ?? null,
                "ZIP"              => $input['ZIP'] ?? null,
                "CountryID"        => isset($input['CountryID']) ? (int) $input['CountryID'] : null,
                "Emailaddress1"    => $input['Emailaddress1'] ?? null,
                "Emailaddress2"    => $input['Emailaddress2'] ?? null,
                "Phone"            => $input['Phone'] ?? null,
                "Mobilephone"      => $input['Mobilephone'] ?? null,
                "Mother"           => $input['Mother'] ?? null,
                "AccountNumber"    => isset($input['AccountNumber']) ? (int) $input['AccountNumber'] : null,
                "RaceID"           => isset($input['RaceID']) ? (int) $input['RaceID'] : 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,
                "LinkTo"           => $input['LinkTo'] ?? null,
                "CreateDate"       => date('Y-m-d H:i:s'),
                "DelDate"          => null,

                // Field tambahan dari struktur sebelumnya (bisa dihapus jika tidak dipakai)
                "PatientComment"   => $input['PatientComment'] ?? null,
                "IdentityIDType"   => $input['IdentityIDType'] ?? null,
                "IdentityID"       => $input['IdentityID'] ?? null
            ];
            // $data = [
            //     "PatientID"        => $input['PatientID'] ?? null,
            //     "AlternatePID"     => $input['AlternateID'] ?? null,
            //     "Prefix"           => $input['Title'] ?? null,
            //     "NameFirst"        => $input['NameFirst'] ?? null,
            //     "NameMiddle"       => $input['NameMiddle'] ?? null,
            //     "NameMaiden"       => $input['NameMaiden'] ?? null,
            //     "NameLast"         => $input['NameLast'] ?? null,
            //     "Suffix"           => $input['Suffix'] ?? null,
            //     "NameAlias"        => null, 
            //     "Gender"           => ((int) $input['Gender']) ?? null, //int
            //     "PlaceOfBirth"     => $input['PlaceOfBirthdate'] ?? null,
            //     "BirthDate"        => $input['BirthDate'] ?? null,
            //     "Street1"          => $input['Street1'] ?? null,
            //     "Street2"          => $input['Street2'] ?? null,
            //     "Street3"          => null,
            //     "City"             => $input['City'] ?? null,
            //     "Province"         => $input['Province'] ?? null,
            //     "ZIP"              => null,
            //     "CountryID"        => null, // int
            //     "EmailAddress1"    => $input['Email1'] ?? null,
            //     "EmailAddress2"    => $input['Email2'] ?? null,
            //     "Phone"            => $input['Phone'] ?? null,
            //     "MobilePhone"      => $input['Mobile'] ?? null,
            //     "Mother"           => ((int) $input['Mother']) ?? null, //int
            //     "AccountNumber"    => null, //int
            //     "RaceID"           => ((int) $input['Race']) ?? null, //int
            //     "MaritalStatus"    => $input['MaritalStatus'] ?? null,
            //     "ReligionID"       => ((int) $input['Religion']) ?? null, //int
            //     "EthnicID"         => ((int) $input['Ethnic']) ?? null, //int
            //     "Citizenship"      => null,
            //     "DeathIndicator"   => ((int) $input['Death']) ?? null, //int
            //     "DeathDateTime"    => $input['DeathTime'] ?? null,
            //     "CreateDate"       => date('Y-m-d H:i:s'),

            //     "LinkTo"           => $input['LinkTo'] ?? null,
            //     "PatientComment"   => $input['PatientComment'] ?? null,
            //     "IdentityIDType"   => $input['IdentityIDType'] ?? null,
            //     "IdentityID"       => $input['IdentityID'] ?? null
            // ];

            $rules = [
                'NameFirst' => 'required|min_length[3]|max_length[255]',
                'NameMiddle' => 'permit_empty',
                'NameMaiden' => 'permit_empty',
                'NameLast' => 'permit_empty',
                // 'birth_date' => 'permit_empty|valid_date[Y-m-d]|not_in_list[0000-00-00]',
                'AlternatePID' => 'permit_empty|max_length[50]',
                'Street_1' => 'permit_empty',
                'Street_2' => 'permit_empty',
                'Street_3' => 'permit_empty',
                'City' => 'permit_empty',
            ];
            
            $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($data, $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($data[$field])) {
                    $datas[$field] = $data[$field];
                }
            }

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

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

            // Sukses & Insert = 201 - Kirim data patient ID
            return $this->respondCreated([
                'status' => 'success',
                'message' => 'Patient updated successfully',
                'data'  => $data
            ], 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.");
            }

            // Hapus data pasien berdasarkan pat_num
            $this->db->table('patient')->where('InternalPID', $InternalPID)->delete();

            // 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());
        }
    }

}