xyzshop/helper/refill/event/card_crash.php

<?php

namespace refill\event;

use refill\order;
use refill\util;
use mtopcard;
use Log;

# 规避相同手机卡号撞单问题解
class card_crash extends IEventRefill
{
    use crash;
    public const cache_name = 'card_crash';
    protected $mChannels = [];
    protected $mSuccInterval = 900;

    public function __construct()
    {
    }
    public function load($cfgs)
    {
        $channels = $cfgs['channels'] ?? '';
        Log::record("card_crash load channels={$cfgs['channels']} succ_interval={$cfgs['succ_interval']}.", Log::DEBUG);
        $channels = explode(',',$channels);

        $this->mChannels = [];
        foreach ($channels as $item) {
            $this->mChannels[] = trim($item);
        }

        $this->mSuccInterval = intval($cfgs['succ_interval'] ?? 900);
    }

    public function onBeforeSubmit(order $order) : bool
    {
        if(!$order->is_phone()) {
            return true;
        }

        $card_no = $order->card_no();
        $ret = $this->can_submit($card_no);

        if(!$ret)
        {
            $mchid = $order->mchid();
            $mch_order = $order->mch_order();

            $mod_refill = Model('refill_order');
            $val = $mod_refill->get_detail($mchid,$mch_order);

            if(!empty($val)) {
                $params = json_decode($val['params'],true);
                util::async_add($params, 60);
                Log::record("card_crash mchid=$mchid,mch_order $mch_order sleep one minute.",Log::DEBUG);

                return false;
            }
        }

        return true;
    }
    public function onSubmit(order $order)
    {
        if(!$order->is_phone()) {
            return;
        }

        $card_no = $order->card_no();
        $oid = $order->unique_id();

        $this->submit($card_no,$oid);
    }


    public function onBeforeCommit(order $order, $ch_name): bool
    {
        if(!$order->is_phone()) {
            return true;
        }

        $card_no = $order->card_no();
        $oid = $order->unique_id();

        return $this->can_commit($card_no, $oid, $ch_name);
    }

    public function onCommit(order $order, $ch_name)
    {
        if(!$order->is_phone()) {
            return;
        }

        $card_no = $order->card_no();
        $oid = $order->unique_id();

        $this->commit($card_no, $oid, $ch_name);
    }

    public function onNeterror(order $order, $ch_name)
    {
        if(!$order->is_phone()) {
            return;
        }

        $card_no = $order->card_no();
        $oid = $order->unique_id();

        $this->submit($card_no,$oid);
    }

    public function onNotify($refill_info, $order_info, $success)
    {
        $card_type = intval($refill_info['card_type']);
        if (!in_array($card_type, [mtopcard\ChinaMobileCard, mtopcard\ChinaUnicomCard, mtopcard\ChinaTelecomCard])) {
            return;
        }

        $oid = "{$refill_info['mchid']}-{$refill_info['mch_order']}";
        $ch_name = $refill_info['channel_name'];
        $card_no = $refill_info['card_no'];

        $this->notify($card_no, $oid, $ch_name, $success);
    }

    public function onComplete($refill_info, $order_info, $success)
    {
        $card_type = intval($refill_info['card_type']);
        if (!in_array($card_type, [mtopcard\ChinaMobileCard, mtopcard\ChinaUnicomCard, mtopcard\ChinaTelecomCard])) {
            return;
        }

        $oid = "{$refill_info['mchid']}-{$refill_info['mch_order']}";
        $ch_name = $refill_info['channel_name'];
        $card_no = $refill_info['card_no'];

        $this->complete($card_no, $oid, $ch_name, $success);
    }
}