<?php
namespace App\Controllers;

use CodeIgniter\RESTful\ResourceController;
use CodeIgniter\I18n\Time;

class API_Requests extends ResourceController {
	
	public function requests() {
		$db = \Config\Database::connect();
		$raw = $this->request->getVar();
		
		// log to cm_tm_logs
		$data = json_encode($raw);
		$sql = "INSERT INTO cmod.dbo.CM_TM_LOGS (URL, METHOD, BODY, LOGDATE) VALUES ('API/REQUESTS', 'POST', '$data', GETDATE())";
		$db->query($sql);
		
		$data = array();
		$qdata = (array)$raw;
		$qpat = (array)$qdata['patient'];
		
		//patdata
		$rm = $qpat['rm_number'];
		$firstname = $qpat['patient_first_name'];
		$lastname = $qpat['patient_last_name'];
		$dob = $qpat['patient_dob'];
		$sex = $qpat['patient_sex'];
		$phone = $qpat['patient_phone'];
		
		$sql = "select PATID from cmod.dbo.CM_TM_PATIENTS where PATNUMBER='$rm'";
		$query = $db->query($sql);
		$results = $query->getResultArray();
		if(!isset($results[0])) { 
			$sql = "INSERT INTO cmod.dbo.CM_TM_PATIENTS (PATNUMBER, FIRSTNAME, LASTNAME, BIRTHDATE, SEX, PHONE ) VALUES ('$rm', '$firstname', '$lastname', '$dob', '$sex', '$phone' )"; 
			$db->query($sql);
			$patid = $db->insertID();
		} else { 
			$patid = $results[0]['PATID'];
			$sql = "UPDATE cmod.dbo.CM_TM_PATIENTS SET FIRSTNAME='$firstname', LASTNAME='$lastname', BIRTHDATE='$dob', SEX='$sex', PHONE='$phone' where PATID='$patid'"; 
			$db->query($sql);
		}
		
		//reqdata
		$reffid = $qdata['reference_id'];
		$visitnum = $qpat['visit_number'];
		$visitdesc = $qpat['visit_description'];
		$visitdt = $qpat['visit_date_time'];
		$agent = $qpat['agent'];
		$agentname = $qpat['agent_name'];
		$visittype = $qpat['visit_type'];
		$company_name = $qdata['company_name'];
		$loc = $qdata['branch'];
		$doc = $qpat['treating_doctor'];
		$createdt = $qdata['created'];
		/*
		$time = Time::createFromFormat('Y-m-d\TH:i:s.u\Z', $utcdt, 'UTC'); //2024-10-19T00:47:06.424654Z
		$time = $time->setTimezone('Asia/Shanghai');
		$orderdt = $time->toDateTimeString();	
		*/
		$sql = "select REQID from cmod.dbo.CM_TM_REQUESTS where REFFID='$reffid'";
		$query = $db->query($sql);
		$results = $query->getResultArray();
		if(!isset($results[0])) { 
			$sql = "INSERT INTO cmod.dbo.CM_TM_REQUESTS (REFFID, REQNUMBER, REQDESC, REQTYPE, REQDATE, AGENT, DOC, LOC, PATID, COMPANY, ISTAKEN, LOGDATE) VALUES ('$reffid', '$visitnum', '$visitdesc', '$visittype', '$visitdt', '$agentname', '$doc', '$loc', '$patid', '$company_name', null, '$createdt' )"; 
			$db->query($sql);
			$reqid = $db->insertID();
		} else { 
			$reqid = $results[0]['REQID'];
			$sql = "UPDATE cmod.dbo.CM_TM_REQUESTS SET REQNUMBER='$visitnum', REQDESC='$visitdesc', REQTYPE='$visittype', REQDATE='$visitdt', AGENT='$agentname', DOC='$doc', LOC='$loc', PATID='$patid' where REQID='$reqid'"; 
			$db->query($sql);
		}	
		
		// tests
		$tests = json_decode(json_encode($qpat['tests']), true);;
		$string = '';
		foreach($tests as $test) {
			$testcode = $test['service_id'];
			$testreffid = $test['test_ref_id'];
			if(isset($test['status'])) { $teststatus = $test['status'];}
			else { $teststatus = ''; }
			$string .= "( '$testreffid', '$reqid', '$testcode', '$teststatus' ),";
		}
		$string = rtrim($string, ',');
		//$sql = "INSERT INTO cmod.dbo.CM_TM_TESTS(REFFID, REQID, HISCODE) VALUES $string";
		$sql = "INSERT INTO cmod.dbo.CM_TM_TESTS (REFFTESTID, REQID, HISCODE, TESTSTATUS) 
			SELECT S.REFFTESTID, S.REQID, S.HISCODE, S.TESTSTATUS FROM ( VALUES $string ) AS S (REFFTESTID, REQID, HISCODE, TESTSTATUS)
			WHERE NOT EXISTS ( SELECT 1 FROM cmod.dbo.CM_TM_TESTS T WHERE T.REQID = S.REQID AND T.HISCODE = S.HISCODE );";
		$db->query($sql);

		$sql = "UPDATE cmod.dbo.CM_TM_TESTS SET TESTSTATUS = S.TESTSTATUS
			FROM cmod.dbo.CM_TM_TESTS T
			INNER JOIN ( VALUES $string ) AS S (REFFTESTID, REQID, HISCODE, TESTSTATUS)
			ON T.REQID = S.REQID AND T.HISCODE = S.HISCODE;";
		$db->query($sql);
		
		
		return $this->respond(201);
		/*
		if( $db->query($sql) )  {
			return $this->respond(201);
		} else {
			$response = [
				'errors' => $db->errors(), 'message' => 'Invalid Messages'
			];
	       return $this->fail($response , 409);
        }
		*/
	}
	
	public function orm($reqid) {
		$db = \Config\Database::connect();
		$sql = "select r.REFFID, r.LOC, p.PATNUMBER, p.FIRSTNAME, p.LASTNAME, p.BIRTHDATE, p.SEX, r.REQNUMBER, r.REQDATE, r.AGENT, r.DOC
		from cmod.dbo.CM_TM_REQUESTS r
		left join cmod.dbo.CM_TM_PATIENTS p on p.PATID=r.PATID
		where r.REQID='$reqid'";
		$query = $db->query($sql);
		$results = $query->getResultArray();
		$res = $results[0];
		
		$reffid = $res['REFFID'];
		$patnumber = $res['PATNUMBER'];
		$loc = $res['LOC'];
		$firstname = $res['FIRSTNAME'];
		$lastname = $res['LASTNAME'];
		$dob = $res['BIRTHDATE'];
		$sex = $res['SEX'];
		$hosp = $res['REQNUMBER'];
		$reqdate = $res['REQDATE'];
		$time = Time::createFromFormat('Y-m-d\TH:i:s.u\Z', $reqdate, 'UTC'); //2024-10-19T00:47:06.424654Z
		// Denpasar
		$time = $time->setTimezone('Asia/Shanghai');
		$reqdate= date_format($time, 'YmdHi');	
		$agent = $res['AGENT'];
		$doc = $res['DOC'];
		$orm = "MSH|^~\&|PBMC|TM|TDNL||||ORM^O01^|||2.3||||\r";
		$orm .= "PID|1||$patnumber^^^^PATNUMBER||$firstname^$lastname^^^^^L||$dob|$sex||^|^^||||||^||||||||||||||||\r";
		$orm .= "PV1|||$loc^^^||||$doc|$doc||||||||||||||||||||||||||||||||||||$reqdate||||||||||\r";
		#$orm += 
		
		$sql = "select t.TESTSTATUS, m.LISCODE from cmod.dbo.CM_TM_TESTS t
			left join cmod.dbo.CM_DICT_MAPPINGS m on m.HISCODE=t.HISCODE
			where t.REQID='$reqid'";
		$query = $db->query($sql);
		$results = $query->getResultArray();
		$i = 1;
		foreach($results as $qdata) {
			$liscode = $qdata['LISCODE'];
			$status = $qdata['TESTSTATUS'];
			if($liscode != '') {
				if($status!=1 || $status !=2) {$status="NW";} else {$status="CA";}
				$orm .= "ORC|$status|$reffid||$reffid|||^^^$reqdate|||||$loc|$doc||$reqdate|||||||||\r";
				$orm .= "OBR|$i|||$liscode|||||||R|||$reqdate||$loc|||||||||||^^^^^R||||||||||||||\r";
				$i++;
			}
		}
		
		echo "<pre>$orm \r";
		
		/*
		MSH|^~\&|LISTHOST|LISTHOST.SEND|||202501171415||ORM^O01|01250101080|P|2.3
		PID|||0111126100014955^^^^PATNUMBER||TJOENG VINCENTIUS MINARDI, MR^^^^^^L||19611211|M|||GRAHA FAMILY PP-9^^SURABAYA||0811300341^^TELEPHON~^^TELEPHON2~^^FAX~^^EMAIL^BERTINAMARTEN@GMAIL.COM|||||||||||||||||||
		PV1|||WALK^2^^||||L0038|L0038||||||||||||||||||||||||||||||||||||202501171102||||||||||
		ORC|CA|01250101080||01250101080|||^^^202501170000|||||L0038|WALK||202501171102|||||||||
		OBR|1|||16549^^Konsultasi dr.Nunki|||||||R|||202501171102||L0038|||||||||||^^^^^R||||||||||||||	

		MSH|^~\&|RSML|HOST|TD-Synergy|202501201926|||ORM^O01||||||||||||
		PID|||75.91.81^^^^PATNUMBER||Kasiyani Ny^^^^^^L||19480806|F|||Sumberwudi RT5 RW2 Sumberwudi Karanggeneng Lamonga^^^^^||^^~^^||||||||||||||
		NTE|||Tamise Ny/Kardiyo Tn
		PV1|||IGD||||1644||||||||||||2596973|||||||||||||||||||||||||202501201926||||||||
		ORC|NW|||1319798|||^^^202501201926|||||1644|IGD||||202501201926||||||||
		NTE|||-
		NTE|||Candra Dewi K. dr. Sp.PK
		NTE|||
		OBR|1|||UREA||||||||||||||||||||||||||||||||||||
		ORC|NW|||1319798|||^^^202501201926|||||1644|IGD||||202501201926||||||||
		OBR|2|||CL||||||||||||||||||||||||||||||||||||
		ORC|NW|||1319798|||^^^202501201926|||||1644|IGD||||202501201926||||||||
		OBR|3|||AGDG||||||||||||||||||||||||||||||||||||
		ORC|NW|||1319798|||^^^202501201926|||||1644|IGD||||202501201926||||||||
		OBR|4|||GGPH||||||||||||||||||||||||||||||||||||
		
		MSH|^~\&|PBMC|TM|TDNL||||ORM^O01^|||2.3||||
		PID|1||^^^^PATNUMBER||^^^^^^L|||||^|^^||||||^||||||||||||||||
		PV1|1||||||||||||||||||||||||||||||||||||||||||||
		ORC|NW||||||^^^|||||||||||||
		OBR|||||||||||||||||||||||||||^^^^^R|
		
		var reqid = msg['reqid'].toString();
		var reffid = msg['reffid'].toString();
		var reqnumber = msg['reqnumber'].toString();
		var patnumber = msg['patnumber'].toString();
		var loc = msg['loc'].toString();
		var doc = msg['doc'].toString();
		var firstname = msg['firstname'].toString();
		var lastname = msg['lastname'].toString();
		var birthdate = msg['birthdate'].toString();
		var sex = msg['sex'].toString();
		sex = sex.substr(0,1);
		var reqdate = msg['reqdate'].toString();
		var agent = msg['agent'].toString();

		curdate = DateUtil.getCurrentDate('yyyyMMddHHmm'); 
		if(loc=='PBMC Bali') { 
			location = 'PADMA'; doctor='PBDPS'; 
		} else { 
			location = 'PBSBY'; doctor='PBSBY'; 
			curdate = curdate-100;
		}

		//DOB
		var DOB = birthdate;
		DOB=DOB.substr(0,4)+DOB.substr(5,2)+DOB.substr(8,2);
		tmp['PID']['PID.7']['PID.7.1'] = DOB;

		//ADT
		tmp['MSH']['MSH.9']['MSH.9.1'] = 'ADT';
		tmp['MSH']['MSH.9']['MSH.9.2'] = 'A08';
		tmp['MSH']['MSH.7']['MSH.7.1'] = curdate;//timestamp
		tmp['PV1']['PV1.44']['PV1.44.1'] = curdate;//admitdatetime
		tmp['PID']['PID.3']['PID.3.1'] = patnumber;//patnum 
		tmp['PID']['PID.5']['PID.5.1'] = firstname;//firstname
		tmp['PID']['PID.5']['PID.5.2'] = lastname;//lastname
		tmp['PID']['PID.7']['PID.7.1'] = DOB;//Date of Birth
		tmp['PID']['PID.8']['PID.8.1'] = sex.toUpperCase();//sex

		tmp['PV1']['PV1.3']['PV1.3.1'] = location;//lokasi
		tmp['PV1']['PV1.7']['PV1.7.1'] = doctor;//dokter
		tmp['PV1']['PV1.8']['PV1.8.1'] = doctor;//dokter
		tmp['PV1']['PV1.19']['PV1.19.1'] = reqnumber;
		tmp['ORC']['ORC.2']['ORC.2.1'] = reffid;
		tmp['ORC']['ORC.4']['ORC.4.1'] = reffid;
		tmp['ORC']['ORC.7']['ORC.7.4'] = curdate;//coldatetime
		tmp['ORC']['ORC.12']['ORC.12.1'] = doctor;//dokter
		tmp['ORC']['ORC.13']['ORC.13.1'] = location;//lokasi
		tmp['ORC']['ORC.15']['ORC.15.1'] = curdate;//timestamp

		//var ADT = '<HL7Message>'+tmp['MSH']+tmp['PID']+tmp['PV1']+'</HL7Message>';
		//logger.info(ADT);
		//ADT = SerializerFactory.getSerializer('HL7V2').fromXML(ADT);
		//channelMap.put('ADT',ADT);

		//ORM
		tmp['MSH']['MSH.9']['MSH.9.1'] = 'ORM';
		tmp['MSH']['MSH.9']['MSH.9.2'] = 'O01';
		tmp['MSH']['MSH.10']['MSH.10.1'] = reffid;

		var sql = "select t.*, m.LISCODE from cmod.dbo.CM_TM_TESTS t"+
			" left join cmod.dbo.CM_DICT_MAPPINGS m on m.HISCODE=t.HISCODE"+
			" where t.REQID='"+reqid+"'";
		var results = dbConn.executeCachedQuery(sql);

		var i=0;
		var obr = tmp['OBR'];
		var orc = tmp['ORC'];

		while(results.next()) {
			var testcode=results.getString('LISCODE');
			var status = results.getString('TESTSTATUS');
			if(testcode != '' && testcode != null) {
				tmp['ORC'][i]=orc;
				if(status == '1' || status == '2') {
					tmp['ORC'][i]['ORC.1']['ORC.1.1']="CA";
				} else {
					tmp['ORC'][i]['ORC.1']['ORC.1.1']="NW";
				}
				tmp['OBR'][i]=obr;
				tmp['OBR'][i]['OBR.1']['OBR.1.1']=i+1;
				tmp['OBR'][i]['OBR.4']['OBR.4.1']=testcode;
				tmp['OBR'][i]['OBR.14']['OBR.14.1']=curdate;
				tmp['OBR'][i]['OBR.16']['OBR.16.1']=doctor;
				tmp['OBR'][i]['OBR.27']['OBR.27.6']='R';
			
				i++;
			}
		}
		*/
		
		
	}
}