feat(adopt): 新增金蝶客户同步功能

- 添加 AbstractCustomer、ContactCO 和 CustomerCO 模型类 - 修改 AdoptMessageController 支持金蝶客户同步接口参数 - 在 AdoptMessageServiceImpl 中实现金蝶数据映射逻辑 - 增加系统类型判断与异常处理机制 - 优化消息体构造方式，支持不同系统的数据转换

feat(adopt): 新增金蝶客户同步功能
- 添加 AbstractCustomer、ContactCO 和 CustomerCO 模型类 - 修改 AdoptMessageController 支持金蝶客户同步接口参数 - 在 AdoptMessageServiceImpl 中实现金蝶数据映射逻辑 - 增加系统类型判断与异常处理机制 - 优化消息体构造方式，支持不同系统的数据转换
zhangmeiyang
1 parent 767330ab
Showing 5 changed files with 100 additions and 13 deletions
tax-adopt/src/main/java/com/diligrp/tax/adopt/api/AdoptMessageController.java
tax-adopt/src/main/java/com/diligrp/tax/adopt/model/AbstractCustomer.java
tax-adopt/src/main/java/com/diligrp/tax/adopt/model/ContactCO.java
tax-adopt/src/main/java/com/diligrp/tax/adopt/model/CustomerCO.java
tax-adopt/src/main/java/com/diligrp/tax/adopt/service/impl/AdoptMessageServiceImpl.java
@@ -32,9 +32,13 @@ public class AdoptMessageController {
     }
  
     /**
-     * 完全同步客户
+     * 完全同步客户(金蝶)
      *
-     * @param file 文件
+     * @param file         文件
+     * @param group        群
+     * @param entity       实体
+     * @param pipelineCode 管道代码
+     * @param documentType 文档类型
      * @return {@link Message }<{@link ? }>
      */
     @PostMapping("/fullySyncCustomer/{group}/{entity}/{pipelineCode}/{documentType}")
+package com.diligrp.tax.adopt.model;
+
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-19 15:38
+ * @Version: todo
+ */
+@Getter
+@Setter
+public class AbstractCustomer {
+    private String systemDataId;
+}
+package com.diligrp.tax.adopt.model;
+
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-19 15:46
+ * @Version: todo
+ */
+@Getter
+@Setter
+public class ContactCO {
+    private String contactName;
+    private String contactPhone;
+    private String contactAddress;
+}
+package com.diligrp.tax.adopt.model;
+
+import lombok.Getter;
+import lombok.Setter;
+
+import java.util.List;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-19 15:30
+ * @Version: todo
+ */
+@Getter
+@Setter
+public class CustomerCO extends AbstractCustomer {
+    private String customerCode;
+    private String customerName;
+    private String customerShortName;
+    private String customerInvoiceTitle;
+    private String legalPerson;
+    private String idNumber;
+    private String country;
+    private String provincial;
+    private String address;
+    private String registerAddress;
+    private String telephone;
+    private List<ContactCO> contacts;
+}
 package com.diligrp.tax.adopt.service.impl;
  
+import com.diligrp.tax.adopt.model.AbstractCustomer;
+import com.diligrp.tax.adopt.model.ContactCO;
+import com.diligrp.tax.adopt.model.CustomerCO;
 import com.diligrp.tax.adopt.model.ReceiveMessageCO;
 import com.diligrp.tax.adopt.service.AdoptMessageService;
 import com.diligrp.tax.adopt.util.ExcelUtils;
@@ -11,6 +14,7 @@ import com.diligrp.tax.central.service.ITaxTenantService;
 import com.diligrp.tax.central.type.TaxSystemType;
 import com.diligrp.tax.central.utils.AdoptUtils;
 import com.diligrp.tax.central.utils.JsonUtils;
+import com.fasterxml.jackson.core.type.TypeReference;
 import lombok.AllArgsConstructor;
 import org.apache.commons.io.FilenameUtils;
 import org.apache.poi.hssf.usermodel.HSSFWorkbook;
@@ -67,23 +71,42 @@ public class AdoptMessageServiceImpl implements AdoptMessageService {
             var book = switch (extension) {
                 case "xlsx" -> new XSSFWorkbook(inputStream);
                 case "xls" -> new HSSFWorkbook(inputStream);
-                default -> throw new TaxAgentServiceException(TaxSystemType.BUSINESS_MATCHES_ARE_INCORRECT, "未支持的文件格式");
+                default -> throw new TaxAgentServiceException(TaxSystemType.ABNORMAL_PARAMETERS, "未支持的文件格式");
             };
             List<Map<String, Object>> list = ExcelUtils.processSheet(book);
             Optional<TenantPipeline> pipelineOptional = taxTenantService.findByTenantAndPipelineCode(group, entity, pipelineCode);
             TenantPipeline pipeline = pipelineOptional.orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.NO_MATCHING_SET_OF_ACCOUNTS_FOUND, "未找到匹配账套"));
-            list.forEach(map -> {
-                ReceiveMessageCO receiveMessageCO = new ReceiveMessageCO();
-                receiveMessageCO.setMsgBody(map);
-                receiveMessageCO.setGroup(group);
-                receiveMessageCO.setEntity(entity);
-                receiveMessageCO.setPipelineCode(pipelineCode);
-                receiveMessageCO.setSystemType(pipeline.getSystemType().code);
-                receiveMessageCO.setDocumentType(documentType);
-                rabbitTemplate.convertAndSend(NORMAL_EXCHANGE, NORMAL_ROUTING, JsonUtils.toJsonString(receiveMessageCO));
-            });
+            list.forEach(map -> rabbitTemplate.convertAndSend(NORMAL_EXCHANGE, NORMAL_ROUTING, JsonUtils.toJsonString(getReceiveMessageCO(group, entity, pipelineCode, documentType, map, pipeline))));
         } catch (IOException e) {
             throw new TaxAgentServiceException(e.getMessage());
         }
     }
+
+    private static ReceiveMessageCO getReceiveMessageCO(String group, String entity, String pipelineCode, String documentType, Map<String, Object> map, TenantPipeline pipeline) {
+        var msgBody = switch (pipeline.getSystemType()) {
+            case KING_DEE -> kingdeeMap(map);
+            case YONG_YOU -> throw new TaxAgentServiceException(TaxSystemType.ABNORMAL_PARAMETERS, "未支持的系统形式");
+        };
+        ReceiveMessageCO receiveMessageCO = new ReceiveMessageCO();
+        AbstractCustomer abstractCustomer = JsonUtils.convertValue(map, AbstractCustomer.class);
+        receiveMessageCO.setSystemDataId(abstractCustomer.getSystemDataId());
+        receiveMessageCO.setGroup(group);
+        receiveMessageCO.setEntity(entity);
+        receiveMessageCO.setPipelineCode(pipelineCode);
+        receiveMessageCO.setSystemType(pipeline.getSystemType().code);
+        receiveMessageCO.setDocumentType(documentType);
+        receiveMessageCO.setMsgBody(msgBody);
+        return receiveMessageCO;
+    }
+
+    private static Map<String, Object> kingdeeMap(Map<String, Object> map) {
+        CustomerCO customerCO = JsonUtils.convertValue(map, CustomerCO.class);
+        var contact = new ContactCO();
+        contact.setContactName(customerCO.getCustomerName());
+        contact.setContactPhone(customerCO.getTelephone());
+        contact.setContactAddress(customerCO.getAddress());
+        customerCO.setContacts(List.of(contact));
+        return JsonUtils.convertValue(customerCO, new TypeReference<>() {
+        });
+    }
 }