From ac3465ff92fe0f50c42e1f471fe609ca72ede5fa Mon Sep 17 00:00:00 2001
From: "liu.zixi" <liu.zixi@ebiz-digits.com>
Date: Thu, 4 Dec 2025 19:04:53 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E5=8A=A0=E5=9B=9E=E6=B3=A8=E8=A7=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../module/boecase/service/impl/CaseAiChatServiceImpl.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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 1a5e8f40..37f0266c 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
@@ -114,6 +114,7 @@ public class CaseAiChatServiceImpl implements ICaseAiChatService {
     private final Map<String, EventSource> conversationEventSourceMap = new ConcurrentHashMap<>();
 
     @Override
+    @Transactional
     public SseEmitter chat(CaseAiChatDto caseAiChatDto, CurrentUser currentUser) {
         // 创建SSE响应器
         SseEmitter sseEmitter = new SseEmitter();
@@ -394,7 +395,7 @@ public class CaseAiChatServiceImpl implements ICaseAiChatService {
     }
 
     @Override
-//    @Transactional
+    @Transactional
     public CaseAiConversations createNewConversation(String userId, String conversationName) {
         try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
             String url = caseAiProperties.getBaseUrl() + "/apigateway/knowledge/v1/conversation";