diff --git a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CaseAiChatServiceImpl.java b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CaseAiChatServiceImpl.java index 9c084941..28eeff73 100644 --- a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CaseAiChatServiceImpl.java +++ b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CaseAiChatServiceImpl.java @@ -103,7 +103,6 @@ public class CaseAiChatServiceImpl implements ICaseAiChatService { private final Map conversationEventSourceMap = new ConcurrentHashMap<>(); @Override - @Transactional public SseEmitter chat(CaseAiChatDto caseAiChatDto, CurrentUser currentUser) { // 创建SSE响应器 SseEmitter sseEmitter = new SseEmitter(); @@ -746,8 +745,8 @@ public class CaseAiChatServiceImpl implements ICaseAiChatService { jsonData.put("content", message); JSONObject finishData = new JSONObject(); - jsonData.put("status", 4); - jsonData.put("content", ""); + finishData.put("status", 4); + finishData.put("content", ""); try { sseEmitter.send(conversationData.toJSONString()); sseEmitter.send(jsonData.toJSONString());