問題描述

請教大佬們，crontab動態(tài)操作更好的方法
我現(xiàn)在是基于Timer實現(xiàn)的，不知道各位有啥好的方法推薦

下面是我的代碼

<?php
namespace app\process;
use app\admin\logic\system\SystemCrontabLogic;
use Workerman\Crontab\Crontab;
use Workerman\Timer;

class Task
{
    protected $crontab=[];
    public function onWorkerStart($worker)
    {
        $this->init();
        $this->heartBeat();
    }
    public function init()
    {
        $logic = new SystemCrontabLogic();
        $taskList = $logic->where('status', 1)->select();
        $allTaskKeys =[];
        foreach ($taskList as $task){
            if(!isset($this->crontab[$task->id])){
                $crontab = new Crontab($task->rule, function () use ($logic, $task) {
                    $logic->run($task->id);
                },$task->name);
                $this->crontab[$task->id] = $crontab;
            }
            $allTaskKeys[$task->id] = $task->id;
        }
        $tasks = array_keys($allTaskKeys);
        foreach ($this->crontab as $key=>$task) {
            if (!in_array($key, $tasks)) { //已經(jīng)從數(shù)據(jù)庫刪除
                $crontab = $this->crontab[$key];
                $crontab->remove($task->getId());
                unset($this->crontab[$key]);
            }
        }
    }
    public function run($args)
    {
        $list = Crontab::getAll();
        foreach ($list as $item){
            var_dump('任務(wù)ID=>'.$item->getId().'任務(wù)名稱=>'.$item->getName());
        }
        echo '任務(wù)調(diào)用：'.date('Y-m-d H:i:s')."\n";
        //        var_dump('參數(shù):'. $args);
    }
    private function heartBeat()
    {
        Timer::add(60, function () {
            echo '心跳檢測：'.date('Y-m-d H:i:s')."\n";
            $this->init();
        });
    }
}