Browse Source

删除马赛克 睡眠两分钟 用于测试马赛克并发问题

dsx 2 years ago
parent
commit
ccb9b6a186

+ 2 - 2
src/main/java/com/fdkankan/scene/service/impl/SceneEditInfoServiceImpl.java

@@ -1842,12 +1842,13 @@ public class SceneEditInfoServiceImpl extends ServiceImpl<ISceneEditInfoMapper,
         return ResultData.ok();
         return ResultData.ok();
     }
     }
 
 
-    private void updateMosaicFlag(String num){
+    private void updateMosaicFlag(String num) throws InterruptedException {
         ScenePlus scenePlus = scenePlusService.getScenePlusByNum(num);
         ScenePlus scenePlus = scenePlusService.getScenePlusByNum(num);
         SceneEditInfoExt sceneEditInfoExt = sceneEditInfoExtService.getByScenePlusId(scenePlus.getId());
         SceneEditInfoExt sceneEditInfoExt = sceneEditInfoExtService.getByScenePlusId(scenePlus.getId());
 
 
         String key = String.format(RedisKey.SCENE_MOSAIC_DATA, num);
         String key = String.format(RedisKey.SCENE_MOSAIC_DATA, num);
         boolean flag = redisUtil.hasKey(key);
         boolean flag = redisUtil.hasKey(key);
+        Thread.sleep(90000L);
         if(flag){
         if(flag){
             sceneEditInfoExt.setMosaic(Integer.valueOf(CommonStatus.YES.code()));
             sceneEditInfoExt.setMosaic(Integer.valueOf(CommonStatus.YES.code()));
         }else{
         }else{
@@ -2699,7 +2700,6 @@ public class SceneEditInfoServiceImpl extends ServiceImpl<ISceneEditInfoMapper,
         redisUtil.hdel(key, param.getPanoIdList().toArray());
         redisUtil.hdel(key, param.getPanoIdList().toArray());
 
 
         //写入本地文件,作为备份
         //写入本地文件,作为备份
-        Thread.sleep(120000L);
         this.writeMosaic(param.getNum());
         this.writeMosaic(param.getNum());
 
 
         //更新数据库
         //更新数据库