新增保证金扣减业务

zhangmeiyang
1 parent 153b18c8
Showing 4 changed files with 120 additions and 31 deletions
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/demarcate/AbstractBillHandler.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/handler/business/bill/SettleBillHandler.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/mapper/TransMapper.java
etrade-thirdparty/src/main/resources/com/diligrp/etrade/thirdparty/mapper/TransMapper.xml
@@ -87,7 +87,7 @@ public abstract class AbstractBillHandler&lt;T extends BaseBillCo&gt; extends Abstract
     private static <T extends BaseBillCo> BiConsumer<String, List<BusinessDetailDto>> multiMapFilter(T e) {
         return (k, v) -> TRANSFER_FUNCTION_MULTI_MAP.get(k).transferDynamic(e, v);
     }
-    private static <T extends BaseBillCo> BiConsumer<String, BusinessDetailDto> singleMapFilter(T e) {
+    protected static <T extends BaseBillCo> BiConsumer<String, BusinessDetailDto> singleMapFilter(T e) {
         return (k, v) -> TRANSFER_FUNCTION_SINGLE_MAP.get(k).transferDynamic(e, v);
     }
@@ -111,7 +111,7 @@ public abstract class AbstractBillHandler&lt;T extends BaseBillCo&gt; extends Abstract
      * 批量转换方法
      *
      */
-    private void transferPayMethod(List<FEntityDetail> fEntityDetail, Long marketId, String systemCode) {
+    protected void transferPayMethod(List<FEntityDetail> fEntityDetail, Long marketId, String systemCode) {
         fEntityDetail.forEach(e -> {
             if (!ObjectUtils.isEmpty(e.getFSettleTypeID())) {
                 e.getFSettleTypeID().setFNumber(getPayMethod(e.getFSettleTypeID().getFNumber(), systemCode, marketId));
@@ -3,18 +3,20 @@ package com.diligrp.etrade.thirdparty.handler.business.bill;
 import com.diligrp.etrade.core.util.JsonUtils;
 import com.diligrp.etrade.thirdparty.demarcate.AbstractBillHandler;
 import com.diligrp.etrade.thirdparty.domain.co.business.bill.SettleBillCo;
+import com.diligrp.etrade.thirdparty.domain.dto.BusinessDetailDto;
+import com.diligrp.etrade.thirdparty.domain.dto.ChargeItemDto;
+import com.diligrp.etrade.thirdparty.domain.model.FCOSTID;
 import com.diligrp.etrade.thirdparty.domain.model.FEntityDetail;
-import com.diligrp.etrade.thirdparty.type.BailFeeType;
 import com.diligrp.etrade.thirdparty.type.BusinessEnum;
 import com.diligrp.etrade.thirdparty.type.DynamicType;
+import com.diligrp.etrade.thirdparty.type.SelectType;
 import com.fasterxml.jackson.core.type.TypeReference;
+import org.apache.commons.lang3.math.NumberUtils;
 import org.springframework.stereotype.Component;
-import java.util.*;
+import java.util.List;
+import java.util.Optional;
 import java.util.function.Consumer;
-import java.util.function.Predicate;
-import java.util.stream.Collectors;
-import java.util.stream.Stream;
 /**
  * @Author: zhangmeiyang
@@ -24,40 +26,65 @@ import java.util.stream.Stream;
 @Component
 public class SettleBillHandler extends AbstractBillHandler<SettleBillCo> {
-    private static Consumer<SettleBillCo> action(List<SettleBillCo> bail, List<SettleBillCo> other) {
-        return e -> Optional.ofNullable(e).filter(predict()).ifPresentOrElse(other::add, special(e, bail));
+    private static Consumer<ChargeItemDto> setSystemChargeItemCode(FEntityDetail fe) {
+        return e -> fe.setSystemChargeItemCode(e.getChargeItemCode());
     }
-    private static Runnable special(SettleBillCo e, List<SettleBillCo> bail) {
-        return () -> {
-            Map<BailFeeType, List<FEntityDetail>> map = new HashMap<>();
-            List<FEntityDetail> fEntityDetail = e.getFEntityDetail();
-            fEntityDetail.forEach(prepareMap(map));
-            map.forEach((k,v)-> k.loadData(v,e,bail));
-        };
+    private static Consumer<BusinessDetailDto> fixedAction(FEntityDetail e) {
+        return f -> e.setFixChargeItemCode(f.getItemValue());
     }
-    private static Consumer<FEntityDetail> prepareMap(Map<BailFeeType, List<FEntityDetail>> map) {
-        return f -> map.computeIfAbsent(BailFeeType.fromCode(f.getFeeType()), k -> new ArrayList<>()).add(f);
+    @Override
+    public void handle(String json, Long marketId, String systemCode) throws Exception {
+        List<SettleBillCo> settleBillCos = JsonUtils.fromJsonString(json, new TypeReference<>() {
+        });
+        List<SettleBillCo> lists = splitBill(settleBillCos, marketId, systemCode);
+        sendPurchaseOrder(lists, marketId, systemCode);
     }
-    private static Predicate<SettleBillCo> predict() {
-        return t -> !DynamicType.areEqual(t.getSystemDynamicCode(), DynamicType.BAIL);
+    private List<SettleBillCo> splitBill(List<SettleBillCo> settleBillCos, Long marketId, String systemCode) {
+        settleBillCos.forEach(
+                e -> {
+                    DynamicType dynamicType = DynamicType.fromCode(e.getSystemDynamicCode());
+                    billTrans.transBillCo(e, marketId, systemCode);
+                    transferPayMethod(e.getFEntityDetail(), marketId, systemCode);
+                    getFilteredDynamicDataSingle(dynamicType, marketId, systemCode).forEach(singleMapFilter(e));
+                    transChargeItem(e.getFEntityDetail(), marketId, systemCode);
+                }
+        );
+        return settleBillCos;
     }
-    @Override
-    public void handle(String json, Long marketId, String systemCode) throws Exception {
-        List<SettleBillCo> settleBillCos = JsonUtils.fromJsonString(json, new TypeReference<>() {});
-        List<SettleBillCo> lists = splitBill(settleBillCos);
-        transferDataListWithFeeItem(lists, marketId, systemCode);
-        sendPurchaseOrder(lists, marketId, systemCode);
+    private void transChargeItem(List<FEntityDetail> fEntityDetail, Long marketId, String systemCode) {
+        fEntityDetail.forEach(e -> Optional.ofNullable(e.getFCOSTID()).ifPresent(chargeItemAction(marketId, systemCode, e)));
     }
-    private List<SettleBillCo> splitBill(List<SettleBillCo> settleBillCos) {
-        List<SettleBillCo> other = new ArrayList<>();
-        List<SettleBillCo> bail = new ArrayList<>();
-        settleBillCos.forEach(action(bail, other));
-        return Stream.of(other, bail).flatMap(List::stream).collect(Collectors.toList());
+    private Consumer<FCOSTID> chargeItemAction(Long marketId, String systemCode, FEntityDetail e) {
+        return costId -> {
+            var number = costId.getFNUMBER();
+            BusinessDetailDto detail = getBusinessDetailDto(marketId, systemCode, costId, number);
+            Optional.ofNullable(detail)
+                    .filter(f -> f.getSelectType() == SelectType.FIXED)
+                    .ifPresentOrElse(fixedAction(e), dynamicAction(number, e));
+        };
+    }
+
+    private Runnable dynamicAction(String number, FEntityDetail fe) {
+        return () -> {
+            ChargeItemDto chargeItem = transMapper.getChargeItem(Long.valueOf(number));
+            Optional.ofNullable(chargeItem).ifPresent(setSystemChargeItemCode(fe));
+        };
+    }
+
+    private BusinessDetailDto getBusinessDetailDto(Long marketId, String systemCode, FCOSTID costId, String number) {
+        BusinessDetailDto detail;
+        if (NumberUtils.isCreatable(number) && DynamicType.notContain(number)) {
+            detail = transMapper.getSingleBusinessDetail(getDocumentType().sign, systemCode, marketId, Long.valueOf(costId.getFNUMBER()));
+        } else {
+            detail = transMapper.getSingleFixedBusinessDetail(getDocumentType().sign, systemCode, marketId, costId.getFNUMBER());
+
+        }
+        return detail;
     }
     @Override
@@ -40,6 +40,30 @@ public interface TransMapper extends MybatisMapperSupport {
     /**
+     * 获取动态参数
+     *
+     * @param documentType 文档类型
+     * @param systemCode   系统代码
+     * @param marketId     市场 ID
+     * @param relationId   关系 ID
+     * @return {@link BusinessDetailDto}
+     */
+    @DataSource(DataSourceConstants.DS_KEY_SLAVE)
+    BusinessDetailDto getSingleBusinessDetail(@Param("documentType") String documentType,@Param("systemCode")String systemCode, @Param("marketId")Long marketId,@Param("relationId")Long relationId);
+
+    /**
+     * 获取动态参数
+     *
+     * @param documentType 文档类型
+     * @param systemCode   系统代码
+     * @param marketId     市场 ID
+     * @param relationId   关系 ID
+     * @return {@link BusinessDetailDto}
+     */
+    @DataSource(DataSourceConstants.DS_KEY_SLAVE)
+    BusinessDetailDto getSingleFixedBusinessDetail(@Param("documentType") String documentType,@Param("systemCode")String systemCode, @Param("marketId")Long marketId,@Param("itemCode")String itemCode);
+
+    /**
      * 获取部门
      *
      * @param departmentId 部门 ID
@@ -135,4 +135,42 @@
           AND system_code = #{systemCode}
           AND `code` = #{dynamicType}
     </select>
+    <select id="getSingleBusinessDetail" resultType="com.diligrp.etrade.thirdparty.domain.dto.BusinessDetailDto">
+        SELECT
+            fbd.code             AS code
+          , fbd.name             AS name
+          , fbd.select_type      AS selectType
+          , fbd.item_code        AS itemCode
+          , fbd.item_name        AS itemName
+          , fbd.item_relation_id AS itemRelationId
+          , fbd.item_value       AS itemValue
+        FROM
+            `dili-basic-data`.`financial_business` fb
+                LEFT JOIN `dili-basic-data`.financial_business_detail fbd ON fb.id = fbd.financial_business_id
+        WHERE
+              1 = 1
+          AND fbd.financial_type = #{documentType}
+          AND fb.market_id = #{marketId}
+          AND fb.system_code = #{systemCode}
+          AND fbd.item_relation_id = #{relationId}
+    </select>
+    <select id="getSingleFixedBusinessDetail" resultType="com.diligrp.etrade.thirdparty.domain.dto.BusinessDetailDto">
+        SELECT
+            fbd.code             AS code
+          , fbd.name             AS name
+          , fbd.select_type      AS selectType
+          , fbd.item_code        AS itemCode
+          , fbd.item_name        AS itemName
+          , fbd.item_relation_id AS itemRelationId
+          , fbd.item_value       AS itemValue
+        FROM
+            `dili-basic-data`.`financial_business` fb
+                LEFT JOIN `dili-basic-data`.financial_business_detail fbd ON fb.id = fbd.financial_business_id
+        WHERE
+              1 = 1
+          AND fbd.financial_type = #{documentType}
+          AND fb.market_id = #{marketId}
+          AND fb.system_code = #{systemCode}
+          AND fbd.item_code = #{itemCode}
+    </select>
 </mapper>