feat(零碳): 长庆

1.修改极短期间开预测定时任务逻辑,解决优化后部分优化结果时间段过短问题;
2.修改心知天气气象数据获取及接收定时任务,解决天气数据通过邮件下载后,部分数据精度丢失问题;
3.修改首页各个接口逻辑,对小数类型字段进行处理,修改首页接口,增加小时保留两位四舍五入逻辑,同时解决线路详情接口部分查询逻辑报错问题;

BREAKING CHANGE: 无

Closes 无

[skip ci]

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

@@ -424,44 +424,44 @@ public class SpaceOptimizeShortPeriodService extends SpaceOptimizeBaseService {
         }
         //开启事务
         return XTransactionHelper.begin(context, () -> {
-//            int size;
-//            SpaceOptimizeViewMapper optimizeViewMapper = context.getBean(SpaceOptimizeViewMapper.class);
-//            if (CollUtil.isNotEmpty(periodDTOList)) {
-//                size = periodDTOList.size();
-//                if (size > BaseUtils.BATCH_SIZE) {
-//                    List<List<SpaceOptimizePeriodDTO>> subList = BaseUtils.getSubList(periodDTOList);
-//                    subList.forEach(optimizeViewMapper::shortPeriodBatchInsertList);
-//                } else {
-//                    optimizeViewMapper.shortPeriodBatchInsertList(periodDTOList);
-//                }
-//            }
-//            if (CollUtil.isNotEmpty(wellheadDTOList)) {
-//                size = wellheadDTOList.size();
-//                if (size > BaseUtils.BATCH_SIZE) {
-//                    List<List<SpaceOptimizeWellheadDTO>> subList = BaseUtils.getSubList(wellheadDTOList);
-//                    subList.forEach(optimizeViewMapper::shortWellheadBatchInsertList);
-//                } else {
-//                    optimizeViewMapper.shortWellheadBatchInsertList(wellheadDTOList);
-//                }
-//            }
-//            if (CollUtil.isNotEmpty(unOptimizeDurationList)) {
-//                size = unOptimizeDurationList.size();
-//                if (size > BaseUtils.BATCH_SIZE) {
-//                    List<List<SpaceOptimizeDurationDTO>> subList = BaseUtils.getSubList(unOptimizeDurationList);
-//                    subList.forEach(optimizeViewMapper::shortDurationBatchInsertList);
-//                } else {
-//                    optimizeViewMapper.shortDurationBatchInsertList(unOptimizeDurationList);
-//                }
-//            }
-//            if (CollUtil.isNotEmpty(durationDTOList)) {
-//                size = durationDTOList.size();
-//                if (size > BaseUtils.BATCH_SIZE) {
-//                    List<List<SpaceOptimizeDurationDTO>> subList = BaseUtils.getSubList(durationDTOList);
-//                    subList.forEach(optimizeViewMapper::shortDurationBatchInsertList);
-//                } else {
-//                    optimizeViewMapper.shortDurationBatchInsertList(durationDTOList);
-//                }
-//            }
+            int size;
+            SpaceOptimizeViewMapper optimizeViewMapper = context.getBean(SpaceOptimizeViewMapper.class);
+            if (CollUtil.isNotEmpty(periodDTOList)) {
+                size = periodDTOList.size();
+                if (size > BaseUtils.BATCH_SIZE) {
+                    List<List<SpaceOptimizePeriodDTO>> subList = BaseUtils.getSubList(periodDTOList);
+                    subList.forEach(optimizeViewMapper::shortPeriodBatchInsertList);
+                } else {
+                    optimizeViewMapper.shortPeriodBatchInsertList(periodDTOList);
+                }
+            }
+            if (CollUtil.isNotEmpty(wellheadDTOList)) {
+                size = wellheadDTOList.size();
+                if (size > BaseUtils.BATCH_SIZE) {
+                    List<List<SpaceOptimizeWellheadDTO>> subList = BaseUtils.getSubList(wellheadDTOList);
+                    subList.forEach(optimizeViewMapper::shortWellheadBatchInsertList);
+                } else {
+                    optimizeViewMapper.shortWellheadBatchInsertList(wellheadDTOList);
+                }
+            }
+            if (CollUtil.isNotEmpty(unOptimizeDurationList)) {
+                size = unOptimizeDurationList.size();
+                if (size > BaseUtils.BATCH_SIZE) {
+                    List<List<SpaceOptimizeDurationDTO>> subList = BaseUtils.getSubList(unOptimizeDurationList);
+                    subList.forEach(optimizeViewMapper::shortDurationBatchInsertList);
+                } else {
+                    optimizeViewMapper.shortDurationBatchInsertList(unOptimizeDurationList);
+                }
+            }
+            if (CollUtil.isNotEmpty(durationDTOList)) {
+                size = durationDTOList.size();
+                if (size > BaseUtils.BATCH_SIZE) {
+                    List<List<SpaceOptimizeDurationDTO>> subList = BaseUtils.getSubList(durationDTOList);
+                    subList.forEach(optimizeViewMapper::shortDurationBatchInsertList);
+                } else {
+                    optimizeViewMapper.shortDurationBatchInsertList(durationDTOList);
+                }
+            }
             return XServiceResult.OK;
         });
     }