zr对接提交commit1

zhangmeiyang
1 parent a782af95
Showing 95 changed files with 3718 additions and 187 deletions
ereport-core/src/main/java/com/diligrp/etrade/report/ReportConfiguration.java
ereport-core/src/main/java/com/diligrp/etrade/report/component/LogArgsInfoAspect.java
ereport-core/src/main/java/com/diligrp/etrade/report/domain/co/ImageCreateCO.java
etrade-thirdparty/build.gradle
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/component/TransferComponent.java
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/demarcate/AbstractBusinessHandler.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/demarcate/AbstractReceiver.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/demarcate/ErrorHandleInterface.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/demarcate/TypeMarkInterface.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/domain/co/TestCo.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/domain/co/basic/BaseSourceCo.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/domain/co/basic/BusinessTypeCo.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/domain/co/basic/ChargeItemCo.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/domain/co/basic/ChargeItemGroupCo.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/domain/co/basic/ContactCo.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/domain/co/basic/CustomerCo.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/domain/co/basic/DepartmentCo.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/domain/co/basic/SettlementCo.java
@@ -7,6 +7,6 @@ import org.springframework.context.annotation.Configuration;
  
 @Configuration
 @ComponentScan("com.diligrp.etrade.report")
-@MapperScan(basePackages = {"com.diligrp.etrade.report.dao"},markerInterface = MybatisMapperSupport.class)
+@MapperScan(basePackages = {"com.diligrp.etrade.report.dao","com.diligrp.etrade.thirdparty.mapper"},markerInterface = MybatisMapperSupport.class)
 public class ReportConfiguration {
 }
@@ -2,27 +2,19 @@ package com.diligrp.etrade.report.component;
  
  
 import cn.hutool.core.util.ArrayUtil;
-import com.diligrp.etrade.core.util.JsonUtils;
 import com.diligrp.etrade.report.anno.LogArgsInfo;
-import jakarta.servlet.http.HttpServletRequest;
-import jakarta.servlet.http.HttpServletResponse;
-import org.aspectj.lang.JoinPoint;
 import org.aspectj.lang.ProceedingJoinPoint;
-import org.aspectj.lang.Signature;
-import org.aspectj.lang.annotation.*;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.aspectj.lang.annotation.Pointcut;
 import org.aspectj.lang.reflect.MethodSignature;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint;
 import org.springframework.stereotype.Component;
-import org.springframework.web.multipart.MultipartFile;
  
 import java.lang.reflect.Method;
 import java.util.Arrays;
-import java.util.Collections;
 import java.util.List;
-import java.util.Objects;
-import java.util.concurrent.locks.Lock;
  
 /**
  * 方法操作日志记录处理
 package com.diligrp.etrade.report.domain.co;
  
-import cn.hutool.core.annotation.Alias;
 import com.diligrp.etrade.report.anno.CheckTimeRange;
-import com.fasterxml.jackson.annotation.JsonAlias;
-import com.fasterxml.jackson.annotation.JsonFormat;
-import com.fasterxml.jackson.annotation.JsonProperty;
 import jakarta.validation.constraints.NotNull;
  
 import java.io.Serializable;
@@ -3,4 +3,6 @@ archivesBaseName = &#39;etrade-thirdparty&#39;
  
 dependencies {
     api project(':etrade-shared')
+    api project(':ereport-core')
+    implementation fileTree(dir: 'src/main/resources/lib', include: ['*.jar'])
 }
+package com.diligrp.etrade.thirdparty.component;
+
+
+import com.diligrp.etrade.thirdparty.domain.co.basic.BaseSourceCo;
+import com.diligrp.etrade.thirdparty.domain.co.business.BaseBillCo;
+import com.diligrp.etrade.thirdparty.domain.model.*;
+import com.diligrp.etrade.thirdparty.mapper.TransMapper;
+import jakarta.annotation.Resource;
+import org.springframework.stereotype.Component;
+import org.springframework.util.ObjectUtils;
+
+import java.time.LocalDateTime;
+
+/**
+ * Transfer Component （传输组件）
+ *
+ * @author zhangmeiyang
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-22 18:16
+ * @Version: todo
+ * @date 2024/10/24
+ */
+@Component
+public class TransferComponent {
+
+    @Resource
+    private TransMapper transMapper;
+
+    /**
+     * 转换数据baseCo
+     *
+     * @param co         CO
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     */
+    public void transBaseCo(BaseBillCo co, Long marketId, String systemCode) {
+        co.setFDATE(LocalDateTime.now().toString());
+        co.setFCURRENCYID(new FCURRENCYID());
+        co.setFMAINBOOKSTDCURRID(new FMAINBOOKSTDCURRID());
+        co.setFPAYORGID(new FPAYORGID());
+        co.setFSALEORGID(new FSALEORGID());
+        co.setFSETTLEORGID(new FSETTLEORGID());
+        if (!ObjectUtils.isEmpty(co.getFORDERID())){
+            this.transOrderId(co.getFORDERID());
+        }
+        if (!ObjectUtils.isEmpty(co.getFCUSTOMERID())){
+            this.transCustomer(co.getFCUSTOMERID());
+        }
+        if (!ObjectUtils.isEmpty(co.getFSALEDEPTID())){
+            this.transDepId(co.getFSALEDEPTID());
+        }
+        if (!ObjectUtils.isEmpty(co.getFTRANSFERID())){
+            this.transTransferId(co.getFTRANSFERID());
+        }
+        this.transPayOrgId(co.getFPAYORGID(), marketId, systemCode);
+        this.transSaleOrgId(co.getFSALEORGID(), marketId, systemCode);
+        this.transSettleOrgId(co.getFSETTLEORGID(), marketId, systemCode);
+        this.transCurrency(co.getFCURRENCYID(), marketId, systemCode);
+        this.transMainBookCurrency(co.getFMAINBOOKSTDCURRID(), marketId, systemCode);
+
+    }
+
+    public void transBasicCo(BaseSourceCo co, Long marketId, String systemCode){
+        co.setFUseOrgId(new FUseOrgId());
+        co.setFCreateOrgId(new FCreateOrgId());
+        this.transFUseOrgId(co.getFUseOrgId(), marketId, systemCode);
+        this.transFCreateOrgId(co.getFCreateOrgId(), marketId, systemCode);
+    }
+
+    /**
+     * 交易货币
+     *
+     * @param fcurrencyid fcurrencyid
+     * @param marketId    市场 ID
+     * @param systemCode  系统代码
+     */
+    public void transCurrency(FCURRENCYID fcurrencyid, Long marketId, String systemCode){
+        fcurrencyid.setFNumber(transMapper.getBaseConfig(systemCode, marketId).getCurrency());
+    }
+
+    /**
+     * Trans Main Book 货币
+     *
+     * @param fmainbookstdcurrid fmainbookstdcurrid
+     * @param marketId           市场 ID
+     * @param systemCode         系统代码
+     */
+    public void transMainBookCurrency(FMAINBOOKSTDCURRID fmainbookstdcurrid, Long marketId, String systemCode){
+        fmainbookstdcurrid.setFNumber(transMapper.getBaseConfig(systemCode, marketId).getCurrency());
+    }
+
+    /**
+     * 跨性别客户
+     *
+     * @param fcustomerid fcustomerid
+     */
+    public void transCustomer(FCUSTOMERID fcustomerid){
+        fcustomerid.setFNumber(transMapper.getCustomer(Long.valueOf(fcustomerid.getFNumber())).getCode());
+    }
+
+    /**
+     * 交易订单 ID
+     *
+     * @param forderid forderid
+     */
+    public void transOrderId(FORDERID forderid){
+        forderid.setFNumber(transMapper.getCustomer(Long.valueOf(forderid.getFNumber())).getCode());
+    }
+
+    /**
+     * Trans Transfer ID （转账 ID）
+     *
+     * @param ftransferid ftransferid
+     */
+    public void transTransferId(FTRANSFERID ftransferid){
+        ftransferid.setFNumber(transMapper.getCustomer(Long.valueOf(ftransferid.getFNumber())).getCode());
+    }
+
+    /**
+     * Trans Pay 组织 ID
+     *
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     * @param fUseOrgId  f 使用组织 ID
+     */
+    public void transFUseOrgId(FUseOrgId fUseOrgId, Long marketId, String systemCode){
+        fUseOrgId.setFNumber(transMapper.getClientParam(systemCode,marketId).getOrganization());
+    }
+
+    /**
+     * Trans fcreate org ID
+     *
+     * @param marketId     市场 ID
+     * @param systemCode   系统代码
+     * @param fCreateOrgId f 创建组织 ID
+     */
+    public void transFCreateOrgId(FCreateOrgId fCreateOrgId, Long marketId, String systemCode){
+        fCreateOrgId.setFNumber(transMapper.getClientParam(systemCode,marketId).getOrganization());
+    }
+
+    /**
+     * Trans Pay 组织 ID
+     *
+     * @param fpayorgid  fpayorgid
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     */
+    public void transPayOrgId(FPAYORGID fpayorgid, Long marketId, String systemCode){
+        fpayorgid.setFNumber(transMapper.getClientParam(systemCode,marketId).getOrganization());
+    }
+
+    /**
+     * Trans 销售组织 ID
+     *
+     * @param fsaleorgid fsaleorgid
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     */
+    public void transSaleOrgId(FSALEORGID fsaleorgid, Long marketId, String systemCode){
+        fsaleorgid.setFNumber(transMapper.getClientParam(systemCode,marketId).getOrganization());
+    }
+
+    /**
+     * Trans Settle 组织 ID
+     *
+     * @param fsettleorgid fsettleorgid
+     * @param marketId     市场 ID
+     * @param systemCode   系统代码
+     */
+    public void transSettleOrgId(FSETTLEORGID fsettleorgid, Long marketId, String systemCode){
+        fsettleorgid.setFNumber(transMapper.getClientParam(systemCode,marketId).getOrganization());
+    }
+
+    /**
+     * 跨性别 dep id
+     *
+     * @param fsaledeptid fsaledeptid
+     */
+    public void transDepId(FSALEDEPTID fsaledeptid){
+        fsaledeptid.setFNumber(transMapper.getDepartment(Long.valueOf(fsaledeptid.getFNumber())).getDepartmentCode());
+    }
+
+}
+package com.diligrp.etrade.thirdparty.demarcate;
+
+import com.diligrp.etrade.thirdparty.component.TransferComponent;
+import com.diligrp.etrade.thirdparty.domain.co.basic.BaseSourceCo;
+import com.diligrp.etrade.thirdparty.domain.dto.BaseConfigDto;
+import com.diligrp.etrade.thirdparty.domain.dto.ClientDto;
+import com.diligrp.etrade.thirdparty.domain.dto.MappingDto;
+import com.diligrp.etrade.thirdparty.mapper.RecordMapper;
+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 java.util.Arrays;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+/**
+ * 抽象业务处理程序
+ *
+ * @author zhangmeiyang
+ * @date 2024/09/26
+ */
+public abstract class AbstractBasicHandler<T extends BaseSourceCo> implements TypeMarkInterface<BasicEnum> {
+
+    @Resource
+    private TransferComponent transferComponent;
+
+    @Resource
+    private RecordMapper recordMapper;
+
+    @Resource
+    private TransMapper transMapper;
+
+
+    /**
+     * 记录映射
+     *
+     * @param marketId         市场 ID
+     * @param systemCode       系统代码
+     * @param systemDataId     系统数据 ID
+     * @param thirdPartyDataId 第三方数据 ID
+     */
+    protected void recordMapping(Long marketId, String systemCode, Long systemDataId, Long thirdPartyDataId) {
+        var mapping = new MappingDto();
+        mapping.setMarketId(marketId);
+        mapping.setBusiness(getType().code);
+        mapping.setSystemCode(systemCode);
+        mapping.setSystemDataId(systemDataId);
+        mapping.setThirdPartyDataId(thirdPartyDataId);
+        recordMapper.recordTheMappingData(mapping);
+    }
+
+    /**
+     * 获取身份信息
+     *
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     * @return {@link IdentifyInfo}
+     */
+    protected IdentifyInfo getIdentifyInfo(Long marketId, String systemCode) {
+        ClientDto clientParam = transMapper.getClientParam(systemCode, marketId);
+        var identifyInfo = new IdentifyInfo();
+        identifyInfo.setAppId(clientParam.getApplyId());
+        identifyInfo.setUserName(clientParam.getUsername());
+        identifyInfo.setServerUrl(clientParam.getServiceAddress());
+        identifyInfo.setAppSecret(clientParam.getSecurityKey());
+        identifyInfo.setdCID(clientParam.getDataCentreId());
+        return identifyInfo;
+    }
+
+    /**
+     * 获取映射数据
+     *
+     * @param marketId     市场 ID
+     * @param systemCode   系统代码
+     * @param systemDataId 系统数据 ID
+     * @return {@link MappingDto}
+     */
+    protected MappingDto getMappingData(Long marketId, String systemCode, Long systemDataId) {
+        var mapping = new MappingDto();
+        mapping.setMarketId(marketId);
+        mapping.setBusiness(getType().code);
+        mapping.setSystemCode(systemCode);
+        mapping.setSystemDataId(systemDataId);
+        return transMapper.getMappingData(mapping);
+    }
+
+    /**
+     * 是否同步
+     *
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     * @return boolean
+     */
+    protected boolean isSync(Long marketId, String systemCode) {
+        BaseConfigDto baseConfig = transMapper.getBaseConfig(systemCode, marketId);
+        Set<String> set = Arrays.stream(baseConfig.getSyncItem().split(",")).map(String::toUpperCase).collect(Collectors.toSet());
+        return set.contains(getType().code);
+    }
+
+    /**
+     * 固定转换
+     *
+     * @param t          t
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     */
+    protected void transfer(T t, Long marketId, String systemCode) {
+        transferComponent.transBasicCo(t, marketId, systemCode);
+    }
+
+    /**
+     * 处理
+     *
+     * @param json       JSON 格式
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     * @throws Exception 例外
+     */
+    public void handle(String json, Long marketId, String systemCode) throws Exception{
+        if (isSync(marketId, systemCode)) {
+            handleInside(json, marketId, systemCode);
+        }
+    }
+
+    /**
+     * 处理
+     *
+     * @param json       JSON 格式
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     * @throws Exception 例外
+     */
+    protected abstract void handleInside(String json, Long marketId, String systemCode) throws Exception;
+}
+package com.diligrp.etrade.thirdparty.demarcate;
+
+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.mapper.TransMapper;
+import com.diligrp.etrade.thirdparty.type.BusinessEnum;
+import jakarta.annotation.Resource;
+
+/**
+ * 抽象业务处理程序
+ *
+ * @author zhangmeiyang
+ * @date 2024/09/26
+ */
+public abstract class AbstractBillHandler<T extends BaseBillCo> implements TypeMarkInterface<BusinessEnum> {
+
+    @Resource
+    protected TransferComponent transferComponent;
+
+    @Resource
+    protected TransMapper transMapper;
+
+    /**
+     * 固定转换
+     *
+     * @param t          t
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     */
+    protected void transfer(T t, Long marketId, String systemCode) {
+        transferComponent.transBaseCo(t, marketId, systemCode);
+    }
+
+
+    /**
+     * 获取动态数据
+     *
+     * @param code       法典
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     * @return {@link BusinessDetailDto}
+     */
+    protected BusinessDetailDto getDynamicData(String code, Long marketId, String systemCode) {
+        return transMapper.getDynamicParam(systemCode, code, marketId);
+    }
+
+
+    /**
+     * 处理
+     *
+     * @param json       JSON 格式
+     * @param marketId   市场 ID
+     * @param systemCode 系统代码
+     * @throws Exception 例外
+     */
+    public abstract void handle(String json, Long marketId, String systemCode) throws Exception;
+}
-package com.diligrp.etrade.thirdparty.demarcate;
-
-import com.diligrp.etrade.core.util.JsonUtils;
-import com.fasterxml.jackson.core.type.TypeReference;
-
-/**
- * 抽象业务处理程序
- *
- * @author zhangmeiyang
- * @date 2024/09/26
- */
-public abstract class AbstractBusinessHandler<T> implements TypeMarkInterface {
-   /**
-    * 处理
-    *
-    * @param json JSON 格式
-    */
-   public void handle(String json){
-      this.handle(this.convertData(json));
-   }
-
-   /**
-    * 转换数据
-    *
-    * @param json JSON 格式
-    * @return {@link T}
-    */
-   protected T convertData(String json){
-      return JsonUtils.fromJsonString(json,new TypeReference<>() {});
-   }
-
-   /**
-    * 处理
-    *
-    * @param t t
-    */
-   protected abstract void handle(T t);
-}
+package com.diligrp.etrade.thirdparty.demarcate;
+
+import com.diligrp.etrade.thirdparty.error.ErrorCo;
+import com.diligrp.etrade.thirdparty.mapper.RecordMapper;
+import jakarta.annotation.Resource;
+import org.springframework.transaction.annotation.Transactional;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 16:27
+ * @Version: todo
+ */
+public abstract class AbstractReceiver {
+
+    @Resource
+    private RecordMapper recordMapper;
+
+    /**
+     * 处理错误
+     *
+     * @param message    消息
+     * @param data       数据
+     * @param business   商
+     * @param systemCode 系统代码
+     * @param marketId   市场 ID
+     */
+    @Transactional
+    public void handleError(String message,String data,String business,String systemCode, Long marketId) {
+        ErrorCo errorCo = new ErrorCo();
+        errorCo.setContent(data);
+        errorCo.setErrorMessage(message);
+        errorCo.setBusiness(business);
+        errorCo.setMarketId(marketId);
+        errorCo.setSystemCode(systemCode);
+        recordMapper.recordError(errorCo);
+    }
+
+}
-package com.diligrp.etrade.thirdparty.demarcate;
-
-/**
- * 错误处理接口
- *
- * @author zhangmeiyang
- * @date 2024/09/26
- */
-public interface ErrorHandleInterface extends TypeMarkInterface {
-    /**
-     * 保存和记录错误
-     *
-     * @param json         JSON 格式
-     * @param errorMessage 错误信息
-     */
-    void saveAndRecordError(String json, String errorMessage);
-}
@@ -8,11 +8,11 @@ import com.diligrp.etrade.thirdparty.type.BusinessEnum;
  * @author zhangmeiyang
  * @date 2024/09/26
  */
-public interface TypeMarkInterface {
+public interface TypeMarkInterface<T> {
     /**
      * 获取类型
      *
      * @return {@link BusinessEnum}
      */
-    BusinessEnum getType();
+    T getType();
 }
-package com.diligrp.etrade.thirdparty.domain.co;
-
-/**
- * @Author: zhangmeiyang
- * @CreateTime: 2024-09-10 15:06
- * @Version: todo
- */
-public class TestCo{
-    private String name;
-
-    public String getName() {
-        return name;
-    }
-
-    public void setName(String name) {
-        this.name = name;
-    }
-}
+package com.diligrp.etrade.thirdparty.domain.co.basic;
+
+import com.diligrp.etrade.thirdparty.domain.model.FCreateOrgId;
+import com.diligrp.etrade.thirdparty.domain.model.FUseOrgId;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * Base Source CO （基础源 CO）
+ *
+ * @author zhangmeiyang
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 15:35
+ * @Version: todo
+ * @date 2024/10/24
+ */
+public class BaseSourceCo {
+    private Long systemDataId;
+    private String FNumber;
+    private String FName;
+    private String FDescription;
+    private FCreateOrgId FCreateOrgId;
+    private FUseOrgId FUseOrgId;
+
+    @JsonProperty("systemDataId")
+    public Long getSystemDataId() {
+        return systemDataId;
+    }
+
+    public void setSystemDataId(Long systemDataId) {
+        this.systemDataId = systemDataId;
+    }
+
+    @JsonProperty("FNumber")
+    public String getFNumber() {
+        return FNumber;
+    }
+
+    public void setFNumber(String FNumber) {
+        this.FNumber = FNumber;
+    }
+    @JsonProperty("FName")
+    public String getFName() {
+        return FName;
+    }
+
+    public void setFName(String FName) {
+        this.FName = FName;
+    }
+    @JsonProperty("FDescription")
+    public String getFDescription() {
+        return FDescription;
+    }
+
+    public void setFDescription(String FDescription) {
+        this.FDescription = FDescription;
+    }
+    @JsonProperty("FCreateOrgId")
+    public FCreateOrgId getFCreateOrgId() {
+        return FCreateOrgId;
+    }
+
+    public void setFCreateOrgId(FCreateOrgId FCreateOrgId) {
+        this.FCreateOrgId = FCreateOrgId;
+    }
+    @JsonProperty("FUseOrgId")
+    public FUseOrgId getFUseOrgId() {
+        return FUseOrgId;
+    }
+
+    public void setFUseOrgId(FUseOrgId FUseOrgId) {
+        this.FUseOrgId = FUseOrgId;
+    }
+}
+package com.diligrp.etrade.thirdparty.domain.co.basic;
+
+import com.diligrp.etrade.thirdparty.domain.model.FBillFormID;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * 文件 CO
+ *
+ * @author zhangmeiyang
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 15:46
+ * @Version: todo
+ * @date 2024/10/24
+ */
+public class BusinessTypeCo extends BaseSourceCo{
+    private Long FBILLTYPEID;
+    private FBillFormID FBillFormID;
+
+    @JsonProperty("FBILLTYPEID")
+    public Long getFBILLTYPEID() {
+        return FBILLTYPEID;
+    }
+
+    public void setFBILLTYPEID(Long FBILLTYPEID) {
+        this.FBILLTYPEID = FBILLTYPEID;
+    }
+
+    @JsonProperty("FBillFormID")
+    public FBillFormID getFBillFormID() {
+        return FBillFormID;
+    }
+
+    public void setFBillFormID(FBillFormID FBillFormID) {
+        this.FBillFormID = FBillFormID;
+    }
+}
+package com.diligrp.etrade.thirdparty.domain.co.basic;
+
+import com.diligrp.etrade.thirdparty.domain.model.FGroup;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-24 14:22
+ * @Version: todo
+ */
+public class ChargeItemCo extends BaseSourceCo{
+    private Long FEXPID;
+    private FGroup FGroup;
+
+    @JsonProperty("FEXPID")
+    public Long getFEXPID() {
+        return FEXPID;
+    }
+
+    public void setFEXPID(Long FEXPID) {
+        this.FEXPID = FEXPID;
+    }
+
+    @JsonProperty("FGroup")
+    public FGroup getFGroup() {
+        return FGroup;
+    }
+
+    public void setFGroup(FGroup FGroup) {
+        this.FGroup = FGroup;
+    }
+}
+package com.diligrp.etrade.thirdparty.domain.co.basic;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * 费用项 CO
+ *
+ * @author zhangmeiyang
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 15:12
+ * @Version: todo
+ * @date 2024/10/24
+ */
+public class ChargeItemGroupCo extends BaseSourceCo{
+
+    private Long FParentId;
+    private Long GroupPkId;
+
+    @JsonProperty("FParentId")
+    public Long getFParentId() {
+        return FParentId;
+    }
+
+    public void setFParentId(Long FParentId) {
+        this.FParentId = FParentId;
+    }
+
+    @JsonProperty("GroupPkId")
+    public Long getGroupPkId() {
+        return GroupPkId;
+    }
+
+    public void setGroupPkId(Long groupPkId) {
+        GroupPkId = groupPkId;
+    }
+}
+package com.diligrp.etrade.thirdparty.domain.co.basic;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * 联系人 CO
+ *
+ * @author zhangmeiyang
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 18:04
+ * @Version: todo
+ * @date 2024/10/23
+ */
+public class ContactCo {
+    private String FName;
+    private String FCompanyType;
+    private String FBizAddress;
+    private String FMobile;
+
+    @JsonProperty("FName")
+    public String getFName() {
+        return FName;
+    }
+
+    public void setFName(String FName) {
+        this.FName = FName;
+    }
+    @JsonProperty("FCompanyType")
+    public String getFCompanyType() {
+        return FCompanyType;
+    }
+
+    public void setFCompanyType(String FCompanyType) {
+        this.FCompanyType = FCompanyType;
+    }
+    @JsonProperty("FBizAddress")
+    public String getFBizAddress() {
+        return FBizAddress;
+    }
+
+    public void setFBizAddress(String FBizAddress) {
+        this.FBizAddress = FBizAddress;
+    }
+    @JsonProperty("FMobile")
+    public String getFMobile() {
+        return FMobile;
+    }
+
+    public void setFMobile(String FMobile) {
+        this.FMobile = FMobile;
+    }
+}
+package com.diligrp.etrade.thirdparty.domain.co.basic;
+
+import com.diligrp.etrade.thirdparty.domain.model.*;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import java.util.List;
+
+/**
+ * 客户 CO
+ *
+ * @author zhangmeiyang
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 15:45
+ * @Version: todo
+ * @date 2024/10/24
+ */
+public class CustomerCo extends BaseSourceCo{
+    private Long FCUSTID;
+    private String FShortName;
+    private FCOUNTRY FCOUNTRY;
+    private FTRADINGCURRID FTRADINGCURRID;
+    private FPROVINCIAL FPROVINCIAL;
+    private String FADDRESS;
+    private FGroup FGroup;
+    private String FINVOICETITLE;
+    private String FLegalPerson;
+    private String FSOCIALCRECODE;
+    private String FRegisterAddress;
+    private List<FT_BD_CUSTLOCATION> FT_BD_CUSTLOCATION;
+
+    @JsonProperty("FCUSTID")
+    public Long getFCUSTID() {
+        return FCUSTID;
+    }
+
+    public void setFCUSTID(Long FCUSTID) {
+        this.FCUSTID = FCUSTID;
+    }
+
+    @JsonProperty("FShortName")
+    public String getFShortName() {
+        return FShortName;
+    }
+
+    public void setFShortName(String FShortName) {
+        this.FShortName = FShortName;
+    }
+    @JsonProperty("FCOUNTRY")
+    public FCOUNTRY getFCOUNTRY() {
+        return FCOUNTRY;
+    }
+
+    public void setFCOUNTRY(FCOUNTRY FCOUNTRY) {
+        this.FCOUNTRY = FCOUNTRY;
+    }
+    @JsonProperty("FTRADINGCURRID")
+    public FTRADINGCURRID getFTRADINGCURRID() {
+        return FTRADINGCURRID;
+    }
+
+    public void setFTRADINGCURRID(FTRADINGCURRID FTRADINGCURRID) {
+        this.FTRADINGCURRID = FTRADINGCURRID;
+    }
+    @JsonProperty("FPROVINCIAL")
+    public FPROVINCIAL getFPROVINCIAL() {
+        return FPROVINCIAL;
+    }
+
+    public void setFPROVINCIAL(FPROVINCIAL FPROVINCIAL) {
+        this.FPROVINCIAL = FPROVINCIAL;
+    }
+    @JsonProperty("FADDRESS")
+    public String getFADDRESS() {
+        return FADDRESS;
+    }
+
+    public void setFADDRESS(String FADDRESS) {
+        this.FADDRESS = FADDRESS;
+    }
+    @JsonProperty("FGroup")
+    public FGroup getFGroup() {
+        return FGroup;
+    }
+
+    public void setFGroup(FGroup FGroup) {
+        this.FGroup = FGroup;
+    }
+    @JsonProperty("FINVOICETITLE")
+    public String getFINVOICETITLE() {
+        return FINVOICETITLE;
+    }
+
+    public void setFINVOICETITLE(String FINVOICETITLE) {
+        this.FINVOICETITLE = FINVOICETITLE;
+    }
+    @JsonProperty("FLegalPerson")
+    public String getFLegalPerson() {
+        return FLegalPerson;
+    }
+
+    public void setFLegalPerson(String FLegalPerson) {
+        this.FLegalPerson = FLegalPerson;
+    }
+    @JsonProperty("FSOCIALCRECODE")
+    public String getFSOCIALCRECODE() {
+        return FSOCIALCRECODE;
+    }
+
+    public void setFSOCIALCRECODE(String FSOCIALCRECODE) {
+        this.FSOCIALCRECODE = FSOCIALCRECODE;
+    }
+    @JsonProperty("FRegisterAddress")
+    public String getFRegisterAddress() {
+        return FRegisterAddress;
+    }
+
+    public void setFRegisterAddress(String FRegisterAddress) {
+        this.FRegisterAddress = FRegisterAddress;
+    }
+
+    @JsonProperty("FT_BD_CUSTLOCATION")
+    public List<FT_BD_CUSTLOCATION> getFT_BD_CUSTLOCATION() {
+        return FT_BD_CUSTLOCATION;
+    }
+
+    public void setFT_BD_CUSTLOCATION(List<FT_BD_CUSTLOCATION> FT_BD_CUSTLOCATION) {
+        this.FT_BD_CUSTLOCATION = FT_BD_CUSTLOCATION;
+    }
+}
+package com.diligrp.etrade.thirdparty.domain.co.basic;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * 部门 CO
+ *
+ * @author zhangmeiyang
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 15:47
+ * @Version: todo
+ * @date 2024/10/24
+ */
+public class DepartmentCo extends BaseSourceCo{
+    private Long FDEPTID;
+
+    @JsonProperty("FDEPTID")
+    public Long getFDEPTID() {
+        return FDEPTID;
+    }
+
+    public void setFDEPTID(Long FDEPTID) {
+        this.FDEPTID = FDEPTID;
+    }
+}
+package com.diligrp.etrade.thirdparty.domain.co.basic;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * 结算公司
+ *
+ * @author zhangmeiyang
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 15:46
+ * @Version: todo
+ * @date 2024/10/24
+ */
+public class SettlementCo extends BaseSourceCo {
+    private Long FID;
+    private String FSETTLECATEGORY;
+    private String FTYPE;
+
+    @JsonProperty("FID")
+    public Long getFID() {
+        return FID;
+    }
+
+    public void setFID(Long FID) {
+        this.FID = FID;
+    }
+
+    @JsonProperty("FSETTLECATEGORY")
+    public String getFSETTLECATEGORY() {
+        return FSETTLECATEGORY;
+    }
+
+    public void setFSETTLECATEGORY(String FSETTLECATEGORY) {
+        this.FSETTLECATEGORY = FSETTLECATEGORY;
+    }
+
+    @JsonProperty("FTYPE")
+    public String getFTYPE() {
+        return FTYPE;
+    }
+
+    public void setFTYPE(String FTYPE) {
+        this.FTYPE = FTYPE;
+    }
+}
+package com.diligrp.etrade.thirdparty.domain.co.business;
+
+import com.diligrp.etrade.thirdparty.domain.model.*;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-22 18:34
+ * @Version: todo
+ */
+public class BaseBillCo implements Serializable {
+    private String FAR_Remark;
+    private BigDecimal FPrice;
+    private BigDecimal FTaxPrice;
+    private BigDecimal FPriceQty;
+    private String FBUSINESSTYPE;
+    private String FDATE;
+    private FBillTypeID FBillTypeID;
+    private FSETTLEORGID FSETTLEORGID;
+    private FCURRENCYID FCURRENCYID;
+    private FCUSTOMERID FCUSTOMERID;
+    private FSALEORGID FSALEORGID;
+    private FSALEDEPTID FSALEDEPTID;
+    private FPAYORGID FPAYORGID;
+    private FTRANSFERID FTRANSFERID;
+    private FORDERID FORDERID;
+    private FMAINBOOKSTDCURRID FMAINBOOKSTDCURRID;
+    private FCOSTID FCOSTID;
+    private FASSETID FASSETID;
+    private FChargeId FChargeId;
+    private FSettleTypeID FSettleTypeID;
+
+    @JsonProperty("FAR_Remark")
+    public String getFAR_Remark() {
+        return FAR_Remark;
+    }
+
+    public void setFAR_Remark(String FAR_Remark) {
+        this.FAR_Remark = FAR_Remark;
+    }
+
+    @JsonProperty("FPrice")
+    public BigDecimal getFPrice() {
+        return FPrice;
+    }
+
+    public void setFPrice(BigDecimal FPrice) {
+        this.FPrice = FPrice;
+    }
+
+    @JsonProperty("FTaxPrice")
+    public BigDecimal getFTaxPrice() {
+        return FTaxPrice;
+    }
+
+    public void setFTaxPrice(BigDecimal FTaxPrice) {
+        this.FTaxPrice = FTaxPrice;
+    }
+
+    @JsonProperty("FPriceQty")
+    public BigDecimal getFPriceQty() {
+        return FPriceQty;
+    }
+
+    public void setFPriceQty(BigDecimal FPriceQty) {
+        this.FPriceQty = FPriceQty;
+    }
+
+    @JsonProperty("FBUSINESSTYPE")
+    public String getFBUSINESSTYPE() {
+        return FBUSINESSTYPE;
+    }
+
+    public void setFBUSINESSTYPE(String FBUSINESSTYPE) {
+        this.FBUSINESSTYPE = FBUSINESSTYPE;
+    }
+
+    @JsonProperty("FDATE")
+    public String getFDATE() {
+        return FDATE;
+    }
+
+    public void setFDATE(String FDATE) {
+        this.FDATE = FDATE;
+    }
+
+    @JsonProperty("FBillTypeID")
+    public FBillTypeID getFBillTypeID() {
+        return FBillTypeID;
+    }
+
+    public void setFBillTypeID(FBillTypeID FBillTypeID) {
+        this.FBillTypeID = FBillTypeID;
+    }
+
+    @JsonProperty("FSETTLEORGID")
+    public FSETTLEORGID getFSETTLEORGID() {
+        return FSETTLEORGID;
+    }
+
+    public void setFSETTLEORGID(FSETTLEORGID FSETTLEORGID) {
+        this.FSETTLEORGID = FSETTLEORGID;
+    }
+
+    @JsonProperty("FCURRENCYID")
+    public FCURRENCYID getFCURRENCYID() {
+        return FCURRENCYID;
+    }
+
+    public void setFCURRENCYID(FCURRENCYID FCURRENCYID) {
+        this.FCURRENCYID = FCURRENCYID;
+    }
+
+    @JsonProperty("FCUSTOMERID")
+    public FCUSTOMERID getFCUSTOMERID() {
+        return FCUSTOMERID;
+    }
+
+    public void setFCUSTOMERID(FCUSTOMERID FCUSTOMERID) {
+        this.FCUSTOMERID = FCUSTOMERID;
+    }
+
+    @JsonProperty("FSALEORGID")
+    public FSALEORGID getFSALEORGID() {
+        return FSALEORGID;
+    }
+
+    public void setFSALEORGID(FSALEORGID FSALEORGID) {
+        this.FSALEORGID = FSALEORGID;
+    }
+
+    @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("FTRANSFERID")
+    public FTRANSFERID getFTRANSFERID() {
+        return FTRANSFERID;
+    }
+
+    public void setFTRANSFERID(FTRANSFERID FTRANSFERID) {
+        this.FTRANSFERID = FTRANSFERID;
+    }
+
+    @JsonProperty("FORDERID")
+    public FORDERID getFORDERID() {
+        return FORDERID;
+    }
+
+    public void setFORDERID(FORDERID FORDERID) {
+        this.FORDERID = FORDERID;
+    }
+
+    @JsonProperty("FMAINBOOKSTDCURRID")
+    public FMAINBOOKSTDCURRID getFMAINBOOKSTDCURRID() {
+        return FMAINBOOKSTDCURRID;
+    }
+
+    public void setFMAINBOOKSTDCURRID(FMAINBOOKSTDCURRID FMAINBOOKSTDCURRID) {
+        this.FMAINBOOKSTDCURRID = FMAINBOOKSTDCURRID;
+    }
+
+    @JsonProperty("FCOSTID")
+    public FCOSTID getFCOSTID() {
+        return FCOSTID;
+    }
+
+    public void setFCOSTID(FCOSTID FCOSTID) {
+        this.FCOSTID = FCOSTID;
+    }
+
+    @JsonProperty("FASSETID")
+    public FASSETID getFASSETID() {
+        return FASSETID;
+    }
+
+    public void setFASSETID(FASSETID FASSETID) {
+        this.FASSETID = FASSETID;
+    }
+
+    @JsonProperty("FChargeId")
+    public FChargeId getFChargeId() {
+        return FChargeId;
+    }
+
+    public void setFChargeId(FChargeId FChargeId) {
+        this.FChargeId = FChargeId;
+    }
+
+    @JsonProperty("FSettleTypeID")
+    public FSettleTypeID getFSettleTypeID() {
+        return FSettleTypeID;
+    }
+
+    public void setFSettleTypeID(FSettleTypeID FSettleTypeID) {
+        this.FSettleTypeID = FSettleTypeID;
+    }
+}
+package com.diligrp.etrade.thirdparty.domain.co.business;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import java.math.BigDecimal;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-14 10:55
+ * @Version: todo
+ */
+public class BusinessBillCo extends BaseBillCo{
+    private BigDecimal FNoTaxAmountFor_D;
+
+    @JsonProperty("FNoTaxAmountFor_D")
+    public BigDecimal getFNoTaxAmountFor_D() {
+        return FNoTaxAmountFor_D;
+    }
+
+    public void setFNoTaxAmountFor_D(BigDecimal FNoTaxAmountFor_D) {
+        this.FNoTaxAmountFor_D = FNoTaxAmountFor_D;
+    }
+}
+package com.diligrp.etrade.thirdparty.domain.co.business;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-10 14:23
+ * @Version: todo
+ */
+public class CardBillCo extends BaseBillCo {
+    private String F_ZDB_Text;
+    private String F_PZCW_Text;
+
+    @JsonProperty("F_ZDB_Text")
+    public String getF_ZDB_Text() {
+        return F_ZDB_Text;
+    }
+
+    public void setF_ZDB_Text(String f_ZDB_Text) {
+        F_ZDB_Text = f_ZDB_Text;
+    }
+
+    @JsonProperty("F_PZCW_Text")
+    public String getF_PZCW_Text() {
+        return F_PZCW_Text;
+    }
+
+    public void setF_PZCW_Text(String f_PZCW_Text) {
+        F_PZCW_Text = f_PZCW_Text;
+    }
+}
+
+
+
+package com.diligrp.etrade.thirdparty.domain.co.business;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import java.math.BigDecimal;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-10 10:17
+ * @Version: todo
+ */
+public class EntranceFeeBillCo extends BaseBillCo{
+    private BigDecimal FNoTaxAmountFor_D;
+
+    @JsonProperty("FNoTaxAmountFor_D")
+    public BigDecimal getFNoTaxAmountFor_D() {
+        return FNoTaxAmountFor_D;
+    }
+
+    public void setFNoTaxAmountFor_D(BigDecimal FNoTaxAmountFor_D) {
+        this.FNoTaxAmountFor_D = FNoTaxAmountFor_D;
+    }
+
+}
+package com.diligrp.etrade.thirdparty.domain.co.business;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import java.math.BigDecimal;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-10 14:18
+ * @Version: todo
+ */
+public class RefrigeratorBillCo extends BaseBillCo {
+    private BigDecimal FNoTaxAmountFor_D;
+
+    @JsonProperty("FNoTaxAmountFor_D")
+    public BigDecimal getFNoTaxAmountFor_D() {
+        return FNoTaxAmountFor_D;
+    }
+
+    public void setFNoTaxAmountFor_D(BigDecimal FNoTaxAmountFor_D) {
+        this.FNoTaxAmountFor_D = FNoTaxAmountFor_D;
+    }
+
+}
+package com.diligrp.etrade.thirdparty.domain.co.business;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-10 14:23
+ * @Version: todo
+ */
+public class SettleBillCo extends BaseBillCo {
+    private String F_ZDB_Text;
+    private String F_PZCW_Text;
+
+    @JsonProperty("F_ZDB_Text")
+    public String getF_ZDB_Text() {
+        return F_ZDB_Text;
+    }
+
+    public void setF_ZDB_Text(String f_ZDB_Text) {
+        F_ZDB_Text = f_ZDB_Text;
+    }
+
+    @JsonProperty("F_PZCW_Text")
+    public String getF_PZCW_Text() {
+        return F_PZCW_Text;
+    }
+
+    public void setF_PZCW_Text(String f_PZCW_Text) {
+        F_PZCW_Text = f_PZCW_Text;
+    }
+
+}
+
+package com.diligrp.etrade.thirdparty.domain.co.business;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import java.math.BigDecimal;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-10 11:08
+ * @Version: todo
+ */
+public class WeighingBillCo extends BaseBillCo {
+    private BigDecimal FNoTaxAmountFor_D;
+
+    @JsonProperty("FNoTaxAmountFor_D")
+    public BigDecimal getFNoTaxAmountFor_D() {
+        return FNoTaxAmountFor_D;
+    }
+
+    public void setFNoTaxAmountFor_D(BigDecimal FNoTaxAmountFor_D) {
+        this.FNoTaxAmountFor_D = FNoTaxAmountFor_D;
+    }
+
+}
+package com.diligrp.etrade.thirdparty.domain.dto;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-22 14:36
+ * @Version: todo
+ */
+public class BaseConfigDto {
+    private String currency;
+    private String syncItem;
+
+    public String getCurrency() {
+        return currency;
+    }
+
+    public void setCurrency(String currency) {
+        this.currency = currency;
+    }
+
+    public String getSyncItem() {
+        return syncItem;
+    }
+
+    public void setSyncItem(String syncItem) {
+        this.syncItem = syncItem;
+    }
+}
+package com.diligrp.etrade.thirdparty.domain.dto;
+
+import com.diligrp.etrade.thirdparty.type.SelectType;
+
+/**
+ * @author zhangmeiyang
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-21 10:29
+ * @Version: todo
+ * @date 2024/10/22
+ */
+public class BusinessDetailDto {
+    private String code;
+    private String name;
+    private SelectType selectType;
+    private String itemCode;
+    private String itemName;
+    private Long itemRelationId;
+    private String itemValue;
+
+    public String getCode() {
+        return code;
+    }
+
+    public void setCode(String code) {
+        this.code = code;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public SelectType getSelectType() {
+        return selectType;
+    }
+
+    public void setSelectType(SelectType selectType) {
+        this.selectType = selectType;
+    }
+
+    public String getItemCode() {
+        return itemCode;
+    }
+
+    public void setItemCode(String itemCode) {
+        this.itemCode = itemCode;
+    }
+
+    public String getItemName() {
+        return itemName;
+    }
+
+    public void setItemName(String itemName) {
+        this.itemName = itemName;
+    }
+
+    public Long getItemRelationId() {
+        return itemRelationId;
+    }
+
+    public void setItemRelationId(Long itemRelationId) {
+        this.itemRelationId = itemRelationId;
+    }
+
+    public String getItemValue() {
+        return itemValue;
+    }
+
+    public void setItemValue(String itemValue) {
+        this.itemValue = itemValue;
+    }
+}
+package com.diligrp.etrade.thirdparty.domain.dto;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-22 16:34
+ * @Version: todo
+ */
+public class ChargeItemDto {
+    private Long id;
+    private String businessType;
+}
+package com.diligrp.etrade.thirdparty.domain.dto;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-21 10:12
+ * @Version: todo
+ */
+public class ClientDto {
+    private String dataCentreId;
+    private String applyId;
+    private String securityKey;
+    private String serviceAddress;
+    private String username;
+    private String organization;
+
+    public String getDataCentreId() {
+        return dataCentreId;
+    }
+
+    public void setDataCentreId(String dataCentreId) {
+        this.dataCentreId = dataCentreId;
+    }
+
+    public String getApplyId() {
+        return applyId;
+    }
+
+    public void setApplyId(String applyId) {
+        this.applyId = applyId;
+    }
+
+    public String getSecurityKey() {
+        return securityKey;
+    }
+
+    public void setSecurityKey(String securityKey) {
+        this.securityKey = securityKey;
+    }
+
+    public String getServiceAddress() {
+        return serviceAddress;
+    }
+
+    public void setServiceAddress(String serviceAddress) {
+        this.serviceAddress = serviceAddress;
+    }
+
+    public String getUsername() {
+        return username;
+    }
+
+    public void setUsername(String username) {
+        this.username = username;
+    }
+
+    public String getOrganization() {
+        return organization;
+    }
+
+    public void setOrganization(String organization) {
+        this.organization = organization;
+    }
+}
+package com.diligrp.etrade.thirdparty.domain.dto;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-22 16:29
+ * @Version: todo
+ */
+public class CustomerDto {
+    private String code;
+    private Long id;
+
+    public String getCode() {
+        return code;
+    }
+
+    public void setCode(String code) {
+        this.code = code;
+    }
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+}
+package com.diligrp.etrade.thirdparty.domain.dto;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-22 14:13
+ * @Version: todo
+ */
+public class DepartmentDto {
+    private Long id;
+    private String departmentCode;
+    private String departmentName;
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public String getDepartmentCode() {
+        return departmentCode;
+    }
+
+    public void setDepartmentCode(String departmentCode) {
+        this.departmentCode = departmentCode;
+    }
+
+    public String getDepartmentName() {
+        return departmentName;
+    }
+
+    public void setDepartmentName(String departmentName) {
+        this.departmentName = departmentName;
+    }
+}
+package com.diligrp.etrade.thirdparty.domain.dto;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-24 10:13
+ * @Version: todo
+ */
+public class MappingDto {
+    private Long id;
+    private Long marketId;
+    private String systemCode;
+    private String business;
+    private Long systemDataId;
+    private Long thirdPartyDataId;
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public Long getMarketId() {
+        return marketId;
+    }
+
+    public void setMarketId(Long marketId) {
+        this.marketId = marketId;
+    }
+
+    public String getSystemCode() {
+        return systemCode;
+    }
+
+    public void setSystemCode(String systemCode) {
+        this.systemCode = systemCode;
+    }
+
+    public String getBusiness() {
+        return business;
+    }
+
+    public void setBusiness(String business) {
+        this.business = business;
+    }
+
+    public Long getSystemDataId() {
+        return systemDataId;
+    }
+
+    public void setSystemDataId(Long systemDataId) {
+        this.systemDataId = systemDataId;
+    }
+
+    public Long getThirdPartyDataId() {
+        return thirdPartyDataId;
+    }
+
+    public void setThirdPartyDataId(Long thirdPartyDataId) {
+        this.thirdPartyDataId = thirdPartyDataId;
+    }
+}
+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 FASSETID {
+    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;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 15:15
+ * @Version: todo
+ */
+public class FBillFormID {
+    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;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-09 10:26
+ * @Version: todo
+ */
+public class FBillTypeID {
+    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;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-10 10:03
+ * @Version: todo
+ */
+public class FCOSTID {
+    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;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 15:15
+ * @Version: todo
+ */
+public class FCOUNTRY {
+    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;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-09 10:25
+ * @Version: todo
+ */
+public class FCURRENCYID {
+
+    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;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-10 10:00
+ * @Version: todo
+ */
+public class FCUSTOMERID {
+
+    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;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-10 10:06
+ * @Version: todo
+ */
+public class FChargeId {
+    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;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 17:56
+ * @Version: todo
+ */
+public class FContactId {
+    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;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 15:15
+ * @Version: todo
+ */
+public class FCreateOrgId {
+    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;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 15:15
+ * @Version: todo
+ */
+public class FGroup {
+    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;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-10 10:06
+ * @Version: todo
+ */
+public class FMAINBOOKSTDCURRID {
+
+    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;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-10 10:06
+ * @Version: todo
+ */
+public class FORDERID {
+    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;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-10 10:01
+ * @Version: todo
+ */
+public class FPAYORGID {
+
+    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;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 15:15
+ * @Version: todo
+ */
+public class FPROVINCIAL {
+    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;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-10 10:01
+ * @Version: todo
+ */
+public class FSALEDEPTID {
+    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;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-10 10:00
+ * @Version: todo
+ */
+public class FSALEORGID {
+
+    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;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-09 10:24
+ * @Version: todo
+ */
+public class FSETTLEORGID {
+    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;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-10 10:06
+ * @Version: todo
+ */
+public class FSettleTypeID {
+    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;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 15:15
+ * @Version: todo
+ */
+public class FTRADINGCURRID {
+    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;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-10 10:05
+ * @Version: todo
+ */
+public class FTRANSFERID {
+    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;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 16:01
+ * @Version: todo
+ */
+public class FT_BD_CUSTLOCATION {
+    private FContactId FContactId;
+    private String FNumber;
+    private String FName;
+    private String FMobile;
+    private String FBizAddress;
+
+    @JsonProperty("FContactId")
+    public FContactId getFContactId() {
+        return FContactId;
+    }
+
+    public void setFContactId(FContactId FContactId) {
+        this.FContactId = FContactId;
+    }
+
+    @JsonProperty("FNumber")
+    public String getFNumber() {
+        return FNumber;
+    }
+
+    public void setFNumber(String FNumber) {
+        this.FNumber = FNumber;
+    }
+
+    @JsonProperty("FName")
+    public String getFName() {
+        return FName;
+    }
+
+    public void setFName(String FName) {
+        this.FName = FName;
+    }
+
+    @JsonProperty("FMobile")
+    public String getFMobile() {
+        return FMobile;
+    }
+
+    public void setFMobile(String FMobile) {
+        this.FMobile = FMobile;
+    }
+
+    @JsonProperty("FBizAddress")
+    public String getFBizAddress() {
+        return FBizAddress;
+    }
+
+    public void setFBizAddress(String FBizAddress) {
+        this.FBizAddress = FBizAddress;
+    }
+}
+package com.diligrp.etrade.thirdparty.domain.model;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 15:15
+ * @Version: todo
+ */
+public class FUseOrgId {
+    private String FNumber;
+
+    @JsonProperty("FNumber")
+    public String getFNumber() {
+        return FNumber;
+    }
+
+    public void setFNumber(String FNumber) {
+        this.FNumber = FNumber;
+    }
+}
-package com.diligrp.etrade.thirdparty.domain.co;
-
-import com.diligrp.etrade.thirdparty.type.BusinessEnum;
+package com.diligrp.etrade.thirdparty.error;
  
 /**
  * @Author: zhangmeiyang
  * @CreateTime: 2024-09-10 11:32
  * @Version: todo
  */
-public class ErrorMessageCo {
+public class ErrorCo{
     private String errorMessage;
-
     private String content;
-
-    private BusinessEnum business;
+    private String business;
+    private String systemCode;
+    private Long marketId;
  
     public String getContent() {
         return content;
@@ -30,11 +28,27 @@ public class ErrorMessageCo {
         this.errorMessage = errorMessage;
     }
  
-    public BusinessEnum getBusiness() {
+    public String getBusiness() {
         return business;
     }
  
-    public void setBusiness(BusinessEnum business) {
+    public void setBusiness(String business) {
         this.business = business;
     }
+
+    public String getSystemCode() {
+        return systemCode;
+    }
+
+    public void setSystemCode(String systemCode) {
+        this.systemCode = systemCode;
+    }
+
+    public Long getMarketId() {
+        return marketId;
+    }
+
+    public void setMarketId(Long marketId) {
+        this.marketId = marketId;
+    }
 }
+package com.diligrp.etrade.thirdparty.error;
+
+import com.diligrp.etrade.core.exception.PlatformServiceException;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-15 11:32
+ * @Version: todo
+ */
+public class ThirdPartyException extends PlatformServiceException {
+
+    public ThirdPartyException(String message) {
+        super(message);
+    }
+}
 package com.diligrp.etrade.thirdparty.exec;
  
-import com.diligrp.etrade.thirdparty.demarcate.AbstractBusinessHandler;
-import com.diligrp.etrade.thirdparty.demarcate.ErrorHandleInterface;
+import com.diligrp.etrade.thirdparty.demarcate.AbstractBasicHandler;
+import com.diligrp.etrade.thirdparty.demarcate.AbstractBillHandler;
+import com.diligrp.etrade.thirdparty.type.BasicEnum;
 import com.diligrp.etrade.thirdparty.type.BusinessEnum;
 import jakarta.annotation.Resource;
 import org.springframework.beans.factory.DisposableBean;
@@ -18,29 +19,25 @@ import java.util.concurrent.ConcurrentHashMap;
  * @Version: todo
  */
 @Component
-public class ZrHolder implements InitializingBean, DisposableBean {
+public class Holder implements InitializingBean, DisposableBean {
  
     /**
      * 上下文
      */
-    public final static Map<BusinessEnum, AbstractBusinessHandler<?>> CONTEXT = new ConcurrentHashMap<>();
+    public final static Map<BusinessEnum, AbstractBillHandler<?>> BUSINESS_CONTEXT = new ConcurrentHashMap<>();
+    public final static Map<BasicEnum, AbstractBasicHandler<?>> BASIC_CONTEXT = new ConcurrentHashMap<>();
  
  
-    /**
-     * 错误处理程序上下文
-     */
-    public final static Map<BusinessEnum, ErrorHandleInterface> ERROR_HANDLER_CONTEXT = new ConcurrentHashMap<>();
-
     @Resource
-    private List<AbstractBusinessHandler<?>> businessHandlers;
+    private List<AbstractBillHandler<?>> businessHandlers;
  
     @Resource
-    private List<ErrorHandleInterface> errorHandleInterfaces;
+    private List<AbstractBasicHandler<?>> basicHandlers;
  
     @Override
     public void afterPropertiesSet() {
-        businessHandlers.forEach(e -> CONTEXT.put(e.getType(), e));
-        errorHandleInterfaces.forEach(e -> ERROR_HANDLER_CONTEXT.put(e.getType(), e));
+        businessHandlers.forEach(e -> BUSINESS_CONTEXT.put(e.getType(), e));
+        basicHandlers.forEach(e -> BASIC_CONTEXT.put(e.getType(), e));
     }
  
     @Override
+package com.diligrp.etrade.thirdparty.exec.basic;
+
+import org.springframework.amqp.core.*;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-09-02 15:51
+ * @Version: todo
+ */
+@Configuration
+public class BasicAutoPush {
+    public static final String ZR_BASIC_NORMAL_EXCHANGE = "zr.normal.basic.exchange";
+    public static final String ZR_BASIC_NORMAL_QUEUE = "zr.normal.basic.queue";
+    public static final String ZR_BASIC_NORMAL_ROUTING = "zr.normal.basic.routing.process";
+    public static final String ZR_BASIC_DEAD_EXCHANGE = "zr.dead.basic.exchange";
+    public static final String ZR_BASIC_DEAD_EXCHANGE_TYPE = "x-delayed-message";
+    public static final String ZR_BASIC_DEAD_QUEUE = "zr.dead.basic.queue";
+
+    @Bean("normalBasicExchange")
+    public DirectExchange normalExchange(){
+        return new DirectExchange(ZR_BASIC_NORMAL_EXCHANGE,true,false);
+    }
+
+    @Bean("normalBasicQueue")
+    public Queue normalQueue(){
+        return new Queue(ZR_BASIC_NORMAL_QUEUE);
+    }
+
+    @Bean("normalBasicBinding")
+    public Binding normalBinding(@Qualifier("normalBasicQueue") Queue normalQueue, @Qualifier("normalBasicExchange") DirectExchange normalExchange) {
+        return BindingBuilder.bind(normalQueue).to(normalExchange).with(ZR_BASIC_NORMAL_ROUTING);
+    }
+
+    @Bean("dlxBasicCustomQueue")
+    public Queue dlxCustomQueue() {
+        return new Queue(ZR_BASIC_DEAD_QUEUE, true, false, false);
+    }
+
+    @Bean("dlxBasicCustomExchange")
+    public CustomExchange dlxCustomExchange() {
+        Map<String, Object> args = new HashMap<>();
+        args.put("x-delayed-type", "direct");
+        return new CustomExchange(ZR_BASIC_DEAD_EXCHANGE, ZR_BASIC_DEAD_EXCHANGE_TYPE, true,false,args);
+    }
+
+    @Bean("dlxBasicCustomBinding")
+    public Binding dlxCustomBinding(@Qualifier("dlxBasicCustomQueue") Queue queue, @Qualifier("dlxBasicCustomExchange") CustomExchange exchange) {
+        return BindingBuilder.bind(queue).to(exchange).with(ZR_BASIC_DEAD_QUEUE).noargs();
+    }
+
+}
+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.Holder;
+import com.diligrp.etrade.thirdparty.message.GeneralMessage;
+import com.rabbitmq.client.Channel;
+import jakarta.annotation.Resource;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.core.MessageBuilder;
+import org.springframework.amqp.rabbit.annotation.Exchange;
+import org.springframework.amqp.rabbit.annotation.Queue;
+import org.springframework.amqp.rabbit.annotation.QueueBinding;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.stereotype.Component;
+
+import java.io.IOException;
+import java.nio.charset.StandardCharsets;
+
+import static com.diligrp.etrade.thirdparty.exec.basic.BasicAutoPush.*;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-09-02 16:32
+ * @Version: todo
+ */
+@Component
+public class BasicReceiver extends AbstractReceiver {
+    private final static Logger LOG = LoggerFactory.getLogger(BasicReceiver.class);
+    private static final Long DELAY = 5000L;
+    private static final String DELAY_PREFIX = "x-delay";
+
+
+    @Resource
+    private RabbitTemplate rabbitTemplate;
+
+    @RabbitListener(bindings = @QueueBinding(value = @Queue(value = ZR_BASIC_NORMAL_QUEUE, autoDelete = "false"), exchange = @Exchange(value = ZR_BASIC_NORMAL_EXCHANGE), key = ZR_BASIC_NORMAL_ROUTING), ackMode = "MANUAL")
+    public void receiveMessage(Channel channel, Message message) throws IOException {
+        var content = new String(message.getBody(), StandardCharsets.UTF_8);
+        LOG.info("business receive message:{}", content);
+        GeneralMessage msg = JsonUtils.fromJsonString(content, GeneralMessage.class);
+        try {
+            Holder.BASIC_CONTEXT.get(msg.getBasic()).handle(msg.getData(), msg.getMarketId(), msg.getSystemCode());
+            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
+            LOG.info("business handle success:{}", content);
+        } catch (Exception e) {
+            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
+            msg.setRetryCount(msg.getRetryCount() + 1);
+            sendDelayMsg(DELAY, JsonUtils.toJsonString(msg));
+            LOG.error("business exception:", e);
+        }
+    }
+
+    @RabbitListener(queues = ZR_BASIC_DEAD_QUEUE, ackMode = "MANUAL")
+    public void handleCustomDelayMsg(Channel channel, Message message) throws IOException {
+        var content = new String(message.getBody(), StandardCharsets.UTF_8);
+        LOG.info("business receive retry message:{}", content);
+        GeneralMessage msg = JsonUtils.fromJsonString(content, GeneralMessage.class);
+        try {
+            Holder.BASIC_CONTEXT.get(msg.getBasic()).handle(msg.getData(), msg.getMarketId(), msg.getSystemCode());
+            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
+            LOG.info("business retry message success:{}", content);
+        } 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());
+                LOG.error("retry business exception:", e);
+            } else {
+                msg.setRetryCount(msg.getRetryCount() + 1);
+                sendDelayMsg(DELAY, JsonUtils.toJsonString(msg));
+            }
+        }
+    }
+
+    public void sendDelayMsg(Long currentMills, String message) {
+        byte[] bytes = message.getBytes(StandardCharsets.UTF_8);
+        Message msg = MessageBuilder.withBody(bytes).setHeader(DELAY_PREFIX, currentMills).build();
+        rabbitTemplate.convertAndSend(ZR_BASIC_DEAD_EXCHANGE, ZR_BASIC_DEAD_QUEUE, msg);
+    }
+}
-package com.diligrp.etrade.thirdparty.exec;
+package com.diligrp.etrade.thirdparty.exec.business;
  
 import org.springframework.amqp.core.*;
 import org.springframework.beans.factory.annotation.Qualifier;
@@ -14,44 +14,44 @@ import java.util.Map;
  * @Version: todo
  */
 @Configuration
-public class ZrAutoPush {
-    public static final String ZR_NORMAL_EXCHANGE = "zr.normal.exchange";
-    public static final String ZR_NORMAL_QUEUE = "zr.normal.queue";
-    public static final String ZR_NORMAL_ROUTING = "zr.normal.routing.process";
-    public static final String ZR_DEAD_EXCHANGE = "zr.dead.exchange";
-    public static final String ZR_DEAD_EXCHANGE_TYPE = "x-delayed-message";
-    public static final String ZR_DEAD_QUEUE = "zr.dead.queue";
+public class BusinessAutoPush {
+    public static final String ZR_BUSINESS_NORMAL_EXCHANGE = "zr.normal.exchange";
+    public static final String ZR_BUSINESS_NORMAL_QUEUE = "zr.normal.queue";
+    public static final String ZR_BUSINESS_NORMAL_ROUTING = "zr.normal.routing.process";
+    public static final String ZR_BUSINESS_DEAD_EXCHANGE = "zr.dead.exchange";
+    public static final String ZR_BUSINESS_DEAD_EXCHANGE_TYPE = "x-delayed-message";
+    public static final String ZR_BUSINESS_DEAD_QUEUE = "zr.dead.queue";
  
     @Bean("normalExchange")
     public DirectExchange normalExchange(){
-        return new DirectExchange(ZR_NORMAL_EXCHANGE,true,false);
+        return new DirectExchange(ZR_BUSINESS_NORMAL_EXCHANGE,true,false);
     }
  
     @Bean("normalQueue")
     public Queue normalQueue(){
-        return new Queue(ZR_NORMAL_QUEUE);
+        return new Queue(ZR_BUSINESS_NORMAL_QUEUE);
     }
  
     @Bean("normalBinding")
     public Binding normalBinding(@Qualifier("normalQueue") Queue normalQueue, @Qualifier("normalExchange") DirectExchange normalExchange) {
-        return BindingBuilder.bind(normalQueue).to(normalExchange).with(ZR_NORMAL_ROUTING);
+        return BindingBuilder.bind(normalQueue).to(normalExchange).with(ZR_BUSINESS_NORMAL_ROUTING);
     }
  
     @Bean("dlxCustomQueue")
     public Queue dlxCustomQueue() {
-        return new Queue(ZR_DEAD_QUEUE, true, false, false);
+        return new Queue(ZR_BUSINESS_DEAD_QUEUE, true, false, false);
     }
  
     @Bean("dlxCustomExchange")
     public CustomExchange dlxCustomExchange() {
         Map<String, Object> args = new HashMap<>();
         args.put("x-delayed-type", "direct");
-        return new CustomExchange(ZR_DEAD_EXCHANGE, ZR_DEAD_EXCHANGE_TYPE, true,false,args);
+        return new CustomExchange(ZR_BUSINESS_DEAD_EXCHANGE, ZR_BUSINESS_DEAD_EXCHANGE_TYPE, true,false,args);
     }
  
     @Bean("dlxCustomBinding")
     public Binding dlxCustomBinding(@Qualifier("dlxCustomQueue") Queue queue, @Qualifier("dlxCustomExchange") CustomExchange exchange) {
-        return BindingBuilder.bind(queue).to(exchange).with(ZR_DEAD_QUEUE).noargs();
+        return BindingBuilder.bind(queue).to(exchange).with(ZR_BUSINESS_DEAD_QUEUE).noargs();
     }
  
 }
-package com.diligrp.etrade.thirdparty.exec;
+package com.diligrp.etrade.thirdparty.exec.business;
  
 import com.diligrp.etrade.core.util.JsonUtils;
-import com.diligrp.etrade.thirdparty.domain.co.ErrorMessageCo;
+import com.diligrp.etrade.thirdparty.demarcate.AbstractReceiver;
+import com.diligrp.etrade.thirdparty.exec.Holder;
 import com.diligrp.etrade.thirdparty.message.GeneralMessage;
-import com.diligrp.etrade.thirdparty.type.BusinessEnum;
 import com.rabbitmq.client.Channel;
 import jakarta.annotation.Resource;
 import org.slf4j.Logger;
@@ -20,7 +20,7 @@ import org.springframework.stereotype.Component;
 import java.io.IOException;
 import java.nio.charset.StandardCharsets;
  
-import static com.diligrp.etrade.thirdparty.exec.ZrAutoPush.*;
+import static com.diligrp.etrade.thirdparty.exec.business.BusinessAutoPush.*;
  
 /**
  * @Author: zhangmeiyang
@@ -28,59 +28,54 @@ import static com.diligrp.etrade.thirdparty.exec.ZrAutoPush.*;
  * @Version: todo
  */
 @Component
-public class ZrReceiver {
-    private final static Logger LOG = LoggerFactory.getLogger(ZrReceiver.class);
+public class BusinessReceiver extends AbstractReceiver {
+    private final static Logger LOG = LoggerFactory.getLogger(BusinessReceiver.class);
     private static final Long DELAY = 5000L;
     private static final String DELAY_PREFIX = "x-delay";
-
     @Resource
     private RabbitTemplate rabbitTemplate;
  
-    @RabbitListener(bindings = @QueueBinding(value = @Queue(value = ZR_NORMAL_QUEUE, autoDelete = "false"), exchange = @Exchange(value = ZR_NORMAL_EXCHANGE), key = ZR_NORMAL_ROUTING), ackMode = "MANUAL")
+    @RabbitListener(bindings = @QueueBinding(value = @Queue(value = ZR_BUSINESS_NORMAL_QUEUE, autoDelete = "false"), exchange = @Exchange(value = ZR_BUSINESS_NORMAL_EXCHANGE), key = ZR_BUSINESS_NORMAL_ROUTING), ackMode = "MANUAL")
     public void receiveMessage(Channel channel, Message message) throws IOException {
         var content = new String(message.getBody(), StandardCharsets.UTF_8);
-        LOG.info("business receive message:{}",content);
+        LOG.info("basic receive message:{}",content);
         GeneralMessage msg = JsonUtils.fromJsonString(content, GeneralMessage.class);
         try {
-            ZrHolder.CONTEXT.get(msg.getBusiness()).handle(msg.getData());
+            Holder.BUSINESS_CONTEXT.get(msg.getBusiness()).handle(msg.getData(), msg.getMarketId(), msg.getSystemCode());
             channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
-            LOG.info("business handle success:{}",content);
+            LOG.info("basic handle success:{}",content);
         } catch (Exception e) {
             channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
             msg.setRetryCount(msg.getRetryCount()+1);
             sendDelayMsg(DELAY, JsonUtils.toJsonString(msg));
-            LOG.error("business exception:",e);
+            LOG.error("basic exception:",e);
         }
     }
  
-    @RabbitListener(queues = ZR_DEAD_QUEUE, ackMode = "MANUAL")
+    @RabbitListener(queues = ZR_BUSINESS_DEAD_QUEUE, ackMode = "MANUAL")
     public void handleCustomDelayMsg(Channel channel, Message message) throws IOException {
         var content = new String(message.getBody(), StandardCharsets.UTF_8);
-        LOG.info("business receive retry message:{}",content);
+        LOG.info("basic receive retry message:{}",content);
         GeneralMessage msg = JsonUtils.fromJsonString(content, GeneralMessage.class);
         try {
-            ZrHolder.CONTEXT.get(msg.getBusiness()).handle(msg.getData());
+            Holder.BUSINESS_CONTEXT.get(msg.getBusiness()).handle(msg.getData(), msg.getMarketId(), msg.getSystemCode());
             channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
-            LOG.info("business retry message success:{}",content);
+            LOG.info("basic retry message success:{}",content);
         } catch (Exception e) {
             channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
-            msg.setRetryCount(msg.getRetryCount() + 1);
             if (msg.getRetryCount() > 3) {
-                ErrorMessageCo errorMessageCo = new ErrorMessageCo();
-                errorMessageCo.setContent(msg.getData());
-                errorMessageCo.setErrorMessage(e.fillInStackTrace().getMessage());
-                errorMessageCo.setBusiness(msg.getBusiness());
-                msg.setData(JsonUtils.toJsonString(errorMessageCo));
-                msg.setBusiness(BusinessEnum.ERROR);
-                LOG.error("retry business exception:",e);
+                super.handleError(e.fillInStackTrace().getMessage(), msg.getData(), msg.getBusiness().code, msg.getSystemCode(),msg.getMarketId());
+                LOG.error("retry basic exception:",e);
+            }else{
+                msg.setRetryCount(msg.getRetryCount() + 1);
+                sendDelayMsg(DELAY, JsonUtils.toJsonString(msg));
             }
-            sendDelayMsg(DELAY, JsonUtils.toJsonString(msg));
         }
     }
  
     public void sendDelayMsg(Long currentMills, String message) {
         byte[] bytes = message.getBytes(StandardCharsets.UTF_8);
         Message msg = MessageBuilder.withBody(bytes).setHeader(DELAY_PREFIX, currentMills).build();
-        rabbitTemplate.convertAndSend(ZR_DEAD_EXCHANGE, ZR_DEAD_QUEUE, msg);
+        rabbitTemplate.convertAndSend(ZR_BUSINESS_DEAD_EXCHANGE, ZR_BUSINESS_DEAD_QUEUE, msg);
     }
 }
+package com.diligrp.etrade.thirdparty.handler.basic;
+
+import com.diligrp.etrade.core.util.JsonUtils;
+import com.diligrp.etrade.thirdparty.demarcate.AbstractBasicHandler;
+import com.diligrp.etrade.thirdparty.domain.co.basic.BusinessTypeCo;
+import com.diligrp.etrade.thirdparty.domain.dto.MappingDto;
+import com.diligrp.etrade.thirdparty.type.BasicEnum;
+import com.diligrp.etrade.thirdparty.utils.BillTypeApiUtils;
+import com.fasterxml.jackson.core.type.TypeReference;
+import org.springframework.stereotype.Component;
+import org.springframework.util.ObjectUtils;
+
+import java.util.List;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 14:58
+ * @Version: todo
+ */
+@Component
+public class BusinessTypeBasicHandler extends AbstractBasicHandler<BusinessTypeCo> {
+
+    @Override
+    public void handleInside(String json, Long marketId, String systemCode) throws Exception {
+        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(String.valueOf(mappingData.getThirdPartyDataId()),JsonUtils.toJsonString(e));
+            }else {
+                String billType = utils.createBillType(JsonUtils.toJsonString(e));
+                super.recordMapping(marketId, systemCode, e.getSystemDataId(), Long.parseLong(billType));
+            }
+        }
+    }
+
+    @Override
+    public BasicEnum getType() {
+        return BasicEnum.FINANCIAL_BUSINESS_TYPE;
+    }
+}
+package com.diligrp.etrade.thirdparty.handler.basic;
+
+import com.diligrp.etrade.core.util.JsonUtils;
+import com.diligrp.etrade.thirdparty.demarcate.AbstractBasicHandler;
+import com.diligrp.etrade.thirdparty.domain.co.basic.ChargeItemCo;
+import com.diligrp.etrade.thirdparty.domain.dto.MappingDto;
+import com.diligrp.etrade.thirdparty.type.BasicEnum;
+import com.diligrp.etrade.thirdparty.utils.FeeApiUtils;
+import com.fasterxml.jackson.core.type.TypeReference;
+import org.springframework.stereotype.Component;
+import org.springframework.util.ObjectUtils;
+
+import java.util.List;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 14:58
+ * @Version: todo
+ */
+@Component
+public class ChargeItemBasicHandler extends AbstractBasicHandler<ChargeItemCo> {
+
+    @Override
+    public void handleInside(String json, Long marketId, String systemCode) throws Exception {
+        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 : mappingData.getThirdPartyDataId());
+            if (!ObjectUtils.isEmpty(mappingData)){
+                utils.updateFee(String.valueOf(mappingData.getThirdPartyDataId()),JsonUtils.toJsonString(e));
+            }else {
+                String fee = utils.createFee(JsonUtils.toJsonString(e));
+                super.recordMapping(marketId, systemCode, e.getSystemDataId(), Long.parseLong(fee));
+            }
+        }
+    }
+
+    @Override
+    public BasicEnum getType() {
+        return BasicEnum.CHARGE_ITEM;
+    }
+}
+package com.diligrp.etrade.thirdparty.handler.basic;
+
+import com.diligrp.etrade.core.util.JsonUtils;
+import com.diligrp.etrade.thirdparty.demarcate.AbstractBasicHandler;
+import com.diligrp.etrade.thirdparty.domain.co.basic.ChargeItemGroupCo;
+import com.diligrp.etrade.thirdparty.domain.dto.MappingDto;
+import com.diligrp.etrade.thirdparty.type.BasicEnum;
+import com.diligrp.etrade.thirdparty.utils.FeeGroupApiUtils;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.kingdee.bos.webapi.entity.IdentifyInfo;
+import org.springframework.stereotype.Component;
+import org.springframework.util.ObjectUtils;
+
+import java.util.List;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 14:58
+ * @Version: todo
+ */
+@Component
+public class ChargeItemGroupBasicHandler extends AbstractBasicHandler<ChargeItemGroupCo> {
+
+    @Override
+    public void handleInside(String json, Long marketId, String systemCode) throws Exception {
+        IdentifyInfo identifyInfo = getIdentifyInfo(marketId, systemCode);
+        var util = new FeeGroupApiUtils(identifyInfo);
+        List<ChargeItemGroupCo> chargeItemGroupCos = JsonUtils.fromJsonString(json, new TypeReference<>(){});
+        for (ChargeItemGroupCo e : chargeItemGroupCos) {
+            super.transfer(e, marketId, systemCode);
+            e.setFParentId(e.getFParentId().equals(0L) ? 0L : super.getMappingData(marketId, systemCode, e.getFParentId()).getThirdPartyDataId());
+            MappingDto mappingData = super.getMappingData(marketId, systemCode, e.getSystemDataId());
+            e.setGroupPkId(ObjectUtils.isEmpty(mappingData) ? null : mappingData.getThirdPartyDataId());
+            String s = util.saveFeeGroup(JsonUtils.toJsonString(e));
+            if (ObjectUtils.isEmpty(mappingData)) {
+                super.recordMapping(marketId, systemCode, e.getSystemDataId(), Long.parseLong(s));
+            }
+        }
+    }
+
+    @Override
+    public BasicEnum getType() {
+        return BasicEnum.CHARGE_ITEM_GROUP;
+    }
+}
+package com.diligrp.etrade.thirdparty.handler.basic;
+
+import com.diligrp.etrade.core.util.JsonUtils;
+import com.diligrp.etrade.thirdparty.demarcate.AbstractBasicHandler;
+import com.diligrp.etrade.thirdparty.domain.co.basic.CustomerCo;
+import com.diligrp.etrade.thirdparty.domain.dto.MappingDto;
+import com.diligrp.etrade.thirdparty.domain.model.FContactId;
+import com.diligrp.etrade.thirdparty.domain.model.FT_BD_CUSTLOCATION;
+import com.diligrp.etrade.thirdparty.type.BasicEnum;
+import com.diligrp.etrade.thirdparty.utils.ContactApiUtils;
+import com.diligrp.etrade.thirdparty.utils.CustomerApiUtils;
+import com.fasterxml.jackson.core.type.TypeReference;
+import org.springframework.stereotype.Component;
+import org.springframework.util.ObjectUtils;
+
+import java.util.List;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 14:58
+ * @Version: todo
+ */
+@Component
+public class CustomerBasicHandler extends AbstractBasicHandler<CustomerCo> {
+
+    @Override
+    public void handleInside(String json, Long marketId, String systemCode) throws Exception {
+        List<CustomerCo> customerCos = JsonUtils.fromJsonString(json, new TypeReference<>() {});
+        var customerUtils = new CustomerApiUtils(getIdentifyInfo(marketId, systemCode));
+        var contactUtils = new ContactApiUtils(getIdentifyInfo(marketId, systemCode));
+        for (CustomerCo e : customerCos) {
+            super.transfer(e, marketId, systemCode);
+            MappingDto mappingData = super.getMappingData(marketId, systemCode, e.getSystemDataId());
+            List<FT_BD_CUSTLOCATION> ftBdCustlocation = e.getFT_BD_CUSTLOCATION();
+            if (!ObjectUtils.isEmpty(ftBdCustlocation)){
+                for (FT_BD_CUSTLOCATION ftBdCustLocation : ftBdCustlocation) {
+                    String contact = contactUtils.createContact(JsonUtils.toJsonString(ftBdCustLocation));
+                    FContactId fContactId = new FContactId();
+                    fContactId.setFNUMBER(contact);
+                    ftBdCustLocation.setFContactId(fContactId);
+                }
+            }
+            e.setFCUSTID(ObjectUtils.isEmpty(mappingData) ? null : mappingData.getThirdPartyDataId());
+            if (!ObjectUtils.isEmpty(mappingData)){
+                customerUtils.updateCustomer(String.valueOf(mappingData.getThirdPartyDataId()),JsonUtils.toJsonString(e));
+            }else {
+                String billType = customerUtils.createCustomer(JsonUtils.toJsonString(e));
+                super.recordMapping(marketId, systemCode, e.getSystemDataId(), Long.parseLong(billType));
+            }
+        }
+    }
+
+    @Override
+    public BasicEnum getType() {
+        return BasicEnum.CUSTOMER;
+    }
+}
+package com.diligrp.etrade.thirdparty.handler.basic;
+
+import com.diligrp.etrade.core.util.JsonUtils;
+import com.diligrp.etrade.thirdparty.demarcate.AbstractBasicHandler;
+import com.diligrp.etrade.thirdparty.domain.co.basic.DepartmentCo;
+import com.diligrp.etrade.thirdparty.domain.dto.MappingDto;
+import com.diligrp.etrade.thirdparty.type.BasicEnum;
+import com.diligrp.etrade.thirdparty.utils.DepartmentApiUtils;
+import com.fasterxml.jackson.core.type.TypeReference;
+import org.springframework.stereotype.Component;
+import org.springframework.util.ObjectUtils;
+
+import java.util.List;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 14:58
+ * @Version: todo
+ */
+@Component
+public class DepartmentBasicHandler extends AbstractBasicHandler<DepartmentCo> {
+
+    @Override
+    public void handleInside(String json, Long marketId, String systemCode) throws Exception {
+        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 : 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(), Long.parseLong(department));
+            }
+        }
+
+    }
+
+    @Override
+    public BasicEnum getType() {
+        return BasicEnum.DEPARTMENT;
+    }
+}
+package com.diligrp.etrade.thirdparty.handler.basic;
+
+import com.diligrp.etrade.core.util.JsonUtils;
+import com.diligrp.etrade.thirdparty.demarcate.AbstractBasicHandler;
+import com.diligrp.etrade.thirdparty.domain.co.basic.SettlementCo;
+import com.diligrp.etrade.thirdparty.domain.dto.MappingDto;
+import com.diligrp.etrade.thirdparty.type.BasicEnum;
+import com.diligrp.etrade.thirdparty.utils.SettleTypeApiUtils;
+import com.fasterxml.jackson.core.type.TypeReference;
+import org.springframework.stereotype.Component;
+import org.springframework.util.ObjectUtils;
+
+import java.util.List;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 14:58
+ * @Version: todo
+ */
+@Component
+public class SettlementBasicHandler extends AbstractBasicHandler<SettlementCo> {
+
+    @Override
+    public void handleInside(String json, Long marketId, String systemCode) throws Exception {
+        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 : 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(), Long.parseLong(billType));
+            }
+        }
+    }
+
+    @Override
+    public BasicEnum getType() {
+        return BasicEnum.FINANCIAL_CHANNEL_TYPE;
+    }
+}
-package com.diligrp.etrade.thirdparty.handler;
+package com.diligrp.etrade.thirdparty.handler.business;
  
-import com.diligrp.etrade.thirdparty.demarcate.AbstractBusinessHandler;
-import com.diligrp.etrade.thirdparty.domain.co.ErrorMessageCo;
-import com.diligrp.etrade.thirdparty.exec.ZrHolder;
+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.type.BusinessEnum;
+import com.fasterxml.jackson.core.type.TypeReference;
 import org.springframework.stereotype.Component;
  
+import java.util.List;
+
 /**
  * @Author: zhangmeiyang
- * @CreateTime: 2024-09-10 10:56
+ * @CreateTime: 2024-10-15 10:57
  * @Version: todo
  */
 @Component
-public class ErrorBusinessHandler extends AbstractBusinessHandler<ErrorMessageCo> {
+public class BusinessBillHandler extends AbstractBillHandler<BusinessBillCo> {
     @Override
-    protected void handle(ErrorMessageCo co) {
-        ZrHolder.ERROR_HANDLER_CONTEXT.get(co.getBusiness()).saveAndRecordError(co.getContent(),co.getErrorMessage());
+    public void handle(String json, Long marketId, String systemCode) {
+        List<BusinessBillCo> businessBillCos = JsonUtils.fromJsonString(json, new TypeReference<>() {});
+        businessBillCos.forEach(e->super.transfer(e,marketId,systemCode));
+        System.out.println(JsonUtils.toJsonString(businessBillCos));
     }
  
     @Override
     public BusinessEnum getType() {
-        return BusinessEnum.ERROR;
+        return BusinessEnum.BILL;
     }
 }
+package com.diligrp.etrade.thirdparty.handler.business;
+
+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.type.BusinessEnum;
+import com.fasterxml.jackson.core.type.TypeReference;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-23 16:53
+ * @Version: todo
+ */
+@Component
+public class CardBillHandler extends AbstractBillHandler<CardBillCo> {
+    @Override
+    public void handle(String json, Long marketId, String systemCode) throws Exception {
+        List<CardBillCo> cardBillCos = JsonUtils.fromJsonString(json, new TypeReference<>() {});
+        cardBillCos.forEach(e-> super.transfer(e,marketId,systemCode));
+        System.out.println(JsonUtils.toJsonString(cardBillCos));
+    }
+
+    @Override
+    public BusinessEnum getType() {
+        return BusinessEnum.CARD;
+    }
+}
+package com.diligrp.etrade.thirdparty.handler.business;
+
+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.type.BusinessEnum;
+import com.fasterxml.jackson.core.type.TypeReference;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-15 10:57
+ * @Version: todo
+ */
+@Component
+public class EntranceFeeBillHandler extends AbstractBillHandler<EntranceFeeBillCo> {
+    @Override
+    public void handle(String json, Long marketId, String systemCode) {
+        List<EntranceFeeBillCo> entranceFeeBillCos = JsonUtils.fromJsonString(json, new TypeReference<>() {});
+        entranceFeeBillCos.forEach(e->super.transfer(e,marketId,systemCode));
+        System.out.println(JsonUtils.toJsonString(entranceFeeBillCos));
+    }
+
+    @Override
+    public BusinessEnum getType() {
+        return BusinessEnum.ENTRANCE_FEE;
+    }
+}
+package com.diligrp.etrade.thirdparty.handler.business;
+
+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.type.BusinessEnum;
+import com.fasterxml.jackson.core.type.TypeReference;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-15 10:57
+ * @Version: todo
+ */
+@Component
+public class RefrigeratorBillHandler extends AbstractBillHandler<RefrigeratorBillCo> {
+    @Override
+    public void handle(String json, Long marketId, String systemCode) {
+        List<RefrigeratorBillCo> refrigeratorBillCos = JsonUtils.fromJsonString(json, new TypeReference<>() {});
+        refrigeratorBillCos.forEach(e->super.transfer(e,marketId,systemCode));
+        System.out.println(JsonUtils.toJsonString(refrigeratorBillCos));
+    }
+
+    @Override
+    public BusinessEnum getType() {
+        return BusinessEnum.REFRIGERATOR;
+    }
+}
 package com.diligrp.etrade.thirdparty.handler.business;
  
-import com.diligrp.etrade.thirdparty.demarcate.AbstractBusinessHandler;
-import com.diligrp.etrade.thirdparty.demarcate.ErrorHandleInterface;
-import com.diligrp.etrade.thirdparty.domain.co.TestCo;
+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.type.BusinessEnum;
+import com.fasterxml.jackson.core.type.TypeReference;
 import org.springframework.stereotype.Component;
  
+import java.util.List;
+
 /**
  * @Author: zhangmeiyang
- * @CreateTime: 2024-09-10 15:03
+ * @CreateTime: 2024-10-22 16:46
  * @Version: todo
  */
 @Component
-public class TestBusinessHandleInterface extends AbstractBusinessHandler<TestCo> implements ErrorHandleInterface {
+public class SettleBillHandler extends AbstractBillHandler<SettleBillCo> {
+
     @Override
-    protected void handle(TestCo t) {
-        var s =  1/0;
+    public void handle(String json, Long marketId, String systemCode) {
+        List<SettleBillCo> settleBillCos = JsonUtils.fromJsonString(json, new TypeReference<>() {});
+        settleBillCos.forEach(e-> super.transfer(e,marketId,systemCode));
+        System.out.println(JsonUtils.toJsonString(settleBillCos));
     }
  
     @Override
     public BusinessEnum getType() {
-        return BusinessEnum.TEST;
-    }
-    @Override
-    public void saveAndRecordError(String json,String errorMessage) {
-        System.out.println(json);
-        System.out.println(errorMessage);
-        System.out.println("save db");
+        return BusinessEnum.SETTLE;
     }
 }
+package com.diligrp.etrade.thirdparty.handler.business;
+
+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.type.BusinessEnum;
+import com.fasterxml.jackson.core.type.TypeReference;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-15 10:57
+ * @Version: todo
+ */
+@Component
+public class WeighingBillHandler extends AbstractBillHandler<WeighingBillCo> {
+    @Override
+    public void handle(String json, Long marketId, String systemCode) {
+        List<WeighingBillCo> weighingBillCos = JsonUtils.fromJsonString(json, new TypeReference<>() {});
+        weighingBillCos.forEach(e->super.transfer(e,marketId,systemCode));
+        System.out.println(JsonUtils.toJsonString(weighingBillCos));
+    }
+
+    @Override
+    public BusinessEnum getType() {
+        return BusinessEnum.WEIGHING;
+    }
+}
+package com.diligrp.etrade.thirdparty.mapper;
+
+import com.diligrp.etrade.core.mybatis.MybatisMapperSupport;
+import com.diligrp.etrade.report.anno.DataSource;
+import com.diligrp.etrade.report.constant.DataSourceConstants;
+import com.diligrp.etrade.thirdparty.domain.dto.MappingDto;
+import com.diligrp.etrade.thirdparty.error.ErrorCo;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+@Mapper
+public interface RecordMapper extends MybatisMapperSupport {
+    /**
+     * 记录错误
+     *
+     * @param co CO
+     */
+    @DataSource(DataSourceConstants.DS_KEY_MASTER)
+    void recordError(@Param("co") ErrorCo co);
+
+    /**
+     * 记录映射数据
+     *
+     * @param mapping 映射
+     */
+    @DataSource(DataSourceConstants.DS_KEY_MASTER)
+    void recordTheMappingData(@Param("mapping")MappingDto mapping);
+}
+package com.diligrp.etrade.thirdparty.mapper;
+
+import com.diligrp.etrade.core.mybatis.MybatisMapperSupport;
+import com.diligrp.etrade.report.anno.DataSource;
+import com.diligrp.etrade.report.constant.DataSourceConstants;
+import com.diligrp.etrade.thirdparty.domain.dto.*;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-16 17:08
+ * @Version: todo
+ */
+@Mapper
+public interface TransMapper extends MybatisMapperSupport {
+
+    /**
+     * 获取客户端参数
+     *
+     * @param systemCode 系统代码
+     * @param marketId   市场 ID
+     * @return {@link ClientDto}
+     */
+    @DataSource(DataSourceConstants.DS_KEY_SLAVE)
+    ClientDto getClientParam(@Param("systemCode") String systemCode, @Param("marketId") Long marketId);
+
+    /**
+     * 获取动态参数
+     *
+     * @param systemCode 系统代码
+     * @param code       法典
+     * @param marketId   市场 ID
+     * @return {@link BusinessDetailDto}
+     */
+    @DataSource(DataSourceConstants.DS_KEY_SLAVE)
+    BusinessDetailDto getDynamicParam(@Param("systemCode")String systemCode, @Param("code") String code, @Param("marketId")Long marketId);
+
+
+    /**
+     * 获取部门
+     *
+     * @param departmentId 部门 ID
+     * @return {@link DepartmentDto}
+     */
+    @DataSource(DataSourceConstants.DS_KEY_SLAVE)
+    DepartmentDto getDepartment(@Param("departmentId") Long departmentId);
+
+    /**
+     * 获取基本配置
+     *
+     * @param systemCode 系统代码
+     * @param marketId   市场 ID
+     * @return {@link BaseConfigDto}
+     */
+    @DataSource(DataSourceConstants.DS_KEY_SLAVE)
+    BaseConfigDto getBaseConfig(@Param("systemCode") String systemCode, @Param("marketId") Long marketId);
+
+
+    /**
+     * 获取客户
+     *
+     * @param customerId 客户 ID
+     * @return {@link CustomerDto}
+     */
+    @DataSource(DataSourceConstants.DS_KEY_SLAVE)
+    CustomerDto getCustomer(@Param("customerId") Long customerId);
+
+    /**
+     * 获取 Charge 项
+     *
+     * @param chargeItemId 收费商品 ID
+     * @return {@link ChargeItemDto}
+     */
+    @DataSource(DataSourceConstants.DS_KEY_SLAVE)
+    ChargeItemDto getChargeItem(@Param("chargeItemId") Long chargeItemId);
+
+
+    /**
+     * 获取映射数据
+     *
+     * @param mappingDto 映射 DTO
+     * @return {@link MappingDto}
+     */
+    @DataSource(DataSourceConstants.DS_KEY_SLAVE)
+    MappingDto getMappingData(@Param("mapping") MappingDto mappingDto);
+
+}
 package com.diligrp.etrade.thirdparty.message;
  
+import com.diligrp.etrade.thirdparty.type.BasicEnum;
 import com.diligrp.etrade.thirdparty.type.BusinessEnum;
  
 /**
@@ -9,11 +10,22 @@ import com.diligrp.etrade.thirdparty.type.BusinessEnum;
  */
 public class GeneralMessage {
     private BusinessEnum business;
+    private BasicEnum basic;
     private String data;
     private Integer retryCount;
+    private Long marketId;
+    private String systemCode;
  
     public GeneralMessage() {
         this.retryCount = 0;
+        this.systemCode = "kingdee";
+    }
+    public BasicEnum getBasic() {
+        return basic;
+    }
+
+    public void setBasic(BasicEnum basic) {
+        this.basic = basic;
     }
  
     public BusinessEnum getBusiness() {
@@ -39,4 +51,20 @@ public class GeneralMessage {
     public void setRetryCount(Integer retryCount) {
         this.retryCount = retryCount;
     }
+
+    public Long getMarketId() {
+        return marketId;
+    }
+
+    public void setMarketId(Long marketId) {
+        this.marketId = marketId;
+    }
+
+    public String getSystemCode() {
+        return systemCode;
+    }
+
+    public void setSystemCode(String systemCode) {
+        this.systemCode = systemCode;
+    }
 }
+package com.diligrp.etrade.thirdparty.message;
+
+import java.util.Map;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-16 14:34
+ * @Version: todo
+ */
+public class GeneralSendMessage {
+    private Map<String,Object> Model;
+    private Boolean IsAutoSubmitAndAudit;
+
+    public Map<String, Object> getModel() {
+        return Model;
+    }
+
+    public void setModel(Map<String, Object> model) {
+        Model = model;
+    }
+
+    public Boolean getAutoSubmitAndAudit() {
+        return IsAutoSubmitAndAudit;
+    }
+
+    public void setAutoSubmitAndAudit(Boolean autoSubmitAndAudit) {
+        IsAutoSubmitAndAudit = autoSubmitAndAudit;
+    }
+}
+package com.diligrp.etrade.thirdparty.type;
+
+/**
+ * 基本枚举
+ *
+ * @author zhangmeiyang
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-16 10:13
+ * @Version: todo
+ * @date 2024/10/18
+ */
+public enum BasicEnum {
+    DEPARTMENT("DEPARTMENT"),
+    CHARGE_ITEM("CHARGE_ITEM"),
+    CHARGE_ITEM_GROUP("CHARGE_ITEM_GROUP"),
+    CUSTOMER("CUSTOMER"),
+    FINANCIAL_CHANNEL_TYPE("FINANCIAL_CHANNEL_TYPE"),
+    FINANCIAL_BUSINESS_TYPE("FINANCIAL_BUSINESS_TYPE");
+    public final String code;
+
+
+    BasicEnum(String code) {
+        this.code = code;
+
+    }
+}
 package com.diligrp.etrade.thirdparty.type;
  
-import com.diligrp.etrade.thirdparty.domain.co.ErrorMessageCo;
-import com.diligrp.etrade.thirdparty.domain.co.TestCo;
-
 /**
  * @Author: zhangmeiyang
  * @CreateTime: 2024-09-10 10:53
  * @Version: todo
  */
-public enum BusinessEnum{
-
-    ERROR("ERROR", ErrorMessageCo.class),
-
-    TEST("TEST",TestCo.class);
+public enum BusinessEnum {
  
+    SETTLE("SETTLE"),
+    ENTRANCE_FEE("ENTRANCE_FEE"),
+    REFRIGERATOR("REFRIGERATOR"),
+    CARD("CARD"),
+    WEIGHING("WEIGHING"),
+    BILL("BILL");
     public final String code;
-    public final Class<?> clazz;
  
-    BusinessEnum(String code, Class<?> clazz) {
+    BusinessEnum(String code) {
         this.code = code;
-        this.clazz = clazz;
     }
 }
+package com.diligrp.etrade.thirdparty.type;
+
+import com.diligrp.etrade.core.type.IEnumType;
+
+public enum SelectType implements IEnumType {
+    FIXED(1,"固定"),
+    FOLLOW_THE_DOCUMENTS(2,"按照单据");
+
+    private Integer code;
+    private String name;
+
+    SelectType(Integer code, String name) {
+        this.code = code;
+        this.name = name;
+    }
+
+    @Override
+    public int getCode() {
+        return this.code;
+    }
+
+    public void setCode(Integer code) {
+        this.code = code;
+    }
+
+    @Override
+    public String getName() {
+        return this.name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+}
+package com.diligrp.etrade.thirdparty.type;
+
+public enum ThirdPartyErrorCodeEnum {
+//           0：默认
+//           1：上下文丢失
+//           2：没有权限
+//           3：操作标识为空
+//           4：异常
+//           5：单据标识为空
+//           6：数据库操作失败
+//           7：许可错误
+//           8：参数错误
+//           9：指定字段/值不存在
+//           10：未找到对应数据
+//           11：验证失败
+//           12：不可操作
+//           13：网控冲突
+//           14：调用限制
+//           15：禁止管理员登录
+    DEFAULT("默认", "0"),
+    CONTEXT_LOST("上下文丢失", "1"),
+    NO_PERMISSION("没有权限", "2"),
+    OPERATION_ID_EMPTY("操作标识为空", "3"),
+    EXCEPTION("异常", "4"),
+    BILL_ID_EMPTY("单据标识为空", "5"),
+    DB_OPERATION_FAIL("数据库操作失败", "6"),
+    LICENSE_ERROR("许可错误", "7"),
+    PARAM_ERROR("参数错误", "8"),
+    FIELD_NOT_EXIST("指定字段/值不存在", "9"),
+    DATA_NOT_FOUND("未找到对应数据", "10"),
+    VALIDATE_FAIL("验证失败", "11"),
+    NOT_ALLOWED("不可操作", "12"),
+    NET_CONTROL_CONFLICT("网控冲突", "13"),
+    CALL_LIMIT("调用限制", "14"),
+    ADMIN_LOGIN_FORBIDDEN("禁止管理员登录", "15");
+
+    public final String code;
+    public final String desc;
+
+    ThirdPartyErrorCodeEnum(String desc, String code) {
+        this.desc = desc;
+        this.code = code;
+    }
+
+    public static ThirdPartyErrorCodeEnum getByCode(String code) {
+        for (ThirdPartyErrorCodeEnum item : ThirdPartyErrorCodeEnum.values()) {
+            if (item.code.equals(code)) {
+                return item;
+            }
+        }
+        return DEFAULT;
+    }
+}
+package com.diligrp.etrade.thirdparty.utils;
+
+import com.kingdee.bos.webapi.entity.IdentifyInfo;
+import com.kingdee.bos.webapi.sdk.K3CloudApi;
+
+/**
+ * 基本 API 实用程序
+ *
+ * @author zhangmeiyang
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-16 16:15
+ * @Version: todo
+ * @date 2024/10/23
+ */
+public abstract class BaseApiUtils {
+    protected K3CloudApi api;
+
+    public BaseApiUtils(IdentifyInfo identifyInfo) {
+        api = new K3CloudApi(identifyInfo);
+    }
+}
+package com.diligrp.etrade.thirdparty.utils;
+
+import com.diligrp.etrade.core.util.JsonUtils;
+import com.diligrp.etrade.thirdparty.error.ThirdPartyException;
+import com.diligrp.etrade.thirdparty.message.GeneralSendMessage;
+import com.diligrp.etrade.thirdparty.type.ThirdPartyErrorCodeEnum;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.kingdee.bos.webapi.entity.IdentifyInfo;
+import com.kingdee.bos.webapi.entity.OperateParam;
+import com.kingdee.bos.webapi.entity.OperatorResult;
+import com.kingdee.bos.webapi.entity.RepoRet;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 账单类型 API 实用程序
+ *
+ * @author zhangmeiyang
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-16 16:12
+ * @Version: todo
+ * @date 2024/10/23
+ */
+public class BillTypeApiUtils extends BaseApiUtils {
+    private static final Logger log = LoggerFactory.getLogger(FeeApiUtils.class);
+
+    public BillTypeApiUtils(IdentifyInfo identifyInfo) {
+        super(identifyInfo);
+    }
+
+    public String createBillType(String json) throws Exception {
+        Map<String, Object> map = JsonUtils.fromJsonString(json, new TypeReference<>() {
+        });
+        var message = new GeneralSendMessage();
+        message.setModel(map);
+        message.setAutoSubmitAndAudit(true);
+        return save(JsonUtils.toJsonString(message));
+    }
+
+    public void updateBillType(String FNumber, String updateJson) throws Exception {
+        unAudit(FNumber);
+        Map<String, Object> map = JsonUtils.fromJsonString(updateJson, new TypeReference<>() {
+        });
+        var message = new GeneralSendMessage();
+        message.setModel(map);
+        message.setAutoSubmitAndAudit(true);
+        save(JsonUtils.toJsonString(message));
+    }
+
+    private String save(String json) throws Exception {
+        String res = api.save("BOS_BillType", json);
+        RepoRet repoRet = JsonUtils.fromJsonString(res, new TypeReference<>() {
+        });
+        if (!repoRet.getResult().getResponseStatus().isIsSuccess()) {
+            ThirdPartyErrorCodeEnum errorCodeEnum = ThirdPartyErrorCodeEnum.getByCode(repoRet.getResult().getResponseStatus().getErrorCode());
+            throw new ThirdPartyException(errorCodeEnum.desc);
+        }
+        log.info("单据类型保存接口已完成,{}", res);
+        return repoRet.getResult().getResponseStatus().getSuccessEntitys().get(0).getId();
+    }
+
+    private void unAudit(String FNumber) throws Exception {
+        var para = new OperateParam();
+        List<String> Numbers = List.of(FNumber);
+        para.setNumbers(Numbers);
+        OperatorResult res = api.unAudit("BOS_BillType", para);
+        if (!res.getResult().getResponseStatus().isIsSuccess()) {
+            ThirdPartyErrorCodeEnum errorCodeEnum = ThirdPartyErrorCodeEnum.getByCode(res.getResult().getResponseStatus().getErrorCode());
+            throw new ThirdPartyException(errorCodeEnum.desc);
+        }
+        log.info("单据类型反审核接口已完成,{}", res);
+    }
+}
+package com.diligrp.etrade.thirdparty.utils;
+
+import com.diligrp.etrade.core.util.JsonUtils;
+import com.diligrp.etrade.thirdparty.error.ThirdPartyException;
+import com.diligrp.etrade.thirdparty.message.GeneralSendMessage;
+import com.diligrp.etrade.thirdparty.type.ThirdPartyErrorCodeEnum;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.kingdee.bos.webapi.entity.IdentifyInfo;
+import com.kingdee.bos.webapi.entity.OperateParam;
+import com.kingdee.bos.webapi.entity.OperatorResult;
+import com.kingdee.bos.webapi.entity.RepoRet;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 客户 API 实用程序
+ *
+ * @author zhangmeiyang
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-15 11:09
+ * @Version: todo
+ * @date 2024/10/23
+ */
+public class ContactApiUtils extends BaseApiUtils {
+    private static final Logger log = LoggerFactory.getLogger(ContactApiUtils.class);
+
+    public ContactApiUtils(IdentifyInfo identifyInfo) {
+        super(identifyInfo);
+    }
+
+    public String createContact(String json) throws Exception {
+        Map<String, Object> map = JsonUtils.fromJsonString(json, new TypeReference<>() {});
+        var message = new GeneralSendMessage();
+        message.setModel(map);
+        message.setAutoSubmitAndAudit(true);
+        return save(JsonUtils.toJsonString(message));
+    }
+
+    public void updateContact(String FNumber, String updateJson) throws Exception {
+        unAudit(FNumber);
+        Map<String, Object> map = JsonUtils.fromJsonString(updateJson, new TypeReference<>() {
+        });
+        var message = new GeneralSendMessage();
+        message.setModel(map);
+        message.setAutoSubmitAndAudit(true);
+        save(JsonUtils.toJsonString(message));
+    }
+
+    private String save(String json) throws Exception {
+        String res = api.save("BD_CommonContact", json);
+        RepoRet repoRet = JsonUtils.fromJsonString(res, new TypeReference<>() {
+        });
+        if (!repoRet.getResult().getResponseStatus().isIsSuccess()) {
+            ThirdPartyErrorCodeEnum errorCodeEnum = ThirdPartyErrorCodeEnum.getByCode(repoRet.getResult().getResponseStatus().getErrorCode());
+            throw new ThirdPartyException(errorCodeEnum.desc);
+        }
+        log.info("联系人保存接口已完成,{}", res);
+        return repoRet.getResult().getResponseStatus().getSuccessEntitys().get(0).getId();
+    }
+
+    private void unAudit(String FNumber) throws Exception {
+        var para = new OperateParam();
+        List<String> Numbers = List.of(FNumber);
+        para.setNumbers(Numbers);
+        OperatorResult res = api.unAudit("BD_CommonContact", para);
+        if (!res.getResult().getResponseStatus().isIsSuccess()) {
+            ThirdPartyErrorCodeEnum errorCodeEnum = ThirdPartyErrorCodeEnum.getByCode(res.getResult().getResponseStatus().getErrorCode());
+            throw new ThirdPartyException(errorCodeEnum.desc);
+        }
+        log.info("联系人反审核接口已完成,{}", res);
+    }
+}
+package com.diligrp.etrade.thirdparty.utils;
+
+import com.diligrp.etrade.core.util.JsonUtils;
+import com.diligrp.etrade.thirdparty.error.ThirdPartyException;
+import com.diligrp.etrade.thirdparty.message.GeneralSendMessage;
+import com.diligrp.etrade.thirdparty.type.ThirdPartyErrorCodeEnum;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.kingdee.bos.webapi.entity.IdentifyInfo;
+import com.kingdee.bos.webapi.entity.OperateParam;
+import com.kingdee.bos.webapi.entity.OperatorResult;
+import com.kingdee.bos.webapi.entity.RepoRet;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 客户 API 实用程序
+ *
+ * @author zhangmeiyang
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-15 11:09
+ * @Version: todo
+ * @date 2024/10/23
+ */
+public class CustomerApiUtils extends BaseApiUtils {
+    private static final Logger log = LoggerFactory.getLogger(CustomerApiUtils.class);
+
+    public CustomerApiUtils(IdentifyInfo identifyInfo) {
+        super(identifyInfo);
+    }
+
+    public String createCustomer(String json) throws Exception {
+        Map<String, Object> map = JsonUtils.fromJsonString(json, new TypeReference<>() {});
+        var message = new GeneralSendMessage();
+        message.setModel(map);
+        message.setAutoSubmitAndAudit(true);
+        return save(JsonUtils.toJsonString(message));
+    }
+
+    public void updateCustomer(String FNumber, String updateJson) throws Exception {
+        unAudit(FNumber);
+        Map<String, Object> map = JsonUtils.fromJsonString(updateJson, new TypeReference<>() {
+        });
+        var message = new GeneralSendMessage();
+        message.setModel(map);
+        message.setAutoSubmitAndAudit(true);
+        save(JsonUtils.toJsonString(message));
+    }
+
+    private String save(String json) throws Exception {
+        String res = api.save("BD_Customer", json);
+        RepoRet repoRet = JsonUtils.fromJsonString(res, new TypeReference<>() {
+        });
+        if (!repoRet.getResult().getResponseStatus().isIsSuccess()) {
+            ThirdPartyErrorCodeEnum errorCodeEnum = ThirdPartyErrorCodeEnum.getByCode(repoRet.getResult().getResponseStatus().getErrorCode());
+            throw new ThirdPartyException(errorCodeEnum.desc);
+        }
+        log.info("客户保存接口已完成,{}", res);
+        return repoRet.getResult().getResponseStatus().getSuccessEntitys().get(0).getId();
+    }
+
+    private void unAudit(String FNumber) throws Exception {
+        var para = new OperateParam();
+        List<String> Numbers = List.of(FNumber);
+        para.setNumbers(Numbers);
+        OperatorResult res = api.unAudit("BD_Customer", para);
+        if (!res.getResult().getResponseStatus().isIsSuccess()) {
+            ThirdPartyErrorCodeEnum errorCodeEnum = ThirdPartyErrorCodeEnum.getByCode(res.getResult().getResponseStatus().getErrorCode());
+            throw new ThirdPartyException(errorCodeEnum.desc);
+        }
+        log.info("客户反审核接口已完成,{}", res);
+    }
+}
+package com.diligrp.etrade.thirdparty.utils;
+
+import com.diligrp.etrade.core.util.JsonUtils;
+import com.diligrp.etrade.thirdparty.error.ThirdPartyException;
+import com.diligrp.etrade.thirdparty.message.GeneralSendMessage;
+import com.diligrp.etrade.thirdparty.type.ThirdPartyErrorCodeEnum;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.kingdee.bos.webapi.entity.IdentifyInfo;
+import com.kingdee.bos.webapi.entity.OperateParam;
+import com.kingdee.bos.webapi.entity.OperatorResult;
+import com.kingdee.bos.webapi.entity.RepoRet;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * settle 类型 API utils
+ *
+ * @author zhangmeiyang
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-16 16:12
+ * @Version: todo
+ * @date 2024/10/23
+ */
+public class DepartmentApiUtils extends BaseApiUtils {
+    private static final Logger log = LoggerFactory.getLogger(FeeApiUtils.class);
+
+    public DepartmentApiUtils(IdentifyInfo identifyInfo) {
+        super(identifyInfo);
+    }
+
+    public String createDepartment(String json) throws Exception {
+        Map<String, Object> map = JsonUtils.fromJsonString(json, new TypeReference<>() {
+        });
+        var message = new GeneralSendMessage();
+        message.setModel(map);
+        message.setAutoSubmitAndAudit(true);
+        return save(JsonUtils.toJsonString(message));
+    }
+
+    public void updateDepartment(String FNumber, String updateJson) throws Exception {
+        unAudit(FNumber);
+        Map<String, Object> map = JsonUtils.fromJsonString(updateJson, new TypeReference<>() {
+        });
+        var message = new GeneralSendMessage();
+        message.setModel(map);
+        message.setAutoSubmitAndAudit(true);
+        save(JsonUtils.toJsonString(message));
+    }
+
+    private String save(String json) throws Exception {
+        String res = api.save("BD_Department", json);
+        RepoRet repoRet = JsonUtils.fromJsonString(res, new TypeReference<>() {});
+        if (!repoRet.getResult().getResponseStatus().isIsSuccess()) {
+            ThirdPartyErrorCodeEnum errorCodeEnum = ThirdPartyErrorCodeEnum.getByCode(repoRet.getResult().getResponseStatus().getErrorCode());
+            throw new ThirdPartyException(errorCodeEnum.desc);
+        }
+        log.info("部门保存接口已完成,{}", res);
+        return repoRet.getResult().getResponseStatus().getSuccessEntitys().get(0).getId();
+    }
+
+    private void unAudit(String FNumber) throws Exception {
+        var para = new OperateParam();
+        List<String> Numbers = List.of(FNumber);
+        para.setNumbers(Numbers);
+        OperatorResult res = api.unAudit("BD_Department", para);
+        if (!res.getResult().getResponseStatus().isIsSuccess()) {
+            ThirdPartyErrorCodeEnum errorCodeEnum = ThirdPartyErrorCodeEnum.getByCode(res.getResult().getResponseStatus().getErrorCode());
+            throw new ThirdPartyException(errorCodeEnum.desc);
+        }
+        log.info("部门反审核接口已完成,{}", res);
+    }
+}
+package com.diligrp.etrade.thirdparty.utils;
+
+import com.diligrp.etrade.core.util.JsonUtils;
+import com.diligrp.etrade.thirdparty.error.ThirdPartyException;
+import com.diligrp.etrade.thirdparty.message.GeneralSendMessage;
+import com.diligrp.etrade.thirdparty.type.ThirdPartyErrorCodeEnum;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.kingdee.bos.webapi.entity.IdentifyInfo;
+import com.kingdee.bos.webapi.entity.OperateParam;
+import com.kingdee.bos.webapi.entity.OperatorResult;
+import com.kingdee.bos.webapi.entity.RepoRet;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 费用 API 实用程序
+ *
+ * @author zhangmeiyang
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-16 15:25
+ * @Version: todo
+ * @date 2024/10/23
+ */
+public class FeeApiUtils extends BaseApiUtils {
+    private static final Logger log = LoggerFactory.getLogger(FeeApiUtils.class);
+
+    public FeeApiUtils(IdentifyInfo identifyInfo) {
+        super(identifyInfo);
+    }
+
+
+    public String createFee(String json) throws Exception {
+        Map<String, Object> map = JsonUtils.fromJsonString(json, new TypeReference<>() {
+        });
+        var message = new GeneralSendMessage();
+        message.setModel(map);
+        message.setAutoSubmitAndAudit(true);
+        return save(JsonUtils.toJsonString(message));
+    }
+
+    public void updateFee(String FNumber, String updateJson) throws Exception {
+        unAudit(FNumber);
+        Map<String, Object> map = JsonUtils.fromJsonString(updateJson, new TypeReference<>() {
+        });
+        var message = new GeneralSendMessage();
+        message.setModel(map);
+        message.setAutoSubmitAndAudit(true);
+        save(JsonUtils.toJsonString(message));
+    }
+
+    private String save(String json) throws Exception {
+        String res = api.save("BD_Expense", json);
+        RepoRet repoRet = JsonUtils.fromJsonString(res, new TypeReference<>() {
+        });
+        if (!repoRet.getResult().getResponseStatus().isIsSuccess()) {
+            ThirdPartyErrorCodeEnum errorCodeEnum = ThirdPartyErrorCodeEnum.getByCode(repoRet.getResult().getResponseStatus().getErrorCode());
+            throw new ThirdPartyException(errorCodeEnum.desc);
+        }
+        log.info("费用项目保存接口已完成,{}", res);
+        return repoRet.getResult().getResponseStatus().getSuccessEntitys().get(0).getId();
+    }
+
+    private void unAudit(String FNumber) throws Exception {
+        var para = new OperateParam();
+        List<String> Numbers = List.of(FNumber);
+        para.setNumbers(Numbers);
+        OperatorResult res = api.unAudit("BD_Expense", para);
+        if (!res.getResult().getResponseStatus().isIsSuccess()) {
+            ThirdPartyErrorCodeEnum errorCodeEnum = ThirdPartyErrorCodeEnum.getByCode(res.getResult().getResponseStatus().getErrorCode());
+            throw new ThirdPartyException(errorCodeEnum.desc);
+        }
+        log.info("费用项目反审核接口已完成,{}", res);
+    }
+}
+package com.diligrp.etrade.thirdparty.utils;
+
+import com.diligrp.etrade.core.util.JsonUtils;
+import com.diligrp.etrade.thirdparty.error.ThirdPartyException;
+import com.diligrp.etrade.thirdparty.message.GeneralSendMessage;
+import com.diligrp.etrade.thirdparty.type.ThirdPartyErrorCodeEnum;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.kingdee.bos.webapi.entity.IdentifyInfo;
+import com.kingdee.bos.webapi.entity.RepoRet;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.Map;
+
+/**
+ * 费用组 API 实用程序
+ *
+ * @author zhangmeiyang
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-16 15:25
+ * @Version: todo
+ * @date 2024/10/23
+ */
+public class FeeGroupApiUtils extends BaseApiUtils {
+    private static final Logger log = LoggerFactory.getLogger(FeeGroupApiUtils.class);
+
+    public FeeGroupApiUtils(IdentifyInfo identifyInfo) {
+        super(identifyInfo);
+    }
+
+
+    /**
+     * 包含 新增、修改
+     *
+     * @param json
+     * @return {@link String}
+     * @throws Exception
+     */
+    public String saveFeeGroup(String json) throws Exception {
+        Map<String, Object> map = JsonUtils.fromJsonString(json, new TypeReference<>() {
+        });
+        var message = new GeneralSendMessage();
+        message.setModel(map);
+        message.setAutoSubmitAndAudit(true);
+        return save(JsonUtils.toJsonString(message));
+    }
+
+    private String save(String json) throws Exception {
+        String res = api.groupSave("BD_Expense", json);
+        RepoRet repoRet = JsonUtils.fromJsonString(res, new TypeReference<>() {
+        });
+        if (!repoRet.getResult().getResponseStatus().isIsSuccess()) {
+            ThirdPartyErrorCodeEnum errorCodeEnum = ThirdPartyErrorCodeEnum.getByCode(repoRet.getResult().getResponseStatus().getErrorCode());
+            throw new ThirdPartyException(errorCodeEnum.desc);
+        }
+        log.info("费用项目保存接口已完成,{}", res);
+        return repoRet.getResult().getResponseStatus().getSuccessEntitys().get(0).getId();
+    }
+
+}
+package com.diligrp.etrade.thirdparty.utils;
+
+import com.diligrp.etrade.core.util.JsonUtils;
+import com.diligrp.etrade.thirdparty.error.ThirdPartyException;
+import com.diligrp.etrade.thirdparty.message.GeneralSendMessage;
+import com.diligrp.etrade.thirdparty.type.ThirdPartyErrorCodeEnum;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.kingdee.bos.webapi.entity.IdentifyInfo;
+import com.kingdee.bos.webapi.entity.RepoRet;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.Map;
+
+/**
+ * 采购订单 API 实用程序
+ *
+ * @author zhangmeiyang
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-15 11:09
+ * @Version: todo
+ * @date 2024/10/23
+ */
+public class PurchaseOrderApiUtils extends BaseApiUtils {
+    private static final Logger log = LoggerFactory.getLogger(PurchaseOrderApiUtils.class);
+
+    public PurchaseOrderApiUtils(IdentifyInfo identifyInfo) {
+        super(identifyInfo);
+    }
+
+
+    public void createOnePurchaseOrder(String json) throws Exception {
+        Map<String, Object> map = JsonUtils.fromJsonString(json, new TypeReference<>() {
+        });
+        var message = new GeneralSendMessage();
+        message.setModel(map);
+        message.setAutoSubmitAndAudit(true);
+        save(JsonUtils.toJsonString(message));
+    }
+
+    private void save(String json) throws Exception {
+        String res = api.save("PUR_PurchaseOrder", json);
+        RepoRet repoRet = JsonUtils.fromJsonString(res, new TypeReference<>() {});
+        if (!repoRet.getResult().getResponseStatus().isIsSuccess()) {
+            ThirdPartyErrorCodeEnum errorCodeEnum = ThirdPartyErrorCodeEnum.getByCode(repoRet.getResult().getResponseStatus().getErrorCode());
+            throw new ThirdPartyException(errorCodeEnum.desc);
+        }
+        log.info("采购订单接口已完成,{}", repoRet);
+    }
+}
+package com.diligrp.etrade.thirdparty.utils;
+
+import com.diligrp.etrade.core.util.JsonUtils;
+import com.diligrp.etrade.thirdparty.error.ThirdPartyException;
+import com.diligrp.etrade.thirdparty.message.GeneralSendMessage;
+import com.diligrp.etrade.thirdparty.type.ThirdPartyErrorCodeEnum;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.kingdee.bos.webapi.entity.IdentifyInfo;
+import com.kingdee.bos.webapi.entity.OperateParam;
+import com.kingdee.bos.webapi.entity.OperatorResult;
+import com.kingdee.bos.webapi.entity.RepoRet;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * settle 类型 API utils
+ *
+ * @author zhangmeiyang
+ * @Author: zhangmeiyang
+ * @CreateTime: 2024-10-16 16:12
+ * @Version: todo
+ * @date 2024/10/23
+ */
+public class SettleTypeApiUtils extends BaseApiUtils {
+    private static final Logger log = LoggerFactory.getLogger(FeeApiUtils.class);
+
+    public SettleTypeApiUtils(IdentifyInfo identifyInfo) {
+        super(identifyInfo);
+    }
+
+    public String createSettleType(String json) throws Exception {
+        Map<String, Object> map = JsonUtils.fromJsonString(json, new TypeReference<>() {
+        });
+        var message = new GeneralSendMessage();
+        message.setModel(map);
+        message.setAutoSubmitAndAudit(true);
+        return save(JsonUtils.toJsonString(message));
+    }
+
+    public void updateSettleType(String FNumber, String updateJson) throws Exception {
+        unAudit(FNumber);
+        Map<String, Object> map = JsonUtils.fromJsonString(updateJson, new TypeReference<>() {
+        });
+        var message = new GeneralSendMessage();
+        message.setModel(map);
+        message.setAutoSubmitAndAudit(true);
+        save(JsonUtils.toJsonString(message));
+    }
+
+    private String save(String json) throws Exception {
+        String res = api.save("BD_SETTLETYPE", json);
+        RepoRet repoRet = JsonUtils.fromJsonString(res, new TypeReference<>() {
+        });
+        if (!repoRet.getResult().getResponseStatus().isIsSuccess()) {
+            ThirdPartyErrorCodeEnum errorCodeEnum = ThirdPartyErrorCodeEnum.getByCode(repoRet.getResult().getResponseStatus().getErrorCode());
+            throw new ThirdPartyException(errorCodeEnum.desc);
+        }
+        log.info("单据类型保存接口已完成,{}", res);
+        return repoRet.getResult().getResponseStatus().getSuccessEntitys().get(0).getId();
+    }
+
+    private void unAudit(String FNumber) throws Exception {
+        var para = new OperateParam();
+        List<String> Numbers = List.of(FNumber);
+        para.setNumbers(Numbers);
+        OperatorResult res = api.unAudit("BD_SETTLETYPE", para);
+        if (!res.getResult().getResponseStatus().isIsSuccess()) {
+            ThirdPartyErrorCodeEnum errorCodeEnum = ThirdPartyErrorCodeEnum.getByCode(res.getResult().getResponseStatus().getErrorCode());
+            throw new ThirdPartyException(errorCodeEnum.desc);
+        }
+        log.info("单据类型反审核接口已完成,{}", res);
+    }
+}
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.diligrp.etrade.thirdparty.mapper.RecordMapper">
+
+    <insert id="recordError">
+        INSERT INTO
+            `zr_etrade`.error_message_info ( `market_id`
+                                           , `system_code`
+                                           , `error_message`
+                                           , `data`
+                                            ,`business`)
+        VALUES
+            ( #{co.marketId}
+            , #{co.systemCode}
+            , #{co.errorMessage}
+            , #{co.content}
+            , #{co.business})
+    </insert>
+    <insert id="recordTheMappingData">
+        INSERT INTO `zr_etrade`.`mapping_data` ( `market_id`
+                                               , `system_code`
+                                               , `business`
+                                               , `system_data_id`
+                                               , `third_party_data_id`
+                                               )
+        VALUES
+            ( #{mapping.marketId}
+            , #{mapping.systemCode}
+            , #{mapping.business}
+            , #{mapping.systemDataId}
+            , #{mapping.thirdPartyDataId}
+            )
+    </insert>
+</mapper>
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.diligrp.etrade.thirdparty.mapper.TransMapper">
+    <select id="getClientParam" resultType="com.diligrp.etrade.thirdparty.domain.dto.ClientDto">
+        SELECT
+            data_centre_id  AS dataCentreId
+          , apply_id        AS applyId
+          , organization    AS organization
+          , username        AS username
+          , security_key    AS securityKey
+          , service_address AS serviceAddress
+        FROM
+            `dili-basic-data`.`financial_client` fc
+        WHERE
+              1 = 1
+          AND market_id = #{marketId}
+          AND system_code = #{systemCode}
+    </select>
+    <select id="getDynamicParam" resultType="com.diligrp.etrade.thirdparty.domain.dto.BusinessDetailDto">
+        SELECT
+            fb.code              AS code
+          , fb.name              AS name
+          , fbd.select_type      AS selectType
+          , fbd.item_code        AS itemCode
+          , fbd.item_name        AS itemName
+          , fbd.item_relation_id AS itemRelationId
+          , fbd.item_value       AS itemValue
+        FROM
+            `dili-basic-data`.`financial_business` fb
+                LEFT JOIN `dili-basic-data`.financial_business_detail fbd ON fb.id = fbd.financial_business_id
+        WHERE
+              1 = 1
+          AND fb.market_id = #{marketId}
+          AND fb.code = #{code}
+          AND fb.system_code = #{systemCode}
+    </select>
+    <select id="getDepartment" resultType="com.diligrp.etrade.thirdparty.domain.dto.DepartmentDto">
+        SELECT
+            kd_code AS departmentCode
+          , name    AS departmentName
+          , id      AS id
+        FROM
+            `uap`.`department`
+        WHERE
+              1 = 1
+          AND id = #{departmentId}
+    </select>
+    <select id="getBaseConfig" resultType="com.diligrp.etrade.thirdparty.domain.dto.BaseConfigDto">
+        SELECT
+            currency  AS currency
+          , sync_item AS syncItem
+        FROM
+            `dili-basic-data`.`financial_base_config` fbc
+        WHERE
+              1 = 1
+          AND market_id = #{marketId}
+          AND system_code = #{systemCode}
+    </select>
+    <select id="getCustomer" resultType="com.diligrp.etrade.thirdparty.domain.dto.CustomerDto">
+        SELECT
+            `id`   AS `id`
+          , `code` AS `code`
+        FROM
+            `dili-customer`.`customer`
+        WHERE
+              1 = 1
+          AND id = #{customerId}
+    </select>
+    <select id="getChargeItem" resultType="com.diligrp.etrade.thirdparty.domain.dto.ChargeItemDto">
+        SELECT
+            `id`            AS `id`
+          , `business_type` AS `businessType`
+        FROM
+            `dili-basic-data`.`business_charge_item`
+        WHERE
+              1 = 1
+          AND id = #{chargeItemId}
+    </select>
+    <select id="getMappingData" resultType="com.diligrp.etrade.thirdparty.domain.dto.MappingDto">
+        SELECT
+            `market_id`           AS `marketId`
+          , `system_code`         AS `systemCode`
+          , `business`            AS `business`
+          , `system_data_id`      AS `systemDataId`
+          , `third_party_data_id` AS `thirdPartyDataId`
+        FROM
+            `zr_etrade`.`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}
+    </select>
+</mapper>