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()
    {
        $result = refill\RefillFactory::instance()->goods();
        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\card_type($card_no);

        if($card_type == mtopcard\UnknownCard) {
            return [false,"充值卡不是电话和中石油中石化类型."];
        }
        
        if($card_type === mtopcard\PetroChinaCard)
        {
            if(empty($params['idcard'])) {
                return [false,'中石油需要参数没有包含身份证号码:idcard'];
            }
            if(empty($params['card_name'])) {
                return [false,'参数没有包含身份证姓名:card_name'];
            }
        }

        if(empty($params['notifyurl'])) {
            return [false,'参数没有包含notifyurl'];
        }
        if(empty($params['order_sn'])) {
            return [false,'参数没有包含贵方唯一订单号:order_sn'];
        }
        $card_type = mtopcard\card_type($card_no);
        if($card_type === mtopcard\UnknownCard) {
            return [false,'卡类型无法识别'];
        }

        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

        $card_type = mtopcard\card_type($card_no);
        $providers = refill\RefillFactory::instance()->find_providers($amount,$card_type);

        if(empty($providers)) {
            return self::outerr(202,"找不到合适的充值通道");
        }

        $buyer_id = $this->adminid();
        $minfo = new member_info($buyer_id);

        $calc = new refill\CalcMerchantPrice($this->mchid(),$amount,$card_type);
        $mch_amount = $calc->calc_vgoods_price([]);
        if($mch_amount > $minfo->available_predeposit()) {
            return self::outerr(203,"余额不足");
        }

        $refill_state = false;
        foreach ($providers as $provider)
        {
            $channel_name = $provider->name();
            [$goods_id, $price] = $provider->goods($amount);

            $input['goods_id'] = $goods_id;
            $input['quantity'] = 1;
            $input['price'] = $price;

            $input['buyer_phone'] = $minfo->mobile();
            $input['buyer_name']  = $minfo->truename();
            $input['buyer_msg']   = $_POST['buyer_msg'] ?? '';
            $input['order_from'] = 1;
            $input['pd_pay'] = true;

            $logic_buy_virtual = Logic('buy_virtual');
            $result = $logic_buy_virtual->buyStep3($input, $buyer_id,[$calc,'calc_vorder_amount'],true);

            $mod_refill = Model('refill_order');
            if($result['state'] === true)
            {
                $order_sn = $result['data']['order_sn'];
                $order_id = $result['data']['order_id'];
                //虚拟订单表信息扩展
                $orderext = ['order_id' => $order_id,'order_sn' => $order_sn,'mchid' => $this->mchid(),
                    'refill_amount' => $amount,'mch_order' => $mch_order,
                    'notify_url' => $notify_url,'channel_name' => $channel_name,
                    'mch_amount' => $mch_amount,'channel_amount' => $price,'order_time' => time(),
                    'card_type' => $card_type,'card_no' => $card_no];
                $mod_refill->add_refill($orderext);
            }
            else {
                continue;
            }

            $params = ['order_sn' => $order_sn];
            [$state,$err] = $provider->add($card_no,$card_type,$amount,$params);
            if($state) {
                $trade_no = $err;
                $logic_vr_order = Logic("vr_order");
                $logic_vr_order->changeOrderStateSend($order_id);
                $data = ['commit_time' => time(),'ch_trade_no' => $trade_no];
                $mod_refill->edit($order_id,$data);
                $refill_state = true;
                break;
            }
            else {
                Log::record("channel:{$channel_name} err:{$err}");
                $logic_vr_order = Logic("vr_order");
                $order_info = Model('vr_order')->getOrderInfo(['order_id' => $order_id]);
                $logic_vr_order->changeOrderStateCancel($order_info,'',"调用{$channel_name}接口失败");
            }
        }

        if($refill_state) {
            return self::outsuccess(['state' => true,'trade_no' => $order_sn]);
        } else {
            return self::outerr(204,"充值失败.");
        }
    }

    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['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,"交易号trade_no错误");
        }

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

        if(empty($refill_info)) {
            return self::outerr(201,"无此订单");
        }

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

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

        if($order_info['order_state'] == ORDER_STATE_SEND) {
            //发起订单查询请求
        }

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

        return self::outsuccess($result);
    }
}