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);
     }