政策同步到销路通

src/main/java/com/qs/serve/modules/tzc/controller/TzcPolicyController.java

@@ -71,8 +71,18 @@ public class TzcPolicyController {
     private TbsBudgetLogService budgetLogService;
 
     @GetMapping("succ")
-    public R<?> succ(Long id){
+    public R<?> succ(Long id,String all){
+        if("all".equals(all)){
+            LambdaQueryWrapper<TzcPolicyItem> itemLqw = new LambdaQueryWrapper<>();
+            itemLqw.select(TzcPolicyItem::getId);
+            itemLqw.eq(TzcPolicyItem::getPolicyItemStatus,TzPolicyItemStatus.Status_1_PassSuccess);
+            List<TzcPolicyItem> policyItemList = tzcPolicyItemService.list(itemLqw);
+            for (TzcPolicyItem policyItem : policyItemList) {
+                policyApplicationService.syncPolicyItem(policyItem.getId());
+            }
+        }else {
             policyApplicationService.syncPolicyItem(id);
+        }
         return R.ok();
     }
 

src/main/java/com/qs/serve/modules/tzc/entity/dto/PolicyItemDto.java

@@ -5,6 +5,7 @@ import lombok.Data;
 import java.math.BigDecimal;
 import java.util.Date;
 import java.util.List;
+import java.util.Set;
 
 /**
  * @author YenHex
@@ -33,6 +34,6 @@ public class PolicyItemDto {
     /** 优惠上限 */
     private BigDecimal discountMax;
 
-    List<String> invCodeList;
+    Set<String> invCodeList;
 
 }

src/main/java/com/qs/serve/modules/tzc/service/TzcPolicyApplicationService.java

@@ -19,6 +19,8 @@ public interface TzcPolicyApplicationService {
      */
     void syncPolicyItem(Long policyItemId);
 
+    void syncPolicy(Long policyId);
+
     /**
      * 创建费用占用结果
      * @param policyId

src/main/java/com/qs/serve/modules/tzc/service/impl/TzcPolicyApplicationServiceImpl.java

@@ -96,9 +96,23 @@ public class TzcPolicyApplicationServiceImpl implements TzcPolicyApplicationServ
     private final BmsRegionMapper regionMapper;
     private final BmsRegion2Mapper region2Mapper;
 
+    @Override
+    public void syncPolicy(Long policyId) {
+        LambdaQueryWrapper<TzcPolicyItem> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(TzcPolicyItem::getPolicyId,policyId);
+        wrapper.select(TzcPolicyItem::getId);
+        List<TzcPolicyItem> list = tzcPolicyItemService.list(wrapper);
+        for (TzcPolicyItem policyItem : list) {
+            this.syncPolicyItem(policyItem.getId());
+        }
+    }
+
     @Override
     public void syncPolicyItem(Long policyItemId) {
         TzcPolicyItem policyItem = tzcPolicyItemService.getById(policyItemId);
+        if(policyItem==null||!policyItem.getPolicyItemStatus().equals(TzPolicyItemStatus.Status_1_PassSuccess)){
+            return;
+        }
         PolicyItemDto policyItemDto = new PolicyItemDto();
         policyItemDto.setTitle(policyItem.getTitle());
         policyItemDto.setCusCode(policyItem.getSupplierCode());
@@ -111,7 +125,7 @@ public class TzcPolicyApplicationServiceImpl implements TzcPolicyApplicationServ
         //加载InvCode
         List<TzcPolicyGoods> policyGoods = tzcPolicyGoodsService.listByItemId(policyItemId);
         Map<String,List<TzcPolicyGoods>> policyGoodsMap = policyGoods.stream().collect(Collectors.groupingBy(TzcPolicyGoods::getTargetType));
-        List<String> invCodes = new ArrayList<>();
+        Set<String> invCodes = new HashSet<>();
         for (String goodType : policyGoodsMap.keySet()) {
             List<TzcPolicyGoods> policyGoodsList = policyGoodsMap.get(goodType);
             List<Long> targetIds = policyGoodsList.stream().map(TzcPolicyGoods::getTargetId).collect(Collectors.toList());
@@ -136,6 +150,9 @@ public class TzcPolicyApplicationServiceImpl implements TzcPolicyApplicationServ
                 invCodes.addAll(invCodeList);
             }
         }
+        if(invCodes.size()<1){
+            return;
+        }
         policyItemDto.setInvCodeList(invCodes);
         //保存异步处理的
         R<String> result = xiaoLuTonService.savePolicyItem(policyItemDto);

src/main/java/com/qs/serve/modules/tzc/service/impl/TzcPolicyOperationServiceImpl.java

@@ -40,6 +40,7 @@ public class TzcPolicyOperationServiceImpl implements SeeYonOperationService {
     private final TzcPolicyService tzcPolicyService;
     private final TzcPolicyItemService tzcPolicyItemService;
     private final TbsBudgetLogService tbsBudgetLogService;
+    private final TzcPolicyApplicationServiceImpl tzcPolicyApplicationService;
 
     @Override
     public String getTargetId(TbsAffairCommitBo affairCommit) {
@@ -96,6 +97,12 @@ public class TzcPolicyOperationServiceImpl implements SeeYonOperationService {
         LambdaQueryWrapper<TzcPolicyItem> itemLqw = new LambdaQueryWrapper<>();
         itemLqw.eq(TzcPolicyItem::getPolicyId,tzcPolicy.getId());
         tzcPolicyItemService.update(policyItem,itemLqw);
+        //同步到销路通表
+        try {
+            tzcPolicyApplicationService.syncPolicy(tzcPolicy.getId());
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
         return R.ok();
     }