220 lines
7.8 KiB
PHP
220 lines
7.8 KiB
PHP
<?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'];
|
|
$utcdt = $qdata['created'];
|
|
$data['created'] = $utcdt;
|
|
$time = Time::createFromFormat('Y-m-d\TH:i:s.u\Z', $utcdt, 'UTC');
|
|
$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) VALUES ('$reffid', '$visitnum', '$visitdesc', '$visittype', '$orderdt', '$agentname', '$doc', '$loc', '$patid', '$company_name', null )";
|
|
$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='$orderdt', 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 sendORMHL7($reqid) {
|
|
$db = \Config\Database::connect();
|
|
$sql = "select r.REQID, 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'";
|
|
|
|
$type = "ORM^O01";
|
|
|
|
$orm = "MSH|^~\&|PBMC|TM|TDNL||||$type^|||2.3||||\r";
|
|
$orm += "PID|1||^^^^PATNUMBER||^^^^^^L|||||^|^^||||||^||||||||||||||||";
|
|
/*
|
|
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++;
|
|
}
|
|
}
|
|
*/
|
|
|
|
}
|
|
}
|