feat(storage): 新增业务流水线配置功能

- 新增业务流水线API接口，支持获取商家信息 - 新增业务流水线请求与响应模型类 - 实现业务流水线服务逻辑，包括参数校验与异常处理 - 扩展业务配置相关实体类及数据访问层- 增加业务扩展信息的增删改查功能 - 完善业务流水线配置重复性校验逻辑 - 提供根据租户ID和编码查询流水线信息方法

feat(storage): 新增业务流水线配置功能
- 新增业务流水线API接口，支持获取商家信息 - 新增业务流水线请求与响应模型类 - 实现业务流水线服务逻辑，包括参数校验与异常处理 - 扩展业务配置相关实体类及数据访问层- 增加业务扩展信息的增删改查功能 - 完善业务流水线配置重复性校验逻辑 - 提供根据租户ID和编码查询流水线信息方法
zhangmeiyang
1 parent a5d09a5d
Showing 18 changed files with 677 additions and 10 deletions
tax-storage/src/main/java/com/diligrp/tax/storage/api/PipelineBusinessApi.java
tax-storage/src/main/java/com/diligrp/tax/storage/api/request/PipelineBusinessRequest.java
tax-storage/src/main/java/com/diligrp/tax/storage/api/response/PipelineBusinessResponse.java
tax-storage/src/main/java/com/diligrp/tax/storage/api/service/PipelineBusinessService.java
tax-storage/src/main/java/com/diligrp/tax/storage/controller/TaxPipelineBusinessConfigController.java
tax-storage/src/main/java/com/diligrp/tax/storage/domain/TaxPipelineBusinessExt.java
tax-storage/src/main/java/com/diligrp/tax/storage/domain/TaxPipelineBusinessExtData.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/co/TaxPipelineBusinessExtCO.java
tax-storage/src/main/java/com/diligrp/tax/storage/model/co/TaxPipelineBusinessExtDefaultDataCO.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/TaxPipelineBusinessExtVO.java
tax-storage/src/main/java/com/diligrp/tax/storage/model/vo/TaxPipelineBusinessVO.java
tax-storage/src/main/java/com/diligrp/tax/storage/repo/TaxPipelineBusinessExtDataRepository.java
tax-storage/src/main/java/com/diligrp/tax/storage/repo/TaxPipelineBusinessExtRepository.java
tax-storage/src/main/java/com/diligrp/tax/storage/service/TaxPipelineBusinessConfigService.java
tax-storage/src/main/java/com/diligrp/tax/storage/service/TaxPipelineService.java
+package com.diligrp.tax.storage.api;
+
+import com.diligrp.tax.storage.api.request.PipelineBusinessRequest;
+import com.diligrp.tax.storage.api.service.PipelineBusinessService;
+import com.diligrp.tax.storage.message.Message;
+import jakarta.annotation.Resource;
+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 18:14
+ * @Version: todo
+ */
+@RestController
+@RequestMapping("remote/tax/pipeline/info")
+public class PipelineBusinessApi {
+
+    @Resource
+    private PipelineBusinessService pipelineBusinessService;
+
+    /**
+     * 获取商家信息
+     *
+     * @param request 请求
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("getBusinessInfo")
+    public Message<?> getBusinessInfo(@RequestBody PipelineBusinessRequest request) {
+        return Message.success(pipelineBusinessService.getBusinessInfo(request));
+    }
+
+}
+package com.diligrp.tax.storage.api.request;
+
+import jakarta.validation.constraints.NotEmpty;
+import lombok.Data;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-13 18:17
+ * @Version: todo
+ */
+@Data
+public class PipelineBusinessRequest {
+    @NotEmpty
+    private String group;
+    @NotEmpty
+    private String entity;
+    @NotEmpty
+    private String pipelineCode;
+    @NotEmpty
+    private String systemType;
+    @NotEmpty
+    private String businessCode;
+}
+package com.diligrp.tax.storage.api.response;
+
+import com.diligrp.tax.central.type.DocumentType;
+import com.diligrp.tax.storage.model.vo.TaxPipelineBusinessExtVO;
+import lombok.Getter;
+import lombok.Setter;
+
+import java.util.List;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-13 18:21
+ * @Version: todo
+ */
+@Getter
+@Setter
+public class PipelineBusinessResponse {
+    /**
+     *
+     */
+    private Long id;
+
+    /**
+     * 账套ID
+     */
+    private Long pipelineId;
+
+    /**
+     * 业务代码
+     */
+    private String businessCode;
+
+    /**
+     * 业务名称
+     */
+    private String businessName;
+
+    /**
+     * 配置
+     */
+    private List<String> configs;
+
+
+    /**
+     * 业务扩展
+     */
+    private List<TaxPipelineBusinessExtVO> businessExt;
+}
+package com.diligrp.tax.storage.api.service;
+
+import com.diligrp.tax.central.exception.TaxAgentServiceException;
+import com.diligrp.tax.central.type.SystemType;
+import com.diligrp.tax.central.type.TaxSystemType;
+import com.diligrp.tax.storage.api.request.PipelineBusinessRequest;
+import com.diligrp.tax.storage.api.response.PipelineBusinessResponse;
+import com.diligrp.tax.storage.model.vo.TaxPipelineVO;
+import com.diligrp.tax.storage.model.vo.TaxTenantVO;
+import com.diligrp.tax.storage.service.TaxPipelineBusinessConfigService;
+import com.diligrp.tax.storage.service.TaxPipelineService;
+import com.diligrp.tax.storage.service.TaxTenantService;
+import jakarta.annotation.Resource;
+import org.springframework.stereotype.Service;
+
+import java.util.Objects;
+import java.util.Optional;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-13 18:22
+ * @Version: todo
+ */
+@Service
+public class PipelineBusinessService {
+
+    @Resource
+    private TaxTenantService taxTenantService;
+
+    @Resource
+    private TaxPipelineService taxPipelineService;
+
+    @Resource
+    private TaxPipelineBusinessConfigService taxPipelineBusinessConfigService;
+
+    public PipelineBusinessResponse getBusinessInfo(PipelineBusinessRequest request) {
+        TaxTenantVO tenant = taxTenantService.getTenant(request.getGroup(), request.getEntity());
+        TaxPipelineVO taxPipelineVO = taxPipelineService.getByTenantIdAndCode(tenant.getId(), request.getPipelineCode());
+        Optional.ofNullable(request.getSystemType()).ifPresent(SystemType::validateSystemCode);
+        if (!Objects.equals(SystemType.from(request.getSystemType()), SystemType.from(taxPipelineVO.getSystemCode()))) {
+            throw new TaxAgentServiceException(TaxSystemType.ABNORMAL_PARAMETERS, "系统类型不匹配");
+        }
+        return taxPipelineBusinessConfigService.getByPipelineIdAndBusinessCode(taxPipelineVO.getId(), request.getBusinessCode());
+    }
+}
@@ -4,6 +4,8 @@ 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.model.co.TaxPipelineBusinessExtCO;
+import com.diligrp.tax.storage.model.co.TaxPipelineBusinessExtDefaultDataCO;
 import com.diligrp.tax.storage.service.TaxPipelineBusinessConfigService;
 import jakarta.annotation.Resource;
 import org.springframework.validation.annotation.Validated;
@@ -83,4 +85,64 @@ public class TaxPipelineBusinessConfigController {
         taxPipelineBusinessConfigService.saveBusinessDocument(co);
         return Message.success();
     }
+
+    /**
+     * 保存业务扩展信息
+     *
+     * @param co 公司
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/ext/saveBusinessExt")
+    public Message<?> saveBusinessExt(@RequestBody @Validated(value = Valid.Create.class) TaxPipelineBusinessExtCO co) {
+        taxPipelineBusinessConfigService.saveBusinessExt(co);
+        return Message.success();
+    }
+
+    /**
+     * 设置业务分机数据
+     *
+     * @param co 公司
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/ext/updateBusinessExt")
+    public Message<?> setBusinessExtData(@RequestBody @Validated(value = Valid.Update.class) TaxPipelineBusinessExtCO co) {
+        taxPipelineBusinessConfigService.updateBusinessExt(co);
+        return Message.success();
+    }
+
+    /**
+     * 设置默认业务扩展数据
+     *
+     * @param co 公司
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/ext/setDefaultBusinessExtData")
+    public Message<?> setDefaultBusinessExtData(@RequestBody @Validated(value = Valid.Update.class) TaxPipelineBusinessExtDefaultDataCO co) {
+        taxPipelineBusinessConfigService.setDefaultBusinessExtData(co);
+        return Message.success();
+    }
+
+    /**
+     * 删除业务扩展
+     *
+     * @param co 公司
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/ext/deleteBusinessExt")
+    public Message<?> deleteBusinessExt(@RequestBody @Validated(value = Valid.Update.class) TaxPipelineBusinessExtCO co) {
+        taxPipelineBusinessConfigService.deleteBusinessExt(co);
+        return Message.success();
+    }
+
+    /**
+     * 刷新业务分机数据
+     *
+     * @param co 公司
+     * @return {@link Message }<{@link ? }>
+     */
+    @RequestMapping("/ext/refreshBusinessExtData")
+    public Message<?> refreshBusinessExtData(@RequestBody @Validated(value = Valid.Update.class) TaxPipelineBusinessExtCO co) {
+        taxPipelineBusinessConfigService.refreshBusinessExtData(co);
+        return Message.success();
+    }
 }
+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 java.time.LocalDateTime;
+import lombok.Data;
+
+/**
+ * 账套业务配置
+ * @TableName tax_pipeline_business_ext
+ */
+@TableName(value ="tax_pipeline_business_ext")
+@Data
+public class TaxPipelineBusinessExt {
+    /**
+     *
+     */
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 业务ID
+     */
+    @TableField(value = "tax_pipeline_business_id")
+    private Long taxPipelineBusinessId;
+
+    /**
+     * 扩展名字
+     */
+    @TableField(value = "ext_name")
+    private String extName;
+
+    /**
+     * 扩展编码
+     */
+    @TableField(value = "ext_code")
+    private String extCode;
+
+    /**
+     * 扩展默认数据
+     */
+    @TableField(value = "ext_default_data")
+    private String extDefaultData;
+
+    /**
+     * 创建时间
+     */
+    @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_ext_data
+ */
+@TableName(value = "tax_pipeline_business_ext_data")
+@Data
+public class TaxPipelineBusinessExtData {
+    /**
+     *
+     */
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 业务扩展表ID
+     */
+    @TableField(value = "tax_pipeline_business_ext_id")
+    private Long taxPipelineBusinessExtId;
+
+    /**
+     * 扩展数据
+     */
+    @TableField(value = "ext_data")
+    private String extData;
+
+    /**
+     * 创建时间
+     */
+    @TableField(value = "created_time")
+    private LocalDateTime createdTime;
+
+    /**
+     * 更新时间
+     */
+    @TableField(value = "modified_time")
+    private LocalDateTime modifiedTime;
+}
@@ -4,14 +4,16 @@ 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;
+import lombok.Getter;
+import lombok.Setter;
  
 /**
  * 账套业务配置
  *
  * @TableName tax_pipeline_business
  */
-@Data
+@Getter
+@Setter
 public class TaxPipelineBusinessCO extends PageQuery {
     /**
      *
@@ -22,7 +24,7 @@ public class TaxPipelineBusinessCO extends PageQuery {
     /**
      * 账套ID
      */
-    @NotNull(groups = {Valid.Read.class})
+    @NotNull(groups = {Valid.Create.class, Valid.Update.class, Valid.Read.class})
     private Long pipelineId;
  
     /**
@@ -3,7 +3,8 @@ 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 lombok.Getter;
+import lombok.Setter;
  
 import java.util.List;
  
@@ -12,7 +13,8 @@ import java.util.List;
  *
  * @TableName tax_pipeline_business_config
  */
-@Data
+@Getter
+@Setter
 public class TaxPipelineBusinessConfigCO {
     /**
      *
+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.Getter;
+import lombok.Setter;
+
+import java.util.List;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-13 17:50
+ * @Version: todo
+ */
+@Getter
+@Setter
+public class TaxPipelineBusinessExtCO {
+
+    @NotNull(groups = {Valid.Update.class})
+    private Long id;
+    /**
+     * 业务ID
+     */
+    @NotNull(groups = {Valid.Create.class, Valid.Update.class})
+    private Long taxPipelineBusinessId;
+
+    /**
+     * 扩展名字
+     */
+    @NotEmpty(groups = {Valid.Create.class})
+    private String extName;
+
+    /**
+     * 扩展编码
+     */
+    @NotEmpty(groups = {Valid.Create.class})
+    private String extCode;
+
+    /**
+     * 扩展可选数据
+     */
+    @NotEmpty(groups = {Valid.Create.class, Valid.Update.class})
+    private List<String> extDatas;
+}
+package com.diligrp.tax.storage.model.co;
+
+import jakarta.validation.constraints.NotEmpty;
+import jakarta.validation.constraints.NotNull;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2025-11-13 17:50
+ * @Version: todo
+ */
+@Getter
+@Setter
+public class TaxPipelineBusinessExtDefaultDataCO {
+
+    /**
+     * id
+     */
+    @NotNull
+    private Long id;
+    /**
+     * 业务ID
+     */
+    @NotNull
+    private Long taxPipelineBusinessId;
+
+    /**
+     * 扩展默认数据
+     */
+    @NotEmpty
+    private String extDefaultData;
+}
 package com.diligrp.tax.storage.model.vo;
  
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
  
 import java.time.LocalDateTime;
  
-@Data
+@Getter
+@Setter
 public class TaxPipelineBusinessConfigVO {
     /**
      *
+package com.diligrp.tax.storage.model.vo;
+
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * 账套业务配置
+ *
+ * @TableName tax_pipeline_business_ext
+ */
+@Getter
+@Setter
+public class TaxPipelineBusinessExtVO {
+    /**
+     *
+     */
+    private Long id;
+
+    /**
+     * 业务ID
+     */
+    private Long taxPipelineBusinessId;
+
+    /**
+     * 扩展名字
+     */
+    private String extName;
+
+    /**
+     * 扩展编码
+     */
+    private String extCode;
+
+    /**
+     * 扩展默认数据
+     */
+    private String extDefaultData;
+}
 package com.diligrp.tax.storage.model.vo;
  
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
  
 import java.time.LocalDateTime;
 import java.util.List;
@@ -10,7 +11,8 @@ import java.util.List;
  *
  * @TableName tax_pipeline_business
  */
-@Data
+@Getter
+@Setter
 public class TaxPipelineBusinessVO {
     /**
      *
+package com.diligrp.tax.storage.repo;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.diligrp.tax.storage.domain.TaxPipelineBusinessExtData;
+import org.springframework.stereotype.Repository;
+
+/**
+ * @author dili
+ * @description 针对表【tax_pipeline_business_ext(账套业务配置)】的数据库操作Mapper
+ * @createDate 2025-11-13 17:38:05
+ * @Entity com.diligrp.tax.storage.domain.TaxPipelineBusinessExt
+ */
+@Repository
+public interface TaxPipelineBusinessExtDataRepository extends BaseMapper<TaxPipelineBusinessExtData> {
+
+}
+
+
+
+
+package com.diligrp.tax.storage.repo;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.diligrp.tax.storage.domain.TaxPipelineBusinessExt;
+import org.springframework.stereotype.Repository;
+
+/**
+ * @author dili
+ * @description 针对表【tax_pipeline_business_ext(账套业务配置)】的数据库操作Mapper
+ * @createDate 2025-11-13 17:38:05
+ * @Entity com.diligrp.tax.storage.domain.TaxPipelineBusinessExt
+ */
+@Repository
+public interface TaxPipelineBusinessExtRepository extends BaseMapper<TaxPipelineBusinessExt> {
+
+}
+
+
+
+
@@ -3,21 +3,32 @@ 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.exception.TaxAgentServiceException;
 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.model.vo.TaxPipelineBusinessConfigVO;
+import com.diligrp.tax.storage.model.vo.TaxPipelineBusinessExtVO;
 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 jakarta.annotation.Resource;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
  
 import java.util.List;
+import java.util.Optional;
  
 /**
  * @Author: zhangmeiyang
@@ -33,6 +44,12 @@ public class TaxPipelineBusinessConfigService {
     @Resource
     private TaxPipelineBusinessRepository taxPipelineBusinessRepository;
  
+    @Resource
+    private TaxPipelineBusinessExtRepository taxPipelineBusinessExtRepository;
+
+    @Resource
+    private TaxPipelineBusinessExtDataRepository taxPipelineBusinessExtDataRepository;
+
     /**
      * 保存业务类型
      *
@@ -40,6 +57,12 @@ public class TaxPipelineBusinessConfigService {
      */
     @Transactional
     public void saveBusiness(TaxPipelineBusinessCO co) {
+        LambdaQueryWrapper<TaxPipelineBusiness> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineBusiness::getPipelineId, co.getPipelineId());
+        queryWrapper.eq(TaxPipelineBusiness::getBusinessCode, co.getBusinessCode());
+        Optional.ofNullable(taxPipelineBusinessRepository.selectOne(queryWrapper)).ifPresent(taxPipelineBusiness -> {
+            throw new TaxAgentServiceException(TaxSystemType.ABNORMAL_PARAMETERS, "业务编码重复");
+        });
         taxPipelineBusinessRepository.insert(JsonUtils.convertValue(co, TaxPipelineBusiness.class));
     }
  
@@ -50,6 +73,12 @@ public class TaxPipelineBusinessConfigService {
      */
     @Transactional
     public void updateBusiness(TaxPipelineBusinessCO co) {
+        LambdaQueryWrapper<TaxPipelineBusiness> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineBusiness::getPipelineId, co.getPipelineId());
+        queryWrapper.eq(TaxPipelineBusiness::getBusinessCode, co.getBusinessCode());
+        Optional.ofNullable(taxPipelineBusinessRepository.selectOne(queryWrapper)).ifPresent(taxPipelineBusiness -> {
+            throw new TaxAgentServiceException(TaxSystemType.ABNORMAL_PARAMETERS, "业务编码重复");
+        });
         taxPipelineBusinessRepository.updateById(JsonUtils.convertValue(co, TaxPipelineBusiness.class));
     }
  
@@ -104,4 +133,132 @@ public class TaxPipelineBusinessConfigService {
             taxPipelineBusinessConfigRepository.insert(save);
         });
     }
+
+    /**
+     * 保存业务文档扩展
+     *
+     * @param co 公司
+     */
+    @Transactional
+    public void saveBusinessExt(TaxPipelineBusinessExtCO co) {
+        LambdaQueryWrapper<TaxPipelineBusinessExt> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineBusinessExt::getTaxPipelineBusinessId, co.getTaxPipelineBusinessId());
+        queryWrapper.eq(TaxPipelineBusinessExt::getExtCode, co.getExtCode());
+        TaxPipelineBusinessExt taxPipelineBusinessExt1 = taxPipelineBusinessExtRepository.selectOne(queryWrapper);
+        Optional.ofNullable(taxPipelineBusinessExt1).ifPresent(taxPipelineBusinessExt -> {
+            throw new TaxAgentServiceException(TaxSystemType.ABNORMAL_PARAMETERS, "业务扩展编码重复");
+        });
+        TaxPipelineBusinessExt taxPipelineBusinessExt = JsonUtils.convertValue(co, TaxPipelineBusinessExt.class);
+        taxPipelineBusinessExtRepository.insert(taxPipelineBusinessExt);
+        Optional.ofNullable(co.getExtDatas()).ifPresent(extDatas -> extDatas.forEach(e -> {
+            var extData = new TaxPipelineBusinessExtData();
+            extData.setTaxPipelineBusinessExtId(taxPipelineBusinessExt.getId());
+            extData.setExtData(e);
+            taxPipelineBusinessExtDataRepository.insert(extData);
+        }));
+    }
+
+    /**
+     * 更新业务扩展
+     *
+     * @param co 公司
+     */
+    @Transactional
+    public void updateBusinessExt(TaxPipelineBusinessExtCO co) {
+        LambdaQueryWrapper<TaxPipelineBusinessExt> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineBusinessExt::getTaxPipelineBusinessId, co.getTaxPipelineBusinessId());
+        queryWrapper.eq(TaxPipelineBusinessExt::getId, co.getId());
+        TaxPipelineBusinessExt taxPipelineBusinessExt = taxPipelineBusinessExtRepository.selectOne(queryWrapper);
+        Optional.ofNullable(taxPipelineBusinessExt).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.MISSING_BUSINESS_INFORMATION, "业务扩展信息不存在"));
+        Optional.ofNullable(co.getExtName()).ifPresent(taxPipelineBusinessExt::setExtName);
+        Optional.ofNullable(co.getExtCode()).ifPresent(taxPipelineBusinessExt::setExtCode);
+        taxPipelineBusinessExtRepository.updateById(taxPipelineBusinessExt);
+    }
+
+    /**
+     * 设置默认业务扩展数据
+     *
+     * @param co 公司
+     */
+    @Transactional
+    public void setDefaultBusinessExtData(TaxPipelineBusinessExtDefaultDataCO co) {
+        LambdaQueryWrapper<TaxPipelineBusinessExt> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineBusinessExt::getTaxPipelineBusinessId, co.getTaxPipelineBusinessId());
+        queryWrapper.eq(TaxPipelineBusinessExt::getId, co.getId());
+        TaxPipelineBusinessExt taxPipelineBusinessExt = taxPipelineBusinessExtRepository.selectOne(queryWrapper);
+        Optional.ofNullable(taxPipelineBusinessExt).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.MISSING_BUSINESS_INFORMATION, "业务扩展信息不存在"));
+        taxPipelineBusinessExt.setExtDefaultData(co.getExtDefaultData());
+        taxPipelineBusinessExtRepository.updateById(taxPipelineBusinessExt);
+    }
+
+    /**
+     * 删除业务扩展
+     *
+     * @param co 公司
+     */
+    @Transactional
+    public void deleteBusinessExt(TaxPipelineBusinessExtCO co) {
+        LambdaQueryWrapper<TaxPipelineBusinessExt> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineBusinessExt::getTaxPipelineBusinessId, co.getTaxPipelineBusinessId());
+        queryWrapper.eq(TaxPipelineBusinessExt::getId, co.getId());
+        taxPipelineBusinessExtRepository.delete(queryWrapper);
+        LambdaQueryWrapper<TaxPipelineBusinessExtData> extDataQueryWrapper = new LambdaQueryWrapper<>();
+        extDataQueryWrapper.eq(TaxPipelineBusinessExtData::getTaxPipelineBusinessExtId, co.getId());
+        taxPipelineBusinessExtDataRepository.delete(extDataQueryWrapper);
+    }
+
+    /**
+     * 刷新业务扩展数据
+     *
+     * @param co 公司
+     */
+    @Transactional
+    public void refreshBusinessExtData(TaxPipelineBusinessExtCO co) {
+        LambdaQueryWrapper<TaxPipelineBusinessExt> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineBusinessExt::getTaxPipelineBusinessId, co.getTaxPipelineBusinessId());
+        queryWrapper.eq(TaxPipelineBusinessExt::getId, co.getId());
+        TaxPipelineBusinessExt taxPipelineBusinessExt = taxPipelineBusinessExtRepository.selectOne(queryWrapper);
+        Optional.ofNullable(taxPipelineBusinessExt).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.MISSING_BUSINESS_INFORMATION, "业务扩展信息不存在"));
+        LambdaQueryWrapper<TaxPipelineBusinessExtData> extDataQueryWrapper = new LambdaQueryWrapper<>();
+        extDataQueryWrapper.eq(TaxPipelineBusinessExtData::getTaxPipelineBusinessExtId, co.getId());
+        taxPipelineBusinessExtDataRepository.delete(extDataQueryWrapper);
+        Optional.ofNullable(co.getExtDatas()).ifPresent(extDatas -> extDatas.forEach(e -> {
+            var extData = new TaxPipelineBusinessExtData();
+            extData.setTaxPipelineBusinessExtId(co.getId());
+            extData.setExtData(e);
+            taxPipelineBusinessExtDataRepository.insert(extData);
+        }));
+    }
+
+    /**
+     * 按管道 ID 和业务代码获取
+     *
+     * @param pipelineId   管道 ID
+     * @param businessCode 业务代码
+     * @return {@link PipelineBusinessResponse }
+     */
+    public PipelineBusinessResponse getByPipelineIdAndBusinessCode(Long pipelineId, String businessCode) {
+        LambdaQueryWrapper<TaxPipelineBusiness> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipelineBusiness::getPipelineId, pipelineId);
+        queryWrapper.eq(TaxPipelineBusiness::getBusinessCode, businessCode);
+        TaxPipelineBusiness taxPipelineBusiness = taxPipelineBusinessRepository.selectOne(queryWrapper);
+        // 查询业务信息
+        Optional.ofNullable(taxPipelineBusiness).orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.MISSING_BUSINESS_INFORMATION, "业务信息不存在"));
+        LambdaQueryWrapper<TaxPipelineBusinessConfig> queryWrapper1 = new LambdaQueryWrapper<>();
+        queryWrapper1.eq(TaxPipelineBusinessConfig::getTaxPipelineBusinessId, taxPipelineBusiness.getId());
+        List<TaxPipelineBusinessConfig> taxPipelineBusinessConfigs = taxPipelineBusinessConfigRepository.selectList(queryWrapper1);
+        // 获取业务配置单据信息
+        LambdaQueryWrapper<TaxPipelineBusinessExt> queryWrapper2 = new LambdaQueryWrapper<>();
+        queryWrapper2.eq(TaxPipelineBusinessExt::getTaxPipelineBusinessId, taxPipelineBusiness.getId());
+        List<TaxPipelineBusinessExt> taxPipelineBusinessExts = taxPipelineBusinessExtRepository.selectList(queryWrapper2);
+        //获取业务扩展信息
+        PipelineBusinessResponse pipelineBusinessResponse = new PipelineBusinessResponse();
+        pipelineBusinessResponse.setId(taxPipelineBusiness.getId());
+        pipelineBusinessResponse.setPipelineId(taxPipelineBusiness.getPipelineId());
+        pipelineBusinessResponse.setBusinessCode(taxPipelineBusiness.getBusinessCode());
+        pipelineBusinessResponse.setBusinessName(taxPipelineBusiness.getBusinessName());
+        pipelineBusinessResponse.setConfigs(taxPipelineBusinessConfigs.stream().map(TaxPipelineBusinessConfig::getDocumentType).toList());
+        pipelineBusinessResponse.setBusinessExt(taxPipelineBusinessExts.stream().map(item -> JsonUtils.convertValue(item, TaxPipelineBusinessExtVO.class)).toList());
+        return pipelineBusinessResponse;
+    }
 }
@@ -3,6 +3,7 @@ package com.diligrp.tax.storage.service;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.diligrp.tax.central.exception.TaxAgentServiceException;
 import com.diligrp.tax.central.type.SystemType;
+import com.diligrp.tax.central.type.TaxSystemType;
 import com.diligrp.tax.central.utils.JsonUtils;
 import com.diligrp.tax.storage.domain.TaxPipeline;
 import com.diligrp.tax.storage.model.co.TaxPipelineCO;
@@ -11,6 +12,7 @@ import com.diligrp.tax.storage.model.vo.TaxTenantVO;
 import com.diligrp.tax.storage.repo.TaxPipelineRepository;
 import com.diligrp.tax.storage.type.StateType;
 import jakarta.annotation.Resource;
+import jakarta.validation.constraints.NotEmpty;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
  
@@ -40,6 +42,13 @@ public class TaxPipelineService {
     @Transactional
     public void save(TaxPipelineCO taxPipelineCO) {
         TaxTenantVO tenant = taxTenantService.getTenant(taxPipelineCO.getGroup(), taxPipelineCO.getEntity());
+        LambdaQueryWrapper<TaxPipeline> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipeline::getTenantId, tenant.getId());
+        queryWrapper.eq(TaxPipeline::getCode, taxPipelineCO.getCode());
+        TaxPipeline taxPipeline1 = taxPipelineRepository.selectOne(queryWrapper);
+        Optional.ofNullable(taxPipeline1).ifPresent(taxPipeline -> {
+            throw new TaxAgentServiceException(TaxSystemType.ABNORMAL_PARAMETERS,"当前账套编码已存在");
+        });
         taxPipelineCO.setTenantId(tenant.getId());
         SystemType.validateSystemCode(taxPipelineCO.getSystemCode());
         TaxPipeline taxPipeline = JsonUtils.convertValue(taxPipelineCO, TaxPipeline.class);
@@ -48,7 +57,11 @@ public class TaxPipelineService {
     }
  
  
-
+    /**
+     * 更新
+     *
+     * @param taxPipelineCO 税务管道公司
+     */
     @Transactional
     public void update(TaxPipelineCO taxPipelineCO) {
         SystemType.validateSystemCode(taxPipelineCO.getSystemCode());
@@ -93,4 +106,19 @@ public class TaxPipelineService {
         taxPipeline.setState(stateType.value);
         taxPipelineRepository.updateById(taxPipeline);
     }
+
+    /**
+     * 按租户 ID 和代码获取
+     *
+     * @param id           id
+     * @param pipelineCode 管道代码
+     * @return {@link TaxPipelineVO }
+     */
+    public TaxPipelineVO getByTenantIdAndCode(Long id, @NotEmpty String pipelineCode) {
+        LambdaQueryWrapper<TaxPipeline> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaxPipeline::getTenantId, id);
+        queryWrapper.eq(TaxPipeline::getCode, pipelineCode);
+        TaxPipeline taxPipeline = taxPipelineRepository.selectOne(queryWrapper);
+        return JsonUtils.convertValue(taxPipeline, TaxPipelineVO.class);
+    }
 }