From 88709c15a5c37d825fe1914f910acfc21fc32adc Mon Sep 17 00:00:00 2001
From: "liu.zixi" <liu.zixi@ebiz-digits.com>
Date: Tue, 30 Sep 2025 11:45:51 +0800
Subject: [PATCH] =?UTF-8?q?=E6=A1=88=E4=BE=8B=E5=8A=A9=E6=89=8B=EF=BC=9A?=
 =?UTF-8?q?=E5=A2=9E=E5=8A=A0@Transactional=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   | 5 ++++-
 1 file changed, 4 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 143a2f56..0722f4a7 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
@@ -45,6 +45,7 @@ import org.jetbrains.annotations.Nullable;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.StringUtils;
 import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
 
@@ -83,6 +84,7 @@ public class CaseAiChatServiceImpl implements ICaseAiChatService {
     private CasesDao casesDao;
 
     @Override
+    @Transactional
     public SseEmitter chat(CaseAiChatDto caseAiChatDto, CurrentUser currentUser) {
         // 1. 获取conversationId
         String conversationId = getOrCreateConversationId(caseAiChatDto, currentUser);
@@ -96,7 +98,7 @@ public class CaseAiChatServiceImpl implements ICaseAiChatService {
             conversation.setAiConversationId(conversationId);
             conversation.setConversationName("AI案例咨询-" + LocalDateTime.now());
             conversation.setConversationUser(currentUser.getAccountId());
-            // 由于编译问题，这里先注释，实际部署时需要取消注释
+            // 保存会话到数据库
             caseAiConversationsDao.save(conversation);
         }
         
@@ -242,6 +244,7 @@ public class CaseAiChatServiceImpl implements ICaseAiChatService {
     }
 
     @Override
+    @Transactional
     public CaseAiConversations createNewConversation(String userId, String conversationName) {
         try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
             String url = caseAiProperties.getBaseUrl() + "/apigateway/knowledge/v1/conversation";