From bea77a264775ba911a6b625726964f2a87f5fcec Mon Sep 17 00:00:00 2001 From: Kurisu Date: Sat, 23 Oct 2021 10:43:14 +0800 Subject: [PATCH] :bug: 修复日期计算错误的bug --- fw-valhalla-service/src/main/java/cn/fw/valhalla/component/InsuranceConsumer.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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 { 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.lambdaQuery() .eq(OriginalData::getType, DataTypeEnum.BI) .eq(OriginalData::getDetailId, t.getOrderNo()) -- libgit2 0.22.2