clqms-be/app/Controllers/Patient.php
2025-08-12 09:19:10 +07:00

552 lines
25 KiB
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 {
$patient = $this->db->table('patient')
->select('patient.*, country.Country as CountryName, race.Race as RaceName, religion.Religion as ReligionName, ethnic.Ethnic as EthnicName')
->join('country', 'country.IntCountryID = patient.IntCountryID', 'left')
->join('race', 'race.RaceID = patient.RaceID', 'left')
->join('religion', 'religion.ReligionID = patient.ReligionID', 'left')
->join('ethnic', 'ethnic.EthnicID = patient.EthnicID', 'left')
->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[0];
}
// 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['Identity']['IdentifierType'] ?? null,
"Identifier" => $input['Identity']['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());
// }
// }
public function update($InternalPID = null) {
try {
if (!$InternalPID || !is_numeric($InternalPID)) {
return $this->respond(['status' => 'error', 'message' => 'Invalid or missing InternalPID'], 400);
}
$input = $this->request->getJSON(true);
if (!$input) {
return $this->respond(['status' => 'error', 'message' => 'Invalid JSON input'], 400);
}
// Cek apakah data patient ada
$patient = $this->db->table('patient')->where('InternalPID', $InternalPID)->get()->getRowArray();
if (!$patient) {
return $this->respond(['status' => 'error', 'message' => 'Patient not found'], 404);
}
$LinkTo = null;
if (!empty($input['LinkTo']) && is_array($input['LinkTo'])) {
$ids = [];
foreach ($input['LinkTo'] as $row) {
if (isset($row['InternalPID']) && is_numeric($row['InternalPID'])) {
$ids[] = (int)$row['InternalPID'];
}
}
$LinkTo = implode(',', $ids);
}
// Data untuk update patient
$dataPatient = [
"PatientID" => $input['PatientID'] ?? $patient['PatientID'],
"AlternatePID" => $input['AlternatePID'] ?? $patient['AlternatePID'],
"Prefix" => $input['Prefix'] ?? $patient['Prefix'],
"NameFirst" => $input['NameFirst'] ?? $patient['NameFirst'],
"NameMiddle" => $input['NameMiddle'] ?? $patient['NameMiddle'],
"NameMaiden" => $input['NameMaiden'] ?? $patient['NameMaiden'],
"NameLast" => $input['NameLast'] ?? $patient['NameLast'],
"Suffix" => $input['Suffix'] ?? $patient['Suffix'],
"NameAlias" => $input['NameAlias'] ?? $patient['NameAlias'],
"Gender" => isset($input['Gender']) && is_numeric($input['Gender']) ? (int)$input['Gender'] : $patient['Gender'],
"PlaceOfBirth" => $input['PlaceOfBirth'] ?? $patient['PlaceOfBirth'],
"Birthdate" => $input['Birthdate'] ?: $patient['Birthdate'],
"Street_1" => $input['Street_1'] ?? $patient['Street_1'],
"Street_2" => $input['Street_2'] ?? $patient['Street_2'],
"Street_3" => $input['Street_3'] ?? $patient['Street_3'],
"City" => $input['City'] ?? $patient['City'],
"Province" => $input['Province'] ?? $patient['Province'],
"ZIP" => $input['ZIP'] ?? $patient['ZIP'],
"EmailAddress1" => $input['EmailAddress1'] ?? $patient['EmailAddress1'],
"EmailAddress2" => $input['EmailAddress2'] ?? $patient['EmailAddress2'],
"Phone" => $input['Phone'] ?? $patient['Phone'],
"MobilePhone" => $input['MobilePhone'] ?? $patient['MobilePhone'],
"RaceID" => isset($input['RaceID']) && is_numeric($input['RaceID']) ? (int)$input['RaceID'] : $patient['RaceID'],
"IntCountryID" => isset($input['IntCountryID']) && is_numeric($input['IntCountryID']) ? (int)$input['IntCountryID'] : $patient['IntCountryID'],
"MaritalStatus" => $input['MaritalStatus'] ?? $patient['MaritalStatus'],
"ReligionID" => isset($input['ReligionID']) && is_numeric($input['ReligionID']) ? (int)$input['ReligionID'] : $patient['ReligionID'],
"EthnicID" => isset($input['EthnicID']) && is_numeric($input['EthnicID']) ? (int)$input['EthnicID'] : $patient['EthnicID'],
"Citizenship" => $input['Citizenship'] ?? $patient['Citizenship'],
"DeathIndicator" => isset($input['DeathIndicator']) && is_numeric($input['DeathIndicator']) ? (int)$input['DeathIndicator'] : $patient['DeathIndicator'],
'DeathDateTime' => $input['DeathDateTime'] ?: $patient['DeathDateTime'],
"LinkTo" => $LinkTo,
];
// Atur aturan validasi dengan pengecualian is_unique untuk InternalPID ini
$rulesDataPatient = [
'PatientID' => "required|max_length[50]|is_unique[patient.PatientID,InternalPID,{$InternalPID}]",
'AlternatePID' => 'permit_empty|max_length[50]',
'NameFirst' => 'required|min_length[1]|max_length[255]',
'EmailAddress1' => "required|is_unique[patient.EmailAddress1,InternalPID,{$InternalPID}]",
'DeathIndicator' => 'required',
'Gender' => 'required'
];
// Ambil data patidt
$patidt = $this->db->table('patidt')->where('InternalPID', $InternalPID)->get()->getRowArray();
$dataPatidt = [
"IdentifierType" => $input['Identity']['IdentifierType'] ?? ($patidt['IdentifierType'] ?? null),
"Identifier" => $input['Identity']['Identifier'] ?? ($patidt['Identifier'] ?? null),
];
$rulesDataPatidt = [
'Identifier' => "required|is_unique[patidt.Identifier,InternalPID,{$InternalPID}]"
];
// Validasi
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);
}
// Transaksi update
$this->db->transStart();
$this->db->table('patient')->where('InternalPID', $InternalPID)->update($dataPatient);
$dbError = $this->db->error();
if (!empty($dbError['message'])) {
$this->db->transRollback();
return $this->failServerError('Update patient failed: ' . $dbError['message']);
}
$this->db->table('patidt')->where('InternalPID', $InternalPID)->update($dataPatidt);
$dbError = $this->db->error();
if (!empty($dbError['message'])) {
$this->db->transRollback();
return $this->failServerError('Update patidt failed: ' . $dbError['message']);
}
$this->db->transComplete();
if ($this->db->transStatus() === false) {
$dbError = $this->db->error();
return $this->failServerError('Failed to update patient data (transaction rolled back): ' . ($dbError['message'] ?? 'Unknown error'));
}
return $this->respond([
'status' => 'success',
'message' => 'Patient updated successfully',
'data' => $InternalPID
], 200);
} catch (\Exception $e) {
$this->db->transRollback();
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;
}
}