feat:添加接口

supply-demand-engine-core/src/main/java/com/tzld/piaoquan/sde/model/vo/ContentDescontructionResultVo.java

@@ -2,15 +2,24 @@ package com.tzld.piaoquan.sde.model.vo;
 
 import lombok.Data;
 
+import java.util.List;
+
 @Data
 public class ContentDescontructionResultVo {
 
     private String contentId;
 
-    private String stage;
+    private String topic;
+
+    private List<DescriptionInfo> description;
+
+    @Data
+    public static class DescriptionInfo {
+
+        private String type;
 
-    private String type;
+        private String typeDesc;
 
-    private String typeDesc;
+    }
 
 }

supply-demand-engine-core/src/main/java/com/tzld/piaoquan/sde/service/impl/ContentProfileServiceImpl.java

@@ -20,6 +20,7 @@ import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
 import java.util.*;
+import java.util.stream.Collectors;
 
 @Slf4j
 @Service
@@ -163,12 +164,32 @@ public class ContentProfileServiceImpl implements ContentProfileService {
                 result.put(keyword, Collections.emptyList());
                 continue;
             }
+
+            Map<String, List<Record>> contentIdAndRecordMap = records.stream()
+                    .collect(Collectors.groupingBy(i -> i.getString("content_id")));
+
             List<ContentDescontructionResultVo> contentDescontructionResultVos = new ArrayList<>(result.size());
-            for (Record record : records) {
+            for (String contentId : contentIdAndRecordMap.keySet()) {
+
+                List<Record> contentRecord = contentIdAndRecordMap.get(contentId);
+                if (CollectionUtils.isEmpty(contentRecord)) {
+                    continue;
+                }
+
+                List<ContentDescontructionResultVo.DescriptionInfo> description = contentRecord.stream()
+                        .map(i -> {
+                            ContentDescontructionResultVo.DescriptionInfo descriptionInfo = new ContentDescontructionResultVo.DescriptionInfo();
+                            descriptionInfo.setType(i.getString("type"));
+                            descriptionInfo.setTypeDesc(i.getString("type_desc"));
+                            return descriptionInfo;
+                        }).collect(Collectors.toList());
+
                 ContentDescontructionResultVo contentDescontructionResultVo = new ContentDescontructionResultVo();
-                contentDescontructionResultVo.setContentId(record.getString("content_id"));
+                contentDescontructionResultVo.setContentId(contentId);
+                contentDescontructionResultVo.setDescription(description);
                 contentDescontructionResultVos.add(contentDescontructionResultVo);
             }
+
             result.put(keyword, contentDescontructionResultVos);
         }
         return result;