diff --git a/fw-valhalla-service/src/main/java/cn/fw/valhalla/component/InsuranceConsumer.java b/fw-valhalla-service/src/main/java/cn/fw/valhalla/component/InsuranceConsumer.java
index a2f8a52..0157633 100644
--- a/fw-valhalla-service/src/main/java/cn/fw/valhalla/component/InsuranceConsumer.java
+++ b/fw-valhalla-service/src/main/java/cn/fw/valhalla/component/InsuranceConsumer.java
@@ -14,6 +14,7 @@ import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
 import org.apache.rocketmq.spring.core.RocketMQListener;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.sql.Timestamp;
 import java.util.Date;
@@ -51,7 +52,8 @@ public class InsuranceConsumer implements RocketMQListener<InsuOrderMqDTO> {
         dealData(t, customer);
     }
 
-    private void dealData(InsuOrderMqDTO t, Customer customer) {
+    @Transactional(rollbackFor = Exception.class)
+    public void dealData(InsuOrderMqDTO t, Customer customer) {
         OriginalData originalData = originalDataService.getOne(Wrappers.<OriginalData>lambdaQuery()
                 .eq(OriginalData::getType, DataTypeEnum.BI)
                 .eq(OriginalData::getDetailId, t.getOrderNo())