Commit 9b9bfdd8 authored by ZWT's avatar ZWT

feat(能源管理系统): 邮件接收

1.添加天气数据邮件方式接收定时任务;
2.修改配置文件,增加新建定时任务,同时增加自定义参数;
3.创建天气邮件数据接收处理实现类,同时验证获取自定义参数方法;
4.添加收件工具类,验证是否能正常接收邮件;
5.天气邮件数据接收定时任务增加获取未读天气数据逻辑,增加附件文件临时存储方法并验证是否能正常读取文件数据同时转换为json数据;
6.增加查询运行中电站列表方法;

BREAKING CHANGE: 无

Closes 无

[skip ci]
parent ef29f82d
......@@ -113,8 +113,8 @@ public class BaseWeatherCloudServiceImpl implements IBaseWeatherCloudService {
Map<String, List<BasePhotovoltaicPlantView>> plantMap = plantList.stream()
.collect(Collectors.groupingBy(BasePhotovoltaicPlantView::getCityCode));
PlantPredictedPowerDataMapper mapper = context.getBean(PlantPredictedPowerDataMapper.class);
PlantPredictedPowerDataViewMapper dataViewMapper = context.getBean(PlantPredictedPowerDataViewMapper.class);
List<String> timeList = Arrays.asList("15:00", "30:00", "45:00");
List<PlantPredictedPowerDataEnt> batchList = new ArrayList<>();
//读取附件
for (Message message : messageList) {
String tempFilePath = this.saveAttachment(message);
......@@ -138,6 +138,7 @@ public class BaseWeatherCloudServiceImpl implements IBaseWeatherCloudService {
//遍历预测数据列表
for (DailyData dailyData : dailyDataList) {
for (BasePhotovoltaicPlantView plant : plantViewList) {
List<PlantPredictedPowerDataEnt> batchList = new ArrayList<>();
List<PlantPredictedPowerDataEnt> allList = new ArrayList<>();
List<PlantPredictedPowerDataEnt> objList = new ArrayList<>();
DateTime dateTime = DateTime.of(dailyData.getDateTime());
......@@ -263,12 +264,6 @@ public class BaseWeatherCloudServiceImpl implements IBaseWeatherCloudService {
}
}
}
}
}
}
FileUtil.del(tempFilePath);
}
PlantPredictedPowerDataViewMapper dataViewMapper = context.getBean(PlantPredictedPowerDataViewMapper.class);
if (CollUtil.isNotEmpty(batchList)) {
int size = batchList.size();
if (size > BaseUtils.BATCH_SIZE) {
......@@ -279,6 +274,11 @@ public class BaseWeatherCloudServiceImpl implements IBaseWeatherCloudService {
}
}
}
}
}
FileUtil.del(tempFilePath);
}
}
} catch (MessagingException e) {
throw new RuntimeException(e);
} catch (IOException e) {
......
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