作者 赵彬吉

update

@@ -36,7 +36,7 @@ class SyncSubmitTask extends Command @@ -36,7 +36,7 @@ class SyncSubmitTask extends Command
36 } 36 }
37 $this->output('任务' . $task_id . '开始'); 37 $this->output('任务' . $task_id . '开始');
38 $task_info = SyncSubmitTaskModel::find($task_id); 38 $task_info = SyncSubmitTaskModel::find($task_id);
39 - if (empty($task_info) || $task_info->status !=2) { 39 + if (empty($task_info) || $task_info->status !=3) {
40 $this->output('任务不存在或者已执行'); 40 $this->output('任务不存在或者已执行');
41 continue; 41 continue;
42 } 42 }
@@ -38,7 +38,7 @@ class SyncSubmitTaskDistribution extends Command @@ -38,7 +38,7 @@ class SyncSubmitTaskDistribution extends Command
38 } else { 38 } else {
39 $tasks = SyncSubmitTaskModel::where('status', 0)->limit(100)->get(); 39 $tasks = SyncSubmitTaskModel::where('status', 0)->limit(100)->get();
40 foreach ($tasks as $task) { 40 foreach ($tasks as $task) {
41 - $task->status = 2; 41 + $task->status = 3;
42 $task->save(); 42 $task->save();
43 Redis::lpush('sync_submit_task', $task->id); 43 Redis::lpush('sync_submit_task', $task->id);
44 } 44 }