diff --git a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/ElasticSearchIndexServiceImpl.java b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/ElasticSearchIndexServiceImpl.java index fc0c0767..8541983f 100644 --- a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/ElasticSearchIndexServiceImpl.java +++ b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/ElasticSearchIndexServiceImpl.java @@ -238,6 +238,7 @@ public class ElasticSearchIndexServiceImpl implements IElasticSearchIndexService Map sourceMap = hit.getSourceAsMap(); CaseAiMessageVo data = parseMessageFromES(sourceMap); if (data != null) { + data.setDocId(hit.getId()); list.add(data); } } @@ -253,6 +254,7 @@ public class ElasticSearchIndexServiceImpl implements IElasticSearchIndexService private CaseAiMessageVo parseMessageFromES(Map sourceMap) { try { CaseAiMessageVo messageVo = new CaseAiMessageVo(); + messageVo.setConversationId((String) sourceMap.get("conversationId")); messageVo.setQuery((String) sourceMap.get("query")); messageVo.setAnswer((String) sourceMap.get("answer")); if (sourceMap.containsKey("startTime")) { @@ -387,6 +389,7 @@ public class ElasticSearchIndexServiceImpl implements IElasticSearchIndexService Map sourceMap = hit.getSourceAsMap(); CaseAiMessageVo data = parseMessageFromES(sourceMap); if (data != null) { + data.setDocId(hit.getId()); list.add(data); } } diff --git a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/vo/CaseAiMessageVo.java b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/vo/CaseAiMessageVo.java index 464b71c0..468e1cf5 100644 --- a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/vo/CaseAiMessageVo.java +++ b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/vo/CaseAiMessageVo.java @@ -10,6 +10,15 @@ import java.util.List; */ @Data public class CaseAiMessageVo { + /** + * ES docId + */ + private String docId; + + /** + * 会话ID + */ + private String conversationId; /** * 用户提问内容