<?php
require_once("helper.php");
require_once("../../system/config/connect.php");
require_once("../../system/config/setting.php");
require_once("../../system/function/TeleAPI.php");
$TeleAPI = new TeleAPI($TeleToken);
$curl = new CurlOrder;

$ShennHL->query("UPDATE cron SET tgl = '$timestamp' WHERE code = 'mrsts'");

$get_ChooseID = filter_entities($_GET['oid']);
$query = (!$get_ChooseID) ? '' : "tid = '$get_ChooseID' AND";

$data = $ShennHL->query("SELECT * FROM trx_ppob WHERE $query status = 'pending'");
if ($data->num_rows == 0) {
    $response = [0 => ['provider' => 'unknown','order_id' => 'unknown','error' => 'Order Pending not found','is_error' => 'true']];
} else {
    while($row = $data->fetch_assoc()) {
        $tid = $row['tid'];
        $prov = $row['provider'];

        if($prov == 'PLM') {
            $json_result = $curl->connectHeaderPost(provider('PLM','link').'/status/pulsa',array('Authorization: Bearer '.provider('PLM','apikey'),'accept: application/json'),array('trxid' => $tid));
            $note = $json_result['data']['note'];
            $status = statusMR($json_result['data']['status']);
            $error = fixError($json_result['result'],$json_result['message'].$json_result['data']);
        } if($prov == 'ATL') {
            $json_result = $curl->connectPost(provider('ATL','link').'/pulsa',array('api_key' => provider('ATL','apikey'),'action' => 'status','id' => $tid));
            $note = $json_result['data']['catatan'];
            $status = statusMR($json_result['data']['status']);
            $error = fixError($json_result['status'],$json_result['data']['pesan']);
        } if($prov == 'SMMINDO') {
            $json_result = $curl->connectPost(provider('SMMINDO','link').'/api/json.php',array('api_key' => provider('SMMINDO','apikey'),'action' => 'status','id' => $tid));
            $note = $json_result['data']['catatan'];
            $status = statusMR($json_result['data']['status']);
            $error = fixError($json_result['status'],$json_result['data']['pesan']);
        } if($prov == 'DPEDIA') {
            $json_result = $curl->connectPost(provider('DPEDIA','link').'/status/pulsa',array('api_key' => provider('DPEDIA','apikey'),'code' => $tid));
            $note = $json_result['catatan'];
            $status = statusMR($json_result['status']);
            $error = fixError('false',$json_result['error']);
        }

        $reply = "User: ".$row['user']."\nService: ".$row['service']."\nTarget: ".$row['target']."\nPrice: ".currency($row['price'])."\nNote: $note\nStatus: $status\nProvider: $prov";
        if($error == 'null') {
            $response[] = array('provider' => $prov,'trx_id' => $tid,'status' => $status,'note' => $note,'jabber' => $reply,'error' => 'null','is_error' => 'false');
        } else {
            $response[] = array('provider' => $prov,'trx_id' => $tid,'error' => $error,'is_error' => 'true');

        }
    }
}

#################################################################################################################################################################################
#-----------------------------------------------------INI BAGIAN INPUT KE DATABASE JANGAN DISENTUH KALAU GAK NGERTI APA APA-----------------------------------------------------#
#################################################################################################################################################################################

$dbno = 0;
while($dbno < count($response)) {
    $result = $response[$dbno];

    $s_provider = $result['provider'];
    $s_order_id = $result['trx_id'];
    $s_status = $result['status'];
    $s_note = $result['note'];
    $s_jabber = $result['jabber'];
    $s_error = $result['error'];

    $s_message = "Server Information!\nTransaksi Mobile Recharge dengan order id $s_order_id diubah ke status $s_status, info selengkapnya:\n\n$s_jabber";
    if ($s_status != 'pending') $TeleAPI->sendMessage($TeleGroup,$s_message);

    if($result['is_error'] == 'false') {
        $ShennHL->query("UPDATE trx_ppob SET status = '$s_status', note = '$s_note' WHERE tid = '$s_order_id'");
        $output[] = array('result' => 'true','provider' => $s_provider,'order_id' => $s_order_id,'status' => $s_status,'note' => $s_note);
    } else {
        $output[] = array('result' => 'false','provider' => $s_provider,'order_id' => $s_order_id,'error' => $s_error);
    }

    $dbno++;
}

print_r(json_encode($output, JSON_PRETTY_PRINT));