Merge branch 'feature' into 'dev'

2022/11/16 16:22

See merge request !90

src/main/java/com/zhiwei/brandkbs2/pojo/BaseMap.java

@@ -83,4 +83,8 @@ public class BaseMap {
         return Tools.getTitleWithContent(title, incompleteContent, content);
     }
 
+    public void subStringContentTop() {
+        this.content = content.substring(0, 200);
+    }
+
 }

src/main/java/com/zhiwei/brandkbs2/pojo/external/BrandkbsHotEventWarn.java

@@ -5,6 +5,7 @@ import lombok.AllArgsConstructor;
 import lombok.Data;
 
 import java.util.List;
+import java.util.Map;
 import java.util.stream.Collectors;
 
 /**
@@ -17,7 +18,7 @@ import java.util.stream.Collectors;
 @AllArgsConstructor
 public class BrandkbsHotEventWarn {
 
-    private List<HotEvent> hotEventList;
+    private Map<String, List<HotEvent>> hotEventMap;
 
     @Data
     public static class HotEvent {

src/main/java/com/zhiwei/brandkbs2/service/impl/ProjectWarnServiceImpl.java

@@ -332,7 +332,10 @@ public class ProjectWarnServiceImpl implements ProjectWarnService {
         } else {
             key4 = keyBuilder4.toString();
         }
-        List<BrandkbsHotEventWarn.HotEvent> collect = eventMap.entrySet().stream().map(entry -> entry.getValue().stream().map(event -> BrandkbsHotEventWarn.HotEvent.createFromEvent(entry.getKey(), event)).collect(Collectors.toList())).collect(Collectors.toList()).stream().flatMap(List::stream).collect(Collectors.toList());
+        Map<String, List<BrandkbsHotEventWarn.HotEvent>> collect = eventMap.entrySet().stream().collect(Collectors.toMap(Map.Entry::getKey, entry -> entry.getValue().stream().map(event -> BrandkbsHotEventWarn.HotEvent.createFromEvent(entry.getKey(), event)).collect(Collectors.toList())));
+//        List<BrandkbsHotEventWarn.HotEvent> collect = eventMap.entrySet().stream().map(entry -> entry.getValue().stream().
+//                map(event -> BrandkbsHotEventWarn.HotEvent.createFromEvent(entry.getKey(), event)).collect(Collectors.toList())).
+//                collect(Collectors.toList()).stream().flatMap(List::stream).collect(Collectors.toList());
         return new BrandkbsWarnTemplate(firstCount, key1, key2, key3, key4, new BrandkbsHotEventWarn(collect));
     }
 
@@ -612,6 +615,8 @@ public class ProjectWarnServiceImpl implements ProjectWarnService {
                 if (!hitMap.isEmpty() && (null != config.getContends() && config.getContends().contains(contendId))) {
                     baseMap.setBrandName(projectService.getProjectByContendId(projectId, contendId).getBrandName());
                 }
+                baseMap.setTitle(baseMap.getTitleNullOptionalContent());
+                baseMap.subStringContentTop();
                 return baseMap;
             }).filter(Objects::nonNull).collect(Collectors.toList());
             // 开启去重
@@ -657,7 +662,12 @@ public class ProjectWarnServiceImpl implements ProjectWarnService {
             // 搜索结果
             SearchHits searchHits = esClientDao.searchHits(helper);
             log.info("获取渠道参与预警-es搜索到数据:{}条,剩余渠道指数筛选未进行,project:{}", searchHits.getHits().length, project.getProjectName());
-            List<BaseMap> datas = Arrays.stream(searchHits.getHits()).map(hit -> Tools.getBaseFromEsMap(hit.getSourceAsMap())).collect(Collectors.toList());
+            List<BaseMap> datas = Arrays.stream(searchHits.getHits()).map(hit -> {
+                BaseMap baseMap = Tools.getBaseFromEsMap(hit.getSourceAsMap());
+                baseMap.setTitle(baseMap.getTitleNullOptionalContent());
+                baseMap.subStringContentTop();
+                return baseMap;
+            }).collect(Collectors.toList());
             // 开启去重
             if (Boolean.TRUE.equals(config.getDuplicate())) {
                 datas = duplicateBaseMapList(datas);