From 300fa7ab06adcf565990190f6faa892831f8ee87 Mon Sep 17 00:00:00 2001 From: Jiang Yulong Date: Fri, 5 Dec 2025 09:33:19 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20AI=E6=B6=88=E6=81=AF=E6=9F=A5=E8=AF=A2?= =?UTF-8?q?=E5=8A=9F=E8=83=BD=E5=87=BA=E5=8F=82=E5=A2=9E=E5=8A=A0=E5=AD=97?= =?UTF-8?q?=E6=AE=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/ElasticSearchIndexServiceImpl.java | 3 +++ .../java/com/xboe/module/boecase/vo/CaseAiMessageVo.java | 9 +++++++++ 2 files changed, 12 insertions(+) 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; /** * 用户提问内容