feat(adopt): 添加日志记录并优化消息处理逻辑

lvqi
1 parent 45aab328
Showing 1 changed file with 10 additions and 5 deletions
tax-adopt/src/main/java/com/diligrp/tax/adopt/service/impl/AdoptMessageServiceImpl.java
@@ -16,6 +16,7 @@ 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 lombok.extern.slf4j.Slf4j;
 import org.apache.commons.io.FilenameUtils;
 import org.apache.poi.hssf.usermodel.HSSFWorkbook;
 import org.apache.poi.xssf.usermodel.XSSFWorkbook;
@@ -37,6 +38,7 @@ import static com.diligrp.tax.central.queue.TaxAutoPush.NORMAL_ROUTING;
  */
 @Service
 @AllArgsConstructor
+@Slf4j
 public class AdoptMessageServiceImpl implements AdoptMessageService {
     private final ITaxPipelineBusinessKeywordService taxPipelineBusinessKeywordService;
@@ -49,12 +51,15 @@ public class AdoptMessageServiceImpl implements AdoptMessageService {
         List<PipelineBusinessKeyword> pipelineBusinessKeywords = taxPipelineBusinessKeywordService.queryByTenantAndPipelineAndBusiness(receiveMessageCO.getGroup(),
                 receiveMessageCO.getEntity(), receiveMessageCO.getPipelineCode(), receiveMessageCO.getBusinessCode(), receiveMessageCO.getDocumentType());
         if (CollectionUtils.isEmpty(pipelineBusinessKeywords)) {
-            throw new TaxAgentServiceException("未找到配置信息");
+            log.info("当前group{},entity {},账套编码{},业务代码{},文档类型{} 无配置信息",
+                    receiveMessageCO.getGroup(), receiveMessageCO.getEntity(), receiveMessageCO.getPipelineCode(),
+                    receiveMessageCO.getBusinessCode(), receiveMessageCO.getDocumentType());
+        } else {
+            Map<String, Object> msgBody = receiveMessageCO.getMsgBody();
+            String json = JsonUtils.toJsonString(msgBody);
+            Map<String, Object> map = AdoptUtils.handleAdopt(pipelineBusinessKeywords, json);
+            receiveMessageCO.setMsgBody(map);
         }
-        Map<String, Object> msgBody = receiveMessageCO.getMsgBody();
-        String json = JsonUtils.toJsonString(msgBody);
-        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().code));
         // 发送mq