<?php


namespace refill\zzx;

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


use refill;
use mtopcard;
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['mid'] = config::MID;
        $params['cardNo'] = $card_no;
        $params['amount'] = $amount;
        $params['orderNum'] = $other['order_sn'];
        $params['backUrl'] = urlencode(config::NOTIFY_URL);
        return $params;
    }

    private function sign($params)
    {
        ksort($params);

        $content = '';
        foreach ($params as $key => $val)
        {
            if(empty($val)){
                continue;
            }
            $content .= "{$key}={$val}&";
        }
        $content .= "key=".config::KEY;

        Log::record("body={$content}",Log::DEBUG);
        return strtoupper(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_post_data(config::ORDER_URL,json_encode($params),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];
            } elseif ($resp['code'] === '0000' && $resp['respCode'] === '1111') {
                return [true, $resp['msg'], false];
            } else {
                return [false, $resp['msg'], false];
            }
        }
    }

    public function query($refill_info)
    {
        $params['mid'] = config::MID;
        $params['orderNum'] = $refill_info['order_sn'];
        $params['sign'] = $this->sign($params);

        $resp = http_post_data(config::QUERY_URL,json_encode($params),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['code'] === '0000') {
                $order_state = ORDER_STATE_SUCCESS;
            } elseif ($resp['code'] === '0004') {
                $order_state = ORDER_STATE_CANCEL;
            } elseif ($resp['code'] === '0005') {
                $order_state = ORDER_STATE_SEND;
            } else {
                return [false, $resp['msg']];
            }
            return [true, $order_state];
        }
    }

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