feat(adopt): 增强客户同步功能并支持Excel文件处理

- 为 fullySyncCustomer 接口增加路径参数以支持多租户管道配置 - 添加对 Excel 文件（xls 和 xlsx）的解析与处理逻辑 - 引入 Apache POI 依赖用于读取电子表格数据 - 新增 ExcelUtils 工具类实现表格数据转换为 Map 列表 - 在 ReceiveMessageCO 中将 systemType 类型从枚举改为字符串 - 更新 controller 和 service 方法签名以传递更多上下文信息 - 添加文件格式校验及空文件名校验防止非法输入 - 优化代码结构并增强异常处理机制确保服务稳定性

feat(adopt): 增强客户同步功能并支持Excel文件处理
- 为 fullySyncCustomer 接口增加路径参数以支持多租户管道配置 - 添加对 Excel 文件（xls 和 xlsx）的解析与处理逻辑 - 引入 Apache POI 依赖用于读取电子表格数据 - 新增 ExcelUtils 工具类实现表格数据转换为 Map 列表 - 在 ReceiveMessageCO 中将 systemType 类型从枚举改为字符串 - 更新 controller 和 service 方法签名以传递更多上下文信息 - 添加文件格式校验及空文件名校验防止非法输入 - 优化代码结构并增强异常处理机制确保服务稳定性
zhangmeiyang
1 parent f9cf2428
Showing 7 changed files with 113 additions and 11 deletions
pom.xml
tax-adopt/pom.xml
tax-adopt/src/main/java/com/diligrp/tax/adopt/api/AdoptMessageController.java
tax-adopt/src/main/java/com/diligrp/tax/adopt/model/ReceiveMessageCO.java
tax-adopt/src/main/java/com/diligrp/tax/adopt/service/AdoptMessageService.java
tax-adopt/src/main/java/com/diligrp/tax/adopt/service/impl/AdoptMessageServiceImpl.java
tax-adopt/src/main/java/com/diligrp/tax/adopt/util/ExcelUtils.java
@@ -34,6 +34,7 @@
         <mybatis-plus.version>3.5.14</mybatis-plus.version>
         <!-- 工具类库 -->
         <lombok.version>1.18.42</lombok.version>
+        <poi.version>5.5.0</poi.version>
     </properties>
     <dependencyManagement>
@@ -69,6 +70,16 @@
                 <artifactId>mysql-connector-j</artifactId>
                 <version>${mysql-connector.version}</version>
             </dependency>
+            <dependency>
+                <groupId>org.apache.poi</groupId>
+                <artifactId>poi</artifactId>
+                <version>${poi.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>org.apache.poi</groupId>
+                <artifactId>poi-ooxml</artifactId>
+                <version>${poi.version}</version>
+            </dependency>
         </dependencies>
     </dependencyManagement>
@@ -8,14 +8,23 @@
         <artifactId>tax-agent</artifactId>
         <version>${revision}</version>
     </parent>
+    <artifactId>tax-adopt</artifactId>
+
     <dependencies>
         <dependency>
             <groupId>com.diligrp</groupId>
             <artifactId>tax-central</artifactId>
             <version>${revision}</version>
         </dependency>
+        <dependency>
+            <groupId>org.apache.poi</groupId>
+            <artifactId>poi</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.poi</groupId>
+            <artifactId>poi-ooxml</artifactId>
+        </dependency>
     </dependencies>
-    <artifactId>tax-adopt</artifactId>
-</project>
 \ No newline at end of file
+</project>
@@ -3,6 +3,7 @@ package com.diligrp.tax.adopt.api;
 import com.diligrp.tax.adopt.model.ReceiveMessageCO;
 import com.diligrp.tax.adopt.service.AdoptMessageService;
 import com.diligrp.tax.central.message.Message;
+import jakarta.validation.constraints.NotNull;
 import lombok.AllArgsConstructor;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
@@ -18,15 +19,31 @@ public class AdoptMessageController {
     private final AdoptMessageService adoptMessageService;
+    /**
+     * 接收消息
+     *
+     * @param receiveMessageCO 接收消息
+     * @return {@link Message }<{@link ? }>
+     */
     @PostMapping("/message")
     public Message<?> receiveMessage(@RequestBody ReceiveMessageCO receiveMessageCO) {
         adoptMessageService.convertMessage(receiveMessageCO);
         return Message.success();
     }
-    @PostMapping("/fullySyncCustomer")
-    public Message<?> fullySyncCustomer(@RequestPart("file")MultipartFile file) {
-        adoptMessageService.fullySyncCustomer(file);
+    /**
+     * 完全同步客户
+     *
+     * @param file 文件
+     * @return {@link Message }<{@link ? }>
+     */
+    @PostMapping("/fullySyncCustomer/{group}/{entity}/{pipelineCode}/{documentType}")
+    public Message<?> fullySyncCustomer(@RequestPart("file") @NotNull MultipartFile file,
+                                        @PathVariable("group") String group,
+                                        @PathVariable("entity") String entity,
+                                        @PathVariable("pipelineCode") String pipelineCode,
+                                        @PathVariable("documentType") String documentType) {
+        adoptMessageService.fullySyncCustomer(file, group, entity, pipelineCode, documentType);
         return Message.success();
     }
 }
@@ -42,5 +42,8 @@ public class ReceiveMessageCO {
      */
     private Map<String, Object> msgBody;
-    private SystemType systemType;
+    /**
+     * 系统类型
+     */
+    private String systemType;
 }
 package com.diligrp.tax.adopt.service;
 import com.diligrp.tax.adopt.model.ReceiveMessageCO;
+import jakarta.validation.constraints.NotNull;
 import org.springframework.web.multipart.MultipartFile;
 /**
@@ -9,6 +10,8 @@ import org.springframework.web.multipart.MultipartFile;
 public interface AdoptMessageService {
     /**
+     * 转换消息
+     *
      * @param receiveMessageCO 接收消息
      */
     void convertMessage(ReceiveMessageCO receiveMessageCO);
@@ -16,7 +19,11 @@ public interface AdoptMessageService {
     /**
      * 完全同步客户
      *
-     * @param file
+     * @param file         文件
+     * @param group        群
+     * @param entity       实体
+     * @param pipelineCode 管道代码
+     * @param documentType
      */
-    void fullySyncCustomer(MultipartFile file);
+    void fullySyncCustomer(@NotNull MultipartFile file, String group, String entity, String pipelineCode, String documentType);
 }
@@ -2,19 +2,25 @@ package com.diligrp.tax.adopt.service.impl;
 import com.diligrp.tax.adopt.model.ReceiveMessageCO;
 import com.diligrp.tax.adopt.service.AdoptMessageService;
+import com.diligrp.tax.adopt.util.ExcelUtils;
 import com.diligrp.tax.central.exception.TaxAgentServiceException;
 import com.diligrp.tax.central.model.PipelineBusinessKeyword;
 import com.diligrp.tax.central.model.TenantPipeline;
 import com.diligrp.tax.central.service.ITaxPipelineBusinessKeywordService;
 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 lombok.AllArgsConstructor;
+import org.apache.commons.io.FilenameUtils;
+import org.apache.poi.hssf.usermodel.HSSFWorkbook;
+import org.apache.poi.xssf.usermodel.XSSFWorkbook;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 import org.springframework.web.multipart.MultipartFile;
+import java.io.IOException;
 import java.util.List;
 import java.util.Map;
 import java.util.Optional;
@@ -46,14 +52,38 @@ public class AdoptMessageServiceImpl implements AdoptMessageService {
         Map<String, Object> map = AdoptUtils.handleAdopt(pipelineBusinessKeywords, json);
         receiveMessageCO.setMsgBody(map);
         Optional<TenantPipeline> byTenantAndPipelineCode = taxTenantService.findByTenantAndPipelineCode(receiveMessageCO.getGroup(), receiveMessageCO.getEntity(), receiveMessageCO.getPipelineCode());
-        byTenantAndPipelineCode.ifPresent(tenantPipeline -> receiveMessageCO.setSystemType(tenantPipeline.getSystemType()));
+        byTenantAndPipelineCode.ifPresent(tenantPipeline -> receiveMessageCO.setSystemType(tenantPipeline.getSystemType().code));
         // 发送mq
         String messageJson = JsonUtils.toJsonString(receiveMessageCO);
         rabbitTemplate.convertAndSend(NORMAL_EXCHANGE, NORMAL_ROUTING, messageJson);
     }
     @Override
-    public void fullySyncCustomer(MultipartFile file) {
-
+    public void fullySyncCustomer(MultipartFile file, String group, String entity, String pipelineCode, String documentType) {
+        try (var inputStream = file.getInputStream()) {
+            Optional.ofNullable(file.getOriginalFilename()).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.MISSING_BUSINESS_INFORMATION, "未找到文件"));
+            String originalFilename = file.getOriginalFilename();
+            String extension = FilenameUtils.getExtension(originalFilename).toLowerCase();
+            var book = switch (extension) {
+                case "xlsx" -> new XSSFWorkbook(inputStream);
+                case "xls" -> new HSSFWorkbook(inputStream);
+                default -> throw new TaxAgentServiceException(TaxSystemType.BUSINESS_MATCHES_ARE_INCORRECT, "未支持的文件格式");
+            };
+            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));
+            });
+        } catch (IOException e) {
+            throw new TaxAgentServiceException(e.getMessage());
+        }
     }
 }
+package com.diligrp.tax.adopt.util;
+
+import com.diligrp.tax.central.exception.TaxAgentServiceException;
+import com.diligrp.tax.central.type.TaxSystemType;
+import org.apache.poi.ss.usermodel.Workbook;
+
+import java.util.*;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-19 15:11
+ * @Version: todo
+ */
+public class ExcelUtils {
+    public static List<Map<String, Object>> processSheet(Workbook book) {
+        var res = new ArrayList<Map<String, Object>>();
+        Optional.ofNullable(book).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.ABNORMAL_PARAMETERS, "文件转换异常"));
+        book.sheetIterator().forEachRemaining(sheet -> sheet.rowIterator().forEachRemaining(row -> {
+            var map = new HashMap<String, Object>();
+            row.cellIterator().forEachRemaining(cell -> map.put(cell.getStringCellValue(), cell.getStringCellValue()));
+            res.add(map);
+        }));
+        return res;
+    }
+}