feat(adopt): 新增客户完全同步功能

- 在 AdoptMessageController 中新增 /fullySyncCustomer 接口 - 支持通过 MultipartFile 上传文件进行客户数据同步 - 在 AdoptMessageService 中定义 fullySyncCustomer 方法 - 实现类 AdoptMessageServiceImpl 中添加空实现 - 优化代码导入语句，统一使用通配符导入 fix(storage): 修正参数注释描述 - 修改 saveBusinessKeyword 接口的参数注释 - 将 cos 描述更正为公司 co feat(storage): 实现租户管道查询方法 - 在 ITaxTenantService 接口中新增 findByTenantAndPipelineCode 方法 - 在 TaxTenantService 中实现该方法的具体逻辑 - 根据 group、entity 和 pipelineCode 查询对应的 TenantPipeline - 使用 Optional 返回结果，提高代码健壮性 - 修复 listByPipelineIdAndDocumentType 方法中的空格格式问题

feat(adopt): 新增客户完全同步功能
- 在 AdoptMessageController 中新增 /fullySyncCustomer 接口 - 支持通过 MultipartFile 上传文件进行客户数据同步 - 在 AdoptMessageService 中定义 fullySyncCustomer 方法 - 实现类 AdoptMessageServiceImpl 中添加空实现 - 优化代码导入语句，统一使用通配符导入 fix(storage): 修正参数注释描述 - 修改 saveBusinessKeyword 接口的参数注释 - 将 cos 描述更正为公司 co feat(storage): 实现租户管道查询方法 - 在 ITaxTenantService 接口中新增 findByTenantAndPipelineCode 方法 - 在 TaxTenantService 中实现该方法的具体逻辑 - 根据 group、entity 和 pipelineCode 查询对应的 TenantPipeline - 使用 Optional 返回结果，提高代码健壮性 - 修复 listByPipelineIdAndDocumentType 方法中的空格格式问题
zhangmeiyang
1 parent 24ffc10f
Showing 6 changed files with 49 additions and 6 deletions
tax-adopt/src/main/java/com/diligrp/tax/adopt/api/AdoptMessageController.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-central/src/main/java/com/diligrp/tax/central/service/ITaxTenantService.java
tax-storage/src/main/java/com/diligrp/tax/storage/controller/TaxPipelineBusinessConfigController.java
tax-storage/src/main/java/com/diligrp/tax/storage/service/TaxTenantService.java
@@ -4,10 +4,8 @@ import com.diligrp.tax.adopt.model.ReceiveMessageCO;
 import com.diligrp.tax.adopt.service.AdoptMessageService;
 import com.diligrp.tax.central.message.Message;
 import lombok.AllArgsConstructor;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
  
 /**
  * @author lvqi
@@ -25,4 +23,10 @@ public class AdoptMessageController {
         adoptMessageService.convertMessage(receiveMessageCO);
         return Message.success();
     }
+
+    @PostMapping("/fullySyncCustomer")
+    public Message<?> fullySyncCustomer(@RequestPart("file")MultipartFile file) {
+        adoptMessageService.fullySyncCustomer(file);
+        return Message.success();
+    }
 }
 package com.diligrp.tax.adopt.service;
  
 import com.diligrp.tax.adopt.model.ReceiveMessageCO;
+import org.springframework.web.multipart.MultipartFile;
  
 /**
  * @author lvqi
  */
 public interface AdoptMessageService {
  
+    /**
+     * @param receiveMessageCO 接收消息
+     */
     void convertMessage(ReceiveMessageCO receiveMessageCO);
+
+    /**
+     * 完全同步客户
+     *
+     * @param file
+     */
+    void fullySyncCustomer(MultipartFile file);
 }
@@ -11,6 +11,7 @@ import lombok.AllArgsConstructor;
 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.util.List;
 import java.util.Map;
@@ -44,4 +45,9 @@ public class AdoptMessageServiceImpl implements AdoptMessageService {
         String messageJson = JsonUtils.toJsonString(receiveMessageCO);
         rabbitTemplate.convertAndSend(NORMAL_EXCHANGE, NORMAL_ROUTING, messageJson);
     }
+
+    @Override
+    public void fullySyncCustomer(MultipartFile file) {
+
+    }
 }
@@ -4,6 +4,7 @@ import com.diligrp.tax.central.model.TenantPipeline;
 import com.diligrp.tax.central.model.TenantPipelineConfig;
  
 import java.util.List;
+import java.util.Optional;
  
 /**
  * @Author: zhangmeiyang
@@ -28,6 +29,14 @@ public interface ITaxTenantService {
      */
     List<TenantPipeline> listAllEnablePipeline();
  
+
+    /**
+     * 列出所有启用管道
+     *
+     * @return {@link List }<{@link TenantPipeline }>
+     */
+    Optional<TenantPipeline> findByTenantAndPipelineCode(String group,String entity,String pipelineCode);
+
     /**
      * 按管道 ID 列出
      *
@@ -160,7 +160,7 @@ public class TaxPipelineBusinessConfigController {
     /**
      * 批量保存业务关键字
      *
-     * @param cos 对象列表
+     * @param co 公司
      * @return {@link Message }<{@link ? }>
      */
     @RequestMapping("/keyword/saveBusinessKeyword")
@@ -76,6 +76,19 @@ public class TaxTenantService implements ITaxTenantService {
         }).toList();
     }
  
+    @Override
+    public Optional<TenantPipeline> findByTenantAndPipelineCode(String group, String entity, String pipelineCode) {
+        Long tenantId = getTenantId(group, entity);
+        LambdaQueryWrapper<TaxPipeline> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipeline::getCode, pipelineCode);
+        queryWrapper.eq(TaxPipeline::getTenantId, tenantId);
+        return Optional.ofNullable(taxPipelineRepository.selectOne(queryWrapper)).map(taxPipeline -> {
+            TenantPipeline pipeline = JsonUtils.convertValue(taxPipeline, TenantPipeline.class);
+            pipeline.setSystemType(SystemType.from(taxPipeline.getSystemCode()));
+            return pipeline;
+        });
+    }
+
     /**
      * 按管道 ID 列出
      *
@@ -84,7 +97,7 @@ public class TaxTenantService implements ITaxTenantService {
      */
     @Override
     public List<TenantPipelineConfig> listByPipelineIdAndDocumentType(Long pipelineId, String documentType) {
-        return taxPipelineFieldConfigService.listByPipelineIdAndDocumentType(pipelineId,documentType);
+        return taxPipelineFieldConfigService.listByPipelineIdAndDocumentType(pipelineId, documentType);
     }