获取热点数据

4dkankan-center-scene/src/main/java/com/fdkankan/scene/controller/SceneEditController.java

@@ -255,6 +255,11 @@ public class SceneEditController extends BaseController {
         return sceneProService.deleteTag(param);
     }
 
+    @PostMapping(value = "/tag/list")
+    public ResultData listTags(@RequestParam(value = "num") String num) throws Exception {
+        return sceneProService.listTags(num);
+    }
+
     /**
      * <p>
      保存场景热点
@@ -689,4 +694,6 @@ public class SceneEditController extends BaseController {
     }
 
 
+
+
 }

4dkankan-center-scene/src/main/java/com/fdkankan/scene/service/ISceneProService.java

@@ -92,6 +92,8 @@ public interface ISceneProService extends IService<ScenePro> {
 
     ResultData deleteTag(DeleteHotParamVO param) throws Exception;
 
+    ResultData listTags(String num);
+
     ResultData saveShopHot(SceneEditParamVO base) throws Exception;
 
     ResultData saveOverlay(SceneEditParamVO base) throws Exception;

4dkankan-center-scene/src/main/java/com/fdkankan/scene/service/impl/SceneProServiceImpl.java

@@ -2248,6 +2248,23 @@ public class SceneProServiceImpl extends ServiceImpl<ISceneProMapper, ScenePro>
         return ResultData.ok();
     }
 
+    @Override
+    public ResultData listTags(String num){
+
+        //查询缓存是否包含热点数据
+        String key = String.format(RedisKey.SCENE_HOT_DATA, num);
+        Map<String, String> allTagsMap = redisUtil.hmget(key);
+        if(CollUtil.isEmpty(allTagsMap)){
+            return ResultData.ok();
+        }
+
+        List<Object> tags = allTagsMap.entrySet().parallelStream().map(entry -> {
+            return entry.getValue();
+        }).collect(Collectors.toList());
+
+        return ResultData.ok(tags);
+    }
+
 
     private void addOrUpdateHotData(String num, Map<String, String> addOrUpdateMap){
         if(CollUtil.isEmpty(addOrUpdateMap))