xyzshop/admin/control/refill_cron.php

<?php
require_once(BASE_HELPER_PATH . '/refill/util.php');
use refill\util;
use Log;
class refill_cronControl extends SystemControl
{
    public function __construct()
    {
        parent::__construct();
    }

    public function indexOp()
    {
        $condition = [];
        if(!empty($_GET['search'])) {
            $search = $_GET['search'];
            $condition['params'] = ['like', '%'.$search.'%'];
        }
        $mod = Model('cron');
        $cron = $mod->getCronList($condition);

        $merchants = [];
        $merchant_list = Model('')->table('merchant')->limit(1000)->select();
        foreach ($merchant_list as  $value) {
            $merchants[$value['mchid']] = $value;
        }

        foreach ($cron as $key => $value) {
            $params = unserialize($value['params']);
            foreach ($params as $param) {
                $mchid = $param['params']['mchid'];
            }
            $cron[$key]['params'] = $params;
            $cron[$key]['company_name'] = $merchants[$mchid]['company_name'];
        }
        Tpl::output('show_page', $mod->showpage());
        Tpl::output('cron', $cron);
        Tpl::showpage('refill.cron');
    }

    public function DelOp()
    {
        $id = $_GET['id'];
        $mod = Model('cron');
        $cron_info = $mod->getCronInfo(['id' => $id]);
        if (empty($cron_info)) {
            showMessage('队列信息不存在');
        }
        if($cron_info['exetime'] <= time()) {
            showMessage('队列任务时间限制');
        }
        $result = $mod->delCron(['id' => $id]);
        if (!$result) {
            showMessage('删除失败');
        }
        $params = unserialize($cron_info['params']);
        foreach ($params as $param) {
            $mchid = $param['params']['mchid'];
            $mch_order = $param['params']['mch_order'];
        }
        Log::record("del cron mchid:{$mchid},mch_order:{$mch_order}",Log::DEBUG);
        if(!empty($mch_order) && !empty($mchid)) {
            util::pop_queue_order($mchid,$mch_order);
        }
        showMessage('删除成功');
    }
}