金蝶收款退款单对接

zhangmeiyang
1 parent 14b6e83e
Showing 37 changed files with 1018 additions and 304 deletions
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/component/BillTrans.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/component/RecTrans.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/component/RefundTrans.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/component/TransferComponent.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/demarcate/AbstractBaseBillHandler.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/demarcate/AbstractBillHandler.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/demarcate/AbstractRecHandler.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/demarcate/AbstractRefundHandler.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/domain/co/rec/BaseRecCo.java → etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/domain/co/business/rec/BaseRecCo.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/domain/co/business/refund/BaseRefundCo.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/domain/co/business/refund/RefundBillCo.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/domain/model/FRECTUNIT.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/domain/model/FREFUNDBILLENTRY.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/domain/model/FSETTLECUR.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/demarcate/AbstractReceiver.java → etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/exec/AbstractReceiver.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/business/refund/PayoutsRefundHandler.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/type/BusinessEnum.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/utils/ReceiptsRefundOrderApiUtils.java
 package com.diligrp.etrade.thirdparty.component;
 import com.diligrp.etrade.core.Constants;
-import com.diligrp.etrade.thirdparty.domain.co.business.BaseBillCo;
+import com.diligrp.etrade.thirdparty.domain.co.business.bill.BaseBillCo;
 import com.diligrp.etrade.thirdparty.domain.model.*;
 import com.diligrp.etrade.thirdparty.type.ProcessType;
 import jakarta.annotation.Resource;
@@ -23,7 +23,11 @@ public class BillTrans {
     @Resource
     private TransferComponent transferComponent;
-
+    /**
+     * 交易费项目
+     *
+     * @param fEntityDetail F 实体详细信息
+     */
     public void transFeeItem(List<FEntityDetail> fEntityDetail) {
         fEntityDetail.forEach(e -> {
             if (!ObjectUtils.isEmpty(e.getFCOSTID())) {
@@ -49,6 +53,13 @@ public class BillTrans {
         afterSet(co, marketId, systemCode);
     }
+    /**
+     * 设置后
+     *
+     * @param co         CO
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     */
     private void afterSet(BaseBillCo co, Long marketId, String systemCode) {
         transferComponent.transPayOrgId(co.getFPAYORGID(), marketId, systemCode);
         transferComponent.transSaleOrgId(co.getFSALEORGID(), marketId, systemCode);
@@ -57,6 +68,11 @@ public class BillTrans {
         transferComponent.transMainBookCurrency(co.getFMAINBOOKSTDCURRID(), marketId, systemCode);
     }
+    /**
+     * 设置部门
+     *
+     * @param co CO
+     */
     private void setDept(BaseBillCo co) {
         if (!ObjectUtils.isEmpty(co.getFSALEDEPTID())) {
             var fNumber = transferComponent.transDepId(co.getFSALEDEPTID());
@@ -71,6 +87,11 @@ public class BillTrans {
         }
     }
+    /**
+     * 设置传输 ID
+     *
+     * @param co CO
+     */
     private void setTransferId(BaseBillCo co) {
         if (!ObjectUtils.isEmpty(co.getFTRANSFERID())) {
             transferComponent.transTransferId(co.getFTRANSFERID());
@@ -79,6 +100,11 @@ public class BillTrans {
         }
     }
+    /**
+     * 设置客户 ID
+     *
+     * @param co CO
+     */
     private void setCustomerId(BaseBillCo co) {
         if (!ObjectUtils.isEmpty(co.getFCUSTOMERID())) {
             transferComponent.transCustomer(co.getFCUSTOMERID());
@@ -87,6 +113,11 @@ public class BillTrans {
         }
     }
+    /**
+     * 设置订单 ID
+     *
+     * @param co CO
+     */
     private void setOrderId(BaseBillCo co) {
         if (!ObjectUtils.isEmpty(co.getFORDERID())) {
             transferComponent.transOrderId(co.getFORDERID());
@@ -95,6 +126,11 @@ public class BillTrans {
         }
     }
+    /**
+     * 设置 Settle Type
+     *
+     * @param co CO
+     */
     private void setSettleType(BaseBillCo co) {
         if (!ObjectUtils.isEmpty(co.getFSettleTypeID())) {
             co.getFEntityDetail().forEach(e -> e.setFSettleTypeID(co.getFSettleTypeID()));
@@ -104,6 +140,11 @@ public class BillTrans {
         }
     }
+    /**
+     * Init Bill 公司
+     *
+     * @param co CO
+     */
     private void initBillCo(BaseBillCo co) {
         co.setF_ZDB_Text1(ObjectUtils.isEmpty(co.getF_ZDB_Text()) ? null : co.getF_ZDB_Text());
         co.setF_PZCW_Text(null);
 package com.diligrp.etrade.thirdparty.component;
 import com.diligrp.etrade.core.Constants;
-import com.diligrp.etrade.thirdparty.domain.co.rec.BaseRecCo;
+import com.diligrp.etrade.thirdparty.domain.co.business.rec.BaseRecCo;
 import com.diligrp.etrade.thirdparty.domain.model.*;
 import jakarta.annotation.Resource;
 import org.springframework.stereotype.Component;
@@ -9,6 +9,7 @@ import org.springframework.util.ObjectUtils;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
+import java.util.List;
 /**
  * @Author: zhangmeiyang
@@ -21,6 +22,23 @@ public class RecTrans {
     @Resource
     private TransferComponent transferComponent;
+    private static final String CONTACT_TYPE = "BD_Customer";
+
+
+    /**
+     * 交易费项目
+     *
+     * @param freceivebillentry fReceiveBillEntry
+     */
+    public void transFeeItem(List<FRECEIVEBILLENTRY> freceivebillentry) {
+        freceivebillentry.forEach(e -> {
+            if (!ObjectUtils.isEmpty(e.getFCOSTID())) {
+                transferComponent.transFCOSTID(e.getFCOSTID());
+            }
+        });
+    }
+
+
     /**
      * 转换数据recCo
      *
@@ -36,6 +54,13 @@ public class RecTrans {
         afterSet(co, marketId, systemCode);
     }
+    /**
+     * 设置后
+     *
+     * @param co         CO
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     */
     private void afterSet(BaseRecCo co, Long marketId, String systemCode) {
         transferComponent.transPayOrgId(co.getFPAYORGID(), marketId, systemCode);
         transferComponent.transSaleOrgId(co.getFSALEORGID(), marketId, systemCode);
@@ -44,6 +69,11 @@ public class RecTrans {
         transferComponent.transSettleMainBookCurrency(co.getFSETTLEMAINBOOKID(), marketId, systemCode);
     }
+    /**
+     * 设置部门
+     *
+     * @param co CO
+     */
     private void setDept(BaseRecCo co) {
         if (!ObjectUtils.isEmpty(co.getFSALEDEPTID())) {
             var fNumber = transferComponent.transDepId(co.getFSALEDEPTID());
@@ -58,7 +88,13 @@ public class RecTrans {
         }
     }
+    /**
+     * 设置支付单位
+     *
+     * @param co CO
+     */
     private void setPayUnit(BaseRecCo co) {
+        co.setFPAYUNITTYPE(CONTACT_TYPE);
         if (!ObjectUtils.isEmpty(co.getFPAYUNIT())) {
             transferComponent.transFPAYUNIT(co.getFPAYUNIT());
         } else {
@@ -66,7 +102,13 @@ public class RecTrans {
         }
     }
+    /**
+     * 设置触点单位
+     *
+     * @param co CO
+     */
     private void setContactUnit(BaseRecCo co) {
+        co.setFCONTACTUNITTYPE(CONTACT_TYPE);
         if (!ObjectUtils.isEmpty(co.getFCONTACTUNIT())) {
             transferComponent.transFCONTACTUNIT(co.getFCONTACTUNIT());
         } else {
@@ -74,6 +116,11 @@ public class RecTrans {
         }
     }
+    /**
+     * Init Rec 公司
+     *
+     * @param co CO
+     */
     private void initRecCo(BaseRecCo co) {
         co.setFDATE(LocalDateTime.now().format(DateTimeFormatter.ofPattern(Constants.DATE_TIME_FORMAT)));
         co.setFCURRENCYID(new FCURRENCYID());
+package com.diligrp.etrade.thirdparty.component;
+
+import com.diligrp.etrade.core.Constants;
+import com.diligrp.etrade.thirdparty.domain.co.business.refund.BaseRefundCo;
+import com.diligrp.etrade.thirdparty.domain.model.*;
+import jakarta.annotation.Resource;
+import org.springframework.stereotype.Component;
+import org.springframework.util.ObjectUtils;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.List;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-11-28 09:42
+ * @Version: todo
+ */
+@Component
+public class RefundTrans {
+
+    private static final String CONTACT_TYPE = "BD_Customer";
+    @Resource
+    private TransferComponent transferComponent;
+
+    public void transFeeItem(List<FREFUNDBILLENTRY> frefundbillentry) {
+        frefundbillentry.forEach(e -> {
+            if (!ObjectUtils.isEmpty(e.getFCOSTID())) {
+                transferComponent.transFCOSTID(e.getFCOSTID());
+            }
+        });
+    }
+
+
+    public void transRefundCo(BaseRefundCo co, Long marketId, String systemCode) {
+        initRefundCo(co);
+        setDept(co);
+        setContactUnit(co);
+        setRecUnit(co);
+        afterSet(co, marketId, systemCode);
+    }
+
+    private void initRefundCo(BaseRefundCo co) {
+        co.setFDATE(LocalDateTime.now().format(DateTimeFormatter.ofPattern(Constants.DATE_TIME_FORMAT)));
+        co.setFCURRENCYID(new FCURRENCYID());
+        co.setFPAYORGID(new FPAYORGID());
+        co.setFSETTLECUR(new FSETTLECUR());
+    }
+
+    /**
+     * 设置部门
+     *
+     * @param co CO
+     */
+    private void setDept(BaseRefundCo co) {
+        if (!ObjectUtils.isEmpty(co.getFSALEDEPTID())) {
+            var fNumber = transferComponent.transDepId(co.getFSALEDEPTID());
+            if (!ObjectUtils.isEmpty(fNumber)) {
+                FCOSTDEPARTMENTID fCOSTDEPARTMENTID = new FCOSTDEPARTMENTID();
+                fCOSTDEPARTMENTID.setFNUMBER(fNumber);
+                co.getFREFUNDBILLENTRY().forEach(e -> e.setFCOSTDEPARTMENTID(fCOSTDEPARTMENTID));
+            }
+        } else {
+            co.setFSALEDEPTID(new FSALEDEPTID());
+            co.getFREFUNDBILLENTRY().forEach(e -> e.setFCOSTDEPARTMENTID(new FCOSTDEPARTMENTID()));
+        }
+    }
+
+    /**
+     * 设置触点单位
+     *
+     * @param co CO
+     */
+    private void setContactUnit(BaseRefundCo co) {
+        co.setFCONTACTUNITTYPE(CONTACT_TYPE);
+        if (!ObjectUtils.isEmpty(co.getFCONTACTUNIT())) {
+            transferComponent.transFCONTACTUNIT(co.getFCONTACTUNIT());
+        } else {
+            co.setFCONTACTUNIT(new FCONTACTUNIT());
+        }
+    }
+
+    /**
+     * 设置支付单位
+     *
+     * @param co CO
+     */
+    private void setRecUnit(BaseRefundCo co) {
+        co.setFRECTUNITTYPE(CONTACT_TYPE);
+        if (!ObjectUtils.isEmpty(co.getFRECTUNIT())) {
+            transferComponent.transFRECTUNIT(co.getFRECTUNIT());
+        } else {
+            co.setFRECTUNIT(new FRECTUNIT());
+        }
+    }
+
+    /**
+     * 设置后
+     *
+     * @param co         CO
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     */
+    private void afterSet(BaseRefundCo co, Long marketId, String systemCode) {
+        transferComponent.transPayOrgId(co.getFPAYORGID(), marketId, systemCode);
+        transferComponent.transSaleOrgId(co.getFSALEORGID(), marketId, systemCode);
+        transferComponent.transSettleOrgId(co.getFSETTLEORGID(), marketId, systemCode);
+        transferComponent.transCurrency(co.getFCURRENCYID(), marketId, systemCode);
+        transferComponent.transSettleCur(co.getFSETTLECUR(), marketId, systemCode);
+    }
+}
@@ -50,6 +50,17 @@ public class TransferComponent {
     /**
      * 交易货币
      *
+     * @param fsettlecur fsettlecur
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     */
+    public void transSettleCur(FSETTLECUR fsettlecur, Long marketId, String systemCode) {
+        fsettlecur.setFNUMBER(transMapper.getBaseConfig(systemCode, marketId).getCurrency());
+    }
+
+    /**
+     * 交易货币
+     *
      * @param marketId   市场 ID
      * @param systemCode 系统代码
      * @param fGroup     F 组
@@ -81,7 +92,7 @@ public class TransferComponent {
     }
     /**
-     * 跨性别客户
+     * 转换客户
      *
      * @param fcustomerid fcustomerid
      */
@@ -93,7 +104,7 @@ public class TransferComponent {
     }
     /**
-     * 跨性别客户
+     * 转换客户
      *
      * @param fcontactunit fcontactunit
      */
@@ -105,7 +116,7 @@ public class TransferComponent {
     }
     /**
-     * 跨性别客户
+     * 转换客户
      *
      * @param fpayunit fpayunit
      */
@@ -117,6 +128,18 @@ public class TransferComponent {
     }
     /**
+     * 转换客户
+     *
+     * @param frectunit frect单位
+     */
+    public void transFRECTUNIT(FRECTUNIT frectunit) {
+        if (ObjectUtils.isEmpty(frectunit.getFNumber())) {
+            return;
+        }
+        frectunit.setFNumber(transMapper.getCustomer(Long.valueOf(frectunit.getFNumber())).getCode());
+    }
+
+    /**
      * 交易订单 ID
      *
      * @param forderid forderid
+package com.diligrp.etrade.thirdparty.demarcate;
+
+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.mapper.TransMapper;
+import com.diligrp.etrade.thirdparty.type.BasicEnum;
+import com.diligrp.etrade.thirdparty.type.DynamicType;
+import com.diligrp.etrade.thirdparty.type.SelectType;
+import com.diligrp.etrade.thirdparty.type.SyncType;
+import com.kingdee.bos.webapi.entity.IdentifyInfo;
+import jakarta.annotation.Resource;
+import org.springframework.util.ObjectUtils;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-11-28 09:18
+ * @Version: todo
+ */
+public abstract class AbstractBaseBillHandler {
+
+    @Resource
+    protected TransMapper transMapper;
+
+    /**
+     * 获取动态数据
+     *
+     * @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 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);
+        Map<String, List<BusinessDetailDto>> map = new HashMap<>();
+        if (!ObjectUtils.isEmpty(dynamicParam)) {
+            dynamicParam.forEach(e -> map.computeIfAbsent(e.getCode(), k -> new ArrayList<>()).add(e));
+        }
+        return map;
+    }
+
+
+    /**
+     * 是否同步
+     *
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     * @return boolean
+     */
+    protected boolean isSync(Long marketId, String systemCode, DynamicType dynamicType) {
+        BusinessDto businessConfig = transMapper.getBusinessConfig(systemCode, marketId, dynamicType.code);
+        if (ObjectUtils.isEmpty(businessConfig)) {
+            return false;
+        }
+        return ObjectUtils.nullSafeEquals(businessConfig.getSyncType(), SyncType.SYNC.code);
+    }
+
+    /**
+     * 获取文档类型
+     *
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     * @param billTypeId 账单类型 ID
+     * @return {@link String}
+     */
+    protected 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();
+    }
+
+    /**
+     * 获取身份信息
+     *
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     * @return {@link IdentifyInfo }
+     */
+    protected 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;
+    }
+
+}
@@ -2,21 +2,18 @@ package com.diligrp.etrade.thirdparty.demarcate;
 import com.diligrp.etrade.core.util.JsonUtils;
 import com.diligrp.etrade.thirdparty.component.BillTrans;
-import com.diligrp.etrade.thirdparty.domain.co.business.BaseBillCo;
+import com.diligrp.etrade.thirdparty.domain.co.business.bill.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.type.BasicEnum;
+import com.diligrp.etrade.thirdparty.type.BillType;
+import com.diligrp.etrade.thirdparty.type.DynamicType;
 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;
 import java.util.Map;
@@ -28,13 +25,10 @@ import java.util.stream.Collectors;
  * @author zhangmeiyang
  * @date 2024/09/26
  */
-public abstract class AbstractBillHandler<T extends BaseBillCo> implements Handler {
+public abstract class AbstractBillHandler<T extends BaseBillCo> extends AbstractBaseBillHandler implements Handler {
     @Resource
-    protected BillTrans trans;
-
-    @Resource
-    protected TransMapper transMapper;
+    protected BillTrans billTrans;
     protected static final Map<String, TransferFunctionSingle<BaseBillCo>> TRANSFER_FUNCTION_SINGLE_MAP = new HashMap<>();
     protected static final Map<String, TransferFunctionMulti<BaseBillCo>> TRANSFER_FUNCTION_MULTI_MAP = new HashMap<>();
@@ -53,29 +47,6 @@ public abstract class AbstractBillHandler&lt;T extends BaseBillCo&gt; implements Handl
     }
     /**
-     * 获取动态数据
-     *
-     * @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 t    t
@@ -93,7 +64,7 @@ public abstract class AbstractBillHandler&lt;T extends BaseBillCo&gt; implements Handl
      */
     protected static <T extends BaseBillCo> void transferDynamicDept(T t, BusinessDetailDto data) {
         t.getFSALEDEPTID().setFNumber(data.getItemValue());
-        t.getFEntityDetail().forEach(e-> e.getFCOSTDEPARTMENTID().setFNUMBER(data.getItemValue()));
+        t.getFEntityDetail().forEach(e -> e.getFCOSTDEPARTMENTID().setFNUMBER(data.getItemValue()));
     }
     /**
@@ -163,39 +134,6 @@ public abstract class AbstractBillHandler&lt;T extends BaseBillCo&gt; implements Handl
     }
     /**
-     * 是否同步
-     *
-     * @param marketId   市场 ID
-     * @param systemCode 系统代码
-     * @return boolean
-     */
-    protected boolean isSync(Long marketId, String systemCode, DynamicType dynamicType) {
-        BusinessDto businessConfig = transMapper.getBusinessConfig(systemCode, marketId, dynamicType.code);
-        if (ObjectUtils.isEmpty(businessConfig)) {
-            return false;
-        }
-        return ObjectUtils.nullSafeEquals(businessConfig.getSyncType(), SyncType.SYNC.code);
-    }
-
-    /**
-     * 获取动态数据
-     *
-     * @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);
-        Map<String, List<BusinessDetailDto>> map = new HashMap<>();
-        if (!ObjectUtils.isEmpty(dynamicParam)) {
-            dynamicParam.forEach(e -> map.computeIfAbsent(e.getCode(), k -> new ArrayList<>()).add(e));
-        }
-        return map;
-    }
-
-    /**
      * 有效数据同步
      *
      * @param ts         茨
@@ -204,7 +142,11 @@ public abstract class AbstractBillHandler&lt;T extends BaseBillCo&gt; implements Handl
      * @return {@link List}<{@link T}>
      */
     protected <T extends BaseBillCo> List<T> validDataSync(List<T> ts, Long marketId, String systemCode) {
-        return ts.stream().filter(t -> isSync(marketId, systemCode, DynamicType.fromCode(t.getSystemDynamicCode()))).collect(Collectors.toList());
+        return ts.stream()
+                .filter(
+                        t -> isSync(marketId, systemCode, DynamicType.fromCode(t.getSystemDynamicCode())
+                        )
+                ).collect(Collectors.toList());
     }
     /**
@@ -217,25 +159,20 @@ public abstract class AbstractBillHandler&lt;T extends BaseBillCo&gt; implements Handl
     protected void transferDataListWithFeeItem(List<T> ts, Long marketId, String systemCode) {
         ts.forEach(e -> {
             DynamicType dynamicType = DynamicType.fromCode(e.getSystemDynamicCode());
-            transfer(e, marketId, systemCode);
-            transferFeeItem(e);
-            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));
+            billTrans.transBillCo(e, marketId, systemCode);
+            billTrans.transFeeItem(e.getFEntityDetail());
+            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
-     * @param marketId   市场 ID
-     * @param systemCode 系统代码
-     */
-    protected void transfer(T t, Long marketId, String systemCode) {
-        trans.transBillCo(t, marketId, systemCode);
-    }
-
-    /**
      * 传输数据列表
      *
      * @param ts         茨
@@ -245,9 +182,15 @@ public abstract class AbstractBillHandler&lt;T extends BaseBillCo&gt; implements Handl
     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));
+            billTrans.transBillCo(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)
+                    );
         });
     }
@@ -280,48 +223,4 @@ public abstract class AbstractBillHandler&lt;T extends BaseBillCo&gt; implements Handl
             }
         }
     }
-
-
-    /**
-     * 获取文档类型
-     *
-     * @param marketId   市场 ID
-     * @param systemCode 系统代码
-     * @param billTypeId 账单类型 ID
-     * @return {@link String}
-     */
-    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();
-    }
-
-    /**
-     * 转账手续费项目
-     *
-     * @param t t
-     */
-    protected void transferFeeItem(T t) {
-        trans.transFeeItem(t.getFEntityDetail());
-    }
-
-    /**
-     * 传递函数 Single
-     *
-     * @author zhangmeiyang
-     * @date 2024/11/20
-     */
-
-
-    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;
-    }
-
-
 }
@@ -2,22 +2,16 @@ package com.diligrp.etrade.thirdparty.demarcate;
 import com.diligrp.etrade.core.util.JsonUtils;
 import com.diligrp.etrade.thirdparty.component.RecTrans;
-import com.diligrp.etrade.thirdparty.domain.co.business.BaseBillCo;
-import com.diligrp.etrade.thirdparty.domain.co.rec.BaseRecCo;
+import com.diligrp.etrade.thirdparty.domain.co.business.rec.BaseRecCo;
 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.FRECEIVEBILLENTRY;
 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.type.BasicEnum;
+import com.diligrp.etrade.thirdparty.type.BillType;
+import com.diligrp.etrade.thirdparty.type.DynamicType;
 import com.diligrp.etrade.thirdparty.utils.ReceiptsOrderApiUtils;
-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;
 import java.util.Map;
@@ -28,7 +22,7 @@ import java.util.stream.Collectors;
  * @CreateTime: 2024-11-25 12:53
  * @Version: todo
  */
-public abstract class AbstractRecHandler<T extends BaseRecCo> implements Handler {
+public abstract class AbstractRecHandler<T extends BaseRecCo> extends AbstractBaseBillHandler implements Handler {
     protected static final Map<String, TransferFunctionSingle<BaseRecCo>> TRANSFER_FUNCTION_SINGLE_MAP = new HashMap<>();
     protected static final Map<String, TransferFunctionMulti<BaseRecCo>> TRANSFER_FUNCTION_MULTI_MAP = new HashMap<>();
@@ -48,8 +42,7 @@ public abstract class AbstractRecHandler&lt;T extends BaseRecCo&gt; implements Handler
     @Resource
     protected RecTrans recTrans;
-    @Resource
-    protected TransMapper transMapper;
+
     /**
      * 转换动态配置部门
@@ -59,7 +52,7 @@ public abstract class AbstractRecHandler&lt;T extends BaseRecCo&gt; implements Handler
      */
     protected static <T extends BaseRecCo> void transferDynamicDept(T t, BusinessDetailDto data) {
         t.getFSALEDEPTID().setFNumber(data.getItemValue());
-        t.getFRECEIVEBILLENTRY().forEach(e-> e.getFCOSTDEPARTMENTID().setFNUMBER(data.getItemValue()));
+        t.getFRECEIVEBILLENTRY().forEach(e -> e.getFCOSTDEPARTMENTID().setFNUMBER(data.getItemValue()));
     }
     /**
@@ -126,69 +119,11 @@ public abstract class AbstractRecHandler&lt;T extends BaseRecCo&gt; implements Handler
         t.setFixedBusinessType(data.getItemValue());
     }
-    private static <T extends BaseRecCo> String getAllAmountFor(T e) {
-        var allAmountFor = BigDecimal.ZERO;
-        for (FRECEIVEBILLENTRY f : e.getFRECEIVEBILLENTRY()) {
-            BigDecimal single = f.getFRECTOTALAMOUNTFOR().multiply(f.getFRECTOTALAMOUNTFOR());
-            allAmountFor = allAmountFor.add(single);
-        }
-        return allAmountFor.toString();
-    }
-
-    /**
-     * 获取动态数据
-     *
-     * @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 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);
-        Map<String, List<BusinessDetailDto>> map = new HashMap<>();
-        if (!ObjectUtils.isEmpty(dynamicParam)) {
-            dynamicParam.forEach(e -> map.computeIfAbsent(e.getCode(), k -> new ArrayList<>()).add(e));
-        }
-        return map;
-    }
-
-    /**
-     * 是否同步
-     *
-     * @param marketId   市场 ID
-     * @param systemCode 系统代码
-     * @return boolean
-     */
-    protected boolean isSync(Long marketId, String systemCode, DynamicType dynamicType) {
-        BusinessDto businessConfig = transMapper.getBusinessConfig(systemCode, marketId, dynamicType.code);
-        if (ObjectUtils.isEmpty(businessConfig)) {
-            return false;
-        }
-        return ObjectUtils.nullSafeEquals(businessConfig.getSyncType(), SyncType.SYNC.code);
+    protected static <T extends BaseRecCo> void setUpThePrepayment(List<T> ts) {
+        ts.forEach(e-> e.getFRECEIVEBILLENTRY().forEach(f-> f.getFPURPOSEID().setFNumber("SFKYT02_SYS")));
     }
     /**
@@ -199,19 +134,12 @@ public abstract class AbstractRecHandler&lt;T extends BaseRecCo&gt; implements Handler
      * @param systemCode 系统代码
      * @return {@link List}<{@link T}>
      */
-    protected <T extends BaseBillCo> List<T> validDataSync(List<T> ts, Long marketId, String systemCode) {
-        return ts.stream().filter(t -> isSync(marketId, systemCode, DynamicType.fromCode(t.getSystemDynamicCode()))).collect(Collectors.toList());
-    }
-
-    /**
-     * 固定转换
-     *
-     * @param t          t
-     * @param marketId   市场 ID
-     * @param systemCode 系统代码
-     */
-    protected void transfer(T t, Long marketId, String systemCode) {
-        recTrans.transRecCo(t, marketId, systemCode);
+    protected <T extends BaseRecCo> List<T> validDataSync(List<T> ts, Long marketId, String systemCode) {
+        return ts.stream()
+                .filter(
+                        t -> isSync(marketId, systemCode, DynamicType.fromCode(t.getSystemDynamicCode())
+                        )
+                ).collect(Collectors.toList());
     }
     /**
@@ -221,12 +149,19 @@ public abstract class AbstractRecHandler&lt;T extends BaseRecCo&gt; implements Handler
      * @param marketId   市场 ID
      * @param systemCode 系统代码
      */
-    protected void transferDataListWithOutFeeItem(List<T> ts, Long marketId, String systemCode) {
+    protected void transferDataListWithFeeItem(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));
+            recTrans.transRecCo(e, marketId, systemCode);
+            recTrans.transFeeItem(e.getFRECEIVEBILLENTRY());
+            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)
+                    );
         });
     }
@@ -261,35 +196,24 @@ public abstract class AbstractRecHandler&lt;T extends BaseRecCo&gt; implements Handler
     }
     /**
-     * 获取文档类型
+     * 传输数据列表
      *
+     * @param ts         茨
      * @param marketId   市场 ID
      * @param systemCode 系统代码
-     * @param billTypeId 账单类型 ID
-     * @return {@link String}
      */
-    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
-     */
-
-
-    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;
+    protected void transferDataListWithOutFeeItem(List<T> ts, Long marketId, String systemCode) {
+        ts.forEach(e -> {
+            DynamicType dynamicType = DynamicType.fromCode(e.getSystemDynamicCode());
+            recTrans.transRecCo(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)
+                    );
+        });
     }
-
 }
+package com.diligrp.etrade.thirdparty.demarcate;
+
+import com.diligrp.etrade.core.util.JsonUtils;
+import com.diligrp.etrade.thirdparty.component.RefundTrans;
+import com.diligrp.etrade.thirdparty.domain.co.business.refund.BaseRefundCo;
+import com.diligrp.etrade.thirdparty.domain.dto.BusinessDetailDto;
+import com.diligrp.etrade.thirdparty.error.ThirdPartyException;
+import com.diligrp.etrade.thirdparty.type.BasicEnum;
+import com.diligrp.etrade.thirdparty.type.BillType;
+import com.diligrp.etrade.thirdparty.type.DynamicType;
+import com.diligrp.etrade.thirdparty.utils.ReceiptsOrderApiUtils;
+import jakarta.annotation.Resource;
+import org.springframework.util.ObjectUtils;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-11-28 09:30
+ * @Version: todo
+ */
+public abstract class AbstractRefundHandler<T extends BaseRefundCo> extends AbstractBaseBillHandler implements Handler {
+
+    protected static final Map<String, TransferFunctionSingle<BaseRefundCo>> TRANSFER_FUNCTION_SINGLE_MAP = new HashMap<>();
+    protected static final Map<String, TransferFunctionMulti<BaseRefundCo>> TRANSFER_FUNCTION_MULTI_MAP = new HashMap<>();
+    protected static final TransferFunctionSingle<BaseRefundCo> DEPT = AbstractRefundHandler::transferDynamicDept;
+    protected static final TransferFunctionSingle<BaseRefundCo> CUSTOMER = AbstractRefundHandler::transferDynamicCustomer;
+    protected static final TransferFunctionSingle<BaseRefundCo> SETTLE_TYPE = AbstractRefundHandler::transferDynamicSettleType;
+    protected static final TransferFunctionSingle<BaseRefundCo> BUSINESS_TYPE = AbstractRefundHandler::transferDynamicBusinessType;
+    protected static final TransferFunctionMulti<BaseRefundCo> CHARGE_ITEM = AbstractRefundHandler::transferDynamicChargeItem;
+
+    static {
+        TRANSFER_FUNCTION_SINGLE_MAP.put(BasicEnum.DEPARTMENT_TO_LOWER.code, DEPT);
+        TRANSFER_FUNCTION_SINGLE_MAP.put(BasicEnum.CUSTOMER_TO_LOWER.code, CUSTOMER);
+        TRANSFER_FUNCTION_SINGLE_MAP.put(BasicEnum.FINANCIAL_CHANNEL_TYPE_TO_LOWER.code, SETTLE_TYPE);
+        TRANSFER_FUNCTION_SINGLE_MAP.put(BasicEnum.FINANCIAL_BUSINESS_TYPE_TO_LOWER.code, BUSINESS_TYPE);
+        TRANSFER_FUNCTION_MULTI_MAP.put(BasicEnum.CHARGE_ITEM_TO_LOWER.code, CHARGE_ITEM);
+    }
+
+    @Resource
+    protected RefundTrans refundTrans;
+
+    /**
+     * 转换动态配置部门
+     *
+     * @param t    t
+     * @param data 数据
+     */
+    protected static <T extends BaseRefundCo> void transferDynamicDept(T t, BusinessDetailDto data) {
+        t.getFSALEDEPTID().setFNumber(data.getItemValue());
+        t.getFREFUNDBILLENTRY().forEach(e-> e.getFCOSTDEPARTMENTID().setFNUMBER(data.getItemValue()));
+    }
+
+    /**
+     * Transfer Dynamic 客户
+     *
+     * @param t    t
+     * @param data 数据
+     */
+    protected static <T extends BaseRefundCo> void transferDynamicCustomer(T t, BusinessDetailDto data) {
+        if (!ObjectUtils.isEmpty(t.getFCONTACTUNIT())) {
+            t.getFCONTACTUNIT().setFNumber(data.getItemValue());
+        }
+        if (!ObjectUtils.isEmpty(t.getFRECTUNIT())) {
+            t.getFRECTUNIT().setFNumber(data.getItemValue());
+        }
+    }
+
+    /**
+     * 转移动态结算类型
+     *
+     * @param t    t
+     * @param data 数据
+     */
+    protected static <T extends BaseRefundCo> void transferDynamicSettleType(T t, BusinessDetailDto data) {
+        t.getFREFUNDBILLENTRY().forEach(e -> e.getFSETTLETYPEID().setFNumber(data.getItemValue()));
+    }
+
+    /**
+     * Transfer Dynamic Charge 项目
+     *
+     * @param data   数据
+     * @param entity 实体
+     */
+    protected static <T extends BaseRefundCo> void transferDynamicChargeItem(T entity, List<BusinessDetailDto> data) {
+        Map<String, String> relationMap = new HashMap<>();
+        Map<String, String> codeMap = new HashMap<>();
+        for (BusinessDetailDto dto : data) {
+            if (!ObjectUtils.isEmpty(dto.getItemRelationId())) {
+                relationMap.put(String.valueOf(dto.getItemRelationId()), dto.getItemValue());
+            }
+            if (!ObjectUtils.isEmpty(dto.getItemCode())) {
+                codeMap.put(dto.getItemCode(), dto.getItemValue());
+            }
+        }
+        entity.getFREFUNDBILLENTRY().forEach(e -> {
+            if (!ObjectUtils.isEmpty(e.getFCOSTID())) {
+                var costId = e.getFCOSTID().getFNUMBER();
+                if (relationMap.containsKey(costId)) {
+                    e.getFCOSTID().setFNUMBER(relationMap.get(costId));
+                } else if (codeMap.containsKey(costId)) {
+                    e.getFCOSTID().setFNUMBER(codeMap.get(costId));
+                }
+            }
+        });
+    }
+
+    /**
+     * Transfer Dynamic 业务类型
+     *
+     * @param t    t
+     * @param data 数据
+     */
+    protected static <T extends BaseRefundCo> void transferDynamicBusinessType(T t, BusinessDetailDto data) {
+        t.setFixedBusinessType(data.getItemValue());
+    }
+
+    /**
+     * 设置预付款
+     */
+    protected static <T extends BaseRefundCo> void setUpThePrepayment(List<T> ts) {
+        ts.forEach(e-> e.getFREFUNDBILLENTRY().forEach(f-> f.getFPURPOSEID().setFNumber("SFKYT02_SYS")));
+    }
+
+    /**
+     * 有效数据同步
+     *
+     * @param ts         茨
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     * @return {@link List}<{@link T}>
+     */
+    protected <T extends BaseRefundCo> List<T> validDataSync(List<T> ts, Long marketId, String systemCode) {
+        return ts.stream()
+                .filter(
+                        t -> isSync(marketId, systemCode, DynamicType.fromCode(t.getSystemDynamicCode())
+                        )
+                ).collect(Collectors.toList());
+    }
+
+    /**
+     * 传输数据列表
+     *
+     * @param ts         茨
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     */
+    protected void transferDataListWithFeeItem(List<T> ts, Long marketId, String systemCode) {
+        ts.forEach(e -> {
+            DynamicType dynamicType = DynamicType.fromCode(e.getSystemDynamicCode());
+            refundTrans.transRefundCo(e, marketId, systemCode);
+            refundTrans.transFeeItem(e.getFREFUNDBILLENTRY());
+            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
+     * @param systemCode 系统代码
+     */
+    protected void transferDataListWithOutFeeItem(List<T> ts, Long marketId, String systemCode) {
+        ts.forEach(e -> {
+            DynamicType dynamicType = DynamicType.fromCode(e.getSystemDynamicCode());
+            refundTrans.transRefundCo(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 marketId   市场 ID
+     * @param systemCode 系统代码
+     * @param ts         茨
+     * @throws Exception 例外
+     */
+    protected void sendPurchaseOrder(List<T> ts, Long marketId, String systemCode) throws Exception {
+        var identifyInfo = getIdentifyInfo(marketId, systemCode);
+        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);
+            }
+            var util = new ReceiptsOrderApiUtils(identifyInfo);
+            boolean purchaseOrder = util.getReceiptsOrder(e.getFBillTypeID().getFNUMBER(), e.getFREMARK());
+            if (purchaseOrder) {
+                util.createOnePurchaseOrder(JsonUtils.toJsonString(e), BillType.RECEIPTS.value);
+            }
+        }
+    }
+
+
+}
-package com.diligrp.etrade.thirdparty.domain.co.business;
+package com.diligrp.etrade.thirdparty.domain.co.business.bill;
 import com.diligrp.etrade.thirdparty.domain.model.*;
 import com.fasterxml.jackson.annotation.JsonProperty;
-package com.diligrp.etrade.thirdparty.domain.co.business;
+package com.diligrp.etrade.thirdparty.domain.co.business.bill;
 /**
  * @Author: zhangmeiyang
-package com.diligrp.etrade.thirdparty.domain.co.business;
+package com.diligrp.etrade.thirdparty.domain.co.business.bill;
 /**
  * @Author: zhangmeiyang
-package com.diligrp.etrade.thirdparty.domain.co.business;
+package com.diligrp.etrade.thirdparty.domain.co.business.bill;
 /**
  * @Author: zhangmeiyang
-package com.diligrp.etrade.thirdparty.domain.co.business;
+package com.diligrp.etrade.thirdparty.domain.co.business.bill;
 /**
  * @Author: zhangmeiyang
-package com.diligrp.etrade.thirdparty.domain.co.business;
+package com.diligrp.etrade.thirdparty.domain.co.business.bill;
 /**
  * @Author: zhangmeiyang
-package com.diligrp.etrade.thirdparty.domain.co.business;
+package com.diligrp.etrade.thirdparty.domain.co.business.bill;
 /**
  * @Author: zhangmeiyang
-package com.diligrp.etrade.thirdparty.domain.co.business;
+package com.diligrp.etrade.thirdparty.domain.co.business.bill;
 /**
  * @Author: zhangmeiyang
-package com.diligrp.etrade.thirdparty.domain.co.rec;
+package com.diligrp.etrade.thirdparty.domain.co.business.rec;
 import com.diligrp.etrade.thirdparty.domain.model.*;
 import com.fasterxml.jackson.annotation.JsonProperty;
-package com.diligrp.etrade.thirdparty.domain.co.rec;
+package com.diligrp.etrade.thirdparty.domain.co.business.rec;
 /**
  * @Author: zhangmeiyang
  * @CreateTime: 2024-11-25 09:35
  * @Version: todo
  */
-public class DepositAndWithdrawBillCo extends BaseRecCo {
+public class DepositBillCo extends BaseRecCo {
 }
+package com.diligrp.etrade.thirdparty.domain.co.business.refund;
+
+import com.diligrp.etrade.thirdparty.domain.model.*;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-11-28 09:11
+ * @Version: todo
+ */
+public class BaseRefundCo implements Serializable {
+    private String systemDynamicCode;
+    private String fixedBusinessType;
+    private String FREMARK;
+    private String FDATE;
+    private FSETTLEORGID FSETTLEORGID;
+    private FSALEORGID FSALEORGID;
+    private FBillTypeID FBillTypeID;
+    private FCURRENCYID FCURRENCYID;
+    private FSALEDEPTID FSALEDEPTID;
+    private FPAYORGID FPAYORGID;
+    private FSETTLECUR FSETTLECUR;
+    private String FRECTUNITTYPE;
+    private FRECTUNIT FRECTUNIT;
+    private String FCONTACTUNITTYPE;
+    private FCONTACTUNIT FCONTACTUNIT;
+    private List<FREFUNDBILLENTRY> FREFUNDBILLENTRY;
+
+    @JsonProperty("systemDynamicCode")
+    public String getSystemDynamicCode() {
+        return systemDynamicCode;
+    }
+
+    public void setSystemDynamicCode(String systemDynamicCode) {
+        this.systemDynamicCode = systemDynamicCode;
+    }
+
+    @JsonProperty("fixedBusinessType")
+    public String getFixedBusinessType() {
+        return fixedBusinessType;
+    }
+
+    public void setFixedBusinessType(String fixedBusinessType) {
+        this.fixedBusinessType = fixedBusinessType;
+    }
+    @JsonProperty("FREMARK")
+    public String getFREMARK() {
+        return FREMARK;
+    }
+
+    public void setFREMARK(String FREMARK) {
+        this.FREMARK = FREMARK;
+    }
+    @JsonProperty("FDATE")
+    public String getFDATE() {
+        return FDATE;
+    }
+
+    public void setFDATE(String FDATE) {
+        this.FDATE = FDATE;
+    }
+
+    @JsonProperty("FSETTLEORGID")
+    public FSETTLEORGID getFSETTLEORGID() {
+        return FSETTLEORGID;
+    }
+
+    public void setFSETTLEORGID(FSETTLEORGID FSETTLEORGID) {
+        this.FSETTLEORGID = FSETTLEORGID;
+    }
+
+    @JsonProperty("FSALEORGID")
+    public FSALEORGID getFSALEORGID() {
+        return FSALEORGID;
+    }
+
+    public void setFSALEORGID(FSALEORGID FSALEORGID) {
+        this.FSALEORGID = FSALEORGID;
+    }
+
+    @JsonProperty("FBillTypeID")
+    public FBillTypeID getFBillTypeID() {
+        return FBillTypeID;
+    }
+
+    public void setFBillTypeID(FBillTypeID FBillTypeID) {
+        this.FBillTypeID = FBillTypeID;
+    }
+
+    @JsonProperty("FCURRENCYID")
+    public FCURRENCYID getFCURRENCYID() {
+        return FCURRENCYID;
+    }
+
+    public void setFCURRENCYID(FCURRENCYID FCURRENCYID) {
+        this.FCURRENCYID = FCURRENCYID;
+    }
+
+    @JsonProperty("FSALEDEPTID")
+    public FSALEDEPTID getFSALEDEPTID() {
+        return FSALEDEPTID;
+    }
+
+    public void setFSALEDEPTID(FSALEDEPTID FSALEDEPTID) {
+        this.FSALEDEPTID = FSALEDEPTID;
+    }
+
+    @JsonProperty("FPAYORGID")
+    public FPAYORGID getFPAYORGID() {
+        return FPAYORGID;
+    }
+
+    public void setFPAYORGID(FPAYORGID FPAYORGID) {
+        this.FPAYORGID = FPAYORGID;
+    }
+
+    @JsonProperty("FSETTLECUR")
+    public FSETTLECUR getFSETTLECUR() {
+        return FSETTLECUR;
+    }
+
+    public void setFSETTLECUR(FSETTLECUR FSETTLECUR) {
+        this.FSETTLECUR = FSETTLECUR;
+    }
+
+    @JsonProperty("FRECTUNITTYPE")
+    public String getFRECTUNITTYPE() {
+        return FRECTUNITTYPE;
+    }
+
+    public void setFRECTUNITTYPE(String FRECTUNITTYPE) {
+        this.FRECTUNITTYPE = FRECTUNITTYPE;
+    }
+
+    @JsonProperty("FRECTUNIT")
+    public FRECTUNIT getFRECTUNIT() {
+        return FRECTUNIT;
+    }
+
+    public void setFRECTUNIT(FRECTUNIT FRECTUNIT) {
+        this.FRECTUNIT = FRECTUNIT;
+    }
+
+    @JsonProperty("FCONTACTUNITTYPE")
+    public String getFCONTACTUNITTYPE() {
+        return FCONTACTUNITTYPE;
+    }
+
+    public void setFCONTACTUNITTYPE(String FCONTACTUNITTYPE) {
+        this.FCONTACTUNITTYPE = FCONTACTUNITTYPE;
+    }
+
+    @JsonProperty("FCONTACTUNIT")
+    public FCONTACTUNIT getFCONTACTUNIT() {
+        return FCONTACTUNIT;
+    }
+
+    public void setFCONTACTUNIT(FCONTACTUNIT FCONTACTUNIT) {
+        this.FCONTACTUNIT = FCONTACTUNIT;
+    }
+
+    @JsonProperty("FREFUNDBILLENTRY")
+    public List<FREFUNDBILLENTRY> getFREFUNDBILLENTRY() {
+        return FREFUNDBILLENTRY;
+    }
+
+    public void setFREFUNDBILLENTRY(List<FREFUNDBILLENTRY> FREFUNDBILLENTRY) {
+        this.FREFUNDBILLENTRY = FREFUNDBILLENTRY;
+    }
+}
+package com.diligrp.etrade.thirdparty.domain.co.business.refund;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-11-28 09:13
+ * @Version: todo
+ */
+public class RefundBillCo extends BaseRefundCo{
+}
+package com.diligrp.etrade.thirdparty.domain.model;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-11-25 15:27
+ * @Version: todo
+ */
+public class FRECTUNIT {
+
+    private String FNumber;
+
+    @JsonProperty("FNumber")
+    public String getFNumber() {
+        return FNumber;
+    }
+
+    public void setFNumber(String FNumber) {
+        this.FNumber = FNumber;
+    }
+}
+package com.diligrp.etrade.thirdparty.domain.model;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import java.math.BigDecimal;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-11-28 09:13
+ * @Version: todo
+ */
+public class FREFUNDBILLENTRY {
+    private FCOSTID FCOSTID;
+    private FSETTLETYPE FSETTLETYPEID;
+    private BigDecimal FREFUNDAMOUNTFOR;
+    private String FNOTE;
+    private FPURPOSEID FPURPOSEID;
+    private FACCOUNTID FACCOUNTID;
+    private FCOSTDEPARTMENTID FCOSTDEPARTMENTID;
+
+    @JsonProperty("FCOSTID")
+    public FCOSTID getFCOSTID() {
+        return FCOSTID;
+    }
+
+    public void setFCOSTID(FCOSTID FCOSTID) {
+        this.FCOSTID = FCOSTID;
+    }
+
+    @JsonProperty("FSETTLETYPEID")
+    public FSETTLETYPE getFSETTLETYPEID() {
+        return FSETTLETYPEID;
+    }
+
+    public void setFSETTLETYPEID(FSETTLETYPE FSETTLETYPEID) {
+        this.FSETTLETYPEID = FSETTLETYPEID;
+    }
+
+    @JsonProperty("FREFUNDAMOUNTFOR")
+    public BigDecimal getFREFUNDAMOUNTFOR() {
+        return FREFUNDAMOUNTFOR;
+    }
+
+    public void setFREFUNDAMOUNTFOR(BigDecimal FREFUNDAMOUNTFOR) {
+        this.FREFUNDAMOUNTFOR = FREFUNDAMOUNTFOR;
+    }
+
+    @JsonProperty("getFNOTE")
+    public String getFNOTE() {
+        return FNOTE;
+    }
+
+    public void setFNOTE(String FNOTE) {
+        this.FNOTE = FNOTE;
+    }
+
+    @JsonProperty("FPURPOSEID")
+    public FPURPOSEID getFPURPOSEID() {
+        return FPURPOSEID;
+    }
+
+    public void setFPURPOSEID(FPURPOSEID FPURPOSEID) {
+        this.FPURPOSEID = FPURPOSEID;
+    }
+
+    @JsonProperty("FACCOUNTID")
+    public FACCOUNTID getFACCOUNTID() {
+        return FACCOUNTID;
+    }
+
+    public void setFACCOUNTID(FACCOUNTID FACCOUNTID) {
+        this.FACCOUNTID = FACCOUNTID;
+    }
+
+    @JsonProperty("FCOSTDEPARTMENTID")
+    public FCOSTDEPARTMENTID getFCOSTDEPARTMENTID() {
+        return FCOSTDEPARTMENTID;
+    }
+
+    public void setFCOSTDEPARTMENTID(FCOSTDEPARTMENTID FCOSTDEPARTMENTID) {
+        this.FCOSTDEPARTMENTID = FCOSTDEPARTMENTID;
+    }
+}
+package com.diligrp.etrade.thirdparty.domain.model;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-10 10:04
+ * @Version: todo
+ */
+public class FSETTLECUR {
+    private String FNUMBER;
+
+    @JsonProperty("FNUMBER")
+    public String getFNUMBER() {
+        return FNUMBER;
+    }
+
+    public void setFNUMBER(String FNUMBER) {
+        this.FNUMBER = FNUMBER;
+    }
+}
-package com.diligrp.etrade.thirdparty.demarcate;
+package com.diligrp.etrade.thirdparty.exec;
 import com.diligrp.etrade.thirdparty.error.ErrorCo;
 import com.diligrp.etrade.thirdparty.mapper.RecordMapper;
 package com.diligrp.etrade.thirdparty.exec.basic;
 import com.diligrp.etrade.core.util.JsonUtils;
-import com.diligrp.etrade.thirdparty.demarcate.AbstractReceiver;
+import com.diligrp.etrade.thirdparty.exec.AbstractReceiver;
 import com.diligrp.etrade.thirdparty.exec.Holder;
 import com.diligrp.etrade.thirdparty.message.GeneralMessage;
 import com.rabbitmq.client.Channel;
 package com.diligrp.etrade.thirdparty.exec.business;
 import com.diligrp.etrade.core.util.JsonUtils;
-import com.diligrp.etrade.thirdparty.demarcate.AbstractReceiver;
+import com.diligrp.etrade.thirdparty.exec.AbstractReceiver;
 import com.diligrp.etrade.thirdparty.exec.Holder;
 import com.diligrp.etrade.thirdparty.message.GeneralMessage;
 import com.rabbitmq.client.Channel;
-package com.diligrp.etrade.thirdparty.handler.business;
+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.BusinessBillCo;
+import com.diligrp.etrade.thirdparty.domain.co.business.bill.BusinessBillCo;
 import com.diligrp.etrade.thirdparty.type.BusinessEnum;
 import com.fasterxml.jackson.core.type.TypeReference;
 import org.springframework.stereotype.Component;
-package com.diligrp.etrade.thirdparty.handler.business;
+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.CardBillCo;
+import com.diligrp.etrade.thirdparty.domain.co.business.bill.CardBillCo;
 import com.diligrp.etrade.thirdparty.type.BusinessEnum;
 import com.diligrp.etrade.thirdparty.type.ProcessType;
 import com.fasterxml.jackson.core.type.TypeReference;
-package com.diligrp.etrade.thirdparty.handler.business;
+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.DepositBillCo;
+import com.diligrp.etrade.thirdparty.domain.co.business.bill.DepositBillCo;
 import com.diligrp.etrade.thirdparty.type.BusinessEnum;
 import com.fasterxml.jackson.core.type.TypeReference;
 import org.springframework.stereotype.Component;
-package com.diligrp.etrade.thirdparty.handler.business;
+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.EntranceFeeBillCo;
+import com.diligrp.etrade.thirdparty.domain.co.business.bill.EntranceFeeBillCo;
 import com.diligrp.etrade.thirdparty.type.BusinessEnum;
 import com.fasterxml.jackson.core.type.TypeReference;
 import org.springframework.stereotype.Component;
-package com.diligrp.etrade.thirdparty.handler.business;
+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.RefrigeratorBillCo;
+import com.diligrp.etrade.thirdparty.domain.co.business.bill.RefrigeratorBillCo;
 import com.diligrp.etrade.thirdparty.type.BusinessEnum;
 import com.fasterxml.jackson.core.type.TypeReference;
 import org.springframework.stereotype.Component;
-package com.diligrp.etrade.thirdparty.handler.business;
+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.SettleBillCo;
+import com.diligrp.etrade.thirdparty.domain.co.business.bill.SettleBillCo;
 import com.diligrp.etrade.thirdparty.type.BusinessEnum;
 import com.fasterxml.jackson.core.type.TypeReference;
 import org.springframework.stereotype.Component;
-package com.diligrp.etrade.thirdparty.handler.business;
+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.WeighingBillCo;
+import com.diligrp.etrade.thirdparty.domain.co.business.bill.WeighingBillCo;
 import com.diligrp.etrade.thirdparty.type.BusinessEnum;
 import com.fasterxml.jackson.core.type.TypeReference;
 import org.springframework.stereotype.Component;
-package com.diligrp.etrade.thirdparty.handler.rec;
+package com.diligrp.etrade.thirdparty.handler.business.rec;
 import com.diligrp.etrade.core.util.JsonUtils;
 import com.diligrp.etrade.thirdparty.demarcate.AbstractRecHandler;
-import com.diligrp.etrade.thirdparty.domain.co.rec.DepositAndWithdrawBillCo;
+import com.diligrp.etrade.thirdparty.domain.co.business.rec.DepositBillCo;
 import com.diligrp.etrade.thirdparty.type.BusinessEnum;
 import com.fasterxml.jackson.core.type.TypeReference;
 import org.springframework.stereotype.Component;
@@ -15,23 +15,14 @@ import java.util.List;
  * @Version: todo
  */
 @Component
-public class DepositAndWithdrawRecHandler extends AbstractRecHandler<DepositAndWithdrawBillCo> {
-    private static void defaultSettings(List<DepositAndWithdrawBillCo> depositAndWithdrawBillCos) {
-        depositAndWithdrawBillCos.forEach(e->{
-            e.setFCONTACTUNITTYPE("BD_Customer");
-            e.setFPAYUNITTYPE("BD_Customer");
-            e.getFRECEIVEBILLENTRY().forEach(f->{
-                f.getFPURPOSEID().setFNumber("SFKYT02_SYS");
-            });
-        });
-    }
+public class DepositRecHandler extends AbstractRecHandler<DepositBillCo> {
     @Override
     public void handle(String json, Long marketId, String systemCode) throws Exception {
-        List<DepositAndWithdrawBillCo> depositAndWithdrawBillCos = JsonUtils.fromJsonString(json, new TypeReference<>() {});
-        transferDataListWithOutFeeItem(depositAndWithdrawBillCos, marketId, systemCode);
-        defaultSettings(depositAndWithdrawBillCos);
-        sendPurchaseOrder(depositAndWithdrawBillCos, marketId, systemCode);
+        List<DepositBillCo> depositBillCos = JsonUtils.fromJsonString(json, new TypeReference<>() {});
+        transferDataListWithOutFeeItem(depositBillCos, marketId, systemCode);
+        setUpThePrepayment(depositBillCos);
+        sendPurchaseOrder(depositBillCos, marketId, systemCode);
     }
     @Override
+package com.diligrp.etrade.thirdparty.handler.business.refund;
+
+import com.diligrp.etrade.core.util.JsonUtils;
+import com.diligrp.etrade.thirdparty.demarcate.AbstractRefundHandler;
+import com.diligrp.etrade.thirdparty.domain.co.business.refund.RefundBillCo;
+import com.diligrp.etrade.thirdparty.type.BusinessEnum;
+import com.fasterxml.jackson.core.type.TypeReference;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-11-28 09:32
+ * @Version: todo
+ */
+@Component
+public class PayoutsRefundHandler extends AbstractRefundHandler<RefundBillCo> {
+    @Override
+    public void handle(String json, Long marketId, String systemCode) throws Exception {
+        List<RefundBillCo> refundBillCos = JsonUtils.fromJsonString(json, new TypeReference<>() {});
+        transferDataListWithOutFeeItem(refundBillCos, marketId, systemCode);
+        sendPurchaseOrder(refundBillCos, marketId, systemCode);
+    }
+
+    @Override
+    public BusinessEnum getType() {
+        return BusinessEnum.PAYOUTS;
+    }
+}
@@ -14,7 +14,8 @@ public enum BusinessEnum {
     WEIGHING("WEIGHING"),
     BILL("BILL"),
     DEPOSIT("DEPOSIT"),
-    DEPOSIT_AND_WITHDRAW("DEPOSIT_AND_WITHDRAW");
+    DEPOSIT_AND_WITHDRAW("DEPOSIT_AND_WITHDRAW"),
+    PAYOUTS("PAYOUTS");
     public final String code;
     BusinessEnum(String code) {
@@ -24,10 +24,10 @@ public class ReceiptsRefundOrderApiUtils extends BaseApiUtils {
         super(identifyInfo);
     }
-    public boolean getReceiptsRefundOrder(String FBillTypeID, String F_ZDB_text1,String allAmountFor,String F_ZDB_Text667 ) throws Exception {
+    public boolean getReceiptsRefundOrder(String FBillTypeID,String remark) 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);
+                FBillTypeID.FNumber = '%s' FREMARK = '%s';
+                """.formatted(FBillTypeID,remark);
         var query = new GeneralQueryMessage();
         query.setFilterString(FilterString);
         query.setFieldKeys("FID");