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

1.开发间开优化长期间开优化定时任务,完成并网流程绿电消纳优先策略;

BREAKING CHANGE: 无

Closes 无

[skip ci]

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

 package pps.core.base.service;
 
+import cn.hutool.core.collection.CollUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import pps.cloud.base.service.IBasePriceStrategyCloudService;
 import pps.cloud.base.service.data.base_price_strategy_detail.GetBasePriceStrategyDetailInput;
@@ -13,6 +14,7 @@ import xstartup.base.XContext;
 import xstartup.base.util.XCopyUtils;
 import xstartup.data.XListResult;
 
+import java.util.ArrayList;
 import java.util.List;
 
 /**
@@ -42,6 +44,12 @@ public class BasePriceStrategyCloudServiceImpl implements IBasePriceStrategyClou
                         .apply("strategy_id = ( SELECT strategy_id FROM base_power_line WHERE id = {0} ) ", input.getLineId())
                         .orderByAsc(BasePriceStrategyDetailEnt::getStartTime)
         );
-        return XListResult.success(XCopyUtils.copyNewList(detailList, GetBasePriceStrategyDetailOutput.class));
+        List<GetBasePriceStrategyDetailOutput> outputs;
+        if (CollUtil.isEmpty(detailList)) {
+            outputs = new ArrayList<>(0);
+        } else {
+            outputs = XCopyUtils.copyNewList(detailList, GetBasePriceStrategyDetailOutput.class);
+        }
+        return XListResult.success(outputs);
     }
-}
+}
\ No newline at end of file

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

@@ -11,6 +11,8 @@ import pps.cloud.base.service.IBasePowerLineCloudService;
 import pps.cloud.base.service.IBaseWellheadCloudService;
 import pps.cloud.base.service.data.base_power_line_plant.DynamicQueryBasePowerLinePlantInput;
 import pps.cloud.base.service.data.base_power_line_plant.DynamicQueryBasePowerLinePlantOutput;
+import pps.cloud.base.service.data.base_price_strategy_detail.GetBasePriceStrategyDetailInput;
+import pps.cloud.base.service.data.base_price_strategy_detail.GetBasePriceStrategyDetailOutput;
 import pps.cloud.base.service.data.base_wellhead.DynamicQueryBaseWellheadInput;
 import pps.cloud.base.service.data.base_wellhead.DynamicQueryBaseWellheadOutput;
 import pps.cloud.prediction.service.IPlantPredictedPowerCloudService;
@@ -23,6 +25,7 @@ import pps.core.common.utils.BaseUtils;
 import pps.core.space.entity.*;
 import pps.core.space.enums.BusinessError;
 import pps.core.space.mapper.*;
+import pps.core.space.utils.ServiceUtil;
 import xstartup.annotation.XService;
 import xstartup.base.XContext;
 import xstartup.data.XListResult;
@@ -131,32 +134,32 @@ public class SpaceOptimizeLongCloudServiceImpl implements ISpaceOptimizeLongClou
                             .filter(w -> StringUtils.equals(detailId, w.getInstitutionId()))
                             .map(SpaceInstitutionWellheadView::getServiceRating)
                             .reduce(BigDecimal.ZERO, BigDecimal::add);
+                    //根据类型过滤井口:大间开,连抽井不优化
+                    List<SpaceInstitutionWellheadView> wellheadViewList = spaceWellheadList.stream()
+                            .filter(w -> StringUtils.equals(detailId, w.getInstitutionId()) &&
+                                    StringUtils.equals("INTERVAL", w.getRunTypeKey()) &&
+                                    StringUtils.equals("0", w.getIntervalTypeKey()))
+                            .sorted(Comparator.comparing(SpaceInstitutionWellheadView::getStartSeq))
+                            .collect(Collectors.toList());
+                    if (CollUtil.isEmpty(wellheadViewList)) {
+                        continue;
+                    }
+                    //通过间开ID和井口ID查所有井口时段配置
+                    List<SpaceInstitutionDurationEnt> durationList = durationMapper.selectList(new LambdaQueryWrapper<SpaceInstitutionDurationEnt>()
+                            .eq(BaseModel::getIsDeleted, BusinessConstant.ONE)
+                            .eq(SpaceInstitutionDurationEnt::getInstitutionId, detailId)
+                            .orderByAsc(SpaceInstitutionDurationEnt::getOpenWellTime)
+                    );
+                    if (CollUtil.isEmpty(durationList)) {
+                        //没有设置时间段,无法优化
+                        continue;
+                    }
+                    Map<String, List<SpaceInstitutionDurationEnt>> durationMap = durationList.stream()
+                            .collect(Collectors.groupingBy(SpaceInstitutionDurationEnt::getWellheadId));
                     int compare = powerMax.compareTo(wellheadTotalPower);
                     //光伏出力峰值大于等于井口总功率:绿电消纳优先策略
                     if (compare >= BusinessConstant.ZERO) {
-                        //根据类型过滤井口:大间开,连抽井不优化
-                        List<SpaceInstitutionWellheadView> wellheadViewList = spaceWellheadList.stream()
-                                .filter(w -> StringUtils.equals(detailId, w.getInstitutionId()) &&
-                                        StringUtils.equals("INTERVAL", w.getRunTypeKey()) &&
-                                        StringUtils.equals("0", w.getIntervalTypeKey()))
-                                .sorted(Comparator.comparing(SpaceInstitutionWellheadView::getStartSeq))
-                                .collect(Collectors.toList());
-                        if (CollUtil.isEmpty(wellheadViewList)) {
-                            continue;
-                        }
-                        //通过间开ID和井口ID查所有井口时段配置
-                        List<SpaceInstitutionDurationEnt> durationList = durationMapper.selectList(new LambdaQueryWrapper<SpaceInstitutionDurationEnt>()
-                                .eq(BaseModel::getIsDeleted, BusinessConstant.ONE)
-                                .eq(SpaceInstitutionDurationEnt::getInstitutionId, detailId)
-                                .orderByAsc(SpaceInstitutionDurationEnt::getOpenWellTime)
-                        );
-                        if (CollUtil.isEmpty(durationList)) {
-                            //没有设置时间段,无法优化
-                            continue;
-                        }
                         //---------------------------------井口优化---------------------------------
-                        Map<String, List<SpaceInstitutionDurationEnt>> durationMap = durationList.stream()
-                                .collect(Collectors.groupingBy(SpaceInstitutionDurationEnt::getWellheadId));
                         int between = 0;
                         //判断是否第一口井
                         boolean isFirstWellhead;
@@ -296,10 +299,23 @@ public class SpaceOptimizeLongCloudServiceImpl implements ISpaceOptimizeLongClou
                         int lowWellheadListSize = lowWellheadList.size();
                         //光伏出力峰值<任何一口井的运行功率:消峰平谷策略
                         if (size == lowWellheadListSize) {
+                            //通过线路ID和月份获取市电峰谷策略明细配置
+                            List<GetBasePriceStrategyDetailOutput> strategyDetailList = ServiceUtil.getStrategyDetailList(context,
+                                    GetBasePriceStrategyDetailInput.builder()
+                                            .lineId(lineId)
+                                            .strategyMonth(String.valueOf(monthNum))
+                                            .build()
+                            );
+                            if (CollUtil.isEmpty(strategyDetailList)) {
+                                //没有配置,不优化
+                                continue;
+                            }
+                            //---------------------------------井口优化---------------------------------
 
                         }
                         //光伏出力峰值>=线路哪部分井口运行功率:满足的部分井口采用绿电消纳优先,不满足的井采用消峰平谷
                         else {
+                            //---------------------------------井口优化---------------------------------
                             List<SpaceInstitutionWellheadView> highWellheadList = collect.get(true);
 
 
@@ -491,4 +507,4 @@ public class SpaceOptimizeLongCloudServiceImpl implements ISpaceOptimizeLongClou
             );
         });
     }
-}
+}
\ No newline at end of file