add insert table mcu_preregister_date pada savecsv preregister offline excel

This commit is contained in:
2026-04-28 13:29:20 +07:00
parent 77e2599d10
commit c0f0caad9e
2 changed files with 1510 additions and 41 deletions

View File

@@ -105,10 +105,10 @@ class Preregisterv2 extends MY_Controller
// exit;
$batchSize = 500; // Define the batch size
// Split the array into chunks of 250 records
$dataChunks = array_chunk($datas, $batchSize);
// Loop through each chunk and insert the batch
foreach ($dataChunks as $batchData) {
$insertData = [];
@@ -123,7 +123,7 @@ class Preregisterv2 extends MY_Controller
json_encode($batchData),
$userid
));
}
$exist_patients_arr = [];
@@ -193,8 +193,8 @@ class Preregisterv2 extends MY_Controller
$patient_id = 0;
if ($v['PID'] != '') {
$sql = "SELECT *
FROM m_patient
$sql = "SELECT *
FROM m_patient
WHERE M_PatientNoReg = '{$v['PID']}' LIMIT 1";
$query = $this->db->query($sql);
if(!$query){
@@ -227,17 +227,17 @@ class Preregisterv2 extends MY_Controller
}
if ($v['KTP'] != '') {
$sql = "SELECT *
FROM m_patient
WHERE
M_PatientIdentifierCode = 'NNIDN' AND
$sql = "SELECT *
FROM m_patient
WHERE
M_PatientIdentifierCode = 'NNIDN' AND
M_PatientIdentifierValue = '{$v['KTP']}' AND
M_PatientIsActive = 'Y' LIMIT 1";
$query = $this->db->query($sql);
if(!$query){
$last_qry = $this->db->last_query();
$this->db->trans_rollback();
$this->sys_error("select m_patient : ".$last_qry);
exit;
}
@@ -280,7 +280,7 @@ class Preregisterv2 extends MY_Controller
} else {
$last_qry = $this->db->last_query();
$this->db->trans_rollback();
$this->sys_error("select corporate : ".$last_qry);
exit;
}
@@ -289,17 +289,17 @@ class Preregisterv2 extends MY_Controller
$v['NAMA'] = addslashes($v['NAMA']);
$sql_pre = "SELECT * FROM mcu_preregister_patients WHERE (
Mcu_PreregisterPatientsPatientName = '{$v['NAMA']}' AND
Mcu_PreregisterPatientsDOB = '{$pdob}' AND
Mcu_PreregisterPatientsPatientName = '{$v['NAMA']}' AND
Mcu_PreregisterPatientsDOB = '{$pdob}' AND
Mcu_PreregisterPatientsNIP = '{$v['NIP']}'
) AND
) AND
Mcu_PreregisterPatientsMgm_McuID = '{$prm['xid']}' AND
Mcu_PreregisterPatientsIsActive = 'Y' LIMIT 1";
$qry_pre = $this->db->query($sql_pre);
if(!$qry_pre){
$last_qry = $this->db->last_query();
$this->db->trans_rollback();
$this->sys_error("select mcu_preregister_patients : ".$last_qry);
exit;
}
@@ -354,7 +354,7 @@ class Preregisterv2 extends MY_Controller
if(!$rows){
$last_qry = $this->db->last_query();
$this->db->trans_rollback();
$this->sys_error("insert mcu_preregister_patients : ".$last_qry);
exit;
}
@@ -362,18 +362,18 @@ class Preregisterv2 extends MY_Controller
$last_id_x = $this->db->insert_id();
if ($patient_id == 0) {
$sql = "SELECT *
$sql = "SELECT *
FROM m_patient
WHERE
M_PatientName = '{$v['NAMA']}' AND
M_PatientDOB = '{$pdob}' AND
M_PatientName = '{$v['NAMA']}' AND
M_PatientDOB = '{$pdob}' AND
M_PatientNIP = '{$v['NIP']}' AND
M_PatientIsActive = 'Y' LIMIT 1";
$query = $this->db->query($sql);
if(!$query){
$last_qry = $this->db->last_query();
$this->db->trans_rollback();
$this->sys_error("select m_patient : ".$last_qry);
exit;
}
@@ -384,9 +384,9 @@ class Preregisterv2 extends MY_Controller
//echo $sql;
}
$sql_cor = "SELECT *
$sql_cor = "SELECT *
FROM corporate
WHERE
WHERE
CorporateID = '{$prm['corporateID']}' AND
CorporateIsActive = 'Y' LIMIT 1";
$qry_cor = $this->db->query($sql_cor);
@@ -404,9 +404,9 @@ class Preregisterv2 extends MY_Controller
if ($v['CORPORATE'] == '') {
$corporate_id = $prm['corporateID'];
} else {
$sql_cor = "SELECT *
$sql_cor = "SELECT *
FROM corporate
WHERE
WHERE
CorporateCode = '{$v['CORPORATE']}' AND
CorporateIsActive = 'Y' LIMIT 1";
$query = $this->db->query($sql_cor);
@@ -539,7 +539,7 @@ class Preregisterv2 extends MY_Controller
//echo $this->db->last_query();
}
$sql = "UPDATE mcu_preregister_patients SET Mcu_PreregisterPatientsM_PatientID = {$patient_id}
$sql = "UPDATE mcu_preregister_patients SET Mcu_PreregisterPatientsM_PatientID = {$patient_id}
WHERE Mcu_PreregisterPatientsID = {$last_id_x}";
$query = $this->db->query($sql);
if(!$query){
@@ -559,7 +559,7 @@ class Preregisterv2 extends MY_Controller
} else {
$this->db->trans_commit();
}
@@ -643,8 +643,8 @@ class Preregisterv2 extends MY_Controller
$number_offset = ($prm['current_page'] - 1) * $number_limit;
$sql = " SELECT count(*) as total
FROM mcu_preregister_patients
WHERE
Mcu_PreregisterPatientsMgm_McuID = {$prm['mgm_mcuid']} AND
WHERE
Mcu_PreregisterPatientsMgm_McuID = {$prm['mgm_mcuid']} AND
Mcu_PreregisterPatientsIsActive = 'Y'
$sql_where
";
@@ -668,7 +668,7 @@ class Preregisterv2 extends MY_Controller
FROM mcu_offline_prepare
JOIN m_company ON McuOfflinePrepareM_CompanyID = M_CompanyID
WHERE
McuOfflinePrepareIsDownloaded = 'Y' AND
McuOfflinePrepareIsDownloaded = 'Y' AND
McuOfflinePrepareIsActive = 'Y'";
//echo $sq
$xrow = $this->db_onedev->query($sql)->row_array();*/
@@ -676,7 +676,7 @@ class Preregisterv2 extends MY_Controller
$sql = "SELECT mcu_preregister_patients.*,
DATE_FORMAT(Mcu_PreregisterPatientsDOB, '%d-%m-%Y') as dob
FROM mcu_preregister_patients
WHERE
WHERE
Mcu_PreregisterPatientsMgm_McuID = {$prm['mgm_mcuid']} AND Mcu_PreregisterPatientsIsActive = 'Y'
$sql_where
ORDER BY Mcu_PreregisterPatientsPatientName ASC
@@ -894,8 +894,8 @@ class Preregisterv2 extends MY_Controller
if ($v['PID'] != '') {
$sql = "SELECT *
FROM m_patient
$sql = "SELECT *
FROM m_patient
JOIN m_sex ON M_PatientM_SexID = M_SexID
WHERE M_PatientNoReg = '{$v['PID']}' LIMIT 1";
$exist_r = $this->db_onedev->query($sql)->row_array();
@@ -919,11 +919,11 @@ class Preregisterv2 extends MY_Controller
}
if ($v['KTP'] != '') {
$sql = "SELECT *
FROM m_patient
$sql = "SELECT *
FROM m_patient
JOIN m_sex ON M_PatientM_SexID = M_SexID
WHERE M_PatientM_IdTypeID = 1 AND
M_PatientIDNumber = '{$v['KTP']}' AND
WHERE M_PatientM_IdTypeID = 1 AND
M_PatientIDNumber = '{$v['KTP']}' AND
M_PatientIsActive = 'Y'
LIMIT 1";
$exist_r = $this->db_onedev->query($sql)->row_array();
@@ -1011,19 +1011,19 @@ class Preregisterv2 extends MY_Controller
if ($rows) {
$last_id_x = $this->db_onedev->insert_id();
$sql = "SELECT *
FROM mcu_offline_prepare
$sql = "SELECT *
FROM mcu_offline_prepare
JOIN m_company ON McuOfflinePrepareM_CompanyID = M_CompanyID
WHERE McuOfflinePrepareID = {$prm['xid']}";
$row_header = $this->db_onedev->query($sql)->row_array();
//print_r($row_header);
if ($patient_id == 0) {
$sql = "SELECT *
$sql = "SELECT *
FROM m_patient
WHERE
M_PatientName = '{$v['NAMA']}' AND
M_PatientDOB = '{$pdob}' AND
M_PatientName = '{$v['NAMA']}' AND
M_PatientDOB = '{$pdob}' AND
M_PatientNIP = '{$v['NIK']}' AND
M_PatientIsActive = 'Y' LIMIT 1";
$exist_r = $this->db_onedev->query($sql)->row_array();

File diff suppressed because it is too large Load Diff