refactor(sender): 优化映射验证逻辑并增强日志记录

- 使用 Optional 简化空值检查逻辑 - 在查询金蝶接口后增加结果日志输出 - 引入 JsonUtils 工具类序列化日志内容 - 添加 Slf4j 注解以支持结构化日志记录 - 重构条件判断避免嵌套判空操作

refactor(sender): 优化映射验证逻辑并增强日志记录
- 使用 Optional 简化空值检查逻辑 - 在查询金蝶接口后增加结果日志输出 - 引入 JsonUtils 工具类序列化日志内容 - 添加 Slf4j 注解以支持结构化日志记录 - 重构条件判断避免嵌套判空操作
zhangmeiyang
1 parent fd9b641c
Showing 1 changed file with 9 additions and 4 deletions
tax-proxy/src/main/java/com/diligrp/tax/proxy/demarcate/Sender.java
@@ -5,17 +5,21 @@ import com.diligrp.tax.central.domain.BaseProxy;
 import com.diligrp.tax.central.exception.TaxAgentServiceException;
 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.proxy.helper.KingDeeHelper;
 import com.kingdee.bos.webapi.entity.IdentifyInfo;
 import com.kingdee.bos.webapi.sdk.K3CloudApi;
+import lombok.extern.slf4j.Slf4j;
 import java.util.List;
+import java.util.Optional;
 /**
  * @Author: zhangmeiyang
  * @CreateTime: 2025-11-03 17:55
  * @Version: todo
  */
+@Slf4j
 public abstract class Sender<T extends BaseProxy> {
     /**
      * 标记文档
@@ -39,11 +43,12 @@ public abstract class Sender&lt;T extends BaseProxy&gt; {
      * @param mapping      映射
      */
     protected void validMapping(IdentifyInfo identifyInfo, BaseMapping mapping) {
-        if (!mapping.getVerifyInformation().isEmpty() && !mapping.getReturnKeys().isEmpty()){
+        Optional.ofNullable(mapping.getVerifyInformation()).filter(e -> !e.isEmpty()).ifPresent(f -> {
             List<Object> infos = KingDeeHelper.querySend(mapping, markDocument().value, new K3CloudApi(identifyInfo));
-            if (!infos.isEmpty()) {
+            Optional.ofNullable(infos).filter(e -> !e.isEmpty()).ifPresent(g -> {
+                log.info("kingdee query result:{}", JsonUtils.toJsonString(g));
                 throw new TaxAgentServiceException(TaxSystemType.REPEAT_SENDING);
-            }
-        }
+            });
+        });
     }
 }