dengsixing недель назад: 2
Родитель
Сommit
bec5035a08

+ 8 - 0
src/main/java/com/fdkankan/contro/mq/listener/UploadSceneListener.java

@@ -243,6 +243,7 @@ public class UploadSceneListener {
         if(CollUtil.isNotEmpty(mosaicArr)){
             Map<String, String> map = mosaicArr.stream().collect(Collectors.toMap(v->((JSONObject)v).getString("sid"), v->JSON.toJSONString(v)));
             if(CollUtil.isNotEmpty(map)){
+                redisUtil.del(String.format(RedisKey.SCENE_MOSAIC_DATA, num));
                 redisUtil.hmset(String.format(RedisKey.SCENE_MOSAIC_DATA, num), map);
             }
         }
@@ -262,6 +263,7 @@ public class UploadSceneListener {
                         .map(v-> v.getString("icon"))
                         .collect(Collectors.toSet());
                 if(!icons.isEmpty()){
+                    redisUtil.del(String.format(RedisKey.SCENE_HOT_ICONS, num));
                     redisUtil.sSet(String.format(RedisKey.SCENE_HOT_ICONS, num), icons.toArray());
                 }
             }
@@ -273,6 +275,7 @@ public class UploadSceneListener {
         if(CollUtil.isNotEmpty(LinkArr)){
             Map<String, String> map = LinkArr.stream().collect(Collectors.toMap(v->((JSONObject)v).getString("sid"), v->JSON.toJSONString(v)));
             if(CollUtil.isNotEmpty(map)){
+                redisUtil.del(String.format(RedisKey.SCENE_LINKPAN_DATA, num));
                 redisUtil.hmset(String.format(RedisKey.SCENE_LINKPAN_DATA, num), map);
             }
 
@@ -285,6 +288,7 @@ public class UploadSceneListener {
         if(CollUtil.isNotEmpty(collect)){
             List<String> list = collect.stream().map(v->JSON.toJSONString(v)).collect(Collectors.toList());
             if(!list.isEmpty()){
+                redisUtil.del(String.format(RedisKey.SCENE_filter_DATA, num));
                 redisUtil.lLeftPushAll(String.format(RedisKey.SCENE_filter_DATA, num), list);
             }
         }
@@ -295,6 +299,7 @@ public class UploadSceneListener {
         if(CollUtil.isNotEmpty(billboards)){
             Map<String, String> allTagsMap = billboards.stream().collect(Collectors.toMap(v->((JSONObject)v).getString("sid"), v->JSON.toJSONString(v)));
             if(!allTagsMap.isEmpty()){
+                redisUtil.del(String.format(RedisKey.SCENE_BILLBOARDS, num));
                 redisUtil.hmset(String.format(RedisKey.SCENE_BILLBOARDS, num), allTagsMap);
             }
             List<JSONObject> billboardList = allTagsMap.values().stream().map(str -> JSON.parseObject(str)).collect(Collectors.toList());
@@ -312,6 +317,7 @@ public class UploadSceneListener {
                         return iconObj.toJSONString();
                     }).collect(Collectors.toList());
             if(CollUtil.isNotEmpty(sytlelist)){
+                redisUtil.del(String.format(RedisKey.SCENE_BILLBOARDS_STYLES, num));
                 redisUtil.sSet(String.format(RedisKey.SCENE_BILLBOARDS_STYLES, num), new HashSet<>(sytlelist).toArray());
             }
         }
@@ -322,6 +328,7 @@ public class UploadSceneListener {
             JSONArray cutModels = JSON.parseArray(cutModelStr);
             Map<String, String> map = cutModels.stream().collect(Collectors.toMap(v->((JSONObject)v).getString("sid"), v->JSON.toJSONString(v)));
             if(!map.isEmpty()){
+                redisUtil.del(String.format(RedisKey.SCENE_CUT_MODEL, num));
                 redisUtil.hmset(String.format(RedisKey.SCENE_CUT_MODEL, num), map);
             }
         }
@@ -332,6 +339,7 @@ public class UploadSceneListener {
             JSONArray objects = JSON.parseArray(sceneDrawFileContent);
             Map<String, String> map = objects.stream().collect(Collectors.toMap(v->((JSONObject)v).getString("sid"), v->JSON.toJSONString(v)));
             if(!map.isEmpty()){
+                redisUtil.del(String.format(RedisKey.SCENE_DRAW, num));
                 redisUtil.hmset(String.format(RedisKey.SCENE_DRAW, num), map);
             }
         }