feat(proxy): 添加第三方ID字段并优化处理逻辑

- 在 BaseProxy 中添加 thirdPartyId 字段及 Getter/Setter 注解- 移除 CustomerProxy 中重复定义的 thirdPartyId 字段 -优化 CustomerSender 中对成功实体列表的判空逻辑 - 在 ProxyProcessor 中设置消息上下文的第三方ID数据

feat(proxy): 添加第三方ID字段并优化处理逻辑
- 在 BaseProxy 中添加 thirdPartyId 字段及 Getter/Setter 注解- 移除 CustomerProxy 中重复定义的 thirdPartyId 字段 -优化 CustomerSender 中对成功实体列表的判空逻辑 - 在 ProxyProcessor 中设置消息上下文的第三方ID数据
zhangmeiyang
1 parent 406ad771
Showing 4 changed files with 9 additions and 4 deletions
tax-central/src/main/java/com/diligrp/tax/central/domain/BaseProxy.java
tax-central/src/main/java/com/diligrp/tax/central/domain/proxy/kingdee/CustomerProxy.java
tax-proxy/src/main/java/com/diligrp/tax/proxy/demarcate/kingdee/CustomerSender.java
tax-proxy/src/main/java/com/diligrp/tax/proxy/process/kingdee/ProxyProcessor.java
 package com.diligrp.tax.central.domain;
  
+import lombok.Getter;
+import lombok.Setter;
+
 /**
  * @Author: zhangmeiyang
  * @CreateTime: 2025-10-30 17:26
  * @Version: todo
  */
+@Getter
+@Setter
 public abstract class BaseProxy {
+    private String thirdPartyId;
 }
@@ -12,5 +12,5 @@ import lombok.Setter;
 @Getter
 @Setter
 public class CustomerProxy extends BaseProxy {
-    private String thirdPartyId;
+
 }
@@ -44,9 +44,7 @@ public class CustomerSender extends Sender&lt;CustomerProxy&gt; {
         RepoRet<?> repoRet = KingDeeHelper.auditSend(JsonUtils.convertValue(mapping, new TypeReference<>() {}), new K3CloudApi(identifyInfo), markDocument().value);
         //联系人新增和更新完成
         ArrayList<SuccessEntity> successEntity = repoRet.getResult().getResponseStatus().getSuccessEntitys();
-        if (successEntity.isEmpty()) {
-            throw new TaxAgentServiceException(TaxSystemType.REMOTE_SERVICE_CALLS_ARE_EXCEPTIONAL);
-        }
+        Optional.ofNullable(successEntity).filter(e -> !e.isEmpty()).orElseThrow(()->new TaxAgentServiceException(TaxSystemType.REMOTE_SERVICE_CALLS_ARE_EXCEPTIONAL));
         SuccessEntity first = successEntity.getFirst();
         var proxy = new CustomerProxy();
         proxy.setThirdPartyId(first.getId());
@@ -25,6 +25,7 @@ public class ProxyProcessor extends AbstractProcessor {
         AbstractConnectionManager<?> abstractConnectionManager = ConnectionContext.CONNECTION_MAP.get(messageContext.getSystemTypeEnum());
         IdentifyInfo identifyInfo = (IdentifyInfo) abstractConnectionManager.getConnection(messageContext.getTenantPipeline());
         BaseProxy send = ProxyContext.CONTEXT.get(messageContext.getDocumentTypeEnum()).send(messageContext.getMappingObject(), identifyInfo);
+        messageContext.setPipelineDataId(send.getThirdPartyId());
         messageContext.setProxyObject(send);
         return messageContext;
     }