redis场景码解冻锁

src/main/java/com/fdkankan/manage/mq/consumer/SceneRestStoreConsumer.java

@@ -61,10 +61,7 @@ public class SceneRestStoreConsumer {
             String bucket= sceneRestStoreVo.getBucket();
             String folderName= sceneRestStoreVo.getFolderName();
             String redisKey = String.format(RedisKeyUtil.restStoreKey, num);
-            if(redisUtil.hasKey(redisKey)){
-                return;
-            }
-            redisUtil.set(redisKey,folderName);
+
             try {
                 fYunFileServiceInterface.restoreFolder(cloudBucket,folderName,1);
             }catch (Exception e){

src/main/java/com/fdkankan/manage/service/impl/SceneProServiceImpl.java

@@ -725,6 +725,7 @@ public class SceneProServiceImpl extends ServiceImpl<ISceneProMapper, ScenePro>
         String homePath = dataSource.replace("/mnt/data","home");
         SceneRestStoreVo sceneRestStoreVo = new SceneRestStoreVo(num,sceneColdStorage.getColdBucket(),sceneColdStorage.getBucket(),homePath);
         Map<String, Object> map = BeanUtil.beanToMap(sceneRestStoreVo);
+        redisUtil.set(redisKey,homePath);
         rabbitMqProducer.sendByWorkQueue(MqQueueUtil.sceneRestoreQueue,map);
         //threadService.checkRestore(num,sceneColdStorage.getColdBucket(),sceneColdStorage.getBucket(),homePath);
     }