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

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

BREAKING CHANGE: 无

Closes 无

[skip ci]

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

@@ -3,8 +3,8 @@ 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 com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import org.apache.commons.lang3.StringUtils;
+import pps.core.base.entity.BaseDieselGeneratorEnt;
 import pps.core.base.entity.BasePowerLineWellheadEnt;
 import pps.core.base.entity.BaseWellheadEnt;
 import pps.core.base.mapper.BasePowerLineWellheadMapper;
@@ -61,9 +61,7 @@ public class BaseWellheadService extends BaseService {
     public XServiceResult updateBaseWellhead(XContext context, UpdateBaseWellheadInput input) {
         return XTransactionHelper.begin(context, () -> {
             BaseWellheadMapper mapper = context.getBean(BaseWellheadMapper.class);
-            BaseWellheadEnt entity = mapper.selectOne(new LambdaUpdateWrapper<BaseWellheadEnt>()
-                    .eq(BaseModel::getId, input.getId())
-            );
+            BaseWellheadEnt entity = this.selectOneByWellheadId(input.getId(), mapper);
             if (Objects.isNull(entity)) {
                 return XServiceResult.error(context, XError.NotFound);
             }
@@ -85,14 +83,12 @@ public class BaseWellheadService extends BaseService {
         }
         return XTransactionHelper.begin(context, () -> {
             BaseWellheadMapper mapper = context.getBean(BaseWellheadMapper.class);
-            BaseWellheadEnt entity = mapper.selectOne(new LambdaUpdateWrapper<BaseWellheadEnt>()
-                    .eq(BaseModel::getId, wellheadId)
-            );
+            BaseWellheadEnt entity = this.selectOneByWellheadId(wellheadId, mapper);
             if (Objects.isNull(entity)) {
                 return XServiceResult.error(context, XError.NotFound);
             }
             entity = new BaseWellheadEnt();
-            entity.setId(input.getId());
+            entity.setId(wellheadId);
             entity.setIsDeleted(BusinessConstant.ZERO);
             PpsUserSession session = context.getSession(PpsUserSession.class);
             BaseUtils.setBaseModelDefault(entity, session);
@@ -106,16 +102,11 @@ public class BaseWellheadService extends BaseService {
     @XApiGet
     public XSingleResult<GetBaseWellheadOutput> getBaseWellhead(XContext context, GetBaseWellheadInput input) {
         BaseWellheadMapper mapper = context.getBean(BaseWellheadMapper.class);
-        QueryWrapper<BaseWellheadEnt> queryWrapper = new QueryWrapper<>();
-        queryWrapper.lambda()
-                .eq(BaseWellheadEnt::getId, input.getId())
-                .eq(BaseWellheadEnt::getIsDeleted, BusinessConstant.ONE);
-        BaseWellheadEnt entity = mapper.selectOne(queryWrapper);
-        if (entity == null) {
+        BaseWellheadEnt entity = this.selectOneByWellheadId(input.getId(), mapper);
+        if (Objects.isNull(entity)) {
             return XSingleResult.error(context, XError.NotFound);
         }
-        GetBaseWellheadOutput output = new GetBaseWellheadOutput();
-        XCopyUtils.copyObject(entity, output);
+        GetBaseWellheadOutput output = XCopyUtils.copyNewObject(entity, GetBaseWellheadOutput.class);
         return XSingleResult.success(output);
     }
 
@@ -152,4 +143,17 @@ public class BaseWellheadService extends BaseService {
         );
         return count > 0;
     }
+
+    /**
+     * 通过井口ID查询井口信息
+     *
+     * @param wellheadId 井口id
+     * @param mapper     映射器
+     * @return {@link BaseDieselGeneratorEnt}
+     */
+    private BaseWellheadEnt selectOneByWellheadId(String wellheadId, BaseWellheadMapper mapper) {
+        return mapper.selectOne(new LambdaQueryWrapper<BaseWellheadEnt>()
+                .eq(BaseModel::getId, wellheadId)
+        );
+    }
 }