Commit ecdbc085 authored by ZWT's avatar ZWT

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

1.修改基础信息配置-井口配置模块删除接口,增加私有方法校验井口是否已被线路引用;
2.修改基础信息配置-光伏电站配置模块删除接口,增加私有方法校验光伏电站是否已被线路引用;
3.修改基础信息配置-储能设备配置模块删除接口,增加私有方法校验储能设备是否已被线路引用;
4.修改基础信息配置-柴发设备配置模块删除接口,增加私有方法校验柴发设备是否已被线路引用;
5.修改基础信息配置-市电峰谷模块新增/修改接口,优化市电峰谷关联信息批量新增逻辑;
6.修改基础信息配置-输电线路配置模块新增/修改接口,优化输电线路关联信息批量新增逻辑;

BREAKING CHANGE: 无

Closes 无

[skip ci]
parent 7defc717
package pps.core.base.mapper;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;
import pps.core.base.entity.BasePowerLineDieselView;
......@@ -22,4 +23,12 @@ public interface BasePowerLineDieselViewMapper {
* @return {@link List}<{@link BasePowerLineDieselView}>
*/
List<BasePowerLineDieselView> selectList(BasePowerLineDieselView record);
/**
* 批量新增
*
* @param list 列表
* @return int
*/
int batchInsertList(@Param(value = "list") List<BasePowerLineDieselView> list);
}
package pps.core.base.mapper;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;
import pps.core.base.entity.BasePowerLinePlantView;
......@@ -22,4 +23,12 @@ public interface BasePowerLinePlantViewMapper {
* @return {@link List}<{@link BasePowerLinePlantView}>
*/
List<BasePowerLinePlantView> selectList(BasePowerLinePlantView record);
/**
* 批量新增
*
* @param list 列表
* @return int
*/
int batchInsertList(@Param(value = "list") List<BasePowerLinePlantView> list);
}
package pps.core.base.mapper;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;
import pps.core.base.entity.BasePowerLineStorageView;
......@@ -22,4 +23,12 @@ public interface BasePowerLineStorageViewMapper {
* @return {@link List}<{@link BasePowerLineStorageView}>
*/
List<BasePowerLineStorageView> selectList(BasePowerLineStorageView record);
/**
* 批量新增
*
* @param list 列表
* @return int
*/
int batchInsertList(@Param(value = "list") List<BasePowerLineStorageView> list);
}
package pps.core.base.mapper;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;
import pps.core.base.entity.BasePowerLineWellheadView;
......@@ -30,4 +31,12 @@ public interface BasePowerLineWellheadViewMapper {
* @return {@link List}<{@link BasePowerLineWellheadView}>
*/
List<BasePowerLineWellheadView> selectWellheadListByParam(BasePowerLineWellheadView record);
/**
* 批量新增
*
* @param list 列表
* @return int
*/
int batchInsertList(@Param(value = "list") List<BasePowerLineWellheadView> list);
}
package pps.core.base.service;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.lang.UUID;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
......@@ -382,60 +383,68 @@ public class BasePowerLineService {
/**
* 保存线路关联信息
*
* @param context 上下文
* @param lineId 线路id
* @param ouId 组织id
* @param session 会话
* @param wellheadInputs 井口列表
* @param plantInputs 光伏列表
* @param storageInputs 储能列表
* @param dieselInputs 柴发列表
* @param ouId ou-id
* @param session 一场
* @param wellheadInputs 井口输入
* @param plantInputs 电厂投入
* @param storageInputs 存储输入
* @param dieselInputs 柴油机输入
*/
private void saveLineRelation(XContext context, String lineId, String ouId, PpsUserSession session,
List wellheadInputs, List plantInputs, List storageInputs, List dieselInputs) {
//todo 改批量新增
//新增井口配置
if (CollUtil.isNotEmpty(wellheadInputs)) {
BasePowerLineWellheadMapper wellheadMapper = context.getBean(BasePowerLineWellheadMapper.class);
List<BasePowerLineWellheadEnt> wellheads = XCopyUtils.copyNewList(wellheadInputs, BasePowerLineWellheadEnt.class);
for (BasePowerLineWellheadEnt wellhead : wellheads) {
BasePowerLineWellheadViewMapper wellheadMapper = context.getBean(BasePowerLineWellheadViewMapper.class);
List<BasePowerLineWellheadView> wellheads = new ArrayList<>(32);
for (BasePowerLineWellheadView wellhead : (List<BasePowerLineWellheadView>) XCopyUtils.copyNewList(wellheadInputs, BasePowerLineWellheadView.class)) {
wellhead.setLineId(lineId);
wellhead.setOuId(ouId);
BaseUtils.setBaseModelDefault(wellhead, session);
wellheadMapper.insert(wellhead);
wellhead.setId(UUID.randomUUID().toString());
wellheads.add(wellhead);
}
wellheadMapper.batchInsertList(wellheads);
}
//新增光伏配置
if (CollUtil.isNotEmpty(plantInputs)) {
BasePowerLinePlantMapper plantMapper = context.getBean(BasePowerLinePlantMapper.class);
List<BasePowerLinePlantEnt> plants = XCopyUtils.copyNewList(plantInputs, BasePowerLinePlantEnt.class);
for (BasePowerLinePlantEnt plant : plants) {
BasePowerLinePlantViewMapper plantMapper = context.getBean(BasePowerLinePlantViewMapper.class);
List<BasePowerLinePlantView> plants = new ArrayList<>(32);
for (BasePowerLinePlantView plant : (List<BasePowerLinePlantView>) XCopyUtils.copyNewList(plantInputs, BasePowerLinePlantView.class)) {
plant.setLineId(lineId);
plant.setOuId(ouId);
BaseUtils.setBaseModelDefault(plant, session);
plantMapper.insert(plant);
plant.setId(UUID.randomUUID().toString());
plants.add(plant);
}
plantMapper.batchInsertList(plants);
}
//新增储能配置
if (CollUtil.isNotEmpty(storageInputs)) {
BasePowerLineStorageMapper storageMapper = context.getBean(BasePowerLineStorageMapper.class);
List<BasePowerLineStorageEnt> storages = XCopyUtils.copyNewList(storageInputs, BasePowerLineStorageEnt.class);
for (BasePowerLineStorageEnt storage : storages) {
BasePowerLineStorageViewMapper storageMapper = context.getBean(BasePowerLineStorageViewMapper.class);
List<BasePowerLineStorageView> storages = new ArrayList<>(32);
for (BasePowerLineStorageView storage : (List<BasePowerLineStorageView>) XCopyUtils.copyNewList(storageInputs, BasePowerLineStorageView.class)) {
storage.setLineId(lineId);
storage.setOuId(ouId);
BaseUtils.setBaseModelDefault(storage, session);
storageMapper.insert(storage);
storage.setId(UUID.randomUUID().toString());
storages.add(storage);
}
storageMapper.batchInsertList(storages);
}
//新增柴发配置
if (CollUtil.isNotEmpty(dieselInputs)) {
BasePowerLineDieselMapper dieselMapper = context.getBean(BasePowerLineDieselMapper.class);
List<BasePowerLineDieselEnt> diesels = XCopyUtils.copyNewList(dieselInputs, BasePowerLineDieselEnt.class);
for (BasePowerLineDieselEnt diesel : diesels) {
BasePowerLineDieselViewMapper dieselMapper = context.getBean(BasePowerLineDieselViewMapper.class);
List<BasePowerLineDieselView> diesels = new ArrayList<>(32);
for (BasePowerLineDieselView diesel : (List<BasePowerLineDieselView>) XCopyUtils.copyNewList(dieselInputs, BasePowerLineDieselView.class)) {
diesel.setLineId(lineId);
diesel.setOuId(ouId);
BaseUtils.setBaseModelDefault(diesel, session);
dieselMapper.insert(diesel);
diesel.setId(UUID.randomUUID().toString());
diesels.add(diesel);
}
dieselMapper.batchInsertList(diesels);
}
}
}
......@@ -52,4 +52,24 @@
AND g.is_deleted = 1
WHERE l.line_id = #{lineId}
</select>
<insert id="batchInsertList" parameterType="list">
INSERT INTO base_power_line_diesel ( id, create_by_id, create_by_name, create_time, modify_by_id,
modify_by_name, modify_time, line_id, diesel_id, ou_id )
VALUES
<foreach collection="list" item="item" separator=",">
(
#{item.id},
#{item.createById},
#{item.createByName},
#{item.createTime},
#{item.modifyById},
#{item.modifyByName},
#{item.modifyTime},
#{item.lineId},
#{item.dieselId},
#{item.ouId}
)
</foreach>
</insert>
</mapper>
\ No newline at end of file
......@@ -52,4 +52,24 @@
AND p.is_deleted = 1
WHERE l.line_id = #{lineId}
</select>
<insert id="batchInsertList" parameterType="list">
INSERT INTO base_power_line_plant ( id, create_by_id, create_by_name, create_time, modify_by_id,
modify_by_name, modify_time, line_id, plant_id, ou_id )
VALUES
<foreach collection="list" item="item" separator=",">
(
#{item.id},
#{item.createById},
#{item.createByName},
#{item.createTime},
#{item.modifyById},
#{item.modifyByName},
#{item.modifyTime},
#{item.lineId},
#{item.plantId},
#{item.ouId}
)
</foreach>
</insert>
</mapper>
\ No newline at end of file
......@@ -52,4 +52,24 @@
AND d.is_deleted = 1
WHERE l.line_id = #{lineId}
</select>
<insert id="batchInsertList" parameterType="list">
INSERT INTO base_power_line_storage ( id, create_by_id, create_by_name, create_time, modify_by_id,
modify_by_name, modify_time, line_id, storage_id, ou_id )
VALUES
<foreach collection="list" item="item" separator=",">
(
#{item.id},
#{item.createById},
#{item.createByName},
#{item.createTime},
#{item.modifyById},
#{item.modifyByName},
#{item.modifyTime},
#{item.lineId},
#{item.storageId},
#{item.ouId}
)
</foreach>
</insert>
</mapper>
\ No newline at end of file
......@@ -81,4 +81,25 @@
</foreach>
</if>
</select>
<insert id="batchInsertList" parameterType="list">
INSERT INTO base_power_line_wellhead ( id, create_by_id, create_by_name, create_time, modify_by_id,
modify_by_name, modify_time, line_id, wellhead_id, ou_id, start_seq )
VALUES
<foreach collection="list" item="item" separator=",">
(
#{item.id},
#{item.createById},
#{item.createByName},
#{item.createTime},
#{item.modifyById},
#{item.modifyByName},
#{item.modifyTime},
#{item.lineId},
#{item.wellheadId},
#{item.ouId},
#{item.startSeq}
)
</foreach>
</insert>
</mapper>
\ No newline at end of file
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment