405 lines
13 KiB
PHP
405 lines
13 KiB
PHP
<?php
|
|
|
|
class Trx_order extends MY_Controller
|
|
{
|
|
function __construct()
|
|
{
|
|
parent::__construct();
|
|
|
|
$this->load->helper(array('form', 'url'));
|
|
$this->db_onedev = $this->load->database("onedev", true);
|
|
$this->db_oneklinik = $this->load->database("onedev", true);
|
|
}
|
|
|
|
|
|
function get_order() {
|
|
$baseurl = 'https://yankes.itb.ac.id/data-services';
|
|
$url = $baseurl.'/api/pemeriksan_mcu';
|
|
$token = 'eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJpc3MiOiJodHRwczpcL1wveWFua2VzLml0Yi5hYy5pZFwvZGV2LXNlcnZpY2VzXC9hcGlcL2F1dGhcL2xvZ2luIiwiaWF0IjoxNzI3MDg0NTcyLCJleHAiOjE3NTg2MjA1NzIsIm5iZiI6MTcyNzA4NDU3MiwianRpIjoiOWpGc3A0TmFIbnZWQkdrVyIsInN1YiI6NzcsInBydiI6IjIzYmQ1Yzg5NDlmNjAwYWRiMzllNzAxYzQwMDg3MmRiN2E1OTc2ZjcifQ.eduGs9bz64uD8paGYxJ1zxJ0du6lQ9yTFT7BzYTFg4A';
|
|
|
|
$ch = curl_init();
|
|
|
|
curl_setopt($ch, CURLOPT_URL, $url);
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
|
curl_setopt($ch, CURLOPT_HTTPHEADER, array(
|
|
'Authorization: Bearer ' . $token,
|
|
'Content-Type: application/json'
|
|
));
|
|
|
|
// Eksekusi request cURL
|
|
$response = curl_exec($ch);
|
|
|
|
// Debug: Cek error cURL
|
|
if (curl_errno($ch)) {
|
|
echo 'cURL Error: ' . curl_error($ch);
|
|
}
|
|
|
|
curl_close($ch);
|
|
|
|
// Kembalikan hasil response (jika perlu, decode JSON)
|
|
//echo $response;
|
|
|
|
|
|
/*$sql = "INSERT INTO itb_yankes.tmp_response(
|
|
response
|
|
)
|
|
VALUES(?)";
|
|
$qry = $this->db_onedev->query($sql,array($response));
|
|
if(!$qry){
|
|
$this->sys_error_db("save response", $this->db_onedev);
|
|
exit;
|
|
}*/
|
|
$rspn = json_decode($response, true);
|
|
if($rspn['success'] == 1){
|
|
$datas = $rspn['response_1'];
|
|
|
|
if(count($datas) > 0){
|
|
//print_r($datas);
|
|
foreach ($datas as $key => $value) {
|
|
if($value['nik']){
|
|
$sql = "SELECT * FROM itb_yankes.download_order WHERE DownloadOrderNumber = ?";
|
|
$qry = $this->db_onedev->query($sql,array($value['no_order']));
|
|
if(!$qry){
|
|
$this->sys_error_db("select order error", $this->db_onedev);
|
|
exit;
|
|
}
|
|
//echo $this->db_onedev->last_query();
|
|
$exist_dt = $qry->result_array();
|
|
if(count($exist_dt) == 0){
|
|
$sql = "INSERT INTO itb_yankes.download_order (
|
|
DownloadOrderNumber,
|
|
DownloadOrderDate,
|
|
DownloadOrderNIK,
|
|
DownloadOrderName,
|
|
DownloadOrderGender,
|
|
DownloadOrderDOB,
|
|
DownloadOrderJSON,
|
|
DownloadOrderCreated
|
|
) VALUES(?,?,?,?,?,?,?,NOW()) ";
|
|
$qry = $this->db_onedev->query($sql,array(
|
|
$value['no_order'],
|
|
$value['tanggal_pemeriksaan'],
|
|
$value['nik'],
|
|
$value['nama_lengkap'],
|
|
$value['jenis_kelamin'],
|
|
$value['tanggal_lahir'],
|
|
json_encode($rspn)
|
|
));
|
|
if(!$qry){
|
|
$this->sys_error_db("select order error", $this->db_onedev);
|
|
exit;
|
|
}
|
|
//echo $this->db_onedev->last_query();
|
|
$lastID = $this->db_onedev->insert_id();
|
|
}else{
|
|
$lastID = $exist_dt[0]['DownloadOrderID'];
|
|
$sql = "UPDATE itb_yankes.download_order SET
|
|
DownloadOrderNIK = ?,
|
|
DownloadOrderDOB = ?,
|
|
DownloadOrderJSON = ?
|
|
WHERE
|
|
DownloadOrderID = ?
|
|
";
|
|
$qry = $this->db_onedev->query($sql,array(
|
|
$value['nik'],
|
|
$value['tanggal_lahir'],
|
|
json_encode($rspn),
|
|
$lastID));
|
|
if(!$qry){
|
|
$this->sys_error_db("update download_order error", $this->db_onedev);
|
|
exit;
|
|
}
|
|
|
|
}
|
|
|
|
$sql = "SELECT T_OrderHeaderID, M_PatientID,M_PatientIDNumber,DownloadOrderNIK,M_PatientDOB,DownloadOrderDOB
|
|
FROM t_orderheader
|
|
JOIN itb_yankes.sys_config ON T_OrderHeaderM_MouID IN (SysConfigM_MouID)
|
|
JOIN m_patient ON T_OrderHeaderM_PatientID = M_PatientID
|
|
JOIN itb_yankes.download_order
|
|
ON REPLACE(m_patient.M_PatientIDNumber, UNHEX('E2808C'), '') = TRIM(download_order.DownloadOrderNIK)
|
|
AND M_PatientDOB = DownloadOrderDOB
|
|
WHERE DownloadOrderID = ? AND T_OrderHeaderIsActive = 'Y';
|
|
";
|
|
$qry = $this->db_onedev->query($sql,array($lastID));
|
|
if(!$qry){
|
|
$this->sys_error_db("select order error", $this->db_onedev);
|
|
exit;
|
|
}
|
|
|
|
$rows_order_lab = $qry->result_array();
|
|
if(count($rows_order_lab)> 0){
|
|
$data_map = $rows_order_lab[0];
|
|
$sql = "UPDATE m_patient
|
|
SET M_PatientIDNumber = REPLACE(M_PatientIDNumber, UNHEX('E2808C'), '')
|
|
WHERE M_PatientID = ?";
|
|
$qry = $this->db_onedev->query($sql,array($data_map['M_PatientID']));
|
|
if(!$qry){
|
|
$this->sys_error_db("select order error", $this->db_onedev);
|
|
exit;
|
|
}
|
|
|
|
|
|
$this->mapping_order($lastID,$data_map['T_OrderHeaderID'],$value['no_order'],555);
|
|
}
|
|
}
|
|
|
|
|
|
//echo json_encode($rspn);
|
|
|
|
|
|
}
|
|
$result = array(
|
|
|
|
"records" => json_encode($rspn['response_1'])
|
|
);
|
|
$this->sys_ok($result);
|
|
exit;
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
function mapping_order($orderID,$orderLabID,$noOrder,$userID){
|
|
$sql = "INSERT INTO itb_yankes.order_map (
|
|
orderMapDownloadOrderID,
|
|
orderMapT_OrderHeaderID,
|
|
orderMapCreated,
|
|
orderMapCreatedUserID
|
|
) VALUES(?,?,NOW(),?)";
|
|
$qry = $this->db_onedev->query($sql,array($orderID,$orderLabID,$userID));
|
|
if(!$qry){
|
|
$this->sys_error_db("select order error", $this->db_onedev);
|
|
exit;
|
|
}
|
|
|
|
$this->update_status($orderID,'mapped');
|
|
|
|
$sql = "UPDATE t_orderheaderaddon SET T_OrderHeaderAddOnLabNumberOrigin = ?
|
|
WHERE T_OrderHeaderAddOnT_OrderHeaderID = ?";
|
|
$qry = $this->db_onedev->query($sql,array($noOrder,$orderLabID));
|
|
if(!$qry){
|
|
$this->sys_error_db("select order error", $this->db_onedev);
|
|
exit;
|
|
}
|
|
}
|
|
|
|
function update_status($orderID,$status){
|
|
$sql = "UPDATE itb_yankes.download_order SET DownloadOrderStatus = ?
|
|
WHERE DownloadOrderID = ?";
|
|
$qry = $this->db_onedev->query($sql,array($status,$orderID));
|
|
if(!$qry){
|
|
$this->sys_error_db("update order error", $this->db_onedev);
|
|
exit;
|
|
}
|
|
}
|
|
|
|
function send_result_all(){
|
|
$sql="SELECT DownloadOrderID as order_id,
|
|
T_OrderDetailT_OrderHeaderID as order_lab_id,
|
|
DownloadOrderNIK as nik,
|
|
DownloadOrderName as patient_name,
|
|
DownloadOrderNumber as order_number,
|
|
T_OrderDetailT_TestCode as bisone_test_code,
|
|
test_yankes_code as yenkes_test_code,
|
|
test_name as yankes_test,
|
|
T_OrderDetailT_TestName as bisone_test,
|
|
T_OrderDetailResult as result
|
|
FROM t_orderdetail
|
|
JOIN itb_yankes.map_test ON T_OrderDetailT_TestCode = test_bisone_code
|
|
JOIN itb_yankes.order_map ON orderMapT_OrderHeaderID = T_OrderDetailT_OrderHeaderID
|
|
JOIN itb_yankes.download_order ON orderMapDownloadOrderID = DownloadOrderID AND
|
|
DownloadOrderStatus = 'mapped'
|
|
WHERE
|
|
T_OrderDetailT_TestIsResult = 'Y' AND
|
|
T_OrderDetailValidation = 'Y' AND
|
|
T_OrderDetailIsActive = 'Y'
|
|
GROUP BY T_OrderDetailT_OrderHeaderID";
|
|
$qry = $this->db_onedev->query($sql);
|
|
if(!$qry){
|
|
$this->sys_error_db("select order error", $this->db_onedev);
|
|
exit;
|
|
}
|
|
|
|
$data_send = $qry->result_array();
|
|
|
|
}
|
|
|
|
function send_result($orderLabID,$userID){
|
|
$sql="SELECT DownloadOrderID as order_id,
|
|
T_OrderDetailT_OrderHeaderID as order_lab_id,
|
|
DownloadOrderNIK as nik,
|
|
DownloadOrderName as patient_name,
|
|
DownloadOrderNumber as order_number,
|
|
T_OrderDetailT_TestCode as bisone_test_code,
|
|
test_yankes_code as yenkes_test_code,
|
|
test_name as yankes_test,
|
|
T_OrderDetailT_TestName as bisone_test,
|
|
T_OrderDetailResult as result
|
|
FROM t_orderdetail
|
|
JOIN itb_yankes.map_test ON T_OrderDetailT_TestCode = test_bisone_code
|
|
JOIN itb_yankes.order_map ON orderMapT_OrderHeaderID = T_OrderDetailT_OrderHeaderID
|
|
JOIN itb_yankes.download_order ON orderMapDownloadOrderID = DownloadOrderID
|
|
WHERE
|
|
T_OrderDetailT_OrderHeaderID = ? AND
|
|
T_OrderDetailT_TestIsResult = 'Y' AND
|
|
T_OrderDetailValidation = 'Y' AND
|
|
T_OrderDetailIsActive = 'Y'
|
|
GROUP BY T_OrderDetailID
|
|
";
|
|
$qry = $this->db_onedev->query($sql,[$orderLabID]);
|
|
if(!$qry){
|
|
$this->sys_error_db("select order error", $this->db_onedev);
|
|
exit;
|
|
}
|
|
$details = $qry->result_array();
|
|
if(count($details) > 0){
|
|
$orderID = '';
|
|
$no_order = '';
|
|
$results = [];
|
|
foreach ($details as $key => $value) {
|
|
$orderID = $value['order_id'];
|
|
$no_order = $value['order_number'];
|
|
$results[] = ['test_id' => $value['yenkes_test_code'],'result' => $value['result'] ];
|
|
}
|
|
|
|
$json_dt = array(
|
|
array('no_order' => $no_order,'order_test' => $results)
|
|
);
|
|
$this->do_send_results($orderID,$no_order,$json_dt,$userID);
|
|
}
|
|
|
|
}
|
|
|
|
function send_lab_results($json_data, $bearer_token) {
|
|
// Base URL
|
|
$baseUrl = 'https://yankes.itb.ac.id/data-services';// Ganti dengan base URL Anda
|
|
$url = $baseUrl . "/api/update_hasil_lab";
|
|
|
|
// Initialize cURL
|
|
$ch = curl_init($url);
|
|
|
|
// Set cURL options
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
|
curl_setopt($ch, CURLOPT_HTTPHEADER, [
|
|
'Content-Type: application/json',
|
|
'Authorization: Bearer ' . $bearer_token
|
|
]);
|
|
curl_setopt($ch, CURLOPT_POST, true);
|
|
curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($json_data));
|
|
|
|
// Execute cURL request
|
|
$response = curl_exec($ch);
|
|
|
|
// Check for errors
|
|
if (curl_errno($ch)) {
|
|
echo 'cURL Error: ' . curl_error($ch);
|
|
} else {
|
|
// Decode the response if needed
|
|
$response_data = json_decode($response, true);
|
|
return $response_data;
|
|
//echo json_encode($response_data);
|
|
//print_r($response_data);
|
|
}
|
|
|
|
// Close cURL session
|
|
curl_close($ch);
|
|
}
|
|
|
|
function do_send_results($orderID,$no_order,$datas,$userID){
|
|
// Contoh penggunaan fungsi
|
|
/*$json_data = [
|
|
"params" => [
|
|
[
|
|
"no_order" => "B2B-ITB-a2q002687",
|
|
"order_test" => [
|
|
["test_id" => "A001HE", "result" => "15.2"],
|
|
["test_id" => "A002HE", "result" => "44"],
|
|
["test_id" => "A003HE", "result" => "3.9"],
|
|
// ... masukkan seluruh data lainnya sesuai kebutuhan
|
|
]
|
|
]
|
|
]
|
|
];*/
|
|
|
|
$json_data = [
|
|
"params" => $datas
|
|
];
|
|
// Bearer token
|
|
$bearer_token = 'eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJpc3MiOiJodHRwczpcL1wveWFua2VzLml0Yi5hYy5pZFwvZGV2LXNlcnZpY2VzXC9hcGlcL2F1dGhcL2xvZ2luIiwiaWF0IjoxNzI3MDg0NTcyLCJleHAiOjE3NTg2MjA1NzIsIm5iZiI6MTcyNzA4NDU3MiwianRpIjoiOWpGc3A0TmFIbnZWQkdrVyIsInN1YiI6NzcsInBydiI6IjIzYmQ1Yzg5NDlmNjAwYWRiMzllNzAxYzQwMDg3MmRiN2E1OTc2ZjcifQ.eduGs9bz64uD8paGYxJ1zxJ0du6lQ9yTFT7BzYTFg4A';
|
|
// Ganti dengan token yang sesuai
|
|
|
|
// Panggil fungsi untuk mengirim data
|
|
$rspn = $this->send_lab_results($json_data, $bearer_token);
|
|
if($rspn){
|
|
$status = 'success';
|
|
if(!$rspn['success'])
|
|
$status = 'failed';
|
|
|
|
$sql = "INSERT INTO itb_yankes.send_results (
|
|
Send_ResultsOrderNumber,
|
|
SendResultsJsonBefore,
|
|
SendResultsJsonAfter,
|
|
SendResultsStatus,
|
|
SendResultsCreated,
|
|
SendResultsCreatedUserID
|
|
) VALUES(?,?,?,?,NOW(),?)";
|
|
$qry = $this->db_onedev->query($sql,[$no_order,json_encode($json_data),json_encode($rspn),$status,$userID]);
|
|
if(!$qry){
|
|
$this->sys_error_db("insert send result error", $this->db_onedev);
|
|
exit;
|
|
}
|
|
|
|
|
|
$this->update_status($orderID,'send_result');
|
|
|
|
return $rspn;
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
function sendresultorder(){
|
|
if (! $this->isLogin) {
|
|
$this->sys_error("Invalid Token");
|
|
exit;
|
|
}
|
|
$prm = $this->sys_input;
|
|
$xuserid = $this->sys_user['M_UserID'];
|
|
$rspn = $this->send_result($prm['T_OrderHeaderID'],$xuserid);
|
|
$result = array(
|
|
|
|
"records" => $rspn
|
|
);
|
|
$this->sys_ok($result);
|
|
exit;
|
|
}
|
|
|
|
function getlogs(){
|
|
if (! $this->isLogin) {
|
|
$this->sys_error("Invalid Token");
|
|
exit;
|
|
}
|
|
$prm = $this->sys_input;
|
|
$sql="SELECT *
|
|
FROM itb_yankes.send_results
|
|
WHERE
|
|
Send_ResultsOrderNumber = ?";
|
|
$qry = $this->db_onedev->query($sql,$prm['order_number_yankes']);
|
|
if(!$qry){
|
|
$this->sys_error_db("select order error", $this->db_onedev);
|
|
exit;
|
|
}
|
|
|
|
$data_send = $qry->result_array();
|
|
$result = array(
|
|
"records" => $data_send
|
|
);
|
|
$this->sys_ok($result);
|
|
exit;
|
|
|
|
}
|
|
|
|
}
|