xyzshop/mobile/control/refill.php

<?php

require_once(BASE_ROOT_PATH . '/mobile/control/merchant.php');
require_once(BASE_HELPER_PATH . '/refill/RefillFactory.php');
require_once(BASE_HELPER_PATH . '/mtopcard/mtopcard.php');
require_once(BASE_HELPER_PATH . '/model/member_info.php');


//商家充值接口中心
class refillControl extends merchantControl
{
    public function __construct()
    {
        parent::__construct();
    }

    public function goodsOp()
    {
        $goods_list = refill\RefillFactory::instance()->goods();

        $sorter = function (array $items) {
            $ret = [];
            foreach ($items as $key => $val) {
                sort($val);
                $ret[$key] = $val;
            }
            return $ret;
        };

        $goods_list = $sorter($goods_list);

        $result = [];
        foreach ($goods_list as $card_type => $value) {
            $key = mtopcard\scard_type($card_type);
            $result[$key] = $value;
        }

        return self::outsuccess($result);
    }

    private function check_params($params)
    {
        if(empty($params['cardno'])) {
            return [false,'参数没有包含cardno'];
        }
        if(empty($params['amount'])) {
            return [false,'参数没有包含充值金额:amount'];
        }

        $card_no = $_GET['cardno'];
        $card_type = mtopcard\simple_card_type($card_no);
        if($card_type == mtopcard\UnknownCard) {
            return [false,'卡类型无法识别'];
        }

        if(empty($params['notifyurl'])) {
            return [false,'参数没有包含notifyurl'];
        }
        if(empty($params['order_sn'])) {
            return [false,'参数没有包含贵方唯一订单号:order_sn'];
        }

        return [true,""];
    }

    public function addOp()
    {
        [$success,$error] = $this->check_params($_GET);
        if($success === false) {
            return self::outerr(201,$error);
        }

        $amount = intval($_GET['amount']);
        $card_no = $_GET['cardno'];
        $notify_url = $_GET['notifyurl'];
        $mch_order = $_GET['order_sn'];   //对方的order编号
        $quality = $_GET['quality'] ?? 0;

        if(!$this->check_mchorder($this->mchid(),$mch_order)) {
            return self::outerr(205,"客户订单号重复或者为空.");
        }

        $card_type = mtopcard\simple_card_type($card_no);
        if($card_type === mtopcard\SinopecCard || $card_type === mtopcard\PetroChinaCard)
        {
            if(!$this->can_refill($card_no)) {
                return self::outerr(206,"平台不支持该卡充值.");
            }

            $allow = refill\RefillFactory::instance()->allow($this->mchid(),$card_type,$amount,$quality);
            if(!$allow)
            {
                if ($card_type === mtopcard\SinopecCard) {
                    $text = "中石化";
                }
                else {
                    $text = "中石油";
                }
                return self::outerr(207,"今日贵司{$amount}{$text}充值库存已经用完.");
            }
        }

        $params = ['mchid' => $this->mchid(),
            'buyer_id' => $this->adminid(),
            'amount' => $amount,
            'card_no' => $card_no,
            'mch_order' => $mch_order,
            'notify_url' => $notify_url,
            'org_quality' => $quality];

        [$can_refill, $period] = refill\util::can_commit($card_no, $card_type);
        if ($can_refill === false) {
            refill\util::push_queue($this->mchid(),$mch_order,time() + $period);
            $state = refill\util::async_add($params, $period);
        } else {
            refill\util::push_queue($this->mchid(),$mch_order,time());
            $state = refill\util::push_add($params);
        }

        if ($state === true) {
            return self::outsuccess(['state' => true]);
        } else {
            $code = $state;
            return self::outerr($code, '提交失败');
        }
    }

    private function can_refill($cardno)
    {
        $card_info = refill\util::read_card($cardno);
        if(empty($card_info)) return false;

        return intval($card_info['black_card']) === 0;
    }

    private function check_mchorder($mchid,$mch_order)
    {
        if(empty($mch_order)) {
            return false;
        }
        else {
            $refill_order = Model('refill_order');
            $ret = $refill_order->getOrderInfo(['mchid' => $mchid,'mch_order' => $mch_order]);

            return empty($ret);
        }
    }

    public function balanceOp()
    {
        $uid = $this->adminid();
        $minfo = new member_info($uid);
        $available = $minfo->available_predeposit();
        return self::outsuccess(['balance' => $available]);
    }

    public function query_tradeOp()
    {
        $mchid = $this->mchid();
        $trade_no = $_GET['trade_no'];
        if(empty($trade_no)) {
            return self::outerr(201,"交易号trade_no错误");
        }

        $mod_refill = Model('refill_order');
        $refill_info = $mod_refill->getOrderInfo(['order_sn' => $trade_no,'mchid' => $mchid]);

        $vr_order = Model('vr_order');
        $order_info = $vr_order->getOrderInfo(['order_sn' => $trade_no]);

        if(empty($refill_info) || empty($order_info)) {
            return self::outerr(201,"无此交易号");
        }

        $result = $this->format($order_info,$refill_info);

        return self::outsuccess($result);
    }

    private function format($order_info,$refill_info)
    {
        $result = [];
        $result['mchid'] = $refill_info['mchid'];
        $result['trade_no'] = $refill_info['order_sn'];
        $result['order_sn'] = $refill_info['mch_order'];
        $result['card_no'] = $refill_info['card_no'];
        $result['card_type'] = $refill_info['card_type'];
        $result['refill_amount'] = $refill_info['refill_amount'];
        $result['order_amount'] = $refill_info['mch_amount'];
        $result['order_time'] = $refill_info['order_time'];
        $result['success_time'] = $refill_info['notify_time'];
        $result['official_sn'] = $refill_info['official_sn'] ?? "";

        if($refill_info['is_retrying']) {
            $result['order_state'] = ORDER_STATE_NEW;
        }
        else {
            $result['order_state'] = $order_info['order_state'];
        }

        return $result;
    }

    public function queryOp()
    {
        $mchid = $this->mchid();
        $order_sn = $_GET['order_sn']; //用户方的订单号，对应数据库中的mch_order

        if(empty($order_sn)) {
            return self::outerr(201,"客户订单号order_sn错误");
        }

        $mod_refill = Model('refill_order');
        $refill_info = $mod_refill->getOrderInfo(['mch_order' => $order_sn,'mchid' => $mchid,'inner_status' => 0]);

        if(empty($refill_info))
        {
            $ret = refill\util::query_queue($mchid,$order_sn);
            if ($ret > 0) {
                $result['mchid'] = $mchid;
                $result['order_sn'] = $order_sn;
                $result['order_state'] = ORDER_STATE_QUEUE;
                return self::outsuccess($result);
            } else {
                return self::outerr(202, "无此订单");
            }
        }
        else
        {
            $vr_order = Model('vr_order');
            $order_info = $vr_order->getOrderInfo(['order_sn' => $refill_info['order_sn']]);

            if(empty($order_info)) {
                return self::outerr(203,"无此交易号");
            }

            if($order_info['order_state'] == ORDER_STATE_SEND) {
                QueueClient::push("QueryRefillState",['order_id' => $refill_info['order_id']]);
            }

            $result = $this->format($order_info,$refill_info);
            return self::outsuccess($result);
        }
    }
}