diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiConsumer.java b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiConsumer.java
index 2d7b408..efb5831 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiConsumer.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiConsumer.java
@@ -4,14 +4,17 @@ import com.alibaba.fastjson.JSON;
 import com.ruoyi.business.domain.*;
 import com.ruoyi.business.mapper.BusReturnVisitInfoMapper;
 import com.ruoyi.business.service.*;
+import com.ruoyi.common.exception.ServiceException;
 import com.ruoyi.common.utils.StringUtils;
 import com.ruoyi.system.mapper.SysDictDataMapper;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
 import org.apache.rocketmq.spring.core.RocketMQListener;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.time.LocalDateTime;
 import java.time.LocalTime;
@@ -21,6 +24,7 @@ import java.util.Date;
 import java.util.List;
 import java.util.stream.Collectors;
 
+@Slf4j
 @Component
 public class AiConsumer {
 
@@ -56,6 +60,7 @@ public class AiConsumer {
 
 
         @Override
+        @Transactional(rollbackFor = ServiceException.class)
         public void onMessage(MqDataInfo mqDataInfo) {
             long startTime = System.currentTimeMillis();
             System.out.println("开始======="+startTime);
@@ -212,14 +217,15 @@ public class AiConsumer {
                  */
                 List<BusReturnVisitInfo> list2 = busReturnVisitInfoMapper.selectBusReturnVisitInfoList(returnVisitInfo);
                 if (list2.size() > 0) {
-                    System.out.println("修改营销事件=====================");
+                    log.error("修改营销事件=====================");
                     returnVisitInfo.setId(list2.get(0).getId());
                     returnVisitInfo.setReturnVisitTime(new Date());
                     busReturnVisitInfoMapper.updateBusReturnVisitInfo(returnVisitInfo);
                 }
             }catch (Exception e){
                 e.printStackTrace();
-                return;
+                log.error("营销事件推出-下次继续=====================");
+                throw new ServiceException("营销事件推出-下次继续");
             }
             System.out.println(("一共耗时time: " + (System.currentTimeMillis() - startTime) / 1000 + " s"));
         }