修改tag分析接口算法

ruoyi-demo/src/main/java/com/ruoyi/demo/controller/ChannelAnalyseController.java

@@ -93,13 +93,13 @@ public class ChannelAnalyseController {
 
         //2.查看redis中是否存在有缓存
         HashMap<String, Object> result = new HashMap<>();
-//        HashMap<String,Object> wdCount = (HashMap<String,Object>) redisTemplate.boundHashOps(RedisContant.CHANNEL_ANALYSE_TAG_ANLYSE).get(md5);
-//        if (wdCount != null) {
-//            result.put("data",(List<TagAnalyse>) wdCount.get(page + ""));
-//            result.put("pages",(int)wdCount.get("pages"));
-//            result.put("total",(int)wdCount.get("total"));
-//            return R.ok(result);
-//        }
+        HashMap<String,Object> wdCount = (HashMap<String,Object>) redisTemplate.boundHashOps(RedisContant.CHANNEL_ANALYSE_TAG_ANLYSE).get(md5);
+        if (wdCount != null) {
+            result.put("data",(List<TagAnalyse>) wdCount.get(page + ""));
+            result.put("pages",(int)wdCount.get("pages"));
+            result.put("total",(int)wdCount.get("total"));
+            return R.ok(result);
+        }
         HashMap<String, Object> hashMap = channelAnalyseService.tagAnalyse(channelMapAceeptVo);
 
         //4.保存到redis中

ruoyi-demo/src/main/java/com/ruoyi/demo/service/impl/ChannelAnalyseServiceImpl.java

@@ -247,7 +247,7 @@ public class ChannelAnalyseServiceImpl implements ChannelAnalyseService {
         ConcurrentHashMap<String, Integer> concurrentHashMap = new ConcurrentHashMap<>();
         concurrentHashMap.put("total",0);
 
-        int split = 6000;
+        int split = 8000;
         int splitCount = collect.size()/split;
         int p1 = 0,p2 = split;
         ArrayList<CompletableFuture<Void>> splitList = new ArrayList<>();