f1-jxyh-php-8525/process/Task.php

<?php
namespace process;


use app\business\TaskBusiness;
use support\Db;
use support\Log;
use Workerman\Timer;
/** 产品每日分红 */
class Task
{
    public function onWorkerStart()
    {
        Timer::add(20, function(){
            $this->task();
        });

    }
    public function task()
    {
        try {
            $taskData=Db::table('wa_cron_task')
                ->where('day_dividend_time','<=',time())
                ->where('is_finish',1)
                ->limit(150)
                ->pluck('id')
                ->toArray();
            foreach ($taskData as $k=>$v){
                TaskBusiness::taskOne($v);
            }
        }catch (\Throwable $exception){
            Log::channel('task')->error($exception->getMessage());
        }
    }
}