xyzshop/helper/refill/RefillBase.php

<?php

namespace refill;

require_once(BASE_HELPER_PATH . '/queue/rdispatcher.php');
require_once(BASE_HELPER_PATH . '/mtopcard/mtopcard.php');
require_once(BASE_HELPER_PATH . '/refill/IRefill.php');
require_once(BASE_HELPER_PATH . '/refill/IRefillOil.php');
require_once(BASE_HELPER_PATH . '/refill/IRefillPhone.php');
require_once(BASE_HELPER_PATH . '/refill/IRefillCallBack.php');
require_once(BASE_HELPER_PATH . '/refill/ProviderManager.php');
require_once(BASE_HELPER_PATH . '/refill/CalcMerchantPrice.php');
require_once(BASE_HELPER_PATH . '/refill/util.php');
require_once(BASE_HELPER_PATH . '/refill/errcode.php');

use Log;
use mtopcard;
use QueueClient;
use member_info;
use Exception;
use trans_wapper;

class RefillBase
{
    protected $mPolicy;

    protected $mLimits = [];
    protected function __construct()
    {
    }

    public function allow($mchid,$card_type,$amount,$quality)
    {
        return $this->mPolicy->allow($mchid,$card_type,$amount,$quality);
    }

    public function goods()
    {
        return $this->mPolicy->goods();
    }

    public function load()
    {
        $this->mPolicy->load();
    }

    public function find_quality($mchid,$spec,$card_type,$org_quality,$times,$period): array {
        return $this->mPolicy->find_quality($mchid,$spec,$card_type,$org_quality,$times,$period);
    }

    public function notify($chname, $input)
    {
        $caller = $this->mPolicy->getCaller($chname);
        if($caller === false) {
            return false;
        }
        elseif ($caller->verify($input))
        {
            [$order_id, $success, $can_try, $need_handle] = $caller->notify($input);
            if (!$need_handle) {
                return true;
            }

            if ($order_id !== false) {
                return $this->proc_notify($order_id, $success, $can_try, $chname);
            } else {
                Log::record("系统无此订单ID：{$order_id}", Log::ERR);
            }
        }
        else {
            Log::record("{$chname} 签名失败.");
        }

        return true;
    }

    private function proc_notify($order_id,$success, $can_try,$chname)
    {
        $mod_order = Model('vr_order');
        $order_info = $mod_order->getOrderInfo(['order_id' => $order_id]);
        $order_state = intval($order_info['order_state']);
        if ($order_state != ORDER_STATE_SEND) {
            return false;
        }

        $logic_vr_order = Logic("vr_order");
        $mod_refill = Model('refill_order');

        try
        {
            $tran = new trans_wapper($mod_order,'notify change order state trans');

            $order_info = $mod_order->getOrderInfo(['order_id' => $order_id],'*',true,true);
            $order_state = intval($order_info['order_state']);
            if ($order_state != ORDER_STATE_SEND) {
                $tran->commit();
                return false;
            }

            $refill_info = $mod_refill->getOrderInfo(['order_id' => $order_id,'inner_status' => 0]);

            $quality = intval($refill_info['quality']);
            $card_type = intval($refill_info['card_type']);
            $spec = intval($refill_info['refill_amount']);

            if ($success) {
                util::incr_notify($chname, $card_type, $spec, $quality, true);
                $logic_vr_order->changeOrderStateSuccess($order_id);
            }
            elseif ($can_try)
            {
                if(!empty($refill_info))
                {
                    util::incr_notify($chname, $card_type, $spec, $quality, false);
                    $logic_vr_order->changeOrderStateCancel($order_info, '', "{$chname}接口回调通知失败，正在重试");
                    [$can_retry,$params] = $this->retry($refill_info, $order_info);
                    if ($can_retry) {
                        $mod_refill->edit($order_id, ['is_retrying' => 1]);
                        $tran->commit();

                        if(defined('USE_COROUTINE') && USE_COROUTINE) {
                            \Swoole\Coroutine::sleep(1);
                        }
                        util::push_add($params);

                        return true;
                    }
                }
            }
            else {
                util::incr_notify($chname, $card_type, $spec, $quality, false);
                $logic_vr_order->changeOrderStateCancel($order_info, '', "{$chname}接口回调通知失败,不可重试.");
            }
            $tran->commit();
        }
        catch (Exception $ex) {
            $tran->rollback();
            Log::record("Error:" . $ex->getMessage(), Log::ERR);
        }

        $mod_refill->edit($order_id, ['notify_time' => time(), 'notify_state' => 1]);
        QueueClient::push("NotifyMerchantComplete", ['order_id' => $order_id,'manual' => false]);

        return true;
    }

    private function retry(array $refill_info, array $order_info)
    {
        $mchid = intval($refill_info['mchid']);
        $spec  = intval($refill_info['refill_amount']);
        $card_type = intval($refill_info['card_type']);
        $org_quality = intval($refill_info['org_quality']);
        $used_time = time() - intval($refill_info['order_time']);
        $commit_times = intval($refill_info['commit_times']);

        [$org_quality,$quality] = $this->find_quality($mchid,$spec,$card_type,$org_quality,$commit_times,$used_time);
        if($quality <= 0) return [false,null];

        $params = [ 'mchid' => $refill_info['mchid'],
            'buyer_id' => $order_info['buyer_id'],
            'amount' => $refill_info['refill_amount'],
            'card_no' => $refill_info['card_no'],
            'card_type' => $refill_info['card_type'],
            'org_quality' => $org_quality,
            'mch_order' =>  $refill_info['mch_order'],
            'notify_url' => $refill_info['notify_url'],
            'idcard' => $refill_info['idcard'] ?? '',
            'card_name' => $refill_info['card_name'] ?? '',
            'order_time' => $refill_info['order_time'],
            'commit_times' => $refill_info['commit_times'] + 1,
            'order_id' => $refill_info['order_id']
        ];

        return [true,$params];
    }

    public function zero_order($mchid, $buyer_id, $amount, $card_no,
                        $mch_order, $idcard, $card_name, $notify_url,$quality,$org_quality,
                        $order_time = 0, $commit_times = 0,$errmsg='')
    {
        $card_type = mtopcard\card_type($card_no);
        $minfo = new member_info($buyer_id);

        $calc = new ZeroMerchantPrice($mchid, $amount, $card_type,$quality);
        $mch_amount = $calc->calc_vgoods_price([]);

        $input['goods_id'] = ZERO_GOODS_ID;
        $input['quantity'] = 1; //数量
        $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'];

            $logic_vr_order = Logic("vr_order");
            $order_info = Model('vr_order')->getOrderInfo(['order_id' => $order_id]);
            $logic_vr_order->changeOrderStateCancel($order_info, '', '无法下单创建0元订单');

            if (empty($mch_order)) {
                $mch_order = $order_sn;
            }
            //虚拟订单表信息扩展
            $orderext = ['order_id' => $order_id, 'order_sn' => $order_sn, 'mchid' => $mchid,
                'refill_amount' => $amount, 'mch_order' => $mch_order,
                'idcard' => $idcard, 'card_name' => $card_name,
                'notify_url' => $notify_url, 'channel_name' => '',
                'mch_amount' => $mch_amount, 'channel_amount' => 0,
                'order_time' => $order_time, 'commit_times' => $commit_times,
                'commit_time' => time(),'notify_state' => 1,'notify_time' => time(),
                'card_type' => $card_type, 'card_no' => $card_no, 'quality' => $quality, 'org_quality' => $org_quality,
                'err_msg' => $errmsg];
            $mod_refill->add_refill($orderext);
            return $order_id;
        }
        else {
            return 0;
        }
    }

    //$quality,质量
    //返回值：[ 错误码，错误信息，订单ID，是否是网络错误]
    //说明：错误码为true 表示成功
    //     其它情况，则需要判断订单ID
    public function add($mchid, $buyer_id, $amount, $card_no,
                        $mch_order, $idcard, $card_name, $notify_url, $quality, $org_quality,
                        $order_time, $commit_times, $last_orderid = 0, $card_type = 0)
    {
        if($card_type == 0) {
            $card_type = mtopcard\card_type($card_no);
        }
        [$providers,$overload] = $this->mPolicy->find_providers($amount,$card_type,$quality);

        if (empty($providers))
        {
            Log::record("canot find any providers",Log::DEBUG);
            if($overload) {
                return [errcode::PROVIDER_OVERLOAD, "匹配不到合适的充值通道",$last_orderid,false];
            }
            else {
                return [errcode::CANNOT_MATCH_PROVIDER, "匹配不到合适的充值通道",$last_orderid,false];
            }
        }

        if (empty($notify_url)) {
            $notify_url = "";
        }

        try {
            $minfo = new member_info($buyer_id);
            $calc = new CalcMerchantPrice($mchid, $amount, $card_type,$quality,$this->mPolicy);
            $mch_amount = $calc->calc_vgoods_price([]);
        }
        catch (Exception $ex) {
            return [errcode::MERCHANT_PRICE_UNSETTING, "没有协商商品价格",$last_orderid,false];
        }

        $available = $minfo->available_predeposit();
        if ($mch_amount > $available) {
            Log::record("下单时机构余额不足,可用余额为：{$available}", Log::DEBUG);
            return [errcode::MERCHANT_SHORT_MONEY, "余额不足支付订单",$last_orderid,false];
        }

        $refill_state = false;
        $order_success = false;

        foreach ($providers as $provider)
        {
            $channel_name = $provider->name();
            Log::record("select channel name = {$channel_name}",Log::DEBUG);

            //通道价格大于客户价格，换通道.
            [$goods_id, $price] = $provider->goods($quality,$amount,$card_type);
            if ($price >= $mch_amount) continue;

            Log::record("start create order",Log::DEBUG);

            $input['goods_id'] = $goods_id;
            $input['quantity'] = 1; //数量
            $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'];

                if($last_orderid > 0) {
                    $mod_refill->edit($last_orderid, ['inner_status' => 1]);
                }
                $last_orderid = $order_id;

                if (empty($mch_order)) {
                    $mch_order = $order_sn;
                }

                //虚拟订单表信息扩展
                $orderext = ['order_id' => $order_id, 'order_sn' => $order_sn, 'mchid' => $mchid,
                    'refill_amount' => $amount, 'mch_order' => $mch_order,
                    'idcard' => $idcard, 'card_name' => $card_name,
                    'notify_url' => $notify_url, 'channel_name' => $channel_name,
                    'mch_amount' => $mch_amount, 'channel_amount' => $price,
                    'order_time' => $order_time, 'commit_times' => $commit_times,
                    'card_type' => $card_type, 'card_no' => $card_no,'quality' => $quality,'org_quality'=> $org_quality];
                $mod_refill->add_refill($orderext);

                if(!$this->pay_completed($order_sn)) {
                    $logic_vr_order = Logic("vr_order");
                    $order_info = Model('vr_order')->getOrderInfo(['order_id' => $order_id]);
                    $logic_vr_order->changeOrderStateCancel($order_info, '', "预存款不足以支付该订单");
                    break;
                }
            }
            else {
                Log::record("{$result['msg']}",Log::ERR);
                continue;
            }

            $order_success = true;
            $params = ['order_sn' => $order_sn, 'idcard' => $idcard, 'card_name' => $card_name,
                'buyer_id' => $buyer_id,
                'quality' => $quality,'order_id' => $order_id];

            util::incr_commit_pre($channel_name,$card_type,$amount,$quality);

            $start = microtime(true);
            [$state, $errmsg, $neterr] = $provider->add($card_no, $card_type, $amount, $params);
            Log::record(sprintf(" %s add request time=%.6f", $channel_name,microtime(true) - $start), Log::DEBUG);

            if ($state)
            {
                //提交成功
                util::incr_commit($channel_name,$card_type,$amount,$quality,true);
                $trade_no = $errmsg;
                if ($provider->refill_type() == 'api') {
                    $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;

                //如果对方没有回调能力，则启动主动查询.
                if($provider->callback() === false) {
                    QueueClient::async_push("QueryRefillState",['order_id' => $order_id],180);
                }

                break;
            }
            else {
                //提交失败
                util::incr_commit($channel_name,$card_type,$amount,$quality,false);
                Log::record("channel:{$channel_name} err:{$errmsg}");
                $logic_vr_order = Logic("vr_order");
                $order_info = Model('vr_order')->getOrderInfo(['order_id' => $order_id]);
                $logic_vr_order->changeOrderStateCancel($order_info, '', "调用{$channel_name}接口失败");
                $mod_refill->edit($order_id, ['commit_time' => time()]);
            }
        }

        if ($refill_state) {
            return [true, '', $last_orderid,false];
        }
        elseif($order_success) {
            return [errcode::MERCHANT_REFILL_ERROR, "充值失败",$last_orderid,$neterr];
        }
        else {
            return [errcode::MERCHANT_REFILL_ERROR, "充值失败",$last_orderid,false];
        }
    }

    private function pay_completed($order_sn)
    {
        $logic_payment = Logic('payment');
        $order = $logic_payment->getVrOrderInfo($order_sn);
        $api_pay_amount = $order['data']['api_pay_amount'];

        return ($api_pay_amount == ncPriceFormat(0.00));
    }

    public function notify_merchant($order_id,$manual)
    {
        if ($order_id <= 0) {
            return [false, "订单ID小于0"];
        }

        $vr_order = Model('vr_order');
        $refill_order = Model('refill_order');

        $order_info = $vr_order->getOrderInfo(['order_id' => $order_id]);
        $refill_info = $refill_order->getOrderInfo(['order_id' => $order_id]);

        if (empty($order_info) || empty($refill_info)) {
            return [false, "无此订单"];
        }

        //手动通知，之所以不做尝试，是担心客户方状态处理不当
        if (!$manual && $refill_info['mch_notify_state'] != 0) {
            return [false, "已经通知客户方"];
        }

        $notify_url = $refill_info['notify_url'];
        if (empty($notify_url)) {
            $refill_order->edit($order_id, ['mch_notify_state' => 1, 'mch_notify_times' => 0]);
            return [false, "回调地址为空"];
        }

        ////////////////////////////////////////////////////////////////////////////////////////////////////////////////
        $order_state = intval($order_info['order_state']);
        if ($order_state !== ORDER_STATE_CANCEL && $order_state !== ORDER_STATE_SUCCESS) {
            return [false, "错误的订单状态,不能通知."];
        }
        $resp = $this->mPolicy->notify($order_info,$refill_info);
        ////////////////////////////////////////////////////////////////////////////////////////////////////////////////
        if ($resp) {
            $refill_order->edit($order_id, ['mch_notify_state' => 1, 'mch_notify_times' => ['exp', 'mch_notify_times+1']]);
            return [true, ""];
        }
        else {
            $refill_order->edit($order_id, ['mch_notify_times' => ['exp', 'mch_notify_times+1']]);
            $times = $refill_info['mch_notify_times'] + 1;

            if ($times > 80) {
                $refill_order->edit($order_id, ['mch_notify_state' => 2]);
            } else {
                $N = intval($times / 5);
                $period = intval(pow(2, $N));
                QueueClient::async_push("NotifyMerchantComplete", ['order_id' => $order_id,'manual' => false], $period);
            }

            return [false, "通知{$times}次，失败."];
        }
    }

    public function query($order_id)
    {
        $mod_order = Model('vr_order');
        $order_info = $mod_order->getOrderInfo(['order_id' => $order_id]);

        if(empty($order_info)) return false;

        $mod_refill = Model('refill_order');
        $refill_info = $mod_refill->getOrderInfo(['order_id' => $order_id,'inner_status' => 0]);
        $chname = $refill_info['channel_name'];

        if($refill_info['notify_state'] == 1) {
            QueueClient::push("NotifyMerchantComplete", ['order_id' => $order_id,'manual' => false]);
            return true;
        }

        try
        {
            $tran = new trans_wapper($mod_order,'query order state trans');
            $order_info = $mod_order->getOrderInfo(['order_id' => $order_id],'*',true,true);
            if($refill_info['is_retrying'] == 1) {
                $query_able = false;
            }
            elseif($order_info['order_state'] == ORDER_STATE_SEND) {
                $query_able = true;
            }
            else {
                $query_able = false;
            }
            $tran->commit();
        }
        catch (Exception $ex) {
            $tran->rollback();
            Log::record($ex->getMessage(),Log::ERR);
        }

        if($query_able)
        {
            if(empty($chname)) return false;

            $provider = $this->mPolicy->provider($chname);
            if(empty($provider)) return false;

            [$state, $order_state] = $provider->query($refill_info);
            if(!$state) {
                QueueClient::async_push("QueryRefillState",['order_id' => $order_id],180);
                return false;
            }
            elseif($order_state == ORDER_STATE_SUCCESS) {
                $this->proc_notify($order_id,true,false,$chname);
            }
            elseif($order_state == ORDER_STATE_CANCEL) {
                $this->proc_notify($order_id,false,true,$chname);
            }
            else {
                QueueClient::async_push("QueryRefillState",['order_id' => $order_id],180);
            }
        }
        
        return true;
    }

    public function manual_success($order_id)
    {
        $order_id = intval($order_id);
        if($order_id <= 0) return false;

        try {
            $mod_order = Model('vr_order');
            $tran = new trans_wapper($mod_order,'manual_success r state trans');

            $order_info = $mod_order->getOrderInfo(['order_id' => $order_id],'*',true,true);
            if(!empty($order_info) && $order_info['order_state'] == ORDER_STATE_SEND) {
                $tran->commit();

                $logic_vr_order = Logic("vr_order");
                $logic_vr_order->changeOrderStateSuccess($order_id);
                $refill_order = Model('refill_order');
                $refill_order->edit($order_id, ['notify_time' => time(), 'notify_state' => 1,'is_retrying' => 0]);
                mtopcard\cards_helper::assign($order_id);
            }
            else {
                $tran->commit();
            }

            QueueClient::push("NotifyMerchantComplete", ['order_id' => $order_id,'manual' => true]);
            return true;
        }
        catch (Exception $ex) {
            $tran->rollback();
            Log::record("manual_success exception:{$ex->getMessage()}",Log::ERR);
            return false;
        }
    }

    public function manual_cancel($order_id)
    {
        $order_id = intval($order_id);
        if($order_id <= 0) return false;

        try {
            $mod_order = Model('vr_order');
            $tran = new trans_wapper($mod_order,'manual_cancel state trans');

            $order_info = $mod_order->getOrderInfo(['order_id' => $order_id],'*',true,true);
            if(!empty($order_info) && $order_info['order_state'] == ORDER_STATE_SEND) {
                $tran->commit();

                $logic_vr_order = Logic("vr_order");
                $logic_vr_order->changeOrderStateCancel($order_info, '', "后台手动回调通知失败");
                $refill_order = Model('refill_order');
                $refill_order->edit($order_id, ['notify_time' => time(), 'notify_state' => 1,'is_retrying' => 0]);
                mtopcard\cards_helper::reuse($order_id);
            }
            else {
                $tran->commit();
            }

            QueueClient::push("NotifyMerchantComplete", ['order_id' => $order_id,'manual' => true]);
            return true;
        }
        catch (Exception $ex) {
            $tran->rollback();
            Log::record("manual_cancel exception:{$ex->getMessage()}",Log::ERR);
            return false;
        }
    }
}