Files
2026-04-27 10:31:17 +07:00

820 lines
29 KiB
PHP

<?php
class Mdprice extends MY_Controller
{
var $db_onedev;
var $load;
var $sspricemou;
public function index()
{
echo "CPONE MD PRICE API";
}
public function __construct()
{
parent::__construct();
$this->db_onedev = $this->load->database("onedev", true);
// $this->load->library("SsPriceMou");
}
function searchpriceheader()
{
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
$prm = $this->sys_input;
$search = '%' . $prm['search'] . '%';
$page = $prm["page"];
$ROW_PER_PAGE = 20;
$start_offset = 0;
// print_r($prm);
if (isset($prm["page"])) {
if (
is_numeric($prm["page"]) && $prm["page"] > 0
) {
$start_offset = ($page - 1) * $ROW_PER_PAGE;
}
}
$sql = "SELECT
count(T_PriceHeaderID ) as total
FROM t_priceheader
WHERE T_PriceHeaderName LIKE '{$search}'
AND T_PriceHeaderIsActive = 'Y'
";
$query = $this->db_onedev->query($sql, []);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->sys_error($message);
exit;
}
$total = $query->row_array()['total'];
$sql = "SELECT
T_PriceHeaderID AS headerID,
T_PriceHeaderName AS headerName,
T_PriceHeaderStartDate AS headerStartDate,
T_PriceHeaderEndDate AS headerEndDate,
T_PriceHeaderCode AS headerCode,
T_PriceHeaderValidasi AS headerValidate,
CASE
WHEN `fn_get_count_price_notgenerate`(T_PriceHeaderID) > 0 THEN 'Y'
ELSE 'N'
END AS readyValidate,
CASE
WHEN `fn_get_status_validate_packet`(T_PriceHeaderID) > 0 THEN 'Y'
ELSE 'N'
END AS validatePacket
FROM t_priceheader
WHERE T_PriceHeaderName LIKE '{$search}'
AND T_PriceHeaderIsActive = 'Y'
LIMIT ? OFFSET ? ";
$query = $this->db_onedev->query($sql, [$ROW_PER_PAGE, $start_offset]);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->sys_error($message);
exit;
}
$result = [
"total" => ceil($total / $ROW_PER_PAGE),
"records" => $query->result_array()
];
$this->sys_ok($result);
}
function insertpriceheader()
{
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
$prm = $this->sys_input;
$userid = $this->sys_user["M_UserID"];
if (!isset($prm['name'])) {
$this->sys_error("Nama harus diisi");
exit;
}
if (trim($prm['name']) == "") {
$this->sys_error("Nama harus diisi");
exit;
}
// if (!isset($prm['sd'])) {
// $this->sys_error("Tanggal awal harus diisi");
// exit;
// }
// if (!isset($prm['ed'])) {
// $this->sys_error("Tanggal akhir harus diisi");
// exit;
// }
$name = $prm['name'];
$startDate = $prm['sd'];
$endDate = $prm['ed'];
$nw = strtotime($startDate);
$nwe = strtotime($endDate);
$sql = "SELECT fn_numbering('PH') as number";
$query = $this->db_onedev->query($sql, []);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->sys_error($message);
exit;
}
$number = $query->row_array()['number'];
$sql = "INSERT INTO t_priceheader (
T_PriceHeaderName,
T_PriceHeaderCreated,
T_PriceHeaderCraetdUserID,
T_PriceHeaderCode)
VALUES (?,NOW(),?,?)";
$query = $this->db_onedev->query($sql, [$name, $userid, $number]);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->sys_error($message);
exit;
}
// "total" => ceil($total / $ROW_PER_PAGE),
$this->sys_ok("OK");
}
function editpriceheader()
{
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
$prm = $this->sys_input;
$userid = $this->sys_user["M_UserID"];
if (!isset($prm['name'])) {
$this->sys_error("Nama harus diisi");
exit;
}
if (trim($prm['name']) == "") {
$this->sys_error("Nama harus diisi");
exit;
}
// if (!isset($prm['sd'])) {
// $this->sys_error("Tanggal awal harus diisi");
// exit;
// }
// if (!isset($prm['ed'])) {
// $this->sys_error("Tanggal akhir harus diisi");
// exit;
// }
$name = $prm['name'];
$startDate = $prm['sd'];
$endDate = $prm['ed'];
$id = $prm['id'];
$nw = strtotime($startDate);
$nwe = strtotime($endDate);
$sql = "UPDATE t_priceheader
SET T_PriceHeaderName = '{$name}',
T_PriceHeaderLastUpdated = NOW(),
T_PriceHeaderLastUpdatedUserID = {$userid}
WHERE T_PriceHeaderID = $id";
$query = $this->db_onedev->query($sql, []);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->sys_error($message);
exit;
}
// "total" => ceil($total / $ROW_PER_PAGE),
$this->sys_ok("OK");
}
function deletepriceheader()
{
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
$prm = $this->sys_input;
$userid = $this->sys_user["M_UserID"];
$id = $prm['id'];
$sql = "UPDATE t_priceheader
SET T_PriceHeaderIsActive = 'N',
T_PriceHeaderDeleted = NOW(),
T_PriceHeaderDeletedUserID = {$userid}
WHERE T_PriceHeaderID = $id";
$query = $this->db_onedev->query($sql, []);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->sys_error($message);
exit;
}
$sql = "UPDATE t_price
SET T_PriceIsActive = 'N',
T_PriceLastUpdated = NOW(),
T_PriceUserID = {$userid}
WHERE T_PriceT_PriceHeaderID = $id";
$query = $this->db_onedev->query($sql, []);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->sys_error($message);
exit;
}
// "total" => ceil($total / $ROW_PER_PAGE),
$this->sys_ok("OK");
}
function getfilterprice()
{
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
$sql = "SELECT Nat_SubGroupID AS id, Nat_SubGroupName AS name
FROM nat_subgroup
WHERE Nat_SubGroupIsActive= 'Y'";
$query = $this->db_onedev->query($sql, []);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->sys_error($message);
exit;
}
$subgroup = $query->result_array();
array_push($subgroup, [
'id' => '0',
'name' => 'Semua'
]);
$status = [[
'id' => 'A',
'name' => 'Semua'
], [
'id' => 'Y',
'name' => 'Ya'
], [
'id' => 'N',
'name' => 'Tidak'
]];
// "total" => ceil($total / $ROW_PER_PAGE),
$rst = [
"subgroup" => $subgroup,
'status' => $status,
];
$this->sys_ok($rst);
}
function searchpricetest()
{
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
$prm = $this->sys_input;
$search = '%' . $prm['search'] . '%';
$subgroup = $prm['subgroup'];
$headerID = $prm['headerid'];
$status = $prm['status'];
$page = $prm["page"];
$ROW_PER_PAGE = 20;
$start_offset = 0;
// print_r($prm);
$filterSubGroup = "";
if ($subgroup != '0') {
$filterSubGroup = "AND Nat_SubGroupID = $subgroup";
}
$filterStatus = "";
if ($status == 'N') {
$filterStatus = 'AND T_PriceID IS NULL ';
}
if ($status == 'Y') {
$filterStatus = 'AND T_PriceID IS NOT NULL ';
}
if (isset($prm["page"])) {
if (
is_numeric($prm["page"]) && $prm["page"] > 0
) {
$start_offset = ($page - 1) * $ROW_PER_PAGE;
}
}
$sql = "SELECT
COUNT(T_TestID) as total
FROM
t_test
JOIN nat_subgroup
ON T_TestNat_SubgroupID = Nat_SubGroupID
AND Nat_SubGroupIsActive = 'Y'
AND `T_TestIsPrice` = 'Y'
AND (T_TestName LIKE ? OR T_TestSasCode LIKE ?)
{$filterSubGroup}
LEFT JOIN t_price
ON T_TestID = T_PriceT_TestID
AND T_PriceT_PriceHeaderID = ?
AND T_PriceIsActive = 'Y'
LEFT JOIN t_priceheader
ON T_PriceT_PriceHeaderID = T_PriceHeaderID
AND T_PriceHeaderIsActive = 'Y'
WHERE
`T_TestIsActive` = 'Y'
{$filterStatus}
";
$query = $this->db_onedev->query($sql, [$search, $search, $headerID,]);
$qryTotal = $this->db_onedev->last_query();
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->sys_error($message);
exit;
}
$total = $query->row_array()['total'];
$sql = "SELECT
T_TestID AS testID,
T_TestSasCode AS testCode,
T_TestName AS testName,
T_TestIsPrice AS testIsPrice,
T_PriceAmount AS priceAmount,
T_PriceDisc AS priceDisc,
T_PriceDiscRp AS priceDiscRp,
T_PriceSubTotal AS subTotal,
T_PriceID AS priceID,
T_PriceT_PriceHeaderID AS headerID,
T_PriceHeaderName AS headerName,
Nat_SubGroupID AS subGroupID,
Nat_SubGroupName AS subGroupName,
'N' AS isChange,
CASE
WHEN T_PriceID IS NULL THEN 'N'
WHEN T_PriceID IS NOT NULL THEN 'Y'
ELSE 'N'
END as status,
IFNULL(Nat_TestMapCode, '') as lis_code
FROM
t_test
JOIN nat_subgroup
ON T_TestNat_SubgroupID = Nat_SubGroupID
AND Nat_SubGroupIsActive = 'Y'
JOIN nat_test ON T_TestNat_TestID = Nat_TestID
AND `T_TestIsPrice` = 'Y'
AND (T_TestName LIKE ? OR T_TestSasCode LIKE ?)
{$filterSubGroup}
LEFT JOIN t_price
ON T_TestID = T_PriceT_TestID
AND T_PriceT_PriceHeaderID = ?
AND T_PriceIsActive = 'Y'
LEFT JOIN t_priceheader
ON T_PriceT_PriceHeaderID = T_PriceHeaderID
AND T_PriceHeaderIsActive = 'Y'
LEFT JOIN nat_testmap ON Nat_TestMapNat_TestID = Nat_TestID AND Nat_TestMapIsActive = 'Y'
WHERE
`T_TestIsActive` = 'Y'
{$filterStatus}
LIMIT ? OFFSET ? ";
$query = $this->db_onedev->query($sql, [$search, $search, $headerID, $ROW_PER_PAGE, $start_offset]);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->sys_error($message);
exit;
}
$result = [
"total" => ceil($total / $ROW_PER_PAGE),
"ttl" => $total,
"records" => $query->result_array(),
"qry" => $this->db_onedev->last_query(),
"qryttl" => $qryTotal,
];
$this->sys_ok($result);
}
function savetest()
{
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
$userid = $this->sys_user["M_UserID"];
// {
// "testID": "19",
// "testCode": "10110200",
// "testName": "Hematologi Rutin",
// "testIsPrice": "Y",
// "priceAmount": "10000",
// "priceDisc": null,
// "priceDiscRp": null,
// "subTotal": 10000,
// "priceID": null,
// "headerID": null,
// "headerName": null,
// "subGroupID": "1",
// "subGroupName": "Hematologi",
// "isChange": "Y",
// "status": "N"
// }
$prm = $this->sys_input;
$test = $prm['test'];
$headerid = $prm['headerid'];
for ($i = 0; $i < count($test); $i++) {
$data = $test[$i];
$diskon = 0;
if ($data['priceDisc'] != null) {
$diskon = $data['priceDisc'];
}
$diskonRp = 0;
if ($data['priceDiscRp'] != null) {
$diskonRp = $data['priceDiscRp'];
}
if ($data['priceID'] === null || $data['priceID'] === '0') {
$sql = "INSERT INTO t_price
(T_PriceT_PriceHeaderID,
T_PriceT_TestID,
T_PriceAmount,
T_PriceDisc,
T_PriceDiscRp,
T_PriceSubTotal,
T_PriceTotal,
T_PriceCreated,
T_PriceUserID
)
VALUES(?,?,?,?,?,?,?,NOW(),?)";
$query = $this->db_onedev->query($sql, [
$headerid,
$data['testID'],
$data['priceAmount'],
$diskon,
$diskonRp,
$data['subTotal'],
$data['subTotal'],
$userid,
]);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->sys_error($message);
exit;
}
} else {
$sql = "UPDATE t_price
SET T_PriceAmount = ?,
T_PriceDisc = ?,
T_PriceDiscRp = ?,
T_PriceSubTotal = ?,
T_PriceTotal = ?,
T_PriceLastUpdated = NOW(),
T_PriceUserID = ?
WHERE T_PriceT_TestID = ?
AND T_PriceID = ?
AND T_PriceT_PriceHeaderID = ?";
$query = $this->db_onedev->query($sql, [
$data['priceAmount'],
$diskon,
$diskonRp,
$data['subTotal'],
$data['subTotal'],
$userid,
$data['testID'],
$data['priceID'],
$headerid,
]);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->sys_error($message);
exit;
}
}
}
$this->sys_ok(["last_qry" => $this->db_onedev->last_query()]);
}
function searchpriceheaderautocomplete()
{
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
$prm = $this->sys_input;
$search = '%' . $prm['search'] . '%';
$sql = "SELECT
T_PriceHeaderID AS headerID,
CONCAT(T_PriceHeaderCode, ' ', T_PriceHeaderName) AS headerName,
T_PriceHeaderStartDate AS headerStartDate,
T_PriceHeaderEndDate AS headerEndDate,
T_PriceHeaderCode AS headerCode,
T_PriceHeaderValidasi AS headerValidate,
CASE
WHEN `fn_get_count_price`(T_PriceHeaderID) > 0 THEN 'Y'
ELSE 'N'
END AS readyValidate
FROM t_priceheader
WHERE CONCAT(T_PriceHeaderCode, ' ', T_PriceHeaderName) LIKE '{$search}'
AND fn_get_count_price(T_PriceHeaderID) > 0
AND T_PriceHeaderIsActive = 'Y'
";
$query = $this->db_onedev->query($sql, []);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->sys_error($message);
exit;
}
$result = [
"records" => $query->result_array()
];
$this->sys_ok($result);
}
function copyharga()
{
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
// $this->db_onedev->trans_begin();
// $this->db_onedev->trans_rollback();
// $this->db_onedev->trans_commit();
$this->db_onedev->trans_begin();
$prm = $this->sys_input;
$headerid = $prm['headerid'];
$name = $prm['name'];
$copypacket = $prm['copypacket'];
$userid = $this->sys_user["M_UserID"];
$sql = "SELECT fn_numbering('PH') as number";
$query = $this->db_onedev->query($sql, []);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->sys_error($message);
exit;
}
$numberHeader = $query->row_array()['number'];
//insert price header
$sql = "INSERT INTO t_priceheader (
T_PriceHeaderName,
T_PriceHeaderCreated,
T_PriceHeaderCraetdUserID,
T_PriceHeaderCode)
VALUES(?,NOW(),?,?)";
$query = $this->db_onedev->query($sql, [$name, $userid, $numberHeader]);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->db_onedev->trans_rollback();
$this->sys_error($message);
exit;
}
$newHeaderid = $this->db_onedev->insert_id();
$sql = "INSERT INTO t_price
( T_PriceT_PriceHeaderID,
T_PriceT_TestID,
T_PriceAmount,
T_PriceDisc,
T_PriceDiscRp,
T_PriceSubTotal,
T_PriceTotal,
T_PriceCreated,
T_PriceUserID)
SELECT
'{$newHeaderid}' AS headerid,
T_PriceT_TestID,
T_PriceAmount,
T_PriceDisc,
T_PriceDiscRp,
T_PriceSubTotal,
T_PriceTotal,
NOW() as created,
'{$userid}' as userID
FROM t_price
WHERE T_PriceT_PriceHeaderID = ?
AND T_PriceIsActive = 'Y'
";
$query = $this->db_onedev->query($sql, [$headerid]);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->db_onedev->trans_rollback();
$this->sys_error($message);
exit;
}
// echo $this->db_onedev->last_query();
// exit;
if ($copypacket) {
$sql = 'SELECT * FROM t_packet WHERE T_PacketT_PriceHeaderID = ? AND T_PacketIsActive = "Y"';
$query = $this->db_onedev->query($sql, [$headerid]);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->db_onedev->trans_rollback();
$this->sys_error($message);
exit;
}
$pcktlst = $query->result_array();
for ($i = 0; $i < count($pcktlst); $i++) {
$p = $pcktlst[$i];
$name = $p['T_PacketName'] . " " . $numberHeader;
$oldPHid = $p['T_PacketID'];
$type_number = "PCPR";
if($pcktlst[$i]['T_PacketType'] == 'PN')
$type_number = "PCPN";
$sql = "SELECT fn_numbering('{$type_number}') as number";
$query = $this->db_onedev->query($sql, []);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->db_onedev->trans_rollback();
$this->sys_error($message);
exit;
}
$number = $query->row_array()['number'];
$sql = "INSERT INTO t_packet
(T_PacketT_PriceHeaderID,
T_PacketType,
T_PacketName,
T_PacketPrice,
T_PacketOriginalPrice,
T_PacketSasCode,
T_PacketStartDate,
T_PacketEndDate,
T_PacketCreated,
T_PacketOriginalBruto)
VALUES(?,?,?,?,?,?,?,?,NOW(),?)";
$query = $this->db_onedev->query($sql, [
$newHeaderid,
$p['T_PacketType'],
$name,
$p['T_PacketPrice'],
$p['T_PacketOriginalPrice'],
$number,
$p['T_PacketStartDate'],
$p['T_PacketEndDate'],
$p['T_PacketOriginalBruto'],
]);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->db_onedev->trans_rollback();
$this->sys_error($message);
exit;
}
$newPHid = $this->db_onedev->insert_id();
$sql = "INSERT INTO t_packetdetail
(T_PacketDetailT_PacketID,
T_PacketDetailT_TestID,
T_PacketDetailOriginalPrice,
T_PacketDetailPrice,
T_PacketDetailCreated,
T_PacketDetailPriceAmount,
T_PacketDetailPriceDisc,
T_PacketDetailPriceDiscRp,
T_PacketDetailPriceSubTotal)
SELECT
'{$newPHid}' as pid,
T_PacketDetailT_TestID,
T_PacketDetailOriginalPrice,
T_PacketDetailPrice,
NOW() as created,
T_PacketDetailPriceAmount,
T_PacketDetailPriceDisc,
T_PacketDetailPriceDiscRp,
T_PacketDetailPriceSubTotal
FROM t_packetdetail
WHERE T_PacketDetailT_PacketID = ?
AND T_PacketDetailIsActive = 'Y'";
$query = $this->db_onedev->query($sql, [
$oldPHid
]);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->db_onedev->trans_rollback();
$this->sys_error($message);
exit;
}
}
}
$this->db_onedev->trans_commit();
// $result = [
// "records" => $query->result_array()
// ];
$this->sys_ok('OK');
}
function create($id)
{
$this->load->library("SsPriceMou");
list($status, $message) = $this->sspricemou->create($id);
if ($status) {
return [
"status" => 'OK',
"msg" => $message
];
} else {
return [
"status" => 'OK',
"msg" => $message
];
}
}
function validateheader()
{
if (!$this->isLogin) {
$this->sys_error("Invalid Token");
exit;
}
// $this->db_onedev->trans_begin();
// $this->db_onedev->trans_rollback();
// $this->db_onedev->trans_commit();
$this->db_onedev->trans_begin();
$prm = $this->sys_input;
$userid = $this->sys_user["M_UserID"];
$id = $prm['id'];
$sql = "UPDATE t_priceheader
SET T_PriceHeaderValidasi = 'Y',
T_PriceHeaderValidasiDate = NOW(),
T_PriceHeaderValidasiUserID = {$userid},
T_PriceHeaderIsGenerated = 'Y',
T_PriceHeaderGeneratedDate = NOW()
WHERE T_PriceHeaderID = $id";
$query = $this->db_onedev->query($sql, []);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->db_onedev->trans_rollback();
$this->sys_error($message);
exit;
}
$sql = "UPDATE t_price
SET T_PriceValidasi = 'Y',
T_PriceValidasiDate = NOW(),
T_PriceValidasiDateUserID = {$userid},
T_PriceIsGenerated = 'Y',
T_PriceIsGeneratedDate = NOW()
WHERE T_PriceT_PriceHeaderID = $id
AND T_PriceValidasi = 'N'";
$query = $this->db_onedev->query($sql, []);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->db_onedev->trans_rollback();
$this->sys_error($message);
exit;
}
$sql = "UPDATE t_packet
SET T_PacketIsGenerated = 'Y',
T_PacketGeneratedDate = NOW()
WHERE T_PacketT_PriceHeaderID = $id
AND T_PacketIsGenerated= 'N'";
$query = $this->db_onedev->query($sql, []);
if (!$query) {
$message = $this->db_onedev->error();
$message['qry'] = $this->db_onedev->last_query();
$this->db_onedev->trans_rollback();
$this->sys_error($message);
exit;
}
$rtn = $this->create($id);
if ($rtn['status'] !== 'OK') {
$message = $rtn['msg'];
$message['qry'] = $this->db_onedev->last_query();
$this->db_onedev->trans_rollback();
$this->sys_error($message);
exit;
}
// "total" => ceil($total / $ROW_PER_PAGE),
$this->db_onedev->trans_commit();
$this->sys_ok([
"msg" => "OK",
"generate" => $rtn
]);
}
}