Files
BE_IBL/application/controllers/mockup/process/resultvalidation-v21/Rv_patient.php
2026-04-15 15:24:21 +07:00

438 lines
20 KiB
PHP

<?php
class Rv_patient extends MY_Controller
{
var $db_smartone;
public function index()
{
echo "RE Patient API";
}
public function __construct()
{
parent::__construct();
$this->db_smartone = $this->load->database("onedev", true);
}
public function save_note() {
$prm = $this->sys_input;
if ( ! $this->isLogin ) {
echo json_encode(
array("status"=>"ERR", "message"=> "Invalid Token")
);
exit;
}
$userID = $this->sys_user["M_UserID"];
$order_id = $prm["order_id"];
$note = $prm["note"];
$int_note = $prm["int_note"];
$sql ="update t_orderheaderaddon set T_OrderHeaderAddOnValidationNote = ? ,
T_OrderHeaderAddOnValidationNoteM_UserID= ?,
T_OrderHeaderAddOnValidationInternal = ?,
T_OrderHeaderAddOnValidationInternalM_UserID = ?
where T_OrderHeaderAddOnT_OrderHeaderID = ?";
$qry = $this->db_smartone->query($sql,array($note,$userID, $int_note, $userID, $order_id));
if (! $qry) {
print_r($this->db_smartone->error());
}
echo $this->sys_ok( array("status" => "OK"));
}
public function send_to_adm() {
$prm = $this->sys_input;
if ( ! $this->isLogin ) {
echo json_encode(
array("status"=>"ERR", "message"=> "Invalid Token")
);
exit;
}
$userID = $this->sys_user["M_UserID"];
$order_id = $prm["order_id"];
$sql ="update t_orderheaderaddon set T_OrderHeaderAddOnReadyPrint = 'Y' ,
T_OrderHeaderAddOnReadyPrintDate = now()
where T_OrderHeaderAddOnT_OrderHeaderID = ?";
$this->db_smartone->query($sql,array($order_id));
$sql ="select * from t_orderdetail where T_OrderDetailValidation = 'Y'
and T_OrderDetailT_OrderHeaderID = ?";
$qry = $this->db_smartone->query($sql,array($order_id));
$rows = [];
if ($qry) {
$rows = $qry->result_array();
}
$j_data = json_encode($rows);
//insert into log
$sql = "insert into one_log.log_printlab(Log_PrintLabT_OrderHeaderID,
Log_PrintLabCode,
Log_PrintLabDatetime, Log_PrintLabJson, Log_PrintLabUserID)
values(?,'SEND.TO.ADM',now(),?,$userID)";
$this->db_smartone->query($sql,array($order_id,$j_data));
echo $this->sys_ok( array("status" => "OK"));
}
public function search()
{
$prm = $this->sys_input;
$max_rst = 10;
$sdate = $prm["start_date"];
$search = '%' . $prm["search"] . '%';
$page = $prm['page'];
if ($page == null)
$page = 1;
$offset = ($page - 1) * $max_rst;
// OVERRIDE
$max_rst = 9999;
$offset = 0;
$q_company = "";
$company_id = 0;
if (isset($prm["company_id"])) $company_id = $prm["company_id"];
if ($company_id > 0 ) $q_company = " and T_OrderHeaderM_CompanyID = $company_id ";
//janji hasil hari ini T_OrderHeaderID
$sql = "select T_OrderPromiseT_OrderHeaderID
from t_orderpromise
where T_OrderPromiseIsActive = 'Y' and date(T_OrderPromiseDateTime) = ?";
$qry = $this->db_smartone->query($sql, array($sdate));
$promise_ids = "0";
if ($qry) {
$xrows = $qry->result_array();
if ( count($xrows) > 0 ) {
$xids = array();
foreach($xrows as $r) $xids[] = $r["T_OrderPromiseT_OrderHeaderID"];
$promise_ids = join(",",$xids);
}
}
$sql = "select T_OrderHeaderID
from t_orderheader
where T_OrderHeaderIsActive = 'Y' and date(T_OrderHeaderDate) = ?";
$qry = $this->db_smartone->query($sql, array($sdate));
$order_ids = $promise_ids;
if ($qry) {
$xrows = $qry->result_array();
if ( count($xrows) > 0 ) {
$xids = array();
foreach($xrows as $r) $xids[] = $r["T_OrderHeaderID"];
$order_ids .= "," . join(",",$xids);
}
}
$q_search = " and
( M_PatientName LIKE ?
or T_OrderHeaderLabNumber like ?
or T_OrderHeaderAddOnLabNumberOrigin like ?
or T_OrderHeaderLabNumberExt like ?
)";
if ($prm["search"] == "" ) $q_search = "";
switch($prm["status_validasi"]) {
case "BV": // ada yang belum validasi
$q_search .= " and T_OrderHeaderAddOnValidationDone <> 'Y' ";
break;
case "SV": // sudah validasi semua dan ( belum pernah kirim atau order umum )
$q_search .= " and T_OrderHeaderAddOnValidationDone = 'Y' ";
$q_search .= " and ( T_OrderHeaderAddOnReadyPrint = 'N' and T_OrderHeaderAddOnLabNumberOrigin is null ) ";
break;
case "SVS": // sudah validasi semua dan ( pernah kirim atau order dari rujukan )
$q_search .= " and T_OrderHeaderAddOnValidationDone = 'Y' ";
$q_search .= " and ( T_OrderHeaderAddOnReadyPrint <> 'N' or T_OrderHeaderAddOnLabNumberOrigin is not null )";
break;
}
$sql = "SELECT *,
CONCAT('[', GROUP_CONCAT(DISTINCT CONCAT('\"', T_OrderPromiseDateTime, '\"') SEPARATOR ','), ']') order_promise
FROM (
SELECT T_OrderHeaderID, T_OrderHeaderLabNumber, T_OrderHeaderDate,T_OrderHeaderDiagnose,
M_PatientID, M_PatientNoReg, fn_global_patient_name(M_PatientID) M_PatientName,
M_PatientDOB, T_OrderHeaderM_PatientAge, M_PatientHP, M_SexName,
da.M_DoctorID doctor_pj_id, fn_global_doctor_name(da.M_DoctorID) doctor_pj_name,
db.M_DoctorID doctor_sender_id, fn_global_doctor_name(db.M_DoctorID) doctor_sender_name,
M_MouID, M_MouName, M_CompanyID, M_CompanyName,
T_OrderHeaderFoNote, T_OrderHeaderSamplingNote, T_OrderHeaderResultNote,
la.Nat_LangID M_LangID, la.Nat_LangCode M_LangCode, la.Nat_LangName M_LangName, T_OrderHeaderLangIsSI,
lb.Nat_LangID SecondM_LangID, lb.Nat_LangCode SecondM_LangCode, lb.Nat_LangName SecondM_LangName,
T_OrderHeaderAddOnSecondLangIsSI,
T_OrderHeaderIsCito, fn_global_delivery_items(T_OrderHeaderID) as deliveries,
T_OrderPromiseDateTime, fn_process_history(T_OrderHeaderID) is_history,
if(T_OrderHeaderAddOnLabNumberOrigin is not null, T_OrderHeaderAddOnLabNumberOrigin,
T_OrderHeaderLabNumberExt) T_OrderHeaderLabNumberExt,
T_OrderHeaderAddOnVerificationDone,
T_OrderHeaderAddOnValidationDone,
T_OrderHeaderAddOnReadyPrint
from t_orderheader
JOIN t_orderheaderaddon ON T_OrderHeaderAddOnT_OrderHeaderID = T_OrderHeaderID
{$q_company}
JOIN t_orderpromise ON T_OrderPromiseT_OrderHeaderID = T_OrderHeadeRID
JOIN t_orderdetail ON T_OrderHeaderID = T_OrderDetailT_OrderHeaderID
AND T_OrderDetailIsActive= 'Y'
JOIN t_test ON T_OrderDetailT_TestID = T_TestID
JOIN documentation_group_detail ON DocumentationGroupDetailNat_SubGroupID = T_TestNat_SubGroupID
AND DocumentationGroupDetailIsActive = 'Y'
JOIN documentation_group ON DocumentationGroupDetailDocumentationGroupID = DocumentationGroupID
AND DocumentationGroupName = 'lab'
join m_patient on T_OrderHeaderM_PatientID = M_PatientID
left join m_doctor da on T_OrderHeaderPJM_DoctorID = da.M_DoctorID
join m_doctor db on T_OrderHeaderSenderM_DoctorID = db.M_DoctorID
JOIN m_company on T_OrderHeaderM_CompanyID = M_CompanyID
JOIN m_mou on T_OrderHeaderM_MouID = M_MouID
JOIN m_sex on M_PatientM_SexID = M_SexID
JOIN nat_lang la ON T_OrderHeaderM_LangID = la.Nat_LangID
LEFT JOIN nat_lang lb ON T_OrderHeaderAddOnSecondM_LangID = lb.Nat_LangID
where T_OrderHeaderIsActive = 'Y'
and T_OrderHeaderID in ( $order_ids )
$q_search
AND T_OrderHeaderAddOnFOVerification = 'Y'
order by FIELD(T_OrderHeaderIsCito, 'Y', 'N') ASC, T_OrderPromiseDateTime
) x
GROUP BY T_OrderHeaderID
order by FIELD(T_OrderHeaderIsCito, 'Y', 'N') ASC, T_OrderPromiseDateTime
limit {$offset}, {$max_rst}";
if ($q_search == "" ) {
$query = $this->db_smartone->query($sql);
} else {
$query = $this->db_smartone->query($sql, [ $search, $search, $search,$search]);
}
if ($query) {
$rows = $query->result_array();
$xrows = array();
foreach ($rows as $k => $v) {
if ($prm["search"] != "" ) {
$x_search = strtoupper($prm["search"]);
$x_name = strtoupper($v["M_PatientName"]);
$x_noreg = $v["T_OrderHeaderLabNumber"];
$x_noreg2 = $v["T_OrderHeaderLabNumberExt"];
$xpos1 = strpos($x_name,$x_search);
$xpos2 = strpos($x_noreg,$x_search);
$xpos3 = strpos($x_noreg2,$x_search);
if ( $xpos1 === false && $xpos2 === false && $xpos3 === false ) {
unset($rows[$k]);
continue;
}
}
$rows[$k]['data'] = json_decode($v['data']);
$rows[$k]['delivery'] = [];
$r = $this->db_smartone->query("CALL sp_fo_payment_get_delivery('{$v['T_OrderHeaderID']}')");
$this->clean_mysqli_connection($this->db_smartone->conn_id);
if ($r) {
$d = $r->row();
$rows[$k]['delivery'] = json_decode($d->delivery);
}
$rows[$k]['deliveries'] = JSON_DECODE($v['deliveries']);
$rows[$k]['order_promise'] = JSON_DECODE($v['order_promise']);
foreach($rows[$k]['order_promise'] as $l => $w)
$rows[$k]['order_promise'][$l] = date('d-m-Y H:i', strtotime($w));
$xrows[] = $rows[$k];
}
$result = array("total" => $tot_count, "total_page" => ceil($tot_count/$max_rst), "cur_page" => $page, "records" => $xrows, "total_display" => sizeof($xrows), "q" => $this->db_smartone->last_query());
$this->sys_ok($result);
}
else {
$this->sys_error_db("worklist rows", $this->db_smartone);
exit;
}
}
public function old_v2search()
{
$prm = $this->sys_input;
$max_rst = 10;
$sdate = $prm["start_date"] . '%';
$search = '%' . $prm["search"] . '%';
$page = $prm['page'];
if ($page == null)
$page = 1;
$offset = ($page - 1) * $max_rst;
// OVERRIDE
$max_rst = 9999;
$offset = 0;
$q_company = "";
$company_id = 0;
if (isset($prm["company_id"])) $company_id = $prm["company_id"];
if ($company_id > 0 ) $q_company = " and T_OrderHeaderM_CompanyID = $company_id ";
// janji hasil hari ini
$sql = "select T_OrderPromiseT_OrderHeaderID
from t_orderpromise
where T_OrderPromiseIsActive = 'Y' and date(T_OrderPromiseDateTime) = ?";
$qry = $this->db_smartone->query($sql, array($sdate));
$promise_ids = "0";
if ($qry) {
$xrows = $qry->result_array();
if ( count($xrows) > 0 ) {
$xids = array();
foreach($xrows as $r) $xids[] = $r["T_OrderPromiseT_OrderHeaderID"];
$promise_ids = join(",",$xids);
}
}
//move patient to outer
$q_search = "and
(
T_OrderHeaderLabNumber like ?
or T_OrderHeaderAddOnLabNumberOrigin like ?
or T_OrderHeaderLabNumberExt like ?
)";
if ($prm["search"] == "" ) $q_search = "";
//get t_orderheaderID
$sql = "SELECT T_OrderHeaderID
from t_orderheader
join t_orderheaderaddon on T_OrderHeaderID = T_OrderHeaderAddOnID
where date(T_OrderHeaderDate) = ?
$q_search ";
if ($q_search == "" ) {
$qry = $this->db_smartone->query($sql, array($sdate));
} else {
$qry = $this->db_smartone->query($sql, array($sdate,$search, $search, $search));
}
echo $this->db_smartone->last_query();
$rows = $qry->result_array();
foreach($rows as $r) {
$promise_ids .= ", " . $r["T_OrderHeaderID"];
}
echo $promise_ids;
exit;
$sql = "SELECT *,
CONCAT('[', GROUP_CONCAT(DISTINCT CONCAT('\"', T_OrderPromiseDateTime, '\"') SEPARATOR ','), ']') order_promise FROM (
SELECT T_OrderHeaderID, T_OrderHeaderLabNumber, T_OrderHeaderDate,
M_PatientID, M_PatientNoReg, fn_global_patient_name(M_PatientID) M_PatientName,
M_PatientDOB, T_OrderHeaderM_PatientAge, M_PatientHP, M_SexName,
da.M_DoctorID doctor_pj_id, fn_global_doctor_name(da.M_DoctorID) doctor_pj_name,
db.M_DoctorID doctor_sender_id, fn_global_doctor_name(db.M_DoctorID) doctor_sender_name,
M_MouID, M_MouName, M_CompanyID, M_CompanyName,
T_OrderHeaderFoNote, T_OrderHeaderSamplingNote, T_OrderHeaderResultNote,
la.Nat_LangID M_LangID, la.Nat_LangCode M_LangCode, la.Nat_LangName M_LangName, T_OrderHeaderLangIsSI,
lb.Nat_LangID SecondM_LangID, lb.Nat_LangCode SecondM_LangCode, lb.Nat_LangName SecondM_LangName,
T_OrderHeaderAddOnSecondLangIsSI,
T_OrderHeaderIsCito, fn_global_delivery_items(T_OrderHeaderID) as deliveries,
T_OrderPromiseDateTime, fn_process_history(T_OrderHeaderID) is_history,
if(T_OrderHeaderAddOnLabNumberOrigin is not null, T_OrderHeaderAddOnLabNumberOrigin,
T_OrderHeaderLabNumberExt) T_OrderHeaderLabNumberExt,
T_OrderHeaderAddOnVerificationDone,
T_OrderHeaderAddOnValidationDone,
T_OrderHeaderAddOnReadyPrint
from t_orderheader
JOIN t_orderheaderaddon ON T_OrderHeaderAddOnT_OrderHeaderID = T_OrderHeaderID
{$q_company}
JOIN t_orderpromise ON T_OrderPromiseT_OrderHeaderID = T_OrderHeaderID
JOIN t_orderdetail ON T_OrderHeaderID = T_OrderDetailT_OrderHeaderID
AND T_OrderDetailIsActive= 'Y'
JOIN t_test ON T_OrderDetailT_TestID = T_TestID
JOIN documentation_group_detail ON DocumentationGroupDetailNat_SubGroupID = T_TestNat_SubGroupID
AND DocumentationGroupDetailIsActive = 'Y'
JOIN documentation_group ON DocumentationGroupDetailDocumentationGroupID = DocumentationGroupID
AND DocumentationGroupName = 'lab'
join m_patient on T_OrderHeaderM_PatientID = M_PatientID
left join m_doctor da on T_OrderHeaderPJM_DoctorID = da.M_DoctorID
join m_doctor db on T_OrderHeaderSenderM_DoctorID = db.M_DoctorID
JOIN m_company on T_OrderHeaderM_CompanyID = M_CompanyID
JOIN m_mou on T_OrderHeaderM_MouID = M_MouID
JOIN m_sex on M_PatientM_SexID = M_SexID
JOIN nat_lang la ON T_OrderHeaderM_LangID = la.Nat_LangID
LEFT JOIN nat_lang lb ON T_OrderHeaderAddOnSecondM_LangID = lb.Nat_LangID
where T_OrderHeaderIsActive = 'Y'
and (T_OrderHeaderDate LIKE ? OR T_OrderHeaderID in ( $promise_ids ) )
$q_search
AND T_OrderHeaderAddOnFOVerification = 'Y'
order by FIELD(T_OrderHeaderIsCito, 'Y', 'N') ASC, T_OrderPromiseDateTime
) x
GROUP BY T_OrderHeaderID
order by FIELD(T_OrderHeaderIsCito, 'Y', 'N') ASC, T_OrderPromiseDateTime
limit {$offset}, {$max_rst}";
if ($q_search == "") {
$query = $this->db_smartone->query($sql, [$sdate ]);
} else {
$query = $this->db_smartone->query($sql, [$sdate, $search, $search,$search]);
}
if ($query) {
$rows = $query->result_array();
foreach ($rows as $k => $v) {
if ($search != "" ) {
if ( strpos($search,$v["M_PatientName"]) === false ) {
unset($rows[$k]);
continue;
}
}
$rows[$k]['data'] = json_decode($v['data']);
$rows[$k]['delivery'] = [];
$r = $this->db_smartone->query("CALL sp_fo_payment_get_delivery('{$v['T_OrderHeaderID']}')");
$this->clean_mysqli_connection($this->db_smartone->conn_id);
if ($r) {
$d = $r->row();
$rows[$k]['delivery'] = json_decode($d->delivery);
}
$rows[$k]['deliveries'] = JSON_DECODE($v['deliveries']);
$rows[$k]['order_promise'] = JSON_DECODE($v['order_promise']);
foreach($rows[$k]['order_promise'] as $l => $w)
$rows[$k]['order_promise'][$l] = date('d-m-Y H:i', strtotime($w));
}
$result = array("total" => $tot_count, "total_page" => ceil($tot_count/$max_rst), "cur_page" => $page, "records" => $rows, "total_display" => sizeof($rows), "q" => $this->db_smartone->last_query());
$this->sys_ok($result);
}
else {
$this->sys_error_db("worklist rows", $this->db_smartone);
exit;
}
}
public function info_req()
{
$prm = $this->sys_input;
$sql = "CALL sp_process_result_reqs(?)";
$query = $this->db_smartone->query($sql, [$prm['order_id']]);
if ($query)
{
$row = $query->row();
$this->clean_mysqli_connection($this->db_smartone->conn_id);
$sql = "select
T_OrderHeaderAddOnValidationNote,T_OrderHeaderAddOnValidationInternal,
fn_get_staff(T_OrderHeaderFoNoteM_UserID) FoUser,
fn_get_staff(T_OrderHeaderVerificationNoteM_UserID) ScreeningUser,
fn_get_staff(T_OrderHeaderSamplingNoteM_UserID) SamplingUser,
fn_get_staff(T_OrderHeaderResultNoteM_UserID) ResultUser
from t_orderheaderaddon
join t_orderheader on T_OrderHeaderAddOnT_OrderHeaderID = T_OrderHeaderID
where T_OrderHeaderAddOnT_OrderHeaderID = ?";
$qry = $this->db_smartone->query($sql, array($prm["order_id"]));
$validationNote = "";
$validationInternal = "";
$foUser = "";
$screeningUser = "";
$samplingUser = "";
$resultUser = "";
if ($qry) {
$rows = $qry->result_array();
if (count($rows) > 0) {
$validationNote = $rows[0]["T_OrderHeaderAddOnValidationNote"];
$validationInternal= $rows[0]["T_OrderHeaderAddOnValidationInternal"];
$foUser= $rows[0]["FoUser"];
$screeningUser= $rows[0]["ScreeningUser"];
$samplingUser= $rows[0]["SamplingUser"];
$resultUser= $rows[0]["ResultUser"];
}
} else {
print_r($this->db->error());
}
$s_data = $row->data;
$s_data = str_replace("\n"," ",$s_data);
$rst = json_decode($s_data,true);
$rst["validation_note"] = $validationNote;
$rst["validation_internal"] = $validationInternal;
$rst["foUser"] = $foUser;
$rst["screeningUser"] = $screeningUser;
$rst["samplingUser"] = $samplingUser;
$rst["resultUser"] = $resultUser;
$this->sys_ok($rst);
exit;
}
$this->sys_error_db("RESULT REQ", $this->db_smartone);
}
}