feat(tax-central): 新增业务关键词处理工具类及枚举类型

- 新增 AdoptUtils 工具类用于处理业务关键词提取逻辑 - 新增 DocumentFieldType 枚举定义文档字段类型及其解析方式 - 新增 DocumentValueWayType 枚举定义文档值获取方式- 扩展 JsonPathUtils 支持将 JSON 路径映射为 Map 结构 - 新增 PipelineBusinessKeyword 模型类用于存储关键词配置- 实现 ITaxPipelineBusinessKeywordService 接口并完成关键词查询逻辑 - 在 TaxPipelineBusinessConfigService 中实现关键词批量保存与查询功能 - 补充 TaxPipelineBusinessKeyword 相关字段以支持更多配置属性

feat(tax-central): 新增业务关键词处理工具类及枚举类型
- 新增 AdoptUtils 工具类用于处理业务关键词提取逻辑 - 新增 DocumentFieldType 枚举定义文档字段类型及其解析方式 - 新增 DocumentValueWayType 枚举定义文档值获取方式- 扩展 JsonPathUtils 支持将 JSON 路径映射为 Map 结构 - 新增 PipelineBusinessKeyword 模型类用于存储关键词配置- 实现 ITaxPipelineBusinessKeywordService 接口并完成关键词查询逻辑 - 在 TaxPipelineBusinessConfigService 中实现关键词批量保存与查询功能 - 补充 TaxPipelineBusinessKeyword 相关字段以支持更多配置属性
zhangmeiyang
1 parent 68e5cc14
Showing 10 changed files with 297 additions and 19 deletions
tax-central/src/main/java/com/diligrp/tax/central/model/PipelineBusinessKeyword.java
tax-central/src/main/java/com/diligrp/tax/central/service/ITaxPipelineBusinessKeywordService.java
tax-central/src/main/java/com/diligrp/tax/central/type/DocumentFieldType.java
tax-central/src/main/java/com/diligrp/tax/central/type/DocumentValueWayType.java
tax-central/src/main/java/com/diligrp/tax/central/utils/AdoptUtils.java
tax-central/src/main/java/com/diligrp/tax/central/utils/JsonPathUtils.java
tax-storage/src/main/java/com/diligrp/tax/storage/domain/TaxPipelineBusinessKeyword.java
tax-storage/src/main/java/com/diligrp/tax/storage/model/co/TaxPipelineBusinessKeywordCO.java
tax-storage/src/main/java/com/diligrp/tax/storage/model/vo/TaxPipelineBusinessKeywordVO.java
tax-storage/src/main/java/com/diligrp/tax/storage/service/TaxPipelineBusinessConfigService.java
+package com.diligrp.tax.central.model;
+
+import com.diligrp.tax.central.type.DocumentFieldType;
+import com.diligrp.tax.central.type.DocumentValueWayType;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-18 09:42
+ * @Version: todo
+ */
+@Getter
+@Setter
+public class PipelineBusinessKeyword {
+
+    /**
+     * id
+     */
+    private Integer id;
+    /**
+     * 业务id
+     */
+    private Long taxPipelineBusinessId;
+    /**
+     * 单据类型
+     */
+    private String documentType;
+
+    /**
+     * 文档字段
+     */
+    private String documentField;
+
+    /**
+     * 文档字段
+     */
+    private Integer documentFieldType;
+
+    /**
+     * 文档字段类型 ENUM
+     */
+    private DocumentFieldType documentFieldTypeEnum;
+
+    /**
+     * 文档值方式
+     */
+    private Integer documentValueWay;
+    /**
+     * 文档价值方式类型 ENUM
+     */
+    private DocumentValueWayType documentValueWayTypeEnum;
+
+    /**
+     * 文档值内容
+     */
+    private String documentValueContent;
+}
 package com.diligrp.tax.central.service;
  
+import com.diligrp.tax.central.model.PipelineBusinessKeyword;
+
+import java.util.List;
+
 /**
  * @author lvqi
  */
 public interface ITaxPipelineBusinessKeywordService {
+
+    /**
+     * 按租户、管道和业务查询
+     *
+     * @param group        群
+     * @param entity       实体
+     * @param pipelineCode 管道代码
+     * @param businessCode 业务代码
+     * @return {@link List }<{@link PipelineBusinessKeyword }>
+     */
+    List<PipelineBusinessKeyword> queryByTenantAndPipelineAndBusiness(String group, String entity, String pipelineCode, String businessCode);
 }
+package com.diligrp.tax.central.type;
+
+import com.diligrp.tax.central.model.PipelineBusinessKeyword;
+import com.diligrp.tax.central.utils.JsonPathUtils;
+import com.diligrp.tax.central.utils.JsonUtils;
+import com.fasterxml.jackson.core.type.TypeReference;
+
+import java.util.*;
+
+public enum DocumentFieldType {
+    OBJECT(1, "对象") {
+        @Override
+        public void handleAdopt(Map<String, Object> res, PipelineBusinessKeyword keyword, String json) {
+            res.put(keyword.getDocumentField(), JsonPathUtils.parse(json, keyword.getDocumentValueContent()));
+        }
+    },
+    OBJECT_ARRAY(2, "对象数组") {
+        @Override
+        public void handleAdopt(Map<String, Object> res, PipelineBusinessKeyword keyword, String json) {
+            List<Map<String, Object>> list = new ArrayList<>();
+            Map<String, Object> data = JsonUtils.fromJsonString(json, new TypeReference<HashMap<String, Object>>() {});
+            data.forEach((k, v) -> {
+                if (v instanceof Object[] os) {
+                    Arrays.stream(os).forEach(o -> list.add(JsonPathUtils.parseToMap(o, keyword.getDocumentValueContent())));
+                }
+            });
+            res.put(keyword.getDocumentField(), list);
+        }
+    },
+    ;
+    public final int value;
+    public final String desc;
+
+    DocumentFieldType(int value, String desc) {
+        this.value = value;
+        this.desc = desc;
+    }
+
+    public static DocumentFieldType from(int value) {
+        for (DocumentFieldType type : DocumentFieldType.values()) {
+            if (type.value == value) {
+                return type;
+            }
+        }
+        throw new IllegalArgumentException("Invalid DocumentFieldType value: " + value);
+    }
+
+    public abstract void handleAdopt(Map<String, Object> res, PipelineBusinessKeyword keyword, String json);
+}
+package com.diligrp.tax.central.type;
+
+import com.diligrp.tax.central.model.PipelineBusinessKeyword;
+
+import java.util.Map;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-18 10:18
+ * @Version: todo
+ */
+public enum DocumentValueWayType {
+    FIX(1, "固定") {
+        @Override
+        public void handleAdopt(Map<String, Object> res, PipelineBusinessKeyword keyword, String json) {
+            res.put(keyword.getDocumentField(), keyword.getDocumentValueContent());
+        }
+    },
+    VARIABLE(2, "可变") {
+        @Override
+        public void handleAdopt(Map<String, Object> res, PipelineBusinessKeyword keyword, String json) {
+            DocumentFieldType documentFieldTypeEnum = keyword.getDocumentFieldTypeEnum();
+            documentFieldTypeEnum.handleAdopt(res,keyword,json);
+        }
+    },
+    ;
+    public final int value;
+    public final String desc;
+
+    DocumentValueWayType(int value, String desc) {
+        this.value = value;
+        this.desc = desc;
+    }
+
+    public static DocumentValueWayType from(int value) {
+        for (DocumentValueWayType type : DocumentValueWayType.values()) {
+            if (type.value == value) {
+                return type;
+            }
+        }
+        throw new IllegalArgumentException("Invalid DocumentValueWayType value: " + value);
+    }
+
+    public abstract void handleAdopt(Map<String, Object> res, PipelineBusinessKeyword keyword, String json);
+}
+package com.diligrp.tax.central.utils;
+
+import com.diligrp.tax.central.model.PipelineBusinessKeyword;
+import com.diligrp.tax.central.type.DocumentValueWayType;
+
+import java.util.*;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-18 10:03
+ * @Version: todo
+ */
+public class AdoptUtils {
+
+    public static Map<String, Object> handleAdopt(List<PipelineBusinessKeyword> pipelineBusinessKeywords, String json) {
+        Map<String, Object> res = new HashMap<>();
+        List<PipelineBusinessKeyword> keywords = Optional.ofNullable(pipelineBusinessKeywords).orElse(new ArrayList<>());
+        keywords.forEach(keyword -> {
+            DocumentValueWayType documentValueWayTypeEnum = keyword.getDocumentValueWayTypeEnum();
+            documentValueWayTypeEnum.handleAdopt(res, keyword, json);
+        });
+        return res;
+    }
+
+}
@@ -2,8 +2,11 @@ package com.diligrp.tax.central.utils;
  
 import com.diligrp.tax.central.exception.TaxAgentServiceException;
 import com.diligrp.tax.central.type.TaxSystemType;
+import com.fasterxml.jackson.core.type.TypeReference;
 import com.jayway.jsonpath.JsonPath;
  
+import java.util.HashMap;
+import java.util.Map;
 import java.util.Optional;
  
 /**
@@ -18,4 +21,39 @@ public class JsonPathUtils {
         Optional.ofNullable(dataPath).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.PARAMETER_IS_NOT_PARSED_CORRECTLY));
         return JsonPath.read(httpResult, dataPath).toString();
     }
+
+    /**
+     * 解析到map
+     *
+     * @param httpResult
+     * @param dataPathMap 数据路径图
+     * @return {@link Map }<{@link String }, {@link Object }>
+     */
+    public static Map<String, Object> parseToMap(String httpResult, Map<String, String> dataPathMap) {
+        Map<String, Object> res = new HashMap<>();
+        Optional.ofNullable(httpResult).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.REMOTE_SERVICE_CALLS_ARE_EXCEPTIONAL));
+        Optional.ofNullable(dataPathMap).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.PARAMETER_IS_NOT_PARSED_CORRECTLY));
+        dataPathMap.forEach((k, v) -> res.put(k, JsonPath.read(httpResult, v)));
+        return res;
+    }
+
+    /**
+     * 解析到map
+     *
+     * @param resultObject    结果对象
+     * @param dataPathMapJson
+     * @return {@link Map }<{@link String }, {@link Object }>
+     */
+    public static Map<String, Object> parseToMap(Object resultObject, String dataPathMapJson) {
+        Map<String, Object> res = new HashMap<>();
+        String httpResult = JsonUtils.toJsonString(resultObject);
+        Map<String, String> dataPathMap = JsonUtils.fromJsonString(dataPathMapJson, new TypeReference<HashMap<String, String>>() {
+        });
+        Optional.ofNullable(httpResult).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.REMOTE_SERVICE_CALLS_ARE_EXCEPTIONAL));
+        Optional.ofNullable(dataPathMap).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.PARAMETER_IS_NOT_PARSED_CORRECTLY));
+        dataPathMap.forEach((k, v) -> res.put(k, JsonPath.read(httpResult, v)));
+        return res;
+    }
+
+
 }
@@ -4,15 +4,13 @@ import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.Data;
 import lombok.Getter;
 import lombok.Setter;
  
 /**
- *
  * @TableName tax_pipeline_business_keyword
  */
-@TableName(value ="tax_pipeline_business_keyword")
+@TableName(value = "tax_pipeline_business_keyword")
 @Getter
 @Setter
 public class TaxPipelineBusinessKeyword {
@@ -41,6 +39,12 @@ public class TaxPipelineBusinessKeyword {
     private String documentField;
  
     /**
+     * 单据字段类型
+     */
+    @TableField(value = "document_field_type")
+    private Integer documentFieldType;
+
+    /**
      * 单据字段取值方式（1:固定，2：可变）
      */
     @TableField(value = "document_value_way")
@@ -34,6 +34,12 @@ public class TaxPipelineBusinessKeywordCO {
     private String documentField;
  
     /**
+     * 文档字段
+     */
+    @NotNull(groups = {Valid.Create.class})
+    private Integer documentFieldType;
+
+    /**
      * 文档值方式
      */
     @NotNull(groups = {Valid.Create.class})
@@ -28,6 +28,11 @@ public class TaxPipelineBusinessKeywordVO {
     private String documentField;
  
     /**
+     * 文档字段
+     */
+    private Integer documentFieldType;
+
+    /**
      * 文档值方式
      */
     private Integer documentValueWay;
@@ -4,16 +4,17 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 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.type.DocumentFieldType;
 import com.diligrp.tax.central.type.DocumentType;
+import com.diligrp.tax.central.type.DocumentValueWayType;
 import com.diligrp.tax.central.type.TaxSystemType;
 import com.diligrp.tax.central.utils.JsonUtils;
 import com.diligrp.tax.storage.api.response.PipelineBusinessResponse;
 import com.diligrp.tax.storage.domain.*;
 import com.diligrp.tax.storage.model.co.*;
-import com.diligrp.tax.storage.model.vo.TaxPipelineBusinessConfigVO;
-import com.diligrp.tax.storage.model.vo.TaxPipelineBusinessExtVO;
-import com.diligrp.tax.storage.model.vo.TaxPipelineBusinessKeywordVO;
-import com.diligrp.tax.storage.model.vo.TaxPipelineBusinessVO;
+import com.diligrp.tax.storage.model.vo.*;
 import com.diligrp.tax.storage.repo.*;
 import jakarta.annotation.Resource;
 import org.springframework.stereotype.Service;
@@ -28,7 +29,7 @@ import java.util.Optional;
  * @Version: todo
  */
 @Service
-public class TaxPipelineBusinessConfigService {
+public class TaxPipelineBusinessConfigService implements ITaxPipelineBusinessKeywordService {
  
     @Resource
     private TaxPipelineBusinessConfigRepository taxPipelineBusinessConfigRepository;
@@ -44,6 +45,10 @@ public class TaxPipelineBusinessConfigService {
  
     @Resource
     private TaxPipelineBusinessKeywordRepository taxPipelineBusinessKeywordRepository;
+    @Resource
+    private TaxTenantService taxTenantService;
+    @Resource
+    private TaxPipelineService taxPipelineService;
  
     /**
      * 保存业务类型
@@ -265,17 +270,16 @@ public class TaxPipelineBusinessConfigService {
     @Transactional
     public void batchSaveBusinessKeyword(List<TaxPipelineBusinessKeywordCO> cos) {
         Optional.ofNullable(cos).ifPresent(ts -> {
-                    Long taxPipelineBusinessId = ts.getFirst().getTaxPipelineBusinessId();
-                    LambdaQueryWrapper<TaxPipelineBusinessKeyword> queryWrapper = new LambdaQueryWrapper<>();
-                    queryWrapper.eq(TaxPipelineBusinessKeyword::getTaxPipelineBusinessId, taxPipelineBusinessId);
-                    taxPipelineBusinessKeywordRepository.delete(queryWrapper);
-                    ts.forEach(co -> {
-                        DocumentType.validateDocumentType(co.getDocumentType());
-                        TaxPipelineBusinessKeyword taxPipelineBusinessKeyword = JsonUtils.convertValue(co, TaxPipelineBusinessKeyword.class);
-                        taxPipelineBusinessKeywordRepository.insert(taxPipelineBusinessKeyword);
-                    });
-                }
-        );
+            Long taxPipelineBusinessId = ts.getFirst().getTaxPipelineBusinessId();
+            LambdaQueryWrapper<TaxPipelineBusinessKeyword> queryWrapper = new LambdaQueryWrapper<>();
+            queryWrapper.eq(TaxPipelineBusinessKeyword::getTaxPipelineBusinessId, taxPipelineBusinessId);
+            taxPipelineBusinessKeywordRepository.delete(queryWrapper);
+            ts.forEach(co -> {
+                DocumentType.validateDocumentType(co.getDocumentType());
+                TaxPipelineBusinessKeyword taxPipelineBusinessKeyword = JsonUtils.convertValue(co, TaxPipelineBusinessKeyword.class);
+                taxPipelineBusinessKeywordRepository.insert(taxPipelineBusinessKeyword);
+            });
+        });
     }
  
     /**
@@ -289,4 +293,33 @@ public class TaxPipelineBusinessConfigService {
         queryWrapper.eq(TaxPipelineBusinessKeyword::getTaxPipelineBusinessId, co.getTaxPipelineBusinessId());
         return taxPipelineBusinessKeywordRepository.selectList(queryWrapper).stream().map(item -> JsonUtils.convertValue(item, TaxPipelineBusinessKeywordVO.class)).toList();
     }
+
+
+    /**
+     * 按租户、管道和业务查询
+     *
+     * @param group        群
+     * @param entity       实体
+     * @param pipelineCode 管道代码
+     * @param businessCode 业务代码
+     * @return {@link List }<{@link PipelineBusinessKeyword }>
+     */
+    @Override
+    public List<PipelineBusinessKeyword> queryByTenantAndPipelineAndBusiness(String group, String entity, String pipelineCode, String businessCode) {
+        Long tenantId = taxTenantService.getTenantId(group, entity);
+        TaxPipelineVO byTenantIdAndCode = taxPipelineService.getByTenantIdAndCode(tenantId, pipelineCode);
+        LambdaQueryWrapper<TaxPipelineBusiness> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineBusiness::getPipelineId, byTenantIdAndCode.getId());
+        queryWrapper.eq(TaxPipelineBusiness::getBusinessCode, businessCode);
+        TaxPipelineBusiness taxPipelineBusiness = taxPipelineBusinessRepository.selectOne(queryWrapper);
+        Optional.ofNullable(taxPipelineBusiness).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.MISSING_BUSINESS_INFORMATION));
+        LambdaQueryWrapper<TaxPipelineBusinessKeyword> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(TaxPipelineBusinessKeyword::getTaxPipelineBusinessId, taxPipelineBusiness.getId());
+        return taxPipelineBusinessKeywordRepository.selectList(wrapper).stream().map(item -> {
+            PipelineBusinessKeyword pipelineBusinessKeyword = JsonUtils.convertValue(item, PipelineBusinessKeyword.class);
+            pipelineBusinessKeyword.setDocumentFieldTypeEnum(DocumentFieldType.from(item.getDocumentFieldType()));
+            pipelineBusinessKeyword.setDocumentValueWayTypeEnum(DocumentValueWayType.from(item.getDocumentValueWay()));
+            return pipelineBusinessKeyword;
+        }).toList();
+    }
 }