feat(kingdee): 完善客户和单据字段映射及配置服务

- 修改 BaseCustomer 类增加字段注释说明 - 优化 CustomerBuilder 中默认数据配置逻辑 - 引入 MappingUtils 工具类统一处理字段反射赋值 - 扩展 DocumentType 枚举支持更多文档类型和字段定义 - 新增 FieldType 和 SettingFieldType 枚举用于字段设置分类 - 添加 DynamicHttpPostClient 和 JsonPathUtils 支持远程调用与解析- 实现 ITaxTenantService 接口方法以支持按文档类型查询配置- 在 ReceiptBuilder、ReceivableBuilder 和 RefundBuilder 中应用新的映射逻辑 - 引入新模型类如 DynamicValue、Option、RemoteParam 等支持灵活配置 - 更新 pom.xml 添加 json-path 依赖- 删除已废弃的 TaxPipelineConfigController 控制器及相关仓储服务代码

feat(kingdee): 完善客户和单据字段映射及配置服务
- 修改 BaseCustomer 类增加字段注释说明 - 优化 CustomerBuilder 中默认数据配置逻辑 - 引入 MappingUtils 工具类统一处理字段反射赋值 - 扩展 DocumentType 枚举支持更多文档类型和字段定义 - 新增 FieldType 和 SettingFieldType 枚举用于字段设置分类 - 添加 DynamicHttpPostClient 和 JsonPathUtils 支持远程调用与解析- 实现 ITaxTenantService 接口方法以支持按文档类型查询配置- 在 ReceiptBuilder、ReceivableBuilder 和 RefundBuilder 中应用新的映射逻辑 - 引入新模型类如 DynamicValue、Option、RemoteParam 等支持灵活配置 - 更新 pom.xml 添加 json-path 依赖- 删除已废弃的 TaxPipelineConfigController 控制器及相关仓储服务代码
zhangmeiyang
1 parent f45f595b
Showing 37 changed files with 1032 additions and 450 deletions
tax-central/pom.xml
tax-central/src/main/java/com/diligrp/tax/central/context/TenantStorageContext.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/model/DynamicValue.java
tax-central/src/main/java/com/diligrp/tax/central/model/Option.java
tax-central/src/main/java/com/diligrp/tax/central/model/RemoteParam.java
tax-central/src/main/java/com/diligrp/tax/central/model/TenantPipeline.java
tax-central/src/main/java/com/diligrp/tax/central/model/TenantPipelineConfig.java
tax-central/src/main/java/com/diligrp/tax/central/service/ITaxTenantService.java
tax-central/src/main/java/com/diligrp/tax/central/type/DocumentType.java
tax-central/src/main/java/com/diligrp/tax/central/type/FieldType.java
tax-central/src/main/java/com/diligrp/tax/central/type/SettingFieldType.java
tax-central/src/main/java/com/diligrp/tax/central/utils/DynamicHttpPostClient.java
tax-central/src/main/java/com/diligrp/tax/central/utils/JsonPathUtils.java
tax-central/src/main/java/com/diligrp/tax/central/utils/MappingUtils.java
tax-central/src/main/java/com/diligrp/tax/central/utils/SingletonHttpClient.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
@@ -31,6 +31,10 @@
             <artifactId>spring-boot-starter-validation</artifactId>
         </dependency>
         <dependency>
+            <groupId>com.jayway.jsonpath</groupId>
+            <artifactId>json-path</artifactId>
+        </dependency>
+        <dependency>
             <groupId>com.kingdee</groupId>
             <artifactId>k3cloud-webapi-sdk</artifactId>
             <version>8.0.6</version>
@@ -2,9 +2,7 @@ package com.diligrp.tax.central.context;
 import com.diligrp.tax.central.event.RestoreTenantEvent;
 import com.diligrp.tax.central.model.TenantPipeline;
-import com.diligrp.tax.central.model.TenantPipelineConfig;
 import com.diligrp.tax.central.service.ITaxTenantService;
-import com.diligrp.tax.central.type.DocumentType;
 import com.diligrp.tax.central.type.SystemType;
 import jakarta.annotation.Resource;
 import lombok.extern.slf4j.Slf4j;
@@ -50,30 +48,16 @@ public class TenantStorageContext implements CommandLineRunner {
     public void loadTenantPipeline() {
         List<TenantPipeline> taxPipelineVOS = tenantTaxService.listAllEnablePipeline();
         Optional.ofNullable(taxPipelineVOS).ifPresent(pipelines -> {
-            Map<Long, Map<SystemType, Map<String, TenantPipeline>>> tenantPipelineMap = pipelines.stream()
-                    .collect(Collectors.groupingBy(
-                            TenantPipeline::getTenantId,
-                            Collectors.groupingBy(
-                                    TenantPipeline::getSystemType,
-                                    Collectors.toMap(
-                                            TenantPipeline::getCode,
-                                            this::loadConfig,
-                                            (existing, replacement) -> existing
-                                    )
-                            )
-                    ));
+            var tenantPipelineMap = pipelines.stream()
+                    .collect(Collectors.groupingBy(TenantPipeline::getTenantId,
+                            Collectors.groupingBy(TenantPipeline::getSystemType,
+                                    Collectors.toMap(TenantPipeline::getCode, e -> e)))
+                    );
             TENANT_PIPELINE_MAP.clear();
             TENANT_PIPELINE_MAP.putAll(tenantPipelineMap);
         });
     }
-    private TenantPipeline loadConfig(TenantPipeline tenantPipeline) {
-        List<TenantPipelineConfig> list = tenantTaxService.listByPipelineId(tenantPipeline.getId());
-        Map<DocumentType, List<TenantPipelineConfig>> collect = list.stream().collect(Collectors.groupingBy(k -> DocumentType.from(k.getDocumentType()), Collectors.toList()));
-        tenantPipeline.setTenantPipelineConfigs(collect);
-        return tenantPipeline;
-    }
-
     @Override
     public void run(String... args) throws Exception {
         publisher.publishEvent(new RestoreTenantEvent(this));
@@ -15,7 +15,7 @@ public class MessageContext {
     private String pipelineDataId;
     /**
-     * 账套数据对接第三方系统id
+     * 账套数据对接第三方系统单据id
      */
     private String systemDataId;
     /**
@@ -24,7 +24,7 @@ public abstract class BaseCustomer extends BaseDocument {
     @Converter(value = StringConverter.class, targetField = "FCUSTID")
     private String customerId;
     /**
-     * 客户编号
+     * 客户编号(FNumber)
      */
     @Converter(value = StringConverter.class, targetField = "FNumber")
     private String customerCode;
@@ -84,7 +84,7 @@ public abstract class BaseCustomer extends BaseDocument {
     @Converter(value = CustomerCreateOrgConverter.class, targetField = "FCreateOrgId")
     private String customerCreateOrg;
     /**
-     * 使用组织
+     * 使用组织(FUseOrgId)
      */
     @Converter(value = CustomerUseOrgConverter.class, targetField = "FUseOrgId")
     private String customerUseOrg;
+package com.diligrp.tax.central.model;
+
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-10 18:16
+ * @Version: todo
+ */
+@Getter
+@Setter
+public class DynamicValue {
+
+    /**
+     * 配置值
+     */
+    private String configValue;
+
+    /**
+     * 配置映射值
+     */
+    private String configMapValue;
+}
+package com.diligrp.tax.central.model;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-10 18:01
+ * @Version: todo
+ */
+@Getter
+@Setter
+@AllArgsConstructor
+@NoArgsConstructor
+public class Option {
+    private String label;
+    private String value;
+
+}
+package com.diligrp.tax.central.model;
+
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-10 18:17
+ * @Version: todo
+ */
+@Getter
+@Setter
+public class RemoteParam {
+
+    /**
+     * 固定参数
+     */
+    private String fixedParams;
+
+    /**
+     * 标识字段（远程调用时替换参数）
+     */
+    private String field;
+
+    /**
+     * 远程地址
+     */
+    private String remoteAddress;
+
+    /**
+     * 数据路径
+     */
+    private String dataPath;
+}
 package com.diligrp.tax.central.model;
-import com.diligrp.tax.central.type.DocumentType;
 import com.diligrp.tax.central.type.SystemType;
 import lombok.Getter;
 import lombok.Setter;
-import java.util.List;
 import java.util.Map;
 /**
@@ -22,5 +20,4 @@ public class TenantPipeline {
     private String name;
     private String code;
     private Map<String, Object> params;
-    private Map<DocumentType, List<TenantPipelineConfig>> tenantPipelineConfigs;
 }
 package com.diligrp.tax.central.model;
+import com.diligrp.tax.central.type.SettingFieldType;
 import lombok.Getter;
 import lombok.Setter;
-import java.time.LocalDateTime;
+import java.util.Map;
 /**
  * @Author: zhangmeiyang
@@ -30,15 +31,22 @@ public class TenantPipelineConfig {
      */
     private String configKey;
     /**
-     * 配置值
+     * 设置字段类型
      */
-    private String configValue;
+    private SettingFieldType settingFieldType;
+
     /**
-     * 创建时间
+     * 固定值
      */
-    private LocalDateTime createdTime;
+    private String fixedValue;
+
+    /**
+     * 动态值
+     */
+    private Map<String, String> dynamicValues;
+
     /**
-     * 修改时间
+     * 远程参数
      */
-    private LocalDateTime modifiedTime;
+    private RemoteParam remoteParam;
 }
@@ -31,8 +31,9 @@ public interface ITaxTenantService {
     /**
      * 按管道 ID 列出
      *
-     * @param pipelineId 管道 ID
+     * @param pipelineId   管道 ID
+     * @param documentType 文档类型
      * @return {@link List }<{@link TenantPipelineConfig }>
      */
-    List<TenantPipelineConfig> listByPipelineId(Long pipelineId);
+    List<TenantPipelineConfig> listByPipelineIdAndDocumentType(Long pipelineId, String documentType);
 }
 package com.diligrp.tax.central.type;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
 public enum DocumentType {
-    CUSTOMER_INFO("BD_Customer"),
-    AR_RECEIVABLE("AR_receivable"),
-    AR_RECEIVE_BILL("AR_RECEIVEBILL"),
-    AR_REFUND_BILL("AR_REFUNDBILL");
+    CUSTOMER_INFO("BD_Customer", "客户信息", Set.of(
+            FieldType.CUSTOMER_CONTACT_COMPANY_TYPE,
+            FieldType.CUSTOMER_CREATE_ORG,
+            FieldType.CUSTOMER_USE_ORG,
+            FieldType.CUSTOMER_GROUP
+    )),
+    AR_RECEIVABLE("AR_receivable", "应收单", Set.of(
+            FieldType.BUSINESS_TYPE,
+            FieldType.SETTLE_ORG,
+            FieldType.SALE_ORG,
+            FieldType.SALE_DEPT,
+            FieldType.PAY_ORG,
+            FieldType.CURRENCY,
+            FieldType.RECEIVABLE_SETTLE_METHOD,
+            FieldType.RECEIVABLE_CUSTOMER,
+            FieldType.RECEIVABLE_RECEIVER,
+            FieldType.RECEIVABLE_ORDERER,
+            FieldType.RECEIVABLE_PAYER,
+            FieldType.RECEIVABLE_STANDARD_CURRENCY,
+            FieldType.RECEIVABLE_CHARGE_ITEM,
+            FieldType.RECEIVABLE_CARD_NUMBER,
+            FieldType.RECEIVABLE_CHARGE_ITEM_DEPT
+    )),
+    AR_RECEIVE_BILL("AR_RECEIVEBILL", "收款单", Set.of(
+            FieldType.BUSINESS_TYPE,
+            FieldType.SETTLE_ORG,
+            FieldType.SALE_ORG,
+            FieldType.SALE_DEPT,
+            FieldType.PAY_ORG,
+            FieldType.CURRENCY,
+            FieldType.RECEIPT_CURRENCY,
+            FieldType.RECEIPT_SETTLE_CURRENCY,
+            FieldType.RECEIPT_CONTACT_TYPE,
+            FieldType.RECEIPT_CONTACT,
+            FieldType.RECEIPT_PAY_CONTACT_TYPE,
+            FieldType.RECEIPT_PAY_CONTACT,
+            FieldType.RECEIPT_CHARGE_ITEM,
+            FieldType.RECEIPT_SETTLE_METHOD,
+            FieldType.RECEIPT_CHARGE_ITEM_DEPT
+    )),
+    AR_REFUND_BILL("AR_REFUNDBILL", "收款退款单", Set.of(
+            FieldType.BUSINESS_TYPE,
+            FieldType.SETTLE_ORG,
+            FieldType.SALE_ORG,
+            FieldType.SALE_DEPT,
+            FieldType.PAY_ORG,
+            FieldType.CURRENCY,
+            FieldType.REFUND_CURRENCY,
+            FieldType.REFUND_SETTLE_CURRENCY,
+            FieldType.REFUND_RECEIVE_CONTACT_TYPE,
+            FieldType.REFUND_RECEIVE_CONTACT,
+            FieldType.REFUND_CONTACT_TYPE,
+            FieldType.REFUND_CONTACT,
+            FieldType.REFUND_CHARGE_ITEM,
+            FieldType.REFUND_SETTLE_METHOD,
+            FieldType.REFUND_CHARGE_ITEM_DEPT
+    ));
     public final String value;
+    public final String desc;
+    public final Set<FieldType> fieldType;
-    DocumentType(String value) {
+    DocumentType(String value, String desc, Set<FieldType> fieldType) {
         this.value = value;
+        this.desc = desc;
+        this.fieldType = fieldType;
     }
     public static DocumentType from(String value) {
@@ -29,4 +93,14 @@ public enum DocumentType {
         }
         throw new IllegalArgumentException("Invalid DocumentType value: " + value);
     }
+
+    public static List<Map<String, String>> getDocumentTypeList() {
+        DocumentType[] values = DocumentType.values();
+        return Stream.of(values).map(type -> {
+            Map<String, String> map = new ConcurrentHashMap<>();
+            map.put("value", type.value);
+            map.put("desc", type.desc);
+            return map;
+        }).collect(Collectors.toList());
+    }
 }
+package com.diligrp.tax.central.type;
+
+public enum FieldType {
+    //customer
+    CUSTOMER_CONTACT_COMPANY_TYPE("contactCompanyType", "联系人类型"),
+    CUSTOMER_CREATE_ORG("customerCreateOrg", "创建组织"),
+    CUSTOMER_USE_ORG("customerUseOrg", "使用组织"),
+    CUSTOMER_GROUP("customerGroup", "分组"),
+    //public
+    BUSINESS_TYPE("businessType", "业务类型"),
+    SETTLE_ORG("settleOrg", "结算组织"),
+    SALE_ORG("saleOrg", "销售组织"),
+    SALE_DEPT("saleDept", "销售部门"),
+    PAY_ORG("payOrg", "支付组织"),
+    CURRENCY("currency", "币别"),
+    //receivable
+    RECEIVABLE_SETTLE_METHOD("settleMethod", "结算方式"),
+    RECEIVABLE_CUSTOMER("customer", "客户"),
+    RECEIVABLE_RECEIVER("receiver", "收货方"),
+    RECEIVABLE_ORDERER("orderer", "订货方"),
+    RECEIVABLE_PAYER("payer", "付款方"),
+    RECEIVABLE_STANDARD_CURRENCY("standardCurrency", "本位币"),
+    RECEIVABLE_CHARGE_ITEM("chargeItem", "费用编码"),
+    RECEIVABLE_CARD_NUMBER("cardNumber", "卡片编码"),
+    RECEIVABLE_CHARGE_ITEM_DEPT("chargeItemDept", "费用部门"),
+    //receipt
+    RECEIPT_CURRENCY("currency","币别"),
+    RECEIPT_SETTLE_CURRENCY("settleCurrency","结算币别"),
+    RECEIPT_CONTACT_TYPE("contactType","往来单位类型"),
+    RECEIPT_CONTACT("contact","往来单位"),
+    RECEIPT_PAY_CONTACT_TYPE("payContactType","付款单位类型"),
+    RECEIPT_PAY_CONTACT("payContact","付款单位"),
+    RECEIPT_CHARGE_ITEM("chargeItem","费用编码"),
+    RECEIPT_SETTLE_METHOD("settleMethod","结算方式"),
+    RECEIPT_CHARGE_ITEM_DEPT("chargeItemDept","费用部门"),
+    //refund
+    REFUND_CURRENCY("currency","币别"),
+    REFUND_SETTLE_CURRENCY("settleCurrency","结算币别"),
+    REFUND_RECEIVE_CONTACT_TYPE("receiveContactType","收款单位类型"),
+    REFUND_RECEIVE_CONTACT("receiveContact","收款单位"),
+    REFUND_CONTACT_TYPE("contactType","往来单位类型"),
+    REFUND_CONTACT("contact","往来单位"),
+    REFUND_CHARGE_ITEM("chargeItem","费用编码"),
+    REFUND_SETTLE_METHOD("settleMethod","结算方式"),
+    REFUND_CHARGE_ITEM_DEPT("chargeItemDept","费用部门"),
+    ;
+    public final String value;
+    public final String desc;
+
+    FieldType(String value, String desc) {
+        this.value = value;
+        this.desc = desc;
+    }
+}
+package com.diligrp.tax.central.type;
+
+public enum SettingFieldType {
+    FIXED(0, "固定"),
+    DYNAMIC(1, "动态"),
+    REMOTE(2, "远程"),
+    ;
+
+    public final int value;
+    public final String desc;
+
+    SettingFieldType(int value, String desc) {
+        this.value = value;
+        this.desc = desc;
+    }
+
+    public static SettingFieldType from(int value) {
+        for (SettingFieldType type : values()) {
+            if (type.value == value) {
+                return type;
+            }
+        }
+        throw new IllegalArgumentException("SettingFieldType not found");
+    }
+}
+package com.diligrp.tax.central.utils;
+
+
+
+import com.diligrp.tax.central.exception.TaxAgentServiceException;
+import com.diligrp.tax.central.type.TaxSystemType;
+
+import java.util.Map;
+
+/**
+ * 动态 HTTP Postor
+ *
+ * @author zhangmeiyang
+ * @date 2025/10/17
+ */
+public class DynamicHttpPostClient extends ServiceEndpointSupport{
+
+    public String postBody(String url, Map<String,Object> params){
+        HttpResult res = send(url, JsonUtils.toJsonString(params));
+        if (res.statusCode != 200) {
+            String format = String.format("远程调用失败, URL:[%s],参数:[%s],code:[%s],消息:[%s]", url, params, res.statusCode, res.responseText);
+            throw new TaxAgentServiceException(TaxSystemType.REMOTE_SERVICE_CALLS_ARE_EXCEPTIONAL,format);
+        }
+        return res.responseText;
+    }
+}
+package com.diligrp.tax.central.utils;
+
+import com.diligrp.tax.central.exception.TaxAgentServiceException;
+import com.diligrp.tax.central.type.TaxSystemType;
+import com.jayway.jsonpath.JsonPath;
+
+import java.util.Optional;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-11 11:21
+ * @Version: todo
+ */
+public class JsonPathUtils {
+
+    public static String parse(String httpResult, String dataPath) {
+        Optional.ofNullable(httpResult).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.REMOTE_SERVICE_CALLS_ARE_EXCEPTIONAL));
+        Optional.ofNullable(dataPath).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.PARAMETER_IS_NOT_PARSED_CORRECTLY));
+        return JsonPath.read(httpResult, dataPath).toString();
+    }
+}
@@ -7,16 +7,15 @@ import com.diligrp.tax.central.converter.anno.Converter;
 import com.diligrp.tax.central.converter.anno.SubConverter;
 import com.diligrp.tax.central.domain.BaseDocument;
 import com.diligrp.tax.central.domain.BaseMapping;
-import com.diligrp.tax.central.domain.document.kingdee.BaseBill;
 import com.diligrp.tax.central.exception.TaxAgentServiceException;
+import com.diligrp.tax.central.model.RemoteParam;
+import com.diligrp.tax.central.model.TenantPipelineConfig;
 import com.diligrp.tax.central.type.TaxSystemType;
+import com.fasterxml.jackson.core.type.TypeReference;
 import lombok.extern.slf4j.Slf4j;
 import java.lang.reflect.Field;
-import java.util.Arrays;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.function.Function;
 import java.util.stream.Stream;
@@ -45,7 +44,7 @@ public class MappingUtils {
             map.put(converter.targetField(), newVal);
         } catch (Exception e) {
             log.error("MappingUtils.configureField转换失败", e.fillInStackTrace());
-            throw new TaxAgentServiceException(TaxSystemType.ABNORMAL_PARAMETERS,e);
+            throw new TaxAgentServiceException(TaxSystemType.ABNORMAL_PARAMETERS, e);
         }
     }
@@ -59,7 +58,7 @@ public class MappingUtils {
             map.put(converter.targetField(), newVal);
         } catch (Exception e) {
             log.error("MappingUtils.configureSubField转换失败", e.fillInStackTrace());
-            throw new TaxAgentServiceException(TaxSystemType.ABNORMAL_PARAMETERS,e);
+            throw new TaxAgentServiceException(TaxSystemType.ABNORMAL_PARAMETERS, e);
         }
     }
@@ -73,4 +72,52 @@ public class MappingUtils {
         Arrays.stream(allFields).filter(field -> field.isAnnotationPresent(SubConverter.class)).forEach(field -> configureSubField(t, field, map));
         return JsonUtils.convertValue(map, clazz);
     }
+
+
+    public static List<Field> listFields(Class<?> clazz) {
+        List<Field> fields = new ArrayList<>();
+        while (Objects.nonNull(clazz)) {
+            fields.addAll(Arrays.asList(clazz.getDeclaredFields()));
+            clazz = clazz.getSuperclass();
+        }
+        return fields;
+    }
+
+    public static void reflectField(Object object, Field field, Map<String, TenantPipelineConfig> kvMap) {
+        if (kvMap.containsKey(field.getName())) {
+            field.setAccessible(true);
+            try {
+                TenantPipelineConfig cfg = kvMap.get(field.getName());
+                switch (cfg.getSettingFieldType()) {
+                    case FIXED -> {
+                        var fixedValue = cfg.getFixedValue();
+                        field.set(object, fixedValue);
+                    }
+                    case DYNAMIC -> {
+                        Map<String, String> dynamicValues = cfg.getDynamicValues();
+                        String value = (String) field.get(object);
+                        if (dynamicValues.containsKey(value)) {
+                            field.set(object, dynamicValues.get(value));
+                        }
+                    }
+                    case REMOTE -> {
+                        RemoteParam remoteParam = cfg.getRemoteParam();
+                        String value = (String) field.get(object);
+                        String fixedParams = remoteParam.getFixedParams();
+                        String remoteAddress = remoteParam.getRemoteAddress();
+                        var params = JsonUtils.fromJsonString(fixedParams, new TypeReference<Map<String, Object>>() {
+                        });
+                        params.put(remoteParam.getField(), value);
+                        var result = SingletonHttpClient.instance().postBody(remoteAddress, params);
+                        String remoteValue = JsonPathUtils.parse(result, remoteParam.getDataPath());
+                        field.set(object, remoteValue);
+                    }
+                }
+            } catch (IllegalAccessException e) {
+                throw new TaxAgentServiceException(TaxSystemType.BUSINESS_MATCHES_ARE_INCORRECT, e.getMessage());
+            }
+        }
+    }
+
+
 }
+package com.diligrp.tax.central.utils;
+
+/**
+ * 单例 HTTP 客户端
+ *
+ * @author zhangmeiyang
+ * @date 2025/10/17
+ */
+public class SingletonHttpClient {
+
+    private static final DynamicHttpPostClient INSTANCE = new DynamicHttpPostClient();
+
+    private SingletonHttpClient() {}
+
+    public static DynamicHttpPostClient instance() {
+        return INSTANCE;
+    }
+
+}
@@ -7,21 +7,21 @@ import com.diligrp.tax.central.model.TenantPipeline;
 import com.diligrp.tax.central.model.TenantPipelineConfig;
 import com.diligrp.tax.central.model.TenantTaxPipelineMapping;
 import com.diligrp.tax.central.service.ITaxPipelineMappingService;
+import com.diligrp.tax.central.service.ITaxTenantService;
 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 jakarta.annotation.Resource;
 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
@@ -35,6 +35,9 @@ public class CustomerBuilder extends Builder&lt;StandardCustomer&gt; {
     @Resource
     private ITaxPipelineMappingService taxPipelineMappingService;
+    @Resource
+    private ITaxTenantService taxTenantService;
+
     @Override
     public DocumentType markDocument() {
@@ -46,7 +49,7 @@ public class CustomerBuilder extends Builder&lt;StandardCustomer&gt; {
         StandardCustomer customer = JsonUtils.fromJsonString(body, StandardCustomer.class);
         Optional.ofNullable(customer.getContacts()).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.MISSING_BUSINESS_INFORMATION, "请完善联系人信息"));
         Optional.ofNullable(systemDataId).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.MISSING_BUSINESS_INFORMATION, "请填写系统数据ID"));
-        List<TenantPipelineConfig> list = pipeline.getTenantPipelineConfigs().get(markDocument());
+        List<TenantPipelineConfig> list = taxTenantService.listByPipelineIdAndDocumentType(pipeline.getId(), markDocument().value);
         Optional.ofNullable(list).ifPresent(ts -> configureDefaultData(customer, ts));
         //查询数据库的客户信息 如果存在 赋值id
         Optional<TenantTaxPipelineMapping> dbOptions = taxPipelineMappingService.findByPipelineIdAndDocumentTypeAndSystemDataId(pipeline.getTenantId(), pipeline.getId(), markDocument().value, systemDataId);
@@ -58,39 +61,10 @@ public class CustomerBuilder extends Builder&lt;StandardCustomer&gt; {
     }
     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());
-            }
-        }
+        Map<String, TenantPipelineConfig> kvMap = list.stream().collect(Collectors.toMap(TenantPipelineConfig::getConfigKey, o -> o));
+        List<Field> fields = MappingUtils.listFields(customer.getClass());
+        fields.forEach(field -> MappingUtils.reflectField(customer, field, kvMap));
+        List<Contact> items = customer.getContacts();
+        items.forEach(item -> MappingUtils.listFields(item.getClass()).forEach(field -> MappingUtils.reflectField(item, field, kvMap)));
     }
 }
@@ -5,16 +5,18 @@ 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.service.ITaxTenantService;
 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 jakarta.annotation.Resource;
 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;
@@ -27,6 +29,9 @@ import java.util.stream.Collectors;
  */
 @Component
 public class ReceiptBuilder extends Builder<ReceiptBill> {
+    @Resource
+    private ITaxTenantService taxTenantService;
+
     @Override
     public DocumentType markDocument() {
         return DocumentType.AR_RECEIVE_BILL;
@@ -37,42 +42,16 @@ public class ReceiptBuilder extends Builder&lt;ReceiptBill&gt; {
         ReceiptBill bill = JsonUtils.fromJsonString(body, ReceiptBill.class);
         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"))));
-        List<TenantPipelineConfig> list = pipeline.getTenantPipelineConfigs().get(markDocument());
+        List<TenantPipelineConfig> list = taxTenantService.listByPipelineIdAndDocumentType(pipeline.getId(), markDocument().value);
         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());
-            }
-        }
+        Map<String, TenantPipelineConfig> kvMap = list.stream().collect(Collectors.toMap(TenantPipelineConfig::getConfigKey, o -> o));
+        List<Field> fields = MappingUtils.listFields(bill.getClass());
+        fields.forEach(field -> MappingUtils.reflectField(bill, field, kvMap));
+        List<ReceiptItem> items = bill.getReceiptItems();
+        items.forEach(item -> MappingUtils.listFields(item.getClass()).forEach(field -> MappingUtils.reflectField(item, field, kvMap)));
     }
 }
@@ -5,16 +5,18 @@ 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.service.ITaxTenantService;
 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 jakarta.annotation.Resource;
 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;
@@ -28,6 +30,9 @@ import java.util.stream.Collectors;
 @Component
 public class ReceivableBuilder extends Builder<ReceivableBill> {
+    @Resource
+    private ITaxTenantService taxTenantService;
+
     @Override
     public DocumentType markDocument() {
         return DocumentType.AR_RECEIVABLE;
@@ -38,43 +43,16 @@ public class ReceivableBuilder extends Builder&lt;ReceivableBill&gt; {
         ReceivableBill bill = JsonUtils.fromJsonString(body, ReceivableBill.class);
         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"))));
-        List<TenantPipelineConfig> list = pipeline.getTenantPipelineConfigs().get(markDocument());
+        List<TenantPipelineConfig> list = taxTenantService.listByPipelineIdAndDocumentType(pipeline.getId(), markDocument().value);
         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());
-            }
-        }
+        Map<String, TenantPipelineConfig> kvMap = list.stream().collect(Collectors.toMap(TenantPipelineConfig::getConfigKey, o -> o));
+        List<Field> fields = MappingUtils.listFields(bill.getClass());
+        fields.forEach(field -> MappingUtils.reflectField(bill, field, kvMap));
+        List<ReceivableItem> items = bill.getReceivableItems();
+        items.forEach(item -> MappingUtils.listFields(item.getClass()).forEach(field -> MappingUtils.reflectField(item, field, kvMap)));
     }
 }
@@ -5,16 +5,18 @@ 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.service.ITaxTenantService;
 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 jakarta.annotation.Resource;
 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;
@@ -28,6 +30,9 @@ import java.util.stream.Collectors;
 @Component
 public class RefundBuilder extends Builder<RefundBill> {
+    @Resource
+    private ITaxTenantService taxTenantService;
+
     @Override
     public DocumentType markDocument() {
         return DocumentType.AR_REFUND_BILL;
@@ -38,43 +43,16 @@ public class RefundBuilder extends Builder&lt;RefundBill&gt; {
         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"))));
-        List<TenantPipelineConfig> list = pipeline.getTenantPipelineConfigs().get(markDocument());
+        List<TenantPipelineConfig> list = taxTenantService.listByPipelineIdAndDocumentType(pipeline.getId(), markDocument().value);
         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());
-            }
-        }
+        Map<String, TenantPipelineConfig> kvMap = list.stream().collect(Collectors.toMap(TenantPipelineConfig::getConfigKey, o -> o));
+        List<Field> fields = MappingUtils.listFields(bill.getClass());
+        fields.forEach(field -> MappingUtils.reflectField(bill, field, kvMap));
+        List<RefundItem> items = bill.getRefundItems();
+        items.forEach(item -> MappingUtils.listFields(item.getClass()).forEach(field -> MappingUtils.reflectField(item, field, kvMap)));
     }
 }
-package com.diligrp.tax.storage.controller;
-
-import com.diligrp.tax.storage.Valid;
-import com.diligrp.tax.storage.anno.RebuildIndex;
-import com.diligrp.tax.storage.message.Message;
-import com.diligrp.tax.storage.model.co.TaxPipelineConfigCO;
-import com.diligrp.tax.storage.service.TaxPipelineConfigService;
-import jakarta.annotation.Resource;
-import org.springframework.validation.annotation.Validated;
-import org.springframework.web.bind.annotation.PathVariable;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-/**
- * @Author: zhangmeiyang
- * @CreateTime: 2025-11-05 16:22
- * @Version: todo
- */
-@RestController
-@RequestMapping("/tax/tenant/pipeline/config")
-public class TaxPipelineConfigController {
-
-    @Resource
-    private TaxPipelineConfigService taxPipelineConfigService;
-
-
-    /**
-     * 按管道 ID 和文档类型列出
-     *
-     * @param pipelineId   管道 ID
-     * @param documentType 文档类型
-     * @return {@link Message }<{@link ? }>
-     */
-    @RequestMapping("/list/{pipelineId}/{documentType}")
-    public Message<?> listByPipelineIdAndDocumentType(@PathVariable("pipelineId") Long pipelineId, @PathVariable("documentType") String documentType) {
-        return Message.success(taxPipelineConfigService.listByPipelineIdAndDocumentType(pipelineId, documentType));
-    }
-
-    /**
-     * 按管道 ID 列出
-     *
-     * @param pipelineId 管道 ID
-     * @return {@link Message }<{@link ? }>
-     */
-    @RequestMapping("/list/{pipelineId}")
-    public Message<?> listByPipelineId(@PathVariable("pipelineId") Long pipelineId) {
-        return Message.success(taxPipelineConfigService.listByPipelineId(pipelineId));
-    }
-
-
-    /**
-     * 保存
-     *
-     * @param taxPipelineConfig 税务管道配置
-     * @return {@link Message }<{@link ? }>
-     */
-    @RequestMapping("/save")
-    @RebuildIndex
-    public Message<?> save(@RequestBody @Validated(value = Valid.Create.class) TaxPipelineConfigCO taxPipelineConfig) {
-        taxPipelineConfigService.save(taxPipelineConfig);
-        return Message.success();
-    }
-
-    /**
-     * 更新
-     *
-     * @param taxPipelineConfig 税务管道配置
-     * @return {@link Message }<{@link ? }>
-     */
-    @RequestMapping("/update")
-    @RebuildIndex
-    public Message<?> update(@RequestBody @Validated(value = {Valid.Update.class}) TaxPipelineConfigCO taxPipelineConfig) {
-        taxPipelineConfigService.update(taxPipelineConfig);
-        return Message.success();
-    }
-
-    /**
-     * 删除
-     *
-     * @param id id
-     * @return {@link Message }<{@link ? }>
-     */
-    @RequestMapping("/delete/{id}")
-    @RebuildIndex
-    public Message<?> delete(@PathVariable("id") Long id) {
-        taxPipelineConfigService.delete(id);
-        return Message.success();
-    }
-
-}
+package com.diligrp.tax.storage.controller;
+
+import com.diligrp.tax.storage.Valid;
+import com.diligrp.tax.storage.message.Message;
+import com.diligrp.tax.storage.model.co.TaxPipelineFieldConfigCO;
+import com.diligrp.tax.storage.service.TaxPipelineFieldConfigService;
+import jakarta.annotation.Resource;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-10 17:40
+ * @Version: todo
+ */
+@RestController
+@RequestMapping("/tax/tenant/pipeline/field/config")
+public class TaxPipelineFieldConfigController {
+
+    @Resource
+    private TaxPipelineFieldConfigService taxPipelineFieldConfigService;
+
+    /**
+     * 列出所有单据
+     *
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/listDocument/{systemType}")
+    public Message<?> listDocument(@PathVariable("systemType") String systemType) {
+        return Message.success(taxPipelineFieldConfigService.listDocumentBySystemType(systemType));
+    }
+
+
+    /**
+     * 列出所有可配置的字段
+     *
+     * @param systemType   系统类型
+     * @param documentType 文档类型
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/listField/{systemType}/{documentType}")
+    public Message<?> listField(@PathVariable("systemType") String systemType, @PathVariable("documentType") String documentType) {
+        return Message.success(taxPipelineFieldConfigService.listFieldBySystemTypeAndDocumentType(systemType, documentType));
+    }
+
+
+    /**
+     * 保存配置
+     *
+     * @param co 公司
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/save")
+    public Message<?> save(@RequestBody @Validated(value = Valid.Create.class) TaxPipelineFieldConfigCO co) {
+        taxPipelineFieldConfigService.save(co);
+        return Message.success();
+    }
+
+
+}
-package com.diligrp.tax.storage.domain;
-
-import com.baomidou.mybatisplus.annotation.IdType;
-import com.baomidou.mybatisplus.annotation.TableField;
-import com.baomidou.mybatisplus.annotation.TableId;
-import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.Getter;
-import lombok.Setter;
-
-import java.time.LocalDateTime;
-
-@Getter
-@Setter
-@TableName("tax_pipeline_config")
-public class TaxPipelineConfig {
-    @TableId(type = IdType.AUTO)
-    private Long id;
-
-    @TableField(value = "pipeline_id")
-    private Long pipelineId;
-
-    @TableField(value = "document_type")
-    private String documentType;
-
-    @TableField(value = "config_key")
-    private String configKey;
-
-    @TableField(value = "config_value")
-    private String configValue;
-
-    @TableField(value = "created_time")
-    private LocalDateTime createdTime;
-
-    @TableField(value = "modified_time")
-    private LocalDateTime modifiedTime;
-
-}
+package com.diligrp.tax.storage.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.time.LocalDateTime;
+import lombok.Data;
+
+/**
+ * 账套动态字段配置表
+ * @TableName tax_pipeline_dynamic_config
+ */
+@TableName(value ="tax_pipeline_dynamic_config")
+@Data
+public class TaxPipelineDynamicConfig {
+    /**
+     *
+     */
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 账套ID
+     */
+    @TableField(value = "pipeline_field_type_id")
+    private Long pipelineFieldTypeId;
+
+    /**
+     * 配置项VALUE
+     */
+    @TableField(value = "config_value")
+    private String configValue;
+
+    /**
+     * 配置项映射VALUE
+     */
+    @TableField(value = "config_map_value")
+    private String configMapValue;
+
+    /**
+     * 创建时间
+     */
+    @TableField(value = "created_time")
+    private LocalDateTime createdTime;
+
+    /**
+     * 更新时间
+     */
+    @TableField(value = "modified_time")
+    private LocalDateTime modifiedTime;
+}
-package com.diligrp.tax.storage.model.vo;
+package com.diligrp.tax.storage.domain;
-import lombok.Getter;
-import lombok.Setter;
-
-import java.time.Instant;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
 import java.time.LocalDateTime;
+import lombok.Data;
-@Getter
-@Setter
-public class TaxPipelineConfigVO {
+/**
+ * 账套字段配置表
+ * @TableName tax_pipeline_field_type
+ */
+@TableName(value ="tax_pipeline_field_type")
+@Data
+public class TaxPipelineFieldType {
     /**
-     * id
+     *
      */
+    @TableId(type = IdType.AUTO)
     private Long id;
+
     /**
-     * 管道 ID
+     * 账套ID
      */
+    @TableField(value = "pipeline_id")
     private Long pipelineId;
+
     /**
-     * 文档类型
+     * 业务单据类型
      */
+    @TableField(value = "document_type")
     private String documentType;
+
     /**
-     * 配置键
+     * 配置项KEY
      */
+    @TableField(value = "config_key")
     private String configKey;
+
     /**
      * 配置值
      */
-    private String configValue;
+    @TableField(value = "setting_field_type")
+    private Integer settingFieldType;
+
     /**
      * 创建时间
      */
+    @TableField(value = "created_time")
     private LocalDateTime createdTime;
+
     /**
-     * 修改时间
+     * 更新时间
      */
+    @TableField(value = "modified_time")
     private LocalDateTime modifiedTime;
-
 }
+package com.diligrp.tax.storage.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.time.LocalDateTime;
+
+/**
+ * 账套默认配置表
+ *
+ * @TableName tax_pipeline_fixed_config
+ */
+@TableName(value = "tax_pipeline_fixed_config")
+@Data
+public class TaxPipelineFixedConfig {
+    /**
+     *
+     */
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 账套ID
+     */
+    @TableField(value = "pipeline_field_type_id")
+    private Long pipelineFieldTypeId;
+
+    /**
+     * 配置项VALUE
+     */
+    @TableField(value = "config_value")
+    private String configValue;
+
+    /**
+     * 创建时间
+     */
+    @TableField(value = "created_time")
+    private LocalDateTime createdTime;
+
+    /**
+     * 更新时间
+     */
+    @TableField(value = "modified_time")
+    private LocalDateTime modifiedTime;
+}
+package com.diligrp.tax.storage.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.time.LocalDateTime;
+
+/**
+ * 账套远程调用配置表
+ *
+ * @TableName tax_pipeline_remote_config
+ */
+@TableName(value = "tax_pipeline_remote_config")
+@Data
+public class TaxPipelineRemoteConfig {
+    /**
+     *
+     */
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 账套ID
+     */
+    @TableField(value = "pipeline_field_type_id")
+    private Long pipelineFieldTypeId;
+
+    /**
+     * 调用接口参数固定值
+     */
+    @TableField(value = "fixed_params")
+    private String fixedParams;
+
+    /**
+     * 调用远程接口映射字段
+     */
+    @TableField(value = "`field`")
+    private String field;
+
+    /**
+     * 远程调用地址
+     */
+    @TableField(value = "remote_address")
+    private String remoteAddress;
+
+    /**
+     * jsonpath获取数据路径
+     */
+    @TableField(value = "data_path")
+    private String dataPath;
+
+    /**
+     * 创建时间
+     */
+    @TableField(value = "created_time")
+    private LocalDateTime createdTime;
+
+    /**
+     * 更新时间
+     */
+    @TableField(value = "modified_time")
+    private LocalDateTime modifiedTime;
+}
 package com.diligrp.tax.storage.model.co;
 import com.diligrp.tax.storage.Valid;
+import com.diligrp.tax.central.model.DynamicValue;
+import com.diligrp.tax.central.model.RemoteParam;
 import jakarta.validation.constraints.NotEmpty;
 import jakarta.validation.constraints.NotNull;
 import lombok.Getter;
 import lombok.Setter;
+import java.util.List;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-10 18:10
+ * @Version: todo
+ */
 @Getter
 @Setter
-public class TaxPipelineConfigCO {
-
-    /**
-     * id
-     */
-    @NotNull(groups = {Valid.Update.class, Valid.Delete.class})
-    private Long id;
+public class TaxPipelineFieldConfigCO {
     /**
      * 管道 ID
@@ -28,6 +31,7 @@ public class TaxPipelineConfigCO {
     @NotEmpty(groups = {Valid.Create.class})
     private String documentType;
+
     /**
      * 配置键
      */
@@ -35,9 +39,23 @@ public class TaxPipelineConfigCO {
     private String configKey;
     /**
-     * 配置值
+     * 设置字段类型
      */
-    @NotEmpty(groups = {Valid.Create.class})
-    private String configValue;
+    @NotNull(groups = {Valid.Create.class})
+    private Integer settingFieldType;
+    /**
+     * 固定值
+     */
+    private String fixedValue;
+
+    /**
+     * 动态值
+     */
+    private List<DynamicValue> dynamicValues;
+
+    /**
+     * 远程参数
+     */
+    private RemoteParam remoteParam;
 }
-package com.diligrp.tax.storage.repo;
-
-import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.diligrp.tax.storage.domain.TaxPipelineConfig;
-import org.springframework.stereotype.Repository;
-
-@Repository
-public interface TaxPipelineConfigRepository extends BaseMapper<TaxPipelineConfig> {
-
-}
+package com.diligrp.tax.storage.repo;
+
+import com.diligrp.tax.storage.domain.TaxPipelineDynamicConfig;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.springframework.stereotype.Repository;
+
+/**
+* @author dili
+* @description 针对表【tax_pipeline_dynamic_config(账套动态字段配置表)】的数据库操作Mapper
+* @createDate 2025-11-10 17:51:55
+* @Entity com.diligrp.tax.storage.domain.TaxPipelineDynamicConfig
+*/
+@Repository
+public interface TaxPipelineDynamicConfigRepository extends BaseMapper<TaxPipelineDynamicConfig> {
+
+}
+
+
+
+
+package com.diligrp.tax.storage.repo;
+
+import com.diligrp.tax.storage.domain.TaxPipelineFieldType;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author dili
+* @description 针对表【tax_pipeline_field_type(账套字段配置表)】的数据库操作Mapper
+* @createDate 2025-11-10 18:40:44
+* @Entity com.diligrp.tax.storage.domain.TaxPipelineFieldType
+*/
+public interface TaxPipelineFieldTypeRepository extends BaseMapper<TaxPipelineFieldType> {
+
+}
+
+
+
+
+package com.diligrp.tax.storage.repo;
+
+import com.diligrp.tax.storage.domain.TaxPipelineFixedConfig;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.springframework.stereotype.Repository;
+
+/**
+* @author dili
+* @description 针对表【tax_pipeline_fixed_config(账套默认配置表)】的数据库操作Mapper
+* @createDate 2025-11-10 17:51:55
+* @Entity com.diligrp.tax.storage.domain.TaxPipelineFixedConfig
+*/
+@Repository
+public interface TaxPipelineFixedConfigRepository extends BaseMapper<TaxPipelineFixedConfig> {
+
+}
+
+
+
+
+package com.diligrp.tax.storage.repo;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.diligrp.tax.storage.domain.TaxPipelineRemoteConfig;
+import org.springframework.stereotype.Repository;
+
+/**
+ * @author dili
+ * @description 针对表【tax_pipeline_remote_config(账套远程调用配置表)】的数据库操作Mapper
+ * @createDate 2025-11-10 17:51:55
+ * @Entity com.diligrp.tax.storage.domain.TaxPipelineRemoteConfig
+ */
+@Repository
+public interface TaxPipelineRemoteConfigRepository extends BaseMapper<TaxPipelineRemoteConfig> {
+
+}
+
+
+
+
-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.type.DocumentType;
-import com.diligrp.tax.central.utils.JsonUtils;
-import com.diligrp.tax.storage.domain.TaxPipelineConfig;
-import com.diligrp.tax.storage.model.co.TaxPipelineConfigCO;
-import com.diligrp.tax.storage.model.vo.TaxPipelineConfigVO;
-import com.diligrp.tax.storage.repo.TaxPipelineConfigRepository;
-import jakarta.annotation.Resource;
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
-
-import java.util.List;
-import java.util.Optional;
-
-/**
- * @Author: zhangmeiyang
- * @CreateTime: 2025-11-05 16:24
- * @Version: todo
- */
-@Service
-public class TaxPipelineConfigService {
-
-    @Resource
-    private TaxPipelineConfigRepository taxPipelineConfigRepository;
-
-    /**
-     * 列表
-     *
-     * @param pipelineId   管道 ID
-     * @param documentType 文档类型
-     * @return {@link Object }
-     */
-    public List<TaxPipelineConfigVO> listByPipelineIdAndDocumentType(Long pipelineId, String documentType) {
-        LambdaQueryWrapper<TaxPipelineConfig> queryWrapper = new LambdaQueryWrapper<>();
-        queryWrapper.eq(TaxPipelineConfig::getPipelineId, pipelineId);
-        queryWrapper.eq(TaxPipelineConfig::getDocumentType, documentType);
-        List<TaxPipelineConfig> taxPipelineConfigs = taxPipelineConfigRepository.selectList(queryWrapper);
-        return taxPipelineConfigs.stream().map(taxPipelineConfig -> JsonUtils.convertValue(taxPipelineConfig, TaxPipelineConfigVO.class)).toList();
-    }
-
-    /**
-     * 按管道 ID 列出
-     *
-     * @param pipelineId 管道 ID
-     * @return {@link List }<{@link TaxPipelineConfigVO }>
-     */
-    public List<TaxPipelineConfigVO> listByPipelineId(Long pipelineId) {
-        LambdaQueryWrapper<TaxPipelineConfig> queryWrapper = new LambdaQueryWrapper<>();
-        queryWrapper.eq(TaxPipelineConfig::getPipelineId, pipelineId);
-        List<TaxPipelineConfig> taxPipelineConfigs = taxPipelineConfigRepository.selectList(queryWrapper);
-        return taxPipelineConfigs.stream().map(taxPipelineConfig -> JsonUtils.convertValue(taxPipelineConfig, TaxPipelineConfigVO.class)).toList();
-    }
-
-
-    /**
-     * 保存配置
-     *
-     * @param taxPipelineConfig 税务管道配置
-     */
-    @Transactional
-    public void save(TaxPipelineConfigCO taxPipelineConfig) {
-        DocumentType.validateDocumentType(taxPipelineConfig.getDocumentType());
-        TaxPipelineConfig config = JsonUtils.convertValue(taxPipelineConfig, TaxPipelineConfig.class);
-        taxPipelineConfigRepository.insert(config);
-    }
-
-
-    /**
-     * 更新
-     *
-     * @param taxPipelineConfig 税务管道配置
-     */
-    @Transactional
-    public void update(TaxPipelineConfigCO taxPipelineConfig) {
-        DocumentType.validateDocumentType(taxPipelineConfig.getDocumentType());
-        TaxPipelineConfig config = JsonUtils.convertValue(taxPipelineConfig, TaxPipelineConfig.class);
-        taxPipelineConfigRepository.updateById(config);
-    }
-
-    /**
-     * 删除
-     *
-     * @param id id
-     */
-    @Transactional
-    public void delete(Long id) {
-        TaxPipelineConfig config = Optional.ofNullable(taxPipelineConfigRepository.selectById(id)).orElseThrow(() -> new TaxAgentServiceException("未找到当前配置"));
-        taxPipelineConfigRepository.deleteById(config);
-    }
-}
+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.DynamicValue;
+import com.diligrp.tax.central.model.Option;
+import com.diligrp.tax.central.model.RemoteParam;
+import com.diligrp.tax.central.model.TenantPipelineConfig;
+import com.diligrp.tax.central.type.DocumentType;
+import com.diligrp.tax.central.type.SettingFieldType;
+import com.diligrp.tax.central.type.SystemType;
+import com.diligrp.tax.central.type.TaxSystemType;
+import com.diligrp.tax.storage.domain.TaxPipelineDynamicConfig;
+import com.diligrp.tax.storage.domain.TaxPipelineFieldType;
+import com.diligrp.tax.storage.domain.TaxPipelineFixedConfig;
+import com.diligrp.tax.storage.domain.TaxPipelineRemoteConfig;
+import com.diligrp.tax.storage.model.co.TaxPipelineFieldConfigCO;
+import com.diligrp.tax.storage.repo.TaxPipelineDynamicConfigRepository;
+import com.diligrp.tax.storage.repo.TaxPipelineFieldTypeRepository;
+import com.diligrp.tax.storage.repo.TaxPipelineFixedConfigRepository;
+import com.diligrp.tax.storage.repo.TaxPipelineRemoteConfigRepository;
+import jakarta.annotation.Resource;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+import java.util.stream.Collectors;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-10 17:59
+ * @Version: todo
+ */
+@Service
+public class TaxPipelineFieldConfigService {
+
+    @Resource
+    private TaxPipelineFieldTypeRepository taxPipelineFieldTypeRepository;
+    @Resource
+    private TaxPipelineRemoteConfigRepository taxPipelineRemoteConfigRepository;
+    @Resource
+    private TaxPipelineFixedConfigRepository taxPipelineFixedConfigRepository;
+    @Resource
+    private TaxPipelineDynamicConfigRepository taxPipelineDynamicConfigRepository;
+
+    /**
+     * 按系统类型列出文档
+     *
+     * @param systemType 系统类型
+     * @return {@link List }<{@link Option }>
+     */
+    public List<Option> listDocumentBySystemType(String systemType) {
+        SystemType from = SystemType.from(systemType);
+        return from.documentTypes.stream().map(documentType -> new Option(documentType.desc, documentType.value)).toList();
+    }
+
+    /**
+     * 按系统类型和文档类型列出字段
+     *
+     * @param systemType   系统类型
+     * @param documentType 文档类型
+     * @return {@link List }<{@link Option }>
+     */
+    public List<Option> listFieldBySystemTypeAndDocumentType(String systemType, String documentType) {
+        SystemType from = SystemType.from(systemType);
+        DocumentType documentType1 = from.documentTypes.stream().filter(doc -> doc.value.equals(documentType)).findFirst().orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.BUSINESS_MATCHES_ARE_INCORRECT));
+        return documentType1.fieldType.stream().map(fieldType -> new Option(fieldType.desc, fieldType.value)).toList();
+    }
+
+    /**
+     * 保存
+     *
+     * @param co 公司
+     */
+    @Transactional
+    public void save(TaxPipelineFieldConfigCO co) {
+        SettingFieldType from = SettingFieldType.from(co.getSettingFieldType());
+        LambdaQueryWrapper<TaxPipelineFieldType> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineFieldType::getPipelineId, co.getPipelineId()).eq(TaxPipelineFieldType::getDocumentType, co.getDocumentType()).eq(TaxPipelineFieldType::getConfigKey, co.getConfigKey());
+        TaxPipelineFieldType type = taxPipelineFieldTypeRepository.selectOne(queryWrapper);
+        Optional.ofNullable(type).ifPresentOrElse(
+                e -> {
+                    deleteFixedConfig(e);
+                    deleteDynamicConfig(e);
+                    deleteRemoteConfig(e);
+                    saveConfig(co, from, e);
+                },
+                () -> {
+                    TaxPipelineFieldType newType = new TaxPipelineFieldType();
+                    newType.setPipelineId(co.getPipelineId());
+                    newType.setDocumentType(co.getDocumentType());
+                    newType.setConfigKey(co.getConfigKey());
+                    newType.setSettingFieldType(co.getSettingFieldType());
+                    taxPipelineFieldTypeRepository.insert(newType);
+                    saveConfig(co, from, newType);
+                }
+        );
+    }
+
+    @Transactional
+    public void deleteRemoteConfig(TaxPipelineFieldType e) {
+        LambdaQueryWrapper<TaxPipelineRemoteConfig> wrapper = new LambdaQueryWrapper<TaxPipelineRemoteConfig>().eq(TaxPipelineRemoteConfig::getPipelineFieldTypeId, e.getId());
+        taxPipelineRemoteConfigRepository.delete(wrapper);
+    }
+
+    @Transactional
+    public void deleteDynamicConfig(TaxPipelineFieldType e) {
+        LambdaQueryWrapper<TaxPipelineDynamicConfig> wrapper = new LambdaQueryWrapper<TaxPipelineDynamicConfig>().eq(TaxPipelineDynamicConfig::getPipelineFieldTypeId, e.getId());
+        taxPipelineDynamicConfigRepository.delete(wrapper);
+    }
+
+    @Transactional
+    public void deleteFixedConfig(TaxPipelineFieldType e) {
+        LambdaQueryWrapper<TaxPipelineFixedConfig> wrapper = new LambdaQueryWrapper<TaxPipelineFixedConfig>().eq(TaxPipelineFixedConfig::getPipelineFieldTypeId, e.getId());
+        taxPipelineFixedConfigRepository.delete(wrapper);
+    }
+
+    @Transactional
+    public void saveConfig(TaxPipelineFieldConfigCO co, SettingFieldType from, TaxPipelineFieldType newType) {
+        switch (from) {
+            case FIXED -> saveFixedConfig(co, newType);
+            case DYNAMIC -> saveDynamicConfig(co, newType);
+            case REMOTE -> saveRemoteConfig(co, newType);
+        }
+    }
+
+    @Transactional
+    public void saveRemoteConfig(TaxPipelineFieldConfigCO co, TaxPipelineFieldType newType) {
+        TaxPipelineRemoteConfig config = new TaxPipelineRemoteConfig();
+        config.setPipelineFieldTypeId(newType.getId());
+        config.setRemoteAddress(co.getRemoteParam().getRemoteAddress());
+        config.setField(co.getRemoteParam().getField());
+        config.setDataPath(co.getRemoteParam().getDataPath());
+        config.setFixedParams(co.getRemoteParam().getFixedParams());
+        taxPipelineRemoteConfigRepository.insert(config);
+    }
+
+    @Transactional
+    public void saveDynamicConfig(TaxPipelineFieldConfigCO co, TaxPipelineFieldType newType) {
+        co.getDynamicValues().forEach(dynamicValue -> {
+            TaxPipelineDynamicConfig dynamicConfig = new TaxPipelineDynamicConfig();
+            dynamicConfig.setPipelineFieldTypeId(newType.getId());
+            dynamicConfig.setConfigValue(dynamicValue.getConfigValue());
+            dynamicConfig.setConfigMapValue(dynamicValue.getConfigMapValue());
+            taxPipelineDynamicConfigRepository.insert(dynamicConfig);
+        });
+    }
+
+    @Transactional
+    public void saveFixedConfig(TaxPipelineFieldConfigCO co, TaxPipelineFieldType newType) {
+        TaxPipelineFixedConfig config = new TaxPipelineFixedConfig();
+        config.setPipelineFieldTypeId(newType.getId());
+        config.setConfigValue(co.getFixedValue());
+        taxPipelineFixedConfigRepository.insert(config);
+    }
+
+    public List<TenantPipelineConfig> listByPipelineIdAndDocumentType(Long pipelineId, String documentType) {
+        LambdaQueryWrapper<TaxPipelineFieldType> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineFieldType::getPipelineId, pipelineId);
+        queryWrapper.eq(TaxPipelineFieldType::getDocumentType, documentType);
+        List<TaxPipelineFieldType> taxPipelineFieldTypes = taxPipelineFieldTypeRepository.selectList(queryWrapper);
+        return taxPipelineFieldTypes.stream().map(e -> {
+            TenantPipelineConfig res = new TenantPipelineConfig();
+            res.setId(e.getId());
+            res.setPipelineId(e.getPipelineId());
+            res.setDocumentType(e.getDocumentType());
+            res.setConfigKey(e.getConfigKey());
+            res.setSettingFieldType(SettingFieldType.from(e.getSettingFieldType()));
+            switch (SettingFieldType.from(e.getSettingFieldType())) {
+                case FIXED -> res.setFixedValue(queryByPipelineFixedFieldTypeId(e.getId()));
+                case DYNAMIC -> res.setDynamicValues(queryByPipelineDynamicFieldTypeId(e.getId()));
+                case REMOTE -> res.setRemoteParam(queryByPipelineRemoteFieldTypeId(e.getId()));
+            }
+            return res;
+        }).toList();
+    }
+
+    /**
+     * 按管道远程字段类型 ID 查询
+     *
+     * @param id id
+     * @return {@link RemoteParam }
+     */
+    private RemoteParam queryByPipelineRemoteFieldTypeId(Long id) {
+        LambdaQueryWrapper<TaxPipelineRemoteConfig> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineRemoteConfig::getPipelineFieldTypeId, id);
+        TaxPipelineRemoteConfig taxPipelineRemoteConfig = taxPipelineRemoteConfigRepository.selectOne(queryWrapper);
+        var remote = new RemoteParam();
+        remote.setRemoteAddress(taxPipelineRemoteConfig.getRemoteAddress());
+        remote.setField(taxPipelineRemoteConfig.getField());
+        remote.setDataPath(taxPipelineRemoteConfig.getDataPath());
+        remote.setFixedParams(taxPipelineRemoteConfig.getFixedParams());
+        return remote;
+    }
+
+    /**
+     * 按管道动态字段类型 ID 查询
+     *
+     * @param id id
+     * @return {@link List }<{@link DynamicValue }>
+     */
+    private Map<String, String> queryByPipelineDynamicFieldTypeId(Long id) {
+        LambdaQueryWrapper<TaxPipelineDynamicConfig> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineDynamicConfig::getPipelineFieldTypeId, id);
+        List<TaxPipelineDynamicConfig> taxPipelineDynamicConfigs = taxPipelineDynamicConfigRepository.selectList(queryWrapper);
+        return taxPipelineDynamicConfigs.stream().map(e -> {
+            var dynamicValue = new DynamicValue();
+            dynamicValue.setConfigValue(e.getConfigValue());
+            dynamicValue.setConfigMapValue(e.getConfigMapValue());
+            return dynamicValue;
+        }).collect(Collectors.toMap(DynamicValue::getConfigValue, DynamicValue::getConfigMapValue));
+    }
+
+    /**
+     * 按管道固定字段类型 ID 查询
+     *
+     * @param id id
+     * @return {@link String }
+     */
+    private String queryByPipelineFixedFieldTypeId(Long id) {
+        LambdaQueryWrapper<TaxPipelineFixedConfig> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineFixedConfig::getPipelineFieldTypeId, id);
+        TaxPipelineFixedConfig taxPipelineFixedConfig = taxPipelineFixedConfigRepository.selectOne(queryWrapper);
+        return taxPipelineFixedConfig.getConfigValue();
+    }
+}
@@ -11,11 +11,9 @@ 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.model.co.TaxTenantCO;
 import com.diligrp.tax.storage.model.vo.TaxTenantVO;
-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;
@@ -42,7 +40,7 @@ public class TaxTenantService implements ITaxTenantService {
     @Resource
     private TaxPipelineRepository taxPipelineRepository;
     @Resource
-    private TaxPipelineConfigRepository taxPipelineConfigRepository;
+    private TaxPipelineFieldConfigService taxPipelineFieldConfigService;
     /**
@@ -85,11 +83,8 @@ public class TaxTenantService implements ITaxTenantService {
      * @return {@link List }<{@link TenantPipelineConfig }>
      */
     @Override
-    public List<TenantPipelineConfig> listByPipelineId(Long pipelineId) {
-        LambdaQueryWrapper<TaxPipelineConfig> queryWrapper = new LambdaQueryWrapper<>();
-        queryWrapper.eq(TaxPipelineConfig::getPipelineId, pipelineId);
-        List<TaxPipelineConfig> taxPipelineConfigs = taxPipelineConfigRepository.selectList(queryWrapper);
-        return taxPipelineConfigs.stream().map(taxPipelineConfig -> JsonUtils.convertValue(taxPipelineConfig, TenantPipelineConfig.class)).toList();
+    public List<TenantPipelineConfig> listByPipelineIdAndDocumentType(Long pipelineId, String documentType) {
+        return taxPipelineFieldConfigService.listByPipelineIdAndDocumentType(pipelineId,documentType);
     }