feat(能源管理系统): 间开制度管理

1.修改基础信息配置-井口配置模块删除接口,增加私有方法校验井口是否已被线路引用;

BREAKING CHANGE: 无

Closes 无

[skip ci]

C09-base/pps-core-base/src/main/java/pps/core/base/service/BasePhotovoltaicPlantService.java

@@ -2,12 +2,16 @@ package pps.core.base.service;
 
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import pps.core.base.entity.BasePhotovoltaicPlantEnt;
+import pps.core.base.entity.BasePowerLineWellheadEnt;
 import pps.core.base.mapper.BasePhotovoltaicPlantMapper;
+import pps.core.base.mapper.BasePowerLineWellheadMapper;
 import pps.core.base.service.data.base_photovoltaic_plant.*;
 import pps.core.common.constant.BusinessConstant;
 import pps.core.common.constant.UserConstant;
+import pps.core.common.entity.BaseModel;
 import pps.core.common.session.PpsUserSession;
 import pps.core.common.utils.BaseUtils;
 import pps.core.system.constant.SysOrganizationCode;
@@ -95,6 +99,24 @@ public class BasePhotovoltaicPlantService extends BaseService {
         return XServiceResult.OK;
     }
 
+    /*-----------------------------------private-----------------------------------*/
+
+    /**
+     * 检查井口是否被引用
+     *
+     * @param context    上下文
+     * @param wellheadId 井口ID
+     * @return boolean
+     */
+    private boolean checkWellheadIsReference(XContext context, String wellheadId) {
+        BasePowerLineWellheadMapper mapper = context.getBean(BasePowerLineWellheadMapper.class);
+        Long count = mapper.selectCount(new LambdaQueryWrapper<BasePowerLineWellheadEnt>()
+                .eq(BasePowerLineWellheadEnt::getWellheadId, wellheadId)
+                .eq(BaseModel::getIsDeleted, BusinessConstant.ONE)
+        );
+        return count > 0;
+    }
+
     @XText("根据id获取详情")
     @XApiAnonymous
     @XApiGet

C09-base/pps-core-base/src/main/java/pps/core/base/service/BasePriceStrategyService.java

@@ -310,6 +310,7 @@ public class BasePriceStrategyService {
         BasePowerLineMapper mapper = context.getBean(BasePowerLineMapper.class);
         Long count = mapper.selectCount(new LambdaQueryWrapper<BasePowerLineEnt>()
                 .eq(BasePowerLineEnt::getStrategyId, strategyId)
+                .eq(BaseModel::getIsDeleted, BusinessConstant.ONE)
         );
         return count > 0;
     }

C09-base/pps-core-base/src/main/java/pps/core/base/service/BaseWellheadService.java

 package pps.core.base.service;
 
 import cn.hutool.core.collection.CollUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import pps.core.base.entity.BasePowerLineWellheadEnt;
 import pps.core.base.entity.BaseWellheadEnt;
+import pps.core.base.mapper.BasePowerLineWellheadMapper;
 import pps.core.base.mapper.BaseWellheadMapper;
 import pps.core.base.service.data.base_wellhead.*;
 import pps.core.common.constant.BusinessConstant;
+import pps.core.common.entity.BaseModel;
 import pps.core.common.session.PpsUserSession;
 import pps.core.common.utils.BaseUtils;
 import xstartup.annotation.XService;
@@ -22,6 +26,7 @@ import xstartup.feature.api.annotation.XApiPost;
 import xstartup.feature.mybatis.helper.XMapperHelper;
 
 import java.util.List;
+import java.util.Objects;
 
 
 /**
@@ -69,10 +74,14 @@ public class BaseWellheadService extends BaseService {
     @XApiPost
     public XServiceResult deleteBaseWellhead(XContext context, DeleteBaseWellheadInput input) {
         BaseWellheadMapper mapper = context.getBean(BaseWellheadMapper.class);
+        String wellheadId = input.getId();
+        if (this.checkWellheadIsReference(context, wellheadId)) {
+            return XServiceResult.error(992, "当前井口已被引用");
+        }
         QueryWrapper<BaseWellheadEnt> queryWrapper = new QueryWrapper<>();
-        queryWrapper.lambda().eq(BaseWellheadEnt::getId, input.getId());
+        queryWrapper.lambda().eq(BaseWellheadEnt::getId, wellheadId);
         BaseWellheadEnt entity = mapper.selectOne(queryWrapper);
-        if (entity == null) {
+        if (Objects.isNull(entity)) {
             return XServiceResult.error(context, XError.NotFound);
         }
         entity = new BaseWellheadEnt();
@@ -117,4 +126,22 @@ public class BaseWellheadService extends BaseService {
                 .orderByDesc(BaseWellheadEnt::getModifyTime);
         return XMapperHelper.query(mapper, input, queryWrapper, QueryBaseWellheadOutput.class);
     }
+
+    /*-----------------------------------private-----------------------------------*/
+
+    /**
+     * 检查井口是否被引用
+     *
+     * @param context    上下文
+     * @param wellheadId 井口ID
+     * @return boolean
+     */
+    private boolean checkWellheadIsReference(XContext context, String wellheadId) {
+        BasePowerLineWellheadMapper mapper = context.getBean(BasePowerLineWellheadMapper.class);
+        Long count = mapper.selectCount(new LambdaQueryWrapper<BasePowerLineWellheadEnt>()
+                .eq(BasePowerLineWellheadEnt::getWellheadId, wellheadId)
+                .eq(BaseModel::getIsDeleted, BusinessConstant.ONE)
+        );
+        return count > 0;
+    }
 }