<?php
class Samplingcall extends MY_Controller
{
	var $db_onedev;
	var $IP_SOCKET_IO = "127.0.0.1";
	public function __construct()
	{
		parent::__construct();
		$this->db_onedev = $this->load->database("onedev", true);
		$this->IP_SOCKET_IO = "127.0.0.1";
	}

	public function index()
	{
		echo "Samplingcall API";
		// Untuk FE: test/vuex/cpone-sample-all/
	}

	public function getstations()
	{
		if (!$this->isLogin) {
			$this->sys_error("Invalid Token");
			exit;
		}
		$rows = [];
		$query = "	SELECT T_SampleStationID as id, T_SampleStationName as name, T_SampleStationIsNonLab as isnonlab, T_SampleStationIsAdditionalFisik as isadditional
						FROM t_samplestation 
						WHERE	
							T_SampleStationIsActive = 'Y'
							ORDER BY T_SampleStationOrder ASC
					";
		//echo $query;
		$rows['stations'] = $this->db_onedev->query($query)->result_array();
		$rows['statuses'] = array(array('id' => 'NEW', 'name' => 'New'), array('id' => 'DONE', 'name' => 'Done'));

		$urls = [];
		$query = "	SELECT * FROM `s_menu` WHERE `S_MenuUrl` LIKE '%cpone-resultentry-other-fisik-mobile%' AND S_MenuIsActive = 'Y' LIMIT 1";
		$urls['url_fisik'] = $this->db_onedev->query($query)->row()->S_MenuUrl;

		$query = "	SELECT * FROM `s_menu` WHERE `S_MenuUrl` LIKE  '%test/vuex/one-resultentry-so-electromedis%'  AND S_MenuIsActive = 'Y' LIMIT 1";
		$urls['url_electromedis'] = $this->db_onedev->query($query)->row()->S_MenuUrl;

		$query = "	SELECT * FROM `s_menu` WHERE `S_MenuUrl` LIKE  '%test/vuex/one-resultentry-so-xray%'  AND S_MenuIsActive = 'Y' LIMIT 1";
		$urls['url_xray'] = $this->db_onedev->query($query)->row()->S_MenuUrl;

		$query = "	SELECT * FROM `s_menu` WHERE `S_MenuName` =  'Specimen Collection Mobile'  AND S_MenuIsActive = 'Y' LIMIT 1";
		$urls['url_sampling'] = $this->db_onedev->query($query)->row()->S_MenuUrl;


		$result = array(
			"total" => count($rows),
			"records" => $rows,
			"urls" => $urls
		);
		$this->sys_ok($result);
		exit;
	}

	public function listpatients()
	{
		try {
			if (!$this->isLogin) {
				$this->sys_error("Invalid Token");
				exit;
			}
			$prm = $this->sys_input;
			$user = $this->sys_user;
			$branchID = $user['M_BranchID'];
			$name = $prm["name"];
			$nolab = $prm["nolab"];
			$stationid = $prm["stationid"];
			$xdate = $prm["xdate"];
			$statusid = $prm["statusid"];
			$corpID = isset($prm["corpID"]) ? $prm["corpID"] : 0;
			$search = isset($prm["searchx"]) ? $prm["searchx"] : '';

			$filter_corp = '';
			if ($corpID != 0 || $corpID != '0') {
				$filter_corp = " AND CorporateID = {$corpID} ";
			}

			$sql_where = "WHERE T_OrderHeaderIsActive = 'Y' AND DATE(T_OrderHeaderDate) = '{$xdate}' AND T_OrderHeaderM_BranchID = {$branchID}";

			if ($name != "") {
				if ($sql_where != "") {
					$sql_where .= " AND ";
				}
				$sql_where .= " M_PatientName like '%$name%' ";
			}

			$filter_search = '';
			if ($nolab != "") {
				$filter_search = "WHERE (T_OrderHeaderLabNumber like '%$nolab%' OR M_PatientName like '%$nolab%')";
			}

			// Cek Station Type
			$sql = "SELECT * FROM t_samplestation WHERE T_SampleStationID = {$stationid}";
			$query = $this->db_onedev->query($sql);
			if (!$query) {
				$this->sys_error_db("data t_samplestation");
				exit;
			}
			$data_station = $query->row_array();
			$stationtype = $data_station['T_SampleStationIsNonLab'];
			$stationadditional = $data_station['T_SampleStationIsAdditionalFisik'];

			$patients = [];
			$sql = "";
			if ($stationtype == '') {
				$sql = "SELECT * FROM ( 
				SELECT DATE_FORMAT(T_OrderHeaderDate,'%d-%m-%Y %H:%i') as order_date,
					T_OrderHeaderID,
					T_OrderHeaderLabNumber,
					T_OrderHeaderM_PatientAge,
					T_OrderLocationT_SampleStationID as T_SampleStationID,
					IFNULL(T_OrderHeaderFoNote,'') as fo_note,
					M_PatientName as patient_fullname,
					M_PatientNoReg,
					IFNULL(M_PatientPhotoThumb,'') as M_PatientPhotoThumb,
					IF(M_PatientGender = 'male','Laki-laki','Perempuan') as M_PatientGender,
					DATE_FORMAT(M_PatientDOB,'%d-%m-%Y') as patient_dob,
					M_PatientJob,
					M_PatientPosisi,
					IF(M_PatientDivisi = '','-',M_PatientDivisi) M_PatientDivisi,
					M_PatientHp,
					M_PatientNIP,
					M_PatientEmail,
					M_PatientPhoto,
					IFNULL(PreregisterAntrianNumber,'-') antrianNumber,
					0 as testid,
					CorporateName,
					fn_sampling_queue_status_id(T_OrderHeaderID,T_OrderLocationT_SampleStationID)  as statusid,
					fn_sampling_reqs_status(T_OrderHeaderID) as fo_requirements_status,
					fn_sampling_queue_status_name(T_OrderHeaderID,T_OrderLocationT_SampleStationID) as status
				FROM t_orderheader
					JOIN m_patient ON T_OrderHeaderM_PatientID = M_PatientID
					JOIN mcu_preregister_patients ON T_OrderHeaderID = Mcu_PreregisterPatientsT_OrderHeaderID
					JOIN corporate ON T_OrderHeaderCorporateID = CorporateID $filter_corp
					JOIN t_ordersample ON T_OrderSampleT_OrderHeaderID = T_OrderHeaderID AND 
						T_OrderSampleT_SampleStationID = {$stationid} AND 
						T_OrderSampleIsActive = 'Y'
					JOIN t_order_location ON T_OrderLocationT_OrderHeaderID = T_OrderSampleT_OrderHeaderID AND 
					T_OrderLocationT_SampleStationID = T_OrderSampleT_SampleStationID AND
					T_OrderLocationIsActive = 'Y'
					LEFT JOIN preregister_antrian ON Mcu_PreregisterPatientsID = PreregisterAntrianMcu_PreregisterPatientsID
					AND PreregisterAntrianIsActive = 'Y'
	
				$sql_where
				GROUP BY T_OrderHeaderID
					) x 
					$filter_search
				";
			} else {
				$sql = "SELECT * FROM ( 
				SELECT DATE_FORMAT(T_OrderHeaderDate,'%d-%m-%Y %H:%i') as order_date,
				T_OrderHeaderID,
				IFNULL(PreregisterAntrianNumber,'-') antrianNumber,
				T_OrderHeaderLabNumber,
				T_OrderHeaderM_PatientAge,
				T_OrderLocationT_SampleStationID as T_SampleStationID,
				IFNULL(T_OrderHeaderFoNote,'') as fo_note,
				M_PatientName as patient_fullname,
				M_PatientNoReg,
				IFNULL(M_PatientPhotoThumb,'') as M_PatientPhotoThumb,
				IF(M_PatientGender = 'male','Laki-laki','Perempuan') as M_PatientGender,
				DATE_FORMAT(M_PatientDOB,'%d-%m-%Y') as patient_dob,
				M_PatientJob,
				M_PatientPosisi,
				IF(M_PatientDivisi = '','-',M_PatientDivisi) M_PatientDivisi,
				M_PatientHp,
				M_PatientNIP,
				M_PatientEmail,
				M_PatientPhoto,
				0 as testid,
				CorporateName,
				fn_sampling_queue_status_id(T_OrderHeaderID,T_OrderLocationT_SampleStationID)  as statusid,
				fn_sampling_reqs_status(T_OrderHeaderID) as fo_requirements_status,
				fn_sampling_queue_status_name(T_OrderHeaderID,T_OrderLocationT_SampleStationID) as status
				FROM t_orderheader
				JOIN corporate ON T_OrderHeaderCorporateID = CorporateID $filter_corp
				JOIN m_patient ON T_OrderHeaderM_PatientID = M_PatientID 
				JOIN mcu_preregister_patients ON T_OrderHeaderID = Mcu_PreregisterPatientsT_OrderHeaderID
				JOIN t_orderdetail ON T_OrderDetailT_OrderHeaderID = T_OrderHeaderID AND T_OrderDetailIsActive = 'Y'
				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 = {$stationid}
				JOIN t_order_location ON T_OrderLocationT_OrderHeaderID = T_OrderHeaderID AND 
					T_OrderLocationT_SampleStationID = T_SampleStationID AND
					T_OrderLocationIsActive = 'Y'
				LEFT JOIN t_samplingso ON T_SamplingSoT_OrderHeaderID = T_OrderHeaderID AND T_SamplingSoT_TestID = T_TestID AND T_SamplingSoIsActive = 'Y'	
				LEFT JOIN preregister_antrian ON Mcu_PreregisterPatientsID = PreregisterAntrianMcu_PreregisterPatientsID
				AND PreregisterAntrianIsActive = 'Y'
				$sql_where
				GROUP BY T_OrderHeaderID
				) x 
					$filter_search
				";
			}

			$query = $this->db_onedev->query($sql);
			if (!$query) {
				$error = json_encode($this->db_onedev->error(), JSON_PRETTY_PRINT);
				$this->sys_error_db($error);
				exit;
			}
			$patients = $query->result_array();
			$this->sys_ok([
				"total" => count($patients),
				"records" => $patients
			]);
			exit;
		} catch (Exception $exc) {
			$msg = json_encode($exc->getMessage(), JSON_PRETTY_PRINT);
			$this->sys_error($msg);
		}
	}

	public function getsampletypes()
	{
		try {
			if (!$this->isLogin) {
				$this->sys_error("Invalid Token");
				exit;
			}
			$prm = $this->sys_input;
			$stationid = $prm['stationid'];

			// Get T_SampleStationIsNonLab as Category, if '' category is Lab 
			$sql = "SELECT T_SampleStationIsNonLab as category
					FROM t_samplestation
					WHERE T_SampleStationID = {$stationid} AND T_SampleStationIsActive = 'Y'";
			$qry = $this->db_onedev->query($sql)->row();
			if (!$qry) {
				$this->sys_error("Invalid Station ID");
				exit;
			}
			$stationCategory = $qry->category;
			if ($stationCategory == '') {
				$result = $this->getsampletypeslab($prm);
			} else {
				$result = $this->getsampletypesnonlab($prm);
			}

			$resp = [
				"total" => count($result),
				"records" => [
					"sampletypes" => $result
				]
			];

			$this->sys_ok($resp);
			exit;
		} catch (Exception $exception) {
			$msg = json_encode($exception->getMessage(), JSON_PRETTY_PRINT);
			$this->sys_error($msg);
		}
	}

	private function getsampletypeslab($prm)
	{
		$stationid = $prm['stationid'];
		$labnumber = $prm['labnumber'];

		$sql = "SELECT 
					'' as groupresult_name,
					T_SampleTypeName as sampletype_name,
					T_OrderSampleBarcode as barcode,
					IF(ISNULL(T_OrderSampleSamplingDate),'Belum diambil',DATE_FORMAT(T_OrderSampleSamplingDate,'%d-%m-%Y')) as sampling_date,
					IF(ISNULL(T_OrderSampleSamplingTime),'',T_OrderSampleSamplingTime) as sample_time,
					IF(ISNULL(T_OrderSampleReceiveDate),'Belum dilakukan',DATE_FORMAT(T_OrderSampleReceiveDate,'%d-%m-%Y')) as receive_date,
					IF(ISNULL(T_OrderSampleReceiveTime),'',DATE_FORMAT(T_OrderSampleReceiveTime,'%H:%i')) as receive_time,
					T_OrderSampleSampling as is_sampling,
					T_OrderSampleReceive as is_received
					FROM t_ordersample
					JOIN t_orderheader ON T_OrderSampleT_OrderHeaderID = T_OrderHeaderID AND 
					T_OrderSampleIsActive = 'Y' AND
					T_OrderHeaderLabNumber = '{$labnumber}'
					JOIN t_sampletype ON T_OrderSampleT_SampleTypeID = T_SampleTypeID
					JOIN t_bahan ON T_SampleTypeT_BahanID = T_BahanID
					JOIN t_samplestation ON T_BahanT_SampleStationID = T_SampleStationID AND T_SampleStationID = {$stationid}
					JOIN t_order_location ON T_OrderLocationT_OrderHeaderID = T_OrderHeaderID AND 
						T_OrderLocationT_SampleStationID = T_SampleStationID AND
						T_OrderLocationIsActive = 'Y' 
						-- AND T_OrderLocationM_LocationID = {$prm['location_id']}
			";

		$query = $this->db_onedev->query($sql);
		if (!$query) {
			$err = json_encode($this->db_onedev->error(), JSON_PRETTY_PRINT);
			$this->sys_error_db($err);
			exit;
		}
		$result = $query->result_array();

		return $result;
	}

	private function getsampletypesnonlab($prm)
	{
		$stationid = $prm['stationid'];
		$labnumber = $prm['labnumber'];

		$sql = "SELECT 
			Group_ResultName as groupresult_name,
			T_TestName as sampletype_name,
			T_OrderHeaderLabNumber as barcode,
			IF(ISNULL(T_SamplingSoProcessDate),'Belum dilakukan',DATE_FORMAT(T_SamplingSoProcessDate,'%d-%m-%Y')) as sampling_date,
			IF(ISNULL(T_SamplingSoProcessTime),'',T_SamplingSoProcessTime) as sample_time,
			IF(ISNULL(T_SamplingSoDoneDate),'Belum dilakukan',DATE_FORMAT(T_SamplingSoDoneDate,'%d-%m-%Y')) as receive_date,
			IF(ISNULL(T_SamplingSoDoneTime),'',DATE_FORMAT(T_SamplingSoDoneTime,'%H:%i')) as receive_time,
			IF(T_SamplingSoFlag = 'P','Y','N') as is_sampling,
			IF(T_SamplingSoFlag = 'D','Y','N') as is_received,
			T_OrderDetailT_TestID as test_id
				FROM t_orderdetail
			JOIN t_orderheader ON T_OrderDetailT_OrderHeaderID = T_OrderHeaderID AND 
			T_OrderDetailIsActive = 'Y' AND
			T_OrderHeaderLabNumber = ?
			JOIN t_test ON T_OrderDetailT_TestID = T_TestID	
			JOIN group_resultdetail
			ON 	T_OrderDetailT_TestID  = Group_ResultDetailT_TestID
			AND Group_ResultDetailIsActive = 'Y'
			JOIN group_result 
			ON Group_ResultDetailGroup_ResultID = Group_ResultID
			AND Group_ResultIsActive = '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 = ?
			JOIN t_order_location ON T_OrderLocationT_OrderHeaderID = T_OrderHeaderID AND 
				T_OrderLocationT_SampleStationID = T_SampleStationID AND
				T_OrderLocationIsActive = 'Y'
			LEFT JOIN t_samplingso ON T_SamplingSoT_OrderHeaderID =T_OrderHeaderID AND 
				T_SamplingSoT_TestID = T_OrderDetailT_TestID AND
				T_SamplingSoIsActive = 'Y'
			GROUP BY Group_ResultID";

		$query = $this->db_onedev->query($sql, [$labnumber, $stationid]);
		if (!$query) {
			$err = json_encode($this->db_onedev->error(), JSON_PRETTY_PRINT);
			$this->sys_error_db($err);
			exit;
		}
		$result = $query->result_array();

		return $result;
	}

	// Call Patient
	public 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 '' 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;
				// Jika sample dari lab
				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();
				}
				// Jika sample dari non lab
				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 ($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']));

			$sql = "INSERT INTO antrian_samplestation(
						AntrianSampleStationT_OrderLocationID,
						AntrianSampleStationTime,
						AntrianSampleStationUserID,
						AntrianSampleStationCreated
					)
					VALUES(
						?,?,?,NOW()
					)";
			$query = $this->db_onedev->query($sql, array($prm['orderlocationid'], $skip_time, $userid));
		}

		$sql = "SELECT 
				T_OrderHeaderM_BranchID as branchID,
				T_OrderHeaderMgm_McuID as mcuID,
				PreregisterAntrianNumber as queueNumber
				FROM t_orderheader
				JOIN mcu_preregister_patients ON T_OrderHeaderID = Mcu_PreregisterPatientsT_OrderHeaderID
				LEFT JOIN preregister_antrian ON Mcu_PreregisterPatientsID = PreregisterAntrianMcu_PreregisterPatientsID
				AND PreregisterAntrianIsActive = 'Y'
				WHERE T_OrderHeaderID = {$prm['id']}";
		$qry = $this->db_onedev->query(
			$sql
		);

		if (!$qry) {
			$this->sys_error_db("Error get broadcast data", $this->db_onedev);
			exit;
		}
		$dataBroadcast = $qry->row_array();
		if ($prm['act'] ==  'call') {
			file_get_contents("http://" . $this->IP_SOCKET_IO . ":9088/broadcast/sm.call." . $prm['stationid'] . "." . $dataBroadcast['mcuID'] . "." . $dataBroadcast['branchID'] . "." . $dataBroadcast['queueNumber']);
		} else if ($prm['act'] == 'process') {
			file_get_contents("http://" . $this->IP_SOCKET_IO . ":9088/broadcast/sm.process." . $prm['stationid'] . "." . $dataBroadcast['mcuID'] . "." . $dataBroadcast['branchID']);
		} else if ($prm['act'] == 'samplingdone') {
			file_get_contents("http://" . $this->IP_SOCKET_IO . ":9088/broadcast/sm.done." . $prm['stationid'] . "." . $dataBroadcast['mcuID'] . "." . $dataBroadcast['branchID']);
		} else if ($prm['act'] == 'skip') {
			file_get_contents("http://" . $this->IP_SOCKET_IO . ":9088/broadcast/sm.skip." . $prm['stationid'] . "." . $dataBroadcast['mcuID'] . "." . $dataBroadcast['branchID']);
		}

		// 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;
	}



	/* 
		--- MAYBE UNUSED ---
		--- DARI DEVONE ---
	*/

	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';
		$statusid = $prm["statusid"];
		$companyid = isset($prm["companyid"]) ? $prm["companyid"] : 0;
		$search = isset($prm["searchx"]) ? $prm["searchx"] : '';
		// $locationID = $prm['locationid'];
		$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";
		}
		// TODO: check ulang, jika T_OrderSampleReceive diperlukan
		$where_status = "";

		$sql_where = "WHERE T_OrderHeaderIsActive = 'Y' AND ( DATE(T_OrderHeaderAddonIsComingDate) = '{$xdate}' OR DATE(T_OrderHeaderDate) = '{$xdate}' ) {$where_status}";

		if ($name != "") {
			if ($sql_where != "") {
				$sql_where .= " and ";
			}
			$sql_where .= " M_PatientName like '%$name%' ";
		}
		$filter_search = '';
		if ($nolab != "") {

			$filter_search = "WHERE ( T_OrderHeaderLabNumber like '%$nolab%' OR M_PatientName 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.*, 
					DATE_FORMAT(T_OrderHeaderDate,'%d-%m-%Y %H:%i') as order_date,
					IFNULL(M_PatientPhotoThumb,'') as M_PatientPhotoThumb,
					M_PatientName as M_PatientName,
					M_SexName, 
					M_TitleName, 
					CONCAT(M_TitleName,' ',M_PatientName) as patient_fullname, 
					M_CompanyName,
					fn_sampling_queue_status_name(T_OrderHeaderID,T_SampleStationID) as status,
					DATE_FORMAT(M_PatientDOB,'%d-%m-%Y') as patient_dob,
					fn_sampling_queue_status_id(T_OrderHeaderID,T_SampleStationID)  as statusid, 
					T_SampleStationID, T_SampleTypeID,
					-- T_SampleStationID as stationid,
					-- Tambahan
					T_TestID,
					{$stationid} as stationid,
					T_OrderPromiseDateTime,

					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,
					IF(fn_fo_ver_have_reqs(T_OrderHeaderID) = 0,'Y','N') as fo_ver_status_req,
					fn_fo_reg_have_reqs(T_OrderHeaderID) as fo_reg_status_req,
					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_sampling_queue_status_confirm(T_OrderHeaderID,T_SampleStationID) as status_confirm,
					CONCAT(M_DoctorPrefix,M_DoctorPrefix2,' ',M_DoctorName,' ',M_DoctorSufix,M_DoctorSufix2,M_DoctorSufix3) as doctor_sender,
					fn_fo_get_laststatus(T_OrderHeaderID) as last_status_fo,
					T_OrderHeaderAddonIsComing as coming,
					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_doctor ON T_OrderHeaderSenderM_DoctorID = M_DoctorID
					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'
					LEFT JOIN t_orderpromise ON T_OrderPromiseT_OrderHeaderID = T_OrderHeaderID AND T_OrderPromiseIsActive = 'Y'
					JOIN t_orderdetail ON T_OrderDetailT_OrderHeaderID = T_OrderHeaderID AND T_OrderDetailIsActive = 'Y'
					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 = {$stationid}
					JOIN last_status ON Last_StatusT_OrderHeaderID = T_OrderHeaderID
					LEFT JOIN t_samplingso ON T_SamplingSoT_OrderHeaderID = T_OrderHeaderID AND 
					T_SamplingSoT_TestID = T_TestID AND 
					T_SamplingSoT_SampleStationID = T_SampleStationID AND
					T_SamplingSoIsActive = 'Y'

					$sql_where
					GROUP BY T_OrderHeaderID
					HAVING last_status_fo IN (3,5)
				)x
				$filter_search
				ORDER BY T_OrderHeaderIsCito DESC, antri_time ASC
				";

		$query = $this->db_onedev->query($sql);
		$rows = $query->result_array();

		if ($rows) {
			$count_arr = count($rows);
			foreach ($rows as $key => $value) {
				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;
	}

	public function search_old()
	{
		$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";
		}

		$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}";

		if ($name != "") {
			if ($sql_where != "") {
				$sql_where .= " and ";
			}
			$sql_where .= " M_PatientName like '%$name%' ";
		}
		$filter_search = '';
		if ($nolab != "") {

			$filter_search = "WHERE ( T_OrderHeaderLabNumber like '%$nolab%' OR M_PatientName 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, 
					CONCAT(M_TitleName,' ',M_PatientName) as patient_fullname, 
					M_PatientName as M_PatientName,
					M_CompanyName,
					fn_sampling_queue_status_name(T_OrderHeaderID,T_SampleStationID) as status,
					DATE_FORMAT(M_PatientDOB,'%d-%m-%Y') as patient_dob,
					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} 
					$sql_where
					GROUP BY T_OrderHeaderID
				)x
				$filter_search
				ORDER BY T_OrderHeaderIsCito DESC, antri_time ASC
				";

		$query = $this->db_onedev->query($sql);
		$rows = $query->result_array();

		if ($rows) {
			$count_arr = count($rows);
			foreach ($rows as $key => $value) {
				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' ";

		$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.*,m_patient.*, IFNULL(M_PatientPhoto,'') as M_PatientPhotoThumb,
				M_SexName, M_TitleName, CONCAT(M_TitleName,' ',M_PatientName) as patient_fullname, M_CompanyName,
				IF(ISNULL(T_SamplingQueueLastStatusID), 'New',T_SamplingQueueStatusName) as status, DATE_FORMAT(M_PatientDOB,'%d-%m-%Y') as patient_dob,
				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;
		$rows = $this->db_onedev->query($query)->row();

		$result = array(
			"total" => count($rows),
			"records" => $rows,
		);
		$this->sys_ok($result);
		exit;
	}

	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_old()
	{
		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;
	}
}