添加事务

performance-web/src/main/java/com/clx/performance/service/impl/breakcontract/BreakContractOwnerRecordServiceImpl.java

@@ -4,18 +4,24 @@ package com.clx.performance.service.impl.breakcontract;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.clx.order.vo.feign.FeignOrderInfoVO;
-import com.clx.performance.dao.breakcontract.*;
+import com.clx.performance.dao.breakcontract.BreakContractOwnerRecordDao;
+import com.clx.performance.dao.breakcontract.BreakContractSettlementOwnerDao;
+import com.clx.performance.dao.breakcontract.BreakContractSettlementOwnerDetailDao;
 import com.clx.performance.enums.*;
 import com.clx.performance.extranal.user.OrderService;
 import com.clx.performance.extranal.user.OwnerInfoService;
-import com.clx.performance.model.breakcontract.*;
+import com.clx.performance.model.breakcontract.BreakContractOwnerRecord;
+import com.clx.performance.model.breakcontract.BreakContractSettlementOwner;
+import com.clx.performance.model.breakcontract.BreakContractSettlementOwnerDetail;
 import com.clx.performance.param.pc.breakcontract.carrier.BreakContractOwnerRecordAddParam;
 import com.clx.performance.param.pc.breakcontract.carrier.PageBreakContractOwnerRecordParam;
 import com.clx.performance.param.pc.breakcontract.owner.PageOwnerBreakContractOwnerRecordParam;
 import com.clx.performance.service.breakcontract.BreakContractOwnerRecordService;
 import com.clx.performance.service.breakcontract.BreakContractSettlementLogService;
 import com.clx.performance.service.impl.UniqueOrderNumService;
-import com.clx.performance.struct.breakcontract.*;
+import com.clx.performance.struct.breakcontract.BreakContractOwnerRecordStruct;
+import com.clx.performance.struct.breakcontract.BreakContractSettlementOwnerDetailStruct;
+import com.clx.performance.struct.breakcontract.BreakContractSettlementOwnerStruct;
 import com.clx.performance.vo.pc.breakcontract.carrier.BreakContractOwnerRecordVO;
 import com.clx.performance.vo.pc.breakcontract.owner.PageOwnerBreakContractOwnerRecordVO;
 import com.clx.user.vo.feign.OwnerInfoFeignVO;
@@ -24,8 +30,8 @@ import com.msl.user.data.UserSessionData;
 import com.msl.user.utils.TokenUtil;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.time.LocalDateTime;
 import java.util.List;
@@ -63,6 +69,7 @@ public class BreakContractOwnerRecordServiceImpl  implements BreakContractOwnerR
     private final BreakContractSettlementLogService breakContractSettlementLogService;
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void saveRecord(BreakContractOwnerRecordAddParam param) {
         UserSessionData loginUserInfo = TokenUtil.getLoginUserInfo();
         Long userNo = loginUserInfo.getUserNo();

performance-web/src/main/java/com/clx/performance/service/impl/breakcontract/BreakContractSettlementOwnerServiceImpl.java

@@ -232,6 +232,7 @@ public class BreakContractSettlementOwnerServiceImpl  implements BreakContractSe
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void updateConfirmSettlement(OwnerConfirmSettlementParam param) {
         BreakContractSettlementOwner settlementOwner = breakContractSettlementOwnerDao.getEntityByKey(param.getId()).orElseThrow(PerformanceResultEnum.DATA_NOT_FIND);
         if(!Objects.equals(settlementOwner.getStatus(), BreakContractSettlementOwnerEnum.Status.OWNER_TO_BE_CONFIRMED.getCode())){
@@ -252,6 +253,7 @@ public class BreakContractSettlementOwnerServiceImpl  implements BreakContractSe
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void saveOwnerBreakContractPayee(CarrierBreakContractSavePayeeParam param) {
         BreakContractSettlementOwner settlementOwner = breakContractSettlementOwnerDao.getEntityByKey(param.getId()).orElseThrow(PerformanceResultEnum.DATA_NOT_FIND);
         if(!Objects.equals(settlementOwner.getStatus(), BreakContractSettlementOwnerEnum.Status.SHIPPER_TO_PAYMENT.getCode())){
@@ -269,6 +271,7 @@ public class BreakContractSettlementOwnerServiceImpl  implements BreakContractSe
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void updateOwnerBreakContractPayeeConfirm(CarrierBreakPayeeConfirmParam param) {
         BreakContractSettlementOwner settlementOwner = breakContractSettlementOwnerDao.getEntityByKey(param.getId()).orElseThrow(PerformanceResultEnum.DATA_NOT_FIND);
         if(!Objects.equals(settlementOwner.getStatus(), BreakContractSettlementOwnerEnum.Status.OWNER_CONFIRMED_PLATFORM_PAYMENT.getCode())){