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

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

BREAKING CHANGE: 无

Closes 无

[skip ci]

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

@@ -111,7 +111,7 @@ public class SpaceOptimizeLongCloudServiceImpl extends SpaceOptimizeBaseService
                 size = periodDTOList.size();
                 if (size > BaseUtils.BATCH_SIZE) {
                     List<List<SpaceOptimizePeriodDTO>> subList = BaseUtils.getSubList(periodDTOList);
-                    subList.forEach(b -> optimizeViewMapper.longPeriodBatchInsertList(b));
+                    subList.forEach(optimizeViewMapper::longPeriodBatchInsertList);
                 } else {
                     optimizeViewMapper.longPeriodBatchInsertList(periodDTOList);
                 }
@@ -120,7 +120,7 @@ public class SpaceOptimizeLongCloudServiceImpl extends SpaceOptimizeBaseService
                 size = wellheadDTOList.size();
                 if (size > BaseUtils.BATCH_SIZE) {
                     List<List<SpaceOptimizeWellheadDTO>> subList = BaseUtils.getSubList(wellheadDTOList);
-                    subList.forEach(b -> optimizeViewMapper.longWellheadBatchInsertList(b));
+                    subList.forEach(optimizeViewMapper::longWellheadBatchInsertList);
                 } else {
                     optimizeViewMapper.longWellheadBatchInsertList(wellheadDTOList);
                 }
@@ -129,7 +129,7 @@ public class SpaceOptimizeLongCloudServiceImpl extends SpaceOptimizeBaseService
                 size = unOptimizeDurationList.size();
                 if (size > BaseUtils.BATCH_SIZE) {
                     List<List<SpaceOptimizeDurationDTO>> subList = BaseUtils.getSubList(unOptimizeDurationList);
-                    subList.forEach(b -> optimizeViewMapper.longDurationBatchInsertList(b));
+                    subList.forEach(optimizeViewMapper::longDurationBatchInsertList);
                 } else {
                     optimizeViewMapper.longDurationBatchInsertList(unOptimizeDurationList);
                 }
@@ -138,7 +138,7 @@ public class SpaceOptimizeLongCloudServiceImpl extends SpaceOptimizeBaseService
                 size = durationDTOList.size();
                 if (size > BaseUtils.BATCH_SIZE) {
                     List<List<SpaceOptimizeDurationDTO>> subList = BaseUtils.getSubList(durationDTOList);
-                    subList.forEach(b -> optimizeViewMapper.longDurationBatchInsertList(b));
+                    subList.forEach(optimizeViewMapper::longDurationBatchInsertList);
                 } else {
                     optimizeViewMapper.longDurationBatchInsertList(durationDTOList);
                 }

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

@@ -4,8 +4,8 @@ import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.DateTime;
 import cn.hutool.core.date.DateUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
+import com.github.pagehelper.page.PageMethod;
 import org.apache.commons.lang3.StringUtils;
 import pps.cloud.base.service.data.base_price_strategy_detail.GetBasePriceStrategyDetailInput;
 import pps.cloud.prediction.service.data.plant_predicted_power_data.DynamicQueryPlantPredictedPowerInput;
@@ -57,7 +57,7 @@ public class SpaceOptimizeLongPeriodService extends SpaceOptimizeBaseService {
     public XPageResult<QuerySpaceOptimizeLongPeriodViewOutput> querySpaceOptimizeLongPeriodView(XContext context, QuerySpaceOptimizeLongPeriodViewInput input) {
         SpaceOptimizeLongPeriodViewMapper mapper = context.getBean(SpaceOptimizeLongPeriodViewMapper.class);
         SpaceOptimizeLongPeriodView record = XCopyUtils.copyNewObject(input, SpaceOptimizeLongPeriodView.class);
-        PageHelper.startPage(input.getPage(), input.getLimit());
+        PageMethod.startPage(input.getPage(), input.getLimit());
         List<SpaceOptimizeLongPeriodView> list = mapper.selectList(record);
         PageInfo<SpaceOptimizeLongPeriodView> pageInfo = new PageInfo<>(list);
         List<QuerySpaceOptimizeLongPeriodViewOutput> outputs = XCopyUtils.copyNewList(pageInfo.getList(), QuerySpaceOptimizeLongPeriodViewOutput.class);

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

@@ -109,7 +109,7 @@ public class SpaceOptimizeMidCloudServiceImpl extends SpaceOptimizeBaseService i
                 size = periodDTOList.size();
                 if (size > BaseUtils.BATCH_SIZE) {
                     List<List<SpaceOptimizePeriodDTO>> subList = BaseUtils.getSubList(periodDTOList);
-                    subList.forEach(b -> optimizeViewMapper.midPeriodBatchInsertList(b));
+                    subList.forEach(optimizeViewMapper::midPeriodBatchInsertList);
                 } else {
                     optimizeViewMapper.midPeriodBatchInsertList(periodDTOList);
                 }
@@ -118,7 +118,7 @@ public class SpaceOptimizeMidCloudServiceImpl extends SpaceOptimizeBaseService i
                 size = wellheadDTOList.size();
                 if (size > BaseUtils.BATCH_SIZE) {
                     List<List<SpaceOptimizeWellheadDTO>> subList = BaseUtils.getSubList(wellheadDTOList);
-                    subList.forEach(b -> optimizeViewMapper.midWellheadBatchInsertList(b));
+                    subList.forEach(optimizeViewMapper::midWellheadBatchInsertList);
                 } else {
                     optimizeViewMapper.midWellheadBatchInsertList(wellheadDTOList);
                 }
@@ -127,7 +127,7 @@ public class SpaceOptimizeMidCloudServiceImpl extends SpaceOptimizeBaseService i
                 size = unOptimizeDurationList.size();
                 if (size > BaseUtils.BATCH_SIZE) {
                     List<List<SpaceOptimizeDurationDTO>> subList = BaseUtils.getSubList(unOptimizeDurationList);
-                    subList.forEach(b -> optimizeViewMapper.midDurationBatchInsertList(b));
+                    subList.forEach(optimizeViewMapper::midDurationBatchInsertList);
                 } else {
                     optimizeViewMapper.midDurationBatchInsertList(unOptimizeDurationList);
                 }
@@ -136,7 +136,7 @@ public class SpaceOptimizeMidCloudServiceImpl extends SpaceOptimizeBaseService i
                 size = durationDTOList.size();
                 if (size > BaseUtils.BATCH_SIZE) {
                     List<List<SpaceOptimizeDurationDTO>> subList = BaseUtils.getSubList(durationDTOList);
-                    subList.forEach(b -> optimizeViewMapper.midDurationBatchInsertList(b));
+                    subList.forEach(optimizeViewMapper::midDurationBatchInsertList);
                 } else {
                     optimizeViewMapper.midDurationBatchInsertList(durationDTOList);
                 }

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

@@ -4,8 +4,8 @@ import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.DateTime;
 import cn.hutool.core.date.DateUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
+import com.github.pagehelper.page.PageMethod;
 import org.apache.commons.lang3.StringUtils;
 import pps.cloud.base.service.data.base_price_strategy_detail.GetBasePriceStrategyDetailInput;
 import pps.cloud.prediction.service.data.plant_predicted_power_data.DynamicQueryPlantPredictedPowerInput;
@@ -57,7 +57,7 @@ public class SpaceOptimizeMidPeriodService extends SpaceOptimizeBaseService {
     public XPageResult<QuerySpaceOptimizeMidPeriodViewOutput> querySpaceOptimizeMidPeriodView(XContext context, QuerySpaceOptimizeMidPeriodViewInput input) {
         SpaceOptimizeMidPeriodViewMapper mapper = context.getBean(SpaceOptimizeMidPeriodViewMapper.class);
         SpaceOptimizeMidPeriodView record = XCopyUtils.copyNewObject(input, SpaceOptimizeMidPeriodView.class);
-        PageHelper.startPage(input.getPage(), input.getLimit());
+        PageMethod.startPage(input.getPage(), input.getLimit());
         List<SpaceOptimizeMidPeriodView> list = mapper.selectList(record);
         PageInfo<SpaceOptimizeMidPeriodView> pageInfo = new PageInfo<>(list);
         List<QuerySpaceOptimizeMidPeriodViewOutput> outputs = XCopyUtils.copyNewList(pageInfo.getList(), QuerySpaceOptimizeMidPeriodViewOutput.class);

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

@@ -202,7 +202,7 @@ public class SpaceOptimizeShortCloudServiceImpl extends SpaceOptimizeBaseService
                 size = periodDTOList.size();
                 if (size > BaseUtils.BATCH_SIZE) {
                     List<List<SpaceOptimizePeriodDTO>> subList = BaseUtils.getSubList(periodDTOList);
-                    subList.forEach(b -> optimizeViewMapper.shortPeriodBatchInsertList(b));
+                    subList.forEach(optimizeViewMapper::shortPeriodBatchInsertList);
                 } else {
                     optimizeViewMapper.shortPeriodBatchInsertList(periodDTOList);
                 }
@@ -211,7 +211,7 @@ public class SpaceOptimizeShortCloudServiceImpl extends SpaceOptimizeBaseService
                 size = wellheadDTOList.size();
                 if (size > BaseUtils.BATCH_SIZE) {
                     List<List<SpaceOptimizeWellheadDTO>> subList = BaseUtils.getSubList(wellheadDTOList);
-                    subList.forEach(b -> optimizeViewMapper.shortWellheadBatchInsertList(b));
+                    subList.forEach(optimizeViewMapper::shortWellheadBatchInsertList);
                 } else {
                     optimizeViewMapper.shortWellheadBatchInsertList(wellheadDTOList);
                 }
@@ -220,7 +220,7 @@ public class SpaceOptimizeShortCloudServiceImpl extends SpaceOptimizeBaseService
                 size = unOptimizeDurationList.size();
                 if (size > BaseUtils.BATCH_SIZE) {
                     List<List<SpaceOptimizeDurationDTO>> subList = BaseUtils.getSubList(unOptimizeDurationList);
-                    subList.forEach(b -> optimizeViewMapper.shortDurationBatchInsertList(b));
+                    subList.forEach(optimizeViewMapper::shortDurationBatchInsertList);
                 } else {
                     optimizeViewMapper.shortDurationBatchInsertList(unOptimizeDurationList);
                 }
@@ -229,7 +229,7 @@ public class SpaceOptimizeShortCloudServiceImpl extends SpaceOptimizeBaseService
                 size = durationDTOList.size();
                 if (size > BaseUtils.BATCH_SIZE) {
                     List<List<SpaceOptimizeDurationDTO>> subList = BaseUtils.getSubList(durationDTOList);
-                    subList.forEach(b -> optimizeViewMapper.shortDurationBatchInsertList(b));
+                    subList.forEach(optimizeViewMapper::shortDurationBatchInsertList);
                 } else {
                     optimizeViewMapper.shortDurationBatchInsertList(durationDTOList);
                 }