|
...
|
...
|
@@ -61,7 +61,7 @@ class SyncFile extends Command |
|
|
|
$task_id = Redis::rpop($key);
|
|
|
|
if(empty($task_id)){
|
|
|
|
$lock_key = 'sync_file_lock';
|
|
|
|
$lock_ttl = 100;
|
|
|
|
$lock_ttl = 60;
|
|
|
|
// 尝试获取锁
|
|
|
|
$lock = Redis::set($lock_key, 1, 'EX', $lock_ttl, 'NX');
|
|
|
|
if (empty($lock)){
|
|
...
|
...
|
@@ -71,10 +71,8 @@ class SyncFile extends Command |
|
|
|
$errorFileModel = new ErrorFile();
|
|
|
|
$lists = $errorFileModel->list(['status'=>0],'id',['id','path'],'asc',2000);
|
|
|
|
foreach ($lists as $v){
|
|
|
|
if (!$this->isTaskInQueue($key, $v['id'])) {
|
|
|
|
Redis::lpush($key, $v['id']);
|
|
|
|
$errorFileModel->edit(['status'=>1],['id'=>$v['id']]);
|
|
|
|
}
|
|
|
|
Redis::lpush($key, $v['id']);
|
|
|
|
$errorFileModel->edit(['status'=>1],['id'=>$v['id']]);
|
|
|
|
}
|
|
|
|
$task_id = Redis::rpop($key);
|
|
|
|
} finally {
|
...
|
...
|
|
