diff --git a/pqs-process/process-api/src/main/java/com/njcn/process/enums/ProcessResponseEnum.java b/pqs-process/process-api/src/main/java/com/njcn/process/enums/ProcessResponseEnum.java index 67a92c075..f626c224b 100644 --- a/pqs-process/process-api/src/main/java/com/njcn/process/enums/ProcessResponseEnum.java +++ b/pqs-process/process-api/src/main/java/com/njcn/process/enums/ProcessResponseEnum.java @@ -20,7 +20,7 @@ public enum ProcessResponseEnum { PROCESS_ERROR("A00553","当前流程未审核通过,操作失败!"), QUERY_IS_EMPTY("A00554","当前未查询到当前策略信息,无法删除!"), ENABLED_CANNOT_BE_DELETED("A00555","策略为启用状态不能删除!"), - THERE_IS_ONLY_ONE_STRATEGY("A00556","自动策略或手动策略,通用策略只能有一条!"), + THERE_IS_ONLY_ONE_STRATEGY("A00556","各个策略等级,通用策略只能有一条!"), ; private final String code; diff --git a/pqs-process/process-api/src/main/java/com/njcn/process/pojo/param/StrategyParam.java b/pqs-process/process-api/src/main/java/com/njcn/process/pojo/param/StrategyParam.java index df6d12bc1..00bca8dad 100644 --- a/pqs-process/process-api/src/main/java/com/njcn/process/pojo/param/StrategyParam.java +++ b/pqs-process/process-api/src/main/java/com/njcn/process/pojo/param/StrategyParam.java @@ -116,6 +116,10 @@ public class StrategyParam { @NotNull(message = "策略选择不能为空") private Integer bigType; + @ApiModelProperty(value = "区分预警单还是告警单(0:预警单;1:告警单)") + @NotNull(message = "区分类别不能为空") + private Integer type; + @ApiModelProperty(value = "等级(0:一级;1:二级;2:三级)") @NotNull(message = "等级不能为空") private Integer grade; diff --git a/pqs-process/process-api/src/main/java/com/njcn/process/pojo/po/ThsWarnStrategy.java b/pqs-process/process-api/src/main/java/com/njcn/process/pojo/po/ThsWarnStrategy.java index ffbf689a7..16c38954c 100644 --- a/pqs-process/process-api/src/main/java/com/njcn/process/pojo/po/ThsWarnStrategy.java +++ b/pqs-process/process-api/src/main/java/com/njcn/process/pojo/po/ThsWarnStrategy.java @@ -53,7 +53,6 @@ public class ThsWarnStrategy extends BaseEntity implements Serializable { @ApiModelProperty(value = "0.删除 1.启用 2.关闭") @TableField("State") - @TableLogic(value = "1",delval = "0") private Integer state; @TableField("Create_By") diff --git a/pqs-process/process-boot/src/main/java/com/njcn/process/service/impl/ThsWarnStrategyServiceImpl.java b/pqs-process/process-boot/src/main/java/com/njcn/process/service/impl/ThsWarnStrategyServiceImpl.java index db170f806..714b04bf2 100644 --- a/pqs-process/process-boot/src/main/java/com/njcn/process/service/impl/ThsWarnStrategyServiceImpl.java +++ b/pqs-process/process-boot/src/main/java/com/njcn/process/service/impl/ThsWarnStrategyServiceImpl.java @@ -79,16 +79,19 @@ public class ThsWarnStrategyServiceImpl extends ServiceImpl() + List one = this.list(new LambdaQueryWrapper() + .ne(ThsWarnStrategy::getState, DataStateEnum.DELETED.getCode()) .eq(ThsWarnStrategy::getName, param.getName()) - .or(wrapper -> + .eq(ThsWarnStrategy::getType,param.getType()) + .or(param.getBigType()==0,wrapper -> wrapper.eq(ThsWarnStrategy::getGrade, param.getGrade()) .eq(ThsWarnStrategy::getBigType, 0) + .eq(ThsWarnStrategy::getType,param.getType()) + .ne(ThsWarnStrategy::getState, DataStateEnum.DELETED.getCode()) ) ); - - if (ObjectUtil.isNotNull(one)) { - if(one.getName().equals(param.getName())){ + if (CollectionUtil.isNotEmpty(one)) { + if(one.size()>1||one.get(0).getName().equals(param.getName())){ throw new BusinessException(PmsDeviceResponseEnum.MODEL_NAME_REPEAT); } throw new BusinessException(ProcessResponseEnum.THERE_IS_ONLY_ONE_STRATEGY); @@ -127,19 +130,25 @@ public class ThsWarnStrategyServiceImpl extends ServiceImpl() + List one = this.list(new LambdaQueryWrapper() + .ne(ThsWarnStrategy::getState, DataStateEnum.DELETED.getCode()) .ne(ThsWarnStrategy::getId, param.getId()) .and(wrapper -> wrapper.eq(ThsWarnStrategy::getName, param.getName()) + .eq(ThsWarnStrategy::getType,param.getType()) ) - .or(wrapper -> + .or(param.getBigType()==0,wrapper -> wrapper.eq( ThsWarnStrategy::getGrade, param.getGrade()) .eq(ThsWarnStrategy::getBigType, 0) + .eq(ThsWarnStrategy::getType,param.getType()) + .ne(ThsWarnStrategy::getId, param.getId()) + .ne(ThsWarnStrategy::getState, DataStateEnum.DELETED.getCode()) + ) ); - if (ObjectUtil.isNotNull(one)) { - if(one.getName().equals(param.getName())){ + if (CollectionUtil.isNotEmpty(one)) { + if(one.size()>1||one.get(0).getName().equals(param.getName())){ throw new BusinessException(PmsDeviceResponseEnum.MODEL_NAME_REPEAT); } throw new BusinessException(ProcessResponseEnum.THERE_IS_ONLY_ONE_STRATEGY); @@ -235,8 +244,11 @@ public class ThsWarnStrategyServiceImpl extends ServiceImpl