setName('check:dispatch-record-notice') ->setDescription('dispatch跟进记录通知,每分钟一次'); } protected function execute(Input $input, Output $output){ $Model = new OrderDispatchRecord(); $now = date('Y-m-d H:i:s'); //创建三十分名以上未接的任务 $Model->where('need_notice',1) ->where('notice_time','<=',$now) ->where('status',0) ->chunk(100, function ($list) { $ids = []; $dispatchIds = []; foreach ($list as $item) { //todo...通知逻辑 $ids[] = $item->id; $dispatchIds = $item->dispatch_id; //修改状态 } OrderDispatchRecord::whereIn('id',$ids)->update(['status'=>1]); OrderDispatch::where('id',$dispatchIds)->where('follow',1)->update(['follow'=>0]); }); } }