Commit dc71ec53 authored by ZWT's avatar ZWT

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

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

BREAKING CHANGE: 无

Closes 无

[skip ci]
parent ec3caf17
...@@ -2,8 +2,8 @@ package pps.core.prediction.service; ...@@ -2,8 +2,8 @@ package pps.core.prediction.service;
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.LambdaQueryWrapper;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import com.github.pagehelper.page.PageMethod;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import pps.core.prediction.entity.WellheadDailyProductionSituationEnt; import pps.core.prediction.entity.WellheadDailyProductionSituationEnt;
import pps.core.prediction.mapper.WellheadDailyProductionSituationMapper; import pps.core.prediction.mapper.WellheadDailyProductionSituationMapper;
...@@ -42,7 +42,7 @@ public class WellheadDailyProductionSituationService { ...@@ -42,7 +42,7 @@ public class WellheadDailyProductionSituationService {
@XApiPost @XApiPost
public XPageResult<QueryWellheadDailyProductionSituationOutput> queryWellheadDailyProductionSituationView(XContext context, QueryWellheadDailyProductionSituationInput input) { public XPageResult<QueryWellheadDailyProductionSituationOutput> queryWellheadDailyProductionSituationView(XContext context, QueryWellheadDailyProductionSituationInput input) {
WellheadDailyProductionSituationMapper mapper = context.getBean(WellheadDailyProductionSituationMapper.class); WellheadDailyProductionSituationMapper mapper = context.getBean(WellheadDailyProductionSituationMapper.class);
PageHelper.startPage(input.getPage(), input.getLimit()); PageMethod.startPage(input.getPage(), input.getLimit());
LambdaQueryWrapper<WellheadDailyProductionSituationEnt> queryWrapper = new LambdaQueryWrapper<WellheadDailyProductionSituationEnt>() LambdaQueryWrapper<WellheadDailyProductionSituationEnt> queryWrapper = new LambdaQueryWrapper<WellheadDailyProductionSituationEnt>()
.eq(WellheadDailyProductionSituationEnt::getWellheadId, input.getWellheadId()) .eq(WellheadDailyProductionSituationEnt::getWellheadId, input.getWellheadId())
.eq(WellheadDailyProductionSituationEnt::getWellNumber, input.getWellNumber()) .eq(WellheadDailyProductionSituationEnt::getWellNumber, input.getWellNumber())
......
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