mkm/TaskSystem
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

更新

Browse Source
This commit is contained in:
mkm 2023-08-24 14:30:42 +08:00
parent 87b9e0a9f9
commit d522bfe816
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
app/task/TaskCron.php
View File

@ -28,14 +28,14 @@ class TaskCron extends Task{
// $tiem_end=$time+86399; // $tiem_end=$time+86399;
$all=TaskTemplate::where('cron_time','<',$time)->where('status',1)->with('company')->select()->toArray(); $all=TaskTemplate::where('cron_time','<',$time)->where('status',1)->with('company')->select()->toArray();
// $all=TaskSchedulingPlan::where('start_time','between',[$time,$tiem_end])->where('is_execute',0)->with(['template_info','scheduling'])->select()->toArray(); // $all=TaskSchedulingPlan::where('start_time','between',[$time,$tiem_end])->where('is_execute',0)->with(['template_info','scheduling'])->select()->toArray();
$company_id=0; $company_id=[];
foreach($all as $k=>$v){ foreach($all as $k=>$v){
queue(TaskAdd::class,$v); queue(TaskAdd::class,$v);
$company_id=$v['company_id']; $company_id[]=$v['company_id'];
} }
if($company_id!=0){ $arr=array_unique($company_id);
if(count($arr)){
Company::where('id',$company_id)->inc('day_count')->update(); Company::where('id','in',$arr)->inc('day_count')->update();
} }
Log::error('定时任务下发执行成功'.date('Y-m-d H:i:s')); Log::error('定时任务下发执行成功'.date('Y-m-d H:i:s'));
//...具体的任务执行 //...具体的任务执行