feat(storage): 新增业务关键字配置功能

- 添加批量保存和查询业务关键字接口- 定义业务关键字相关实体类和传输对象 - 实现业务关键字数据访问层逻辑- 更新导入包路径使用通配符简化代码 - 修改单据类型字段为字符串类型以支持更多场景

feat(storage): 新增业务关键字配置功能
- 添加批量保存和查询业务关键字接口- 定义业务关键字相关实体类和传输对象 - 实现业务关键字数据访问层逻辑- 更新导入包路径使用通配符简化代码 - 修改单据类型字段为字符串类型以支持更多场景
zhangmeiyang
1 parent 370056a9
Showing 6 changed files with 157 additions and 37 deletions
tax-storage/src/main/java/com/diligrp/tax/storage/controller/TaxPipelineBusinessConfigController.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
tax-storage/src/main/java/com/diligrp/tax/storage/service/TaxPipelineBusinessKeywordService.java
@@ -2,10 +2,7 @@ package com.diligrp.tax.storage.controller;
  
 import com.diligrp.tax.central.message.Valid;
 import com.diligrp.tax.central.message.Message;
-import com.diligrp.tax.storage.model.co.TaxPipelineBusinessCO;
-import com.diligrp.tax.storage.model.co.TaxPipelineBusinessConfigCO;
-import com.diligrp.tax.storage.model.co.TaxPipelineBusinessExtCO;
-import com.diligrp.tax.storage.model.co.TaxPipelineBusinessExtDefaultDataCO;
+import com.diligrp.tax.storage.model.co.*;
 import com.diligrp.tax.storage.service.TaxPipelineBusinessConfigService;
 import jakarta.annotation.Resource;
 import org.springframework.validation.annotation.Validated;
@@ -14,6 +11,8 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
  
+import java.util.List;
+
 /**
  * @Author: zhangmeiyang
  * @CreateTime: 2025-11-13 15:12
@@ -145,4 +144,27 @@ public class TaxPipelineBusinessConfigController {
         taxPipelineBusinessConfigService.refreshBusinessExtData(co);
         return Message.success();
     }
+
+    /**
+     * 批量保存业务关键字
+     *
+     * @param cos 对象列表
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/keyword/batchSaveBusinessKeyword")
+    public Message<?> batchSaveBusinessKeyword(@RequestBody @Validated(value = Valid.Create.class) List<TaxPipelineBusinessKeywordCO> cos) {
+        taxPipelineBusinessConfigService.batchSaveBusinessKeyword(cos);
+        return Message.success();
+    }
+
+    /**
+     * 列表业务关键字
+     *
+     * @param co 公司
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/keyword/listBusinessKeyword")
+    public Message<?> listBusinessKeyword(@RequestBody @Validated(value = Valid.Read.class) TaxPipelineBusinessKeywordCO co) {
+        return Message.success(taxPipelineBusinessConfigService.listBusinessKeyword(co));
+    }
 }
@@ -5,13 +5,16 @@ 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")
-@Data
+@Getter
+@Setter
 public class TaxPipelineBusinessKeyword {
     /**
      *
@@ -29,7 +32,7 @@ public class TaxPipelineBusinessKeyword {
      * 单据类型
      */
     @TableField(value = "document_type")
-    private Integer documentType;
+    private String documentType;
  
     /**
      * 单据字段
+package com.diligrp.tax.storage.model.co;
+
+import com.diligrp.tax.central.message.Valid;
+import jakarta.validation.constraints.NotEmpty;
+import jakarta.validation.constraints.NotNull;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-17 16:32
+ * @Version: todo
+ */
+@Getter
+@Setter
+public class TaxPipelineBusinessKeywordCO {
+
+    private Integer id;
+    /**
+     * 业务id
+     */
+    @NotNull(groups = {Valid.Create.class, Valid.Read.class})
+    private Long taxPipelineBusinessId;
+    /**
+     * 单据类型
+     */
+    @NotEmpty(groups = {Valid.Create.class})
+    private String documentType;
+
+    /**
+     * 文档字段
+     */
+    @NotEmpty(groups = {Valid.Create.class})
+    private String documentField;
+
+    /**
+     * 文档值方式
+     */
+    @NotNull(groups = {Valid.Create.class})
+    private Integer documentValueWay;
+
+    /**
+     * 文档值内容
+     */
+    @NotEmpty(groups = {Valid.Create.class})
+    private String documentValueContent;
+}
+package com.diligrp.tax.storage.model.vo;
+
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-17 16:32
+ * @Version: todo
+ */
+@Getter
+@Setter
+public class TaxPipelineBusinessKeywordVO {
+
+    private Integer id;
+    /**
+     * 业务id
+     */
+    private Long taxPipelineBusinessId;
+    /**
+     * 单据类型
+     */
+    private String documentType;
+
+    /**
+     * 文档字段
+     */
+    private String documentField;
+
+    /**
+     * 文档值方式
+     */
+    private Integer documentValueWay;
+
+    /**
+     * 文档值内容
+     */
+    private String documentValueContent;
+}
@@ -8,21 +8,13 @@ import com.diligrp.tax.central.type.DocumentType;
 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.TaxPipelineBusiness;
-import com.diligrp.tax.storage.domain.TaxPipelineBusinessConfig;
-import com.diligrp.tax.storage.domain.TaxPipelineBusinessExt;
-import com.diligrp.tax.storage.domain.TaxPipelineBusinessExtData;
-import com.diligrp.tax.storage.model.co.TaxPipelineBusinessCO;
-import com.diligrp.tax.storage.model.co.TaxPipelineBusinessConfigCO;
-import com.diligrp.tax.storage.model.co.TaxPipelineBusinessExtCO;
-import com.diligrp.tax.storage.model.co.TaxPipelineBusinessExtDefaultDataCO;
+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.repo.TaxPipelineBusinessConfigRepository;
-import com.diligrp.tax.storage.repo.TaxPipelineBusinessExtDataRepository;
-import com.diligrp.tax.storage.repo.TaxPipelineBusinessExtRepository;
-import com.diligrp.tax.storage.repo.TaxPipelineBusinessRepository;
+import com.diligrp.tax.storage.repo.*;
 import jakarta.annotation.Resource;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -50,6 +42,9 @@ public class TaxPipelineBusinessConfigService {
     @Resource
     private TaxPipelineBusinessExtDataRepository taxPipelineBusinessExtDataRepository;
  
+    @Resource
+    private TaxPipelineBusinessKeywordRepository taxPipelineBusinessKeywordRepository;
+
     /**
      * 保存业务类型
      *
@@ -261,4 +256,37 @@ public class TaxPipelineBusinessConfigService {
         pipelineBusinessResponse.setBusinessExt(taxPipelineBusinessExts.stream().map(item -> JsonUtils.convertValue(item, TaxPipelineBusinessExtVO.class)).toList());
         return pipelineBusinessResponse;
     }
+
+    /**
+     * 批量保存业务关键字
+     *
+     * @param cos 因为
+     */
+    @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);
+                    });
+                }
+        );
+    }
+
+    /**
+     * 列表业务关键字
+     *
+     * @param co 公司
+     * @return {@link List }<{@link TaxPipelineBusinessKeywordVO }>
+     */
+    public List<TaxPipelineBusinessKeywordVO> listBusinessKeyword(TaxPipelineBusinessKeywordCO co) {
+        LambdaQueryWrapper<TaxPipelineBusinessKeyword> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineBusinessKeyword::getTaxPipelineBusinessId, co.getTaxPipelineBusinessId());
+        return taxPipelineBusinessKeywordRepository.selectList(queryWrapper).stream().map(item -> JsonUtils.convertValue(item, TaxPipelineBusinessKeywordVO.class)).toList();
+    }
 }
-package com.diligrp.tax.storage.service;
-
-import com.diligrp.tax.storage.repo.TaxPipelineBusinessKeywordRepository;
-import jakarta.annotation.Resource;
-import org.springframework.stereotype.Service;
-
-/**
- * @Author: zhangmeiyang
- * @CreateTime: 2025-11-17 16:05
- * @Version: todo
- */
-@Service
-public class TaxPipelineBusinessKeywordService {
-
-    @Resource
-    private TaxPipelineBusinessKeywordRepository taxPipelineBusinessKeywordRepository;
-
-
-}