Commit bea77a264775ba911a6b625726964f2a87f5fcec
1 parent
20ad529a
修复日期计算错误的bug
Showing
1 changed file
with
3 additions
and
1 deletions
fw-valhalla-service/src/main/java/cn/fw/valhalla/component/InsuranceConsumer.java
... | ... | @@ -14,6 +14,7 @@ import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; |
14 | 14 | import org.apache.rocketmq.spring.core.RocketMQListener; |
15 | 15 | import org.springframework.beans.factory.annotation.Autowired; |
16 | 16 | import org.springframework.stereotype.Component; |
17 | +import org.springframework.transaction.annotation.Transactional; | |
17 | 18 | |
18 | 19 | import java.sql.Timestamp; |
19 | 20 | import java.util.Date; |
... | ... | @@ -51,7 +52,8 @@ public class InsuranceConsumer implements RocketMQListener<InsuOrderMqDTO> { |
51 | 52 | dealData(t, customer); |
52 | 53 | } |
53 | 54 | |
54 | - private void dealData(InsuOrderMqDTO t, Customer customer) { | |
55 | + @Transactional(rollbackFor = Exception.class) | |
56 | + public void dealData(InsuOrderMqDTO t, Customer customer) { | |
55 | 57 | OriginalData originalData = originalDataService.getOne(Wrappers.<OriginalData>lambdaQuery() |
56 | 58 | .eq(OriginalData::getType, DataTypeEnum.BI) |
57 | 59 | .eq(OriginalData::getDetailId, t.getOrderNo()) | ... | ... |