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

<?php


namespace refill\saihu;

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


use refill;
use Log;

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

    private function req_params(string $card_no, int $amount, array $other)
    {
        $params['app_id'] = config::APP_ID;
        $params['gas_userid'] = $card_no;
        $params['cardnum'] = $amount;
        $params['ordersn'] = $other['order_sn'];

        return $params;
    }

    private function sign($params)
    {
        $key = config::APP_KEY;
        $content = $params['app_id'] . $key . $params['gas_userid'] . $params['ordersn'] . $params['cardnum'];

        Log::record("body={$content}", Log::DEBUG);
        return md5($content);
    }

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

        $resp = http_request(config::ORDER_URL, $params, 'GET', false, [], $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];
            } elseif ($resp['code'] == 0) {
                return [true, $resp['result'], false];
            } else {
                return [false, $resp['msg'], false];
            }
        }
    }

    public function query($refill_info)
    {
        $params['ordersn'] = $refill_info['order_sn'];
        $params['app_id'] = config::APP_ID;
        $params['sign'] = md5(config::APP_ID . config::APP_KEY . $refill_info['order_sn']);

        $resp = http_request(config::QUERY_URL, $params);
        if (empty($resp)) {
            return [false, '系统错误'];
        }
        else
        {
            Log::record($resp, Log::DEBUG);
            $resp = json_decode($resp, true);
            if (empty($resp)) {
                return [false, '系统错误'];
            }
            elseif ($resp['code'] == 0)
            {
                if ($resp['result']['order_state'] == 1) {
                    $order_state = ORDER_STATE_SUCCESS;
                } elseif ($resp['result']['order_state'] == 9) {
                    $order_state = ORDER_STATE_CANCEL;
                } elseif ($resp['result']['order_state'] == 0){
                    $order_state = ORDER_STATE_SEND;
                } else {
                    return [false, $resp['result']];
                }

                return [true, $order_state];
            }
            else {
                return [false, $resp['msg']];
            }
        }
    }

    public function balance()
    {
        return [false, '暂无余额接口'];
    }

    public function callback()
    {
        return false;
    }
}