feat(storage): 新增账套业务配置管理功能- 新增 TaxPipelineBusiness 和 TaxPipelineBusinessConfig 实体类及对应仓储层接口

- 新增 TaxPipelineBusinessCO、TaxPipelineBusinessConfigCO 数据传输对象- 新增 TaxPipelineBusinessConfigController 控制器，提供业务配置的增删改查接口- 新增 TaxPipelineBusinessConfigService 服务实现业务逻辑处理- 引入分页查询支持，完善业务配置相关 VO 类结构 - 在 GlobalExceptionHandler 中增加对 NoHandlerFoundException 和 NoResourceFoundException 的处理 - 修改 Builder 接口及其子类 CustomerBuilder、ReceiptBuilder 等方法参数类型为 Map<String, Object> - 更新 MessageContext 中 msgBody 字段类型为 Map<String, Object> - 修改 TaxReceiveService 中 originData 存储方式为 JSON 字符串 - 在 TaxSystemType 枚举中新增 NOT_FOUND 类型用于 404 错误响应- 在 TaxTenantController 中新增 call 接口用于调试请求转发测试 - 调整 ServiceEndpointSupport 中 HttpClient 使用方式以提升可读性与维护性

feat(storage): 新增账套业务配置管理功能- 新增 TaxPipelineBusiness 和 TaxPipelineBusinessConfig 实体类及对应仓储层接口
- 新增 TaxPipelineBusinessCO、TaxPipelineBusinessConfigCO 数据传输对象- 新增 TaxPipelineBusinessConfigController 控制器，提供业务配置的增删改查接口- 新增 TaxPipelineBusinessConfigService 服务实现业务逻辑处理- 引入分页查询支持，完善业务配置相关 VO 类结构 - 在 GlobalExceptionHandler 中增加对 NoHandlerFoundException 和 NoResourceFoundException 的处理 - 修改 Builder 接口及其子类 CustomerBuilder、ReceiptBuilder 等方法参数类型为 Map<String, Object> - 更新 MessageContext 中 msgBody 字段类型为 Map<String, Object> - 修改 TaxReceiveService 中 originData 存储方式为 JSON 字符串 - 在 TaxSystemType 枚举中新增 NOT_FOUND 类型用于 404 错误响应- 在 TaxTenantController 中新增 call 接口用于调试请求转发测试 - 调整 ServiceEndpointSupport 中 HttpClient 使用方式以提升可读性与维护性
zhangmeiyang
1 parent 23576525
Showing 21 changed files with 542 additions and 14 deletions
tax-boot/src/main/java/com/diligrp/tax/boot/service/TaxReceiveService.java
tax-central/src/main/java/com/diligrp/tax/central/domain/MessageContext.java
tax-central/src/main/java/com/diligrp/tax/central/type/TaxSystemType.java
tax-central/src/main/java/com/diligrp/tax/central/utils/ServiceEndpointSupport.java
tax-doc/src/main/java/com/diligrp/tax/doc/demarcate/Builder.java
tax-doc/src/main/java/com/diligrp/tax/doc/demarcate/kingdee/CustomerBuilder.java
tax-doc/src/main/java/com/diligrp/tax/doc/demarcate/kingdee/ReceiptBuilder.java
tax-doc/src/main/java/com/diligrp/tax/doc/demarcate/kingdee/ReceivableBuilder.java
tax-doc/src/main/java/com/diligrp/tax/doc/demarcate/kingdee/RefundBuilder.java
tax-storage/src/main/java/com/diligrp/tax/storage/GlobalExceptionHandler.java
tax-storage/src/main/java/com/diligrp/tax/storage/controller/TaxPipelineBusinessConfigController.java
tax-storage/src/main/java/com/diligrp/tax/storage/controller/TaxTenantController.java
tax-storage/src/main/java/com/diligrp/tax/storage/domain/TaxPipelineBusiness.java
tax-storage/src/main/java/com/diligrp/tax/storage/domain/TaxPipelineBusinessConfig.java
tax-storage/src/main/java/com/diligrp/tax/storage/model/co/TaxPipelineBusinessCO.java
tax-storage/src/main/java/com/diligrp/tax/storage/model/co/TaxPipelineBusinessConfigCO.java
tax-storage/src/main/java/com/diligrp/tax/storage/model/vo/TaxPipelineBusinessConfigVO.java
tax-storage/src/main/java/com/diligrp/tax/storage/model/vo/TaxPipelineBusinessVO.java
tax-storage/src/main/java/com/diligrp/tax/storage/repo/TaxPipelineBusinessConfigRepository.java
tax-storage/src/main/java/com/diligrp/tax/storage/repo/TaxPipelineBusinessRepository.java
@@ -14,6 +14,7 @@ import com.diligrp.tax.central.type.DocumentType;
 import com.diligrp.tax.central.type.MappingStateType;
 import com.diligrp.tax.central.type.SystemType;
 import com.diligrp.tax.central.type.TaxSystemType;
+import com.diligrp.tax.central.utils.JsonUtils;
 import jakarta.annotation.Resource;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -69,7 +70,7 @@ public class TaxReceiveService {
                     TaxPipelineMappingCreate create = new TaxPipelineMappingCreate();
                     create.setId(e.getId());
                     create.setTenantId(messageContext.getTenantId());
-                    create.setOriginData(messageContext.getMsgBody());
+                    create.setOriginData(JsonUtils.toJsonString(messageContext.getMsgBody()));
                     taxPipelineMappingService.update(create);
                 }, () -> {
                     TaxPipelineMappingCreate create = new TaxPipelineMappingCreate();
@@ -79,7 +80,7 @@ public class TaxReceiveService {
                     create.setSystemDataId(messageContext.getSystemDataId());
                     create.setPipelineDataId(messageContext.getPipelineDataId());
                     create.setState(MappingStateType.SYNCED.value);
-                    create.setOriginData(messageContext.getMsgBody());
+                    create.setOriginData(JsonUtils.toJsonString(messageContext.getMsgBody()));
                     taxPipelineMappingService.insert(create);
                 });
@@ -94,7 +95,7 @@ public class TaxReceiveService {
         error.setSystemType(ctx.getSystemType());
         error.setSystemDataId(ctx.getSystemDataId());
         error.setPipelineCode(ctx.getPipelineCode());
-        error.setOriginData(ctx.getMsgBody());
+        error.setOriginData(JsonUtils.toJsonString(ctx.getMsgBody()));
         error.setState(MappingStateType.SYNC_FAILED.value);
         error.setErrorMessage(e.getMessage());
         taxMappingErrorService.insert(error);
@@ -6,6 +6,8 @@ import com.diligrp.tax.central.type.SystemType;
 import lombok.Getter;
 import lombok.Setter;
+import java.util.Map;
+
 @Setter
 @Getter
 public class MessageContext {
@@ -41,7 +43,7 @@ public class MessageContext {
     /**
      * 消息信息
      */
-    private String msgBody;
+    private Map<String, Object> msgBody;
     /**
      * 公文
      */
@@ -8,6 +8,7 @@ package com.diligrp.tax.central.type;
 public enum TaxSystemType {
     SUCCESS(200, "成功"),
+    NOT_FOUND(404, "404"),
     UNKNOWN_ERROR(5000, "未知错误"),
     ABNORMAL_PARAMETERS(5001, "参数异常"),
     REPEAT_SENDING(5002, "重复发送"),
@@ -188,7 +188,8 @@ public abstract class ServiceEndpointSupport {
      */
     protected HttpResult execute(HttpRequest request) {
         try {
-            HttpResponse<String> response = getHttpClient().send(request, HttpResponse.BodyHandlers.ofString());
+            HttpClient client = getHttpClient();
+            HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());
             HttpResult result = HttpResult.create();
             result.statusCode = response.statusCode();
@@ -4,6 +4,8 @@ import com.diligrp.tax.central.domain.BaseDocument;
 import com.diligrp.tax.central.model.TenantPipeline;
 import com.diligrp.tax.central.type.DocumentType;
+import java.util.Map;
+
 /**
  * @Author: zhangmeiyang
  * @CreateTime: 2025-10-30 10:33
@@ -26,5 +28,5 @@ public abstract class Builder&lt;T extends BaseDocument&gt; {
      * @param systemDataId
      * @return {@link T }
      */
-    public abstract T build(String body, TenantPipeline pipeline, String systemDataId);
+    public abstract T build(Map<String, Object> body, TenantPipeline pipeline, String systemDataId);
 }
@@ -45,8 +45,8 @@ public class CustomerBuilder extends Builder&lt;StandardCustomer&gt; {
     }
     @Override
-    public StandardCustomer build(String body, TenantPipeline pipeline, String systemDataId) {
-        StandardCustomer customer = JsonUtils.fromJsonString(body, StandardCustomer.class);
+    public StandardCustomer build(Map<String, Object> body, TenantPipeline pipeline, String systemDataId) {
+        StandardCustomer customer = JsonUtils.convertValue(body, StandardCustomer.class);
         Optional.ofNullable(customer.getContacts()).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.MISSING_BUSINESS_INFORMATION, "请完善联系人信息"));
         Optional.ofNullable(systemDataId).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.MISSING_BUSINESS_INFORMATION, "请填写系统数据ID"));
         List<TenantPipelineConfig> list = taxTenantService.listByPipelineIdAndDocumentType(pipeline.getId(), markDocument().value);
@@ -38,8 +38,8 @@ public class ReceiptBuilder extends Builder&lt;ReceiptBill&gt; {
     }
     @Override
-    public ReceiptBill build(String body, TenantPipeline pipeline, String systemDataId) {
-        ReceiptBill bill = JsonUtils.fromJsonString(body, ReceiptBill.class);
+    public ReceiptBill build(Map<String, Object> body, TenantPipeline pipeline, String systemDataId) {
+        ReceiptBill bill = JsonUtils.convertValue(body, ReceiptBill.class);
         Optional.ofNullable(bill.getReceiptItems()).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.MISSING_BUSINESS_INFORMATION, "请填写收款项目"));
         bill.setCreateTime(Optional.ofNullable(bill.getCreateTime()).orElse(LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))));
         List<TenantPipelineConfig> list = taxTenantService.listByPipelineIdAndDocumentType(pipeline.getId(), markDocument().value);
@@ -39,8 +39,8 @@ public class ReceivableBuilder extends Builder&lt;ReceivableBill&gt; {
     }
     @Override
-    public ReceivableBill build(String body, TenantPipeline pipeline, String systemDataId) {
-        ReceivableBill bill = JsonUtils.fromJsonString(body, ReceivableBill.class);
+    public ReceivableBill build(Map<String, Object> body, TenantPipeline pipeline, String systemDataId) {
+        ReceivableBill bill = JsonUtils.convertValue(body, ReceivableBill.class);
         Optional.ofNullable(bill.getReceivableItems()).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.MISSING_BUSINESS_INFORMATION, "请填写收款项目"));
         bill.setCreateTime(Optional.ofNullable(bill.getCreateTime()).orElse(LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))));
         List<TenantPipelineConfig> list = taxTenantService.listByPipelineIdAndDocumentType(pipeline.getId(), markDocument().value);
@@ -39,8 +39,8 @@ public class RefundBuilder extends Builder&lt;RefundBill&gt; {
     }
     @Override
-    public RefundBill build(String body, TenantPipeline pipeline, String systemDataId) {
-        RefundBill bill = JsonUtils.fromJsonString(body, RefundBill.class);
+    public RefundBill build(Map<String, Object> body, TenantPipeline pipeline, String systemDataId) {
+        RefundBill bill = JsonUtils.convertValue(body, RefundBill.class);
         Optional.ofNullable(bill.getRefundItems()).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.MISSING_BUSINESS_INFORMATION, "请填写收款项目"));
         bill.setCreateTime(Optional.ofNullable(bill.getCreateTime()).orElse(LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))));
         List<TenantPipelineConfig> list = taxTenantService.listByPipelineIdAndDocumentType(pipeline.getId(), markDocument().value);
@@ -16,6 +16,8 @@ import org.springframework.web.bind.MethodArgumentNotValidException;
 import org.springframework.web.bind.MissingServletRequestParameterException;
 import org.springframework.web.bind.annotation.ControllerAdvice;
 import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.servlet.NoHandlerFoundException;
+import org.springframework.web.servlet.resource.NoResourceFoundException;
 import java.util.List;
 import java.util.Set;
@@ -116,4 +118,28 @@ public class GlobalExceptionHandler {
         log.error("unknown error :", ex);
         return Message.failure(TaxSystemType.UNKNOWN_ERROR.code, TaxSystemType.UNKNOWN_ERROR.message);
     }
+
+    /**
+     * 未找到处理程序异常处理程序
+     *
+     * @param ex 系统异常
+     * @return 响应消息对象
+     */
+    @ExceptionHandler(NoHandlerFoundException.class)
+    public Message<?> NoHandlerFoundExceptionHandler(NoHandlerFoundException ex) {
+        log.error("no handler found exception :", ex);
+        return Message.failure(TaxSystemType.NOT_FOUND.code, TaxSystemType.NOT_FOUND.message);
+    }
+
+    /**
+     * 未找到处理程序异常处理程序
+     *
+     * @param ex 系统异常
+     * @return 响应消息对象
+     */
+    @ExceptionHandler(NoResourceFoundException.class)
+    public Message<?> NoResourceFoundExceptionHandler(NoResourceFoundException ex) {
+        log.error("no resource found exception :", ex);
+        return Message.failure(TaxSystemType.NOT_FOUND.code, TaxSystemType.NOT_FOUND.message);
+    }
 }
+package com.diligrp.tax.storage.controller;
+
+import com.diligrp.tax.storage.Valid;
+import com.diligrp.tax.storage.message.Message;
+import com.diligrp.tax.storage.model.co.TaxPipelineBusinessCO;
+import com.diligrp.tax.storage.model.co.TaxPipelineBusinessConfigCO;
+import com.diligrp.tax.storage.service.TaxPipelineBusinessConfigService;
+import jakarta.annotation.Resource;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-13 15:12
+ * @Version: todo
+ */
+@RestController
+@RequestMapping("/tax/tenant/pipeline/business/config")
+public class TaxPipelineBusinessConfigController {
+
+    @Resource
+    private TaxPipelineBusinessConfigService taxPipelineBusinessConfigService;
+
+    /**
+     * 保存业务
+     *
+     * @param co 公司
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/saveBusiness")
+    public Message<?> saveBusiness(@RequestBody @Validated(value = Valid.Create.class) TaxPipelineBusinessCO co) {
+        taxPipelineBusinessConfigService.saveBusiness(co);
+        return Message.success();
+    }
+
+    /**
+     * 更新业务
+     *
+     * @param co 公司
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/updateBusiness")
+    public Message<?> updateBusiness(@RequestBody @Validated(value = Valid.Update.class) TaxPipelineBusinessCO co) {
+        taxPipelineBusinessConfigService.updateBusiness(co);
+        return Message.success();
+    }
+
+    /**
+     * 删除业务
+     *
+     * @param id id
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/deleteBusiness/{id}")
+    public Message<?> deleteBusiness(@PathVariable("id") Long id) {
+        taxPipelineBusinessConfigService.deleteBusiness(id);
+        return Message.success();
+    }
+
+    /**
+     * 分页查询账套内业务
+     *
+     * @param co 公司
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/pageBusiness")
+    public Message<?> pageBusiness(@RequestBody @Validated(value = Valid.Read.class) TaxPipelineBusinessCO co) {
+        return Message.success(taxPipelineBusinessConfigService.pageBusiness(co));
+    }
+
+
+    /**
+     * 保存业务文档
+     *
+     * @param co 公司
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/saveBusinessDocument")
+    public Message<?> saveBusinessDocument(@RequestBody @Validated(value = Valid.Create.class) TaxPipelineBusinessConfigCO co) {
+        taxPipelineBusinessConfigService.saveBusinessDocument(co);
+        return Message.success();
+    }
+}
@@ -12,6 +12,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.Map;
+
 /**
  * 税务租户
  *
@@ -25,6 +27,12 @@ public class TaxTenantController {
     @Resource
     private TaxTenantService taxTenantService;
+
+    @RequestMapping("call")
+    public Message<?> call(@RequestBody Map<String, Object> map) {
+        return Message.success(map);
+    }
+
     /**
      * 获取
      *
+package com.diligrp.tax.storage.domain;
+
+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 java.time.LocalDateTime;
+
+/**
+ * 账套业务配置
+ *
+ * @TableName tax_pipeline_business
+ */
+@TableName(value = "tax_pipeline_business")
+@Data
+public class TaxPipelineBusiness {
+    /**
+     *
+     */
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 账套ID
+     */
+    @TableField(value = "pipeline_id")
+    private Long pipelineId;
+
+    /**
+     * 业务代码
+     */
+    @TableField(value = "business_code")
+    private String businessCode;
+
+    /**
+     * 业务名称
+     */
+    @TableField(value = "business_name")
+    private String businessName;
+
+    /**
+     * 创建时间
+     */
+    @TableField(value = "created_time")
+    private LocalDateTime createdTime;
+
+    /**
+     * 更新时间
+     */
+    @TableField(value = "modified_time")
+    private LocalDateTime modifiedTime;
+}
+package com.diligrp.tax.storage.domain;
+
+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 java.time.LocalDateTime;
+
+/**
+ * 账套业务配置
+ *
+ * @TableName tax_pipeline_business_config
+ */
+@TableName(value = "tax_pipeline_business_config")
+@Data
+public class TaxPipelineBusinessConfig {
+    /**
+     *
+     */
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 业务ID
+     */
+    @TableField(value = "tax_pipeline_business_id")
+    private Long taxPipelineBusinessId;
+
+    /**
+     * 单据配置
+     */
+    @TableField(value = "document_type")
+    private String documentType;
+
+    /**
+     * 创建时间
+     */
+    @TableField(value = "created_time")
+    private LocalDateTime createdTime;
+
+    /**
+     * 更新时间
+     */
+    @TableField(value = "modified_time")
+    private LocalDateTime modifiedTime;
+}
+package com.diligrp.tax.storage.model.co;
+
+import com.diligrp.tax.storage.Valid;
+import com.diligrp.tax.storage.message.PageQuery;
+import jakarta.validation.constraints.NotEmpty;
+import jakarta.validation.constraints.NotNull;
+import lombok.Data;
+
+/**
+ * 账套业务配置
+ *
+ * @TableName tax_pipeline_business
+ */
+@Data
+public class TaxPipelineBusinessCO extends PageQuery {
+    /**
+     *
+     */
+    @NotNull(groups = {Valid.Update.class, Valid.Delete.class})
+    private Long id;
+
+    /**
+     * 账套ID
+     */
+    @NotNull(groups = {Valid.Read.class})
+    private Long pipelineId;
+
+    /**
+     * 业务代码
+     */
+    @NotEmpty(groups = {Valid.Create.class, Valid.Update.class})
+    private String businessCode;
+
+    /**
+     * 业务名称
+     */
+    @NotEmpty(groups = {Valid.Create.class, Valid.Update.class})
+    private String businessName;
+}
+package com.diligrp.tax.storage.model.co;
+
+import com.diligrp.tax.storage.Valid;
+import jakarta.validation.constraints.NotEmpty;
+import jakarta.validation.constraints.NotNull;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * 账套业务配置
+ *
+ * @TableName tax_pipeline_business_config
+ */
+@Data
+public class TaxPipelineBusinessConfigCO {
+    /**
+     *
+     */
+    private Long id;
+
+    /**
+     * 业务ID
+     */
+    @NotNull(groups = {Valid.Create.class, Valid.Update.class})
+    private Long taxPipelineBusinessId;
+
+    /**
+     * 单据配置
+     */
+    @NotEmpty(groups = {Valid.Create.class, Valid.Update.class})
+    private List<String> documentTypes;
+}
+package com.diligrp.tax.storage.model.vo;
+
+import lombok.Data;
+
+import java.time.LocalDateTime;
+
+@Data
+public class TaxPipelineBusinessConfigVO {
+    /**
+     *
+     */
+    private Long id;
+
+    /**
+     * 业务ID
+     */
+    private Long taxPipelineBusinessId;
+
+    /**
+     * 单据配置
+     */
+    private String documentType;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdTime;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime modifiedTime;
+}
+package com.diligrp.tax.storage.model.vo;
+
+import lombok.Data;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * 账套业务配置
+ *
+ * @TableName tax_pipeline_business
+ */
+@Data
+public class TaxPipelineBusinessVO {
+    /**
+     *
+     */
+    private Long id;
+
+    /**
+     * 账套ID
+     */
+    private Long pipelineId;
+
+    /**
+     * 业务代码
+     */
+    private String businessCode;
+
+    /**
+     * 业务名称
+     */
+    private String businessName;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdTime;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime modifiedTime;
+
+    /**
+     * 配置
+     */
+    private List<TaxPipelineBusinessConfigVO> configs;
+}
+package com.diligrp.tax.storage.repo;
+
+import com.diligrp.tax.storage.domain.TaxPipelineBusinessConfig;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.springframework.stereotype.Repository;
+
+/**
+* @author dili
+* @description 针对表【tax_pipeline_business_config(账套业务配置)】的数据库操作Mapper
+* @createDate 2025-11-13 14:58:05
+* @Entity com.diligrp.tax.storage.domain.TaxPipelineBusinessConfig
+*/
+@Repository
+public interface TaxPipelineBusinessConfigRepository extends BaseMapper<TaxPipelineBusinessConfig> {
+
+}
+
+
+
+
+package com.diligrp.tax.storage.repo;
+
+import com.diligrp.tax.storage.domain.TaxPipelineBusiness;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author dili
+* @description 针对表【tax_pipeline_business(账套业务配置)】的数据库操作Mapper
+* @createDate 2025-11-13 14:58:05
+* @Entity com.diligrp.tax.storage.domain.TaxPipelineBusiness
+*/
+public interface TaxPipelineBusinessRepository extends BaseMapper<TaxPipelineBusiness> {
+
+}
+
+
+
+
+package com.diligrp.tax.storage.service;
+
+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.type.DocumentType;
+import com.diligrp.tax.central.utils.JsonUtils;
+import com.diligrp.tax.storage.domain.TaxPipelineBusiness;
+import com.diligrp.tax.storage.domain.TaxPipelineBusinessConfig;
+import com.diligrp.tax.storage.model.co.TaxPipelineBusinessCO;
+import com.diligrp.tax.storage.model.co.TaxPipelineBusinessConfigCO;
+import com.diligrp.tax.storage.model.vo.TaxPipelineBusinessConfigVO;
+import com.diligrp.tax.storage.model.vo.TaxPipelineBusinessVO;
+import com.diligrp.tax.storage.repo.TaxPipelineBusinessConfigRepository;
+import com.diligrp.tax.storage.repo.TaxPipelineBusinessRepository;
+import jakarta.annotation.Resource;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-13 15:15
+ * @Version: todo
+ */
+@Service
+public class TaxPipelineBusinessConfigService {
+
+    @Resource
+    private TaxPipelineBusinessConfigRepository taxPipelineBusinessConfigRepository;
+
+    @Resource
+    private TaxPipelineBusinessRepository taxPipelineBusinessRepository;
+
+    /**
+     * 保存业务类型
+     *
+     * @param co 公司
+     */
+    @Transactional
+    public void saveBusiness(TaxPipelineBusinessCO co) {
+        taxPipelineBusinessRepository.insert(JsonUtils.convertValue(co, TaxPipelineBusiness.class));
+    }
+
+    /**
+     * 更新业务
+     *
+     * @param co 公司
+     */
+    @Transactional
+    public void updateBusiness(TaxPipelineBusinessCO co) {
+        taxPipelineBusinessRepository.updateById(JsonUtils.convertValue(co, TaxPipelineBusiness.class));
+    }
+
+    /**
+     * 删除业务
+     *
+     * @param id id
+     */
+    @Transactional
+    public void deleteBusiness(Long id) {
+        taxPipelineBusinessRepository.deleteById(id);
+        LambdaQueryWrapper<TaxPipelineBusinessConfig> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineBusinessConfig::getTaxPipelineBusinessId, id);
+        taxPipelineBusinessConfigRepository.delete(queryWrapper);
+    }
+
+    /**
+     * 分页查询账套内业务
+     *
+     * @param co 公司
+     * @return {@link IPage }<{@link TaxPipelineBusinessVO }>
+     */
+    public IPage<TaxPipelineBusinessVO> pageBusiness(TaxPipelineBusinessCO co) {
+        LambdaQueryWrapper<TaxPipelineBusiness> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineBusiness::getPipelineId, co.getPipelineId());
+        Page<TaxPipelineBusiness> page = taxPipelineBusinessRepository.selectPage(Page.of(co.getPageNumber(), co.getPageSize()), queryWrapper);
+        return page.convert(item -> {
+            TaxPipelineBusinessVO pipelineBusiness = JsonUtils.convertValue(item, TaxPipelineBusinessVO.class);
+            LambdaQueryWrapper<TaxPipelineBusinessConfig> wrapper = new LambdaQueryWrapper<>();
+            wrapper.eq(TaxPipelineBusinessConfig::getTaxPipelineBusinessId, item.getId());
+            List<TaxPipelineBusinessConfig> configs = taxPipelineBusinessConfigRepository.selectList(wrapper);
+            pipelineBusiness.setConfigs(configs.stream().map(e -> JsonUtils.convertValue(e, TaxPipelineBusinessConfigVO.class)).toList());
+            return pipelineBusiness;
+        });
+    }
+
+    /**
+     * 保存业务文档
+     *
+     * @param co 公司
+     */
+    @Transactional
+    public void saveBusinessDocument(TaxPipelineBusinessConfigCO co) {
+        LambdaQueryWrapper<TaxPipelineBusinessConfig> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineBusinessConfig::getTaxPipelineBusinessId, co.getTaxPipelineBusinessId());
+        taxPipelineBusinessConfigRepository.delete(queryWrapper);
+        co.getDocumentTypes().forEach(documentType -> {
+            DocumentType.validateDocumentType(documentType);
+            var save = new TaxPipelineBusinessConfig();
+            save.setTaxPipelineBusinessId(co.getTaxPipelineBusinessId());
+            save.setDocumentType(documentType);
+            taxPipelineBusinessConfigRepository.insert(save);
+        });
+    }
+}