447 lines
12 KiB
PHP
447 lines
12 KiB
PHP
<?php
|
|
class Uploader extends MY_Controller
|
|
{
|
|
var $db;
|
|
var $max_limit = 20;
|
|
var $IP_ADDRESS = "192.168.250.73";
|
|
|
|
public function __construct()
|
|
{
|
|
parent::__construct();
|
|
// db wilayah contoh surabaya
|
|
// $this->db = $this->load->database("regional", true);
|
|
|
|
// string database
|
|
// $this->db_str_doctor = 'one_doctor';
|
|
}
|
|
|
|
public function index()
|
|
{
|
|
echo "NAT REPORT API";
|
|
}
|
|
|
|
function get($url, $timeout = 60, $c_timeout = 5)
|
|
{
|
|
$ch = curl_init($url);
|
|
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $c_timeout);
|
|
curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
|
$result = curl_exec($ch);
|
|
$err_msg = curl_error($ch);
|
|
if ($err_msg != "") {
|
|
return json_encode(["status" => "ERR", "message" => $err_msg]);
|
|
}
|
|
return $result;
|
|
}
|
|
|
|
function reply_err($message)
|
|
{
|
|
echo json_encode(["status" => "ERR", "data" => $message]);
|
|
exit();
|
|
}
|
|
|
|
public function post($url, $data)
|
|
{
|
|
$ch = curl_init($url);
|
|
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "POST");
|
|
curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
|
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 10);
|
|
curl_setopt($ch, CURLOPT_TIMEOUT, 10);
|
|
curl_setopt($ch, CURLOPT_HTTPHEADER, [
|
|
"Content-Type: application/text",
|
|
"Content-Length: " . strlen($data),
|
|
]);
|
|
$result = curl_exec($ch);
|
|
if (curl_error($ch) != "") {
|
|
echo json_encode([
|
|
"status" => "ERR",
|
|
"message" => "Http Error : " . curl_error($ch),
|
|
]);
|
|
curl_close($ch);
|
|
exit();
|
|
}
|
|
curl_close($ch);
|
|
return $result;
|
|
}
|
|
|
|
function log($msg)
|
|
{
|
|
// $dt = Date("Y-m-d H:i:s");
|
|
// echo "$dt $msg \n";
|
|
echo $msg;
|
|
}
|
|
|
|
function get_param_z()
|
|
{
|
|
$body_z = file_get_contents("php://input");
|
|
$body = gzuncompress($body_z);
|
|
return json_decode($body, true);
|
|
}
|
|
|
|
function reply($resp)
|
|
{
|
|
echo json_encode($resp);
|
|
}
|
|
|
|
function reply_gz($resp)
|
|
{
|
|
//echo json_encode($resp);
|
|
echo gzcompress(json_encode($resp));
|
|
}
|
|
|
|
// nat_sales start
|
|
function get_sales($T_OrderHeaderDate)
|
|
{
|
|
// print_r($T_OrderHeaderDate);
|
|
$sql_sales = "with branch
|
|
as (
|
|
select M_BranchID, M_BranchCode
|
|
from
|
|
m_branch where M_BranchIsActive='Y' and M_BranchIsDefault ='Y'
|
|
)
|
|
|
|
select
|
|
M_BranchID,
|
|
M_BranchCode,
|
|
date(T_OrderHeaderDate) day,
|
|
month(T_OrderHeaderDate) month,
|
|
year(T_OrderHeaderDate) year,
|
|
quarter(T_OrderHeaderDate) quarter,
|
|
T_OrderHeaderM_CompanyID,
|
|
Nat_TestNat_GroupID,
|
|
Nat_TestNat_SubGroupID,
|
|
sum(SsPiutangTestPrice) SalesPrice,
|
|
sum(SsPiutangTestDiscTotal) SalesDiscount,
|
|
sum(SsPiutangTestTotal) SalesTotal,
|
|
sum(if(T_TestIsPrice='Y',1,0) ) CountPx
|
|
from t_orderheader
|
|
join ss_piutang on T_OrderHeaderID = SsPiutangT_OrderHeaderID
|
|
and SsPiutangType in ( 'A1','A2','A3')
|
|
and T_OrderHeaderIsActive = 'Y' and date(T_OrderHeaderDate) = ?
|
|
join ss_piutang_test on SsPiutangID = SsPiutangTestSsPiutangID
|
|
join t_test on SsPiutangTestT_TestID = T_TestID
|
|
join nat_test on T_TestNat_TestID = Nat_TestID,
|
|
branch
|
|
group by Nat_TestID,
|
|
Nat_TestNat_GroupID,
|
|
Nat_TestNat_SubGroupID
|
|
";
|
|
|
|
$qry_sales = $this->db->query($sql_sales, [
|
|
$T_OrderHeaderDate
|
|
]);
|
|
|
|
if (!$qry_sales) {
|
|
$this->db->trans_rollback();
|
|
$this->sys_error_db("error select sales ss_piutang", $this->db);
|
|
exit;
|
|
}
|
|
|
|
$row_sales = $qry_sales->result_array();
|
|
if (count($row_sales) == 0) {
|
|
// $this->sys_error('sales Tidak Ada');
|
|
return json_encode(
|
|
array(
|
|
'status' => 'OK',
|
|
'message' => 'Data Tidak Ada',
|
|
'data' => $row_sales,
|
|
'total_recors' => count($row_sales)
|
|
)
|
|
);
|
|
} else {
|
|
return json_encode(
|
|
array(
|
|
'status' => 'OK',
|
|
'data' => $row_sales,
|
|
'total_recors' => count($row_sales)
|
|
)
|
|
);
|
|
}
|
|
}
|
|
|
|
function upload_nat_sales_nat_report_range($start_date = "", $end_date = "")
|
|
{
|
|
// $T_OrderHeaderDate = "";
|
|
if ($start_date == "") {
|
|
$start_date = date('Y-m-d');
|
|
}
|
|
|
|
if ($end_date == "") {
|
|
$end_date = date('Y-m-d');
|
|
}
|
|
|
|
if ($end_date < $start_date) {
|
|
$this->reply([
|
|
"status" => "ERR",
|
|
'message' => "Start date lebih besar dari end date"
|
|
]);
|
|
exit;
|
|
}
|
|
|
|
// check max jarak start date dan end date adalah 10 hari but failed
|
|
if (($end_date - $start_date) / 60 / 60 / 24 > 10) {
|
|
$this->reply([
|
|
"status" => "ERR",
|
|
'message' => "Maksimal jarak start date dan end date adalah 10 hari"
|
|
]);
|
|
exit;
|
|
}
|
|
|
|
for ($date = $start_date; $date <= $end_date;) {
|
|
// echo $date;
|
|
$date = date("Y-m-d", strtotime("$date + 1 day"));
|
|
// echo "\n";
|
|
// echo $date;
|
|
|
|
$this->upload_nat_sales_nat_report_gzcompress($date);
|
|
sleep(3);
|
|
}
|
|
}
|
|
|
|
function upload_nat_sales_nat_report_gzcompress($date = "")
|
|
{
|
|
// check format tanggal
|
|
|
|
$T_OrderHeaderDate = "";
|
|
if ($date == "") {
|
|
$T_OrderHeaderDate = date('Y-m-d');
|
|
} else {
|
|
$T_OrderHeaderDate = $date;
|
|
}
|
|
|
|
|
|
$this->db->trans_begin();
|
|
$j_param = $this->get_sales($T_OrderHeaderDate);
|
|
$result = json_decode($j_param, true);
|
|
|
|
if (count($result['data']) > 0) {
|
|
$size = round(strlen($j_param) / 1024, 2);
|
|
$z_param = gzcompress($j_param, 9);
|
|
$size_z = round(strlen($z_param) / 1024, 2);
|
|
|
|
$url = "http://$this->IP_ADDRESS/one-api/one-dash/R_sales/r_sales_upload_log";
|
|
//$this->log("Post to $url | size : $size k | comprezzed $size_z k");
|
|
$resp = $this->post($url, $z_param);
|
|
$j_resp = json_decode($resp, true);
|
|
// $j_resp_x = $this->get_param_z();
|
|
// print_r($j_resp);
|
|
// print_r($resp);
|
|
// print_r($j_resp_x);
|
|
|
|
if ($j_resp["status"] == "OK") {
|
|
$this->db->trans_commit();
|
|
// $this->db->trans_rollback();
|
|
$this->reply(["status" => "OK", 'message' => "Proses upload sudah berhasil. $url, $size_z k"]);
|
|
} else {
|
|
$this->db->trans_rollback();
|
|
// print_r($j_resp['status']);
|
|
$this->reply([
|
|
"status" => "ERR",
|
|
'message' => "Gagal update",
|
|
'debug' => print_r($resp, true)
|
|
]);
|
|
}
|
|
} else {
|
|
$this->db->trans_rollback();
|
|
// print_r($j_resp['status']);
|
|
$this->reply([
|
|
"status" => "OK",
|
|
'message' => "Tidak Ada Data",
|
|
'debug' => print_r($resp, true)
|
|
]);
|
|
}
|
|
}
|
|
// nat_sales end
|
|
|
|
// nat payment start
|
|
function get_payment($T_OrderHeaderDate)
|
|
{
|
|
// print_r($T_OrderHeaderDate);
|
|
$sql_payment = "with branch
|
|
as (
|
|
select M_BranchID, M_BranchCode
|
|
from
|
|
m_branch where M_BranchIsActive='Y' and M_BranchIsDefault ='Y'
|
|
),
|
|
payment
|
|
as (
|
|
select
|
|
T_OrderHeaderID,
|
|
T_OrderHeaderM_CompanyID,
|
|
date(T_OrderHeaderDate) orderDay,
|
|
month(T_OrderHeaderDate) orderMonth,
|
|
quarter(T_OrderHeaderDate) orderQuarter,
|
|
year(T_OrderHeaderDate) orderYear,
|
|
ssPiutangDate,
|
|
ssPiutangTotal piutangTotal,
|
|
sum(ssPiutangPayment) as paymentTotal,
|
|
max(ssPiutangIsLunas) isLunas
|
|
from t_orderheader
|
|
join ss_piutang on SsPiutangT_OrderHeaderID = T_OrderHeaderID
|
|
and date(T_OrderHeaderDate) = ?
|
|
and date(SsPiutangDate) >= ?
|
|
and SsPiutangIsActive = 'Y'
|
|
and SsPiutangPayment <> 0
|
|
group by
|
|
T_OrderHeaderID, SsPiutangDate
|
|
)
|
|
|
|
select
|
|
M_BranchID,
|
|
M_BranchCode,
|
|
T_OrderHeaderM_CompanyID,
|
|
orderDay,
|
|
orderMonth,
|
|
orderQuarter,
|
|
orderYear,
|
|
ssPiutangDate paymentDay,
|
|
month(ssPiutangDate) month,
|
|
year(ssPiutangDate) year,
|
|
quarter(ssPiutangDate) quarter,
|
|
sum(piutangTotal) piutang,
|
|
sum(paymentTotal) paymentTotal,
|
|
sum(piutangTotal) - sum(paymentTotal) sisaPiutang
|
|
from payment,branch
|
|
group by
|
|
T_OrderHeaderM_CompanyID,
|
|
orderDay,
|
|
orderMonth,
|
|
orderQuarter,
|
|
orderYear,
|
|
paymentDay,
|
|
month,
|
|
year,
|
|
quarter
|
|
order by paymentDay";
|
|
|
|
$qry_payment = $this->db->query($sql_payment, [
|
|
$T_OrderHeaderDate,
|
|
$T_OrderHeaderDate,
|
|
]);
|
|
|
|
if (!$qry_payment) {
|
|
$this->db->trans_rollback();
|
|
$this->sys_error_db("error select sales ss_piutang", $this->db);
|
|
exit;
|
|
}
|
|
|
|
$row_payment = $qry_payment->result_array();
|
|
if (count($row_payment) == 0) {
|
|
// $this->sys_error('sales Tidak Ada');
|
|
return json_encode(
|
|
array(
|
|
'status' => 'OK',
|
|
'message' => 'Data Tidak Ada',
|
|
'data' => $row_payment,
|
|
'total_recors' => count($row_payment)
|
|
)
|
|
);
|
|
} else {
|
|
return json_encode(
|
|
array(
|
|
'status' => 'OK',
|
|
'total_recors' => count($row_payment),
|
|
'data' => $row_payment,
|
|
|
|
)
|
|
);
|
|
}
|
|
}
|
|
|
|
function upload_nat_payment_nat_report_gzcompress($date = "")
|
|
{
|
|
// check format tanggal
|
|
|
|
$T_OrderHeaderDate = "";
|
|
if ($date == "") {
|
|
$T_OrderHeaderDate = date('Y-m-d');
|
|
} else {
|
|
$T_OrderHeaderDate = $date;
|
|
}
|
|
|
|
|
|
$this->db->trans_begin();
|
|
$j_param = $this->get_payment($T_OrderHeaderDate);
|
|
$result = json_decode($j_param, true);
|
|
|
|
if (count($result['data']) > 0) {
|
|
$size = round(strlen($j_param) / 1024, 2);
|
|
$z_param = gzcompress($j_param, 9);
|
|
$size_z = round(strlen($z_param) / 1024, 2);
|
|
|
|
$url = "http://$this->IP_ADDRESS/one-api/one-dash/R_payment/r_payment_upload_log";
|
|
// $this->log("Post to $url | size : $size k | comprezzed $size_z k");
|
|
$resp = $this->post($url, $z_param);
|
|
$j_resp = json_decode($resp, true);
|
|
// $j_resp_x = $this->get_param_z();
|
|
// print_r($j_resp);
|
|
// print_r($resp);
|
|
// print_r($j_resp_x);
|
|
|
|
if ($j_resp["status"] == "OK") {
|
|
$this->db->trans_commit();
|
|
// $this->db->trans_rollback();
|
|
$this->reply(["status" => "OK", 'message' => "Proses upload sudah berhasil. $url | $size_z k"]);
|
|
} else {
|
|
$this->db->trans_rollback();
|
|
// print_r($j_resp['status']);
|
|
$this->reply([
|
|
"status" => "ERR",
|
|
'message' => "Gagal update",
|
|
'debug' => print_r($resp, true)
|
|
]);
|
|
}
|
|
} else {
|
|
$this->db->trans_rollback();
|
|
// print_r($j_resp['status']);
|
|
$this->reply([
|
|
"status" => "OK",
|
|
'message' => "Tidak Ada Data",
|
|
'debug' => print_r($resp, true)
|
|
]);
|
|
}
|
|
}
|
|
|
|
function upload_nat_payment_nat_report_range($start_date = "", $end_date = "")
|
|
{
|
|
// $T_OrderHeaderDate = "";
|
|
if ($start_date == "") {
|
|
$start_date = date('Y-m-d');
|
|
}
|
|
|
|
if ($end_date == "") {
|
|
$end_date = date('Y-m-d');
|
|
}
|
|
|
|
if ($end_date < $start_date) {
|
|
$this->reply([
|
|
"status" => "ERR",
|
|
'message' => "Start date lebih besar dari end date"
|
|
]);
|
|
exit;
|
|
}
|
|
|
|
// check max jarak start date dan end date adalah 10 hari but failed
|
|
if (($end_date - $start_date) / 60 / 60 / 24 > 10) {
|
|
$this->reply([
|
|
"status" => "ERR",
|
|
'message' => "Maksimal jarak start date dan end date adalah 10 hari"
|
|
]);
|
|
exit;
|
|
}
|
|
|
|
for ($date = $start_date; $date <= $end_date;) {
|
|
// echo $date;
|
|
$date = date("Y-m-d", strtotime("$date + 1 day"));
|
|
// echo "\n";
|
|
// echo $date;
|
|
|
|
$this->upload_nat_payment_nat_report_gzcompress($date);
|
|
sleep(3);
|
|
}
|
|
}
|
|
// nat payment end
|
|
|
|
}
|