ngds/common/libs/taskQueue/TaskFunc.php

<?php

namespace common\libs\taskQueue;

use common\helpers\Cache;
use common\helpers\Date;
use common\models\forms\HistoryBonusForm;
use common\models\forms\OrderLogisticsForm;
use common\models\TaskQueue;

class TaskFunc
{
    /**
     * 初始化自动备份余额任务
     */
    public static function initAutoBakBalance(){
        // 查看数据库中是否存在未开始的备份奖金表的任务，如果没有就添加一个新任务
        if(!TaskQueue::find()->where('TYPE=:TYPE AND CONTENT=:CONTENT AND STARTED_AT>:STARTED_AT', [':TYPE'=>Queue::TYPE_FUNC, ':CONTENT'=>TaskFunc::class.'::autoBakBonusTable', ':STARTED_AT'=>Date::nowTime()])->asArray()->exists()){
            // 获取站点配置中的备份时间
            $config = Cache::getSystemConfig();
            $backupWeekDate = (int)$config['backupWeekDate']['VALUE'];
            $backupTime = (int)$config['backupTime']['VALUE'];
            Queue::instance()->addTask(Queue::TYPE_FUNC, TaskFunc::class.'::autoBakBonusTable', [], Queue::LOOP_TYPE_WEEK, $backupWeekDate.','.$backupTime.':00', 0);
        }
    }

    /**
     * 自动备份奖金表
     * @throws \yii\base\InvalidConfigException
     *
     */
    public static function autoBakBonusTable(){
        $form = new HistoryBonusForm();
        $form->taskAutoBackup();
    }

    /**
     * 测试队列任务
     */
    public static function testTaskQueue(){
        print_r('执行到测试任务'.PHP_EOL);
    }

    /**
     * 初始化订单物流任务
     */
    public static function initAutoOrderLogistics()
    {
        // 查看数据库中是否存在未开始的发送订单的任务，如果没有就添加一个新任务
        $taskQueue = TaskQueue::find()->where('TYPE = :TYPE AND CONTENT = :CONTENT AND STARTED_AT > :STARTED_AT', [':TYPE' => Queue::TYPE_FUNC, ':CONTENT' => TaskFunc::class . '::autoSendLogistics', ':STARTED_AT' => Date::nowTime()])->asArray()->exists();
        if (!$taskQueue) {
            // 获取站点配置中的发送订单时间
            $config = Cache::getSystemConfig();
            $sendTime = (int)$config['sendOrderTime']['VALUE'];
            Queue::instance()->addTask(Queue::TYPE_FUNC, TaskFunc::class . '::autoSendLogistics', [], Queue::LOOP_TYPE_DAY, $sendTime . ':00', 0);
        }
    }

    /**
     * 自动发送订单到物流站
     */
    public static function autoSendLogistics(){
        $form = new OrderLogisticsForm();
        $form->taskAutoSendEmail();
    }
}