潘志宝
2025-02-07 9ab5e80bf7b73a4b006708895ee1ead980e1743f
定时任务过滤
已修改3个文件
16 ■■■■■ 文件已修改
iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/config/ScheduleConfig.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/config/ScheduleJobListConfig.java 12 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/utils/ScheduleJob.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/config/ScheduleConfig.java
@@ -31,7 +31,7 @@
        //JobStore配置
        prop.put("org.quartz.jobStore.class", "org.springframework.scheduling.quartz.LocalDataSourceJobStore");
        //集群配置
        prop.put("org.quartz.jobStore.isClustered", "true");
        prop.put("org.quartz.jobStore.isClustered", "false");
        prop.put("org.quartz.jobStore.clusterCheckinInterval", "15000");
        prop.put("org.quartz.jobStore.maxMisfiresToHandleAtATime", "1");
iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/config/ScheduleJobListConfig.java
@@ -15,9 +15,13 @@
    public static List<String> scheduleJobList = new ArrayList<>();
    public ScheduleJobListConfig() {
        scheduleJobList.add("CleanItemResultJsonTask");
        scheduleJobList.add("CleanMmPredictAlarmMessageTask");
        scheduleJobList.add("CleanScheduleRecordTask");
        scheduleJobList.add("CleanStScheduleSuggestTask");
        scheduleJobList.add("DevCameraDahuaTask");
        scheduleJobList.add("DevCameraHikvisionTask");
        scheduleJobList.add("PointCollectTaskNet1h");
        scheduleJobList.add("PointCollectTaskNet10");
        scheduleJobList.add("PointCollectTaskNet30");
        scheduleJobList.add("PointCollectTaskNet60");
        scheduleJobList.add("PointCollectTaskNetKIO10");
        scheduleJobList.add("PointCollectTaskNetKIO60");
    }
}
iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/job/utils/ScheduleJob.java
@@ -33,7 +33,7 @@
                get(ScheduleUtils.JOB_PARAM_KEY);
        // 过滤定时任务
        if (ScheduleJobListConfig.scheduleJobList.contains(scheduleJob.getBeanName())) {
        if (!ScheduleJobListConfig.scheduleJobList.contains(scheduleJob.getBeanName())) {
            logger.info("过滤定时任务,BeanName=" + scheduleJob.getBeanName());
            return;
        }