From 17d9680846fdec953c086695ec0040e510998f4c Mon Sep 17 00:00:00 2001
From: 潘志宝 <979469083@qq.com>
Date: 星期五, 03 一月 2025 16:36:08 +0800
Subject: [PATCH] 压缩空气运行指标定时任务
---
shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleAirIndexWeekTask.java | 35 +++++++++--------------------------
1 files changed, 9 insertions(+), 26 deletions(-)
diff --git a/shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleAirClassMonthTask.java b/shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleAirIndexWeekTask.java
similarity index 61%
copy from shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleAirClassMonthTask.java
copy to shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleAirIndexWeekTask.java
index 5f30c33..4887b8f 100644
--- a/shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleAirClassMonthTask.java
+++ b/shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleAirIndexWeekTask.java
@@ -14,21 +14,19 @@
import org.springframework.util.CollectionUtils;
import javax.annotation.Resource;
-import java.time.LocalDate;
-import java.time.LocalDateTime;
-import java.time.temporal.ChronoUnit;
import java.util.*;
/**
- * 压空，计算机组比功率，计算结果写入测点
- * 定时出发，5 0/1 * * * ?
+ * 压缩空气运行指标（周）
+ * 最近7天的数据
+ * 每天更新，20 0 0 1/1 * ?
*
* @author PanZhibao
* @Description
- * @createTime 2024年12月31日
+ * @createTime 2025年01月03日
*/
-@Component("runScheduleAirClassMonthTask")
-public class RunScheduleAirClassMonthTask implements ITask {
+@Component("runScheduleAirIndexWeekTask")
+public class RunScheduleAirIndexWeekTask implements ITask {
private Logger logger = LoggerFactory.getLogger(getClass());
@Resource
@@ -39,9 +37,8 @@
@Override
public void run(String params) {
- logger.info("RunScheduleAirTask，参数为：{}", params);
+ logger.info("RunScheduleAirIndexWeekTask，参数为：{}", params);
try {
-
Calendar calendar = Calendar.getInstance();
calendar.set(Calendar.MILLISECOND, 0);
calendar.set(Calendar.SECOND, 0);
@@ -50,39 +47,25 @@
logger.info("参数为空");
return;
}
-
// 根据条件查找方案
List<StScheduleSchemeDTO> schemeList = mcsApi.listScheduleScheme(ScheduleTriggerMethodEnum.JOB.getCode(), params);
if (CollectionUtils.isEmpty(schemeList)) {
logger.info("方案为空");
return;
}
-
for (StScheduleSchemeDTO scheme : schemeList) {
MdkScheduleReqDTO dto = new MdkScheduleReqDTO();
dto.setScheduleTime(scheduleTime);
dto.setScheduleCode(scheme.getCode());
- LocalDateTime now = LocalDateTime.now();
- LocalDate startOfMonth = LocalDate.now().withDayOfMonth(1);
- LocalDateTime startOfMonthAtMidnight = startOfMonth.atStartOfDay();
- long timeDifference = ChronoUnit.MINUTES.between(startOfMonthAtMidnight, now);
- Map<Integer, Integer> dynamicDataLength = new HashMap<>();
- dynamicDataLength.put(1, (int) timeDifference);
- dynamicDataLength.put(2, (int) timeDifference);
- dynamicDataLength.put(3, (int) timeDifference);
- dto.setDynamicDataLength( dynamicDataLength);
- Map<String, String> dynamicSettings = new HashMap<>();
- dynamicSettings.put("embedDim", String.valueOf(timeDifference));
- dto.setDynamicSettings(dynamicSettings);
MdkScheduleRespDTO mdkScheduleRespDTO = mdkApi.doSchedule(dto);
// 结果写入测点
mdkApi.scheduleModelOut(mdkScheduleRespDTO);
}
logger.info(params + "调度方案执行完成");
} catch (Exception ex) {
- logger.error("RunScheduleAirTask运行异常");
+ logger.error("RunScheduleAirIndexWeekTask运行异常");
ex.printStackTrace();
}
- logger.info("RunScheduleAirTask运行完成");
+ logger.info("RunScheduleAirIndexWeekTask运行完成");
}
}
\ No newline at end of file
--
Gitblit v1.9.3