feat(utils): 增强JsonPath解析工具类功能

- 修改parse方法返回类型为Object并增加空值校验 - 新增parseString方法用于安全字符串转换 - 在MappingUtils中替换使用新的parseString方法 - 新增YongYouConnectionManager实现类 - 实现系统类型标记和连接获取基础逻辑

feat(utils): 增强JsonPath解析工具类功能
- 修改parse方法返回类型为Object并增加空值校验 - 新增parseString方法用于安全字符串转换 - 在MappingUtils中替换使用新的parseString方法 - 新增YongYouConnectionManager实现类 - 实现系统类型标记和连接获取基础逻辑
zhangmeiyang
1 parent 8f99bf48
Showing 3 changed files with 35 additions and 5 deletions
tax-central/src/main/java/com/diligrp/tax/central/manager/impl/YongYouConnectionManager.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
+package com.diligrp.tax.central.manager.impl;
+
+import com.diligrp.tax.central.manager.AbstractConnectionManager;
+import com.diligrp.tax.central.model.TenantPipeline;
+import com.diligrp.tax.central.type.SystemType;
+import com.kingdee.bos.webapi.entity.IdentifyInfo;
+import org.springframework.stereotype.Component;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-06 14:59
+ * @Version: todo
+ */
+@Component
+public class YongYouConnectionManager extends AbstractConnectionManager<Object> {
+    @Override
+    public SystemType markSystemType() {
+        return SystemType.YONG_YOU;
+    }
+
+    @Override
+    public IdentifyInfo getConnection(TenantPipeline tenantPipeline) {
+        return null;
+    }
+}
@@ -16,10 +16,17 @@ import java.util.Optional;
  */
 public class JsonPathUtils {
  
-    public static String parse(String httpResult, String dataPath) {
+    public static Object 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();
+        return JsonPath.read(httpResult, dataPath);
+    }
+
+    public static String parseString(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));
+        var res = JsonPath.read(httpResult, dataPath);
+        return Optional.ofNullable(res).map(Object::toString).orElse("");
     }
  
     /**
@@ -54,6 +61,4 @@ public class JsonPathUtils {
         dataPathMap.forEach((k, v) -> res.put(k, JsonPath.read(httpResult, v)));
         return res;
     }
-
-
 }
@@ -106,7 +106,7 @@ public class MappingUtils {
                         });
                         params.put(remoteParam.getField(), value);
                         var result = SingletonHttpClient.instance().postBody(remoteAddress, params);
-                        String remoteValue = JsonPathUtils.parse(result, remoteParam.getDataPath());
+                        String remoteValue = JsonPathUtils.parseString(result, remoteParam.getDataPath());
                         field.set(object, remoteValue);
                     }
                 }