金蝶多对一费用项优化，应收单单据创建优化

zhangmeiyang
1 parent 14200344
Showing 18 changed files with 415 additions and 144 deletions
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/demarcate/AbstractBasicHandler.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/demarcate/AbstractBillHandler.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/exec/basic/BasicReceiver.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/exec/business/BusinessReceiver.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/handler/basic/BusinessTypeBasicHandler.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/handler/basic/ChargeItemBasicHandler.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/handler/basic/ChargeItemGroupBasicHandler.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/handler/basic/CustomerBasicHandler.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/handler/basic/DepartmentBasicHandler.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/handler/basic/SettlementBasicHandler.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/mapper/RecordMapper.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/type/BillType.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/utils/DepartmentApiUtils.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/utils/FeeApiUtils.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/utils/PurchaseOrderApiUtils.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/utils/ReceiptsOrderApiUtils.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/utils/ReceiptsRefundOrderApiUtils.java
etrade-thirdparty/src/main/resources/com/diligrp/etrade/thirdparty/mapper/RecordMapper.xml
@@ -11,6 +11,7 @@ import com.diligrp.etrade.thirdparty.mapper.TransMapper;
 import com.diligrp.etrade.thirdparty.type.BasicEnum;
 import com.kingdee.bos.webapi.entity.IdentifyInfo;
 import jakarta.annotation.Resource;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.ObjectUtils;
 import java.util.Arrays;
@@ -53,6 +54,16 @@ public abstract class AbstractBasicHandler&lt;T extends BaseSourceCo&gt; implements Ty
         recordMapper.recordTheMappingData(mapping);
     }
+    @Transactional
+    protected void deleteMapping(Long marketId, String systemCode, Long systemDataId){
+        var mapping = new MappingDto();
+        mapping.setMarketId(marketId);
+        mapping.setBusiness(getType().code);
+        mapping.setSystemCode(systemCode);
+        mapping.setSystemDataId(systemDataId);
+        recordMapper.deleteTheMappingData(mapping);
+    }
+
     /**
      * 获取身份信息
      *
 package com.diligrp.etrade.thirdparty.demarcate;
-import com.diligrp.etrade.core.util.JsonUtils;
 import com.diligrp.etrade.thirdparty.component.TransferComponent;
 import com.diligrp.etrade.thirdparty.domain.co.business.BaseBillCo;
 import com.diligrp.etrade.thirdparty.domain.dto.BusinessDetailDto;
 import com.diligrp.etrade.thirdparty.domain.dto.BusinessDto;
 import com.diligrp.etrade.thirdparty.domain.dto.ClientDto;
-import com.diligrp.etrade.thirdparty.domain.model.FEntityDetail;
 import com.diligrp.etrade.thirdparty.error.ThirdPartyException;
 import com.diligrp.etrade.thirdparty.mapper.TransMapper;
 import com.diligrp.etrade.thirdparty.type.*;
-import com.diligrp.etrade.thirdparty.utils.PurchaseOrderApiUtils;
 import com.kingdee.bos.webapi.entity.IdentifyInfo;
 import jakarta.annotation.Resource;
 import org.springframework.util.ObjectUtils;
-import java.math.BigDecimal;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
@@ -53,6 +49,55 @@ public abstract class AbstractBillHandler&lt;T extends BaseBillCo&gt; implements TypeM
     }
     /**
+     * 处理
+     *
+     * @param json       JSON 格式
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     * @throws Exception 例外
+     */
+    public abstract void handle(String json, Long marketId, String systemCode) throws Exception;
+
+     /**
+     * 获取动态数据
+     *
+     * @param marketId    市场 ID
+     * @param systemCode  系统代码
+     * @param dynamicType 动态型
+     * @return {@link Map}<{@link String}, {@link BusinessDetailDto}>
+     */
+    protected Map<String, BusinessDetailDto> getFilteredDynamicDataSingle(DynamicType dynamicType, Long marketId, String systemCode) {
+        var queryArrays = new String[]{
+                BasicEnum.DEPARTMENT_TO_LOWER.code,
+                BasicEnum.CUSTOMER_TO_LOWER.code,
+                BasicEnum.FINANCIAL_CHANNEL_TYPE_TO_LOWER.code,
+                BasicEnum.FINANCIAL_BUSINESS_TYPE_TO_LOWER.code
+        };
+        var dynamicParam = transMapper.getFixedWithQueryArrays(systemCode, dynamicType.code, marketId, SelectType.FIXED.getCode(), queryArrays);
+        Map<String, BusinessDetailDto> map = new HashMap<>();
+        if (!ObjectUtils.isEmpty(dynamicParam)) {
+            dynamicParam.forEach(e -> map.computeIfAbsent(e.getCode(), k -> e));
+        }
+        return map;
+    }
+
+    /**
+     * 传输数据列表
+     *
+     * @param ts         茨
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     */
+    protected void transferDataListWithOutFeeItem(List<T> ts, Long marketId, String systemCode) {
+        ts.forEach(e -> {
+            DynamicType dynamicType = DynamicType.fromCode(e.getSystemDynamicCode());
+            transfer(e, marketId, systemCode);
+            getFilteredDynamicDataSingle(dynamicType, marketId, systemCode).forEach((k, v) -> TRANSFER_FUNCTION_SINGLE_MAP.get(k).transferDynamic(e, v));
+            getFilteredDynamicDataMulti(dynamicType, marketId, systemCode).forEach((k, v) -> TRANSFER_FUNCTION_MULTI_MAP.get(k).transferDynamic(e, v));
+        });
+    }
+
+    /**
      * 转换动态配置部门
      *
      * @param t    t
@@ -180,22 +225,6 @@ public abstract class AbstractBillHandler&lt;T extends BaseBillCo&gt; implements TypeM
     /**
      * 传输数据列表
      *
-     * @param ts         茨
-     * @param marketId   市场 ID
-     * @param systemCode 系统代码
-     */
-    protected void transferDataListWithOutFeeItem(List<T> ts, Long marketId, String systemCode) {
-        ts.forEach(e -> {
-            DynamicType dynamicType = DynamicType.fromCode(e.getSystemDynamicCode());
-            transfer(e, marketId, systemCode);
-            getFilteredDynamicDataSingle(dynamicType, marketId, systemCode).forEach((k, v) -> TRANSFER_FUNCTION_SINGLE_MAP.get(k).transferDynamic(e, v));
-            getFilteredDynamicDataMulti(dynamicType, marketId, systemCode).forEach((k, v) -> TRANSFER_FUNCTION_MULTI_MAP.get(k).transferDynamic(e, v));
-        });
-    }
-
-    /**
-     * 传输数据列表
-     *
      *
      * @param ts         茨
      * @param marketId   市场 ID
@@ -219,29 +248,6 @@ public abstract class AbstractBillHandler&lt;T extends BaseBillCo&gt; implements TypeM
      * @param dynamicType 动态型
      * @return {@link Map}<{@link String}, {@link BusinessDetailDto}>
      */
-    protected Map<String, BusinessDetailDto> getFilteredDynamicDataSingle(DynamicType dynamicType, Long marketId, String systemCode) {
-        var queryArrays = new String[]{
-                BasicEnum.DEPARTMENT_TO_LOWER.code,
-                BasicEnum.CUSTOMER_TO_LOWER.code,
-                BasicEnum.FINANCIAL_CHANNEL_TYPE_TO_LOWER.code,
-                BasicEnum.FINANCIAL_BUSINESS_TYPE_TO_LOWER.code
-        };
-        var dynamicParam = transMapper.getFixedWithQueryArrays(systemCode, dynamicType.code, marketId, SelectType.FIXED.getCode(), queryArrays);
-        Map<String, BusinessDetailDto> map = new HashMap<>();
-        if (!ObjectUtils.isEmpty(dynamicParam)) {
-            dynamicParam.forEach(e -> map.computeIfAbsent(e.getCode(), k -> e));
-        }
-        return map;
-    }
-
-    /**
-     * 获取动态数据
-     *
-     * @param marketId    市场 ID
-     * @param systemCode  系统代码
-     * @param dynamicType 动态型
-     * @return {@link Map}<{@link String}, {@link BusinessDetailDto}>
-     */
     protected Map<String, List<BusinessDetailDto>> getFilteredDynamicDataMulti(DynamicType dynamicType, Long marketId, String systemCode) {
         var queryArrays = new String[]{BasicEnum.CHARGE_ITEM_TO_LOWER.code};
         var dynamicParam = transMapper.getFixedWithQueryArrays(systemCode, dynamicType.code, marketId, SelectType.FIXED.getCode(), queryArrays);
@@ -262,51 +268,22 @@ public abstract class AbstractBillHandler&lt;T extends BaseBillCo&gt; implements TypeM
      */
     protected void sendPurchaseOrder(List<T> ts, Long marketId, String systemCode) throws Exception {
         var identifyInfo = getIdentifyInfo(marketId, systemCode);
-        var util = new PurchaseOrderApiUtils(identifyInfo);
         for (T e : ts) {
             var billId = e.getFBillTypeID().getFNUMBER();
             //获取单据类型
             String documentType = getDocumentType(marketId, systemCode, billId);
+            if (ObjectUtils.isEmpty(documentType)) {
+                throw new ThirdPartyException("未配置业务映射");
+            }
             var fixedBusinessType = e.getFixedBusinessType();
             //业务类型固定的情况下
             if (!ObjectUtils.isEmpty(fixedBusinessType)){
                 e.getFBillTypeID().setFNUMBER(fixedBusinessType);
             }
-            if (ObjectUtils.isEmpty(documentType)) {
-                throw new ThirdPartyException("未配置业务映射");
-            }
-            if (util.getPurchaseOrder(e.getFBillTypeID().getFNUMBER(), e.getF_ZDB_Text1(), getAllAmountFor(e), e.getF_ZDB_Text667())) {
-                util.createOnePurchaseOrder(JsonUtils.toJsonString(e), documentType);
-            }
+            BillType.getBillType(documentType).handle(e,identifyInfo);
         }
     }
-    private IdentifyInfo getIdentifyInfo(Long marketId, String systemCode) {
-        var identifyInfo = new IdentifyInfo();
-        ClientDto clientParam = transMapper.getClientParam(systemCode, marketId);
-        identifyInfo.setAppId(clientParam.getApplyId());
-        identifyInfo.setUserName(clientParam.getUsername());
-        identifyInfo.setServerUrl(clientParam.getServiceAddress());
-        identifyInfo.setAppSecret(clientParam.getSecurityKey());
-        identifyInfo.setdCID(clientParam.getDataCentreId());
-        return identifyInfo;
-    }
-
-    /**
-     * 获取 所有金额
-     *
-     * @param e e
-     * @return {@link String}
-     */
-    private String getAllAmountFor(T e) {
-        var allAmountFor = BigDecimal.ZERO;
-        for (FEntityDetail f : e.getFEntityDetail()) {
-            BigDecimal single = f.getFPrice().multiply(f.getFPriceQty());
-            allAmountFor = allAmountFor.add(single);
-        }
-        return allAmountFor.toString();
-    }
-
     /**
      * 获取文档类型
      *
@@ -315,29 +292,53 @@ public abstract class AbstractBillHandler&lt;T extends BaseBillCo&gt; implements TypeM
      * @param billTypeId 账单类型 ID
      * @return {@link String}
      */
-    protected String getDocumentType(Long marketId, String systemCode, String billTypeId) {
+    private String getDocumentType(Long marketId, String systemCode, String billTypeId) {
         var res = transMapper.getMappingDict(BasicEnum.FINANCIAL_BUSINESS_TYPE_TO_LOWER.code, systemCode, marketId, billTypeId);
         return ObjectUtils.isEmpty(res) ? null : res.getMapType();
     }
-
+    /**
+     * 传递函数 Single
+     *
+     * @author zhangmeiyang
+     * @date 2024/11/20
+     */
     @FunctionalInterface
     protected interface TransferFunctionSingle {
+        /**
+         * Transfer Dynamic （传输动态）
+         *
+         * @param baseBillCo Base Bill 公司
+         * @param data       数据
+         */
         void transferDynamic(BaseBillCo baseBillCo, BusinessDetailDto data);
     }
-    @FunctionalInterface
-    protected interface TransferFunctionMulti {
-        void transferDynamic(BaseBillCo baseBillCo, List<BusinessDetailDto> data);
+    private IdentifyInfo getIdentifyInfo(Long marketId, String systemCode) {
+        var identifyInfo = new IdentifyInfo();
+        ClientDto clientParam = transMapper.getClientParam(systemCode, marketId);
+        identifyInfo.setAppId(clientParam.getApplyId());
+        identifyInfo.setUserName(clientParam.getUsername());
+        identifyInfo.setServerUrl(clientParam.getServiceAddress());
+        identifyInfo.setAppSecret(clientParam.getSecurityKey());
+        identifyInfo.setdCID(clientParam.getDataCentreId());
+        return identifyInfo;
     }
     /**
-     * 处理
+     * 传递函数 Multi
      *
-     * @param json       JSON 格式
-     * @param marketId   市场 ID
-     * @param systemCode 系统代码
-     * @throws Exception 例外
+     * @author zhangmeiyang
+     * @date 2024/11/20
      */
-    public abstract void handle(String json, Long marketId, String systemCode) throws Exception;
+    @FunctionalInterface
+    protected interface TransferFunctionMulti {
+        /**
+         * Transfer Dynamic （传输动态）
+         *
+         * @param baseBillCo Base Bill 公司
+         * @param data       数据
+         */
+        void transferDynamic(BaseBillCo baseBillCo, List<BusinessDetailDto> data);
+    }
 }
@@ -66,7 +66,7 @@ public class BasicReceiver extends AbstractReceiver {
         } catch (Exception e) {
             channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
             if (msg.getRetryCount() > 3) {
-                super.handleError(e.fillInStackTrace().getMessage(), msg.getData(), msg.getBasic().code, msg.getSystemCode(), msg.getMarketId());
+                handleError(e.fillInStackTrace().getMessage(), msg.getData(), msg.getBasic().code, msg.getSystemCode(), msg.getMarketId());
                 LOG.error("基础数据重试队列消息处理失败:", e);
             } else {
                 msg.setRetryCount(msg.getRetryCount() + 1);
@@ -64,7 +64,7 @@ public class BusinessReceiver extends AbstractReceiver {
         } catch (Exception e) {
             channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
             if (msg.getRetryCount() > 3) {
-                super.handleError(e.fillInStackTrace().getMessage(), msg.getData(), msg.getBusiness().code, msg.getSystemCode(),msg.getMarketId());
+                handleError(e.fillInStackTrace().getMessage(), msg.getData(), msg.getBusiness().code, msg.getSystemCode(),msg.getMarketId());
                 LOG.error("业务重试队列消息处理失败:",e);
             }else{
                 msg.setRetryCount(msg.getRetryCount() + 1);
@@ -25,18 +25,22 @@ public class BusinessTypeBasicHandler extends AbstractBasicHandler&lt;BusinessTypeC
         List<BusinessTypeCo> businessTypeCos = JsonUtils.fromJsonString(json, new TypeReference<>() {});
         var utils = new BillTypeApiUtils(getIdentifyInfo(marketId, systemCode));
         for (BusinessTypeCo e : businessTypeCos) {
-            super.transfer(e, marketId, systemCode);
-            MappingDto mappingData = super.getMappingData(marketId, systemCode, e.getSystemDataId());
-            e.setFBILLTYPEID(ObjectUtils.isEmpty(mappingData) ? null : mappingData.getThirdPartyDataId());
-            if (!ObjectUtils.isEmpty(mappingData)){
-                utils.updateBillType(mappingData.getThirdPartyDataId(),JsonUtils.toJsonString(e));
-            }else {
-                String billType = utils.createBillType(JsonUtils.toJsonString(e));
-                super.recordMapping(marketId, systemCode, e.getSystemDataId(), billType);
-            }
+            transfer(e, marketId, systemCode);
+            MappingDto mappingData = getMappingData(marketId, systemCode, e.getSystemDataId());
+            saveData(marketId, systemCode, e, mappingData, utils);
         }
     }
+    private void saveData(Long marketId, String systemCode, BusinessTypeCo e, MappingDto mappingData, BillTypeApiUtils utils) throws Exception {
+        if (!ObjectUtils.isEmpty(mappingData)){
+            e.setFBILLTYPEID(mappingData.getThirdPartyDataId());
+            utils.updateBillType(mappingData.getThirdPartyDataId(), JsonUtils.toJsonString(e));
+            return;
+        }
+        String billType = utils.createBillType(JsonUtils.toJsonString(e));
+        recordMapping(marketId, systemCode, e.getSystemDataId(), billType);
+    }
+
     @Override
     public BasicEnum getType() {
         return BasicEnum.FINANCIAL_BUSINESS_TYPE;
@@ -25,18 +25,36 @@ public class ChargeItemBasicHandler extends AbstractBasicHandler&lt;ChargeItemCo&gt; {
         List<ChargeItemCo> chargeItemCos = JsonUtils.fromJsonString(json, new TypeReference<>(){});
         var utils =new FeeApiUtils(getIdentifyInfo(marketId, systemCode));
         for (ChargeItemCo e : chargeItemCos) {
-            super.transfer(e, marketId, systemCode);
-            MappingDto mappingData = super.getMappingData(marketId, systemCode, e.getSystemDataId());
-            e.setFEXPID(ObjectUtils.isEmpty(mappingData) ? null : Long.valueOf(mappingData.getThirdPartyDataId()));
+            transfer(e, marketId, systemCode);
+            ChargeItemCo existFee = utils.getFee(e.getFNumber(),e.getFGroup().getFNumber());
+            MappingDto mappingData = getMappingData(marketId, systemCode, e.getSystemDataId());
+            establishMappings(marketId, systemCode, e, existFee, mappingData, utils);
+        }
+    }
+
+    private void establishMappings(Long marketId, String systemCode, ChargeItemCo e, ChargeItemCo existFee, MappingDto mappingData, FeeApiUtils utils) throws Exception {
+        if (ObjectUtils.isEmpty(existFee)){ //如果查询到jd上的费用项不存在 分为两种情况 1.新增映射 2.修改老的映射（但是修改了费用项编码）
             if (!ObjectUtils.isEmpty(mappingData)){
+                //mappingData存在表明存在旧映射关系，删除旧映射关系
+                deleteMapping(mappingData.getMarketId(), mappingData.getSystemCode(), mappingData.getSystemDataId());
+            }
+            String fee = utils.createFee(JsonUtils.toJsonString(e));
+            recordMapping(marketId, systemCode, e.getSystemDataId(), fee);
+            //重做映射
+        }else{
+            //查询到jd费用项存在映射 分为两种情况 1.修改映射 2.新增多重映射
+            if (ObjectUtils.isEmpty(mappingData)){
+                //新增多重映射
+                recordMapping(marketId, systemCode, e.getSystemDataId(), String.valueOf(existFee.getFEXPID()));
+            }else{
+                //变更映射
+                e.setFEXPID(Long.valueOf(mappingData.getThirdPartyDataId()));
                 utils.updateFee(String.valueOf(mappingData.getThirdPartyDataId()),JsonUtils.toJsonString(e));
-            }else {
-                String fee = utils.createFee(JsonUtils.toJsonString(e));
-                super.recordMapping(marketId, systemCode, e.getSystemDataId(), fee);
             }
         }
     }
+
     @Override
     public BasicEnum getType() {
         return BasicEnum.CHARGE_ITEM;
@@ -32,7 +32,7 @@ public class ChargeItemGroupBasicHandler extends AbstractBasicHandler&lt;ChargeItem
         List<ChargeItemGroupCo> chargeItemGroupCos = JsonUtils.fromJsonString(json, new TypeReference<>() {
         });
         for (ChargeItemGroupCo e : chargeItemGroupCos) {
-            super.transfer(e, marketId, systemCode);
+            transfer(e, marketId, systemCode);
             Long systemParentId = e.getFParentId();
             Long systemDataId = e.getSystemDataId();
             MappingDto parentMappingData = getMappingData(marketId, systemCode, systemParentId);
@@ -34,31 +34,35 @@ public class CustomerBasicHandler extends AbstractBasicHandler&lt;CustomerCo&gt; {
         FGroup fGroup = new FGroup();
         transferCustomerGroup(fGroup, marketId, systemCode);
         for (CustomerCo e : customerCos) {
-            super.transfer(e, marketId, systemCode);
+            MappingDto mappingData = getMappingData(marketId, systemCode, e.getSystemDataId());
+            transfer(e, marketId, systemCode);
             e.setFGroup(fGroup);
-            MappingDto mappingData = super.getMappingData(marketId, systemCode, e.getSystemDataId());
-            List<FT_BD_CUSTLOCATION> ftBdCustlocation = e.getFT_BD_CUSTLOCATION();
-            var list = new ArrayList<FT_BD_CUSTLOCATION>();
-            if (!ObjectUtils.isEmpty(ftBdCustlocation)){
-                for (FT_BD_CUSTLOCATION ftBdCustLocation : ftBdCustlocation) {
-                    ftBdCustLocation.setFCompanyType(F_COMPANY_TYPE);
-                    String contact = contactUtils.createContact(JsonUtils.toJsonString(ftBdCustLocation));
-                    FContactId fContactId = new FContactId();
-                    fContactId.setFNUMBER(contact);
-                    var item = new FT_BD_CUSTLOCATION();
-                    item.setFContactId(fContactId);
-                    list.add(item);
-                }
-            }
-            e.setFT_BD_CUSTLOCATION(list);
-            e.setFCUSTID(ObjectUtils.isEmpty(mappingData) ? null : Long.valueOf(mappingData.getThirdPartyDataId()));
+            e.setFT_BD_CUSTLOCATION(getFtBdCustlocations(e, contactUtils));
             if (!ObjectUtils.isEmpty(mappingData)){
+                e.setFCUSTID(Long.valueOf(mappingData.getThirdPartyDataId()));
                 customerUtils.updateCustomer(String.valueOf(mappingData.getThirdPartyDataId()),JsonUtils.toJsonString(e));
             }else {
                 String billType = customerUtils.createCustomer(JsonUtils.toJsonString(e));
-                super.recordMapping(marketId, systemCode, e.getSystemDataId(), billType);
+                recordMapping(marketId, systemCode, e.getSystemDataId(), billType);
+            }
+        }
+    }
+
+    private List<FT_BD_CUSTLOCATION> getFtBdCustlocations(CustomerCo e, ContactApiUtils contactUtils) throws Exception {
+        List<FT_BD_CUSTLOCATION> ftBdCustlocation = e.getFT_BD_CUSTLOCATION();
+        var list = new ArrayList<FT_BD_CUSTLOCATION>();
+        if (!ObjectUtils.isEmpty(ftBdCustlocation)){
+            for (FT_BD_CUSTLOCATION ftBdCustLocation : ftBdCustlocation) {
+                ftBdCustLocation.setFCompanyType(F_COMPANY_TYPE);
+                String contact = contactUtils.createContact(JsonUtils.toJsonString(ftBdCustLocation));
+                FContactId fContactId = new FContactId();
+                fContactId.setFNUMBER(contact);
+                var item = new FT_BD_CUSTLOCATION();
+                item.setFContactId(fContactId);
+                list.add(item);
             }
         }
+        return list;
     }
     @Override
@@ -25,19 +25,23 @@ public class DepartmentBasicHandler extends AbstractBasicHandler&lt;DepartmentCo&gt; {
         List<DepartmentCo> departmentCos = JsonUtils.fromJsonString(json, new TypeReference<>(){});
         var utils = new DepartmentApiUtils(getIdentifyInfo(marketId, systemCode));
         for (DepartmentCo e : departmentCos) {
-            super.transfer(e, marketId, systemCode);
-            MappingDto mappingData = super.getMappingData(marketId, systemCode, e.getSystemDataId());
-            e.setFDEPTID(ObjectUtils.isEmpty(mappingData) ? null : Long.valueOf(mappingData.getThirdPartyDataId()));
-            if (!ObjectUtils.isEmpty(mappingData)){
-                utils.updateDepartment(String.valueOf(mappingData.getThirdPartyDataId()),JsonUtils.toJsonString(e));
-            }else {
-                String department = utils.createDepartment(JsonUtils.toJsonString(e));
-                super.recordMapping(marketId, systemCode, e.getSystemDataId(), department);
-            }
+            transfer(e, marketId, systemCode);
+            MappingDto mappingData = getMappingData(marketId, systemCode, e.getSystemDataId());
+            saveData(marketId, systemCode, e, mappingData, utils);
         }
     }
+    private void saveData(Long marketId, String systemCode, DepartmentCo e, MappingDto mappingData, DepartmentApiUtils utils) throws Exception {
+        if (!ObjectUtils.isEmpty(mappingData)){
+            e.setFDEPTID(Long.valueOf(mappingData.getThirdPartyDataId()));
+            utils.updateDepartment(String.valueOf(mappingData.getThirdPartyDataId()),JsonUtils.toJsonString(e));
+        }else {
+            String department = utils.createDepartment(JsonUtils.toJsonString(e));
+            recordMapping(marketId, systemCode, e.getSystemDataId(), department);
+        }
+    }
+
     @Override
     public BasicEnum getType() {
         return BasicEnum.DEPARTMENT;
@@ -25,15 +25,19 @@ public class SettlementBasicHandler extends AbstractBasicHandler&lt;SettlementCo&gt; {
         List<SettlementCo> settlementCos = JsonUtils.fromJsonString(json, new TypeReference<>() {});
         var utils = new SettleTypeApiUtils(getIdentifyInfo(marketId, systemCode));
         for (SettlementCo e : settlementCos) {
-            super.transfer(e, marketId, systemCode);
-            MappingDto mappingData = super.getMappingData(marketId, systemCode, e.getSystemDataId());
-            e.setFID(ObjectUtils.isEmpty(mappingData) ? null : Long.valueOf(mappingData.getThirdPartyDataId()));
-            if (!ObjectUtils.isEmpty(mappingData)){
-                utils.updateSettleType(String.valueOf(mappingData.getThirdPartyDataId()),JsonUtils.toJsonString(e));
-            }else {
-                String billType = utils.createSettleType(JsonUtils.toJsonString(e));
-                super.recordMapping(marketId, systemCode, e.getSystemDataId(), billType);
-            }
+            transfer(e, marketId, systemCode);
+            MappingDto mappingData = getMappingData(marketId, systemCode, e.getSystemDataId());
+            saveData(marketId, systemCode, e, mappingData, utils);
+        }
+    }
+
+    private void saveData(Long marketId, String systemCode, SettlementCo e, MappingDto mappingData, SettleTypeApiUtils utils) throws Exception {
+        if (!ObjectUtils.isEmpty(mappingData)){
+            e.setFID(Long.valueOf(mappingData.getThirdPartyDataId()));
+            utils.updateSettleType(String.valueOf(mappingData.getThirdPartyDataId()),JsonUtils.toJsonString(e));
+        }else {
+            String billType = utils.createSettleType(JsonUtils.toJsonString(e));
+            recordMapping(marketId, systemCode, e.getSystemDataId(), billType);
         }
     }
@@ -25,4 +25,11 @@ public interface RecordMapper extends MybatisMapperSupport {
      */
     @DataSource(DataSourceConstants.DS_KEY_MASTER)
     void recordTheMappingData(@Param("mapping")MappingDto mapping);
+
+
+    /**
+     * @param mapping
+     */
+    @DataSource(DataSourceConstants.DS_KEY_MASTER)
+    void deleteTheMappingData(@Param("mapping")MappingDto mapping);
 }
+package com.diligrp.etrade.thirdparty.type;
+
+import com.diligrp.etrade.core.util.JsonUtils;
+import com.diligrp.etrade.thirdparty.domain.co.business.BaseBillCo;
+import com.diligrp.etrade.thirdparty.domain.model.FEntityDetail;
+import com.diligrp.etrade.thirdparty.error.ThirdPartyException;
+import com.diligrp.etrade.thirdparty.utils.PurchaseOrderApiUtils;
+import com.diligrp.etrade.thirdparty.utils.ReceiptsOrderApiUtils;
+import com.diligrp.etrade.thirdparty.utils.ReceiptsRefundOrderApiUtils;
+import com.kingdee.bos.webapi.entity.IdentifyInfo;
+
+import java.math.BigDecimal;
+
+public enum BillType {
+
+    RECEIVABLES("AR_receivable") {
+        @Override
+        public <T extends BaseBillCo> void handle(T t, IdentifyInfo identifyInfo) throws Exception {
+            var util = new PurchaseOrderApiUtils(identifyInfo);
+            boolean purchaseOrder = util.getPurchaseOrder(t.getFBillTypeID().getFNUMBER(), t.getF_ZDB_Text1(), getAllAmountFor(t), t.getF_ZDB_Text667());
+            if (purchaseOrder) {
+                util.createOnePurchaseOrder(JsonUtils.toJsonString(t), this.value);
+            }
+        }
+    },
+    RECEIPTS("AR_RECEIVEBILL") {
+        @Override
+        public <T extends BaseBillCo> void handle(T t, IdentifyInfo identifyInfo) throws Exception {
+            var util = new ReceiptsOrderApiUtils(identifyInfo);
+            boolean purchaseOrder = util.getReceiptsOrder(t.getFBillTypeID().getFNUMBER(), t.getF_ZDB_Text1(), getAllAmountFor(t), t.getF_ZDB_Text667());
+            if (purchaseOrder) {
+                util.createOnePurchaseOrder(JsonUtils.toJsonString(t), this.value);
+            }
+        }
+    },
+    RECEIPT_AND_REFUND_FORM("AR_REFUNDBILL") {
+        @Override
+        public <T extends BaseBillCo> void handle(T t, IdentifyInfo identifyInfo) throws Exception {
+            var util = new ReceiptsRefundOrderApiUtils(identifyInfo);
+            boolean purchaseOrder = util.getReceiptsRefundOrder(t.getFBillTypeID().getFNUMBER(), t.getF_ZDB_Text1(), getAllAmountFor(t), t.getF_ZDB_Text667());
+            if (purchaseOrder) {
+                util.createOnePurchaseOrder(JsonUtils.toJsonString(t), this.value);
+            }
+        }
+    },
+    ;
+
+    public final String value;
+
+    BillType(String value) {
+        this.value = value;
+    }
+
+    public static BillType getBillType(String value) {
+        for (BillType type : BillType.values()) {
+            if (type.value.equals(value)) {
+                return type;
+            }
+        }
+        throw new ThirdPartyException("未实现的业务类型");
+    }
+
+    private static <T extends BaseBillCo> String getAllAmountFor(T e) {
+        var allAmountFor = BigDecimal.ZERO;
+        for (FEntityDetail f : e.getFEntityDetail()) {
+            BigDecimal single = f.getFPrice().multiply(f.getFPriceQty());
+            allAmountFor = allAmountFor.add(single);
+        }
+        return allAmountFor.toString();
+    }
+
+    public abstract <T extends BaseBillCo> void handle(T t, IdentifyInfo identifyInfo) throws Exception;
+}
@@ -22,6 +22,17 @@ public class DepartmentApiUtils extends BaseApiUtils {
         super(identifyInfo);
     }
+    /**
+     * {
+     * "FormId": "BD_Department",
+     * "FieldKeys": "FDEPTID",
+     * "FilterString": "FNumber = '001'"
+     * }
+     *
+     * @param json
+     * @return
+     * @throws Exception
+     */
     public String createDepartment(String json) throws Exception {
         return save(createSendMessageWithAudit(json));
     }
 package com.diligrp.etrade.thirdparty.utils;
+import com.diligrp.etrade.core.util.JsonUtils;
+import com.diligrp.etrade.thirdparty.domain.co.basic.ChargeItemCo;
+import com.diligrp.etrade.thirdparty.message.GeneralQueryMessage;
 import com.kingdee.bos.webapi.entity.IdentifyInfo;
 import com.kingdee.bos.webapi.entity.OperateParam;
 import com.kingdee.bos.webapi.entity.OperatorResult;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import java.util.List;
+
 /**
  * 费用 API 实用程序
  *
@@ -22,6 +27,25 @@ public class FeeApiUtils extends BaseApiUtils {
         super(identifyInfo);
     }
+    public ChargeItemCo getFee(String fNumber,String groupNumber) throws Exception {
+        var filterString = "FNumber = '%s' and FGroup.FNumber = '%s' ".formatted(fNumber,groupNumber);
+        var query = new GeneralQueryMessage();
+        query.setFormId("BD_Expense");
+        query.setFieldKeys("FEXPID,FNumber");
+        query.setFilterString(filterString);
+        List<List<Object>> res = api.executeBillQuery(JsonUtils.toJsonString(query));
+        log.info("费用项接口查回数据,json数据：{}", res);
+        if (res.isEmpty()){
+            return null;
+        }
+        var feeId = String.valueOf(res.get(0).get(0));
+        var FNumber = String.valueOf(res.get(0).get(1));
+        ChargeItemCo chargeItemCo = new ChargeItemCo();
+        chargeItemCo.setFEXPID(Long.valueOf(feeId));
+        chargeItemCo.setFNumber(FNumber);
+        return chargeItemCo;
+    }
+
     public String createFee(String json) throws Exception {
         return save(createSendMessageWithAudit(json));
@@ -33,7 +33,7 @@ public class PurchaseOrderApiUtils extends BaseApiUtils {
         query.setFieldKeys("FID");
         query.setFormId("AR_receivable");
         List<List<Object>> res = api.executeBillQuery(JsonUtils.toJsonString(query));
-        log.info("采购订单接口查回数据,json数据：{}", res);
+        log.info("应收单接口查回数据,json数据：{}", res);
         return res.isEmpty();
     }
@@ -43,9 +43,9 @@ public class PurchaseOrderApiUtils extends BaseApiUtils {
     }
     private void save(String json, String formId) throws Exception {
-        log.info("采购订单接口json数据：{}", json);
+        log.info("应收单接口json数据：{}", json);
         String res = api.save(formId, json);
         var repoRet = getRepoRet(res);
-        log.info("采购订单接口已完成,{}", repoRet);
+        log.info("应收单接口已完成,{}", repoRet);
     }
 }
+package com.diligrp.etrade.thirdparty.utils;
+
+import com.diligrp.etrade.core.util.JsonUtils;
+import com.diligrp.etrade.thirdparty.message.GeneralQueryMessage;
+import com.kingdee.bos.webapi.entity.IdentifyInfo;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.List;
+
+/**
+ * 收款单 API 实用程序
+ *
+ * @author zhangmeiyang
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-15 11:09
+ * @Version: todo
+ * @date 2024/10/23
+ */
+public class ReceiptsOrderApiUtils extends BaseApiUtils {
+    private static final Logger log = LoggerFactory.getLogger(ReceiptsOrderApiUtils.class);
+
+    public ReceiptsOrderApiUtils(IdentifyInfo identifyInfo) {
+        super(identifyInfo);
+    }
+
+    public boolean getReceiptsOrder(String FBillTypeID, String F_ZDB_text1,String allAmountFor,String F_ZDB_Text667 ) throws Exception {
+        String FilterString = """
+                FBillTypeID.FNumber = '%s' and F_ZDB_text1 ='%s' and FALLAMOUNTFOR = '%s' and F_ZDB_Text667 = '%s'
+                """.formatted(FBillTypeID, F_ZDB_text1,allAmountFor,F_ZDB_Text667);
+        var query = new GeneralQueryMessage();
+        query.setFilterString(FilterString);
+        query.setFieldKeys("FID");
+        query.setFormId("AR_RECEIVEBILL");
+        List<List<Object>> res = api.executeBillQuery(JsonUtils.toJsonString(query));
+        log.info("收款单接口查回数据,json数据：{}", res);
+        return res.isEmpty();
+    }
+
+
+    public void createOnePurchaseOrder(String json, String formId) throws Exception {
+        save(createSendMessageWithAudit(json), formId);
+    }
+
+    private void save(String json, String formId) throws Exception {
+        log.info("收款单接口json数据：{}", json);
+        String res = api.save(formId, json);
+        var repoRet = getRepoRet(res);
+        log.info("收款单接口已完成,{}", repoRet);
+    }
+}
+package com.diligrp.etrade.thirdparty.utils;
+
+import com.diligrp.etrade.core.util.JsonUtils;
+import com.diligrp.etrade.thirdparty.message.GeneralQueryMessage;
+import com.kingdee.bos.webapi.entity.IdentifyInfo;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.List;
+
+/**
+ * 收款单 API 实用程序
+ *
+ * @author zhangmeiyang
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-15 11:09
+ * @Version: todo
+ * @date 2024/10/23
+ */
+public class ReceiptsRefundOrderApiUtils extends BaseApiUtils {
+    private static final Logger log = LoggerFactory.getLogger(ReceiptsRefundOrderApiUtils.class);
+
+    public ReceiptsRefundOrderApiUtils(IdentifyInfo identifyInfo) {
+        super(identifyInfo);
+    }
+
+    public boolean getReceiptsRefundOrder(String FBillTypeID, String F_ZDB_text1,String allAmountFor,String F_ZDB_Text667 ) throws Exception {
+        String FilterString = """
+                FBillTypeID.FNumber = '%s' and F_ZDB_text1 ='%s' and FALLAMOUNTFOR = '%s' and F_ZDB_Text667 = '%s'
+                """.formatted(FBillTypeID, F_ZDB_text1,allAmountFor,F_ZDB_Text667);
+        var query = new GeneralQueryMessage();
+        query.setFilterString(FilterString);
+        query.setFieldKeys("FID");
+        query.setFormId("AR_REFUNDBILL");
+        List<List<Object>> res = api.executeBillQuery(JsonUtils.toJsonString(query));
+        log.info("收款退款单接口查回数据,json数据：{}", res);
+        return res.isEmpty();
+    }
+
+
+    public void createOnePurchaseOrder(String json, String formId) throws Exception {
+        save(createSendMessageWithAudit(json), formId);
+    }
+
+    private void save(String json, String formId) throws Exception {
+        log.info("收款收款退款单接口json数据：{}", json);
+        String res = api.save(formId, json);
+        var repoRet = getRepoRet(res);
+        log.info("收款收款退款单接口已完成,{}", repoRet);
+    }
+}
@@ -31,4 +31,12 @@
             , #{mapping.thirdPartyDataId}
             )
     </insert>
+    <delete id="deleteTheMappingData">
+        DELETE FROM `zr_etrade`.`tp_mapping_data`
+        WHERE 1=1
+        AND market_id = #{mapping.marketId}
+        AND system_code = #{mapping.systemCode}
+        AND business = #{mapping.business}
+        AND system_data_id = #{mapping.systemDataId}
+    </delete>
 </mapper>