xyzshop/helper/refill/api/xyz/leyou/RefillOil.php

<?php

namespace refill\leyou;

require_once(BASE_HELPER_RAPI_PATH . '/leyou/config.php');

use refill;
use Log;
use mtopcard;

class RefillOil extends refill\IRefillOil
{
    public function __construct($cfgs)
    {
        parent::__construct($cfgs);
    }

    private function req_params(int $card_no, int $amount, int $card_type, string $order_sn)
    {
        $cur_time = function () {
            return date('Y-m-d H:i:s', time());
        };

        $params['username'] = config::USER_NAME;
        $params['orderNumber'] = $order_sn;
        $params['number'] = $card_no;
        $params['productNo'] = config::product_code[$card_type][$amount];

        $params['money'] = $amount;
        $params['orderTime'] = $cur_time();
        $params['notifyUrl'] = config::NOTIFY_URL;

        return $params;
    }

    public function add($card_no, $card_type, $amount, $params, &$net_errno = 0)
    {
        $params = $this->req_params($card_no, $amount, $card_type, $params['order_sn']);

        $sign = $this->sign($params);
        $params['sign'] = $sign;

        $resp = http_request(config::ORDER_URL, $params, 'POST', false, config::ExtHeaders, $net_errno);

        if (empty($resp)) {
            return [false, '系统错误', true];
        }
        else
        {
            Log::record($resp, Log::DEBUG);
            $resp = json_decode($resp, true);
            if (empty($resp)) {
                return [false, '系统错误', true];
            }

            $status = $resp['status'];
            if ($status === 122600) { //success
                return [true, '', false];
            }
            elseif (in_array($status,[122610,122616])) { //manual handle
                $net_errno = "HTTP-$status";
                return [false, $resp['data'], true];
            }
            else { //error
                return [false, $resp['data'], false];
            }
        }
    }

    public function query($refill_info)
    {
        $waterno_by_voucher = function($voucher):string {
            $matches = [];
            $ret = preg_match("/\:(\d+)/",$voucher,$matches);
            if ($ret === 1 && !empty($matches)){
                return $matches[1];
            }
          return '';
        };
        
        $params['username'] = config::USER_NAME;
        $params['orderNumber'] = $refill_info['order_sn'];
        $params['sign'] = $this->sign($params);

        $resp = http_request(config::QUERY_URL, $params, 'POST', false, config::ExtHeaders);
        if (empty($resp)) {
            return [false, '网络错误'];
        }
        else
        {
            Log::record($resp, Log::DEBUG);
            $resp = json_decode($resp, true);

            if (empty($resp)) {
                return [false, '网络错误'];
            }
            elseif ($resp['status'] === 122600 )
            {
                $status = $resp['data']['status'];
                if ($status === 5) {
                    $official_sn = config::extract_official_sn($resp['data']['voucher']);
                    Model('refill_order')->edit($refill_info['order_id'], ['official_sn' => $official_sn]);
                    $order_state = ORDER_STATE_SUCCESS;
                } elseif ($status === 6) {
                    $order_state = ORDER_STATE_CANCEL;
                } else
                {
                    $order_state = ORDER_STATE_SEND;
                }

                return [true, $order_state];
            }
            elseif ($resp['status'] === 122617) {
                return [false, '订单不存在，需人工核实.'];
            }
            else
            {
                return [false, $resp['desc']];
            }
        }
    }

    public function balance()
    {
        $params['username'] = config::USER_NAME;
        $params['sign'] = $this->sign($params);

        $s = config::ExtHeaders;
        $resp = http_request(config::BALANCE_URL, $params, 'POST', false, config::ExtHeaders);

        if (empty($resp)) {
            return [false, '系统错误'];
        }
        else
        {
            Log::record($resp, Log::DEBUG);
            $resp = json_decode($resp, true);
            if (empty($resp)) {
                return [false, '系统错误'];
            }
            elseif ($resp['status'] === 122600) {
                return [true, $resp['data']];
            }
            else
            {
                return [false, $resp['desc']];
            }
        }
    }

    private function sign($param): string
    {
        $originalStr = '';
        foreach (config::SIGN_KEY_SORT as $key)
        {
            if (!empty($param[$key])) {
                $originalStr .= $param[$key];
            }
        }
        $originalStr .= config::APP_KEY;
        return md5($originalStr);
    }
}