hz/java-servers
1
0
Fork 0
mirror of https://codeup.aliyun.com/67762337eccfc218f6110e0e/per-boe/java-servers.git synced 2025-12-06 09:26:48 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: AI消息查询功能出参增加字段

Browse Source
This commit is contained in:
Jiang Yulong
2025-12-05 09:33:19 +08:00
parent 784fe062bf
commit 300fa7ab06
2 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/ElasticSearchIndexServiceImpl.java
View File

@@ -238,6 +238,7 @@ public class ElasticSearchIndexServiceImpl implements IElasticSearchIndexService
Map<String, Object> sourceMap = hit.getSourceAsMap(); Map<String, Object> sourceMap = hit.getSourceAsMap();
CaseAiMessageVo data = parseMessageFromES(sourceMap); CaseAiMessageVo data = parseMessageFromES(sourceMap);
if (data != null) { if (data != null) {
data.setDocId(hit.getId());
list.add(data); list.add(data);
} }
} }
@@ -253,6 +254,7 @@ public class ElasticSearchIndexServiceImpl implements IElasticSearchIndexService
private CaseAiMessageVo parseMessageFromES(Map<String, Object> sourceMap) { private CaseAiMessageVo parseMessageFromES(Map<String, Object> sourceMap) {
try { try {
CaseAiMessageVo messageVo = new CaseAiMessageVo(); CaseAiMessageVo messageVo = new CaseAiMessageVo();
messageVo.setConversationId((String) sourceMap.get("conversationId"));
messageVo.setQuery((String) sourceMap.get("query")); messageVo.setQuery((String) sourceMap.get("query"));
messageVo.setAnswer((String) sourceMap.get("answer")); messageVo.setAnswer((String) sourceMap.get("answer"));
if (sourceMap.containsKey("startTime")) { if (sourceMap.containsKey("startTime")) {
@@ -387,6 +389,7 @@ public class ElasticSearchIndexServiceImpl implements IElasticSearchIndexService
Map<String, Object> sourceMap = hit.getSourceAsMap(); Map<String, Object> sourceMap = hit.getSourceAsMap();
CaseAiMessageVo data = parseMessageFromES(sourceMap); CaseAiMessageVo data = parseMessageFromES(sourceMap);
if (data != null) { if (data != null) {
data.setDocId(hit.getId());
list.add(data); list.add(data);
} }
} }

9
servers/boe-server-all/src/main/java/com/xboe/module/boecase/vo/CaseAiMessageVo.java
View File

@@ -10,6 +10,15 @@ import java.util.List;
*/ */
@Data @Data
public class CaseAiMessageVo { public class CaseAiMessageVo {
/**
* ES docId
*/
private String docId;
/**
* 会话ID
*/
private String conversationId;
/** /**
* 用户提问内容 * 用户提问内容