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 ++++-------------
shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleAirIndexMonthTask.java | 17 ++++----
shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleAirIndexClassTask.java | 39 ++++++-------------
3 files changed, 29 insertions(+), 62 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/RunScheduleAirIndexClassTask.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/RunScheduleAirIndexClassTask.java
index 5f30c33..e48c6c6 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/RunScheduleAirIndexClassTask.java
@@ -14,21 +14,21 @@
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.*;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.List;
/**
- * 压空，计算机组比功率，计算结果写入测点
- * 定时出发，5 0/1 * * * ?
+ * 压缩空气运行指标（班）
+ * 8*60=480 数据
+ * 每班更新，20 0 0,8,16 * * ? *
*
* @author PanZhibao
* @Description
- * @createTime 2024年12月31日
+ * @createTime 2025年01月03日
*/
-@Component("runScheduleAirClassMonthTask")
-public class RunScheduleAirClassMonthTask implements ITask {
+@Component("runScheduleAirIndexWeekTask")
+public class RunScheduleAirIndexClassTask implements ITask {
private Logger logger = LoggerFactory.getLogger(getClass());
@Resource
@@ -39,9 +39,8 @@
@Override
public void run(String params) {
- logger.info("RunScheduleAirTask，参数为：{}", params);
+ logger.info("RunScheduleAirIndexClassTask，参数为：{}", params);
try {
-
Calendar calendar = Calendar.getInstance();
calendar.set(Calendar.MILLISECOND, 0);
calendar.set(Calendar.SECOND, 0);
@@ -50,39 +49,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("RunScheduleAirIndexClassTask运行异常");
ex.printStackTrace();
}
- logger.info("RunScheduleAirTask运行完成");
+ logger.info("RunScheduleAirIndexClassTask运行完成");
}
}
\ No newline at end of file
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/RunScheduleAirIndexMonthTask.java
similarity index 87%
rename from shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleAirClassMonthTask.java
rename to shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleAirIndexMonthTask.java
index 5f30c33..1d66298 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/RunScheduleAirIndexMonthTask.java
@@ -20,15 +20,16 @@
import java.util.*;
/**
- * 压空，计算机组比功率，计算结果写入测点
- * 定时出发，5 0/1 * * * ?
+ * 压缩空气运行指标（月）
+ * 动态数据长度，月初到当天
+ * 每天更新，10 0 0 1/1 * ?
*
* @author PanZhibao
* @Description
* @createTime 2024年12月31日
*/
-@Component("runScheduleAirClassMonthTask")
-public class RunScheduleAirClassMonthTask implements ITask {
+@Component("runScheduleAirIndexMonthTask")
+public class RunScheduleAirIndexMonthTask implements ITask {
private Logger logger = LoggerFactory.getLogger(getClass());
@Resource
@@ -39,9 +40,8 @@
@Override
public void run(String params) {
- logger.info("RunScheduleAirTask，参数为：{}", params);
+ logger.info("RunScheduleAirIndexMonthTask，参数为：{}", params);
try {
-
Calendar calendar = Calendar.getInstance();
calendar.set(Calendar.MILLISECOND, 0);
calendar.set(Calendar.SECOND, 0);
@@ -50,7 +50,6 @@
logger.info("参数为空");
return;
}
-
// 根据条件查找方案
List<StScheduleSchemeDTO> schemeList = mcsApi.listScheduleScheme(ScheduleTriggerMethodEnum.JOB.getCode(), params);
if (CollectionUtils.isEmpty(schemeList)) {
@@ -80,9 +79,9 @@
}
logger.info(params + "调度方案执行完成");
} catch (Exception ex) {
- logger.error("RunScheduleAirTask运行异常");
+ logger.error("RunScheduleAirIndexMonthTask运行异常");
ex.printStackTrace();
}
- logger.info("RunScheduleAirTask运行完成");
+ logger.info("RunScheduleAirIndexMonthTask运行完成");
}
}
\ No newline at end of file
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