<?php
class Done extends MY_Controller
{
   var $db_onedev;
   public function index()
   {
      echo "SampleStorage API";
   }
   
   public function __construct()
   {
      parent::__construct();
      $this->db_onedev = $this->load->database("onedev", true);
   }
   
    public function search()
   {
      $prm = $this->sys_input;
		if (! $this->isLogin) {
			$this->sys_error("Invalid Token");
			exit;
		}

      $nolab = $prm["nolab"];
	  $groupid = $prm["groupid"];
	  //$subgroupid = $prm["subgroupid"];
	  $join_group = '';
	  if($groupid != '0'){
		   $join_group = "JOIN nat_group ON T_TestNat_GroupID = Nat_GroupID AND Nat_GroupID = {$groupid}";
	  }
	  /*$join_subgroup = '';
	  if($subgroupid != 0){
		   $join_group = "JOIN nat_subgroup ON T_TestNat_SubgroupID = Nat_SubgroupID AND Nat_SubgroupID = {$subgroupid}";
	  }*/
	 
	  if(!isset($prm['current_page']))
		  $prm['current_page'] = 1;
	  
	  $sql_where = "WHERE Result_CourierStatus = 'S' AND JSON_CONTAINS(Result_COurierIds,T_OrderDetailID)";
	  $number_limit = 10;
	  $number_offset = ($prm['current_page'] - 1) * $number_limit ;
      //$sql_param = array();
      if ($nolab != "" ) {
         if ($sql_where != "") {
            $sql_where .=" and ";
         }
         $sql_where .= " ( T_OrderHeaderLabNumber like '%$nolab%' OR M_PatientName like '%$nolab%' )";
      }
	  
	  /*if ($nama != "") {
         if ($sql_where != "") {
            $sql_where .=" and ";
         }
         $sql_where .= " M_PatientName like '%$nama%' ";
      }*/
	  
		$sql = 	"SELECT Result_CourierID as xid,
					T_OrderHeaderID as orderid,
					T_OrderHeaderLabNumber as ordernumber,
					UPPER(CONCAT(M_TitleName,' ',M_PatientName)) as patient_fullname,
					Result_CourierT_TestName as test_name,
					'N' as chex
				FROM result_courier
				join t_orderheader ON Result_CourierT_OrderHeaderID = T_OrderHeaderID
				JOIN t_orderdetail ON T_OrderDetailT_OrderHeaderID = T_OrderHeaderID
				JOIN t_test ON T_OrderDetailT_TestID = T_TestID AND JSON_CONTAINS(Result_CourierIds, T_OrderDetailID)
				$join_group
				JOIN m_patient ON T_OrderHeaderM_PatientID = M_PatientID
				JOIN m_sex ON M_PatientM_SexID = M_SexID
				LEFT JOIN m_title ON M_PatientM_TitleID = M_TitleID
				$sql_where
				GROUP BY Result_CourierID
		";
		//echo $sql;
		$query = $this->db_onedev->query($sql);
		$rows = $query->result_array();
		foreach($rows as $k => $v){
			if($v['chex'] == 'N')
				$rows[$k]['chex'] = false;
			else
				$rows[$k]['chex'] = true;
		}
		
		$result = array("total" => count($rst), "records" => $rows, "sql"=> '');
		$this->sys_ok($result);
		exit;
   }
   
   function getkerajaan(){
	   if (! $this->isLogin) {
			$this->sys_error("Invalid Token");
			exit;
		}
		
		//$rst = array(array('id'=>0,'name'=>'Semua'));
		
		$sql = "SELECT 0 as id, 'Semua' as name UNION SELECT Nat_GroupID as id, Nat_GroupName as name FROM nat_group WHERE Nat_GroupIsActive = 'Y'";
		$rst_db = $this->db_onedev->query($sql)->result_array();
		//$c = array_combine($rst,$rst_db);

		$result = array(
			"total" => 1 , 
			"records" => $rst_db
		); 
		$this->sys_ok($result);
		exit;
   }
   
   function dosend(){
	   if (! $this->isLogin) {
			$this->sys_error("Invalid Token");
			exit;
		}
		$prm = $this->sys_input;
		$userid = $this->sys_user['M_UserID'];
		$selected = $prm['selected'];
		
			foreach($selected as $k => $v){
			$sql = "UPDATE result_frontoffice SET Result_FrontOfficeStatus = 'R' WHERE Result_FrontOfficeID = {$v['xid']}";
			$this->db_onedev->query($sql);
			}
		
		
		

		$result = array(
			"total" => 1 , 
			"records" => array('status'=>'OK'), 
		); 
		$this->sys_ok($result);
		exit;
   }
   
   
   function sendemail(){
	   
    try {
        //# cek token valid
        if (! $this->isLogin) {
			$this->sys_error("Invalid Token");
			exit;
        }
		
		$prm = $this->sys_input;
		$userid = $this->sys_user['M_UserID'];
		$rows = array();
		$ids = "(".$prm['ids'].")";
		$sql = "UPDATE result_sendemail SET Result_SendEmailStatus = 'S', Result_SendEmailUserID = {$userid} WHERE Result_SendEmailID IN {$ids}";
		//echo $sql;
		$this->db_onedev->query($sql);
		$sql = "SELECT * FROM result_sendemail WHERE Result_SendEmailID IN {$ids}";
		$dt_rst = $this->db_onedev->query($sql)->result_array();
		foreach($dt_rst as $k => $v){
			$dt_log = json_encode($v);
			$sql = "INSERT INTO one_log.log_resultsendemail (
						Log_ResultSendEmailDatetime,
						Log_ResultSendEmailJson,
						Log_ResultSendEmailUserID
					)
					VALUES(
						NOW(),
						'{$dt_log}',
						{$userid}
					)";
			$this->db_onedev->query($sql);
		}
		
		$result = array ("total" => 0, "records" => $rows);
		$this->sys_ok($result);
    } catch(Exception $exc) {
        $message = $exc->getMessage();
        $this->sys_error($message);
	}
   }
   
   function updateemail(){
	   
    try {
        //# cek token valid
        if (! $this->isLogin) {
			$this->sys_error("Invalid Token");
			exit;
        }
		
		$prm = $this->sys_input;
		$userid = $this->sys_user['M_UserID'];
		$rows = array();
		$id = $prm['id'];
		$sql = "UPDATE t_orderdelivery SET T_OrderDeliveryDestination = '{$prm['edited_email']}', T_OrderDeliveryUserID = {$userid} WHERE T_OrderDeliveryID = {$id}";
		//echo $sql;
		$this->db_onedev->query($sql);
		
		$result = array ("total" => 0, "records" => array());
		$this->sys_ok($result);
    } catch(Exception $exc) {
        $message = $exc->getMessage();
        $this->sys_error($message);
	}
   }
   
}