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";