From ac15907b5565bb7ee11749414efead3f252d6ec3 Mon Sep 17 00:00:00 2001
From: dongyukun <1208714201@qq.com>
Date: 星期五, 21 三月 2025 16:56:33 +0800
Subject: [PATCH] point天频率采集
---
iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointCollectTaskNetDay.java | 45 +++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 45 insertions(+), 0 deletions(-)
diff --git a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointCollectTaskNetDay.java b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointCollectTaskNetDay.java
new file mode 100644
index 0000000..7e9c125
--- /dev/null
+++ b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointCollectTaskNetDay.java
@@ -0,0 +1,45 @@
+package com.iailab.module.data.job.task;
+
+import com.iailab.module.data.point.collection.PointCollector;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.time.LocalDateTime;
+import java.util.Calendar;
+
+/**
+ * Point采集器日
+ * 59 23 * * *
+ *
+ * @author DongYukun
+ * @Description
+ * @createTime 2025年03月21日 16:54:00
+ */
+@Component("pointCollectTaskNetDay")
+public class PointCollectTaskNetDay implements ITask {
+ private final Logger logger = LoggerFactory.getLogger(getClass());
+
+ private static final String NET = "Day";
+
+ @Resource
+ private PointCollector pointCollector;
+
+ @Override
+ public void run(String params) {
+ // 59 23 * * * ?
+ logger.info("pointCollectTaskNetDay定时任务正在执行，参数为：{}", params);
+ try {
+ Calendar calendar = Calendar.getInstance();
+ calendar.set(Calendar.SECOND, 0);
+ calendar.set(Calendar.MILLISECOND, 0);
+ pointCollector.collect(calendar.getTime(), NET);
+ logger.info("pointCollectTaskNetDay定时任务完成时间：" + LocalDateTime.now());
+ } catch (Exception ex) {
+ ex.printStackTrace();
+ logger.error("pointCollectTaskNetDay定时任务失败时间：" + LocalDateTime.now());
+ }
+
+ }
+}
--
Gitblit v1.9.3