From 736e79f7fbae0745a6921a53f78d0f0e27f59ae4 Mon Sep 17 00:00:00 2001
From: dongyukun <1208714201@qq.com>
Date: 星期五, 21 二月 2025 08:21:13 +0800
Subject: [PATCH] 时序数据归档定时任务
---
iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointArchivingTaskNet1h.java | 38 +++++++++
iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointArchivingTaskNetMonth.java | 36 +++++++++
iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointArchivingTaskNetShift.java | 36 +++++++++
iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointArchivingTaskNetDay.java | 36 +++++++++
iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointArchivingTaskNetYear.java | 36 +++++++++
5 files changed, 182 insertions(+), 0 deletions(-)
diff --git a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointArchivingTaskNet1h.java b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointArchivingTaskNet1h.java
new file mode 100644
index 0000000..27bac8f
--- /dev/null
+++ b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointArchivingTaskNet1h.java
@@ -0,0 +1,38 @@
+package com.iailab.module.data.job.task;
+
+import com.iailab.module.data.common.enums.ArcTypeEnum;
+import com.iailab.module.data.point.collection.PointCollector;
+import com.iailab.module.data.point.service.ArcPointDataService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import javax.annotation.Resource;
+import java.time.LocalDateTime;
+import java.util.Calendar;
+
+/**
+ * @description: Point归档1h
+ * @author: dyk
+ * @date: 2025/2/20 16:30
+ **/
+public class PointArchivingTaskNet1h implements ITask {
+ private Logger logger = LoggerFactory.getLogger(getClass());
+
+ private final String NET = "1h";
+
+ @Resource
+ private ArcPointDataService arcPointDataService;
+
+ @Override
+ public void run(String params){
+ logger.debug("PointArchivingTaskNet1h定时任务正在执行，参数为：{}", params);
+ try {
+ arcPointDataService.archiving(ArcTypeEnum.HOUR.getCode());
+ logger.info("PointArchivingTaskNet1h定时任务完成时间：" + LocalDateTime.now());
+ } catch (Exception ex) {
+ ex.printStackTrace();
+ logger.error("PointArchivingTaskNet1h定时任务失败时间：" + LocalDateTime.now());
+ }
+
+ }
+}
diff --git a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointArchivingTaskNetDay.java b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointArchivingTaskNetDay.java
new file mode 100644
index 0000000..7c3c84a
--- /dev/null
+++ b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointArchivingTaskNetDay.java
@@ -0,0 +1,36 @@
+package com.iailab.module.data.job.task;
+
+import com.iailab.module.data.common.enums.ArcTypeEnum;
+import com.iailab.module.data.point.service.ArcPointDataService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import javax.annotation.Resource;
+import java.time.LocalDateTime;
+
+/**
+ * @description: Point归档日
+ * @author: dyk
+ * @date: 2025/2/20 16:30
+ **/
+public class PointArchivingTaskNetDay implements ITask {
+ private Logger logger = LoggerFactory.getLogger(getClass());
+
+ private final String NET = "1h";
+
+ @Resource
+ private ArcPointDataService arcPointDataService;
+
+ @Override
+ public void run(String params){
+ logger.debug("PointArchivingTaskNetDay定时任务正在执行，参数为：{}", params);
+ try {
+ arcPointDataService.archiving(ArcTypeEnum.DAY.getCode());
+ logger.info("PointArchivingTaskNetDay定时任务完成时间：" + LocalDateTime.now());
+ } catch (Exception ex) {
+ ex.printStackTrace();
+ logger.error("PointArchivingTaskNetDay定时任务失败时间：" + LocalDateTime.now());
+ }
+
+ }
+}
diff --git a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointArchivingTaskNetMonth.java b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointArchivingTaskNetMonth.java
new file mode 100644
index 0000000..dd4b199
--- /dev/null
+++ b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointArchivingTaskNetMonth.java
@@ -0,0 +1,36 @@
+package com.iailab.module.data.job.task;
+
+import com.iailab.module.data.common.enums.ArcTypeEnum;
+import com.iailab.module.data.point.service.ArcPointDataService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import javax.annotation.Resource;
+import java.time.LocalDateTime;
+
+/**
+ * @description: Point归档月
+ * @author: dyk
+ * @date: 2025/2/20 16:30
+ **/
+public class PointArchivingTaskNetMonth implements ITask {
+ private Logger logger = LoggerFactory.getLogger(getClass());
+
+ private final String NET = "1h";
+
+ @Resource
+ private ArcPointDataService arcPointDataService;
+
+ @Override
+ public void run(String params){
+ logger.debug("PointArchivingTaskNetMonth定时任务正在执行，参数为：{}", params);
+ try {
+ arcPointDataService.archiving(ArcTypeEnum.MONTH.getCode());
+ logger.info("PointArchivingTaskNetMonth定时任务完成时间：" + LocalDateTime.now());
+ } catch (Exception ex) {
+ ex.printStackTrace();
+ logger.error("PointArchivingTaskNetMonth定时任务失败时间：" + LocalDateTime.now());
+ }
+
+ }
+}
diff --git a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointArchivingTaskNetShift.java b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointArchivingTaskNetShift.java
new file mode 100644
index 0000000..fd5405b
--- /dev/null
+++ b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointArchivingTaskNetShift.java
@@ -0,0 +1,36 @@
+package com.iailab.module.data.job.task;
+
+import com.iailab.module.data.common.enums.ArcTypeEnum;
+import com.iailab.module.data.point.service.ArcPointDataService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import javax.annotation.Resource;
+import java.time.LocalDateTime;
+
+/**
+ * @description: Point归档班
+ * @author: dyk
+ * @date: 2025/2/20 16:30
+ **/
+public class PointArchivingTaskNetShift implements ITask {
+ private Logger logger = LoggerFactory.getLogger(getClass());
+
+ private final String NET = "1h";
+
+ @Resource
+ private ArcPointDataService arcPointDataService;
+
+ @Override
+ public void run(String params){
+ logger.debug("PointArchivingTaskNetShift定时任务正在执行，参数为：{}", params);
+ try {
+ arcPointDataService.archiving(ArcTypeEnum.SHIFT.getCode());
+ logger.info("PointArchivingTaskNetShift定时任务完成时间：" + LocalDateTime.now());
+ } catch (Exception ex) {
+ ex.printStackTrace();
+ logger.error("PointArchivingTaskNetShift定时任务失败时间：" + LocalDateTime.now());
+ }
+
+ }
+}
diff --git a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointArchivingTaskNetYear.java b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointArchivingTaskNetYear.java
new file mode 100644
index 0000000..9db2c3c
--- /dev/null
+++ b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/task/PointArchivingTaskNetYear.java
@@ -0,0 +1,36 @@
+package com.iailab.module.data.job.task;
+
+import com.iailab.module.data.common.enums.ArcTypeEnum;
+import com.iailab.module.data.point.service.ArcPointDataService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import javax.annotation.Resource;
+import java.time.LocalDateTime;
+
+/**
+ * @description: Point归档年
+ * @author: dyk
+ * @date: 2025/2/20 16:30
+ **/
+public class PointArchivingTaskNetYear implements ITask {
+ private Logger logger = LoggerFactory.getLogger(getClass());
+
+ private final String NET = "1h";
+
+ @Resource
+ private ArcPointDataService arcPointDataService;
+
+ @Override
+ public void run(String params){
+ logger.debug("PointArchivingTaskNetYear定时任务正在执行，参数为：{}", params);
+ try {
+ arcPointDataService.archiving(ArcTypeEnum.YEAR.getCode());
+ logger.info("PointArchivingTaskNetYear定时任务完成时间：" + LocalDateTime.now());
+ } catch (Exception ex) {
+ ex.printStackTrace();
+ logger.error("PointArchivingTaskNetYear定时任务失败时间：" + LocalDateTime.now());
+ }
+
+ }
+}
--
Gitblit v1.9.3