xyzshop/helper/queue/monitor.php

<?php

namespace queue;

use queue\DispatcherClient;
use queue\DispatcherDB;
use queue\IClient;

class MonitorDB extends IQueueDB
{
    public function __construct()
    {
        parent::__construct('REFILL_MONITOR_QUEUE');
    }
}

class MonitorClient extends IJsonClient
{
    private static $stInstance = null;

    public static function instance()
    {
        if (self::$stInstance == null) {
            self::$stInstance = new MonitorClient();
        }

        return self::$stInstance;
    }

    public function __construct()
    {
        $db = new MonitorDB();
        parent::__construct($db);
    }

    public function onSubmit($mchid,$time,$spec,$card_type,$mch_amount)
    {
        $params = ['mchid' => $mchid,'time' => $time,'spec' => $spec,'card_type' => $card_type,'mch_amount' => $mch_amount];
        $this->push('mch_submit',$params);
    }

    public function onCallback($mchid,$time,$spec,$card_type,$mch_amount,$channel_amount,$succ)
    {
        if($succ) {
            $params = ['mchid' => $mchid,'time' => $time,'spec' => $spec,'card_type' => $card_type,'mch_amount' => $mch_amount,'channel_amount' => $channel_amount];
            $this->push('mch_succ',$params);
        } else {
            $params = ['mchid' => $mchid,'time' => $time,'spec' => $spec,'card_type' => $card_type,'mch_amount' => $mch_amount];
            $this->push('mch_fail',$params);
        }
    }

    public function onNetCheck($chname, $time, $succ)
    {
        $params = ['channel_name' => $chname,'time' => $time];
        if($succ) {
            $this->push('net_succ',$params);
        } else {
            $this->push('net_fail',$params);
        }
    }

    public function onCommit($chname,$time,$spec,$card_type,$channel_amount)
    {
        $params = ['channel_name' => $chname, 'time' => $time, 'spec' => $spec, 'card_type' => $card_type, 'channel_amount' => $channel_amount];
        $this->push('ch_commit', $params);
    }

    public function onNotify($chname,$time,$spec,$card_type,$channel_amount,$period,$succ)
    {
        $params = ['channel_name' => $chname, 'time' => $time, 'spec' => $spec, 'card_type' => $card_type, 'channel_amount' => $channel_amount, 'period' => $period];
        if ($succ) {
            $this->push('ch_succ', $params);
        } else {
            $this->push('ch_fail', $params);
        }
    }
}