|
...
|
...
|
@@ -44,7 +44,7 @@ class SyncSubmitTask extends Command |
|
|
|
}
|
|
|
|
$this->output('任务' . $task_id . '开始');
|
|
|
|
$task_info = SyncSubmitTaskModel::find($task_id);
|
|
|
|
if (empty($task_info) || $task_info->status) {
|
|
|
|
if (empty($task_info) || $task_info->status !=2) {
|
|
|
|
$this->output('任务不存在或者已执行');
|
|
|
|
continue;
|
|
|
|
}
|
|
...
|
...
|
@@ -88,9 +88,11 @@ class SyncSubmitTask extends Command |
|
|
|
if (Redis::setnx($lockKey, 1)) {
|
|
|
|
// 设置锁的过期时间,防止死锁
|
|
|
|
Redis::expire($lockKey, 10);
|
|
|
|
$ids = SyncSubmitTaskModel::where('status', 0)->limit(100)->pluck('id');
|
|
|
|
foreach ($ids as $id) {
|
|
|
|
Redis::lpush('sync_submit_task', $id);
|
|
|
|
$tasks = SyncSubmitTaskModel::where('status', 0)->limit(100)->get();
|
|
|
|
foreach ($tasks as $task) {
|
|
|
|
$task->status = 2;
|
|
|
|
$task->save();
|
|
|
|
Redis::lpush('sync_submit_task', $task->id);
|
|
|
|
}
|
|
|
|
$task_id = Redis::rpop('sync_submit_task');
|
|
|
|
Redis::del($lockKey);
|
...
|
...
|
|