<?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()
   {
      $prm = $this->sys_input;
      $max_rst = 10;

      //$sdate = $prm["start_date"] . '%';
      $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);
         }
      }

      // t_order_attachment
      $sql_attachment = "select T_OrderAttachmentName, T_OrderAttachmentType, T_OrderAttachmentUrl
      from t_order_attachment
      join t_orderheader
      ON T_OrderAttachmentT_OrderHeaderID = T_OrderHeaderID
      AND T_OrderAttachmentIsActive = 'Y'
      AND T_OrderHeaderIsActive = 'Y'
      AND T_OrderAttachmentT_OrderHeaderID in ( $order_ids )";

      $qry_attachment = $this->db_smartone->query($sql_attachment);
      if (!$qry_attachment) {
         $this->db_smartone->trans_rollback();
         $this->sys_error_db("select t_order_attachment ", $this->db_smartone);
         exit;
      }

      $extension_lab = "-";
      $extension_non_lab = "-";
      $lab_name = "-";
      $non_lab_name = "-";
      $lab_type = "-";
      $non_lab_type = "-";
      $lab_url = "-";
      $non_lab_url = "-";

      $row_attachment = $qry_attachment->result_array();
      if (count($row_attachment) > 0) {
         foreach ($row_attachment as $key => $value) {
            if ($value['T_OrderAttachmentType'] == "NonLab") {
               $non_lab_type = $value['T_OrderAttachmentType'];
               $non_lab_url = $value['T_OrderAttachmentUrl'];
               $non_lab_name = $value['T_OrderAttachmentName'];
               $extension = pathinfo(strtolower($non_lab_name), PATHINFO_EXTENSION);
               if ($extension === "pdf") {
                  $extension_non_lab = "pdf";
               } else {
                  if ($extension === "png" || $extension === "jpg" || $extension === "jpeg") {
                     $extension_non_lab = "image";
                  }
               }
            } else {
               if ($value['T_OrderAttachmentType'] == "Lab") {
                  $lab_type = $value['T_OrderAttachmentType'];
                  $lab_url = $value['T_OrderAttachmentUrl'];
                  $lab_name = $value['T_OrderAttachmentName'];
                  $extension = pathinfo(strtolower($lab_name), PATHINFO_EXTENSION);
                  if ($extension === "pdf") {
                     $extension_lab = "pdf";
                  } else {
                     if ($extension === "png" || $extension === "jpg" || $extension === "jpeg") {
                        $extension_lab = "image";
                     }
                  }
               }
            }
         }
      } else {
         $extension_lab = "-";
         $extension_non_lab = "-";
         $lab_name = "-";
         $non_lab_name = "-";
         $lab_type = "-";
         $non_lab_type = "-";
         $lab_url = "-";
         $non_lab_url = "-";
      }

      $sql = "SELECT *,
         CONCAT('[', GROUP_CONCAT(DISTINCT CONCAT('\"', T_OrderPromiseDateTime, '\"') SEPARATOR ','), ']') order_promise 
         FROM (
            select 
            BrnListBarcode,
            T_OrderHeaderAddOnBNR,
            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,
            IFNULL(userfo.M_UserUsername,'') as username_fo,
            IFNULL(usersample.M_UserUsername,'') as username_sample
            from t_orderheader
            JOIN t_orderheaderaddon ON T_OrderHeaderAddOnT_OrderHeaderID = T_OrderHeaderID
               AND T_OrderHeaderAddOnVerificationDone <> 'Y'
               AND T_OrderHeaderIsActive = 'Y'
               AND T_OrderHeaderID in ( $order_ids ) 
               {$q_company}
               AND T_OrderHeaderAddOnFOVerification = '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 {$q_search}
            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 brn_list ON T_OrderHeaderAddOnBNR = BrnListBarcode
            LEFT JOIN nat_lang lb ON T_OrderHeaderAddOnSecondM_LangID = lb.Nat_LangID
            LEFT JOIN m_user userfo ON T_OrderHeaderFoNoteM_UserID = userfo.M_UserID
            LEFT JOIN m_user usersample ON T_OrderHeaderSamplingNoteM_UserID = usersample.M_UserID
         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 = [];
         $arr_brn_have_lab = [];

         foreach ($rows as $k => $v) {
            if ($v['T_OrderHeaderAddOnBNR'] != "") {
               $arr_brn_have_lab[] = "'" . $v['T_OrderHeaderAddOnBNR'] . "'";
            }
            $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));
         }

         $arr_itf = [];

         if (count($arr_brn_have_lab) > 0) {
            $str_no_reg = implode(",", $arr_brn_have_lab);

            $sql_itf = "select Itf_ResultNoreg,
                group_concat(Itf_ResultKode) as result
                from itf_result
                WHERE Itf_ResultNoReg IN ($str_no_reg)
                GROUP BY Itf_ResultNoReg
            ";

            $query_itf = $this->db_onedev->query($sql_itf);
            if (!$query_itf) {
               $this->sys_error_db(
                  "Error Get Result "
               );
               exit;
            }

            $rows_itf = $query_itf->result_array();
            // print_r($rows_itf);
            // exit;

            foreach ($rows_itf as $key => $value) {
               $arr_itf[$value['Itf_ResultNoreg']] = $value['result'];
            }
         }

         foreach ($rows as $key => $value) {
            $brn = $value['T_OrderHeaderAddOnBNR'];

            if (isset($arr_itf[$brn])) {
               $rows[$key]['Itf'] = $arr_itf[$brn];
            } else {
               $rows[$key]['Itf'] = "";
            }
         }
         
         $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(),
            "attachment" => [
               "extension_lab" => $extension_lab,
               "extension_non_lab" => $extension_non_lab,
               "lab_name" => $lab_name,
               "non_lab_name" => $non_lab_name,
               "lab_type" => $lab_type,
               "non_lab_type" => $non_lab_type,
               "lab_url" => $lab_url,
               "non_lab_url" => $non_lab_url,
            ]
         );
         $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);
   }
}