Commit f877cf88 authored by ZWT's avatar ZWT

feat(吉林演示): 松原

1.修改风电站运行状态接口,增加模拟实际发电功率处理逻辑,完成接口冒烟测试;
2.修改天气数据处理定时任务,解决晚上十一点半天气预报数据处理异常问题,修改风资源预测数据和光伏资源预测数据时间处理逻辑,完成接口冒烟测试;
3.修改风机预测数据模块相关功能接口,增加判断当前部署环境逻辑,解决查询全量数据问题;
4.修改风机预测数据生成模块第三方风力发电数据生成功能,增加数据拆分逻辑,区分15分数据层级,完成功能冒烟测试;
5.修改风机预测监控页面历史风速统计接口,统计数据不显示问题及小数位过多问题;
6.修改天气预报数据爬取定时任务,解决8:00-11:00期间没有数据问题,完成功能验证;
7,修改风资源预测历史数据处理定时任务,修改查询逻辑,解决未保存历史预测数据问题;

BREAKING CHANGE: 无

Closes 无

[skip ci]
parent fa185cdb
...@@ -3,7 +3,6 @@ package pps.core.base.service; ...@@ -3,7 +3,6 @@ package pps.core.base.service;
import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateTime; import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import pps.cloud.base.service.IWindPredictionHistoryCloudService; import pps.cloud.base.service.IWindPredictionHistoryCloudService;
import pps.core.base.entity.ThirdWindPowerGenerationEnt; import pps.core.base.entity.ThirdWindPowerGenerationEnt;
...@@ -34,6 +33,8 @@ public class WindPredictionHistoryCloudServiceImpl implements IWindPredictionHis ...@@ -34,6 +33,8 @@ public class WindPredictionHistoryCloudServiceImpl implements IWindPredictionHis
/** /**
* 风资源训练集定时任务 * 风资源训练集定时任务
* wind_prediction_history的 actual_power存实际功率
* wind_prediction_future的 actual_power为预测功率
* *
* @param context 上下文 * @param context 上下文
* @return {@link XServiceResult } * @return {@link XServiceResult }
...@@ -44,7 +45,17 @@ public class WindPredictionHistoryCloudServiceImpl implements IWindPredictionHis ...@@ -44,7 +45,17 @@ public class WindPredictionHistoryCloudServiceImpl implements IWindPredictionHis
DateTime endTime = DateUtil.endOfDay(startTime); DateTime endTime = DateUtil.endOfDay(startTime);
//取日期范围内已预测数据 //取日期范围内已预测数据
WindPredictionFutureMapper mapper = context.getBean(WindPredictionFutureMapper.class); WindPredictionFutureMapper mapper = context.getBean(WindPredictionFutureMapper.class);
List<WindPredictionFutureEnt> list = mapper.selectList(new LambdaQueryWrapper<WindPredictionFutureEnt>() List<WindPredictionFutureEnt> list = mapper.selectList(new QueryWrapper<WindPredictionFutureEnt>()
.select("station_id",
"data_time",
"wind_direction",
"wind_speed",
"air_temperature",
"humidity",
"pressure",
"actual_wind_speed",
"actual_power AS predicted_power")
.lambda()
.between(WindPredictionFutureEnt::getDataTime, startTime, endTime) .between(WindPredictionFutureEnt::getDataTime, startTime, endTime)
); );
if (CollUtil.isNotEmpty(list)) { if (CollUtil.isNotEmpty(list)) {
......
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