refactor(kingdee): 提取成功响应验证逻辑到公共方法

- 在 Sender 基类中新增 validSuccess 方法统一处理空成功实体情况 - 移除 ReceiptSender、ReceivableSender 和 RefundSender 中重复的空列表检查代码 - 引入 JsonUtils 和 MessageFormat 用于构建详细的错误消息 - 当远程调用返回空的成功实体列表时，抛出带有错误详情的异常

refactor(kingdee): 提取成功响应验证逻辑到公共方法
- 在 Sender 基类中新增 validSuccess 方法统一处理空成功实体情况 - 移除 ReceiptSender、ReceivableSender 和 RefundSender 中重复的空列表检查代码 - 引入 JsonUtils 和 MessageFormat 用于构建详细的错误消息 - 当远程调用返回空的成功实体列表时，抛出带有错误详情的异常
zhangmeiyang
1 parent 0f11c8e8
Showing 4 changed files with 21 additions and 9 deletions
tax-proxy/src/main/java/com/diligrp/tax/proxy/demarcate/Sender.java
tax-proxy/src/main/java/com/diligrp/tax/proxy/demarcate/kingdee/ReceiptSender.java
tax-proxy/src/main/java/com/diligrp/tax/proxy/demarcate/kingdee/ReceivableSender.java
tax-proxy/src/main/java/com/diligrp/tax/proxy/demarcate/kingdee/RefundSender.java
@@ -8,9 +8,13 @@ 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.entity.RepoRet;
+import com.kingdee.bos.webapi.entity.SuccessEntity;
 import com.kingdee.bos.webapi.sdk.K3CloudApi;
 import lombok.extern.slf4j.Slf4j;
  
+import java.text.MessageFormat;
+import java.util.ArrayList;
 import java.util.List;
 import java.util.Optional;
  
@@ -51,4 +55,12 @@ public abstract class Sender&lt;T extends BaseProxy&gt; {
             });
         });
     }
+
+    protected void validSuccess(ArrayList<SuccessEntity> successEntity, RepoRet<?> repoRet) {
+        if (successEntity.isEmpty()) {
+            var errorArrayJson = JsonUtils.toJsonString(repoRet.getResult().getResponseStatus().getErrors());
+            String format = MessageFormat.format("{0}, caused by: {1}", TaxSystemType.REMOTE_SERVICE_CALLS_ARE_EXCEPTIONAL.message, errorArrayJson);
+            throw new TaxAgentServiceException(TaxSystemType.REMOTE_SERVICE_CALLS_ARE_EXCEPTIONAL, format);
+        }
+    }
 }
@@ -6,6 +6,7 @@ import com.diligrp.tax.central.domain.proxy.kingdee.ReceiptProxy;
 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.demarcate.Sender;
 import com.diligrp.tax.proxy.helper.KingDeeHelper;
 import com.kingdee.bos.webapi.entity.IdentifyInfo;
@@ -13,6 +14,7 @@ import com.kingdee.bos.webapi.entity.RepoRet;
 import com.kingdee.bos.webapi.entity.SuccessEntity;
 import org.springframework.stereotype.Component;
  
+import java.text.MessageFormat;
 import java.util.ArrayList;
  
 /**
@@ -34,9 +36,7 @@ public class ReceiptSender extends Sender&lt;ReceiptProxy&gt; {
         validMapping(identifyInfo, mapping);
         RepoRet<?> repoRet = KingDeeHelper.auditSend(mapping, identifyInfo, markDocument().value);
         ArrayList<SuccessEntity> successEntity = repoRet.getResult().getResponseStatus().getSuccessEntitys();
-        if (successEntity.isEmpty()) {
-            throw new TaxAgentServiceException(TaxSystemType.REMOTE_SERVICE_CALLS_ARE_EXCEPTIONAL);
-        }
+        validSuccess(successEntity, repoRet);
         SuccessEntity first = successEntity.getFirst();
         var proxy = new ReceiptProxy();
         proxy.setThirdPartyId(first.getId());
@@ -6,6 +6,7 @@ import com.diligrp.tax.central.domain.proxy.kingdee.ReceivableProxy;
 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.demarcate.Sender;
 import com.diligrp.tax.proxy.helper.KingDeeHelper;
 import com.kingdee.bos.webapi.entity.IdentifyInfo;
@@ -13,6 +14,7 @@ import com.kingdee.bos.webapi.entity.RepoRet;
 import com.kingdee.bos.webapi.entity.SuccessEntity;
 import org.springframework.stereotype.Component;
  
+import java.text.MessageFormat;
 import java.util.ArrayList;
  
 /**
@@ -34,9 +36,7 @@ public class ReceivableSender extends Sender&lt;ReceivableProxy&gt; {
         validMapping(identifyInfo, mapping);
         RepoRet<?> repoRet = KingDeeHelper.auditSend(mapping, identifyInfo, markDocument().value);
         ArrayList<SuccessEntity> successEntity = repoRet.getResult().getResponseStatus().getSuccessEntitys();
-        if (successEntity.isEmpty()) {
-            throw new TaxAgentServiceException(TaxSystemType.REMOTE_SERVICE_CALLS_ARE_EXCEPTIONAL);
-        }
+        validSuccess(successEntity, repoRet);
         SuccessEntity first = successEntity.getFirst();
         var proxy = new ReceivableProxy();
         proxy.setThirdPartyId(first.getId());
@@ -6,6 +6,7 @@ import com.diligrp.tax.central.domain.proxy.kingdee.RefundProxy;
 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.demarcate.Sender;
 import com.diligrp.tax.proxy.helper.KingDeeHelper;
 import com.kingdee.bos.webapi.entity.IdentifyInfo;
@@ -13,6 +14,7 @@ import com.kingdee.bos.webapi.entity.RepoRet;
 import com.kingdee.bos.webapi.entity.SuccessEntity;
 import org.springframework.stereotype.Component;
  
+import java.text.MessageFormat;
 import java.util.ArrayList;
  
 /**
@@ -34,9 +36,7 @@ public class RefundSender extends Sender&lt;RefundProxy&gt; {
         validMapping(identifyInfo, mapping);
         RepoRet<?> repoRet = KingDeeHelper.auditSend(mapping, identifyInfo, markDocument().value);
         ArrayList<SuccessEntity> successEntity = repoRet.getResult().getResponseStatus().getSuccessEntitys();
-        if (successEntity.isEmpty()) {
-            throw new TaxAgentServiceException(TaxSystemType.REMOTE_SERVICE_CALLS_ARE_EXCEPTIONAL);
-        }
+        validSuccess(successEntity, repoRet);
         SuccessEntity first = successEntity.getFirst();
         var proxy = new RefundProxy();
         proxy.setThirdPartyId(first.getId());