feat(adopt): 引入消息接收与转换模块

lvqi
1 parent b80e0bc9
Showing 9 changed files with 112 additions and 4 deletions
tax-adopt/src/main/java/com/diligrp/tax/adopt/AdoptConfig.java
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-boot/pom.xml
tax-boot/src/main/java/com/diligrp/tax/boot/TaxApplication.java
tax-boot/src/main/java/com/diligrp/tax/boot/receiver/TaxReceiver.java
tax-boot/src/main/java/com/diligrp/tax/boot/queue/TaxAutoPush.java → tax-central/src/main/java/com/diligrp/tax/central/queue/TaxAutoPush.java
+package com.diligrp.tax.adopt;
+
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @author lvqi
+ */
+@Configuration
+@ComponentScan(basePackages = "com.diligrp.tax.adopt")
+public class AdoptConfig {
+}
+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 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;
+
+/**
+ * @author lvqi
+ */
+@RestController
+@RequestMapping("/tax/tenant/adopt")
+@AllArgsConstructor
+public class AdoptMessageController {
+
+    private final AdoptMessageService adoptMessageService;
+
+
+    @PostMapping("/message")
+    public Message<?> receiveMessage(@RequestBody ReceiveMessageCO receiveMessageCO) {
+        adoptMessageService.convertMessage(receiveMessageCO);
+        return Message.success();
+    }
+}
 package com.diligrp.tax.adopt.model;
+import lombok.Data;
+
 import java.util.Map;
 /**
  * @author lvqi
  */
-
+@Data
 public class ReceiveMessageCO {
     /**
@@ -24,6 +26,8 @@ public class ReceiveMessageCO {
      * 租户账套编码
      */
     private String pipelineCode;
+
+    private String businessCode;
     /**
      * 消息信息
      */
+package com.diligrp.tax.adopt.service;
+
+import com.diligrp.tax.adopt.model.ReceiveMessageCO;
+
+/**
+ * @author lvqi
+ */
+public interface AdoptMessageService {
+
+    void convertMessage(ReceiveMessageCO receiveMessageCO);
+}
+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.central.exception.TaxAgentServiceException;
+import com.diligrp.tax.central.model.PipelineBusinessKeyword;
+import com.diligrp.tax.central.service.ITaxPipelineBusinessKeywordService;
+import com.diligrp.tax.central.utils.AdoptUtils;
+import com.diligrp.tax.central.utils.JsonUtils;
+import lombok.AllArgsConstructor;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
+
+import java.util.List;
+import java.util.Map;
+
+import static com.diligrp.tax.central.queue.TaxAutoPush.NORMAL_EXCHANGE;
+import static com.diligrp.tax.central.queue.TaxAutoPush.NORMAL_ROUTING;
+
+/**
+ * @author lvqi
+ */
+@Service
+@AllArgsConstructor
+public class AdoptMessageServiceImpl implements AdoptMessageService {
+
+    private final ITaxPipelineBusinessKeywordService taxPipelineBusinessKeywordService;
+    private final RabbitTemplate rabbitTemplate;
+
+    @Override
+    public void convertMessage(ReceiveMessageCO receiveMessageCO) {
+        // 查询配置信息
+        List<PipelineBusinessKeyword> pipelineBusinessKeywords = taxPipelineBusinessKeywordService.queryByTenantAndPipelineAndBusiness(receiveMessageCO.getGroup(),
+                receiveMessageCO.getEntity(), receiveMessageCO.getPipelineCode(), receiveMessageCO.getBusinessCode());
+        if (CollectionUtils.isEmpty(pipelineBusinessKeywords)) {
+            throw new TaxAgentServiceException("未找到配置信息");
+        }
+        Map<String, Object> msgBody = receiveMessageCO.getMsgBody();
+        String json = JsonUtils.toJsonString(msgBody);
+        Map<String, Object> map = AdoptUtils.handleAdopt(pipelineBusinessKeywords, json);
+        receiveMessageCO.setMsgBody(map);
+        // 发送mq
+        String messageJson = JsonUtils.toJsonString(receiveMessageCO);
+        rabbitTemplate.convertAndSend(NORMAL_EXCHANGE, NORMAL_ROUTING, messageJson);
+    }
+}
@@ -26,6 +26,11 @@
         </dependency>
         <dependency>
             <groupId>com.diligrp</groupId>
+            <artifactId>tax-adopt</artifactId>
+            <version>${revision}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.diligrp</groupId>
             <artifactId>tax-proxy</artifactId>
             <version>${revision}</version>
         </dependency>
 package com.diligrp.tax.boot;
+import com.diligrp.tax.adopt.AdoptConfig;
 import com.diligrp.tax.central.CentralConfig;
 import com.diligrp.tax.central.process.Processor;
 import com.diligrp.tax.central.process.ProcessorChain;
@@ -25,7 +26,7 @@ import java.util.concurrent.ConcurrentHashMap;
 @SpringBootApplication
 @EnableDiscoveryClient
-@Import({CentralConfig.class, ConvConfig.class, OrderConfig.class, ProxyConfig.class, StorageConfig.class})
+@Import({CentralConfig.class, ConvConfig.class, OrderConfig.class, ProxyConfig.class, StorageConfig.class,AdoptConfig.class})
 public class TaxApplication {
     public static void main(String[] args) {
         SpringApplication.run(TaxApplication.class, args);
@@ -21,7 +21,7 @@ import java.nio.charset.StandardCharsets;
 import java.util.Map;
 import java.util.Optional;
-import static com.diligrp.tax.boot.queue.TaxAutoPush.*;
+import static com.diligrp.tax.central.queue.TaxAutoPush.*;
 /**
-package com.diligrp.tax.boot.queue;
+package com.diligrp.tax.central.queue;
 import org.springframework.amqp.core.*;
 import org.springframework.beans.factory.annotation.Qualifier;