From 0c2b01f800194cd036488168141dff9409d806a4 Mon Sep 17 00:00:00 2001
From: mahdahar <89adham@gmail.com>
Date: Tue, 21 Jan 2025 09:32:37 +0700
Subject: [PATCH] second commit for sendormphp

---
 app/Controllers/API_Requests.php | 206 ++++++++++++-------------------
 1 file changed, 76 insertions(+), 130 deletions(-)

diff --git a/app/Controllers/API_Requests.php b/app/Controllers/API_Requests.php
index 2e4c3cf..e0a53b9 100644
--- a/app/Controllers/API_Requests.php
+++ b/app/Controllers/API_Requests.php
@@ -24,6 +24,7 @@ class API_Requests extends ResourceController {
 		$firstname = $qpat['patient_first_name'];
 		$lastname = $qpat['patient_last_name'];
 		$dob = $qpat['patient_dob'];
+		$dob = str_replace("-","",$dob);
 		$sex = $qpat['patient_sex'];
 		$phone = $qpat['patient_phone'];
 		
@@ -61,12 +62,12 @@ class API_Requests extends ResourceController {
 		$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' )"; 
+			$sql = "INSERT INTO cmod.dbo.CM_TM_REQUESTS (REFFID, REQNUMBER, REQDESC, REQTYPE, REQDATE, AGENT, DOC, LOC, PATID, COMPANY, LOGDATE) VALUES ('$reffid', '$visitnum', '$visitdesc', '$visittype', '$visitdt', '$agentname', '$doc', '$loc', '$patid', '$company_name', '$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'"; 
+			$sql = "UPDATE cmod.dbo.CM_TM_REQUESTS SET REQNUMBER='$visitnum', REQDESC='$visitdesc', REQTYPE='$visittype', REQDATE='$visitdt', AGENT='$agentname', DOC='$doc', LOC='$loc', PATID='$patid', LOGDATE='$createdt' where REQID='$reqid'"; 
 			$db->query($sql);
 		}	
 		
@@ -107,6 +108,63 @@ class API_Requests extends ResourceController {
 		*/
 	}
 	
+	function sendHL7Message($host, $port, $message, $timeout = 5) {
+		try {
+			// Create a TCP/IP socket
+			$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
+			if ($socket === false) {
+				throw new Exception("socket_create() failed: " . socket_strerror(socket_last_error()));
+			}
+
+			// Set socket options (timeout)
+			socket_set_option($socket, SOL_SOCKET, SO_RCVTIMEO, array("sec" => $timeout, "usec" => 0));
+			socket_set_option($socket, SOL_SOCKET, SO_SNDTIMEO, array("sec" => $timeout, "usec" => 0));
+
+			// Connect to the remote host
+			$result = socket_connect($socket, $host, $port);
+			if ($result === false) {
+				throw new Exception("socket_connect() failed: " . socket_strerror(socket_last_error($socket)));
+			}
+
+			// Add MLLP framing (Minimal Lower Layer Protocol)
+			$mllpMessage = chr(0x0B) . $message . chr(0x1C) . chr(0x0D);
+
+			// Send the message
+			$bytesSent = socket_write($socket, $mllpMessage, strlen($mllpMessage));
+			if ($bytesSent === false) {
+				throw new Exception("socket_write() failed: " . socket_strerror(socket_last_error($socket)));
+			}
+			if($bytesSent != strlen($mllpMessage)){
+				throw new Exception("socket_write() only sent $bytesSent bytes out of ". strlen($mllpMessage));
+			}
+
+			// Read the acknowledgement (optional but recommended)
+			$ack = socket_read($socket, 8192); // Adjust buffer size as needed
+			if ($ack === false) {
+				// Handle cases where no ACK is received within the timeout
+				throw new Exception("socket_read() failed or timed out: " . socket_strerror(socket_last_error($socket)));
+			}
+
+			//Close the socket
+			socket_close($socket);
+
+			//Basic ACK check. More robust parsing is recommended.
+			if (strpos($ack, "MSA") !== false) {
+				return true; // Success (basic ACK check)
+			} else {
+				error_log("Unexpected ACK: " . $ack); // Log the unexpected ACK
+				return false; // Failure (unexpected ACK)
+			}
+
+		} catch (Exception $e) {
+			error_log("HL7 Sending Error: " . $e->getMessage()); // Log the error
+			if(isset($socket)){
+				socket_close($socket); // Ensure socket closure on error
+			}
+			return false; // Indicate failure
+		}
+	}
+	
 	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
@@ -120,6 +178,7 @@ class API_Requests extends ResourceController {
 		$reffid = $res['REFFID'];
 		$patnumber = $res['PATNUMBER'];
 		$loc = $res['LOC'];
+		$doc = $res['DOC'];
 		$firstname = $res['FIRSTNAME'];
 		$lastname = $res['LASTNAME'];
 		$dob = $res['BIRTHDATE'];
@@ -127,15 +186,22 @@ class API_Requests extends ResourceController {
 		$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'];
+		
+		// LOC
+		if($loc == "PBMC Bali") { 
+			$loc = "PADMA"; $doc = "PBDPS"; 
+			$time = $time->setTimezone('Asia/Shanghai');
+			$reqdate= date_format($time, 'YmdHi');	
+		} else { 
+			$loc = "PBSBY"; $doc = "PBSBY";
+			$time = $time->setTimezone('Asia/Jakarta');
+			$reqdate= date_format($time, 'YmdHi');	
+		}
+		
 		$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
@@ -149,132 +215,12 @@ class API_Requests extends ResourceController {
 			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";
+				$orm .= "OBR|$i|||$liscode|||||||R|||||$loc|||||||||||||||||||||||||\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++;
-			}
-		}
-		*/
-		
-		
+		echo "<pre>$orm";
+		//sendHL7Message($host, $port, $message, $timeout = 5);
 	}
 }