Commit 13b8f95a authored by ZWT's avatar ZWT

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

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

BREAKING CHANGE: 无

Closes 无

[skip ci]
parent bef68dc2
...@@ -6,8 +6,8 @@ import cn.hutool.core.date.DateTime; ...@@ -6,8 +6,8 @@ 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.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
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.cloud.base.service.IBasePowerLineCloudService; import pps.cloud.base.service.IBasePowerLineCloudService;
import pps.cloud.base.service.data.base_power_line_wellhead.DynamicQueryBasePowerLineWellheadInput; import pps.cloud.base.service.data.base_power_line_wellhead.DynamicQueryBasePowerLineWellheadInput;
...@@ -242,7 +242,7 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService { ...@@ -242,7 +242,7 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService {
String lineId = input.getLineId(); String lineId = input.getLineId();
String institutionName = input.getInstitutionName(); String institutionName = input.getInstitutionName();
SpaceInstitutionDetailMapper mapper = context.getBean(SpaceInstitutionDetailMapper.class); SpaceInstitutionDetailMapper mapper = context.getBean(SpaceInstitutionDetailMapper.class);
PageHelper.startPage(input.getPage(), input.getLimit()); PageMethod.startPage(input.getPage(), input.getLimit());
List<SpaceInstitutionDetailEnt> detailEntList = mapper.selectList(new LambdaQueryWrapper<SpaceInstitutionDetailEnt>() List<SpaceInstitutionDetailEnt> detailEntList = mapper.selectList(new LambdaQueryWrapper<SpaceInstitutionDetailEnt>()
.eq(BaseModel::getIsDeleted, BusinessConstant.ONE) .eq(BaseModel::getIsDeleted, BusinessConstant.ONE)
.eq(SpaceInstitutionDetailEnt::getOuId, input.getOuId()) .eq(SpaceInstitutionDetailEnt::getOuId, input.getOuId())
...@@ -372,7 +372,7 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService { ...@@ -372,7 +372,7 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService {
@XText("间开优化历史--分页列表") @XText("间开优化历史--分页列表")
public XPageResult<QueryOptimizeHistoryViewOutput> queryOptimizeHistoryView(XContext context, QueryOptimizeHistoryViewInput input) { public XPageResult<QueryOptimizeHistoryViewOutput> queryOptimizeHistoryView(XContext context, QueryOptimizeHistoryViewInput input) {
SpaceInstitutionDetailViewMapper mapper = context.getBean(SpaceInstitutionDetailViewMapper.class); SpaceInstitutionDetailViewMapper mapper = context.getBean(SpaceInstitutionDetailViewMapper.class);
PageHelper.startPage(input.getPage(), input.getLimit()); PageMethod.startPage(input.getPage(), input.getLimit());
List<SpaceInstitutionDetailView> historyList = mapper.selectOptimizeHistoryList(SpaceInstitutionDetailView.builder() List<SpaceInstitutionDetailView> historyList = mapper.selectOptimizeHistoryList(SpaceInstitutionDetailView.builder()
.ouId(input.getOuId()) .ouId(input.getOuId())
.build() .build()
...@@ -505,7 +505,7 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService { ...@@ -505,7 +505,7 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService {
size = longPeriodDTOList.size(); size = longPeriodDTOList.size();
if (size > BaseUtils.BATCH_SIZE) { if (size > BaseUtils.BATCH_SIZE) {
List<List<SpaceOptimizePeriodDTO>> subList = BaseUtils.getSubList(longPeriodDTOList); List<List<SpaceOptimizePeriodDTO>> subList = BaseUtils.getSubList(longPeriodDTOList);
subList.forEach(b -> optimizeViewMapper.longPeriodBatchInsertList(b)); subList.forEach(optimizeViewMapper::longPeriodBatchInsertList);
} else { } else {
optimizeViewMapper.longPeriodBatchInsertList(longPeriodDTOList); optimizeViewMapper.longPeriodBatchInsertList(longPeriodDTOList);
} }
...@@ -514,7 +514,7 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService { ...@@ -514,7 +514,7 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService {
size = longWellheadDTOList.size(); size = longWellheadDTOList.size();
if (size > BaseUtils.BATCH_SIZE) { if (size > BaseUtils.BATCH_SIZE) {
List<List<SpaceOptimizeWellheadDTO>> subList = BaseUtils.getSubList(longWellheadDTOList); List<List<SpaceOptimizeWellheadDTO>> subList = BaseUtils.getSubList(longWellheadDTOList);
subList.forEach(b -> optimizeViewMapper.longWellheadBatchInsertList(b)); subList.forEach(optimizeViewMapper::longWellheadBatchInsertList);
} else { } else {
optimizeViewMapper.longWellheadBatchInsertList(longWellheadDTOList); optimizeViewMapper.longWellheadBatchInsertList(longWellheadDTOList);
} }
...@@ -523,7 +523,7 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService { ...@@ -523,7 +523,7 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService {
size = longDurationDTOList.size(); size = longDurationDTOList.size();
if (size > BaseUtils.BATCH_SIZE) { if (size > BaseUtils.BATCH_SIZE) {
List<List<SpaceOptimizeDurationDTO>> subList = BaseUtils.getSubList(longDurationDTOList); List<List<SpaceOptimizeDurationDTO>> subList = BaseUtils.getSubList(longDurationDTOList);
subList.forEach(b -> optimizeViewMapper.longDurationBatchInsertList(b)); subList.forEach(optimizeViewMapper::longDurationBatchInsertList);
} else { } else {
optimizeViewMapper.longDurationBatchInsertList(longDurationDTOList); optimizeViewMapper.longDurationBatchInsertList(longDurationDTOList);
} }
...@@ -532,7 +532,7 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService { ...@@ -532,7 +532,7 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService {
size = longUnOptimizeDurationList.size(); size = longUnOptimizeDurationList.size();
if (size > BaseUtils.BATCH_SIZE) { if (size > BaseUtils.BATCH_SIZE) {
List<List<SpaceOptimizeDurationDTO>> subList = BaseUtils.getSubList(longUnOptimizeDurationList); List<List<SpaceOptimizeDurationDTO>> subList = BaseUtils.getSubList(longUnOptimizeDurationList);
subList.forEach(b -> optimizeViewMapper.longDurationBatchInsertList(b)); subList.forEach(optimizeViewMapper::longDurationBatchInsertList);
} else { } else {
optimizeViewMapper.longDurationBatchInsertList(longUnOptimizeDurationList); optimizeViewMapper.longDurationBatchInsertList(longUnOptimizeDurationList);
} }
...@@ -542,7 +542,7 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService { ...@@ -542,7 +542,7 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService {
size = midPeriodDTOList.size(); size = midPeriodDTOList.size();
if (size > BaseUtils.BATCH_SIZE) { if (size > BaseUtils.BATCH_SIZE) {
List<List<SpaceOptimizePeriodDTO>> subList = BaseUtils.getSubList(midPeriodDTOList); List<List<SpaceOptimizePeriodDTO>> subList = BaseUtils.getSubList(midPeriodDTOList);
subList.forEach(b -> optimizeViewMapper.midPeriodBatchInsertList(b)); subList.forEach(optimizeViewMapper::midPeriodBatchInsertList);
} else { } else {
optimizeViewMapper.midPeriodBatchInsertList(midPeriodDTOList); optimizeViewMapper.midPeriodBatchInsertList(midPeriodDTOList);
} }
...@@ -551,7 +551,7 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService { ...@@ -551,7 +551,7 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService {
size = midWellheadDTOList.size(); size = midWellheadDTOList.size();
if (size > BaseUtils.BATCH_SIZE) { if (size > BaseUtils.BATCH_SIZE) {
List<List<SpaceOptimizeWellheadDTO>> subList = BaseUtils.getSubList(midWellheadDTOList); List<List<SpaceOptimizeWellheadDTO>> subList = BaseUtils.getSubList(midWellheadDTOList);
subList.forEach(b -> optimizeViewMapper.midWellheadBatchInsertList(b)); subList.forEach(optimizeViewMapper::midWellheadBatchInsertList);
} else { } else {
optimizeViewMapper.midWellheadBatchInsertList(midWellheadDTOList); optimizeViewMapper.midWellheadBatchInsertList(midWellheadDTOList);
} }
...@@ -560,7 +560,7 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService { ...@@ -560,7 +560,7 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService {
size = midDurationDTOList.size(); size = midDurationDTOList.size();
if (size > BaseUtils.BATCH_SIZE) { if (size > BaseUtils.BATCH_SIZE) {
List<List<SpaceOptimizeDurationDTO>> subList = BaseUtils.getSubList(midDurationDTOList); List<List<SpaceOptimizeDurationDTO>> subList = BaseUtils.getSubList(midDurationDTOList);
subList.forEach(b -> optimizeViewMapper.midDurationBatchInsertList(b)); subList.forEach(optimizeViewMapper::midDurationBatchInsertList);
} else { } else {
optimizeViewMapper.midDurationBatchInsertList(midDurationDTOList); optimizeViewMapper.midDurationBatchInsertList(midDurationDTOList);
} }
...@@ -569,7 +569,7 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService { ...@@ -569,7 +569,7 @@ public class SpaceInstitutionDetailService extends SpaceOptimizeBaseService {
size = midUnOptimizeDurationList.size(); size = midUnOptimizeDurationList.size();
if (size > BaseUtils.BATCH_SIZE) { if (size > BaseUtils.BATCH_SIZE) {
List<List<SpaceOptimizeDurationDTO>> subList = BaseUtils.getSubList(midUnOptimizeDurationList); List<List<SpaceOptimizeDurationDTO>> subList = BaseUtils.getSubList(midUnOptimizeDurationList);
subList.forEach(b -> optimizeViewMapper.midDurationBatchInsertList(b)); subList.forEach(optimizeViewMapper::midDurationBatchInsertList);
} else { } else {
optimizeViewMapper.midDurationBatchInsertList(midUnOptimizeDurationList); optimizeViewMapper.midDurationBatchInsertList(midUnOptimizeDurationList);
} }
......
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