From 97f0c8f65fb1699971ddafa40abdaf02a74b633e Mon Sep 17 00:00:00 2001
From: xupei <xupei3360@163.com>
Date: Tue, 18 Nov 2025 16:02:26 +0800
Subject: [PATCH] =?UTF-8?q?BUGFIX:=20=E8=8E=B7=E5=8F=96=E7=B3=BB=E7=BB=9F?=
 =?UTF-8?q?=E9=80=9A=E7=9F=A5=E6=9C=AA=E8=AF=BB=E6=95=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/ai/da/common/RabbitMQ/GenerateConsumer.java    | 1 +
 .../com/ai/da/service/impl/MessageCenterServiceImpl.java    | 6 ++++--
 2 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java b/src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java
index ded8b9a3..573b1ecb 100644
--- a/src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java
+++ b/src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java
@@ -296,6 +296,7 @@ public class GenerateConsumer {
                 redisUtil.addToMap(exceptionMapKey, exceptionInfo);
             }
         } catch (Exception e) {
+            e.printStackTrace();
             log.error(e.getMessage());
             try {
                 channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false);
diff --git a/src/main/java/com/ai/da/service/impl/MessageCenterServiceImpl.java b/src/main/java/com/ai/da/service/impl/MessageCenterServiceImpl.java
index b7f40399..e31c4ce0 100644
--- a/src/main/java/com/ai/da/service/impl/MessageCenterServiceImpl.java
+++ b/src/main/java/com/ai/da/service/impl/MessageCenterServiceImpl.java
@@ -30,6 +30,7 @@ import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
@@ -385,6 +386,8 @@ public class MessageCenterServiceImpl extends ServiceImpl<NotificationMapper, No
         return PageBaseResponse.success(convert);
     }
 
+    @Override
+    @Transactional(rollbackFor = Exception.class)
     public void videoFinishedMsg(Long userId, String projectName, boolean isSuccess) {
         Account account = accountService.getById(userId);
         String language = account.getLanguage();
@@ -410,11 +413,10 @@ public class MessageCenterServiceImpl extends ServiceImpl<NotificationMapper, No
             }
         }
         notification.setContent(JSON.toJSONString(sysNotificationDTO));
-
         notification.setIsRead(0);
         notification.setCreateTime(LocalDateTime.now());
-
         save(notification);
+
         pushMessage("system", userId);
     }