xyzshop/rdispatcher/proxy.php

<?php

use refill;
use mtopcard;

require_once (BASE_ROOT_PATH . '/helper/model_helper.php');

class proxy
{
    const max_retry = 5;
    const max_time_out = 120;

    public function add($params)
    {
        $refill_order = Model('refill_order');

        $mchid = $params['mchid'];
        $buyer_id = $params['buyer_id'];
        $amount = intval($params['amount']);

        $card_no = $params['card_no'];
        $mch_order = $params['mch_order'];
        $notify_url = $params['notify_url'];
        $idcard = $params['idcard'] ?? '';
        $card_name = $params['card_name'] ?? '';

        $order_time = $params['order_time'] ?? time();
        $commit_times = $params['commit_times'] ?? 0;
        $last_order_id = $params['order_id'] ?? 0;

        $org_quality = intval($params['org_quality']) ?? 0;
        $card_type   = intval($params['card_type']) ?? 0;

        Log::record("proxy::add 1" ,Log::DEBUG);

        $need_check = false;
        if($card_type == 0)
        {
            $card_type = mtopcard\card_type($card_no);
            if($card_type != mtopcard\PetroChinaCard && $card_type != mtopcard\SinopecCard) {
                $need_check = true;
            }
        }
        Log::record("proxy::add 2" ,Log::DEBUG);

        [$org_quality,$quality] = refill\RefillFactory::instance()->find_quality($mchid,$amount,$card_type,$org_quality,$commit_times,time() - $order_time);
        Log::record("org_quality = {$org_quality} quality = {$quality}",Log::DEBUG);

        if ($need_check)
        {
            $valided = mtopcard\valid_phone($card_no);
            if (!$valided) {
                $order_id = refill\RefillFactory::instance()->zero_order($mchid, $buyer_id, $amount, $card_no,
                    $mch_order, $idcard, $card_name, $notify_url, $quality, $org_quality, $order_time, $commit_times,
                    "无效的手机号");
                QueueClient::push("NotifyMerchantComplete", ['order_id' => $order_id, 'manual' => false]);
                return;
            }
        }

        Log::record("proxy::add 3" ,Log::DEBUG);

        [$errcode, $errmsg, $order_id, $neterr] = refill\RefillFactory::instance()->add($mchid, $buyer_id, $amount, $card_no,
            $mch_order, $idcard, $card_name, $notify_url, $quality,$org_quality,
            $order_time, $commit_times, $last_order_id,$card_type);
        $params['commit_times'] += 1;
        $commit_times += 1;

        Log::record("proxy::add 4" ,Log::DEBUG);

        if($errcode !== true)
        {
            $fNotify = true;
            if(($errcode === refill\errcode::MERCHANT_REFILL_ERROR && $neterr) || $errcode == refill\errcode::PROVIDER_OVERLOAD)
            {
                [$org_quality,$quality] = refill\RefillFactory::instance()->find_quality($mchid,$amount,$card_type,$org_quality,$commit_times,time() - $order_time);
                if ($quality > 0) {
                    $fNotify = false;
                    $params['order_id'] = $order_id;
                    if($order_id > 0) {
                        $refill_order->edit($order_id, ['is_retrying' => 1]);
                    }
                    \Swoole\Coroutine::sleep(2);
                    refill\util::push_add($params);
                }
            }

            if($fNotify)
            {
                if ($order_id === 0)
                {
                    $order_info = $this->latest_order($refill_order, $mchid, $mch_order);
                    if (empty($order_info)) {
                        $order_id = refill\RefillFactory::instance()->zero_order($mchid, $buyer_id, $amount, $card_no,
                            $mch_order, $idcard, $card_name, $notify_url, $quality, $org_quality, $order_time, $commit_times, $errmsg);
                    } else {
                        $order_id = $order_info['order_id'];
                    }
                }
                else {
                    $refill_order->edit($order_id, ['notify_time' => time(), 'notify_state' => 1]);
                }

                QueueClient::push("NotifyMerchantComplete", ['order_id' => $order_id,'manual' => false]);
            }
        }
    }

    private function latest_order($refill_order,$mchid,$mch_order)
    {
        $orders = $refill_order->getMerchantOrderList(['mchid' => $mchid,'mch_order' => $mch_order]);
        if(empty($orders)) {
            return [];
        }
        else {
            $orders[0];
        }
    }

    public function notify($channel,$input)
    {
        return refill\RefillFactory::instance()->notify($channel,$input);
    }

    public function notify_merchant($order_id,$manual)
    {
        return refill\RefillFactory::instance()->notify_merchant($order_id,$manual);
    }
    public function query($order_id)
    {
        return refill\RefillFactory::instance()->query($order_id);
    }
}