feat(tax): 添加账套状态验证功能

- 在PipelineDO中新增state字段用于存储账套状态 - 在StateType中添加of方法用于状态值转换 - 在TaxReceiveService中添加租户账套有效性验证逻辑 - 添加ACCOUNTS_IS_NOT_ENABLED错误类型定义 - 移除TenantService中的状态过滤条件以支持所有状态查询

feat(tax): 添加账套状态验证功能
- 在PipelineDO中新增state字段用于存储账套状态 - 在StateType中添加of方法用于状态值转换 - 在TaxReceiveService中添加租户账套有效性验证逻辑 - 添加ACCOUNTS_IS_NOT_ENABLED错误类型定义 - 移除TenantService中的状态过滤条件以支持所有状态查询
张楣扬
1 parent 0a44d560
Showing 5 changed files with 17 additions and 2 deletions
tax-boot/src/main/java/com/diligrp/tax/boot/service/TaxReceiveService.java
tax-central/src/main/java/com/diligrp/tax/central/model/PipelineDO.java
tax-central/src/main/java/com/diligrp/tax/central/type/TaxSystemType.java
tax-storage/src/main/java/com/diligrp/tax/storage/service/TenantService.java
tax-storage/src/main/java/com/diligrp/tax/storage/type/StateType.java
@@ -15,6 +15,7 @@ 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 com.diligrp.tax.storage.type.StateType;
 import jakarta.annotation.Resource;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -60,11 +61,15 @@ public class TaxReceiveService {
         ctx.setPipelineDO(pipelineDO);
         //获取租户id
         ctx.setTenantId(tenantService.getTenantId(ctx.getGroup(), ctx.getEntity()));
+        //验证租户账套是否有效
+        Optional.of(pipelineDO)
+                .filter(p -> StateType.of(p.getState()) == StateType.ENABLE)
+                .orElseThrow(() -> new TaxAgentServiceException(TaxSystemType.ACCOUNTS_IS_NOT_ENABLED));
     }
     @Transactional
     public void recordMapping(MessageContext messageContext) {
-        Optional<PipelineMappingDO> dbOptions = taxPipelineMappingService.findByPipelineIdAndDocumentTypeAndSystemDataIdAndPipelineDataId(messageContext.getPipelineDO().getTenantId(), messageContext.getPipelineDO().getId(), messageContext.getDocumentType(), messageContext.getSystemDataId(),messageContext.getPipelineDataId());
+        Optional<PipelineMappingDO> dbOptions = taxPipelineMappingService.findByPipelineIdAndDocumentTypeAndSystemDataIdAndPipelineDataId(messageContext.getPipelineDO().getTenantId(), messageContext.getPipelineDO().getId(), messageContext.getDocumentType(), messageContext.getSystemDataId(), messageContext.getPipelineDataId());
         dbOptions.ifPresentOrElse(
                 e -> {
                     PipelineMappingCreateDO create = new PipelineMappingCreateDO();
@@ -20,4 +20,5 @@ public class PipelineDO {
     private String name;
     private String code;
     private Map<String, Object> params;
+    private Integer state;
 }
@@ -20,6 +20,7 @@ public enum TaxSystemType {
     NO_MATCHING_SET_OF_ACCOUNTS_FOUND(5008, "未找到匹配账套"),
     NO_TENANT_INFORMATION_FOUND(5009, "未找到匹配账套"),
     PARAMETER_IS_NOT_PARSED_CORRECTLY(5010, "参数解析不正确"),
+    ACCOUNTS_IS_NOT_ENABLED(5011, "账套未启用"),
     ;
     public final int code;
     public final String message;
@@ -87,7 +87,6 @@ public class TenantService implements ITenantService {
         LambdaQueryWrapper<Pipeline> queryWrapper = new LambdaQueryWrapper<>();
         queryWrapper.eq(Pipeline::getCode, pipelineCode);
         queryWrapper.eq(Pipeline::getTenantId, tenantId);
-        queryWrapper.eq(Pipeline::getState, StateType.ENABLE.value);
         return Optional.ofNullable(pipelineRepository.selectOne(queryWrapper)).map(taxPipeline -> {
             PipelineDO pipelineDO = JsonUtils.convertValue(taxPipeline, PipelineDO.class);
             pipelineDO.setSystemTypeEnum(SystemType.from(taxPipeline.getSystemType()));
@@ -8,4 +8,13 @@ public enum StateType {
     StateType(int value) {
         this.value = value;
     }
+
+    public static StateType of(int value) {
+        for (StateType stateType : values()) {
+            if (stateType.value == value) {
+                return stateType;
+            }
+        }
+        throw new IllegalArgumentException("Invalid value: " + value);
+    }
 }