fajri/BE_IBL
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Files
34d90c95b6a2addadfc11da1e95668ba72d2c096
BE_IBL/application/controllers/mockup/samplinglab-v15/Samplingcall.php
sas.fajri 34d90c95b6 FHM31052601IBL - sampling & klinik controllers: decrypt PII pasien untuk pengambilan sampel 
- samplinglab-v15, samplingradiodiagnostic-v5, samplingelectromedis-v5,
  doctorclinicv2: search via bidx, nolab search tanpa nama, decrypt di hasil
- sampling-lab-mobile-cpone-v10: decrypt nama/HP/email/DOB/NIP
- klinik/Registrationv3: search bidx (nama/HP/DOB/NIK), hapus address search, decrypt

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
2026-05-31 17:04:20 +07:00

1216 lines
47 KiB
PHP
Raw Blame History

<?php
class Samplingcall extends MY_Controller
{
var $db_onedev;
public function index()
{
echo "Samplingcall API";
}
public function __construct()
{
parent::__construct();
$this->db_onedev = $this->load->database("onedev", true);
$this->load->library('ibl_encryptor');
// $this->IP_SOCKET_IO = "devone.aplikasi.web.id";
$this->IP_SOCKET_IO = "localhost";
}
function getsampletypes()
{
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
$prm = $this->sys_input;
$orderid = $prm['orderid'];
$stationid = $prm['stationid'];
$statusid = $prm['statusid'];
$sql = "SELECT T_OrderHeaderLabNumber,
T_TestID,
IFNULL(local_sample_id,nas_sample_id) as xsample_id,
IFNULL(local_sample_code,nas_sample_code) as xsample_code
FROM (
SELECT T_OrderHeaderLabNumber, T_TestID,
a.T_SampleTypeID as nas_sample_id,
a.T_SampleTypeSuffix as nas_sample_code,
b.T_SampleTypeID as local_sample_id,
b.T_SampleTypeSuffix as local_sample_code
from t_orderheader
JOIN t_orderdetail ON t_orderheaderid = t_orderdetailt_orderheaderid AND t_orderdetailIsActive = 'Y'
JOIN t_test ON t_orderdetailt_testid = t_testid AND T_TestIsResult = 'Y'
JOIN t_sampletype a ON T_TestT_SampleTypeID = a.T_SampleTypeID
LEFT JOIN t_specimenlocal ON T_SpecimenLocalNat_TestID = T_TestNat_TestID AND T_SpecimenLocalIsActive = 'Y'
LEFT JOIN t_sampletype b ON T_SpecimenLocalT_SampleTypeID = b.T_SampleTypeID
where T_OrderHeaderID = {$orderid}
group by a.T_SampleTypeID, b.T_SampleTypeID ) x
GROUP BY xsample_id";
$data_samples = $this->db_onedev->query($sql)->result_array();
if ($data_samples) {
$all_done = "Y";
foreach ($data_samples as $sk => $sv) {
$sql = "SELECT COUNT(*) as xcount
FROM t_ordersample
WHERE
T_OrderSampleT_OrderHeaderID = '{$orderid}' AND
T_OrderSampleT_SampleStationID = {$stationid} AND
T_OrderSampleIsActive = 'Y' AND
T_OrderSampleReceive <> 'Y' AND
T_OrderSampleT_SampleTypeID = {$sv['xsample_id']}";
//echo $sql;
$xxdata_ordersample = $this->db_onedev->query($sql)->row();
if ($xxdata_ordersample->xcount > 0)
$all_done = "N";
}
if ($all_done == 'N') {
$sql = "UPDATE t_sampling_queue_last_status
SET
T_SamplingQueueLastStatusT_SamplingQueueStatusID = 2
WHERE
T_SamplingQueueLastStatusT_OrderHeaderID = '{$orderid}' AND
T_SamplingQueueLastStatusT_SampleStationID = {$stationid} AND
T_SamplingQueueLastStatusT_SamplingQueueStatusID = 5";
//echo $sql;
$this->db_onedev->query($sql);
}
}
$rows = array();
$sql = "SELECT T_OrderDetailID, T_OrderHeaderID,T_OrderDetailID as id,
T_BarcodeLabID,
T_BarcodeLabBarcode,
T_OrderDetailT_TestCode,
T_OrderDetailT_TestName,
T_SampleTypeID,
T_SampleTypeName,
T_BahanName,
IFNULL(T_OrderSampleID,0) as T_OrderSampleID,
T_OrderSampleSampling,
T_OrderSampleReceive,
IF(ISNULL(T_OrderSampleID) OR T_OrderSampleSampling = 'N','N',IF(T_OrderSampleSampling = 'Y' AND T_OrderSampleReceive = 'N','P','D')) as status,
IF(ISNULL(T_OrderSampleSamplingDate),'00-00-0000',DATE_FORMAT(T_OrderSampleSamplingDate,'%d-%m-%Y')) as process_date,
IF(ISNULL(T_OrderSampleSamplingTime),'00:00',DATE_FORMAT(T_OrderSampleSamplingTime,'%H:%i')) as process_time,
IF(ISNULL(T_OrderSampleReceiveDate),'00-00-0000',DATE_FORMAT(T_OrderSampleReceiveDate,'%d-%m-%Y')) as done_date,
IF(ISNULL(T_OrderSampleReceiveTime),'00:00',DATE_FORMAT(T_OrderSampleReceiveTime,'%H:%i')) as done_time,
IF(ISNULL(T_OrderSampleReqID),'X',T_OrderSampleReqStatus) as requirement_status,
'' as requirements
FROM t_orderheader
JOIN t_orderdetail ON T_OrderDetailT_OrderHeaderID = T_OrderHeaderID AND T_OrderDetailIsActive = 'Y'
JOIN t_test ON T_OrderDetailT_TestID = T_TestID
JOIN t_ordersample ON
T_OrderSampleT_OrderHeaderID = T_OrderHeaderID AND
T_OrderSampleIsActive = 'Y'
JOIN t_barcodelab ON T_OrderSampleT_BarcodeLabID = T_BarcodeLabID AND T_BarcodeLabIsActive = 'Y'
JOIN t_sampletype ON T_SampleTypeID = T_OrderSampleT_SampleTypeID
JOIN t_bahan ON T_SampleTypeT_BahanID = T_BahanID
JOIN t_samplestation ON T_BahanT_SampleStationID = T_SampleStationID AND T_SampleStationID = {$stationid}
LEFT JOIN t_ordersamplereq ON T_OrderSampleReqT_OrderHeaderID = T_OrderHeaderID AND
T_OrderSampleReqT_OrderSampleID = T_OrderSampleID AND
T_OrderSampleReqNat_PositionID = 2 AND
T_OrderSampleReqT_SampleStationID = T_SampleStationID AND
T_OrderSampleReqIsActive = 'Y'
WHERE
T_OrderHeaderID = {$orderid} AND T_OrderHeaderIsActive = 'Y'
GROUP BY T_BarcodeLabID
ORDER BY T_SampleTypeName";
//echo $sql;
$rows['sampletypes'] = $this->db_onedev->query($sql)->result_array();
if ($rows) {
foreach ($rows['sampletypes'] as $k => $v) {
$zxprm = array();
$zxprm['status'] = $v['status'];
$zxprm['orderdetailid'] = $v['T_OrderDetailID'];
$zxprm['orderid'] = $v['T_OrderHeaderID'];
$zxprm['sampletypeid'] = $v['T_SampleTypeID'];
$rows['sampletypes'][$k]['requirements'] = $this->getrequirements($zxprm);
}
}
$sql = "SELECT T_BahanID as id, T_BahanName,
IF(T_TestIsNonLab = '',fn_sampling_receive_status_by_bahan_lab({$orderid},T_SampleTypeID),fn_sampling_receive_status_by_bahan_so({$orderid},T_TestID)) as status_bahan
FROM t_orderdetail
JOIN t_test ON T_OrderDetailT_TestID = T_TestID
JOIN t_sampletype ON T_TestT_SampleTypeID = T_SampleTypeID
JOIN t_bahan ON T_SampleTypeT_BahanID = T_BahanID
WHERE
T_OrderDetailT_OrderHeaderID = {$orderid}
GROUP BY T_BahanID";
//echo $sql;
$rows['information_bahan'] = $this->db_onedev->query($sql)->result_array();
$result = array("total" => count($rows), "records" => $rows, "sql" => $this->db_onedev->last_query());
$this->sys_ok($result);
exit;
}
public function search()
{
$prm = $this->sys_input;
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
$name = $prm["name"];
$nolab = $prm["nolab"];
$stationid = $prm["stationid"];
$xdate = $prm["xdate"];
$statusid = 'NEW';
$companyid = isset($prm["companyid"]) ? $prm["companyid"] : 0;
$search = isset($prm["searchx"]) ? $prm["searchx"] : '';
$locationID = $prm['locationid'];
$filter_companyid = '';
if ($companyid != 0 || $companyid != '0') {
$filter_companyid = " AND M_CompanyID = {$companyid} ";
}
$where_status = '';
$limit = '';
$not_receive = '';
if ($statusid === 'NEW') {
$where_status = "AND T_OrderSampleReceive = 'N'";
} else {
$limit = 'limit 0,20';
$where_status = "AND T_SamplingQueueLastStatusT_SamplingQueueStatusID = 5";
}
// echo $norm;
//$where_status = " AND {$where_status}";
$sql_where_cito = "WHERE T_OrderHeaderIsCito = 'Y' AND T_OrderHeaderIsActive = 'Y' AND ( DATE(T_OrderHeaderAddonIsComingDate) = '{$xdate}' OR DATE(T_OrderHeaderDate) = '{$xdate}' ) {$where_status}";
$sql_where = "WHERE T_OrderHeaderIsActive = 'Y' AND ( DATE(T_OrderHeaderAddonIsComingDate) = '{$xdate}' OR DATE(T_OrderHeaderDate) = '{$xdate}' ) {$where_status}";
//$sql_param = array();
if ($name != "" && mb_strlen(trim($name)) >= 3) {
$toks = $this->ibl_encryptor->query_tokens($name);
foreach ($toks as $tok) {
$tok_esc = $this->db_onedev->escape_str($tok);
$sql_where .= " AND JSON_CONTAINS(M_PatientName_bidx, '\"$tok_esc\"')";
}
}
$filter_search = '';
if ($nolab != "") {
// Hanya cari by nomor lab — nama pasien sudah dimasking
$filter_search = "WHERE ( T_OrderHeaderLabNumber like '%$nolab%' OR T_OrderHeaderLabNumberExt like '%$nolab%' )";
}
if ($search != '') {
$sql_where = "WHERE T_OrderHeaderIsActive = 'Y' AND T_OrderHeaderLabNumber = '{$search}'";
}
$rst = array();
$sql = "SELECT * FROM (
SELECT t_orderheader.*,
IFNULL(M_PatientPhotoThumb,'') as M_PatientPhotoThumb,
M_SexName as M_SexName,
M_TitleName as M_TitleName,
M_PatientName_enc, M_PatientDOB_enc, M_TitleName,
M_CompanyName,
fn_sampling_queue_status_name(T_OrderHeaderID,T_SampleStationID) as status,
M_PatientDOB as patient_dob_raw,
fn_sampling_queue_status_id(T_OrderHeaderID,T_SampleStationID) as statusid, T_SampleStationID, T_SampleTypeID,
T_SampleStationID as stationid,
fn_fo_get_laststatus(T_OrderHeaderID) as last_status_fo,
T_OrderHeaderAddonIsComing as coming,
T_OrderHeaderIsCito as iscito,
IFNULL(T_OrderHeaderFoNote,'') as fo_note,
IFNULL(T_OrderHeaderVerificationNote,'') as fo_ver_note,
fn_sampling_reqs(T_OrderHeaderID) as fo_requirements,
'' as htmlforeqs,
fn_sampling_reqs_status(T_OrderHeaderID) as fo_requirements_status,
IF(fn_fo_get_verification_status(T_OrderHeaderID) = 0, 'X','Y') as fo_verification_status,
IFNULL(T_OrderHeaderSamplingNote,'') as sampling_note,
fn_cek_status_sample_receive_not_yet(T_OrderHeaderID) as not_yet_receive,
T_OrderLocationID as order_location_id,
IF(ISNULL(AntrianSampleStationTime),IFNULL(T_OrderHeaderAddonIsComingDate,T_OrderHeaderDate),AntrianSampleStationTime) as antri_time,
IF(ISNULL(AntrianSampleStationTime),IFNULL(T_OrderHeaderAddonIsComingDate,T_OrderHeaderDate),AntrianSampleStationTime) as skip_time
FROM t_orderheader
JOIN t_orderheaderaddon ON T_OrderHeaderAddOnT_OrderHeaderID = T_OrderHeaderID
JOIN m_company ON T_OrderHeaderM_CompanyID = M_CompanyID $filter_companyid
JOIN m_patient ON T_OrderHeaderM_PatientID = M_PatientID
JOIN m_title ON M_PatientM_TitleID = M_TitleID
JOIN m_sex ON M_PatientM_SexID = M_SexID
JOIN t_order_location ON T_OrderLocationT_OrderHeaderID = T_OrderHeaderID AND T_OrderLocationT_SampleStationID = {$stationid} AND T_OrderLocationIsActive = 'Y'
LEFT JOIN antrian_samplestation ON AntrianSampleStationT_OrderLocationID =T_OrderLocationID AND AntrianSampleStationIsActive = 'Y'
JOIN m_location ON T_OrderLocationM_LocationID = M_LocationID AND M_LocationID = {$locationID}
JOIN last_status ON Last_StatusT_OrderHeaderID = T_OrderHeaderID AND ( Last_StatusM_StatusID > 3 OR Last_StatusM_StatusID NOT IN (4,6) )
JOIN t_ordersample ON
T_OrderSampleT_OrderHeaderID = T_OrderHeaderID AND
T_OrderSampleIsActive = 'Y'
JOIN t_barcodelab ON T_OrderSampleT_BarcodeLabID = T_BarcodeLabID AND T_BarcodeLabIsActive = 'Y'
JOIN t_sampletype ON T_SampleTypeID = T_OrderSampleT_SampleTypeID
JOIN t_bahan ON T_SampleTypeT_BahanID = T_BahanID
JOIN t_samplestation ON T_BahanT_SampleStationID = T_SampleStationID AND T_SampleStationID = {$stationid} AND T_SampleStationIsNonLab = ''
$sql_where
GROUP BY T_OrderHeaderID
)x
$filter_search
ORDER BY T_OrderHeaderIsCito DESC, antri_time ASC
";
//echo $sql;
$query = $this->db_onedev->query($sql);
//echo $this->db_onedev->last_query();
$rows = $query->result_array();
if ($rows) {
$enc = $this->ibl_encryptor;
$count_arr = count($rows);
foreach ($rows as $key => $value) {
$name = $enc->decrypt($value['M_PatientName_enc']) ?? '';
$rows[$key]['M_PatientName'] = $name;
$rows[$key]['patient_fullname'] = trim(($value['M_TitleName'] ? $value['M_TitleName'] . ' ' : '') . $name);
$rows[$key]['patient_dob'] = $enc->decrypt($value['M_PatientDOB_enc']) ?? date('d-m-Y', strtotime($value['patient_dob_raw']));
unset($rows[$key]['M_PatientName_enc'], $rows[$key]['M_PatientDOB_enc'], $rows[$key]['patient_dob_raw']);
if ($key + 1 != $count_arr) {
$rows[$key]['skip_time'] = $rows[$key + 1]['antri_time'];
}
}
}
$result = array("total" => count($rst), "records" => $rows, "sql" => $this->db_onedev->last_query());
$this->sys_ok($result);
exit;
}
function searchcompany()
{
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
$prm = $this->sys_input;
$max_rst = 12;
$tot_count = 0;
$q = [
'search' => '%'
];
if ($prm['search'] != '') {
$q['search'] = "%{$prm['search']}%";
}
// QUERY TOTAL
$sql = "SELECT count(*) as total
FROM m_company
WHERE
M_CompanyName like ?
AND M_CompanyIsActive = 'Y'";
$query = $this->db_onedev->query($sql, $q['search']);
//echo $query;
if ($query) {
$tot_count = $query->result_array()[0]["total"];
} else {
$this->sys_error_db("m_city count", $this->db_onedev);
exit;
}
$rows = array('id' => 0, 'name' => 'Semua');
$sql = "
SELECT M_CompanyID as id, M_CompanyName as name
FROM m_company
WHERE
M_CompanyName like ?
AND M_CompanyIsActive = 'Y'
ORDER BY M_CompanyName DESC
";
$query = $this->db_onedev->query($sql, array($q['search']));
if ($query) {
$rows = $query->result_array();
array_push($rows, array('id' => 0, 'name' => 'Semua'));
//echo $this->db_onedev->last_query();
$result = array("total" => $tot_count, "records" => $rows, "total_display" => sizeof($rows));
$this->sys_ok($result);
} else {
$this->sys_error_db("m_company rows", $this->db_onedev);
exit;
}
}
function getstationstatus()
{
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
$rows = [];
$query = " SELECT T_SampleStationID as id, T_SampleStationName as name
FROM t_samplestation
WHERE
T_SampleStationIsActive = 'Y' AND T_SampleStationIsNonLab = ''
";
//echo $query;
$rows['stations'] = $this->db_onedev->query($query)->result_array();
$rows['statuses'] = array(array('id' => 'NEW', 'name' => 'New'), array('id' => 'DONE', 'name' => 'Done'));
$result = array(
"total" => count($rows),
"records" => $rows,
);
$this->sys_ok($result);
exit;
}
function search_staff()
{
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
$prm = $this->sys_input;
$rows = [];
$query = " SELECT M_StaffID as id, M_StaffName as name, M_StaffCode as code, M_UserID as userid
FROM m_staff
JOIN m_user ON M_UserM_StaffID = M_StaffID AND M_UserIsActive = 'Y'
WHERE
M_StaffIsActive = 'Y' AND M_StaffCode = '{$prm['search']}' LIMIT 1
";
//echo $query;
$rows = $this->db_onedev->query($query)->row_array();
$result = array(
"total" => count($rows),
"records" => $rows,
);
$this->sys_ok($result);
exit;
}
function search_patient()
{
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
$prm = $this->sys_input;
$search = '%' . $prm["search"] . '%';
$stationid = $prm["stationid"];
$statusid = $prm["statusid"];
$patients = $prm["patients"];
$where_status = '';
if ($statusid === 'NEW') {
$where_status = "AND (ISNULL(T_SamplingQueueLastStatusID) OR T_SamplingQueueLastStatusT_SamplingQueueStatusID <> 5 )";
} else {
$where_status = "AND T_SamplingQueueLastStatusT_SamplingQueueStatusID = 5";
}
// echo $norm;
//$where_status = " AND {$where_status}";
$sql_where = "WHERE T_OrderHeaderLabNumber LIKE '{$search}' AND T_OrderHeaderIsActive = 'Y' {$where_status}";
$rows = [];
$query = "SELECT t_orderheader.*, IFNULL(M_PatientPhoto,'') as M_PatientPhotoThumb,
M_SexName, M_TitleName, M_PatientName_enc, M_PatientDOB_enc, M_PatientDOB as patient_dob_raw, M_CompanyName,
IF(ISNULL(T_SamplingQueueLastStatusID), 'New',T_SamplingQueueStatusName) as status,
IF(ISNULL(T_SamplingQueueLastStatusID), 0,T_SamplingQueueLastStatusT_SamplingQueueStatusID) as statusid, T_SampleStationID, T_SampleTypeID,
{$stationid} as stationid,
fn_global_check_is_cito(T_OrderHeaderID) as iscito
FROM t_orderheader
JOIN m_company ON T_OrderHeaderM_CompanyID = M_CompanyID
JOIN m_patient ON T_OrderHeaderM_PatientID = M_PatientID
JOIN m_title ON M_PatientM_TitleID = M_TitleID
JOIN m_sex ON M_PatientM_SexID = M_SexID
JOIN t_orderdetail ON T_OrderDetailT_OrderHeaderID = T_OrderHeaderID
JOIN t_test ON T_OrderDetailT_TestID = T_TestID
JOIN t_ordersample ON
T_OrderSampleT_OrderHeaderID = T_OrderHeaderID AND
T_OrderSampleIsActive = 'Y'
JOIN t_barcodelab ON T_OrderSampleT_BarcodeLabID = T_BarcodeLabID AND T_BarcodeLabIsActive = 'Y'
JOIN t_sampletype ON T_SampleTypeID = T_OrderSampleT_SampleTypeID
JOIN t_bahan ON T_SampleTypeT_BahanID = T_BahanID
JOIN t_samplestation ON T_BahanT_SampleStationID = T_SampleStationID AND T_SampleStationID = {$stationid} AND T_SampleStationIsNonLab = ''
JOIN last_status ON Last_StatusT_OrderHeaderID = T_OrderHeaderID AND ( Last_StatusM_StatusID > 3 OR Last_StatusM_StatusID NOT IN (4,6) )
LEFT JOIN t_sampling_queue_last_status ON
T_SamplingQueueLastStatusT_SampleStationID = T_SampleStationID AND
T_SamplingQueueLastStatusT_OrderHeaderID = T_OrderHeaderID
LEFT JOIN t_sampling_queue_status ON T_SamplingQueueLastStatusT_SamplingQueueStatusID = T_SamplingQueueStatusID
LEFT JOIN t_ordersamplereq ON T_OrderSampleReqT_SampleStationID = T_SampleStationID AND T_OrderSampleReqT_OrderSampleID
$sql_where
GROUP BY T_OrderHeaderID
ORDER BY T_OrderHeaderID DESC
limit 1";
//echo $query;
$row = $this->db_onedev->query($query)->row_array();
if ($row) {
$enc = $this->ibl_encryptor;
$name = $enc->decrypt($row['M_PatientName_enc']) ?? '';
$row['M_PatientName'] = $name;
$row['patient_fullname'] = trim(($row['M_TitleName'] ? $row['M_TitleName'] . ' ' : '') . $name);
$row['patient_dob'] = $enc->decrypt($row['M_PatientDOB_enc']) ?? date('d-m-Y', strtotime($row['patient_dob_raw']));
unset($row['M_PatientName_enc'], $row['M_PatientDOB_enc'], $row['patient_dob_raw']);
}
$result = array("total" => 1, "records" => $row);
$this->sys_ok($result);
exit;
}
/*function getrequirements($prm){
$query =" SELECT Nat_RequirementID as id,
Nat_RequirementName as name, '{$prm['status']}' as status,
if(ISNULL(T_SamplingSoRequirementID),'N', if(json_contains(T_SamplingSoRequirementRequirements,Nat_RequirementID),'Y','N') ) as chex,
Nat_RequirementPositionNat_PositionID as positionid
FROM nat_requirement
JOIN nat_testrequirement ON Nat_TestRequirementNat_RequirementID = Nat_RequirementID
JOIN nat_requirementposition ON Nat_RequirementPositionNat_RequirementID = Nat_RequirementID AND Nat_RequirementPositionNat_PositionID = 8 AND
Nat_RequirementPositionIsActive = 'Y'
JOIN t_test ON T_TestNat_TestID = Nat_TestRequirementNat_TestID
LEFT JOIN t_samplingso_requirement ON T_SamplingSoRequirementT_OrderHeaderID = {$prm['orderid']} AND
T_SamplingSoRequirementT_SampletypeID = {$prm['sampletypeid']} AND T_SamplingSoRequirementNat_PositionID = Nat_RequirementPositionNat_PositionID
WHERE
Nat_TestRequirementIsActive = 'Y'
";
//echo $query;
$rows = $this->db_onedev->query($query)->result_array();
return $rows;
}*/
function getrequirements($prm)
{
$rows = array();
$query = "
SELECT Nat_RequirementID as id,
Nat_RequirementName as name, 'P' as status,
T_OrderSampleReceive,
if(ISNULL(T_OrderSampleReqID),'N', if(json_contains(T_OrderSampleReqs,Nat_RequirementID),'Y','N') ) as chex,
Nat_RequirementPositionNat_PositionID as positionid
FROM nat_requirement
JOIN nat_testrequirement ON Nat_TestRequirementNat_RequirementID = Nat_RequirementID
JOIN nat_requirementposition ON Nat_RequirementPositionNat_RequirementID = Nat_RequirementID AND Nat_RequirementPositionNat_PositionID = 2 AND
Nat_RequirementPositionIsActive = 'Y'
JOIN t_test ON T_TestNat_TestID = Nat_TestRequirementNat_TestID
JOIN t_barcodelab ON T_barcodeLabT_OrderHeaderID = {$prm['orderid']} AND T_BarcodeLabT_SampleTypeID = {$prm['sampletypeid']}
JOIN t_ordersample ON T_OrderSampleT_OrderHeaderID = {$prm['orderid']} AND T_OrderSampleT_SampleTypeID = {$prm['sampletypeid']} AND
T_OrderSampleT_BarcodeLabID = T_BarcodeLabID AND T_OrderSampleIsActive = 'Y'
LEFT JOIN t_ordersamplereq ON T_OrderSampleReqT_OrderSampleID = T_OrderSampleID AND T_OrderSampleReqT_OrderHeaderID = {$prm['orderid']} AND
T_OrderSampleReqNat_PositionID = Nat_RequirementPositionNat_PositionID
WHERE
Nat_TestRequirementIsActive = 'Y'
GROUP BY nat_requirementID
union
SELECT Nat_RequirementID as id,
Nat_RequirementName as name, 'P' as status,
T_OrderSampleReceive,
if(ISNULL(T_OrderSampleReqID),'N', if(json_contains(T_OrderSampleReqs,Nat_RequirementID),'Y','N') ) as chex,
Nat_RequirementPositionNat_PositionID as positionid
FROM nat_requirement
JOIN nat_requirementposition ON Nat_RequirementPositionNat_RequirementID = Nat_RequirementID
AND Nat_RequirementPositionNat_PositionID = 2 AND Nat_RequirementPositionIsActive = 'Y'
AND Nat_RequirementIsAllTest = 'Y'
JOIN t_barcodelab ON T_barcodeLabT_OrderHeaderID = {$prm['orderid']} AND T_BarcodeLabT_SampleTypeID = {$prm['sampletypeid']}
JOIN t_ordersample ON T_OrderSampleT_OrderHeaderID = {$prm['orderid']} AND T_OrderSampleT_SampleTypeID = {$prm['sampletypeid']} AND
T_OrderSampleT_BarcodeLabID = T_BarcodeLabID AND T_OrderSampleIsActive = 'Y'
LEFT JOIN t_ordersamplereq ON T_OrderSampleReqT_OrderSampleID = T_OrderSampleID AND T_OrderSampleReqT_OrderHeaderID = {$prm['orderid']} AND
T_OrderSampleReqNat_PositionID = Nat_RequirementPositionNat_PositionID
GROUP BY nat_requirementID
";
//echo $query;
$rows = $this->db_onedev->query($query)->result_array();
return $rows;
}
function saverequirement()
{
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
$prm = $this->sys_input;
$query = " INSERT INTO t_samplingso_requirement (
T_SamplingSoRequirementT_OrderHeaderID,
T_SamplingSoRequirementT_SampleStationID,
T_SamplingSoRequirementT_SampletypeID,
T_SamplingSoRequirementStatus,
T_SamplingSoRequirementRequirements,
T_SamplingSoRequirementNote,
T_SamplingSoRequirementNat_PositionID,
T_SamplingSoRequirementUserID,
T_SamplingSoRequirementCreated
)VALUES(
{$prm['T_OrderHeaderID']},
{$prm['stationid']},
{$prm['sample']['T_SampleTypeID']},
'N',
)";
//echo $query;
$rows = $this->db_onedev->query($query)->result_array();
$result = array(
"total" => count($rows),
"records" => $rows,
);
$this->sys_ok($result);
exit;
}
function doaction()
{
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
$rst_data = array('status' => 'OK');
$status_call = array('status' => 'OK', 'data' => array());
$prm = $this->sys_input;
$userid = $this->sys_user["M_UserID"];
if ($prm['staff']['id'] != 0 || $prm['staff']['id'] != '0') {
$userid = $prm['staff']['userid'];
}
$sql = "SELECT T_OrderHeaderQueue AS queueNumber ,
M_LocationID AS locationID,
M_LocationName AS locationName FROM t_orderheader
JOIN t_order_location ON T_OrderHeaderID = T_OrderLocationT_OrderHeaderID
JOIN m_location ON T_OrderLocationM_LocationID = M_LocationID
AND T_OrderLocationT_SampleStationID = {$prm['stationid']}
WHERE T_OrderHeaderID={$prm['id']}";
$location = $this->db_onedev->query($sql)->row_array();
$locationID = $location['locationID'];
$locationName = $location['locationName'];
$queueNumber = $location['queueNumber'];
$splitedLocationName = explode(" ", $locationName);
$locationName = $splitedLocationName[0];
if ($prm['act'] == 'call') {
$sql = "SELECT T_SamplingQueueLastStatusID, T_SamplingQueueStatusName, T_SampleStationName, T_SampleStationID, T_SampleStationIsNonLab
FROM t_sampling_queue_last_status
JOIN t_sampling_queue_status ON T_SamplingQueueLastStatusT_SamplingQueueStatusID = T_SamplingQueueStatusID
JOIN t_samplestation ON T_SampleStationID = T_SamplingQueueLastStatusT_SampleStationID
WHERE
T_SamplingQueueLastStatusT_OrderHeaderID = {$prm['id']} AND
T_SamplingQueueLastStatusT_SampleStationID <> {$prm['stationid']} AND
T_SamplingQueueLastStatusT_SamplingQueueStatusID IN (1,3) LIMIT 1";
$data_status_call = $this->db_onedev->query($sql)->row_array();
if ($data_status_call) {
$status_call = array('status' => 'NOTCALL', 'data' => $data_status_call);
$check_valid = false;
if ($data_status_call['T_SampleStationIsNonLab'] == '') {
$sql = "SELECT COUNT(*) as xcount
FROM t_ordersample
WHERE
T_OrderSampleReceive <> 'Y' AND
T_OrderSampleT_OrderHeaderID = {$prm['id']} AND
T_OrderSampleT_SampleStationID = {$data_status_call['T_SampleStationID']} AND
T_OrderSampleIsActive = 'Y'
";
$not_sampled = $this->db_onedev->query($sql)->row_array();
} else {
$sql = "SELECT SUM(countx) as xcount
FROM (
SELECT COUNT(*) as countx
FROM t_orderdetail
JOIN t_test ON T_OrderDetailT_TestID = T_TestID AND T_TestIsResult = 'Y'
JOIN t_sampletype ON T_TestT_SampleTypeID = T_SampleTypeID
JOIN t_bahan ON T_SampleTypeT_BahanID = T_BahanID
JOIN t_samplestation ON T_BahanT_SampleStationID = T_SampleStationID AND
T_SampleStationID = {$data_status_call['T_SampleStationID']}
LEFT JOIN t_samplingso ON T_SamplingSoT_OrderHeaderID = T_OrderDetailT_OrderHeaderID AND
T_SamplingSoT_TestID = T_TestID AND
T_SamplingSoIsActive = 'Y'
WHERE
T_OrderDetailT_OrderHeaderID = {$prm['id']} AND T_OrderDetailIsActive = 'Y' AND
ISNULL(T_SamplingSoDoneDate)
) x";
$not_sampled = $this->db_onedev->query($sql)->row_array();
}
if (intval($not_sampled['xcount']) == 0) {
$sql = "UPDATE t_sampling_queue_last_status
SET T_SamplingQueueLastStatusT_SamplingQueueStatusID = 5
WHERE
T_SamplingQueueLastStatusT_OrderHeaderID = {$prm['id']} AND
T_SamplingQueueLastStatusT_SampleStationID = {$data_status_call['T_SampleStationID']}";
$this->db_onedev->query($sql);
$status_call = array('status' => 'OK', 'data' => array());
}
}
}
$next_status = $prm['statusnextid'];
if ($prm['act'] == 'process') {
$sql = "SELECT T_OrderDetailID, T_OrderHeaderID,T_OrderDetailID as id,
T_BarcodeLabID,
T_BarcodeLabBarcode,
T_OrderDetailT_TestCode,
T_OrderDetailT_TestName,
T_SampleTypeID,
T_SampleTypeName,
T_BahanName
FROM t_orderheader
JOIN t_orderdetail ON T_OrderDetailT_OrderHeaderID = T_OrderHeaderID AND T_OrderDetailIsActive = 'Y'
JOIN t_test ON T_OrderDetailT_TestID = T_TestID
JOIN t_ordersample ON
T_OrderSampleT_OrderHeaderID = T_OrderHeaderID AND
T_OrderSampleIsActive = 'Y' AND T_OrderSampleReceive = 'N'
JOIN t_barcodelab ON T_OrderSampleT_BarcodeLabID = T_BarcodeLabID AND T_BarcodeLabIsActive = 'Y'
JOIN t_sampletype ON T_SampleTypeID = T_OrderSampleT_SampleTypeID
JOIN t_bahan ON T_SampleTypeT_BahanID = T_BahanID
JOIN t_samplestation ON T_BahanT_SampleStationID = T_SampleStationID AND T_SampleStationID = {$prm['stationid']}
LEFT JOIN t_ordersamplereq ON T_OrderSampleReqT_OrderHeaderID = T_OrderHeaderID AND
T_OrderSampleReqT_OrderSampleID = T_OrderSampleID AND
T_OrderSampleReqNat_PositionID = 2 AND
T_OrderSampleReqT_SampleStationID = T_SampleStationID AND
T_OrderSampleReqIsActive = 'Y'
WHERE
T_OrderHeaderID = {$prm['id']} AND (T_OrderSampleReceive = 'N' OR T_OrderSampleSampling = 'X') AND T_OrderHeaderIsActive = 'Y'
GROUP BY T_BarcodeLabID";
//echo $sql;
$rows_all_sample = $this->db_onedev->query($sql)->result();
if ($rows_all_sample) {
foreach ($rows_all_sample as $k => $v) {
$sql = "INSERT INTO t_ordersample (
T_OrderSampleT_OrderHeaderID,
T_OrderSampleT_SampleTypeID,
T_OrderSampleT_BarcodeLabID,
T_OrderSampleCreated,
T_OrderSampleUserID
)
VALUES(
{$prm['id']},
{$v->T_SampleTypeID},
{$v->T_BarcodeLabID},
NOW(),
{$userid}
) ON DUPLICATE KEY UPDATE
T_OrderSampleSampling = 'Y',
T_OrderSampleSamplingDate = CURDATE(),
T_OrderSampleSamplingTime = CURTIME(),
T_OrderSampleSamplingUserID = {$userid},
T_OrderSampleIsActive = 'Y',
T_OrderSampleUserID = {$userid}";
//echo $sql;
$this->db_onedev->query($sql);
$sql = "INSERT INTO sample_by_step(
SampleByStepM_StatusSampleCode,
SampleByStepT_OrderHeaderID,
SampleByStepT_BarcodeLabID,
SampleByStepRequirementStatus,
SampleByStepRequirements,
SampleByStepUserID,
SampleByStepDateTime
)
VALUES(
'SAMPLING.Sampling.Sampled',
{$prm['id']},
{$v->T_BarcodeLabID},
'Y',
'[]',
{$userid},
NOW()
)";
$this->db_onedev->query($sql);
//echo $sql;
}
$this->broadcast("specimen-col-process");
}
}
if (!isset($prm['typeaction']) && $prm['act'] == 'samplingdone') {
$sql = "INSERT INTO t_ordersample (
T_OrderSampleT_OrderHeaderID,
T_OrderSampleT_SampleTypeID,
T_OrderSampleT_BarcodeLabID,
T_OrderSampleCreated,
T_OrderSampleUserID
)
VALUES(
{$prm['sample']['T_OrderHeaderID']},
{$prm['sample']['T_SampleTypeID']},
{$prm['sample']['T_BarcodeLabID']},
NOW(),
{$userid}
) ON DUPLICATE KEY UPDATE
T_OrderSampleReceiveDate = CURDATE(),
T_OrderSampleReceiveTime = CURTIME(),
T_OrderSampleReceiveUserID = {$userid},
T_OrderSampleReceive = 'Y',
T_OrderSampleIsActive = 'Y',
T_OrderSampleUserID = {$userid}";
$this->db_onedev->query($sql);
//echo $sql;
$sql = "SELECT * FROM t_ordersample
WHERE T_OrderSampleT_BarcodeLabID = {$prm['sample']['T_BarcodeLabID']} AND T_OrderSampleIsActive = 'Y'
ORDER BY T_OrderSampleID DESC LIMIT 1";
$dt_sampleorder = $this->db_onedev->query($sql)->row();
$sql = "SELECT * FROM t_sampletype WHERE T_SampleTypeID = {$prm['sample']['T_SampleTypeID']}";
$dt_sampletype = $this->db_onedev->query($sql)->row();
//echo $dt_sampleorder->T_OrderSampleReceiveDate;
//echo $dt_sampleorder->T_OrderSampleReceiveTime;
$readytime = date('Y-m-d H:i:s', strtotime($dt_sampleorder->T_OrderSampleReceiveDate . ' ' . $dt_sampleorder->T_OrderSampleReceiveTime));
//echo $readytime;
if ($dt_sampletype->T_SampleTypeAgingOnHold == 'Y') {
$readytime = date('Y-m-d H:i:s', strtotime("+{$dt_sampletype->T_SampleTypeAgingOnHoldTime} minutes", strtotime($dt_sampleorder->T_OrderSampleReceiveDate . ' ' . $dt_sampleorder->T_OrderSampleReceiveTime)));
//echo $readytime;
}
//echo $readytime;
$sql = "UPDATE t_ordersample
SET T_OrderSampleReadyToProcessDateTime = '{$readytime}'
WHERE
T_OrderSampleT_BarcodeLabID = {$prm['sample']['T_BarcodeLabID']} AND T_OrderSampleIsActive = 'Y' ";
$this->db_onedev->query($sql);
//echo $sql;
$xreq = $prm['sample']['requirements'];
$arr_requirements = array();
foreach ($xreq as $k => $v) {
if ($v['chex'] == 'Y')
array_push($arr_requirements, $v['id']);
}
$requirements = '[' . join(',', $arr_requirements) . ']';
$sql = "INSERT INTO t_ordersamplereq(
T_OrderSampleReqT_OrderHeaderID,
T_OrderSampleReqT_SampleStationID,
T_OrderSampleReqT_OrderSampleID,
T_OrderSampleReqNat_PositionID,
T_OrderSampleReqStatus,
T_OrderSampleReqs,
T_OrderSampleReqUserID,
T_OrderSampleReqCreated
)
VALUES(
{$prm['sample']['T_OrderHeaderID']},
{$prm['stationid']},
{$prm['sample']['T_OrderSampleID']},
{$prm['sample']['requirements'][0]['positionid']},
'{$prm['sample']['requirement_status']}',
'{$requirements}',
{$userid},
NOW()
)ON DUPLICATE KEY UPDATE
T_OrderSampleReqStatus = '{$prm['sample']['requirement_status']}',
T_OrderSampleReqs = '{$requirements}',
T_OrderSampleReqUserID = {$userid}";
//echo $sql;
$this->db_onedev->query($sql);
$sql = "INSERT INTO sample_by_step(
SampleByStepM_StatusSampleCode,
SampleByStepT_OrderHeaderID,
SampleByStepT_BarcodeLabID,
SampleByStepRequirementStatus,
SampleByStepRequirements,
SampleByStepUserID,
SampleByStepDateTime
)
VALUES(
'SAMPLING.Sampling.Received',
{$prm['sample']['T_OrderHeaderID']},
{$prm['sample']['T_BarcodeLabID']},
'{$prm['sample']['requirement_status']}',
'{$requirements}',
{$userid},
NOW()
)";
$this->db_onedev->query($sql);
//echo $sql;
$sql = "SELECT count(*) as xcount
FROM (SELECT *
FROM t_orderheader
JOIN t_orderdetail ON T_OrderDetailT_OrderHeaderID = T_OrderHeaderID AND T_OrderDetailIsActive = 'Y'
JOIN t_test ON T_OrderDetailT_TestID = T_TestID
LEFT JOIN t_ordersample ON T_OrderSampleT_OrderHeaderID = T_OrderHeaderID AND
T_OrderSampleIsActive = 'Y'
LEFT JOIN t_barcodelab ON T_OrderSampleT_BarcodeLabID = T_BarcodeLabID AND T_BarcodeLabIsActive = 'Y'
LEFT JOIN t_sampletype ON T_SampleTypeID = T_OrderSampleT_SampleTypeID
LEFT JOIN t_bahan ON T_SampleTypeT_BahanID = T_BahanID
LEFT JOIN t_samplestation ON T_BahanT_SampleStationID = T_SampleStationID AND
T_SampleStationID = {$prm['stationid']}
WHERE
T_OrderHeaderID = {$prm['id']} AND
T_OrderSampleReceive = 'N' AND T_OrderHeaderIsActive = 'Y'
GROUP BY T_BarcodeLabID ) xx";
//echo $sql;
$xcount = $this->db_onedev->query($sql)->row()->xcount;
$rst_data = array('status' => 'PARTIAL');
if ($xcount == 0) {
$next_status = 5;
$rst_data = array('status' => 'OK');
}
$this->broadcast("specimen-col-receive");
}
if (isset($prm['typeaction']) && $prm['typeaction'] == 'multi' && $prm['act'] == 'samplingdone') {
$xx_samples = $prm['sample'];
foreach ($xx_samples as $ks => $vs) {
$sql = "INSERT INTO t_ordersample (
T_OrderSampleT_OrderHeaderID,
T_OrderSampleT_SampleTypeID,
T_OrderSampleT_BarcodeLabID,
T_OrderSampleCreated,
T_OrderSampleUserID
)
VALUES(
{$vs['T_OrderHeaderID']},
{$vs['T_SampleTypeID']},
{$vs['T_BarcodeLabID']},
NOW(),
{$userid}
) ON DUPLICATE KEY UPDATE
T_OrderSampleReceiveDate = CURDATE(),
T_OrderSampleReceiveTime = CURTIME(),
T_OrderSampleReceiveUserID = {$userid},
T_OrderSampleReceive = 'Y',
T_OrderSampleIsActive = 'Y',
T_OrderSampleUserID = {$userid}";
$this->db_onedev->query($sql);
$sql = "SELECT * FROM t_ordersample
WHERE T_OrderSampleT_BarcodeLabID = {$vs['T_BarcodeLabID']} AND T_OrderSampleIsActive = 'Y'
ORDER BY T_OrderSampleID DESC LIMIT 1";
$dt_sampleorder = $this->db_onedev->query($sql)->row();
$sql = "SELECT * FROM t_sampletype WHERE T_SampleTypeID = {$vs['T_SampleTypeID']}";
$dt_sampletype = $this->db_onedev->query($sql)->row();
//echo $dt_sampleorder->T_OrderSampleReceiveDate;
//echo $dt_sampleorder->T_OrderSampleReceiveTime;
$readytime = date('Y-m-d H:i:s', strtotime($dt_sampleorder->T_OrderSampleReceiveDate . ' ' . $dt_sampleorder->T_OrderSampleReceiveTime));
//echo $readytime;
if ($dt_sampletype->T_SampleTypeAgingOnHold == 'Y') {
$readytime = date('Y-m-d H:i:s', strtotime("+{$dt_sampletype->T_SampleTypeAgingOnHoldTime} minutes", strtotime($dt_sampleorder->T_OrderSampleReceiveDate . ' ' . $dt_sampleorder->T_OrderSampleReceiveTime)));
//echo $readytime;
}
//echo $readytime;
$sql = "UPDATE t_ordersample
SET T_OrderSampleReadyToProcessDateTime = '{$readytime}'
WHERE
T_OrderSampleT_BarcodeLabID = {$vs['T_BarcodeLabID']} AND T_OrderSampleIsActive = 'Y' ";
$this->db_onedev->query($sql);
//echo $sql;
$xreq = $vs['requirements'];
$arr_requirements = array();
foreach ($xreq as $k => $v) {
if ($v['chex'] == 'Y')
array_push($arr_requirements, $v['id']);
}
$requirements = '[' . join(',', $arr_requirements) . ']';
$sql = "INSERT INTO t_ordersamplereq(
T_OrderSampleReqT_OrderHeaderID,
T_OrderSampleReqT_SampleStationID,
T_OrderSampleReqT_OrderSampleID,
T_OrderSampleReqNat_PositionID,
T_OrderSampleReqStatus,
T_OrderSampleReqs,
T_OrderSampleReqUserID,
T_OrderSampleReqCreated
)
VALUES(
{$vs['T_OrderHeaderID']},
{$prm['stationid']},
{$vs['T_OrderSampleID']},
{$vs['requirements'][0]['positionid']},
'{$vs['requirement_status']}',
'{$requirements}',
{$userid},
NOW()
)ON DUPLICATE KEY UPDATE
T_OrderSampleReqStatus = '{$vs['requirement_status']}',
T_OrderSampleReqs = '{$requirements}',
T_OrderSampleReqUserID = {$userid}";
//echo $sql;
$this->db_onedev->query($sql);
$sql = "INSERT INTO sample_by_step(
SampleByStepM_StatusSampleCode,
SampleByStepT_OrderHeaderID,
SampleByStepT_BarcodeLabID,
SampleByStepRequirementStatus,
SampleByStepRequirements,
SampleByStepUserID,
SampleByStepDateTime
)
VALUES(
'SAMPLING.Sampling.Received',
{$vs['T_OrderHeaderID']},
{$vs['T_BarcodeLabID']},
'{$vs['requirement_status']}',
'{$requirements}',
{$userid},
NOW()
)";
$this->db_onedev->query($sql);
}
$sql = "SELECT count(*) as xcount
FROM (SELECT *
FROM t_orderheader
JOIN t_orderdetail ON T_OrderDetailT_OrderHeaderID = T_OrderHeaderID AND T_OrderDetailIsActive = 'Y'
JOIN t_test ON T_OrderDetailT_TestID = T_TestID
JOIN t_sampletype ON T_TestT_SampleTypeID = T_SampleTypeID
JOIN t_barcodelab ON T_BarcodeLabT_OrderHeaderID = T_OrderHeaderID AND T_BarcodeLabT_SampleTypeID = T_SampleTypeID
JOIN t_bahan ON T_SampleTypeT_BahanID = T_BahanID
JOIN t_samplestation ON T_BahanT_SampleStationID = T_SampleStationID AND T_SampleStationID = {$prm['stationid']}
LEFT JOIN t_ordersample ON T_OrderSampleT_OrderHeaderID = T_OrderHeaderID AND
T_OrderSampleT_SampleTypeID = T_SampleTypeID AND
T_OrderSampleT_BarcodeLabID = T_BarcodeLabID AND
T_OrderSampleIsActive = 'Y'
WHERE
T_OrderHeaderID = {$prm['id']} AND
T_OrderSampleReceive = 'N' AND T_OrderHeaderIsActive = 'Y'
GROUP BY T_BarcodeLabID ) xx";
//echo $sql;
$xcount = $this->db_onedev->query($sql)->row()->xcount;
$rst_data = array('status' => 'PARTIAL');
if ($xcount == 0) {
$next_status = 5;
$rst_data = array('status' => 'OK');
}
$this->broadcast("specimen-col-receive");
}
if ($prm['act'] !== 'samplingprocess' && $status_call['status'] == 'OK') {
$dt_json = json_encode(array('T_SampleStationID' => $prm['stationid'], 'T_OrderHeaderID' => $prm['id'], 'T_SamplingQueueStatusID' => $next_status));
$query = "INSERT INTO one_log.log_sampling_queue (Log_SamplingQueueDate,Log_SamplingQueueJSON,Log_SamplingQueueUserID)
VALUES(NOW(),'{$dt_json}',{$userid})";
//echo $query;
$rows = $this->db_onedev->query($query);
$sql = "SELECT *
FROM t_sampling_queue_last_status
WHERE
T_SamplingQueueLastStatusT_SampleStationID = {$prm['stationid']} AND
T_SamplingQueueLastStatusT_OrderHeaderID = {$prm['id']} AND
T_SamplingQueueLastStatusIsActive = 'Y'";
$data_last = $this->db_onedev->query($sql)->row();
$query = "INSERT INTO t_sampling_queue_last_status (
T_SamplingQueueLastStatusT_SampleStationID,
T_SamplingQueueLastStatusT_OrderHeaderID,
T_SamplingQueueLastStatusT_SamplingQueueStatusID,
T_SamplingQueueLastStatusUserID)
VALUES(
{$prm['stationid']},
{$prm['id']},
{$next_status},
{$userid}) ON DUPLICATE KEY UPDATE
T_SamplingQueueLastStatusT_SamplingQueueStatusID = {$next_status},
T_SamplingQueueLastStatusUserID = {$userid}";
//echo $query;
$rows = $this->db_onedev->query($query);
}
if ($status_call['status'] == 'NOTCALL') {
$rst_data = $status_call;
}
if ($prm['act'] == 'skip' || $status_call['status'] == 'NOTCALL') {
$skip_time = date('Y-m-d H:i:s', strtotime($prm['skiptime'])+10);
$sql = "UPDATE antrian_samplestation SET AntrianSampleStationIsActive = 'N'
WHERE
AntrianSampleStationT_OrderLocationID = ?";
$query = $this->db_onedev->query($sql,array($prm['orderlocationid']));
/* start dipaggil 3 kali skpi ururtan jd ke bawah */
/*$sql = "SELECT COUNT(*) as x_count
FROM antrian_samplestation
WHERE AntrianSampleStationT_OrderLocationID = ? AND
AntrianSampleStationIsActive = 'N' AND
DATE(AntrianSampleStationTime) = DATE(NOW())";
$query = $this->db_onedev->query($sql,array($prm['orderlocationid']));
$xcount_skip = $query->row()->x_count;
$modby3 = $xcount_skip % 2;
if($xcount_skip > 0 && $modby3 == 0){
$skip_time = date('Y-m-d H:i:s', strtotime($prm['last_skiptime'])+1);
}*/
/* end dipaggil 3 kali skpi ururtan jd ke bawah */
$sql = "INSERT INTO antrian_samplestation(
AntrianSampleStationT_OrderLocationID,
AntrianSampleStationTime,
AntrianSampleStationUserID,
AntrianSampleStationCreated
)
VALUES(
?,?,?,NOW()
)";
$query = $this->db_onedev->query($sql,array($prm['orderlocationid'],$skip_time,$userid));
}
if (intval($next_status) == 1) {
if ($status_call['status'] == 'OK') {
file_get_contents("http://" . $this->IP_SOCKET_IO . ":9099/broadcast/call.sm.{$locationID}.{$queueNumber}.{$locationName}"); //CALL NODE
}
} else if (intval($next_status) == 2) {
file_get_contents("http://" . $this->IP_SOCKET_IO . ":9099/broadcast/skip.sm.{$locationID}");
} else if (intval($next_status) == 3) {
file_get_contents("http://" . $this->IP_SOCKET_IO . ":9099/broadcast/serve.sm.{$locationID}");
} else if (intval($next_status) == 5) {
file_get_contents("http://" . $this->IP_SOCKET_IO . ":9099/broadcast/done.sm.{$locationID}");
} else {
file_get_contents("http://" . $this->IP_SOCKET_IO . ":9099/broadcast/done.sm.{$locationID}");
}
$result = array(
"total" => 1,
"records" => $rst_data,
"nextstatus" => $next_status
);
$this->sys_ok($result);
exit;
}
function addnewlabel()
{
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
$rst_data = array('status' => 'OK');
$prm = $this->sys_input;
$userid = $this->sys_user["M_UserID"];
$counter_barcode = substr($prm["sample"]["T_BarcodeLabBarcode"], -1, 1); //explode(".",$prm["sample"]["T_BarcodeLabBarcode"]);
$new_counter = intval($counter_barcode) + 1;
$new_label = substr($prm["sample"]["T_BarcodeLabBarcode"], 0, -1) . $new_counter;
$sql = "INSERT INTO t_barcodelab (
T_BarcodeLabT_OrderHeaderID ,
T_BarcodeLabBarcode,
T_BarcodeLabT_SampleTypeID,
T_BarcodeLabUserID
)
VALUES(
{$prm['sample']['T_OrderHeaderID']},
'{$new_label}',
{$prm['sample']['T_SampleTypeID']},
{$userid}
)";
//echo $sql;
$this->db_onedev->query($sql);
$result = array(
"total" => 1,
"records" => $rst_data
);
$this->sys_ok($result);
exit;
}
function getdatanoterequirement()
{
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
$rst_data = array();
$prm = $this->sys_input;
$sql = "SELECT 'fo registration' as position,GROUP_CONCAT(DISTINCT Nat_RequirementName separator ',') as requirements
FROM t_orderheader
JOIN t_orderreq ON T_OrderReqT_OrderHeaderID = T_OrderHeaderID
JOIN nat_requirement ON json_contains(T_OrderReqs,Nat_RequirementID)
WHERE T_OrderHeaderID = {$prm['T_OrderHeaderID']}
GROUP BY T_OrderHeaderID";
//echo $sql;
$query = $this->db_onedev->query($sql)->row_array();
if ($query) {
array_push($rst_data, $query);
}
$sql = "SELECT 'fo verifikasi' as position, GROUP_CONCAT(DISTINCT Fo_VerificationsLabelName separator ',') as requirements
FROM fo_verificationsvalue
JOIN fo_verificationslabel ON Fo_VerificationsValueFo_VerificationsLabelID = Fo_VerificationsLabelID
WHERE
Fo_VerificationsValueCheck = 'N' AND
Fo_VerificationsValueT_OrderHeaderID = {$prm['T_OrderHeaderID']}
GROUP BY Fo_VerificationsValueT_OrderHeaderID
";
//echo $sql;
$query = $this->db_onedev->query($sql)->row_array();
if ($query) {
array_push($rst_data, $query);
}
$result = array(
"total" => 1,
"records" => $rst_data
);
$this->sys_ok($result);
exit;
}
function savenotesampling()
{
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
$rst_data = array();
$prm = $this->sys_input;
$sql = "UPDATE t_orderheader SET T_OrderHeaderSamplingNote = '{$prm['sampling_note']}' WHERE T_OrderHeaderID = {$prm['T_OrderHeaderID']}";
//echo $sql;
$query = $this->db_onedev->query($sql);
$result = array(
"total" => 1,
"records" => $rst_data
);
$this->sys_ok($result);
exit;
}
function getlocation()
{
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
$prm = $this->sys_input;
$stationID = $prm['station_id'];
$rows = [];
$query = "SELECT M_LocationID AS locationID,
M_LocationName AS locationName
FROM m_location
WHERE M_LocationT_SampleStationID= ?
AND M_LocationIsActive = 'Y'
";
//echo $query;
$qry = $this->db_onedev->query($query, [$stationID]);
if (!$qry) {
$error = array(
"message" => $this->db_onedev->error()["message"],
);
$this->sys_error($error);
exit;
}
$rows = $qry->result_array();
$result = array(
"total" => count($rows),
"records" => $rows,
);
$this->sys_ok($result);
exit;
}
}
Reference in New Issue View Git Blame Copy Permalink