<?php

class Re_patient extends MY_Controller
{
   var $db_smartone;

   public function index()
   {
      echo "RE Patient API";
   }

   public function __construct()
   {
      parent::__construct();
      $this->db_smartone = $this->load->database("onedev", true);
   }

   public function search()
   {
      if (! $this->isLogin) {
			$this->sys_error("Invalid Token");
			exit;
		}
      $prm = $this->sys_input;
      $max_rst = 10;

      $sdate = $prm["start_date"] . '%';
      $search = '%' . $prm["search"] . '%';
      $page = $prm['page'];
      $group_id = 0;
      if (isset($prm['group_id'])) $group_id = $prm['group_id'];

      $company_id = 0;
      $q_company = "";
      if (isset($prm['company_id'])) {
         $company_id = $prm['company_id'];
         if ($company_id > 0 ) {
            $q_company = " and T_OrderHeaderM_CompanyID = $company_id ";
         }
      }
      $q_search = " and 
            ( M_PatientName LIKE ?
            or T_OrderHeaderLabNumber like ?
            or T_OrderHeaderAddOnLabNumberOrigin like ?
            or T_OrderHeaderLabNumberExt like ?
            )";
      if ($prm["search"] == "" ) $q_search = "";
      if ($page == null)
         $page = 1;

      $offset = ($page - 1) * $max_rst;

      $max_rst = 9999;
      $offset = 0;

      $q_group = "";
      if ($group_id != 0 ) {
         $sql = "select T_WorklistDetailNat_TestID Nat_TestID 
            from t_worklistdetailv2
            where T_WorklistDetailT_WorklistID = $group_id
            ";
          $qry = $this->db_smartone->query($sql);
          $rows = $qry->result_array();
          $nat_test_ids = "0";
          foreach($rows as $r) {
             $nat_test_ids .= ", " . $r["Nat_TestID"];
          } 
          $q_group = " and T_TestNat_TestID in ( $nat_test_ids ) ";
      }

       //janji hasil hari ini T_OrderHeaderID  
        $sql = "select T_OrderPromiseT_OrderHeaderID 
         from t_orderpromise
         where T_OrderPromiseIsActive = 'Y' and date(T_OrderPromiseDateTime) = ?";
        $qry = $this->db_smartone->query($sql, array($sdate));
         $promise_ids = "0";
         if ($qry) {
            $xrows = $qry->result_array();
            if ( count($xrows) > 0 ) {
               $xids = array();
               foreach($xrows as $r) $xids[] = $r["T_OrderPromiseT_OrderHeaderID"];
               $promise_ids = join(",",$xids);
            }
         } 
        $sql = "select T_OrderHeaderID 
         from t_orderheader
         where T_OrderHeaderIsActive = 'Y' and date(T_OrderHeaderDate) = ?";
        $qry = $this->db_smartone->query($sql, array($sdate));
        $order_ids = $promise_ids;
        if ($qry) {
            $xrows = $qry->result_array();
            if ( count($xrows) > 0 ) {
               $xids = array();
               foreach($xrows as $r) $xids[] = $r["T_OrderHeaderID"];
               $order_ids .=  "," . join(",",$xids);
            }
         } 

      $sql = "SELECT *,
         CONCAT('[', GROUP_CONCAT(DISTINCT CONCAT('\"', T_OrderPromiseDateTime, '\"') SEPARATOR ','), ']') order_promise 
         FROM (
            select T_OrderHeaderID, T_OrderHeaderLabNumber, T_OrderHeaderDate,
            if(T_OrderHeaderAddOnLabNumberOrigin is null, T_OrderHeaderLabNumberExt, T_OrderHeaderAddOnLabNumberOrigin)
            T_OrderHeaderLabNumberExt, T_OrderHeaderDiagnose,
            M_PatientID, M_PatientNoReg, fn_global_patient_name(M_PatientID) M_PatientName,
            M_PatientDOB, T_OrderHeaderM_PatientAge, M_PatientHP, M_SexName, M_PatientNote,
            da.M_DoctorID doctor_pj_id, fn_global_doctor_name(da.M_DoctorID) doctor_pj_name,
            db.M_DoctorID doctor_sender_id, fn_global_doctor_name(db.M_DoctorID) doctor_sender_name,
            M_MouID, M_MouName, M_CompanyID, M_CompanyName,
            T_OrderHeaderFoNote, T_OrderHeaderSamplingNote, T_OrderHeaderResultNote, 
            la.Nat_LangID M_LangID, la.Nat_LangCode M_LangCode, la.Nat_LangName M_LangName, T_OrderHeaderLangIsSI,
            lb.Nat_LangID SecondM_LangID, lb.Nat_LangCode SecondM_LangCode, lb.Nat_LangName SecondM_LangName, 
            T_OrderHeaderAddOnSecondLangIsSI,
            T_OrderHeaderIsCito, fn_global_delivery_items(T_OrderHeaderID) as delivery,
            T_OrderPromiseDateTime, fn_process_history(T_OrderHeaderID) is_history,
            T_OrderHeaderAddOnVerificationDone,
            T_OrderHeaderAddOnValidationDone, T_OrderHeaderAddOnRequestChangeDOB
            from t_orderheader
            JOIN t_orderheaderaddon ON T_OrderHeaderAddOnT_OrderHeaderID = T_OrderHeaderID
               and T_OrderHeaderAddOnVerificationDone <> 'Y'
            JOIN t_orderpromise ON T_OrderPromiseT_OrderHeaderID = T_OrderHeadeRID and T_OrderPromiseIsActive = 'Y'
            JOIN t_orderdetail ON T_OrderHeaderID = T_OrderDetailT_OrderHeaderID AND T_OrderDetailIsActive = 'Y'
            JOIN t_test ON T_OrderDetailT_TestID = T_TestID
               {$q_group}
            JOIN group_resultdetail ON Group_ResultDetailT_TestID = T_TestID AND Group_ResultDetailIsActive = 'Y' 
			JOIN group_result ON Group_ResultDetailGroup_ResultID = Group_ResultID AND Group_ResultFlagNonLab = 'N'
            join m_patient on T_OrderHeaderM_PatientID = M_PatientID
            left join m_doctor da on T_OrderHeaderPJM_DoctorID = da.M_DoctorID
            join m_doctor db on T_OrderHeaderSenderM_DoctorID = db.M_DoctorID
            JOIN m_company on T_OrderHeaderM_CompanyID = M_CompanyID
            JOIN m_mou on T_OrderHeaderM_MouID = M_MouID
            JOIN m_sex on M_PatientM_SexID = M_SexID

            JOIN nat_lang la ON T_OrderHeaderM_LangID = la.Nat_LangID
            LEFT JOIN nat_lang lb ON T_OrderHeaderAddOnSecondM_LangID = lb.Nat_LangID
            where T_OrderHeaderIsActive = 'Y'
            and T_OrderHeaderID in ( $order_ids ) 
            {$q_company}
            {$q_search}
         AND T_OrderHeaderAddOnFOVerification = 'Y'
         order by FIELD(T_OrderHeaderIsCito, 'Y', 'N') ASC,  T_OrderHeaderLabNumber 
      ) x
      GROUP BY T_OrderHeaderID
      order by FIELD(T_OrderHeaderIsCito, 'Y', 'N') ASC,  T_OrderHeaderLabNumber 
      ";
      if ($q_search == "" ) {
         $query = $this->db_smartone->query($sql);
      } else {
         $query = $this->db_smartone->query($sql, [ $search, $search, $search,$search ]);
      }
	  // echo $this->db_smartone->last_query();
      if ($query) { 
         $rows = $query->result_array();
         $tmp_ohnumber = [];
         foreach ($rows as $k => $v)
         {
            $lang = [["id"=>0, "code"=>"ID", "is_si"=>"N"]];
            if ($v['M_LangCode'] != "ID")
               $lang[] = ["id"=>$v['M_LangID'], "code"=>$v['M_LangCode'], "is_si"=>$v['T_OrderHeaderLangIsSI']];

            $rows[$k]['data'] = json_decode($v['data']);
            $rows[$k]['lang'] = $lang;
            $rows[$k]['delivery'] = JSON_DECODE($v['delivery']);
            $rows[$k]['order_promise'] = JSON_DECODE($v['order_promise']);

            foreach($rows[$k]['order_promise'] as $l => $w)
               $rows[$k]['order_promise'][$l] = date('d-m-Y H:i', strtotime($w));
         }
         $tot_count = count( $rows );
         $result = array("total" => $tot_count, 
            "total_page" => ceil($tot_count/$max_rst), 
            "cur_page" => $page, 
            "records" => $rows, 
            "total_display" => sizeof($rows), 
            "q" => $this->db_smartone->last_query());
         $this->sys_ok($result);
      } 
      else {
         $this->sys_error_db("worklist rows", $this->db_smartone);
         exit;
      }
   }

   public function history()
   {
      $prm = $this->sys_input;

      // QUERY TOTAL
      $sql = "CALL sp_process_result_history(?)";
      $query = $this->db_smartone->query($sql, [$prm['order_id']]);

      if ($query) 
      {
         $row = $query->row();
         $history = json_decode($row->rst);

         $this->sys_ok($history);
      } 
      else 
      {
         $this->sys_error_db("RESULT HISTORY", $this->db_smartone);
         exit;
      }
   }

   public function save_note()
   {
      $prm = $this->sys_input;

      $sql = "UPDATE t_orderheader SET T_OrderHeaderResultNote = ?, T_OrderHeaderResultNoteM_UserID = ?
         WHERE T_OrderHeaderID = ?";
      $query = $this->db_smartone->query($sql, [$prm['note'], $this->sys_user['M_UserID'], $prm['order_id']]);
      if ($query)
      {
         $this->sys_ok($prm['order_id']);
         exit;
      }

      $this->sys_error_db("RESULT NOTE", $this->db_smartone);
   }

   public function info_req()
   {
      $prm = $this->sys_input;

      $sql = "CALL sp_process_result_reqs(?)";
      $query = $this->db_smartone->query($sql, [$prm['order_id']]);
      if ($query)
      {
         $row = $query->row();
         $s_data = $row->data;
         $s_data = str_replace("\n"," ",$s_data); 
         $this->sys_ok(json_decode($s_data));
         exit;
      }

      $this->sys_error_db("RESULT REQ", $this->db_smartone);
   }
}