事务BUG处理

hx-purchase/src/main/java/com/fjhx/purchase/service/quality/impl/QualityServiceImpl.java

@@ -1,6 +1,7 @@
 package com.fjhx.purchase.service.quality.impl;
 
 import com.baomidou.dynamic.datasource.annotation.DS;
+import com.baomidou.dynamic.datasource.annotation.DSTransactional;
 import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
 import com.fjhx.common.constant.SourceConstant;
 import com.fjhx.common.enums.CodingRuleEnum;
@@ -73,7 +74,7 @@ public class QualityServiceImpl extends ServiceImpl<QualityMapper, Quality> impl
      * @param quality
      */
     @Override
-    @Transactional(rollbackFor = Exception.class)
+    @DSTransactional
     public void add(Quality quality) {
 //        quality.setCode(CodeEnum.QUALITY.getCode());
         quality.setCode(codingRuleService.createCode(CodingRuleEnum.QUALITY.getKey(),null));

hx-sale/src/main/java/com/fjhx/sale/service/claim/impl/ClaimServiceImpl.java

@@ -131,7 +131,6 @@ public class ClaimServiceImpl extends ServiceImpl<ClaimMapper, Claim> implements
             this.removeBatchByIds(claimIds);
             claimContractService.remove(Wrappers.<ClaimContract>query().lambda().in(ClaimContract::getClaimId,claimIds));
         }
-
     }
 
     /**

hx-sale/src/main/java/com/fjhx/sale/service/pack/impl/PackServiceImpl.java

@@ -1,5 +1,6 @@
 package com.fjhx.sale.service.pack.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DSTransactional;
 import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
 import com.baomidou.mybatisplus.core.toolkit.IdWorker;
 import com.fjhx.common.enums.CodingRuleEnum;
@@ -74,7 +75,7 @@ public class PackServiceImpl extends ServiceImpl<PackMapper, Pack> implements Pa
      * @param pack
      */
     @Override
-    @Transactional(rollbackFor = Exception.class)
+    @DSTransactional
     public void add(Pack pack) {
         if(StringUtils.isEmpty(pack.getContractIds())){
             throw new ServiceException("参数异常");

hx-sale/src/main/java/com/fjhx/sale/service/quality/impl/EhsdQualityServiceImpl.java

@@ -1,5 +1,6 @@
 package com.fjhx.sale.service.quality.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DSTransactional;
 import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
 import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
@@ -102,6 +103,7 @@ public class EhsdQualityServiceImpl extends ServiceImpl<EhsdQualityMapper, EhsdQ
      */
     @Override
     @LogicIgnore(tableName = {""},alias = {""})
+    @DSTransactional
     public void submit(EhsdQualityDto ehsdQualityDto) {
         if(ObjectUtils.isEmpty(ehsdQualityDto.getId())){//添加
 //            ehsdQualityDto.setCode(codingRuleService.createCode(CodingRuleEnum.CONTRACT.getKey(),null));