<?php
class Delivery extends MY_Controller
{
   var $db_onedev;
   public function index()
   {
      echo "Delivery API";
   }
   
   public function __construct()
   {
      parent::__construct();
      $this->db_onedev = $this->load->database("onedev", true);
	  $this->load->helper(array('form', 'url'));
   }
   
   
   function getcompanycouriers(){
		$rows  = [];

		$sql = "SELECT M_CompanyID as id,
				M_CompanyName as name
				FROM m_company
				WHERE
					M_CompanyIsActive = 'Y'";
		//echo $sql;
		$rows['companys'] = $this->db_onedev->query($sql)->result_array();
		
		$sql = "SELECT M_StaffID as id,
				M_StaffName as name
				FROM m_courier
				JOIN m_staff ON M_StaffID = M_CourierM_StaffID
				WHERE
					M_CourierIsActive = 'Y'";
		//echo $sql;
		$rows['couriers'] = $this->db_onedev->query($sql)->result_array();
		$result = array(
			"total" => count($rows) , 
			"records" => $rows, 
		); 
		$this->sys_ok($result);
		exit;
		
   }
   
   function getdetails($id){
		$rows  = [];

		$sql = "SELECT t_receivereferencedeliverydetail.*, M_SexName, 
					T_ReceiveReferencePatientName as patient_fullname,
					T_SampleTypeName as samplename,
					T_ReceiveReferencePatientNoRef as labnumberref, 
					T_OrderHeaderLabNumber as labnumber, 
					'Y' as active, 
					T_ReceiveReferenceDeliveryDetailID as idx,
					T_ReceiveReferencePatientID as orderid,
					T_SampleTypeID as sampleid
					FROM t_receivereferencedeliverydetail 
					JOIN t_receivereferenceheader ON T_ReceiveReferenceDeliveryDetailT_ReceiveReferenceHeaderID = T_ReceiveReferenceHeaderID
					JOIN t_receivereferencepatient ON T_ReceiveReferenceDeliveryDetailT_ReceiveReferencePatientID = T_ReceiveReferencePatientID
					LEFT JOIN t_orderheader ON T_ReceiveReferencePatientT_OrderHeaderID = T_OrderHeaderID
					JOIN t_sampletype ON T_ReceiveReferenceDeliveryDetailT_SampleTypeID = T_SampleTypeID
					JOIN m_sex ON T_ReceiveReferencePatientM_SexID = M_SexID
					WHERE	
						T_ReceiveReferenceDeliveryDetailT_ReceiveReferenceDeliveryID = {$id} AND T_ReceiveReferenceDeliveryDetailIsActive = 'Y'";
		//echo $sql;
		$rows = $this->db_onedev->query($sql)->result_array();
		return $rows;
		
   }
   
   public function search()
   {
      $prm = $this->sys_input;
		if (! $this->isLogin) {
			$this->sys_error("Invalid Token");
			exit;
		}

      $search = $prm["namelab"];
	  $status = $prm["stationid"];
	  $startdate = $prm["startdate"];
	  $enddate = $prm["enddate"];
	  
	  $sql_where = "WHERE T_ReceiveReferenceDeliveryStatus = '{$status}' AND ( T_ReceiveReferenceDeliveryDate BETWEEN '{$startdate} 00:00:00' AND '{$enddate} 23:59:59' ) AND T_ReceiveReferenceDeliveryIsActive = 'Y'";
	  
      //$sql_param = array();
      if ($search != "") {
         if ($sql_where != "") {
            $sql_where .=" and ";
         }
         $sql_where .= " ( T_ReceiveReferenceDeliveryNumber like '%$search%' ) ";
         //$sql_param[] = "%$nama%";
      }


      $sql = "	SELECT count(*) as total
				FROM t_receivereferencedelivery	
				JOIN m_company ON T_ReceiveReferenceDeliveryM_CompanyID = M_CompanyID
				LEFT JOIN m_staff ON T_ReceiveReferenceDeliveryM_StaffID = M_StaffID
				$sql_where
				";
		//echo $sql;
		$query = $this->db_onedev->query($sql);

		$tot_count = 0;
		if ($query) {
			$tot_count = $query->result_array()[0]["total"];
		} else {
			$this->sys_error_db("m_company count", $this->db_onedev);
			exit;
		}  
	  
		$sql = 	"SELECT t_receivereferencedelivery.*, IFNULL(M_StaffName,'-') as courier_name, 
				T_ReceiveReferenceDeliveryID as trx_id,
				T_ReceiveReferenceDeliveryNumber as trx_numbering,
				T_ReceiveReferenceDeliveryDate as trx_date,
				DATE_FORMAT(T_ReceiveReferenceDeliveryDate,'%d-%m-%Y') as trx_date_ina,
				T_ReceiveReferenceDeliveryNote as trx_note,
				T_ReceiveReferenceDeliveryStatus as status,
				M_CompanyName as company_fullname,
				'' as details,
				CASE
					WHEN T_ReceiveReferenceDeliveryStatus = 'CREATED' THEN 'BARU'
					WHEN T_ReceiveReferenceDeliveryStatus = 'RELEASEC'  THEN 'RILIS SURAT JALAN'
					WHEN T_ReceiveReferenceDeliveryStatus = 'RCVDOC'  THEN 'DITERIMA DOKTER'
					WHEN T_ReceiveReferenceDeliveryStatus = 'PARTDONE'  THEN 'SELESAI SEBAGIAN'
					ELSE 'SELESAI'
				END as status_name
				FROM t_receivereferencedelivery	
				JOIN m_company ON T_ReceiveReferenceDeliveryM_CompanyID = M_CompanyID
				LEFT JOIN m_staff ON T_ReceiveReferenceDeliveryM_StaffID = M_StaffID
				$sql_where
				ORDER BY T_ReceiveReferenceDeliveryID DESC
				limit 0,20";
		//echo $sql;
		$query = $this->db_onedev->query($sql);
		//echo $this->db_onedev->last_query();
		$rows = $query->result_array();
		if($rows){
			foreach($rows as $k => $v){				
				//$rows[$k]['companys'] = $this->getcompanys();
				$rows[$k]['details'] = $this->getdetails($v['T_ReceiveReferenceDeliveryID']);
				
			}
		}
	  
	  
		//$this->_add_address($rows);
		$result = array("total" => $tot_count, "records" => $rows, "sql"=> $this->db_onedev->last_query());
		$this->sys_ok($result);
		exit;
   }
   
   function getordersamples(){
	   $prm = $this->sys_input;
		if (! $this->isLogin) {
			$this->sys_error("Invalid Token");
			exit;
		}
		$prm = $this->sys_input;
		$companyid = $prm['companyid'];
	   $sql = "SELECT * FROM
	   (SELECT 0 as idx,
					M_SexName, 
					CONCAT(T_ReceiveReferencePatientName, '\n', '[',M_SexName,' | ',DATE_FORMAT(T_ReceiveReferencePatientDOB,'%d-%m-%Y'),']') as patient_fullname,
					T_SampleTypeName as samplename, 
					T_ReceiveReferencePatientNoRef as labnumberref,
					T_OrderHeaderLabNumber as labnumber, 
					T_ReceiveReferencePatientID as rpatientid,
					T_ReceiveReferencePatientT_ReceiveReferenceHeaderID as rheaderid,
					T_SampleTypeID as sampleid,
					'Y' as active,
					T_ReceiveReferenceDeliveryDetailID
					FROM t_receivereferenceheader
					LEFT JOIN t_receivereferencepatient ON T_ReceiveReferencePatientT_ReceiveReferenceHeaderID= T_ReceiveReferenceHeaderID AND  T_ReceiveReferencePatientIsActive = 'Y'
					LEFT JOIN t_orderheader ON T_ReceiveReferencePatientT_OrderHeaderID = T_OrderHeaderID
					LEFT JOIN t_receivereferencetest ON T_ReceiveReferenceTestT_ReceiveReferencePatientID = T_ReceiveReferencePatientID AND T_ReceiveReferenceTestIsActive = 'Y'
					LEFT JOIN t_test p ON T_ReceiveReferenceTestT_TestID = p.T_TestID
					join t_test c on c.T_TestSasCode like concat(p.T_TestSasCode,'%') and c.T_TestT_SampleTypeID > 1
					LEFT JOIN t_sampletype ON c.T_TestT_SampleTypeID = T_SampleTypeID
					LEFT JOIN m_sex ON T_ReceiveReferencePatientM_SexID = M_SexID
					LEFT JOIN t_receivereferencedeliverydetail ON T_ReceiveReferencePatientID = T_ReceiveReferenceDeliveryDetailT_ReceiveReferencePatientID AND T_ReceiveReferenceDeliveryDetailIsActive = 'Y'
					WHERE	
					T_ReceiveReferenceHeaderM_CompanyID = {$companyid} AND T_ReceiveReferenceHeaderIsActive = 'Y'
					AND T_ReceiveReferenceHeaderIsConfirm = 'Y'
					GROUP BY T_ReceiveReferencePatientID,T_SampleTypeID) a
					WHERE T_ReceiveReferenceDeliveryDetailID IS NULL";
		//echo $sql;
		$rows = $this->db_onedev->query($sql)->result_array();
		$result = array(
			"total" => count($rows) , 
			"records" => $rows, 
		); 
		$this->sys_ok($result);
		exit;
	   
   }
   
   function getstation(){
		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'
				";
				//echo $query;
		$rows['stations'] = $this->db_onedev->query($query)->result_array();
		//print_r($statuses);
		foreach($statuses as $k=>$v){
			array_push($rows['statuses'],$v);
		}

		$result = array(
			"total" => count($rows) , 
			"records" => $rows, 
		); 
		$this->sys_ok($result);
		exit;
	}
	
	function getcompanyaddress(){
		if (! $this->isLogin) {
			$this->sys_error("Invalid Token");
			exit;
		}
		$prm = $this->sys_input;
		$query ="	SELECT M_CompanyAddressID as id, M_CompanyAddressDescription as name
					FROM m_companyaddress 
					WHERE	
						M_CompanyAddressM_CompanyID = {$prm['id']} AND M_CompanyAddressIsActive = 'Y'
				";
				//echo $query;
		$rows = $this->db_onedev->query($query)->result_array();

		$result = array(
			"total" => count($rows) , 
			"records" => $rows, 
		); 
		$this->sys_ok($result);
		exit;
	}
	
	
   function save(){
		if (! $this->isLogin) {
			$this->sys_error("Invalid Token");
			exit;
		}
		$prm = $this->sys_input;
		$userid = $this->sys_user["M_UserID"];
		
		$xdate = date('Y-m-d',strtotime($prm["trx_date"]));
		if($prm['trx_id'] == '0' || $prm['trx_id'] == 0){
			$numbering = $this->db_onedev->query("SELECT fn_numbering('REF.DELIV') as numbering")->row()->numbering;
			$query ="INSERT INTO t_receivereferencedelivery (
						T_ReceiveReferenceDeliveryNumber,
						T_ReceiveReferenceDeliveryDate,
						T_ReceiveReferenceDeliveryNote,
						T_ReceiveReferenceDeliveryM_StaffID,
						T_ReceiveReferenceDeliveryM_CompanyID,
						T_ReceiveReferenceDeliveryCreated,
						T_ReceiveReferenceDeliveryUserID
					)
					VALUES(
						'{$numbering}',
						'{$xdate}',
						'{$prm['trx_note']}',
						'{$prm['courier']['id']}',
						'{$prm['company']['id']}',
						NOW(),
						'{$userid}'
					)
				";
			//echo $query;
			$saveheader = $this->db_onedev->query($query);
			$last_id = $this->db_onedev->insert_id();
		}else{
			$numbering = $this->db_onedev->query("SELECT T_ReceiveReferenceDeliveryNumber as numbering FROM t_receivereferencedelivery WHERE T_ReceiveReferenceDeliveryID = {$prm['trx_id']}")->row()->numbering;
			$query ="UPDATE t_receivereferencedelivery SET
						T_ReceiveReferenceDeliveryDate = '{$xdate}',
						T_ReceiveReferenceDeliveryNote = '{$prm['trx_note']}',
						T_ReceiveReferenceDeliveryM_StaffID = '{$prm['courier']['id']}',
						T_ReceiveReferenceDeliveryCreated = NOW(),
						T_ReceiveReferenceDeliveryUserID = '{$userid}'
					WHERE
						T_ReceiveReferenceDeliveryID = {$prm['trx_id']}
				";
			//echo $query;
			$saveheader = $this->db_onedev->query($query);
			$last_id = $prm['trx_id'];
		}
		
		if($saveheader){
			foreach($prm['details'] as $k => $v){
				if($v['active'] === 'Y' && ($v['idx'] == 0 || $v['idx'] == '0')){
					$query ="INSERT INTO t_receivereferencedeliverydetail (
								T_ReceiveReferenceDeliveryDetailT_ReceiveReferenceDeliveryID,
								T_ReceiveReferenceDeliveryDetailT_ReceiveReferenceHeaderID,
								T_ReceiveReferenceDeliveryDetailT_ReceiveReferencePatientID,
								T_ReceiveReferenceDeliveryDetailT_SampleTypeID,
								T_ReceiveReferenceDeliveryDetailCreated,
								T_ReceiveReferenceDeliveryDetailUserID
							)
							VALUES(
								'{$last_id}',
								'{$v['rheaderid']}',
								'{$v['rpatientid']}',
								'{$v['sampleid']}',
								 NOW(),
								'{$userid}'
							)";
							//echo $query;
							$savedetail = $this->db_onedev->query($query);
							$querystatus = "SELECT COUNT(*) as exist FROM g_receivereferenceheaderstatuslog WHERE G_ReceiveReferenceHeaderStatusLogIsActive = 'Y' AND G_ReceiveReferenceHeaderStatusLogT_ReceiveReferenceHeaderID = '{$v['rheaderid']}' AND G_ReceiveReferenceHeaderStatusLogM_StatusReferenceID = '4'";
							$exist_id =  $this->db_onedev->query($querystatus)->row()->exist;
							if($exist_id == 0){
								$querylog ="INSERT INTO g_receivereferenceheaderstatuslog (
									G_ReceiveReferenceHeaderStatusLogDate,
									G_ReceiveReferenceHeaderStatusLogT_ReceiveReferenceHeaderID,
									G_ReceiveReferenceHeaderStatusLogM_StatusReferenceID,
									G_ReceiveReferenceHeaderStatusLogM_UserID,
									G_ReceiveReferenceHeaderStatusLogUserID,
									G_ReceiveReferenceHeaderStatusLogCreated,
									G_ReceiveReferenceHeaderStatusLogLastUpdated
								)
								VALUES(
									NOW(),
									'{$v['rheaderid']}',
									'4',
									'{$userid}',
									'1',
									NOW(),
									NOW()
								)";
								//echo $querylog;
								$insert_new_log = $this->db_onedev->query($querylog);
							}								
							
				}
				
				if($v['active'] === 'Y' && ($v['idx'] != 0 || $v['idx'] != '0')){
					$query ="UPDATE t_receivereferencedeliverydetail SET
								T_ReceiveReferenceDeliveryDetailT_ReceiveReferenceDeliveryID = '{$last_id}',
								T_ReceiveReferenceDeliveryDetailT_ReceiveReferenceHeaderID = '{$v['T_ReceiveReferenceDeliveryDetailT_ReceiveReferenceHeaderID']}',
								T_ReceiveReferenceDeliveryDetailT_ReceiveReferencePatientID = '{$v['T_ReceiveReferenceDeliveryDetailT_ReceiveReferencePatientID']}',
								T_ReceiveReferenceDeliveryDetailT_SampleTypeID = '{$v['sampleid']}',
								T_ReceiveReferenceDeliveryDetailUserID = '{$userid}'
							WHERE
								T_ReceiveReferenceDeliveryDetailID = {$v['idx']}
							";
							//echo $query;
							$savedetail = $this->db_onedev->query($query);
				}
				
				if($v['active'] === 'N' && $v['idx'] != 0){
					$query ="UPDATE t_receivereferencedeliverydetail SET
								T_ReceiveReferenceDeliveryDetailIsActive = 'N',
								T_ReceiveReferenceDeliveryDetailUserID = '{$userid}'
							WHERE
								T_ReceiveReferenceDeliveryDetailID = {$v['idx']}
							";
							//echo $query;
							$savedetail = $this->db_onedev->query($query);
				}
			}
		}
		$result = array(
			"total" => 1 , 
			"records" => array('status'=>'OK'),
			"numbering" => $numbering,
			"id" => $last_id 
		); 
		$this->sys_ok($result);
		exit;
	}
	
	
	
   function deletetrx(){
		if (! $this->isLogin) {
			$this->sys_error("Invalid Token");
			exit;
		}
		$prm = $this->sys_input;
		$userid = $this->sys_user["M_UserID"];
		
		$query ="UPDATE t_receivereferencedelivery SET
					T_ReceiveReferenceDeliveryIsActive = 'N',
					T_ReceiveReferenceDeliveryUserID = '{$userid}'
				WHERE
					T_ReceiveReferenceDeliveryID = {$prm['trx_id']}
			";
		//echo $query;
		$saveheader = $this->db_onedev->query($query);
		$last_id = $prm['trx_id'];
		
		$result = array(
			"total" => 1 , 
			"records" => array('status'=>'OK'),
			"numbering" => $prm['trx_numbering'],
			"id" => $prm['trx_id']
		); 
		$this->sys_ok($result);
		exit;
	}
	
	
	function doaction(){
		if (! $this->isLogin) {
			$this->sys_error("Invalid Token");
			exit;
		}
		$prm = $this->sys_input;
		$userid = $this->sys_user["M_UserID"];
		
		if($prm['act'] == 'RELEASEC'){
			$sql = "UPDATE t_receivereferencedelivery SET 
						T_ReceiveReferenceDeliveryStatus = '{$prm['act']}',
						T_ReceiveReferenceDeliveryNote = '{$prm['trx_note']}',
						T_ReceiveReferenceDeliveryUserID = {$userid}
					WHERE
						T_ReceiveReferenceDeliveryID = {$prm['trx']['trx_id']}
					";
			$this->db_onedev->query($sql);

			$details = $prm['details'];
			foreach($details as $k => $v){
				$querystatus = "SELECT COUNT(*) as exist FROM g_receivereferenceheaderstatuslog WHERE G_ReceiveReferenceHeaderStatusLogIsActive = 'Y' AND G_ReceiveReferenceHeaderStatusLogT_ReceiveReferenceHeaderID = '{$v['T_ReceiveReferenceDeliveryDetailT_ReceiveReferenceHeaderID']}' AND G_ReceiveReferenceHeaderStatusLogM_StatusReferenceID = '5'";
							$exist_id =  $this->db_onedev->query($querystatus)->row()->exist;
							if($exist_id == 0){
								$querylog ="INSERT INTO g_receivereferenceheaderstatuslog (
									G_ReceiveReferenceHeaderStatusLogDate,
									G_ReceiveReferenceHeaderStatusLogT_ReceiveReferenceHeaderID,
									G_ReceiveReferenceHeaderStatusLogM_StatusReferenceID,
									G_ReceiveReferenceHeaderStatusLogM_UserID,
									G_ReceiveReferenceHeaderStatusLogUserID,
									G_ReceiveReferenceHeaderStatusLogCreated,
									G_ReceiveReferenceHeaderStatusLogLastUpdated
								)
								VALUES(
									NOW(),
									'{$v['T_ReceiveReferenceDeliveryDetailT_ReceiveReferenceHeaderID']}',
									'5',
									'{$userid}',
									'{$userid}',
									NOW(),
									NOW()
								)";
								//echo $querylog;
								$insert_new_log = $this->db_onedev->query($querylog);

			}
		}
	}
	if($prm['act'] === 'RCVLAB' ){
		$sql = "UPDATE t_receivereferencedelivery SET 
					T_ReceiveReferenceDeliveryStatus = '{$prm['act']}',
					T_ReceiveReferenceDeliveryNote = '{$prm['trx_note']}',
					T_ReceiveReferenceDeliveryUserID = {$userid}
				WHERE
					T_ReceiveReferenceDeliveryID = {$prm['trx']['trx_id']}
				";
		$this->db_onedev->query($sql);

		$details = $prm['details'];
		foreach($details as $k => $v){
			$querystatus = "SELECT COUNT(*) as exist FROM g_receivereferenceheaderstatuslog WHERE G_ReceiveReferenceHeaderStatusLogIsActive = 'Y' AND G_ReceiveReferenceHeaderStatusLogT_ReceiveReferenceHeaderID = '{$v['T_ReceiveReferenceDeliveryDetailT_ReceiveReferenceHeaderID']}' AND G_ReceiveReferenceHeaderStatusLogM_StatusReferenceID = '6'";
						$exist_id =  $this->db_onedev->query($querystatus)->row()->exist;
						if($exist_id == 0){
							$querylog ="INSERT INTO g_receivereferenceheaderstatuslog (
								G_ReceiveReferenceHeaderStatusLogDate,
								G_ReceiveReferenceHeaderStatusLogT_ReceiveReferenceHeaderID,
								G_ReceiveReferenceHeaderStatusLogM_StatusReferenceID,
								G_ReceiveReferenceHeaderStatusLogM_UserID,
								G_ReceiveReferenceHeaderStatusLogUserID,
								G_ReceiveReferenceHeaderStatusLogCreated,
								G_ReceiveReferenceHeaderStatusLogLastUpdated
							)
							VALUES(
								NOW(),
								'{$v['T_ReceiveReferenceDeliveryDetailT_ReceiveReferenceHeaderID']}',
								'6',
								'{$userid}',
								'{$userid}',
								NOW(),
								NOW()
							)";
							//echo $querylog;
							$insert_new_log = $this->db_onedev->query($querylog);

		}
	}
}
		if($prm['act'] === 'DONE'){
			$details = $prm['details'];
			$count_n = 0;
			foreach($details as $k => $v){
				if($v['flag_image_receive'] === 'N'){
					$count_n++;
				}
				if($v['flag_result_receive'] === 'N'){
					$count_n++;
				}
				$query ="UPDATE t_receivereferencedeliverydetail SET
								T_ReceiveReferenceDeliveryDetailFlagReceiveImage = '{$v['flag_image_receive']}',
								T_ReceiveReferenceDeliveryDetailFlagReceiveResult = '{$v['flag_result_receive']}',
								T_ReceiveReferenceDeliveryDetailUserID = '{$userid}'
					WHERE
						T_ReceiveReferenceDeliveryDetailID = {$v['idx']}
					";
					//echo $query;
				$savedetail = $this->db_onedev->query($query);
			}
			$status = 'DONE';
			if($count_n > 0){
				$status = 'PARTDONE';
			}
			$sql = "UPDATE t_receivereferencedelivery SET 
						T_ReceiveReferenceDeliveryStatus = '{$status}',
						T_ReceiveReferenceDeliveryNote = '{$prm['trx_note']}',
						T_ReceiveReferenceDeliveryUserID = {$userid}
					WHERE
						T_ReceiveReferenceDeliveryID = {$prm['trx']['trx_id']}
					";
			$this->db_onedev->query($sql);
		}
		
		if($prm['act'] == 'FORCEDONE'){
			$sql = "UPDATE t_receivereferencedelivery SET 
						T_ReceiveReferenceDeliveryNote = '{$prm['trx_note']}',
						T_ReceiveReferenceDeliveryStatus = 'DONE',
						T_ReceiveReferenceDeliveryUserID = {$userid}
					WHERE
						T_ReceiveReferenceDeliveryID = {$prm['trx']['trx_id']}
					";
			$this->db_onedev->query($sql);
		}

		$result = array(
			"total" => 1 , 
			"records" => array('status'=>'OK')
		); 
		$this->sys_ok($result);
		
		exit;
	}
	
   
   
}