|
...
|
...
|
@@ -70,7 +70,7 @@ class SyncSubmitTaskZbj extends Command |
|
|
|
$task_info->status = 2;
|
|
|
|
$task_info->remark = Str::substr($e->getMessage(), 0, 200);
|
|
|
|
} else {
|
|
|
|
Redis::lpush('sync_submit_task', $task_id);
|
|
|
|
Redis::lpush('sync_submit_task_zbj', $task_id);
|
|
|
|
}
|
|
|
|
$task_info->save();
|
|
|
|
|
|
...
|
...
|
@@ -81,13 +81,13 @@ class SyncSubmitTaskZbj extends Command |
|
|
|
|
|
|
|
public function getTaskId()
|
|
|
|
{
|
|
|
|
$task_id = Redis::rpop('sync_submit_task');
|
|
|
|
$task_id = Redis::rpop('sync_submit_task_zbj');
|
|
|
|
if (empty($task_id)) {
|
|
|
|
$ids = SyncSubmitTaskModel::where('status', 3)->limit(100)->pluck('id');
|
|
|
|
foreach ($ids as $id) {
|
|
|
|
Redis::lpush('sync_submit_task', $id);
|
|
|
|
Redis::lpush('sync_submit_task_zbj', $id);
|
|
|
|
}
|
|
|
|
$task_id = Redis::rpop('sync_submit_task');
|
|
|
|
$task_id = Redis::rpop('sync_submit_task_zbj');
|
|
|
|
}
|
|
|
|
return $task_id;
|
|
|
|
}
|
...
|
...
|
|