feat(tax): 引入税务管道映射创建模型并更新服务接口

- 新增 TaxPipelineMappingCreate 模型用于创建税务管道映射- 更新 ITaxPipelineMappingService 接口以使用新的创建模型 - 修改 DynamicTaxPipelineMappingService 实现以适配新模型 - 移除旧的 TaxPipelineMappingCreateCO 模型引用 - 添加对 TaxPipelineMappingCreate 的参数验证支持

feat(tax): 引入税务管道映射创建模型并更新服务接口
- 新增 TaxPipelineMappingCreate 模型用于创建税务管道映射- 更新 ITaxPipelineMappingService 接口以使用新的创建模型 - 修改 DynamicTaxPipelineMappingService 实现以适配新模型 - 移除旧的 TaxPipelineMappingCreateCO 模型引用 - 添加对 TaxPipelineMappingCreate 的参数验证支持
zhangmeiyang
1 parent 31b05494
Showing 3 changed files with 66 additions and 9 deletions
tax-central/src/main/java/com/diligrp/tax/central/model/TaxPipelineMappingCreate.java
tax-central/src/main/java/com/diligrp/tax/central/service/ITaxPipelineMappingService.java
tax-storage/src/main/java/com/diligrp/tax/storage/service/DynamicTaxPipelineMappingService.java
+package com.diligrp.tax.central.model;
+
+import jakarta.validation.Valid;
+import jakarta.validation.constraints.NotEmpty;
+import jakarta.validation.constraints.NotNull;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-07 11:06
+ * @Version: todo
+ */
+@Getter
+@Setter
+@Valid
+public class TaxPipelineMappingCreate {
+    /**
+     * 租户 ID
+     */
+    @NotNull(message = "租户ID不能为空")
+    private Long tenantId;
+    /**
+     * 管道 ID
+     */
+    @NotNull(message = "管道ID不能为空")
+    private Long pipelineId;
+    /**
+     * 文档类型
+     */
+    @NotEmpty(message = "文档类型不能为空")
+    private String documentType;
+    /**
+     * 同步系统数据唯一键
+     */
+    @NotEmpty(message = "同步系统数据唯一键不能为空")
+    private String systemDataId;
+    /**
+     * 账套数据唯一键
+     */
+    @NotEmpty(message = "账套数据唯一键不能为空")
+    private String pipelineDataId;
+    /**
+     * 原始发送数据
+     */
+    @NotEmpty(message = "原始发送数据不能为空")
+    private String originData;
+    /**
+     * 同步状态
+     */
+    @NotNull(message = "同步状态不能为空")
+    private Integer state;
+}
 package com.diligrp.tax.central.service;
  
+import com.diligrp.tax.central.model.TaxPipelineMappingCreate;
 import com.diligrp.tax.central.model.TenantTaxPipelineMapping;
  
 import java.util.Optional;
@@ -16,4 +17,11 @@ public interface ITaxPipelineMappingService {
      * @return {@link Optional }<{@link TenantTaxPipelineMapping }>
      */
     Optional<TenantTaxPipelineMapping> findByPipelineIdAndDocumentTypeAndSystemDataId(Long tenantId,Long pipelineId,String documentType,String systemDataId);
+
+    /**
+     * 插入
+     *
+     * @param taxPipelineMappingCreate
+     */
+    void insert(TaxPipelineMappingCreate taxPipelineMappingCreate);
 }
@@ -2,6 +2,7 @@ package com.diligrp.tax.storage.service;
  
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.diligrp.tax.central.exception.TaxAgentServiceException;
+import com.diligrp.tax.central.model.TaxPipelineMappingCreate;
 import com.diligrp.tax.central.model.TenantTaxPipelineMapping;
 import com.diligrp.tax.central.service.ITaxPipelineMappingService;
 import com.diligrp.tax.central.type.DocumentType;
@@ -9,7 +10,6 @@ import com.diligrp.tax.central.type.TaxSystemType;
 import com.diligrp.tax.central.utils.JsonUtils;
 import com.diligrp.tax.storage.domain.TaxPipelineMapping;
 import com.diligrp.tax.storage.model.co.TaxPipelineMappingCO;
-import com.diligrp.tax.storage.model.co.TaxPipelineMappingCreateCO;
 import com.diligrp.tax.storage.repo.TaxPipelineMappingRepository;
 import com.diligrp.tax.storage.type.MappingStateType;
 import jakarta.annotation.Resource;
@@ -82,14 +82,10 @@ public class DynamicTaxPipelineMappingService implements ITaxPipelineMappingServ
         return taxPipelineMappingRepository.findByPipelineIdAndDocumentTypeAndSystemDataId(taxPipelineMapping);
     }
  
-    /**
-     * 插入
-     *
-     * @param taxPipelineMappingCO 税务管道测绘公司
-     */
-    public void insert(@Validated TaxPipelineMappingCreateCO taxPipelineMappingCO) {
-        DocumentType.validateDocumentType(taxPipelineMappingCO.getDocumentType());
-        TaxPipelineMapping taxPipelineMapping = JsonUtils.convertValue(taxPipelineMappingCO, TaxPipelineMapping.class);
+    @Override
+    public void insert(@Validated TaxPipelineMappingCreate taxPipelineMappingCreate) {
+        DocumentType.validateDocumentType(taxPipelineMappingCreate.getDocumentType());
+        TaxPipelineMapping taxPipelineMapping = JsonUtils.convertValue(taxPipelineMappingCreate, TaxPipelineMapping.class);
         taxPipelineMapping.setState(MappingStateType.SYNCED.value);
         taxPipelineMappingRepository.insert(taxPipelineMapping);
     }