2.7.18

shikeyin

2024-01-11 65da8373531677b1c37a98f53eaa30c892f35e5a

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
package com.iplatform.scheduler.util;
 
import com.iplatform.model.po.S_scheduler;
import com.walker.infrastructure.utils.ClassUtils;
import com.walker.infrastructure.utils.StringUtils;
import com.walker.scheduler.Option;
import com.walker.scheduler.ScheduleEngine;
import com.walker.scheduler.impl.ForeverScheduler;
import com.walker.scheduler.impl.TimedScheduler;
import com.walker.scheduler.util.OptionUtils;
 
import java.lang.reflect.Constructor;
import java.util.ArrayList;
import java.util.List;
 
public class SchedulerUtils {
 
    /**
     * 根据数据库存储的调度信息记录，组装出来一个调度选项对象
     * @param schedule
     * @return
     */
    public static final Option combineOption(S_scheduler schedule){
        Option option = new Option();
        if(schedule.getTime_type().equals(Option.TimeType.RANGE.getIndex())){
            String[] ranges = schedule.getRanges().split(StringUtils.SEPARATOR_SEMI_COLON);
            if(ranges == null || ranges.length == 0){
                throw new IllegalArgumentException("时间段范围不存在，输入错误：" + schedule.getRanges());
            }
 
            List<Integer[]> timeRanges = new ArrayList<Integer[]>(ranges.length);
 
            for(String r : ranges){
                String[] array = r.split(StringUtils.DEFAULT_SPLIT_SEPARATOR);
                if(array.length != 2){
                    throw new IllegalArgumentException("时间数组错误，必须是两个数字");
                }
                timeRanges.add(new Integer[]{Integer.parseInt(array[0]), Integer.parseInt(array[1])});
            }
            option.setRangeTime(timeRanges);
        }
 
        option.setTimeType(Option.TimeType.getObject(schedule.getTime_type()));
        option.setPeriodType(Option.PeriodType.getObject(schedule.getPeriod_type()));
        option.setExactlyTime(schedule.getYear(), schedule.getMonth(), schedule.getDay(), schedule.getHour());
        return option;
    }
 
    /**
     * 创建一个调度器对象
     * @param schedule 数据库记录的调度器配置信息
     * @param schedulerEngine 调度引擎
     * @return
     * @throws Exception
     */
    @SuppressWarnings("unchecked")
    public static final TimedScheduler createScheduler(S_scheduler schedule, ScheduleEngine schedulerEngine) throws Exception{
        Class<?> schedulerClass = ClassUtils.forName(schedule.getClass_name(), SchedulerUtils.class.getClassLoader());
        Constructor<TimedScheduler> constructor = (Constructor<TimedScheduler>)schedulerClass.getConstructor(int.class, String.class);
 
        TimedScheduler listeningScheduler = constructor.newInstance(schedule.getId().intValue(), schedule.getName());
//        listeningScheduler.setScheduleEngine(new EmptySchedulerEngine());
        listeningScheduler.setScheduleEngine(schedulerEngine);
//        listeningScheduler.setId(schedule.getId().intValue());
//        listeningScheduler.setName(schedule.getName());
        listeningScheduler.setMaxFailedTimes(3);
        listeningScheduler.setTaskTerminateCondition(false);
        listeningScheduler.setTimeInterval(schedule.getInterval_time());
        listeningScheduler.setWaitSleepTime(schedule.getSleep_time());
 
        if(listeningScheduler instanceof ForeverScheduler){
            ForeverScheduler scheduler = (ForeverScheduler)listeningScheduler;
            scheduler.setOption(OptionUtils.combineEveryDay24HourOption());
        } else {
            listeningScheduler.setOption(combineOption(schedule));
        }
        return listeningScheduler;
    }
 
}