585 lines
16 KiB
PHP
585 lines
16 KiB
PHP
<?php
|
|
class Satu_sehat
|
|
{
|
|
var $base_url, $base_consent_url, $base_oauth_url;
|
|
var $is_staging, $organizationID;
|
|
var $key, $secret;
|
|
var $tz;
|
|
var $db, $dbname;
|
|
function __construct()
|
|
{
|
|
$this->tz = "+07:00";
|
|
$this->is_staging = false;
|
|
$this->base_url = "https://api-satusehat.kemkes.go.id/fhir-r4/v1";
|
|
$this->base_oauth_url = "https://api-satusehat.kemkes.go.id/oauth2/v1";
|
|
$this->base_consent_url = "https://api-satusehat.dto.kemkes.go.id/consent/v1";
|
|
$CI = &get_instance();
|
|
$this->db = $CI->load->database("default", true);
|
|
|
|
$this->dbname = "one_health";
|
|
if ($this->is_staging) {
|
|
$this->base_url = "https://api-satusehat-stg.kemkes.go.id/fhir-r4/v1";
|
|
$this->base_oauth_url = "https://api-satusehat-stg.kemkes.go.id/oauth2/v1";
|
|
$this->base_consent_url = "https://api-satusehat-stg.dto.kemkes.go.id/consent/v1";
|
|
$this->dbname = "one_health_dev";
|
|
}
|
|
$this->get_organization_id();
|
|
}
|
|
function load_clinic()
|
|
{
|
|
$this->dbname = "one_health_clinic";
|
|
}
|
|
function ss_organization()
|
|
{
|
|
$this->get_organization_id();
|
|
$o_resp = $this->ss_get("/Organization/{$this->organizationID}");
|
|
$resp = $this->objToArray($o_resp);
|
|
$id = $resp["id"];
|
|
$name = $resp["name"];
|
|
$x_type = $resp["type"][0]["coding"][0];
|
|
$type = $x_type["display"];
|
|
$code = $x_type["code"];
|
|
$system = $x_type["system"];
|
|
return json_encode([
|
|
"ID" => $id,
|
|
"Name" => $name,
|
|
"Type" => $type,
|
|
"CodeSystem" => $code . " | " . $system,
|
|
]);
|
|
}
|
|
|
|
function search_practicioner_by_nik($nik, $debug = "")
|
|
{
|
|
$service = "/Practitioner?identifier=https://fhir.kemkes.go.id/id/nik|" . $nik;
|
|
$o_resp = $this->ss_get($service, $debug);
|
|
$resp = $this->objToArray($o_resp);
|
|
if (count($resp["entry"]) > 0) {
|
|
$rs = $resp["entry"][0]["resource"];
|
|
return json_encode([
|
|
"status" => "OK",
|
|
"ihsID" => $rs["id"],
|
|
"name" => $rs["name"][0]["text"]
|
|
]);
|
|
}
|
|
return json_encode([
|
|
"status" => "ERR",
|
|
"message" => "Practitioner not found [$nik]"
|
|
]);
|
|
}
|
|
|
|
function search_patient_by_nik($nik, $debug = "")
|
|
{
|
|
$service = "/Patient?identifier=https://fhir.kemkes.go.id/id/nik|" . $nik;
|
|
$resp = $this->ss_get($service);
|
|
if ($debug != "") {
|
|
echo "resp : ";
|
|
print_r($resp);
|
|
}
|
|
$a_resp = $this->objToArray($resp);
|
|
if (isset($a_resp["entry"][0]["resource"]["id"])) {
|
|
return $a_resp["entry"][0]["resource"]["id"];
|
|
}
|
|
return "";
|
|
}
|
|
|
|
function location_by_organization($organizationIhsID, $debug = "")
|
|
{
|
|
$service = "/Location?organization=" . $organizationIhsID;
|
|
$resp = $this->ss_get($service);
|
|
if ($debug != "") {
|
|
echo "resp : ";
|
|
print_r($resp);
|
|
}
|
|
$a_resp = $this->objToArray($resp);
|
|
return $a_resp;
|
|
}
|
|
|
|
function location_create(
|
|
$code,
|
|
$name,
|
|
$description,
|
|
$address,
|
|
$city,
|
|
$kodePos,
|
|
$administrativeCode,
|
|
$rt,
|
|
$rw,
|
|
$phone,
|
|
$type,
|
|
$partOf = "",
|
|
$email = "",
|
|
$fax = "",
|
|
$url = "",
|
|
$long = "",
|
|
$lat = ""
|
|
) {
|
|
$this->get_organization_id();
|
|
$organizationID = $this->organizationID;
|
|
list($type_code, $type_display) = explode("^", $type);
|
|
$telecom = [];
|
|
$telecom[] = ["system" => "phone", "value" => "$phone", "use" => "work"];
|
|
if ($fax != "") $telecom[] = ["system" => "fax", "value" => "$fax", "use" => "work"];
|
|
if ($email != "") $telecom[] = ["system" => "email", "value" => "$email"];
|
|
if ($url != "") $telecom[] = ["system" => "url", "value" => "$url"];
|
|
$provCode = substr($administrativeCode, 0, 2);
|
|
$cityCode = substr($administrativeCode, 0, 4);
|
|
$districtCode = substr($administrativeCode, 0, 7);
|
|
$villageCode = substr($administrativeCode, 0, 10);
|
|
|
|
$data = [
|
|
"resourceType" => "Location",
|
|
"identifier" => [
|
|
[
|
|
"system" => "http://sys-ids.kemkes.go.id/location/{$organizationID}",
|
|
"value" => "$code",
|
|
],
|
|
],
|
|
"status" => "active",
|
|
"name" => "$name",
|
|
"description" => "$description",
|
|
"mode" => "instance",
|
|
"telecom" => $telecom,
|
|
"address" => [
|
|
"use" => "work",
|
|
"line" => [
|
|
$address,
|
|
],
|
|
"city" => "$city",
|
|
"postalCode" => "$kodePos",
|
|
"country" => "ID",
|
|
"extension" => [
|
|
[
|
|
"url" =>
|
|
"https://fhir.kemkes.go.id/r4/StructureDefinition/administrativeCode",
|
|
"extension" => [
|
|
["url" => "province", "valueCode" => $provCode],
|
|
["url" => "city", "valueCode" => $cityCode],
|
|
["url" => "district", "valueCode" => "$districtCode"],
|
|
["url" => "village", "valueCode" => "$villageCode"],
|
|
["url" => "rt", "valueCode" => "$rt"],
|
|
["url" => "rw", "valueCode" => "$rw"],
|
|
],
|
|
],
|
|
],
|
|
],
|
|
"physicalType" => [
|
|
"coding" => [
|
|
[
|
|
"system" =>
|
|
"http://terminology.hl7.org/CodeSystem/location-physical-type",
|
|
"code" => "$type_code",
|
|
"display" => "$type_display",
|
|
],
|
|
],
|
|
],
|
|
"position" => [
|
|
"longitude" => intval($long),
|
|
"latitude" => intval($lat),
|
|
"altitude" => 0,
|
|
],
|
|
"managingOrganization" => ["reference" => "Organization/{$organizationID}"],
|
|
];
|
|
if ($partOf != "") {
|
|
$data["partOf"] = [
|
|
"reference" => "Location/$partOf"
|
|
];
|
|
}
|
|
$service = "/Location";
|
|
$resp = $this->ss_post($service, $data);
|
|
$oresp = $this->objToArray($resp);
|
|
if (!isset($oresp["id"])) {
|
|
header("Content-Type: text/plain");
|
|
print_r($data);
|
|
print_r($resp);
|
|
}
|
|
return $oresp;
|
|
}
|
|
|
|
function location_nonactive(
|
|
$ihsID
|
|
) {
|
|
$this->get_organization_id();
|
|
$data = [
|
|
[
|
|
"op" => "replace",
|
|
"path" => "/status",
|
|
"value" => "inactive"
|
|
]
|
|
];
|
|
|
|
$service = "/Location/$ihsID";
|
|
$resp = $this->ss_patch($service, $data);
|
|
return $this->objToArray($resp);
|
|
}
|
|
function get_location($locationID)
|
|
{
|
|
}
|
|
|
|
|
|
|
|
|
|
function encounter_by_id($encounterID)
|
|
{
|
|
$this->get_organization_id();
|
|
$service = "/Encounter/$";
|
|
$resp = $this->ss_get($service);
|
|
return $this->objToArray($resp);
|
|
}
|
|
function encounter_by_subject($patientIhsID)
|
|
{
|
|
$this->get_organization_id();
|
|
$service = "/Encounter?subject=$patientIhsID";
|
|
$resp = $this->ss_get($service);
|
|
return $this->objToArray($resp);
|
|
}
|
|
function encounter(
|
|
$orderDate,
|
|
$patientIhsID,
|
|
$patientName,
|
|
$doctorIhsID,
|
|
$doctorName,
|
|
$locationID,
|
|
$locationName,
|
|
$labNumber,
|
|
$tz = "+07:00",
|
|
$payload_only = false
|
|
) {
|
|
$service = "/Encounter";
|
|
$xdate = substr($orderDate, 0, 10) . "T" . substr($orderDate, 11) . $tz;
|
|
$this->get_organization_id();
|
|
$param = $this->encounter_param(
|
|
$patientIhsID,
|
|
$patientName,
|
|
$doctorIhsID,
|
|
$doctorName,
|
|
$locationID,
|
|
$locationName,
|
|
$this->organizationID,
|
|
$labNumber,
|
|
$xdate
|
|
);
|
|
$payload = json_encode($param);
|
|
if ($payload_only) {
|
|
return ["", "", $payload, ""];
|
|
}
|
|
$jresp = $this->ss_post($service, $param);
|
|
$resp = $this->objToArray($jresp);
|
|
$response = json_encode($resp);
|
|
if (is_array($resp) && isset($resp["id"])) {
|
|
$encounterResponseID = $resp["id"];
|
|
return [$encounterResponseID, "", $payload, $response];
|
|
} else {
|
|
return ["", $response, $payload, $response];
|
|
}
|
|
}
|
|
function encounter_param(
|
|
$patientIhs,
|
|
$patientName,
|
|
$dpjpIhs,
|
|
$dpjpName,
|
|
$locationIhs,
|
|
$locationName,
|
|
$organizationID,
|
|
$orderHeaderNumber,
|
|
$dateTime // 2022-06-14T07:00:00+07:00
|
|
) {
|
|
if ($this->is_staging) {
|
|
$dpjpIhs = "N10000001";
|
|
$dpjpName = "Dokter Bronsig";
|
|
}
|
|
$encounterParam = [
|
|
"resourceType" => "Encounter",
|
|
"status" => "arrived",
|
|
"class" => [
|
|
"system" => "http://terminology.hl7.org/CodeSystem/v3-ActCode",
|
|
"code" => "AMB",
|
|
"display" => "ambulatory"
|
|
],
|
|
"subject" => [
|
|
"reference" => "Patient/{$patientIhs}",
|
|
"display" => "$patientName"
|
|
],
|
|
"participant" => [
|
|
[
|
|
"type" => [
|
|
[
|
|
"coding" => [
|
|
[
|
|
"system" => "http://terminology.hl7.org/CodeSystem/v3-ParticipationType",
|
|
"code" => "ATND",
|
|
"display" => "attender"
|
|
]
|
|
]
|
|
]
|
|
],
|
|
"individual" => [
|
|
"reference" => "Practitioner/{$dpjpIhs}",
|
|
"display" => "$dpjpName"
|
|
]
|
|
]
|
|
],
|
|
"period" => [
|
|
"start" => "$dateTime",
|
|
],
|
|
"location" => [
|
|
[
|
|
"location" => [
|
|
"reference" => "Location/$locationIhs",
|
|
"display" => "$locationName"
|
|
]
|
|
]
|
|
],
|
|
"statusHistory" => [
|
|
[
|
|
"status" => "arrived",
|
|
"period" => [
|
|
"start" => $dateTime
|
|
]
|
|
]
|
|
],
|
|
"serviceProvider" => [
|
|
"reference" => "Organization/{$organizationID}"
|
|
],
|
|
"identifier" => [
|
|
[
|
|
"system" => "http://sys-ids.kemkes.go.id/encounter/{$organizationID}",
|
|
"value" => "$orderHeaderNumber"
|
|
]
|
|
]
|
|
];
|
|
return $encounterParam;
|
|
}
|
|
|
|
|
|
|
|
|
|
// helper
|
|
function get_organization_id()
|
|
{
|
|
|
|
$sql = "SELECT organizationID
|
|
FROM {$this->dbname}.organization
|
|
JOIN m_branch ON organizationM_BranchID = M_BranchID AND M_BranchIsDefault = 'Y' AND M_BranchIsActive = 'Y'
|
|
WHERE organizationIsActive = 'Y'";
|
|
$qry = $this->db->query($sql);
|
|
if (!$qry) {
|
|
return;
|
|
}
|
|
$rows = $qry->result_array();
|
|
if (count($rows) > 0) {
|
|
$this->organizationID = $rows[0]["organizationID"];
|
|
}
|
|
}
|
|
|
|
function ss_patch($service, $data)
|
|
{
|
|
$token = $this->get_token();
|
|
$authorization = "Authorization: Bearer " . $token;
|
|
$xbase_url = $this->base_url;
|
|
$url = $xbase_url . "$service";
|
|
$ch = curl_init($url);
|
|
# Setup request to send json via POST.
|
|
$payload = json_encode($data);
|
|
|
|
curl_setopt($ch, CURLOPT_POSTFIELDS, $payload);
|
|
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "PATCH");
|
|
curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-Type: application/json-patch+json', $authorization));
|
|
# Return response instead of printing.
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
|
# Send request.
|
|
$result = curl_exec($ch);
|
|
curl_close($ch);
|
|
# Print response.
|
|
$data_rst = json_decode($result);
|
|
return $data_rst;
|
|
}
|
|
|
|
function get_client_key($debug = "")
|
|
{
|
|
$sql = "select * from {$this->dbname}.client where clientIsActive = 'Y'";
|
|
$qry = $this->db->query($sql);
|
|
if (!$qry) {
|
|
return [false, "", ""];
|
|
}
|
|
$rows = $qry->result_array();
|
|
if (count($rows) == 0) {
|
|
if ($debug != "") {
|
|
print_r([false, "", ""]);
|
|
}
|
|
return [false, "", ""];
|
|
}
|
|
if ($debug != "") {
|
|
print_r([true, $rows[0]["clientKey"], $rows[0]["clientSecret"]]);
|
|
}
|
|
|
|
return [true, $rows[0]["clientKey"], $rows[0]["clientSecret"]];
|
|
}
|
|
|
|
function reset_token()
|
|
{
|
|
$sql = "delete from {$this->dbname}.token ";
|
|
$qry = $this->db->query($sql);
|
|
if (!$qry) {
|
|
echo "ERR : " . $this->db->error()["message"];
|
|
echo " " . $this->db->last_query();
|
|
exit;
|
|
}
|
|
}
|
|
|
|
function put_token()
|
|
{
|
|
$auth_url = $this->base_oauth_url;
|
|
$url = $auth_url . "/accesstoken?grant_type=client_credentials";
|
|
list($status, $key, $secret) = $this->get_client_key();
|
|
$data = [
|
|
"client_id" => $key,
|
|
"client_secret" => $secret
|
|
];
|
|
$ch = curl_init($url);
|
|
$post_data = http_build_query($data);
|
|
curl_setopt($ch, CURLOPT_POSTFIELDS, $post_data);
|
|
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "POST");
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
|
$result = curl_exec($ch);
|
|
curl_close($ch);
|
|
if ($result) {
|
|
$token_rst = json_decode($result);
|
|
$sql = "select count(*) as xcount, tokenID
|
|
from {$this->dbname}.token
|
|
where
|
|
tokenIsActive = 'y'
|
|
";
|
|
$qry = $this->db->query($sql);
|
|
if (!$qry) {
|
|
echo "get count token error";
|
|
exit;
|
|
}
|
|
|
|
$rst_count = $qry->row_array();
|
|
// print_r($token_rst);
|
|
if ($rst_count['xcount'] > 0) {
|
|
$sql = "update {$this->dbname}.token set tokenValue = ?, tokenExpired = date_add(now(), interval 50 minute)
|
|
where tokenID = ?";
|
|
$qry = $this->db->query($sql, [$token_rst->access_token, $rst_count['tokenID']]);
|
|
if (!$qry) {
|
|
$this->sys_error_db("refresh token error", $this->db->last_query());
|
|
exit;
|
|
}
|
|
} else {
|
|
$sql = "update {$this->dbname}.token set tokenIsActive = 'N' where tokenIsActive = 'Y'";
|
|
$qry = $this->db->query($sql);
|
|
if (!$qry) {
|
|
echo "nonactive token error";
|
|
exit;
|
|
}
|
|
|
|
$sql = "insert into {$this->dbname}.token(tokenValue,tokenExpired) values(?,date_add(now(), interval 50 minute))";
|
|
$qry = $this->db->query($sql, [$token_rst->access_token]);
|
|
if (!$qry) {
|
|
echo "insert token error";
|
|
exit;
|
|
}
|
|
}
|
|
|
|
$sql = "select tokenValue
|
|
from {$this->dbname}.token
|
|
where
|
|
tokenIsActive = 'Y' limit 1
|
|
";
|
|
$qry = $this->db->query($sql);
|
|
if (!$qry) {
|
|
echo "get token error";
|
|
exit;
|
|
}
|
|
|
|
return $qry->row()->tokenValue;
|
|
}
|
|
}
|
|
|
|
function get_token()
|
|
{
|
|
$sql = "SELECT COUNT(*) as xcount, tokenValue
|
|
FROM {$this->dbname}.token
|
|
WHERE tokenIsActive = 'Y' AND NOW() < tokenExpired AND tokenValue IS NOT NULL ";
|
|
$qry = $this->db->query($sql);
|
|
$this->check_error($qry, "select token");
|
|
|
|
$data_token = $qry->row_array();
|
|
//print_r($data_token);
|
|
if ($data_token['xcount'] > 0) {
|
|
return $data_token['tokenValue'];
|
|
} else {
|
|
return $this->put_token();
|
|
}
|
|
}
|
|
|
|
|
|
function ss_post($service, $data)
|
|
{
|
|
$token = $this->get_token();
|
|
$authorization = "Authorization: Bearer " . $token;
|
|
$xbase_url = $this->base_url;
|
|
$url = $xbase_url . "$service";
|
|
$ch = curl_init($url);
|
|
# Setup request to send json via POST.
|
|
$payload = json_encode($data);
|
|
|
|
curl_setopt($ch, CURLOPT_POSTFIELDS, $payload);
|
|
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "POST");
|
|
curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-Type: application/json', $authorization));
|
|
# Return response instead of printing.
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
|
# Send request.
|
|
$result = curl_exec($ch);
|
|
curl_close($ch);
|
|
# Print response.
|
|
$data_rst = json_decode($result);
|
|
return $data_rst;
|
|
}
|
|
function ss_get($service, $debug = "")
|
|
{
|
|
$token = $this->get_token();
|
|
$authorization = "Authorization: Bearer " . $token;
|
|
$xbase_url = $this->base_url;
|
|
$url = $xbase_url . "$service";
|
|
$ch = curl_init($url);
|
|
|
|
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "GET");
|
|
curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-Type: application/json', $authorization));
|
|
# Return response instead of printing.
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
|
# Send request.
|
|
$result = curl_exec($ch);
|
|
curl_close($ch);
|
|
# Print response.
|
|
if ($debug != "") {
|
|
echo "url : $url \n";
|
|
print_r($result);
|
|
}
|
|
$data_rst = json_decode($result);
|
|
return $data_rst;
|
|
}
|
|
protected function objToArray($obj)
|
|
{
|
|
if (!is_object($obj) && !is_array($obj)) {
|
|
return $obj;
|
|
}
|
|
foreach ($obj as $key => $value) {
|
|
$arr[$key] = $this->objToArray($value);
|
|
}
|
|
return $arr;
|
|
}
|
|
|
|
function check_error($qry, $stage)
|
|
{
|
|
if (!$qry) {
|
|
echo json_encode([
|
|
"status" => "ERR",
|
|
"message" => $this->db->error(),
|
|
"sql" => $this->db->last_query()
|
|
]);
|
|
exit;
|
|
}
|
|
}
|
|
}
|