变更数据

@@ -61,20 +61,28 @@ class SyncFile extends Command
         $task_id = Redis::rpop($key);
         $task_id = Redis::rpop($key);
         if(empty($task_id)){
         if(empty($task_id)){
             $lock_key = 'sync_file_lock';
             $lock_key = 'sync_file_lock';
-            $lock_ttl = 60; // 锁时间大于当前 锁功能执行时间
-            // 尝试获取锁，非阻塞方式
+            $lock_ttl = 100;
+            // 尝试获取锁
             $lock = Redis::set($lock_key, 1, 'EX', $lock_ttl, 'NX');
             $lock = Redis::set($lock_key, 1, 'EX', $lock_ttl, 'NX');
             if (empty($lock)){
             if (empty($lock)){
                 return $task_id;
                 return $task_id;
             }
             }
+            try {
                 $errorFileModel = new ErrorFile();
                 $errorFileModel = new ErrorFile();
-            $lists = $errorFileModel->list(['status'=>0],'id',['id','path'],'asc',2000);//未同步成功的图片及文件
+                $lists = $errorFileModel->list(['status'=>0],'id',['id','path'],'asc',2000);
                 foreach ($lists as $v){
                 foreach ($lists as $v){
+                    if (!$this->isTaskInQueue($key, $v['id'])) {
                         Redis::lpush($key, $v['id']);
                         Redis::lpush($key, $v['id']);
                         $errorFileModel->edit(['status'=>1],['id'=>$v['id']]);
                         $errorFileModel->edit(['status'=>1],['id'=>$v['id']]);
                     }
                     }
+                }
                 $task_id = Redis::rpop($key);
                 $task_id = Redis::rpop($key);
+            } finally {
+                // 释放锁
+                Redis::del($lock_key);
+            }
         }
         }
+
         return $task_id;
         return $task_id;
     }
     }