feat(mapping): 实现金蝶客户转换器验证标记功能

-为多个金蝶基础实体类实现 VerifyMarkInterface 接口 - 添加验证标记和值的获取方法 - 修改 CustomerTransformer 以支持租户管道参数- 更新 ReceiptTransformer 和 MappingProcessor 以传递租户管道信息 - 引入 ITaxPipelineVerifyService 接口定义验证输入输出方法

feat(mapping): 实现金蝶客户转换器验证标记功能
-为多个金蝶基础实体类实现 VerifyMarkInterface 接口 - 添加验证标记和值的获取方法 - 修改 CustomerTransformer 以支持租户管道参数- 更新 ReceiptTransformer 和 MappingProcessor 以传递租户管道信息 - 引入 ITaxPipelineVerifyService 接口定义验证输入输出方法
zhangmeiyang
1 parent e4f0e999
Showing 52 changed files with 1181 additions and 41 deletions
tax-central/src/main/java/com/diligrp/tax/central/domain/mapping/kingdee/VerifyMarkInterface.java
tax-central/src/main/java/com/diligrp/tax/central/domain/mapping/kingdee/base/FACCOUNTID.java
tax-central/src/main/java/com/diligrp/tax/central/domain/mapping/kingdee/base/FASSETID.java
tax-central/src/main/java/com/diligrp/tax/central/domain/mapping/kingdee/base/FBillTypeID.java
tax-central/src/main/java/com/diligrp/tax/central/domain/mapping/kingdee/base/FCONTACTUNIT.java
tax-central/src/main/java/com/diligrp/tax/central/domain/mapping/kingdee/base/FCOSTDEPARTMENTID.java
tax-central/src/main/java/com/diligrp/tax/central/domain/mapping/kingdee/base/FCOSTID.java
tax-central/src/main/java/com/diligrp/tax/central/domain/mapping/kingdee/base/FCOUNTRY.java
tax-central/src/main/java/com/diligrp/tax/central/domain/mapping/kingdee/base/FCURRENCYID.java
tax-central/src/main/java/com/diligrp/tax/central/domain/mapping/kingdee/base/FCUSTOMERID.java
tax-central/src/main/java/com/diligrp/tax/central/domain/mapping/kingdee/base/FChargeId.java
tax-central/src/main/java/com/diligrp/tax/central/domain/mapping/kingdee/base/FContactId.java
tax-central/src/main/java/com/diligrp/tax/central/domain/mapping/kingdee/base/FCreateOrgId.java
tax-central/src/main/java/com/diligrp/tax/central/domain/mapping/kingdee/base/FEntityDetail.java
tax-central/src/main/java/com/diligrp/tax/central/domain/mapping/kingdee/base/FGroup.java
tax-central/src/main/java/com/diligrp/tax/central/domain/mapping/kingdee/base/FMAINBOOKSTDCURRID.java
tax-central/src/main/java/com/diligrp/tax/central/domain/mapping/kingdee/base/FORDERID.java
tax-central/src/main/java/com/diligrp/tax/central/domain/mapping/kingdee/base/FPAYORGID.java
tax-central/src/main/java/com/diligrp/tax/central/domain/mapping/kingdee/base/FPAYUNIT.java
tax-central/src/main/java/com/diligrp/tax/central/domain/mapping/kingdee/base/FPROVINCIAL.java
+package com.diligrp.tax.central.domain.mapping.kingdee;
+
+public interface VerifyMarkInterface {
+
+    String getVerifyMark();
+
+    String value();
+}
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-11-25 15:27
  * @Version: todo
  */
-public class FACCOUNTID {
+public class FACCOUNTID implements VerifyMarkInterface {
  
     private String FNumber;
  
@@ -19,4 +20,14 @@ public class FACCOUNTID {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FACCOUNTID.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-10 10:04
  * @Version: todo
  */
-public class FASSETID {
+public class FASSETID implements VerifyMarkInterface {
     private String FNUMBER;
  
     @JsonProperty("FNUMBER")
@@ -18,4 +19,14 @@ public class FASSETID {
     public void setFNUMBER(String FNUMBER) {
         this.FNUMBER = FNUMBER;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FASSETID.FNUMBER";
+    }
+
+    @Override
+    public String value() {
+        return FNUMBER;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-09 10:26
  * @Version: todo
  */
-public class FBillTypeID {
+public class FBillTypeID implements VerifyMarkInterface {
     private String FNUMBER;
  
     @JsonProperty("FNUMBER")
@@ -18,4 +19,14 @@ public class FBillTypeID {
     public void setFNUMBER(String FNUMBER) {
         this.FNUMBER = FNUMBER;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FBillTypeID.FNUMBER";
+    }
+
+    @Override
+    public String value() {
+        return FNUMBER;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-23 15:15
  * @Version: todo
  */
-public class FCONTACTUNIT {
+public class FCONTACTUNIT implements VerifyMarkInterface {
     private String FNumber;
  
     @JsonProperty("FNumber")
@@ -18,4 +19,14 @@ public class FCONTACTUNIT {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FCONTACTUNIT.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-10 10:04
  * @Version: todo
  */
-public class FCOSTDEPARTMENTID {
+public class FCOSTDEPARTMENTID implements VerifyMarkInterface {
     private String FNUMBER;
  
     @JsonProperty("FNUMBER")
@@ -18,4 +19,14 @@ public class FCOSTDEPARTMENTID {
     public void setFNUMBER(String FNUMBER) {
         this.FNUMBER = FNUMBER;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FCOSTDEPARTMENTID.FNUMBER";
+    }
+
+    @Override
+    public String value() {
+        return FNUMBER;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-10 10:03
  * @Version: todo
  */
-public class FCOSTID {
+public class FCOSTID implements VerifyMarkInterface {
     private String FNUMBER;
  
     @JsonProperty("FNUMBER")
@@ -18,4 +19,14 @@ public class FCOSTID {
     public void setFNUMBER(String FNUMBER) {
         this.FNUMBER = FNUMBER;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FCOSTID.FNUMBER";
+    }
+
+    @Override
+    public String value() {
+        return FNUMBER;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-23 15:15
  * @Version: todo
  */
-public class FCOUNTRY {
+public class FCOUNTRY implements VerifyMarkInterface {
     private String FNumber;
  
     @JsonProperty("FNumber")
@@ -18,4 +19,14 @@ public class FCOUNTRY {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FCOUNTRY.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-09 10:25
  * @Version: todo
  */
-public class FCURRENCYID {
+public class FCURRENCYID implements VerifyMarkInterface {
  
     private String FNumber;
  
@@ -19,4 +20,14 @@ public class FCURRENCYID {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FCURRENCYID.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-10 10:00
  * @Version: todo
  */
-public class FCUSTOMERID {
+public class FCUSTOMERID implements VerifyMarkInterface {
  
     private String FNumber;
  
@@ -19,4 +20,14 @@ public class FCUSTOMERID {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FCUSTOMERID.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-10 10:06
  * @Version: todo
  */
-public class FChargeId {
+public class FChargeId implements VerifyMarkInterface {
     private String FNumber;
  
     @JsonProperty("FNumber")
@@ -18,4 +19,14 @@ public class FChargeId {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FChargeId.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-23 17:56
  * @Version: todo
  */
-public class FContactId {
+public class FContactId implements VerifyMarkInterface {
     private String FNUMBER;
  
     @JsonProperty("FNUMBER")
@@ -18,4 +19,14 @@ public class FContactId {
     public void setFNUMBER(String FNUMBER) {
         this.FNUMBER = FNUMBER;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FContactId.FNUMBER";
+    }
+
+    @Override
+    public String value() {
+        return FNUMBER;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-23 15:15
  * @Version: todo
  */
-public class FCreateOrgId {
+public class FCreateOrgId implements VerifyMarkInterface {
     private String FNumber;
  
     @JsonProperty("FNumber")
@@ -18,4 +19,14 @@ public class FCreateOrgId {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FCreateOrgId.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
@@ -2,8 +2,6 @@ package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
 import com.fasterxml.jackson.annotation.JsonProperty;
  
-import java.math.BigDecimal;
-
 /**
  * @Author: zhangmeiyang
  * @CreateTime: 2024-10-28 16:41
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-23 15:15
  * @Version: todo
  */
-public class FGroup {
+public class FGroup implements VerifyMarkInterface {
     private String FNumber;
  
     @JsonProperty("FNumber")
@@ -18,4 +19,14 @@ public class FGroup {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FGroup.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-10 10:06
  * @Version: todo
  */
-public class FMAINBOOKSTDCURRID {
+public class FMAINBOOKSTDCURRID implements VerifyMarkInterface {
  
     private String FNumber;
  
@@ -19,4 +20,14 @@ public class FMAINBOOKSTDCURRID {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FMAINBOOKSTDCURRID.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-10 10:06
  * @Version: todo
  */
-public class FORDERID {
+public class FORDERID implements VerifyMarkInterface {
     private String FNumber;
  
     @JsonProperty("FNumber")
@@ -18,4 +19,14 @@ public class FORDERID {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FORDERID.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-10 10:01
  * @Version: todo
  */
-public class FPAYORGID {
+public class FPAYORGID implements VerifyMarkInterface {
  
     private String FNumber;
  
@@ -19,4 +20,14 @@ public class FPAYORGID {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FPAYORGID.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-23 15:15
  * @Version: todo
  */
-public class FPAYUNIT {
+public class FPAYUNIT implements VerifyMarkInterface {
     private String FNumber;
  
     @JsonProperty("FNumber")
@@ -18,4 +19,14 @@ public class FPAYUNIT {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FPAYUNIT.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-23 15:15
  * @Version: todo
  */
-public class FPROVINCIAL {
+public class FPROVINCIAL implements VerifyMarkInterface {
     private String FNumber;
  
     @JsonProperty("FNumber")
@@ -18,4 +19,14 @@ public class FPROVINCIAL {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FPROVINCIAL.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-23 15:15
  * @Version: todo
  */
-public class FPURPOSEID {
+public class FPURPOSEID implements VerifyMarkInterface {
     private String FNumber;
  
     @JsonProperty("FNumber")
@@ -18,4 +19,14 @@ public class FPURPOSEID {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FPURPOSEID.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-11-25 15:27
  * @Version: todo
  */
-public class FRECTUNIT {
+public class FRECTUNIT implements VerifyMarkInterface {
  
     private String FNumber;
  
@@ -19,4 +20,14 @@ public class FRECTUNIT {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FRECTUNIT.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-10 10:01
  * @Version: todo
  */
-public class FSALEDEPTID {
+public class FSALEDEPTID implements VerifyMarkInterface {
     private String FNumber;
  
     @JsonProperty("FNumber")
@@ -18,4 +19,14 @@ public class FSALEDEPTID {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FSALEDEPTID.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-10 10:00
  * @Version: todo
  */
-public class FSALEORGID {
+public class FSALEORGID implements VerifyMarkInterface {
  
     private String FNumber;
  
@@ -19,4 +20,14 @@ public class FSALEORGID {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FSALEORGID.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-10 10:04
  * @Version: todo
  */
-public class FSETTLECUR {
+public class FSETTLECUR implements VerifyMarkInterface {
     private String FNUMBER;
  
     @JsonProperty("FNUMBER")
@@ -18,4 +19,14 @@ public class FSETTLECUR {
     public void setFNUMBER(String FNUMBER) {
         this.FNUMBER = FNUMBER;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FSETTLECUR.FNUMBER";
+    }
+
+    @Override
+    public String value() {
+        return FNUMBER;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-10 10:03
  * @Version: todo
  */
-public class FSETTLEMAINBOOKID {
+public class FSETTLEMAINBOOKID implements VerifyMarkInterface {
     private String FNUMBER;
  
     @JsonProperty("FNUMBER")
@@ -18,4 +19,14 @@ public class FSETTLEMAINBOOKID {
     public void setFNUMBER(String FNUMBER) {
         this.FNUMBER = FNUMBER;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FSETTLEMAINBOOKID.FNUMBER";
+    }
+
+    @Override
+    public String value() {
+        return FNUMBER;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-09 10:24
  * @Version: todo
  */
-public class FSETTLEORGID {
+public class FSETTLEORGID implements VerifyMarkInterface {
     private String FNumber;
  
     @JsonProperty("FNumber")
@@ -18,4 +19,14 @@ public class FSETTLEORGID {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FSETTLEORGID.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-11-25 15:29
  * @Version: todo
  */
-public class FSETTLETYPE {
+public class FSETTLETYPE implements VerifyMarkInterface {
  
     private String FNumber;
  
@@ -19,4 +20,14 @@ public class FSETTLETYPE {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FSETTLETYPEID.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-10 10:06
  * @Version: todo
  */
-public class FSettleTypeID {
+public class FSettleTypeID implements VerifyMarkInterface {
     private String FNumber;
  
     @JsonProperty("FNumber")
@@ -18,4 +19,14 @@ public class FSettleTypeID {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FSettleTypeID.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-23 15:15
  * @Version: todo
  */
-public class FTRADINGCURRID {
+public class FTRADINGCURRID implements VerifyMarkInterface {
     private String FNumber;
  
     @JsonProperty("FNumber")
@@ -18,4 +19,14 @@ public class FTRADINGCURRID {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FTRADINGCURRID.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-10 10:05
  * @Version: todo
  */
-public class FTRANSFERID {
+public class FTRANSFERID implements VerifyMarkInterface {
     private String FNumber;
  
     @JsonProperty("FNumber")
@@ -18,4 +19,14 @@ public class FTRANSFERID {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FTRANSFERID.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2024-10-23 15:15
  * @Version: todo
  */
-public class FUseOrgId {
+public class FUseOrgId implements VerifyMarkInterface {
     private String FNumber;
  
     @JsonProperty("FNumber")
@@ -18,4 +19,14 @@ public class FUseOrgId {
     public void setFNumber(String FNumber) {
         this.FNumber = FNumber;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "FUseOrgId.FNumber";
+    }
+
+    @Override
+    public String value() {
+        return FNumber;
+    }
 }
 package com.diligrp.tax.central.domain.mapping.kingdee.base;
  
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.fasterxml.jackson.annotation.JsonProperty;
  
 /**
@@ -7,7 +8,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
  * @CreateTime: 2025-09-19 14:53
  * @Version: todo
  */
-public class F_PZCW_Base_qtr {
+public class F_PZCW_Base_qtr implements VerifyMarkInterface {
     private String FName;
  
     @JsonProperty("FName")
@@ -18,4 +19,14 @@ public class F_PZCW_Base_qtr {
     public void setFName(String FName) {
         this.FName = FName;
     }
+
+    @Override
+    public String getVerifyMark() {
+        return "F_PZCW_Base_qtr.FName";
+    }
+
+    @Override
+    public String value() {
+        return FName;
+    }
 }
+package com.diligrp.tax.central.model;
+
+import lombok.Getter;
+import lombok.Setter;
+
+import java.time.LocalDateTime;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-11 18:44
+ * @Version: todo
+ */
+@Getter
+@Setter
+public class TaxPipelineVerify {
+    /**
+     *
+     */
+    private Long id;
+
+    /**
+     * 账套ID
+     */
+    private Long pipelineId;
+
+    /**
+     * 业务单据类型
+     */
+    private String documentType;
+
+    /**
+     * 配置验证字段名称
+     */
+    private String configVerifyField;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdTime;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime modifiedTime;
+}
+package com.diligrp.tax.central.model;
+
+import lombok.Getter;
+import lombok.Setter;
+
+import java.time.LocalDateTime;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-11 18:44
+ * @Version: todo
+ */
+@Getter
+@Setter
+public class TaxPipelineVerifyReturn {
+    /**
+     *
+     */
+    private Long id;
+
+    /**
+     * 账套ID
+     */
+    private Long pipelineId;
+
+    /**
+     * 业务单据类型
+     */
+    private String documentType;
+
+    /**
+     * 配置验证字段名称
+     */
+    private String configReturnField;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdTime;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime modifiedTime;
+}
+package com.diligrp.tax.central.service;
+
+import com.diligrp.tax.central.model.TaxPipelineVerify;
+import com.diligrp.tax.central.model.TaxPipelineVerifyReturn;
+
+import java.util.List;
+
+public interface ITaxPipelineVerifyService {
+
+    /**
+     * 验证输入
+     *
+     * @param pipelineId   管道 ID
+     * @param documentType 文档类型
+     * @return {@link List }<{@link TaxPipelineVerify }>
+     */
+    List<TaxPipelineVerify> verifyInput(Long pipelineId, String documentType);
+
+    /**
+     * 验证输出
+     *
+     * @param pipelineId   管道 ID
+     * @param documentType 文档类型
+     * @return {@link TaxPipelineVerifyReturn }
+     */
+    TaxPipelineVerifyReturn verifyOutput(Long pipelineId, String documentType);
+}
@@ -2,15 +2,32 @@ package com.diligrp.tax.mapping.demarcate;
  
 import com.diligrp.tax.central.domain.BaseDocument;
 import com.diligrp.tax.central.domain.BaseMapping;
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
+import com.diligrp.tax.central.exception.TaxAgentServiceException;
+import com.diligrp.tax.central.model.TaxPipelineVerify;
+import com.diligrp.tax.central.model.TaxPipelineVerifyReturn;
+import com.diligrp.tax.central.model.TenantPipeline;
+import com.diligrp.tax.central.service.ITaxPipelineVerifyService;
 import com.diligrp.tax.central.type.DocumentType;
+import com.diligrp.tax.central.type.TaxSystemType;
+import com.diligrp.tax.central.utils.MappingUtils;
+import jakarta.annotation.Resource;
+import lombok.extern.slf4j.Slf4j;
+
+import java.lang.reflect.Field;
+import java.util.*;
  
 /**
  * @Author: zhangmeiyang
  * @CreateTime: 2025-10-30 18:36
  * @Version: todo
  */
+@Slf4j
 public abstract class Transformer<T extends BaseMapping> {
  
+    @Resource
+    protected ITaxPipelineVerifyService taxPipelineVerifyService;
+
     /**
      * 标记文档
      *
@@ -21,8 +38,83 @@ public abstract class Transformer&lt;T extends BaseMapping&gt; {
     /**
      * 变换
      *
-     * @param document 公文
+     * @param document       公文
+     * @param tenantPipeline
      * @return {@link T }
      */
-    public abstract T transform(BaseDocument document);
+    public abstract T transform(BaseDocument document, TenantPipeline tenantPipeline);
+
+
+    /**
+     * 获取验证密钥
+     *
+     * @param pipelineId 管道 ID
+     * @return {@link List }<{@link String }>
+     */
+    protected List<String> getVerifyKeys(Long pipelineId) {
+        List<TaxPipelineVerify> taxPipelineVerifies = taxPipelineVerifyService.verifyInput(pipelineId, markDocument().value);
+        return Optional.ofNullable(taxPipelineVerifies).orElse(List.of()).stream().map(TaxPipelineVerify::getConfigVerifyField).toList();
+    }
+
+    /**
+     * 获取返回值
+     *
+     * @param pipelineId 管道 ID
+     * @return {@link String }
+     */
+    protected String getReturnKeys(Long pipelineId) {
+        TaxPipelineVerifyReturn taxPipelineVerifyReturn = taxPipelineVerifyService.verifyOutput(pipelineId, markDocument().value);
+        if (Objects.isNull(taxPipelineVerifyReturn)) {
+            return "";
+        }
+        return taxPipelineVerifyReturn.getConfigReturnField();
+    }
+
+
+    /**
+     * 获取验证字符串
+     *
+     * @param verifyKeys 验证密钥
+     * @param mapping
+     * @return {@link String }
+     */
+    protected String getVerifyString(List<String> verifyKeys, BaseMapping mapping) {
+        var verifyKeysSet = new HashSet<>(verifyKeys);
+        List<String> concatVerify = new ArrayList<>();
+        List<Field> fields = MappingUtils.listFields(mapping.getClass());
+        fields.forEach(field -> {
+            if (verifyKeysSet.contains(field.getName())) {
+                try {
+                    if (VerifyMarkInterface.class.isAssignableFrom(field.getType())) {
+                        // 获取字段值
+                        field.setAccessible(true);
+                        Object fieldValue = field.get(mapping);
+                        // 检查字段值是否为null
+                        if (Objects.nonNull(fieldValue)) {
+                            VerifyMarkInterface verifyObject = (VerifyMarkInterface) fieldValue;
+                            String verifyMark = verifyObject.getVerifyMark();
+                            String value = verifyObject.value();
+                            if (Objects.nonNull(value)) {
+                                var verify = verifyMark + "=" + value;
+                                concatVerify.add(verify);
+                            }
+                        }
+                    }
+                    if (field.getType().equals(String.class)) {
+                        field.setAccessible(true);
+                        Object fieldValue = field.get(mapping);
+                        if (Objects.nonNull(fieldValue)) {
+                            String verify = field.getName() + "=" + fieldValue;
+                            concatVerify.add(verify);
+                        }
+                    }
+                } catch (IllegalAccessException e) {
+                    log.error("获取字段值异常", e);
+                    throw new TaxAgentServiceException(TaxSystemType.ABNORMAL_PARAMETERS);
+                }
+            }
+        });
+        log.info("verifyInfo is {},", String.join(" and ", concatVerify));
+        return String.join(" and ", concatVerify);
+    }
 }
 package com.diligrp.tax.mapping.demarcate.kingdee;
  
 import com.diligrp.tax.central.domain.BaseDocument;
+import com.diligrp.tax.central.domain.BaseMapping;
 import com.diligrp.tax.central.domain.document.kingdee.basic.StandardCustomer;
 import com.diligrp.tax.central.domain.mapping.kingdee.CustomerMapping;
+import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
+import com.diligrp.tax.central.exception.TaxAgentServiceException;
+import com.diligrp.tax.central.model.TenantPipeline;
 import com.diligrp.tax.central.type.DocumentType;
+import com.diligrp.tax.central.type.TaxSystemType;
 import com.diligrp.tax.central.utils.MappingUtils;
 import com.diligrp.tax.mapping.demarcate.Transformer;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
  
+import java.lang.reflect.Field;
+import java.util.ArrayList;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Optional;
+
 /**
  * @Author: zhangmeiyang
  * @CreateTime: 2025-11-04 16:50
  * @Version: todo
  */
+@Slf4j
 @Component
 public class CustomerTransformer extends Transformer<CustomerMapping> {
  
@@ -22,10 +35,13 @@ public class CustomerTransformer extends Transformer&lt;CustomerMapping&gt; {
     }
  
     @Override
-    public CustomerMapping transform(BaseDocument document) {
+    public CustomerMapping transform(BaseDocument document, TenantPipeline tenantPipeline) {
         StandardCustomer customer = (StandardCustomer) document;
         CustomerMapping mapping = MappingUtils.convertValue(customer, CustomerMapping.class);
-        //TODO 组装部分参数字段
+        List<String> verifyKeys = getVerifyKeys(tenantPipeline.getId());
+        String returnKeys = getReturnKeys(tenantPipeline.getId());
+        Optional.ofNullable(verifyKeys).ifPresent(e -> mapping.setVerifyInformation(getVerifyString(verifyKeys, mapping)));
+        Optional.ofNullable(returnKeys).ifPresent(mapping::setReturnKeys);
         return mapping;
     }
 }
@@ -3,6 +3,7 @@ package com.diligrp.tax.mapping.demarcate.kingdee;
 import com.diligrp.tax.central.domain.BaseDocument;
 import com.diligrp.tax.central.domain.document.kingdee.bill.ReceiptBill;
 import com.diligrp.tax.central.domain.mapping.kingdee.ReceiptMapping;
+import com.diligrp.tax.central.model.TenantPipeline;
 import com.diligrp.tax.central.type.DocumentType;
 import com.diligrp.tax.central.utils.MappingUtils;
 import com.diligrp.tax.mapping.demarcate.Transformer;
@@ -23,7 +24,7 @@ public class ReceiptTransformer extends Transformer&lt;ReceiptMapping&gt; {
     }
  
     @Override
-    public ReceiptMapping transform(BaseDocument document) {
+    public ReceiptMapping transform(BaseDocument document, TenantPipeline tenantPipeline) {
         ReceiptBill bill = (ReceiptBill) document;
         ReceiptMapping mapping = MappingUtils.convertValue(bill,ReceiptMapping.class);
         var verifyInformation = "FBillTypeID.FNumber = 'scfyys-001' AND F_ZDB_text1 ='202510310900489' AND FALLAMOUNTFOR = '515.0' AND F_ZDB_Text667 = '正向流程' AND F_ZDB_Text5 ='666625013581'";
@@ -3,6 +3,7 @@ package com.diligrp.tax.mapping.demarcate.kingdee;
 import com.diligrp.tax.central.domain.BaseDocument;
 import com.diligrp.tax.central.domain.document.kingdee.bill.ReceivableBill;
 import com.diligrp.tax.central.domain.mapping.kingdee.ReceivableMapping;
+import com.diligrp.tax.central.model.TenantPipeline;
 import com.diligrp.tax.central.type.DocumentType;
 import com.diligrp.tax.central.utils.MappingUtils;
 import com.diligrp.tax.mapping.demarcate.Transformer;
@@ -23,7 +24,7 @@ public class ReceivableTransformer extends Transformer&lt;ReceivableMapping&gt; {
     }
  
     @Override
-    public ReceivableMapping transform(BaseDocument document) {
+    public ReceivableMapping transform(BaseDocument document, TenantPipeline tenantPipeline) {
         ReceivableBill bill = (ReceivableBill) document;
         ReceivableMapping mapping = MappingUtils.convertValue(bill,ReceivableMapping.class);
         var verifyInformation = "FBillTypeID.FNumber = 'scfyys-001' AND F_ZDB_text1 ='202510310900489' AND FALLAMOUNTFOR = '515.0' AND F_ZDB_Text667 = '正向流程' AND F_ZDB_Text5 ='666625013581'";
@@ -3,6 +3,7 @@ package com.diligrp.tax.mapping.demarcate.kingdee;
 import com.diligrp.tax.central.domain.BaseDocument;
 import com.diligrp.tax.central.domain.document.kingdee.bill.RefundBill;
 import com.diligrp.tax.central.domain.mapping.kingdee.RefundMapping;
+import com.diligrp.tax.central.model.TenantPipeline;
 import com.diligrp.tax.central.type.DocumentType;
 import com.diligrp.tax.central.utils.MappingUtils;
 import com.diligrp.tax.mapping.demarcate.Transformer;
@@ -23,7 +24,7 @@ public class RefundTransformer extends Transformer&lt;RefundMapping&gt; {
     }
  
     @Override
-    public RefundMapping transform(BaseDocument document) {
+    public RefundMapping transform(BaseDocument document, TenantPipeline tenantPipeline) {
         RefundBill bill = (RefundBill) document;
         RefundMapping mapping = MappingUtils.convertValue(bill,RefundMapping.class);
         var verifyInformation = "FBillTypeID.FNumber = 'scfyys-001' AND F_ZDB_text1 ='202510310900489' AND FALLAMOUNTFOR = '515.0' AND F_ZDB_Text667 = '正向流程' AND F_ZDB_Text5 ='666625013581'";
@@ -29,7 +29,7 @@ public class MappingProcessor extends AbstractProcessor {
     @Override
     public MessageContext process(MessageContext messageContext) {
         Transformer<?> transformer = MappingContext.CONTEXT.get(messageContext.getDocumentTypeEnum());
-        BaseMapping transform = transformer.transform(messageContext.getDocumentObject());
+        BaseMapping transform = transformer.transform(messageContext.getDocumentObject(),messageContext.getTenantPipeline());
         messageContext.setMappingObject(transform);
         Map<String,Object> map = JsonUtils.convertValue(transform, new TypeReference<>() {});
         log.info("转换结果,{}", JsonUtils.toJsonString(map));
+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.TaxPipelineFieldVerifyCO;
+import com.diligrp.tax.storage.model.co.TaxPipelineFieldVerifyReturnCO;
+import com.diligrp.tax.storage.service.TaxPipelineFieldVerifyService;
+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;
+
+import java.util.List;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-11 18:33
+ * @Version: todo
+ */
+@RestController
+@RequestMapping("/tax/tenant/pipeline/field/verify")
+public class TaxPipelineFieldVerifyController {
+
+    @Resource
+    private TaxPipelineFieldVerifyService taxPipelineFieldVerifyService;
+
+    /**
+     * 保存验证
+     *
+     * @param list 列表
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/saveVerify")
+    public Message<?> saveVerify(@RequestBody @Validated(value = Valid.Create.class) List<TaxPipelineFieldVerifyCO> list) {
+        taxPipelineFieldVerifyService.saveVerify(list);
+        return Message.success();
+    }
+
+    /**
+     * 删除验证
+     *
+     * @param id id
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/deleteVerify/{id}")
+    public Message<?> deleteVerify(@PathVariable Long id) {
+        taxPipelineFieldVerifyService.deleteVerify(id);
+        return Message.success();
+    }
+
+    /**
+     * 按管道列出验证
+     *
+     * @param pipelineId 管道 ID
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/listVerifyByPipeline/{pipelineId}")
+    public Message<?> listVerifyByPipeline(@PathVariable String pipelineId) {
+        return Message.success(taxPipelineFieldVerifyService.listVerifyByPipeline(pipelineId));
+    }
+
+    /**
+     * 列表按管道和文档验证
+     *
+     * @param co 公司
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/listVerifyByPipelineAndDocument")
+    public Message<?> listVerifyByPipelineAndDocument(@RequestBody @Validated(value = Valid.Read.class) TaxPipelineFieldVerifyCO co) {
+        return Message.success(taxPipelineFieldVerifyService.listVerifyByPipelineAndDocument(co));
+    }
+
+    /**
+     * 保存返回键
+     *
+     * @param co 公司
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/saveReturnKey")
+    public Message<?> saveReturnKey(@RequestBody @Validated(value = Valid.Create.class) TaxPipelineFieldVerifyReturnCO co) {
+        taxPipelineFieldVerifyService.saveReturnKey(co);
+        return Message.success();
+    }
+
+    /**
+     * 按管道获取返回密钥
+     *
+     * @param pipelineId 管道 ID
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/getReturnKeyByPipeline/{pipelineId}")
+    public Message<?> getReturnKeyByPipeline(@PathVariable String pipelineId) {
+        return Message.success(taxPipelineFieldVerifyService.getReturnKeyByPipeline(pipelineId));
+    }
+
+    /**
+     * 按管道和文档获取返回密钥
+     *
+     * @param co 公司
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/getReturnKeyByPipelineAndDocument")
+    public Message<?> getReturnKeyByPipelineAndDocument(@RequestBody @Validated(value = Valid.Read.class) TaxPipelineFieldVerifyCO co) {
+        return Message.success(taxPipelineFieldVerifyService.getReturnKeyByPipelineAndDocument(co));
+    }
+}
+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_field_verify
+ */
+@TableName(value ="tax_pipeline_field_verify")
+@Data
+public class TaxPipelineFieldVerify {
+    /**
+     *
+     */
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 账套ID
+     */
+    @TableField(value = "pipeline_id")
+    private Long pipelineId;
+
+    /**
+     * 业务单据类型
+     */
+    @TableField(value = "document_type")
+    private String documentType;
+
+    /**
+     * 配置验证字段名称
+     */
+    @TableField(value = "config_verify_field")
+    private String configVerifyField;
+
+    /**
+     * 创建时间
+     */
+    @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_field_verify_return
+ */
+@TableName(value ="tax_pipeline_field_verify_return")
+@Data
+public class TaxPipelineFieldVerifyReturn {
+    /**
+     *
+     */
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 账套ID
+     */
+    @TableField(value = "pipeline_id")
+    private Long pipelineId;
+
+    /**
+     * 业务单据类型
+     */
+    @TableField(value = "document_type")
+    private String documentType;
+
+    /**
+     * 配置验证值返回字段名称
+     */
+    @TableField(value = "config_return_field")
+    private String configReturnField;
+
+    /**
+     * 创建时间
+     */
+    @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 jakarta.validation.constraints.NotEmpty;
+import jakarta.validation.constraints.NotNull;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-11 18:35
+ * @Version: todo
+ */
+@Getter
+@Setter
+public class TaxPipelineFieldVerifyCO {
+    /**
+     * 账套ID
+     */
+    @NotNull(groups = {Valid.Create.class, Valid.Read.class})
+    private Long pipelineId;
+
+    /**
+     * 业务单据类型
+     */
+    @NotEmpty(groups = {Valid.Create.class, Valid.Read.class})
+    private String documentType;
+
+    /**
+     * 配置验证字段名称
+     */
+    @NotEmpty(groups = {Valid.Create.class})
+    private String configVerifyField;
+}
+package com.diligrp.tax.storage.model.co;
+
+import com.diligrp.tax.storage.Valid;
+import jakarta.validation.constraints.NotEmpty;
+import jakarta.validation.constraints.NotNull;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * 账套字段验证重复表
+ *
+ * @TableName tax_pipeline_field_verify_return
+ */
+@Getter
+@Setter
+public class TaxPipelineFieldVerifyReturnCO {
+
+    /**
+     * 账套ID
+     */
+    @NotNull(groups = {Valid.Create.class, Valid.Read.class})
+    private Long pipelineId;
+
+    /**
+     * 业务单据类型
+     */
+    @NotEmpty(groups = {Valid.Create.class, Valid.Read.class})
+    private String documentType;
+
+    /**
+     * 配置验证值返回字段名称
+     */
+    @NotEmpty(groups = {Valid.Create.class})
+    private String configReturnField;
+}
+package com.diligrp.tax.storage.model.vo;
+
+import lombok.Getter;
+import lombok.Setter;
+
+import java.time.LocalDateTime;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-11 18:44
+ * @Version: todo
+ */
+@Getter
+@Setter
+public class TaxPipelineFieldVerifyReturnVO {
+    /**
+     *
+     */
+    private Long id;
+
+    /**
+     * 账套ID
+     */
+    private Long pipelineId;
+
+    /**
+     * 业务单据类型
+     */
+    private String documentType;
+
+    /**
+     * 配置验证字段名称
+     */
+    private String configReturnField;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdTime;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime modifiedTime;
+}
+package com.diligrp.tax.storage.model.vo;
+
+import lombok.Getter;
+import lombok.Setter;
+
+import java.time.LocalDateTime;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-11 18:44
+ * @Version: todo
+ */
+@Getter
+@Setter
+public class TaxPipelineFieldVerifyVO {
+    /**
+     *
+     */
+    private Long id;
+
+    /**
+     * 账套ID
+     */
+    private Long pipelineId;
+
+    /**
+     * 业务单据类型
+     */
+    private String documentType;
+
+    /**
+     * 配置验证字段名称
+     */
+    private String configVerifyField;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdTime;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime modifiedTime;
+}
+package com.diligrp.tax.storage.repo;
+
+import com.diligrp.tax.storage.domain.TaxPipelineFieldVerify;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.springframework.stereotype.Repository;
+
+/**
+* @author dili
+* @description 针对表【tax_pipeline_field_verify(账套字段验证重复表)】的数据库操作Mapper
+* @createDate 2025-11-11 18:31:50
+* @Entity com.diligrp.tax.storage.domain.TaxPipelineFieldVerify
+*/
+@Repository
+public interface TaxPipelineFieldVerifyRepository extends BaseMapper<TaxPipelineFieldVerify> {
+
+}
+
+
+
+
+package com.diligrp.tax.storage.repo;
+
+import com.diligrp.tax.storage.domain.TaxPipelineFieldVerifyReturn;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.springframework.stereotype.Repository;
+
+/**
+* @author dili
+* @description 针对表【tax_pipeline_field_verify_return(账套字段验证重复表)】的数据库操作Mapper
+* @createDate 2025-11-11 18:31:50
+* @Entity com.diligrp.tax.storage.domain.TaxPipelineFieldVerifyReturn
+*/
+@Repository
+public interface TaxPipelineFieldVerifyReturnRepository extends BaseMapper<TaxPipelineFieldVerifyReturn> {
+
+}
+
+
+
+
+package com.diligrp.tax.storage.service;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.diligrp.tax.central.model.TaxPipelineVerify;
+import com.diligrp.tax.central.model.TaxPipelineVerifyReturn;
+import com.diligrp.tax.central.service.ITaxPipelineVerifyService;
+import com.diligrp.tax.central.type.DocumentType;
+import com.diligrp.tax.central.utils.JsonUtils;
+import com.diligrp.tax.storage.domain.TaxPipelineFieldVerify;
+import com.diligrp.tax.storage.domain.TaxPipelineFieldVerifyReturn;
+import com.diligrp.tax.storage.model.co.TaxPipelineFieldVerifyCO;
+import com.diligrp.tax.storage.model.co.TaxPipelineFieldVerifyReturnCO;
+import com.diligrp.tax.storage.model.vo.TaxPipelineFieldVerifyReturnVO;
+import com.diligrp.tax.storage.model.vo.TaxPipelineFieldVerifyVO;
+import com.diligrp.tax.storage.repo.TaxPipelineFieldVerifyRepository;
+import com.diligrp.tax.storage.repo.TaxPipelineFieldVerifyReturnRepository;
+import jakarta.annotation.Resource;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-11 18:36
+ * @Version: todo
+ */
+@Service
+public class TaxPipelineFieldVerifyService implements ITaxPipelineVerifyService {
+
+    @Resource
+    private TaxPipelineFieldVerifyRepository taxPipelineFieldVerifyRepository;
+
+    @Resource
+    private TaxPipelineFieldVerifyReturnRepository taxPipelineFieldVerifyReturnRepository;
+
+    /**
+     * 保存验证
+     *
+     * @param list 列表
+     */
+    @Transactional
+    public void saveVerify(List<TaxPipelineFieldVerifyCO> list) {
+        List<TaxPipelineFieldVerify> saveList = list.stream().map(item -> {
+            DocumentType.validateDocumentType(item.getDocumentType());
+            return JsonUtils.convertValue(item, TaxPipelineFieldVerify.class);
+        }).toList();
+        taxPipelineFieldVerifyRepository.insert(saveList);
+    }
+
+
+    /**
+     * 删除验证
+     *
+     * @param id id
+     */
+    @Transactional
+    public void deleteVerify(Long id) {
+        taxPipelineFieldVerifyRepository.deleteById(id);
+    }
+
+    /**
+     * 按管道列出验证
+     *
+     * @param pipelineId 管道 ID
+     * @return {@link List }<{@link TaxPipelineFieldVerifyVO }>
+     */
+    public List<TaxPipelineFieldVerifyVO> listVerifyByPipeline(String pipelineId) {
+        LambdaQueryWrapper<TaxPipelineFieldVerify> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineFieldVerify::getPipelineId, pipelineId);
+        return taxPipelineFieldVerifyRepository.selectList(queryWrapper).stream().map(item -> JsonUtils.convertValue(item, TaxPipelineFieldVerifyVO.class)).toList();
+    }
+
+    /**
+     * 列表按管道和文档验证
+     *
+     * @param co 公司
+     * @return {@link List }<{@link TaxPipelineFieldVerifyVO }>
+     */
+    public List<TaxPipelineFieldVerifyVO> listVerifyByPipelineAndDocument(TaxPipelineFieldVerifyCO co) {
+        LambdaQueryWrapper<TaxPipelineFieldVerify> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineFieldVerify::getPipelineId, co.getPipelineId());
+        queryWrapper.eq(TaxPipelineFieldVerify::getDocumentType, co.getDocumentType());
+        return taxPipelineFieldVerifyRepository.selectList(queryWrapper).stream().map(item -> JsonUtils.convertValue(item, TaxPipelineFieldVerifyVO.class)).toList();
+    }
+
+    /**
+     * 保存返回键
+     *
+     * @param co 公司
+     */
+    @Transactional
+    public void saveReturnKey(TaxPipelineFieldVerifyReturnCO co) {
+        DocumentType.validateDocumentType(co.getDocumentType());
+        taxPipelineFieldVerifyReturnRepository.insert(JsonUtils.convertValue(co, TaxPipelineFieldVerifyReturn.class));
+    }
+
+    /**
+     * 按管道获取返回密钥
+     *
+     * @param pipelineId 管道 ID
+     * @return {@link List }<{@link TaxPipelineFieldVerifyReturnVO }>
+     */
+    public List<TaxPipelineFieldVerifyReturnVO> getReturnKeyByPipeline(String pipelineId) {
+        LambdaQueryWrapper<TaxPipelineFieldVerifyReturn> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineFieldVerifyReturn::getPipelineId, pipelineId);
+        return taxPipelineFieldVerifyReturnRepository.selectList(queryWrapper).stream().map(item -> JsonUtils.convertValue(item, TaxPipelineFieldVerifyReturnVO.class)).toList();
+    }
+
+    /**
+     * 按管道和文档获取返回键
+     *
+     * @param co 公司
+     * @return {@link TaxPipelineFieldVerifyReturnVO }
+     */
+    public TaxPipelineFieldVerifyReturnVO getReturnKeyByPipelineAndDocument(TaxPipelineFieldVerifyCO co) {
+        LambdaQueryWrapper<TaxPipelineFieldVerifyReturn> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineFieldVerifyReturn::getPipelineId, co.getPipelineId());
+        queryWrapper.eq(TaxPipelineFieldVerifyReturn::getDocumentType, co.getDocumentType());
+        return JsonUtils.convertValue(taxPipelineFieldVerifyReturnRepository.selectOne(queryWrapper), TaxPipelineFieldVerifyReturnVO.class);
+    }
+
+    /**
+     * 验证输入
+     *
+     * @param pipelineId   管道 ID
+     * @param documentType 文档类型
+     * @return {@link List }<{@link TaxPipelineVerify }>
+     */
+    @Override
+    public List<TaxPipelineVerify> verifyInput(Long pipelineId, String documentType) {
+        LambdaQueryWrapper<TaxPipelineFieldVerify> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineFieldVerify::getPipelineId, pipelineId);
+        queryWrapper.eq(TaxPipelineFieldVerify::getDocumentType, documentType);
+        List<TaxPipelineFieldVerify> taxPipelineFieldVerifies = taxPipelineFieldVerifyRepository.selectList(queryWrapper);
+        return taxPipelineFieldVerifies.stream().map(item -> JsonUtils.convertValue(item, TaxPipelineVerify.class)).toList();
+    }
+
+    /**
+     * 验证输出
+     *
+     * @param pipelineId   管道 ID
+     * @param documentType 文档类型
+     * @return {@link TaxPipelineVerifyReturn }
+     */
+    @Override
+    public TaxPipelineVerifyReturn verifyOutput(Long pipelineId, String documentType) {
+        LambdaQueryWrapper<TaxPipelineFieldVerifyReturn> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineFieldVerifyReturn::getPipelineId, pipelineId);
+        queryWrapper.eq(TaxPipelineFieldVerifyReturn::getDocumentType, documentType);
+        TaxPipelineFieldVerifyReturn returnKey = taxPipelineFieldVerifyReturnRepository.selectOne(queryWrapper);
+        return JsonUtils.convertValue(returnKey, TaxPipelineVerifyReturn.class);
+    }
+}