feat(能源管理系统): 间开优化定时任务

1.开发间开优化定期校准定时任务,配置表达式修改定时任务配置文件,创建cloud模块方法;
2.开发间开优化定期校准定时任务,完成业务逻辑开发;
3.修改间开制度管理模块定期校准新增功能,增加初始化校准历史业务逻辑;
4.开发间开优化短期间开优化定时任务,配置表达式修改定时任务配置文件,创建cloud模块方法;
5.修改长期间开优化定时任务,添加离网型线路数据处理逻辑;
6.创建储能预测电量数据(模拟数据测试用)表,生成对应代码,添加条件查询各时段储能预测数据Cloud模块接口;
7.修改长期间开优化定时任务,增加离网型算法计算储能可用时长逻辑;
8.修改长期间开优化定时任务,优化部分sql查询语句查询逻辑,优化代码结构;
9.光伏预测Cloud模块查询预测发电量接口修改,增加查询长期发电量逻辑;
10.修改中短期间开优化定时任务,添加离网型优化逻辑;
11.修改长期/中短期间开优化定时任务,优化代码结构;
12.修改基础间开配置模块设为基础间开制度及重新优化接口,增加并网型优化逻辑;

BREAKING CHANGE: 无

Closes 无

[skip ci]

C11-space/pps-core-space/src/main/java/pps/core/space/service/SpaceOptimizeShortCloudServiceImpl.java

@@ -7,8 +7,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import pps.cloud.space.service.ISpaceOptimizeShortCloudService;
 import pps.core.common.constant.BusinessConstant;
 import pps.core.common.entity.BaseModel;
-import pps.core.space.entity.SpaceInstitutionDetailEnt;
-import pps.core.space.entity.SpaceInstitutionWellheadEnt;
+import pps.core.space.entity.*;
 import pps.core.space.enums.BusinessError;
 import pps.core.space.mapper.SpaceInstitutionWellheadMapper;
 import xstartup.annotation.XService;
@@ -16,7 +15,9 @@ import xstartup.base.XContext;
 import xstartup.base.exception.XServiceException;
 import xstartup.data.XServiceResult;
 
+import java.util.ArrayList;
 import java.util.List;
+import java.util.Map;
 import java.util.stream.Collectors;
 
 /**
@@ -53,9 +54,25 @@ public class SpaceOptimizeShortCloudServiceImpl extends SpaceOptimizeBaseService
             //未发现可优化井口
             throw new XServiceException(BusinessError.DidNotFindWellhead);
         }
+        Map<String, List<SpaceInstitutionWellheadEnt>> wellheadsByInstitutionIdIdMap = wellheadList.stream()
+                .collect(Collectors.groupingBy(SpaceInstitutionWellheadEnt::getInstitutionId));
+        List<SpaceOptimizePeriodDTO> periodDTOList = new ArrayList<>(32);
+        List<SpaceOptimizeWellheadDTO> wellheadDTOList = new ArrayList<>(64);
+        List<SpaceOptimizeDurationDTO> durationDTOList = new ArrayList<>(128);
+        List<SpaceOptimizeDurationDTO> unOptimizeDurationList = new ArrayList<>(128);
+        DateTime endOfDay = DateUtil.endOfDay(date);
+        //优化
+        for (SpaceInstitutionDetailEnt detail : detailEntList) {
+            String detailId = detail.getId();
+            String lineId = detail.getLineId();
+            //创建记录
+            String periodId = super.createOptimizePeriod(periodDTOList, detailId, lineId, null, endOfDay);
+            if (!wellheadsByInstitutionIdIdMap.containsKey(detailId)) {
+                continue;
+            }
+            List<SpaceInstitutionWellheadEnt> wellheadEntList = wellheadsByInstitutionIdIdMap.get(detailId);
 
-
-
+        }
         return XServiceResult.OK;
     }
 }
\ No newline at end of file