Selaa lähdekoodia

fix: 给涉及到库存操作的业务添加事务

luofeiyun 1 viikko sitten
vanhempi
commit
5831b2a98b

+ 2 - 0
ship-module-trade/ship-module-trade-biz/src/main/java/com/yc/ship/module/trade/service/order/impl/AdminTradeOrderServiceImpl.java

@@ -53,6 +53,7 @@ import com.yc.ship.module.trade.service.refund.TradeRefundService;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
 import java.time.LocalDateTime;
@@ -250,6 +251,7 @@ public class AdminTradeOrderServiceImpl implements AdminTradeOrderService {
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public CommonResult<?> refundAudit(LoginUser loginUser, TradeRefundAuditReqVO refundAuditReqVO) {
         TradeRefundAuditReqDTO refundAuditReqDTO = TradeRefundConvert.INSTANCE.convert(refundAuditReqVO);
         refundAuditReqDTO.setAuditUser(loginUser.getId());

+ 2 - 0
ship-module-trade/ship-module-trade-biz/src/main/java/com/yc/ship/module/trade/service/otc/impl/OtcTradeOrderServiceImpl.java

@@ -367,6 +367,7 @@ public class OtcTradeOrderServiceImpl implements OtcTradeOrderService {
 
     @Override
     @TradeOrderLog(operateType = TradeOrderOperateTypeEnum.ORDER_AUDIT)
+    @Transactional(rollbackFor = Exception.class)
     @TenantIgnore
     public CommonResult<?> orderAudit(Long orderId, Integer auditStatus) {
         TradeOrderDO tradeOrderDO = tradeOrderMapper.selectById(orderId);
@@ -610,6 +611,7 @@ public class OtcTradeOrderServiceImpl implements OtcTradeOrderService {
 
     @Override
     @TradeOrderLog(operateType = TradeOrderOperateTypeEnum.CANCEL_AUDIT)
+    @Transactional(rollbackFor = Exception.class)
     @TenantIgnore
     public CommonResult<?> cancelAuto(Long orderId) {
         TradeOrderDO tradeOrderDO = tradeOrderMapper.selectById(orderId);

+ 2 - 0
ship-module-trade/ship-module-trade-biz/src/main/java/com/yc/ship/module/trade/service/pay/impl/TradeOrderPayServiceImpl.java

@@ -58,6 +58,7 @@ import org.redisson.api.RLock;
 import org.redisson.api.RedissonClient;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
 import java.math.BigDecimal;
@@ -388,6 +389,7 @@ public class TradeOrderPayServiceImpl implements TradeOrderPayService {
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     @TradeOrderLog(operateType = TradeOrderOperateTypeEnum.MANUL_CANCEL)
     public CommonResult<?> orderPayCancelHandler(Long orderId) {
         String lockKey = String.format(UPDATE_ORDER_LOCK, orderId);