refactor(mapping): 重构校验逻辑并优化字段反射访问

- 移除未使用的 Optional 导入 - 添加 putDefaultValid 抽象方法用于自定义校验规则 - 将 getVerifyKeys 和 getReturnKeys 方法重命名为 loadDbValid 和 loadDbValidReturn - 新增 reflectFieldValue 工具方法统一处理字段访问异常 - 优化验证字符串生成逻辑，支持默认校验规则注入 - 调整 Transformer 类结构，增强扩展性和可维护性

refactor(mapping): 重构校验逻辑并优化字段反射访问
- 移除未使用的 Optional 导入 - 添加 putDefaultValid 抽象方法用于自定义校验规则 - 将 getVerifyKeys 和 getReturnKeys 方法重命名为 loadDbValid 和 loadDbValidReturn - 新增 reflectFieldValue 工具方法统一处理字段访问异常 - 优化验证字符串生成逻辑，支持默认校验规则注入 - 调整 Transformer 类结构，增强扩展性和可维护性
zhangmeiyang
1 parent 617c9355
Showing 6 changed files with 94 additions and 51 deletions
tax-central/src/main/java/com/diligrp/tax/central/utils/MappingUtils.java
tax-map/src/main/java/com/diligrp/tax/mapping/demarcate/Transformer.java
tax-map/src/main/java/com/diligrp/tax/mapping/demarcate/kingdee/CustomerTransformer.java
tax-map/src/main/java/com/diligrp/tax/mapping/demarcate/kingdee/ReceiptTransformer.java
tax-map/src/main/java/com/diligrp/tax/mapping/demarcate/kingdee/ReceivableTransformer.java
tax-map/src/main/java/com/diligrp/tax/mapping/demarcate/kingdee/RefundTransformer.java
@@ -8,8 +8,8 @@ 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.exception.TaxAgentServiceException;
-import com.diligrp.tax.central.model.PipelineDocFieldTypeRemoteParamDO;
 import com.diligrp.tax.central.model.PipelineDocFieldTypeDO;
+import com.diligrp.tax.central.model.PipelineDocFieldTypeRemoteParamDO;
 import com.diligrp.tax.central.type.TaxSystemType;
 import com.fasterxml.jackson.core.type.TypeReference;
 import lombok.extern.slf4j.Slf4j;
@@ -79,6 +79,15 @@ public class MappingUtils {
         return fields;
     }
  
+    public static Object reflectFieldValue(Field field, Object o) {
+        field.setAccessible(true);
+        try {
+            return field.get(o);
+        } catch (IllegalAccessException e) {
+            throw new TaxAgentServiceException(TaxSystemType.UNKNOWN_ERROR, e.getMessage());
+        }
+    }
+
     public static void reflectField(Object object, Field field, Map<String, PipelineDocFieldTypeDO> kvMap) {
         if (kvMap.containsKey(field.getName())) {
             field.setAccessible(true);
@@ -2,7 +2,6 @@ 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.CustomerMapping;
 import com.diligrp.tax.central.domain.mapping.kingdee.VerifyMarkInterface;
 import com.diligrp.tax.central.exception.TaxAgentServiceException;
 import com.diligrp.tax.central.model.PipelineDO;
@@ -16,6 +15,7 @@ import jakarta.annotation.Resource;
 import lombok.extern.slf4j.Slf4j;
  
 import java.lang.reflect.Field;
+import java.text.MessageFormat;
 import java.util.*;
  
 /**
@@ -39,7 +39,7 @@ public abstract class Transformer&lt;T extends BaseMapping&gt; {
     /**
      * 变换
      *
-     * @param document       公文
+     * @param document   公文
      * @param pipelineDO
      * @return {@link T }
      */
@@ -47,12 +47,21 @@ public abstract class Transformer&lt;T extends BaseMapping&gt; {
  
  
     /**
+     * 设置默认校验
+     *
+     * @param verifyKeys 验证密钥
+     * @param t          t
+     */
+    protected abstract void putDefaultValid(List<String> verifyKeys, T t);
+
+
+    /**
      * 获取验证密钥
      *
      * @param pipelineId 管道 ID
      * @return {@link List }<{@link String }>
      */
-    protected List<String> getVerifyKeys(Long pipelineId) {
+    private List<String> loadDbValid(Long pipelineId) {
         List<PipelineDocValidDO> taxPipelineVerifies = taxPipelineVerifyService.verifyInput(pipelineId, markDocument().value);
         return Optional.ofNullable(taxPipelineVerifies).orElse(List.of()).stream().map(PipelineDocValidDO::getConfigVerifyField).toList();
     }
@@ -63,10 +72,10 @@ public abstract class Transformer&lt;T extends BaseMapping&gt; {
      * @param pipelineId 管道 ID
      * @return {@link String }
      */
-    protected String getReturnKeys(Long pipelineId) {
+    private String loadDbValidReturn(Long pipelineId) {
         PipelineValidReturnDO pipelineValidReturnDO = taxPipelineVerifyService.verifyOutput(pipelineId, markDocument().value);
         if (Objects.isNull(pipelineValidReturnDO)) {
-            return "";
+            throw new TaxAgentServiceException(TaxSystemType.ABNORMAL_PARAMETERS, "配置了单据验证但是未配置验证返回值");
         }
         return pipelineValidReturnDO.getConfigReturnField();
     }
@@ -79,50 +88,45 @@ public abstract class Transformer&lt;T extends BaseMapping&gt; {
      * @param mapping
      * @return {@link String }
      */
-    protected String getVerifyString(List<String> verifyKeys, BaseMapping mapping) {
+    protected List<String> loadDbValidation(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.verify();
-                            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);
-                }
+        fields.stream().filter(field -> verifyKeysSet.contains(field.getName())).forEach(e -> {
+            Object fieldValue = MappingUtils.reflectFieldValue(e, mapping);
+            var fieldType = e.getType();
+            if (VerifyMarkInterface.class.isAssignableFrom(fieldType)) {
+                Optional.ofNullable(fieldValue).ifPresent(f -> {
+                    VerifyMarkInterface verifyObject = (VerifyMarkInterface) f;
+                    Optional.ofNullable(verifyObject.value()).ifPresent(v -> {
+                        String valid = MessageFormat.format("{0} = {1}", verifyObject.verify(), v);
+                        concatVerify.add(valid);
+                    });
+                });
+            }
+            if (fieldType.equals(String.class)) {
+                Optional.ofNullable(fieldValue).ifPresent(v -> {
+                    String valid = MessageFormat.format("{0} = {1}", e.getName(), v);
+                    concatVerify.add(valid);
+                });
             }
         });
-        log.info("verifyInfo is {},", String.join(" and ", concatVerify));
-        return String.join(" and ", concatVerify);
+        return concatVerify;
     }
  
-    protected void setValidKeys(PipelineDO pipelineDO, BaseMapping mapping) {
-        List<String> verifyKeys = getVerifyKeys(pipelineDO.getId());
-        String returnKeys = getReturnKeys(pipelineDO.getId());
-        Optional.ofNullable(verifyKeys).ifPresent(e -> mapping.setVerifyInformation(getVerifyString(verifyKeys, mapping)));
-        Optional.ofNullable(returnKeys).ifPresent(mapping::setReturnKeys);
+    /**
+     * 设置有效密钥
+     *
+     * @param pipelineDO 管道DO
+     * @param t          t
+     */
+    protected void setValidKeys(PipelineDO pipelineDO, T t) {
+        List<String> verifyKeys = loadDbValid(pipelineDO.getId());
+        Optional.ofNullable(verifyKeys).ifPresent(e -> {
+            t.setReturnKeys(loadDbValidReturn(pipelineDO.getId()));
+            List<String> validations = loadDbValidation(verifyKeys, t);
+            putDefaultValid(validations, t);
+            t.setVerifyInformation(String.join(" AND ", validations));
+        });
     }
 }
@@ -11,7 +11,6 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
  
 import java.util.List;
-import java.util.Optional;
  
 /**
  * @Author: zhangmeiyang
@@ -28,6 +27,11 @@ public class CustomerTransformer extends Transformer&lt;CustomerMapping&gt; {
     }
  
     @Override
+    protected void putDefaultValid(List<String> verifyKeys, CustomerMapping customerMapping) {
+        // 空方法 不需要校验
+    }
+
+    @Override
     public CustomerMapping transform(BaseDocument document, PipelineDO pipelineDO) {
         StandardCustomer customer = (StandardCustomer) document;
         CustomerMapping mapping = MappingUtils.convertValue(customer, CustomerMapping.class);
@@ -3,12 +3,15 @@ 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.domain.mapping.kingdee.base.FRECEIVEBILLENTRY;
 import com.diligrp.tax.central.model.PipelineDO;
 import com.diligrp.tax.central.type.DocumentType;
 import com.diligrp.tax.central.utils.MappingUtils;
 import com.diligrp.tax.mapping.demarcate.Transformer;
 import org.springframework.stereotype.Component;
  
+import java.math.BigDecimal;
+import java.text.MessageFormat;
 import java.util.List;
 import java.util.Optional;
  
@@ -27,10 +30,15 @@ public class ReceiptTransformer extends Transformer&lt;ReceiptMapping&gt; {
     }
  
     @Override
+    protected void putDefaultValid(List<String> verifyKeys, ReceiptMapping receiptMapping) {
+        // 空方法 不需要校验金额
+    }
+
+    @Override
     public ReceiptMapping transform(BaseDocument document, PipelineDO pipelineDO) {
         ReceiptBill bill = (ReceiptBill) document;
-        ReceiptMapping mapping = MappingUtils.convertValue(bill,ReceiptMapping.class);
-        setValidKeys(pipelineDO,mapping);
+        ReceiptMapping mapping = MappingUtils.convertValue(bill, ReceiptMapping.class);
+        setValidKeys(pipelineDO, mapping);
         return mapping;
     }
 }
@@ -9,6 +9,11 @@ import com.diligrp.tax.central.utils.MappingUtils;
 import com.diligrp.tax.mapping.demarcate.Transformer;
 import org.springframework.stereotype.Component;
  
+import java.math.BigDecimal;
+import java.text.MessageFormat;
+import java.util.List;
+import java.util.Optional;
+
  
 /**
  * @Author: zhangmeiyang
@@ -24,6 +29,17 @@ public class ReceivableTransformer extends Transformer&lt;ReceivableMapping&gt; {
     }
  
     @Override
+    protected void putDefaultValid(List<String> verifyKeys, ReceivableMapping mapping) {
+        var sum = mapping.getFEntityDetail().stream().map(e -> {
+            BigDecimal absoluteValue = Optional.ofNullable(e.getFPrice()).map(BigDecimal::new).orElse(BigDecimal.ZERO);
+            BigDecimal factor = Optional.ofNullable(e.getFPriceQty()).map(BigDecimal::new).orElse(BigDecimal.ZERO);
+            return absoluteValue.multiply(factor);
+        }).reduce(BigDecimal::add).orElse(BigDecimal.ZERO);
+        String format = MessageFormat.format("FALLAMOUNTFOR = {0}", sum);
+        verifyKeys.add(format);
+    }
+
+    @Override
     public ReceivableMapping transform(BaseDocument document, PipelineDO pipelineDO) {
         ReceivableBill bill = (ReceivableBill) document;
         ReceivableMapping mapping = MappingUtils.convertValue(bill, ReceivableMapping.class);
@@ -27,13 +27,15 @@ public class RefundTransformer extends Transformer&lt;RefundMapping&gt; {
     }
  
     @Override
+    protected void putDefaultValid(List<String> verifyKeys, RefundMapping refundMapping) {
+        // 空方法 不需要默认校验
+    }
+
+    @Override
     public RefundMapping transform(BaseDocument document, PipelineDO pipelineDO) {
         RefundBill bill = (RefundBill) document;
         RefundMapping mapping = MappingUtils.convertValue(bill,RefundMapping.class);
-        List<String> verifyKeys = getVerifyKeys(pipelineDO.getId());
-        String returnKeys = getReturnKeys(pipelineDO.getId());
-        Optional.ofNullable(verifyKeys).ifPresent(e -> mapping.setVerifyInformation(getVerifyString(verifyKeys, mapping)));
-        Optional.ofNullable(returnKeys).ifPresent(mapping::setReturnKeys);
+        setValidKeys(pipelineDO,mapping);
         return mapping;
     }
 }