run_task(); return 0; } /** * 执行任务 * * */ public function run_task(){ // 实例化 $Model = New Model(); $time = time(); // 活动结束 $activeList = $Model->query()->where([['end_time','<=',time()],['status','=',1]])->get(); $activeList = $activeList->toArray(); $activeList = array_column($activeList,null,'id'); if ($activeList){ $activeIds = array_column($activeList,'id'); $regiment = RegimentModel::query()->where('status','=',1)->whereIn('id',$activeIds)->get()->toArray(); var_dump($regiment); if ($regiment){ var_dump(222);exit(); foreach ($regiment as $v){ //虚拟成团 if ($activeList[$v['active_id']]['virtually'] == 2){ //修改状态 RegimentModel::query()->where('id','=',$v['id'])->update(['status'=>3]); RegimentRecord::query()->where('regiment_id','=',$v['id'])->update(['status'=>2]); //查询记录 $regimentRecordList = regimentRecord::query()->where('regiment_id','=',$v['id'])->get(); $regimentRecordListIds = array_column($regimentRecordList,'id'); //修改订单 $res = Orders::query()->whereIn('id',$regimentRecordListIds)->update(['status'=>2]); }else{ RegimentModel::query()->where('id','=',$v['id'])->update(['status'=>2]); RegimentRecord::query()->where('regiment_id','=',$v['id'])->update(['status'=>3]); //查询记录 $regimentRecordList = regimentRecord::query()->where('regiment_id','=',$v['id'])->get(); $regimentRecordListIds = array_column($regimentRecordList,'id'); //修改订单 $res = Orders::query()->whereIn('id',$regimentRecordListIds)->update(['status'=>11]); } } } $res = $Model->query()->whereIn('id',$activeIds)->update(['status'=>2]); } //团过期 $regimentList = RegimentModel::query()->where([['status','=',1],['end_time','<=',$time]])->get(); if ($regimentList){ foreach ($regimentList as $v){ $activeList = $Model->query()->where('id','=',$v['active_id'])->first(); //虚拟成团 if ($activeList['virtually'] == 2){ //修改状态 $r = RegimentModel::query()->where('id','=',$v['id'])->update(['status'=>3]); RegimentRecord::query()->where('regiment_id','=',$v['id'])->update(['status'=>2]); //查询记录 $regimentRecordList = regimentRecord::query()->where('regiment_id','=',$v['id'])->get(); $regimentRecordListIds = array_column($regimentRecordList,'id'); //修改订单 $res = Orders::query()->whereIn('id',$regimentRecordListIds)->update(['status'=>2]); }else{ $r = RegimentModel::query()->where('id','=',$v['id'])->update(['status'=>2]); RegimentRecord::query()->where('regiment_id','=',$v['id'])->update(['status'=>3]); //查询记录 $regimentRecordList = regimentRecord::query()->where('regiment_id','=',$v['id'])->get(); $regimentRecordListIds = array_column($regimentRecordList,'id'); //修改订单 $res = Orders::query()->whereIn('id',$regimentRecordListIds)->update(['status'=>11]); } } } } }