feat(kingdee):优化客户和单据构建逻辑并调整金蝶连接管理

- 修改 BaseCustomer 类中的字段访问权限为 protected，并注释掉 currency 字段 - 在 Builder 和具体实现类中增加对 TenantPipeline 的支持以配置默认数据 - 更新 CustomerBuilder、ReceiptBuilder 等类以通过反射方式设置对象属性 - 调整 KingDeeConnectionManager 返回 IdentifyInfo 而非 K3CloudApi 实例 - 修改 CustomerSender 及其他 Sender 类处理联系人信息的方式- 在 ProxyProcessor 和 InitializeProcessor 中传递 pipelineCode 参数 - 增加 ITenantTaxService 接口获取租户 ID 方法- 扩展 MessageContext 类新增 group、entity 和 pipelineCode 属性-优化 MappingUtils 工具类以支持父类字段映射 - 在 KingDeeHelper 中添加日志记录以便调试审核发送过程

feat(kingdee):优化客户和单据构建逻辑并调整金蝶连接管理
- 修改 BaseCustomer 类中的字段访问权限为 protected，并注释掉 currency 字段 - 在 Builder 和具体实现类中增加对 TenantPipeline 的支持以配置默认数据 - 更新 CustomerBuilder、ReceiptBuilder 等类以通过反射方式设置对象属性 - 调整 KingDeeConnectionManager 返回 IdentifyInfo 而非 K3CloudApi 实例 - 修改 CustomerSender 及其他 Sender 类处理联系人信息的方式- 在 ProxyProcessor 和 InitializeProcessor 中传递 pipelineCode 参数 - 增加 ITenantTaxService 接口获取租户 ID 方法- 扩展 MessageContext 类新增 group、entity 和 pipelineCode 属性-优化 MappingUtils 工具类以支持父类字段映射 - 在 KingDeeHelper 中添加日志记录以便调试审核发送过程
zhangmeiyang
1 parent 0134403a
Showing 26 changed files with 338 additions and 94 deletions
tax-boot/src/main/java/com/diligrp/tax/boot/receiver/TaxReceiver.java
tax-central/src/main/java/com/diligrp/tax/central/converter/impl/CustomerCountryConverter.java
tax-central/src/main/java/com/diligrp/tax/central/converter/impl/CustomerGroupConverter.java
tax-central/src/main/java/com/diligrp/tax/central/converter/impl/StringConverter.java
tax-central/src/main/java/com/diligrp/tax/central/domain/BaseMapping.java
tax-central/src/main/java/com/diligrp/tax/central/domain/MessageContext.java
tax-central/src/main/java/com/diligrp/tax/central/domain/document/kingdee/BaseCustomer.java
tax-central/src/main/java/com/diligrp/tax/central/domain/mapping/kingdee/CustomerMapping.java
tax-central/src/main/java/com/diligrp/tax/central/manager/impl/KingDeeConnectionManager.java
tax-central/src/main/java/com/diligrp/tax/central/service/ITenantTaxService.java
tax-central/src/main/java/com/diligrp/tax/central/type/TaxSystemType.java
tax-central/src/main/java/com/diligrp/tax/central/utils/MappingUtils.java
tax-doc/src/main/java/com/diligrp/tax/doc/demarcate/Builder.java
tax-doc/src/main/java/com/diligrp/tax/doc/demarcate/kingdee/CustomerBuilder.java
tax-doc/src/main/java/com/diligrp/tax/doc/demarcate/kingdee/ReceiptBuilder.java
tax-doc/src/main/java/com/diligrp/tax/doc/demarcate/kingdee/ReceivableBuilder.java
tax-doc/src/main/java/com/diligrp/tax/doc/demarcate/kingdee/RefundBuilder.java
tax-doc/src/main/java/com/diligrp/tax/doc/process/kingdee/InitializeProcessor.java
tax-proxy/src/main/java/com/diligrp/tax/proxy/demarcate/Sender.java
tax-proxy/src/main/java/com/diligrp/tax/proxy/demarcate/kingdee/CustomerSender.java
@@ -5,6 +5,7 @@ import com.diligrp.tax.central.process.ProcessorChain;
 import com.diligrp.tax.central.type.StatusType;
 import com.diligrp.tax.central.type.SystemType;
 import com.diligrp.tax.central.utils.JsonUtils;
+import com.diligrp.tax.storage.service.TenantTaxService;
 import com.rabbitmq.client.Channel;
 import jakarta.annotation.Resource;
 import lombok.extern.slf4j.Slf4j;
@@ -36,6 +37,9 @@ public class TaxReceiver {
     @Resource
     private Map<SystemType, ProcessorChain> processorChainMap;
+    @Resource
+    private TenantTaxService tenantTaxService;
+
     @RabbitListener(bindings =
     @QueueBinding(
             value = @Queue(value = NORMAL_QUEUE, autoDelete = "false"),
@@ -59,6 +63,7 @@ public class TaxReceiver {
     }
     private void handle(MessageContext ctx) {
+        ctx.setTenantId(tenantTaxService.getTenantId(ctx.getGroup(), ctx.getEntity()));
         MessageContext messageContext = processorChainMap.get(SystemType.from(ctx.getSystemType())).startProcess(ctx);
         messageContext.setStatus(StatusType.SUCCESS.code);
         //TODO write to db
@@ -2,7 +2,6 @@ package com.diligrp.tax.central.converter.impl;
 import com.diligrp.tax.central.converter.IConverter;
 import com.diligrp.tax.central.domain.mapping.kingdee.base.FCOUNTRY;
-import com.diligrp.tax.central.domain.mapping.kingdee.base.FTRADINGCURRID;
 import org.springframework.stereotype.Component;
 import java.util.Objects;
 package com.diligrp.tax.central.converter.impl;
 import com.diligrp.tax.central.converter.IConverter;
-import com.diligrp.tax.central.domain.mapping.kingdee.base.FContactId;
 import com.diligrp.tax.central.domain.mapping.kingdee.base.FGroup;
 import org.springframework.stereotype.Component;
@@ -15,7 +15,7 @@ public class StringConverter implements IConverter&lt;String&gt; {
     @Override
     public String convert(Object source) {
         if (Objects.isNull(source)) {
-            return "";
+            return null;
         }
         return (String) source;
     }
 package com.diligrp.tax.central.domain;
-import com.diligrp.tax.central.model.TenantPipeline;
 import lombok.Getter;
 import lombok.Setter;
@@ -11,10 +11,22 @@ public class MessageContext {
      */
     private String thirdPartyCode;
     /**
+     * 分组
+     */
+    private String group;
+    /**
+     * 实体
+     */
+    private String entity;
+    /**
      * 租户 ID
      */
     private Long tenantId;
     /**
+     * 租户账套编码
+     */
+    private String pipelineCode;
+    /**
      * 消息信息
      */
     private String msgBody;
@@ -17,80 +17,80 @@ public abstract class BaseCustomer extends BaseDocument {
     /**
      * 系统数据 ID
      */
-    private String systemDataId;
-    /**
-     * 结算货币(FTRADINGCURRID)
-     */
-    @Converter(value = CustomerCurrencyConverter.class, targetField = "FTRADINGCURRID")
-    private String currency;
+    protected String systemDataId;
+//    /**
+//     * 结算货币(FTRADINGCURRID)
+//     */
+//    @Converter(value = CustomerCurrencyConverter.class, targetField = "FTRADINGCURRID")
+//    protected String currency;
     /**
      * 客户 ID(FCUSTID)
      */
     @Converter(value = StringConverter.class, targetField = "FCUSTID")
-    private String customerId;
+    protected String customerId;
     /**
      * 客户编号
      */
     @Converter(value = StringConverter.class, targetField = "FNumber")
-    private String customerCode;
+    protected String customerCode;
     /**
      * 客户姓名(FName)
      */
     @Converter(value = StringConverter.class, targetField = "FName")
-    private String customerName;
+    protected String customerName;
     /**
      * 客户简称(FShortName)
      */
     @Converter(value = StringConverter.class, targetField = "FShortName")
-    private String customerShortName;
+    protected String customerShortName;
     /**
      * 客户发票抬头(FINVOICETITLE)
      */
     @Converter(value = StringConverter.class, targetField = "FINVOICETITLE")
-    private String customerInvoiceTitle;
+    protected String customerInvoiceTitle;
     /**
      * 法人姓名(FLegalPerson)
      */
     @Converter(value = StringConverter.class, targetField = "FLegalPerson")
-    private String legalPerson;
+    protected String legalPerson;
     /**
      * 证件号(FSOCIALCRECODE)
      */
     @Converter(value = StringConverter.class, targetField = "FSOCIALCRECODE")
-    private String idNumber;
+    protected String idNumber;
     /**
      * 国家(FCOUNTRY)
      */
     @Converter(value = CustomerCountryConverter.class, targetField = "FCOUNTRY")
-    private String country;
+    protected String country;
     /**
      * 区域组织(FPROVINCIAL)
      */
     @Converter(value = CustomerProvincialConverter.class, targetField = "FPROVINCIAL")
-    private String provincial;
+    protected String provincial;
     /**
      * 地址(FADDRESS)
      */
     @Converter(value = StringConverter.class, targetField = "FADDRESS")
-    private String address;
+    protected String address;
     /**
      * 注册地址(FRegisterAddress)
      */
     @Converter(value = StringConverter.class, targetField = "FRegisterAddress")
-    private String registerAddress;
+    protected String registerAddress;
     /**
      * 客户分组-配置数据(FGroup)
      */
     @Converter(value = CustomerGroupConverter.class, targetField = "FGroup")
-    private String customerGroup;
+    protected String customerGroup;
     /**
      * 创建组织(FCreateOrgId)
      */
     @Converter(value = CustomerCreateOrgConverter.class, targetField = "FCreateOrgId")
-    private String customerCreateOrg;
+    protected String customerCreateOrg;
     /**
      * 使用组织
      */
     @Converter(value = CustomerUseOrgConverter.class, targetField = "FUseOrgId")
-    private String customerUseOrg;
+    protected String customerUseOrg;
 }
@@ -20,7 +20,7 @@ public class CustomerMapping extends BaseMapping {
     private FUseOrgId FUseOrgId;
     private String FShortName;
     private FCOUNTRY FCOUNTRY;
-    private FTRADINGCURRID FTRADINGCURRID;
+//    private FTRADINGCURRID FTRADINGCURRID;
     private FPROVINCIAL FPROVINCIAL;
     private String FADDRESS;
     private FGroup FGroup;
@@ -102,14 +102,14 @@ public class CustomerMapping extends BaseMapping {
         this.FCOUNTRY = FCOUNTRY;
     }
-    @JsonProperty("FTRADINGCURRID")
-    public FTRADINGCURRID getFTRADINGCURRID() {
-        return FTRADINGCURRID;
-    }
-
-    public void setFTRADINGCURRID(FTRADINGCURRID FTRADINGCURRID) {
-        this.FTRADINGCURRID = FTRADINGCURRID;
-    }
+//    @JsonProperty("FTRADINGCURRID")
+//    public FTRADINGCURRID getFTRADINGCURRID() {
+//        return FTRADINGCURRID;
+//    }
+//
+//    public void setFTRADINGCURRID(FTRADINGCURRID FTRADINGCURRID) {
+//        this.FTRADINGCURRID = FTRADINGCURRID;
+//    }
     @JsonProperty("FPROVINCIAL")
     public FPROVINCIAL getFPROVINCIAL() {
@@ -5,7 +5,6 @@ import com.diligrp.tax.central.model.TenantPipeline;
 import com.diligrp.tax.central.type.SystemType;
 import com.diligrp.tax.central.utils.JsonUtils;
 import com.kingdee.bos.webapi.entity.IdentifyInfo;
-import com.kingdee.bos.webapi.sdk.K3CloudApi;
 import org.springframework.stereotype.Component;
 /**
@@ -14,15 +13,14 @@ import org.springframework.stereotype.Component;
  * @Version: todo
  */
 @Component
-public class KingDeeConnectionManager extends AbstractConnectionManager<K3CloudApi> {
+public class KingDeeConnectionManager extends AbstractConnectionManager<IdentifyInfo> {
     @Override
     public SystemType markSystemType() {
         return SystemType.KING_DEE;
     }
     @Override
-    public K3CloudApi getConnection(TenantPipeline tenantPipeline) {
-        IdentifyInfo identifyInfo = JsonUtils.convertValue(tenantPipeline.getParams(), IdentifyInfo.class);
-        return new K3CloudApi(identifyInfo);
+    public IdentifyInfo getConnection(TenantPipeline tenantPipeline) {
+        return JsonUtils.convertValue(tenantPipeline.getParams(), IdentifyInfo.class);
     }
 }
@@ -13,6 +13,15 @@ import java.util.List;
 public interface ITenantTaxService {
     /**
+     * 获取租户 ID
+     *
+     * @param group  群
+     * @param entity 实体
+     * @return {@link Long }
+     */
+    Long getTenantId(String group,String entity);
+
+    /**
      * 列出所有启用管道
      *
      * @return {@link List }<{@link TenantPipeline }>
@@ -17,6 +17,7 @@ public enum TaxSystemType {
     REMOTE_SERVICE_CALLS_ARE_EXCEPTIONAL(5006, "远程服务调用异常"),
     INVALID_HTTP_REQUEST_PARAMS(5007, "无效的http请求参数"),
     NO_MATCHING_SET_OF_ACCOUNTS_FOUND(5008, "未找到匹配账套"),
+    NO_TENANT_INFORMATION_FOUND(5009, "未找到匹配账套"),
     ;
     public final int code;
     public final String message;
@@ -18,6 +18,7 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.function.Function;
+import java.util.stream.Stream;
 /**
  * @Author: zhangmeiyang
@@ -64,8 +65,12 @@ public class MappingUtils {
     public static <T extends BaseDocument, R extends BaseMapping> R convertValue(T t, Class<R> clazz) {
         Map<String, Object> map = new HashMap<>();
-        Arrays.stream(t.getClass().getDeclaredFields()).filter(field -> field.isAnnotationPresent(Converter.class)).forEach(field -> configureField(t, field, map));
-        Arrays.stream(t.getClass().getDeclaredFields()).filter(field -> field.isAnnotationPresent(SubConverter.class)).forEach(field -> configureSubField(t, field, map));
+        Field[] allFields = Stream.concat(
+                Arrays.stream(t.getClass().getDeclaredFields()),
+                Arrays.stream(t.getClass().getSuperclass().getDeclaredFields())
+        ).toArray(Field[]::new);
+        Arrays.stream(allFields).filter(field -> field.isAnnotationPresent(Converter.class)).forEach(field -> configureField(t, field, map));
+        Arrays.stream(allFields).filter(field -> field.isAnnotationPresent(SubConverter.class)).forEach(field -> configureSubField(t, field, map));
         return JsonUtils.convertValue(map, clazz);
     }
 }
 package com.diligrp.tax.doc.demarcate;
 import com.diligrp.tax.central.domain.BaseDocument;
+import com.diligrp.tax.central.model.TenantPipeline;
 import com.diligrp.tax.central.type.DocumentType;
 /**
@@ -20,8 +21,9 @@ public abstract class Builder&lt;T extends BaseDocument&gt; {
     /**
      * 建
      *
-     * @param body 身体
+     * @param body     身体
+     * @param pipeline
      * @return {@link T }
      */
-    public abstract T build(String body);
+    public abstract T build(String body, TenantPipeline pipeline);
 }
 package com.diligrp.tax.doc.demarcate.kingdee;
 import com.diligrp.tax.central.domain.document.kingdee.basic.StandardCustomer;
+import com.diligrp.tax.central.domain.document.kingdee.basic.item.Contact;
 import com.diligrp.tax.central.exception.TaxAgentServiceException;
+import com.diligrp.tax.central.model.TenantPipeline;
+import com.diligrp.tax.central.model.TenantPipelineConfig;
 import com.diligrp.tax.central.type.DocumentType;
 import com.diligrp.tax.central.type.TaxSystemType;
 import com.diligrp.tax.central.utils.JsonUtils;
 import com.diligrp.tax.doc.demarcate.Builder;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
+import java.lang.reflect.Field;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
 import java.util.Optional;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
 /**
  * @Author: zhangmeiyang
@@ -16,6 +26,7 @@ import java.util.Optional;
  * @Version: todo
  */
 @Component
+@Slf4j
 public class CustomerBuilder extends Builder<StandardCustomer> {
     @Override
@@ -24,13 +35,50 @@ public class CustomerBuilder extends Builder&lt;StandardCustomer&gt; {
     }
     @Override
-    public StandardCustomer build(String body) {
+    public StandardCustomer build(String body, TenantPipeline pipeline) {
         StandardCustomer customer = JsonUtils.fromJsonString(body, StandardCustomer.class);
         Optional.ofNullable(customer.getContacts()).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.MISSING_BUSINESS_INFORMATION, "请完善联系人信息"));
-        Optional.ofNullable(customer.getSystemDataId()).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.MISSING_BUSINESS_INFORMATION, "请填写系统数据ID"));
-        //TODO 获取币别
-
+//        Optional.ofNullable(customer.getSystemDataId()).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.MISSING_BUSINESS_INFORMATION, "请填写系统数据ID"));
+        List<TenantPipelineConfig> list = pipeline.getTenantPipelineConfigs().get(markDocument());
+        Optional.ofNullable(list).ifPresent(ts -> configureDefaultData(customer, ts));
         //TODO 查询数据库的客户信息 如果存在 赋值id
         return customer;
     }
+
+    private void configureDefaultData(StandardCustomer customer, List<TenantPipelineConfig> list) {
+        Map<String, String> kvMap = list.stream().collect(Collectors.toMap(TenantPipelineConfig::getConfigKey, TenantPipelineConfig::getConfigValue));
+        Field[] allFields = Stream.concat(
+                Arrays.stream(customer.getClass().getDeclaredFields()),
+                Arrays.stream(customer.getClass().getSuperclass().getDeclaredFields())
+        ).toArray(Field[]::new);
+        Arrays.stream(allFields).forEach(field -> reflectField(customer, field, kvMap));
+        List<Contact> refundItems = customer.getContacts();
+        refundItems.forEach(item -> {
+            Field[] declaredFields1 = item.getClass().getDeclaredFields();
+            Arrays.stream(declaredFields1).forEach(field -> reflectField(item, field, kvMap));
+        });
+    }
+
+    public static void reflectField(StandardCustomer object, Field field, Map<String, String> kvMap) {
+        if (kvMap.containsKey(field.getName())) {
+            field.setAccessible(true);
+            try {
+                field.set(object, kvMap.get(field.getName()));
+            } catch (IllegalAccessException e) {
+                throw new TaxAgentServiceException(TaxSystemType.BUSINESS_MATCHES_ARE_INCORRECT, e.getMessage());
+            }
+        }
+    }
+
+
+    public static void reflectField(Contact object, Field field, Map<String, String> kvMap) {
+        if (kvMap.containsKey(field.getName())) {
+            field.setAccessible(true);
+            try {
+                field.set(object, kvMap.get(field.getName()));
+            } catch (IllegalAccessException e) {
+                throw new TaxAgentServiceException(TaxSystemType.BUSINESS_MATCHES_ARE_INCORRECT, e.getMessage());
+            }
+        }
+    }
 }
 package com.diligrp.tax.doc.demarcate.kingdee;
 import com.diligrp.tax.central.domain.document.kingdee.bill.ReceiptBill;
+import com.diligrp.tax.central.domain.document.kingdee.bill.item.ReceiptItem;
 import com.diligrp.tax.central.exception.TaxAgentServiceException;
+import com.diligrp.tax.central.model.TenantPipeline;
+import com.diligrp.tax.central.model.TenantPipelineConfig;
 import com.diligrp.tax.central.type.DocumentType;
 import com.diligrp.tax.central.type.TaxSystemType;
 import com.diligrp.tax.central.utils.JsonUtils;
 import com.diligrp.tax.doc.demarcate.Builder;
 import org.springframework.stereotype.Component;
+import java.lang.reflect.Field;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
 import java.util.Optional;
+import java.util.stream.Collectors;
 /**
  * @Author: zhangmeiyang
@@ -25,14 +33,46 @@ public class ReceiptBuilder extends Builder&lt;ReceiptBill&gt; {
     }
     @Override
-    public ReceiptBill build(String body) {
+    public ReceiptBill build(String body, TenantPipeline pipeline) {
         ReceiptBill bill = JsonUtils.fromJsonString(body, ReceiptBill.class);
-        Optional.ofNullable(bill.getReceiptItems()).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.MISSING_BUSINESS_INFORMATION,"请填写收款项目"));
+        Optional.ofNullable(bill.getReceiptItems()).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.MISSING_BUSINESS_INFORMATION, "请填写收款项目"));
         bill.setCreateTime(Optional.ofNullable(bill.getCreateTime()).orElse(LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))));
-        //TODO 获取币别
-        //TODO 获取组织
-        //TODO 部门转换
-        //TODO 业务类型转换
+        List<TenantPipelineConfig> list = pipeline.getTenantPipelineConfigs().get(markDocument());
+        Optional.ofNullable(list).ifPresent(ts -> configureDefaultData(bill, ts));
         return bill;
     }
+
+    private void configureDefaultData(ReceiptBill bill, List<TenantPipelineConfig> list) {
+        Map<String, String> kvMap = list.stream().collect(Collectors.toMap(TenantPipelineConfig::getConfigKey, TenantPipelineConfig::getConfigValue));
+        Field[] declaredFields = bill.getClass().getDeclaredFields();
+        Arrays.stream(declaredFields).forEach(field -> reflectField(bill, field, kvMap));
+        List<ReceiptItem> refundItems = bill.getReceiptItems();
+        refundItems.forEach(item -> {
+            Field[] declaredFields1 = item.getClass().getDeclaredFields();
+            Arrays.stream(declaredFields1).forEach(field -> reflectField(item, field, kvMap));
+        });
+    }
+
+    public static void reflectField(ReceiptBill object, Field field, Map<String, String> kvMap) {
+        if (kvMap.containsKey(field.getName())) {
+            field.setAccessible(true);
+            try {
+                field.set(object, kvMap.get(field.getName()));
+            } catch (IllegalAccessException e) {
+                throw new TaxAgentServiceException(TaxSystemType.BUSINESS_MATCHES_ARE_INCORRECT, e.getMessage());
+            }
+        }
+    }
+
+
+    public static void reflectField(ReceiptItem object, Field field, Map<String, String> kvMap) {
+        if (kvMap.containsKey(field.getName())) {
+            field.setAccessible(true);
+            try {
+                field.set(object, kvMap.get(field.getName()));
+            } catch (IllegalAccessException e) {
+                throw new TaxAgentServiceException(TaxSystemType.BUSINESS_MATCHES_ARE_INCORRECT, e.getMessage());
+            }
+        }
+    }
 }
 package com.diligrp.tax.doc.demarcate.kingdee;
+import com.diligrp.tax.central.domain.document.kingdee.bill.ReceiptBill;
+import com.diligrp.tax.central.domain.document.kingdee.bill.ReceivableBill;
+import com.diligrp.tax.central.domain.document.kingdee.bill.item.ReceiptItem;
+import com.diligrp.tax.central.domain.document.kingdee.bill.item.ReceivableItem;
 import com.diligrp.tax.central.exception.TaxAgentServiceException;
+import com.diligrp.tax.central.model.TenantPipeline;
+import com.diligrp.tax.central.model.TenantPipelineConfig;
 import com.diligrp.tax.central.type.DocumentType;
 import com.diligrp.tax.central.type.TaxSystemType;
 import com.diligrp.tax.central.utils.JsonUtils;
+import com.diligrp.tax.central.utils.MappingUtils;
 import com.diligrp.tax.doc.demarcate.Builder;
-import com.diligrp.tax.central.domain.document.kingdee.bill.ReceivableBill;
 import org.springframework.stereotype.Component;
+import java.lang.reflect.Field;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
 import java.util.Optional;
+import java.util.stream.Collectors;
 /**
  * @Author: zhangmeiyang
@@ -26,14 +37,47 @@ public class ReceivableBuilder extends Builder&lt;ReceivableBill&gt; {
     }
     @Override
-    public ReceivableBill build(String body) {
+    public ReceivableBill build(String body, TenantPipeline pipeline) {
         ReceivableBill bill = JsonUtils.fromJsonString(body, ReceivableBill.class);
-        Optional.ofNullable(bill.getReceivableItems()).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.MISSING_BUSINESS_INFORMATION,"请填写收款项目"));
+        Optional.ofNullable(bill.getReceivableItems()).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.MISSING_BUSINESS_INFORMATION, "请填写收款项目"));
         bill.setCreateTime(Optional.ofNullable(bill.getCreateTime()).orElse(LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))));
-        //TODO 获取币别
-        //TODO 获取组织
-        //TODO 部门转换
-        //TODO 业务类型转换
+        List<TenantPipelineConfig> list = pipeline.getTenantPipelineConfigs().get(markDocument());
+        Optional.ofNullable(list).ifPresent(ts -> configureDefaultData(bill, ts));
+        //todo动态规则转换
         return bill;
     }
+
+    private void configureDefaultData(ReceivableBill bill, List<TenantPipelineConfig> list) {
+        Map<String, String> kvMap = list.stream().collect(Collectors.toMap(TenantPipelineConfig::getConfigKey, TenantPipelineConfig::getConfigValue));
+        Field[] declaredFields = bill.getClass().getDeclaredFields();
+        Arrays.stream(declaredFields).forEach(field -> reflectField(bill, field, kvMap));
+        List<ReceivableItem> refundItems = bill.getReceivableItems();
+        refundItems.forEach(item -> {
+            Field[] declaredFields1 = item.getClass().getDeclaredFields();
+            Arrays.stream(declaredFields1).forEach(field -> reflectField(item, field, kvMap));
+        });
+    }
+
+    public static void reflectField(ReceivableBill object, Field field, Map<String, String> kvMap) {
+        if (kvMap.containsKey(field.getName())) {
+            field.setAccessible(true);
+            try {
+                field.set(object, kvMap.get(field.getName()));
+            } catch (IllegalAccessException e) {
+                throw new TaxAgentServiceException(TaxSystemType.BUSINESS_MATCHES_ARE_INCORRECT, e.getMessage());
+            }
+        }
+    }
+
+
+    public static void reflectField(ReceivableItem object, Field field, Map<String, String> kvMap) {
+        if (kvMap.containsKey(field.getName())) {
+            field.setAccessible(true);
+            try {
+                field.set(object, kvMap.get(field.getName()));
+            } catch (IllegalAccessException e) {
+                throw new TaxAgentServiceException(TaxSystemType.BUSINESS_MATCHES_ARE_INCORRECT, e.getMessage());
+            }
+        }
+    }
 }
 package com.diligrp.tax.doc.demarcate.kingdee;
+import com.diligrp.tax.central.domain.document.kingdee.bill.ReceivableBill;
 import com.diligrp.tax.central.domain.document.kingdee.bill.RefundBill;
+import com.diligrp.tax.central.domain.document.kingdee.bill.item.ReceivableItem;
+import com.diligrp.tax.central.domain.document.kingdee.bill.item.RefundItem;
 import com.diligrp.tax.central.exception.TaxAgentServiceException;
+import com.diligrp.tax.central.model.TenantPipeline;
+import com.diligrp.tax.central.model.TenantPipelineConfig;
 import com.diligrp.tax.central.type.DocumentType;
 import com.diligrp.tax.central.type.TaxSystemType;
 import com.diligrp.tax.central.utils.JsonUtils;
+import com.diligrp.tax.central.utils.MappingUtils;
 import com.diligrp.tax.doc.demarcate.Builder;
 import org.springframework.stereotype.Component;
+import java.lang.reflect.Field;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
 import java.util.Optional;
+import java.util.stream.Collectors;
 /**
  * @Author: zhangmeiyang
@@ -26,14 +37,47 @@ public class RefundBuilder extends Builder&lt;RefundBill&gt; {
     }
     @Override
-    public RefundBill build(String body) {
+    public RefundBill build(String body, TenantPipeline pipeline) {
         RefundBill bill = JsonUtils.fromJsonString(body, RefundBill.class);
         Optional.ofNullable(bill.getRefundItems()).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.MISSING_BUSINESS_INFORMATION, "请填写收款项目"));
         bill.setCreateTime(Optional.ofNullable(bill.getCreateTime()).orElse(LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))));
-        //TODO 获取币别
-        //TODO 获取组织
-        //TODO 部门转换
-        //TODO 业务类型转换
+        List<TenantPipelineConfig> list = pipeline.getTenantPipelineConfigs().get(markDocument());
+        Optional.ofNullable(list).ifPresent(ts -> configureDefaultData(bill, ts));
+        //todo动态规则转换
         return bill;
     }
+
+    private void configureDefaultData(RefundBill bill, List<TenantPipelineConfig> list) {
+        Map<String, String> kvMap = list.stream().collect(Collectors.toMap(TenantPipelineConfig::getConfigKey, TenantPipelineConfig::getConfigValue));
+        Field[] declaredFields = bill.getClass().getDeclaredFields();
+        Arrays.stream(declaredFields).forEach(field -> reflectField(bill, field, kvMap));
+        List<RefundItem> refundItems = bill.getRefundItems();
+        refundItems.forEach(item -> {
+            Field[] declaredFields1 = item.getClass().getDeclaredFields();
+            Arrays.stream(declaredFields1).forEach(field -> reflectField(item, field, kvMap));
+        });
+    }
+
+    public static void reflectField(RefundBill object, Field field, Map<String, String> kvMap) {
+        if (kvMap.containsKey(field.getName())) {
+            field.setAccessible(true);
+            try {
+                field.set(object, kvMap.get(field.getName()));
+            } catch (IllegalAccessException e) {
+                throw new TaxAgentServiceException(TaxSystemType.BUSINESS_MATCHES_ARE_INCORRECT, e.getMessage());
+            }
+        }
+    }
+
+
+    public static void reflectField(RefundItem object, Field field, Map<String, String> kvMap) {
+        if (kvMap.containsKey(field.getName())) {
+            field.setAccessible(true);
+            try {
+                field.set(object, kvMap.get(field.getName()));
+            } catch (IllegalAccessException e) {
+                throw new TaxAgentServiceException(TaxSystemType.BUSINESS_MATCHES_ARE_INCORRECT, e.getMessage());
+            }
+        }
+    }
 }
 package com.diligrp.tax.doc.process.kingdee;
+import com.diligrp.tax.central.context.TenantStorageContext;
 import com.diligrp.tax.central.domain.MessageContext;
 import com.diligrp.tax.central.exception.TaxAgentServiceException;
+import com.diligrp.tax.central.model.TenantPipeline;
 import com.diligrp.tax.central.process.AbstractProcessor;
 import com.diligrp.tax.central.type.DocumentType;
 import com.diligrp.tax.central.type.SystemType;
@@ -12,6 +14,8 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.core.annotation.Order;
 import org.springframework.stereotype.Component;
+import java.util.Optional;
+
 /**
  * 初始化处理器
@@ -31,8 +35,10 @@ public class InitializeProcessor extends AbstractProcessor {
         if (!system.documentTypes.contains(from)) {
             throw new TaxAgentServiceException(TaxSystemType.BUSINESS_MATCHES_ARE_INCORRECT);
         }
+        Optional<TenantPipeline> option = TenantStorageContext.getTenantPipeline(messageContext.getTenantId(), system, messageContext.getPipelineCode());
+        TenantPipeline pipeline = option.orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.NO_MATCHING_SET_OF_ACCOUNTS_FOUND));
         Builder<?> builder = DocumentContext.CONTEXT.get(from);
-        messageContext.setDocumentObject(builder.build(messageContext.getMsgBody()));
+        messageContext.setDocumentObject(builder.build(messageContext.getMsgBody(),pipeline));
         return messageContext;
     }
 }
@@ -3,7 +3,7 @@ package com.diligrp.tax.proxy.demarcate;
 import com.diligrp.tax.central.domain.BaseMapping;
 import com.diligrp.tax.central.domain.BaseProxy;
 import com.diligrp.tax.central.type.DocumentType;
-import com.kingdee.bos.webapi.sdk.K3CloudApi;
+import com.kingdee.bos.webapi.entity.IdentifyInfo;
 /**
  * @Author: zhangmeiyang
@@ -22,8 +22,8 @@ public abstract class Sender&lt;T extends BaseProxy&gt; {
      * 变换
      *
      * @param mappingObject 映射对象
-     * @param connection
+     * @param identifyInfo
      * @return {@link T }
      */
-    public abstract T send(BaseMapping mappingObject, K3CloudApi connection);
+    public abstract T send(BaseMapping mappingObject, IdentifyInfo identifyInfo);
 }
@@ -2,6 +2,7 @@ package com.diligrp.tax.proxy.demarcate.kingdee;
 import com.diligrp.tax.central.domain.BaseMapping;
 import com.diligrp.tax.central.domain.mapping.kingdee.CustomerMapping;
+import com.diligrp.tax.central.domain.mapping.kingdee.base.FContactId;
 import com.diligrp.tax.central.domain.mapping.kingdee.base.FT_BD_CUSTLOCATION;
 import com.diligrp.tax.central.domain.proxy.kingdee.CustomerProxy;
 import com.diligrp.tax.central.exception.TaxAgentServiceException;
@@ -35,22 +36,12 @@ public class CustomerSender extends Sender&lt;CustomerProxy&gt; {
     }
     @Override
-    public CustomerProxy send(BaseMapping mappingObject, K3CloudApi connection) {
+    public CustomerProxy send(BaseMapping mappingObject, IdentifyInfo identifyInfo) {
         CustomerMapping mapping = (CustomerMapping) mappingObject;
-        List<FT_BD_CUSTLOCATION> contacts = mapping.getFT_BD_CUSTLOCATION();
-        contacts.forEach(contact -> {
-            Map<String, Object> model = JsonUtils.convertValue(contact, new TypeReference<>() {
-            });
-            RepoRet<?> repoRet = KingDeeHelper.nonAuditSend(model, connection, "BD_CommonContact");
-            SuccessEntity first = repoRet.getResult().getResponseStatus().getSuccessEntitys().getFirst();
-            contact.getFContactId().setFNUMBER(first.getNumber());
-        });
+        mapping.setFT_BD_CUSTLOCATION(handleContact(identifyInfo, mapping));
         // 联系人新增
-        Optional.ofNullable(mapping.getFCUSTID())
-                .filter(e -> !e.isEmpty())
-                .ifPresent(e -> KingDeeHelper.unAuditSend(e, connection, markDocument().value));
-        RepoRet<?> repoRet = KingDeeHelper.auditSend(JsonUtils.convertValue(mapping, new TypeReference<>() {
-        }), connection, markDocument().value);
+        Optional.ofNullable(mapping.getFCUSTID()).filter(e -> !e.isEmpty()).ifPresent(e -> KingDeeHelper.unAuditSend(e, new K3CloudApi(identifyInfo), markDocument().value));
+        RepoRet<?> repoRet = KingDeeHelper.auditSend(JsonUtils.convertValue(mapping, new TypeReference<>() {}), new K3CloudApi(identifyInfo), markDocument().value);
         //联系人新增和更新完成
         ArrayList<SuccessEntity> successEntity = repoRet.getResult().getResponseStatus().getSuccessEntitys();
         if (successEntity.isEmpty()) {
@@ -62,4 +53,25 @@ public class CustomerSender extends Sender&lt;CustomerProxy&gt; {
         proxy.setThirdPartyCode(first.getNumber());
         return proxy;
     }
+
+    private List<FT_BD_CUSTLOCATION> handleContact(IdentifyInfo identifyInfo, CustomerMapping mapping) {
+        List<FT_BD_CUSTLOCATION> contacts = mapping.getFT_BD_CUSTLOCATION();
+        return contacts.stream().map(contact -> customerConvert(contact,identifyInfo)).toList();
+    }
+
+    private FT_BD_CUSTLOCATION customerConvert(FT_BD_CUSTLOCATION contact,IdentifyInfo identifyInfo) {
+        var customerLocation = new FT_BD_CUSTLOCATION();
+        customerLocation.setFBizAddress(contact.getFBizAddress());
+        customerLocation.setFCompanyType(contact.getFCompanyType());
+        customerLocation.setFMOBILEPHONE(contact.getFMOBILEPHONE());
+        customerLocation.setFName(contact.getFName());
+        Map<String, Object> model = JsonUtils.convertValue(customerLocation, new TypeReference<>() {});
+        RepoRet<?> repoRet = KingDeeHelper.nonAuditSend(model, new K3CloudApi(identifyInfo), "BD_CommonContact");
+        SuccessEntity first = repoRet.getResult().getResponseStatus().getSuccessEntitys().getFirst();
+        var res = new FT_BD_CUSTLOCATION();
+        FContactId fContactId = new FContactId();
+        fContactId.setFNUMBER(first.getId());
+        res.setFContactId(fContactId);
+        return res;
+    }
 }
@@ -34,13 +34,14 @@ public class ReceiptSender extends Sender&lt;ReceiptProxy&gt; {
     }
     @Override
-    public ReceiptProxy send(BaseMapping mappingObject, K3CloudApi connection) {
+    public ReceiptProxy send(BaseMapping mappingObject, IdentifyInfo identifyInfo) {
         ReceiptMapping mapping = (ReceiptMapping) mappingObject;
-        List<Object> infos = KingDeeHelper.querySend(mapping, markDocument().value, connection);
+        List<Object> infos = KingDeeHelper.querySend(mapping, markDocument().value, new K3CloudApi(identifyInfo));
         if (!infos.isEmpty()) {
             throw new TaxAgentServiceException(TaxSystemType.REPEAT_SENDING);
         }
-        RepoRet<?> repoRet = KingDeeHelper.auditSend(JsonUtils.convertValue(mapping, new TypeReference<>() {}), connection, markDocument().value);
+        RepoRet<?> repoRet = KingDeeHelper.auditSend(JsonUtils.convertValue(mapping, new TypeReference<>() {
+        }), new K3CloudApi(identifyInfo), markDocument().value);
         ArrayList<SuccessEntity> successEntity = repoRet.getResult().getResponseStatus().getSuccessEntitys();
         if (successEntity.isEmpty()) {
             throw new TaxAgentServiceException(TaxSystemType.REMOTE_SERVICE_CALLS_ARE_EXCEPTIONAL);
@@ -32,15 +32,15 @@ public class ReceivableSender extends Sender&lt;ReceivableProxy&gt; {
     }
     @Override
-    public ReceivableProxy send(BaseMapping mappingObject, K3CloudApi connection) {
+    public ReceivableProxy send(BaseMapping mappingObject, IdentifyInfo identifyInfo) {
         ReceivableMapping mapping = (ReceivableMapping) mappingObject;
-        List<Object> infos = KingDeeHelper.querySend(mapping, markDocument().value, connection);
+        List<Object> infos = KingDeeHelper.querySend(mapping, markDocument().value, new K3CloudApi(identifyInfo));
         if (!infos.isEmpty()) {
             throw new TaxAgentServiceException(TaxSystemType.REPEAT_SENDING);
         }
         Map<String, Object> model = JsonUtils.convertValue(mapping, new TypeReference<>() {
         });
-        RepoRet<?> repoRet = KingDeeHelper.auditSend(model, connection, markDocument().value);
+        RepoRet<?> repoRet = KingDeeHelper.auditSend(model, new K3CloudApi(identifyInfo), markDocument().value);
         ArrayList<SuccessEntity> successEntity = repoRet.getResult().getResponseStatus().getSuccessEntitys();
         if (successEntity.isEmpty()) {
             throw new TaxAgentServiceException(TaxSystemType.REMOTE_SERVICE_CALLS_ARE_EXCEPTIONAL);
@@ -34,13 +34,14 @@ public class RefundSender extends Sender&lt;RefundProxy&gt; {
     }
     @Override
-    public RefundProxy send(BaseMapping mappingObject, K3CloudApi connection) {
+    public RefundProxy send(BaseMapping mappingObject, IdentifyInfo identifyInfo) {
         RefundMapping mapping = (RefundMapping) mappingObject;
-        List<Object> infos = KingDeeHelper.querySend(mapping, markDocument().value, connection);
+        List<Object> infos = KingDeeHelper.querySend(mapping, markDocument().value, new K3CloudApi(identifyInfo));
         if (!infos.isEmpty()) {
             throw new TaxAgentServiceException(TaxSystemType.REPEAT_SENDING);
         }
-        RepoRet<?> repoRet = KingDeeHelper.auditSend(JsonUtils.convertValue(mapping, new TypeReference<>() {}), connection, markDocument().value);
+        RepoRet<?> repoRet = KingDeeHelper.auditSend(JsonUtils.convertValue(mapping, new TypeReference<>() {
+        }), new K3CloudApi(identifyInfo), markDocument().value);
         ArrayList<SuccessEntity> successEntity = repoRet.getResult().getResponseStatus().getSuccessEntitys();
         if (successEntity.isEmpty()) {
             throw new TaxAgentServiceException(TaxSystemType.REMOTE_SERVICE_CALLS_ARE_EXCEPTIONAL);
@@ -90,6 +90,7 @@ public class KingDeeHelper {
         message.setIsAutoAdjustField(true);
         var body = JsonUtils.toJsonString(message);
         try {
+            log.info("kingdee auditSend: {}", body);
             String res;
             res = api.save(formId, body);
             log.info("金蝶审核接口完成，formId={},res={}", formId, res);
@@ -12,6 +12,7 @@ import com.diligrp.tax.central.type.DocumentType;
 import com.diligrp.tax.central.type.SystemType;
 import com.diligrp.tax.central.type.TaxSystemType;
 import com.diligrp.tax.proxy.context.ProxyContext;
+import com.kingdee.bos.webapi.entity.IdentifyInfo;
 import com.kingdee.bos.webapi.sdk.K3CloudApi;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.core.annotation.Order;
@@ -32,11 +33,11 @@ public class ProxyProcessor extends AbstractProcessor {
     public MessageContext process(MessageContext messageContext) {
         DocumentType from = DocumentType.from(messageContext.getDocumentType());
         SystemType systemType = SystemType.from(messageContext.getSystemType());
-        Optional<TenantPipeline> option = TenantStorageContext.getTenantPipeline(messageContext.getTenantId(), systemType, from.value);
+        Optional<TenantPipeline> option = TenantStorageContext.getTenantPipeline(messageContext.getTenantId(), systemType, messageContext.getPipelineCode());
         TenantPipeline pipeline = option.orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.NO_MATCHING_SET_OF_ACCOUNTS_FOUND));
         AbstractConnectionManager<?> abstractConnectionManager = ConnectionContext.CONNECTION_MAP.get(systemType);
-        K3CloudApi connection = (K3CloudApi) abstractConnectionManager.getConnection(pipeline);
-        BaseProxy send = ProxyContext.CONTEXT.get(from).send(messageContext.getMappingObject(), connection);
+        IdentifyInfo identifyInfo = (IdentifyInfo) abstractConnectionManager.getConnection(pipeline);
+        BaseProxy send = ProxyContext.CONTEXT.get(from).send(messageContext.getMappingObject(), identifyInfo);
         messageContext.setProxyObject(send);
         return messageContext;
     }
 package com.diligrp.tax.storage.service;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.diligrp.tax.central.exception.TaxAgentServiceException;
 import com.diligrp.tax.central.model.TenantPipeline;
 import com.diligrp.tax.central.model.TenantPipelineConfig;
 import com.diligrp.tax.central.service.ITenantTaxService;
 import com.diligrp.tax.central.type.SystemType;
+import com.diligrp.tax.central.type.TaxSystemType;
 import com.diligrp.tax.central.utils.JsonUtils;
 import com.diligrp.tax.storage.domain.TaxPipeline;
 import com.diligrp.tax.storage.domain.TaxPipelineConfig;
+import com.diligrp.tax.storage.domain.TaxTenant;
 import com.diligrp.tax.storage.repo.TaxPipelineConfigRepository;
 import com.diligrp.tax.storage.repo.TaxPipelineRepository;
+import com.diligrp.tax.storage.repo.TaxTenantRepository;
 import com.diligrp.tax.storage.type.StateType;
 import jakarta.annotation.Resource;
 import org.springframework.stereotype.Service;
 import java.util.List;
+import java.util.Optional;
 /**
  * @Author: zhangmeiyang
@@ -25,12 +30,24 @@ import java.util.List;
 public class TenantTaxService implements ITenantTaxService {
     @Resource
+    private TaxTenantRepository taxTenantRepository;
+
+    @Resource
     private TaxPipelineRepository taxPipelineRepository;
     @Resource
     private TaxPipelineConfigRepository taxPipelineConfigRepository;
     @Override
+    public Long getTenantId(String group, String entity) {
+        LambdaQueryWrapper<TaxTenant> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxTenant::getGroup, group);
+        queryWrapper.eq(TaxTenant::getEntity, entity);
+        TaxTenant taxTenant = taxTenantRepository.selectOne(queryWrapper);
+        return Optional.ofNullable(taxTenant).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.NO_TENANT_INFORMATION_FOUND)).getId();
+    }
+
+    @Override
     public List<TenantPipeline> listAllEnablePipeline() {
         LambdaQueryWrapper<TaxPipeline> queryWrapper = new LambdaQueryWrapper<>();
         queryWrapper.eq(TaxPipeline::getState, StateType.ENABLE.value);