diff --git a/.gitignore b/.gitignore index 2211c6e..2b93c4b 100644 --- a/.gitignore +++ b/.gitignore @@ -3,4 +3,5 @@ !public/ !cretab.sql !.gitignore +!docs/ !env \ No newline at end of file diff --git a/app/Config/Routes.php b/app/Config/Routes.php index f50e609..9930452 100644 --- a/app/Config/Routes.php +++ b/app/Config/Routes.php @@ -6,5 +6,6 @@ use CodeIgniter\Router\RouteCollection; * @var RouteCollection $routes */ $routes->get('/', 'Pages::home'); -$routes->post('/api/requests/', 'API::requests'); -$routes->get('/api/results/(:any)', 'API::results/$1'); +$routes->post('/api/requests/', 'API_Requests::requests'); +$routes->get('/api/requests/orm/(:any)', 'API_Requests::orm/$1'); +$routes->get('/api/results/(:any)', 'API_Results::results/$1'); diff --git a/app/Controllers/API_Requests.php b/app/Controllers/API_Requests.php new file mode 100644 index 0000000..2e4c3cf --- /dev/null +++ b/app/Controllers/API_Requests.php @@ -0,0 +1,280 @@ +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 "
$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 = ''+tmp['MSH']+tmp['PID']+tmp['PV1']+' ';
+ //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++;
+ }
+ }
+ */
+
+
+ }
+}
diff --git a/app/Controllers/API_Results.php b/app/Controllers/API_Results.php
new file mode 100644
index 0000000..d0d395e
--- /dev/null
+++ b/app/Controllers/API_Results.php
@@ -0,0 +1,110 @@
+query($sql);
+ // $results = $query->getResultArray();
+ // $data['LISNO'] = $accessnumber;
+ // $hisno = $results[0]['HISNO'];
+ // $sql = "select TESTCODE, TESTORDER, RESTYPE, RESVALUE, RESFLAG, UNIT, REFRANGE, USERVAL, RESDATE
+ // from cmod.dbo.CM_RESULTS r
+ // where ACCESSNUMBER='$accessnumber'
+ // order by TESTORDER";
+ // $query = $db->query($sql);
+ // $results = $query->getResultArray();
+
+ $sql = "SELECT sp.HOSTORDERNUMBER, hiso.LOC, hiso.PAYERNAME
+ FROM dbo.SP_REQUESTS sp
+ LEFT JOIN cmod.dbo.CM_HIS_ORDERS hiso ON hiso.VISITNUMBER = sp.HOSTORDERNUMBER
+ WHERE SP_ACCESSNUMBER = '$accessnumber'";
+ $query = $db->query($sql);
+ $results = $query->getResultArray();
+
+ $location = $results[0]['LOC'] == null ? 'PBMC Bali' : 'PBMC Surabaya';
+ $payer_name = $results[0]['PAYERNAME'] == null ? '' : $results[0]['PAYERNAME'];
+
+ $sql = "select
+ dc.CHAPID,
+ dc.FULLTEXT as chap_eng,
+ dc.FULLTEXT as chap_ind,
+ st.FULLTEXT as serum_type,
+ cdt.TEXT1 as test_eng,
+ cdt.TEXT2 as test_ind,
+ cdt.UNIT as UNITTEXT,
+ cdt.REFFTEXT,
+ t.DEPTH as text_depth,
+ t.NOTPRINTABLE,
+ t.TESTORDER,
+ t.RESTYPE as code_type,
+ t.VALIDATIONINITIALS as validator,
+ dt.SHORTTEXT,
+ RESULT = case when t.RESVALUE is null then tx.FULLTEXT else t.RESVALUE end,
+ cr.*
+ from REQUESTS r
+ left join TESTS t on t.REQUESTID = r.REQUESTID
+ left join DICT_TESTS dt on dt.ENDVALIDDATE is null and t.TESTID=dt.TESTID
+ left join DICT_TEXTS tx on tx.TEXTID=t.CODEDRESULTID
+ left join DICT_CHAPTERS dc on dc.CHAPID=dt.CHAPID and dc.ENDVALIDDATE is null
+ left join DICT_TEST_SAMPLES ts on ts.TESTID=t.TESTID and dt.TESTID=ts.TESTID
+ left join DICT_SAMPLES_TYPES st on st.SAMPTYPEID=ts.SAMPTYPEID
+ left join cmod.dbo.CM_DICT_TESTS cdt on dt.TESTCODE=cdt.TESTCODE
+ left join cmod.dbo.CM_RESULTS cr on cr.ACCESSNUMBER=r.ACCESSNUMBER and cr.TESTCODE=cdt.TESTCODE and cr.TESTCODE=dt.TESTCODE
+ where r.ACCESSNUMBER='$accessnumber'
+ ORDER BY t.TESTORDER";
+ $query = $db->query($sql);
+ $test_results = $query->getResultArray();
+
+ // $uuid24 = $this->generateUUID24();
+ $response = [
+ "headers" => [
+ "Content-Type" => "application/json",
+ "Authorization" => "Transmedic api key"
+ ],
+ "data" => [
+ "reference_id" => "",
+ "created" => "2024-10-19T02:11:06.424654Z",
+ "company_name" => $payer_name,
+ "branch" => $location,
+ "test_results" => []
+ ]
+ ];
+
+ // Digunakan Untuk Hasil test
+ foreach ($test_results as $result) {
+
+ // var_dump($result);die();
+
+ if ($result['text_depth'] == 0) {
+ // $uuid32 = $this->generateUUID32();
+ $uuid24 = $this->generateUUID24();
+
+ $data = [
+ "test_ref_id"=> $uuid24,
+ "service_id"=> "",
+ "service_name"=> $result['test_eng'],
+ "test_medium"=> $result['serum_type'],
+ "test_container"=> "",
+ "chapter_type"=> $result['chap_eng'],
+ "test_summary"=> "",
+ "status"=> "",
+ ];
+
+ array_push($response['data']['test_results'], $data);
+ }
+
+
+ }
+
+ return $this->respond($response,200);
+ }
+
+}
\ No newline at end of file
diff --git a/app/Controllers/Home.php b/app/Controllers/Home.php
new file mode 100644
index 0000000..5934333
--- /dev/null
+++ b/app/Controllers/Home.php
@@ -0,0 +1,11 @@
+
diff --git a/public/web.config b/public/web.config
new file mode 100644
index 0000000..116c616
--- /dev/null
+++ b/public/web.config
@@ -0,0 +1,33 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+