Browse Source

定时任务sql提交

jingyuanchao 1 year ago
parent
commit
c1b0fcdabd

+ 33 - 5
project_data/sql/0.1.1/quartz/quartz.sql

@@ -1,8 +1,36 @@
+delete
+from sys_job
+where invoke_target in
+      ('MediatorTask.baseDeviceInfo()',
+       'MediatorTask.dvsBaseInfo()',
+       'MediatorTask.alarmHostBaseInfo()',
+       'MediatorTask.videoIntegrityCheck()');
 
+-- 每日凌晨1点基础设备信息主动获取
+INSERT INTO `sys_job`(`job_name`, `job_group`, `invoke_target`, `cron_expression`, `misfire_policy`, `concurrent`,
+                      `status`, `create_by`, `create_time`, `update_by`, `update_time`)
+VALUES ('基础设备信息获取', 'DEFAULT', 'MediatorTask.baseDeviceInfo()', '0 0 1 * * ?', '1', '1', '0', NULL, now(), NULL,
+        NULL);
+
+-- 每日凌晨2点通道设备信息主动获取
+INSERT INTO `sys_job`(`job_name`, `job_group`, `invoke_target`, `cron_expression`, `misfire_policy`, `concurrent`,
+                      `status`, `create_by`, `create_time`, `update_by`, `update_time`)
+VALUES ('通道设备信息主动获取', 'DEFAULT', 'MediatorTask.dvsBaseInfo()', '0 0 2 * * ?', '1', '1', '0', NULL, now(),
+        NULL,
+        NULL);
+
+-- 每日凌晨2点子系统信息主动获取
+INSERT INTO `sys_job`(`job_name`, `job_group`, `invoke_target`, `cron_expression`, `misfire_policy`, `concurrent`,
+                      `status`, `create_by`, `create_time`, `update_by`, `update_time`)
+VALUES ('子系统信息主动获取', 'DEFAULT', 'MediatorTask.alarmHostBaseInfo()', '0 0 2 * * ?', '1', '1', '0', NULL, now(),
+        NULL,
+        NULL);
+
+
+-- 每日凌晨3点录像完整性主动获取
+INSERT INTO `sys_job`(`job_name`, `job_group`, `invoke_target`, `cron_expression`, `misfire_policy`, `concurrent`,
+                      `status`, `create_by`, `create_time`, `update_by`, `update_time`)
+VALUES ('录像完整性主动获取', 'DEFAULT', 'MediatorTask.videoIntegrityCheck()', '0 0 3 * * ?', '1', '1', '0', NULL,
+        now(), NULL, now());
 
 
-delete from sys_job where invoke_target in ('MediatorTask.videoIntegrityCheck()','MediatorTask.baseDeviceInfo()');
--- 每日凌晨2点获取设备基础数据
-INSERT INTO `sys_job`(`job_id`, `job_name`, `job_group`, `invoke_target`, `cron_expression`, `misfire_policy`, `concurrent`, `status`, `create_by`, `create_time`, `update_by`, `update_time`) VALUES (213, '录像完整性主动获取', 'DEFAULT', 'MediatorTask.videoIntegrityCheck()', '0 0 3 * * ?', '1', '1', '0', '景远超', '2024-07-11 10:14:50', '景远超', '2024-07-11 10:15:32');
--- 每日凌晨3点获取录像完整性数据
-INSERT INTO `sys_job`(`job_id`, `job_name`, `job_group`, `invoke_target`, `cron_expression`, `misfire_policy`, `concurrent`, `status`, `create_by`, `create_time`, `update_by`, `update_time`) VALUES (214, '基础设备信息获取', 'DEFAULT', 'MediatorTask.baseDeviceInfo()', '0 0 2 * * ?', '1', '1', '0', '景远超', '2024-07-24 14:31:01', '', NULL);

+ 2 - 2
soc-modules/soc-modules-job/src/main/java/com/xunmei/job/task/MediatorTask.java

@@ -41,7 +41,7 @@ public class MediatorTask {
         log.info("获取设备基础信息结束....,当前任务 id:{},当前时间:{},结果:{}", id, new Date(), JSON.toJSONString(result));
     }
 
-    //定时获取设备基础信息
+    //定时获取通道基础信息
     public void dvsBaseInfo() {
         String id = UUID.fastUUID().toString();
         log.info("开始获取dvs下基础信息,当前任务 id:{},当前时间:{}", id, new Date());
@@ -49,7 +49,7 @@ public class MediatorTask {
         log.info("获取获取dvs下基础信息....,当前任务 id:{},当前时间:{},结果:{}", id, new Date(), JSON.toJSONString(result));
     }
 
-    //定时获取设备基础信息
+    //定时获取子系统/防区基础信息
     public void alarmHostBaseInfo() {
         String id = UUID.fastUUID().toString();
         log.info("开始获取报警主机下基础信息,当前任务 id:{},当前时间:{}", id, new Date());