feat(能源管理系统): 基础信息配置

1.优化基础信息配置-柴发设备模块新增,修改,删除,查询接口,优化代码结构增加事务处理;
2.优化基础信息配置-储能设备模块新增,修改,删除,查询接口,优化代码结构增加事务处理;
3.优化基础信息配置-井口设备模块新增,修改,删除,查询接口,优化代码结构增加事务处理;
4.优化基础信息配置-光伏电站模块新增,修改,删除,查询接口,优化代码结构增加事务处理;

BREAKING CHANGE: 无

Closes 无

[skip ci]

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

@@ -5,6 +5,7 @@ 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.BasePowerLineEnt;
 import pps.core.base.entity.BasePowerLinePlantEnt;
 import pps.core.base.mapper.BasePhotovoltaicPlantMapper;
 import pps.core.base.mapper.BasePowerLinePlantMapper;
@@ -31,6 +32,7 @@ import xstartup.feature.api.annotation.XApiAnonymous;
 import xstartup.feature.api.annotation.XApiGet;
 import xstartup.feature.api.annotation.XApiPost;
 import xstartup.feature.mybatis.helper.XMapperHelper;
+import xstartup.helper.XTransactionHelper;
 
 import java.util.List;
 import java.util.Objects;
@@ -49,33 +51,32 @@ public class BasePhotovoltaicPlantService extends BaseService {
     @XApiAnonymous
     @XApiPost
     public XServiceResult createBasePhotovoltaicPlant(XContext context, CreateBasePhotovoltaicPlantInput input) {
-        BasePhotovoltaicPlantMapper mapper = context.getBean(BasePhotovoltaicPlantMapper.class);
-        BasePhotovoltaicPlantEnt entity = new BasePhotovoltaicPlantEnt();
-        XCopyUtils.copyObject(input, entity);
-        PpsUserSession session = context.getSession(PpsUserSession.class);
-        BaseUtils.setBaseModelDefault(entity, session);
-        mapper.insert(entity);
-        return XServiceResult.OK;
+        return XTransactionHelper.begin(context, () -> {
+            BasePhotovoltaicPlantMapper mapper = context.getBean(BasePhotovoltaicPlantMapper.class);
+            BasePhotovoltaicPlantEnt entity = XCopyUtils.copyNewObject(input, BasePhotovoltaicPlantEnt.class);
+            PpsUserSession session = context.getSession(PpsUserSession.class);
+            BaseUtils.setBaseModelDefault(entity, session);
+            mapper.insert(entity);
+            return XServiceResult.OK;
+        });
     }
 
     @XText("更新")
     @XApiAnonymous
     @XApiPost
     public XServiceResult updateBasePhotovoltaicPlant(XContext context, UpdateBasePhotovoltaicPlantInput input) {
-        BasePhotovoltaicPlantMapper mapper = context.getBean(BasePhotovoltaicPlantMapper.class);
-        QueryWrapper<BasePhotovoltaicPlantEnt> queryWrapper = new QueryWrapper<>();
-        queryWrapper.lambda()
-                .eq(BasePhotovoltaicPlantEnt::getId, input.getId())
-                .eq(BasePhotovoltaicPlantEnt::getIsDeleted, BusinessConstant.ONE);
-        BasePhotovoltaicPlantEnt entity = mapper.selectOne(queryWrapper);
-        if (entity == null) {
-            return XServiceResult.error(context, XError.NotFound);
-        }
-        XCopyUtils.copyObject(input, entity);
-        PpsUserSession session = context.getSession(PpsUserSession.class);
-        BaseUtils.setBaseModelDefault(entity, session);
-        mapper.updateById(entity);
-        return XServiceResult.OK;
+        return XTransactionHelper.begin(context, () -> {
+            BasePhotovoltaicPlantMapper mapper = context.getBean(BasePhotovoltaicPlantMapper.class);
+            BasePhotovoltaicPlantEnt entity = this.selectOneByPlantId(input.getId(), mapper);
+            if (Objects.isNull(entity)) {
+                return XServiceResult.error(context, XError.NotFound);
+            }
+            XCopyUtils.copyObject(input, entity);
+            PpsUserSession session = context.getSession(PpsUserSession.class);
+            BaseUtils.setBaseModelDefault(entity, session);
+            mapper.updateById(entity);
+            return XServiceResult.OK;
+        });
     }
 
     @XText("删除")
@@ -86,22 +87,20 @@ public class BasePhotovoltaicPlantService extends BaseService {
         if (this.checkPhotovoltaicIsReference(context, plantId)) {
             return XServiceResult.error(992, "当前光伏电站已被引用");
         }
-        BasePhotovoltaicPlantMapper mapper = context.getBean(BasePhotovoltaicPlantMapper.class);
-        QueryWrapper<BasePhotovoltaicPlantEnt> queryWrapper = new QueryWrapper<>();
-        queryWrapper.lambda()
-                .eq(BasePhotovoltaicPlantEnt::getId, plantId)
-                .eq(BasePhotovoltaicPlantEnt::getIsDeleted, BusinessConstant.ONE);
-        BasePhotovoltaicPlantEnt entity = mapper.selectOne(queryWrapper);
-        if (Objects.isNull(entity)) {
-            return XServiceResult.error(context, XError.NotFound);
-        }
-        entity = new BasePhotovoltaicPlantEnt();
-        entity.setId(input.getId());
-        entity.setIsDeleted(BusinessConstant.ZERO);
-        PpsUserSession session = context.getSession(PpsUserSession.class);
-        BaseUtils.setBaseModelDefault(entity, session);
-        mapper.updateById(entity);
-        return XServiceResult.OK;
+        return XTransactionHelper.begin(context, () -> {
+            BasePhotovoltaicPlantMapper mapper = context.getBean(BasePhotovoltaicPlantMapper.class);
+            BasePhotovoltaicPlantEnt entity = this.selectOneByPlantId(plantId, mapper);
+            if (Objects.isNull(entity)) {
+                return XServiceResult.error(context, XError.NotFound);
+            }
+            entity = new BasePhotovoltaicPlantEnt();
+            entity.setId(plantId);
+            entity.setIsDeleted(BusinessConstant.ZERO);
+            PpsUserSession session = context.getSession(PpsUserSession.class);
+            BaseUtils.setBaseModelDefault(entity, session);
+            mapper.updateById(entity);
+            return XServiceResult.OK;
+        });
     }
 
     @XText("根据id获取详情")
@@ -109,23 +108,19 @@ public class BasePhotovoltaicPlantService extends BaseService {
     @XApiGet
     public XSingleResult<GetBasePhotovoltaicPlantOutput> getBasePhotovoltaicPlant(XContext context, GetBasePhotovoltaicPlantInput input) {
         BasePhotovoltaicPlantMapper mapper = context.getBean(BasePhotovoltaicPlantMapper.class);
-        QueryWrapper<BasePhotovoltaicPlantEnt> queryWrapper = new QueryWrapper<>();
-        queryWrapper.lambda()
-                .eq(BasePhotovoltaicPlantEnt::getId, input.getId())
-                .eq(BasePhotovoltaicPlantEnt::getIsDeleted, BusinessConstant.ONE);
-        BasePhotovoltaicPlantEnt entity = mapper.selectOne(queryWrapper);
-        if (entity == null) {
+        BasePhotovoltaicPlantEnt entity = this.selectOneByPlantId(input.getId(), mapper);
+        if (Objects.isNull(entity)) {
             return XSingleResult.error(context, XError.NotFound);
         }
-        GetBasePhotovoltaicPlantOutput output = new GetBasePhotovoltaicPlantOutput();
-        XCopyUtils.copyObject(entity, output);
+        GetBasePhotovoltaicPlantOutput output = XCopyUtils.copyNewObject(entity, GetBasePhotovoltaicPlantOutput.class);
         //根据组织机构的路径获取
         SysOrganizationViewMapper organizationViewMapper = context.getBean(SysOrganizationViewMapper.class);
         SysOrganizationView organizationView = new SysOrganizationView();
         organizationView.setId(entity.getOuId());
         organizationView = organizationViewMapper.selectOrgProvince(organizationView);
-        if (null != organizationView)
+        if (Objects.nonNull(organizationView)) {
             output.setProvince(organizationView.getProvinceName());
+        }
         return XSingleResult.success(output);
     }
 
@@ -206,4 +201,16 @@ public class BasePhotovoltaicPlantService extends BaseService {
         );
         return count > 0;
     }
+
+    /**
+     * 通过电站ID获取电站信息
+     *
+     * @param plantId 电站id
+     * @param mapper  映射器
+     * @return {@link BasePowerLineEnt}
+     */
+    private BasePhotovoltaicPlantEnt selectOneByPlantId(String plantId, BasePhotovoltaicPlantMapper mapper) {
+        return mapper.selectOne(new LambdaQueryWrapper<BasePhotovoltaicPlantEnt>()
+                .eq(BaseModel::getId, plantId));
+    }
 }