停止跟踪项目文件

david-PC\david

2018-06-12 cc7f57619fd09f68582b748a3580402717b84c50

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
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
package frame.schedule;
 
import org.apache.log4j.Logger;
import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.JobBuilder;
import org.quartz.JobDataMap;
import org.quartz.JobDetail;
import org.quartz.JobKey;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.TriggerKey;
import org.quartz.impl.StdSchedulerFactory;
 
import frame.config.Configer;
 
 
public class Schedule {
    private static Logger logger;
    private static Scheduler scheduler;
    public static boolean Terminated;
    
    static {
        logger = Logger.getLogger(Schedule.class);
        Terminated = false;
    }
    
    
    public static void startup() {
        try {
            SchedulerFactory factory = new StdSchedulerFactory(Configer.getPath_TimerConfig());
            scheduler = factory.getScheduler();
        } catch (Exception e) {
            logger.error(e.getMessage());
        }
    }
    
    public static void shutdown() {
        if (scheduler == null) {
            return;
        }
        
        try {
            Terminated = true;
            scheduler.shutdown();
        }
        catch (Exception e) {
            logger.error(e);
        }
    }
    
    public static void appendJob(IJob job) throws Exception {
        String runTime = job.getRunTime();
        
        if (runTime == null) {
            return;
        }
        
        JobKey jobKey = job.getJobKey();
        JobDetail jobDetail = JobBuilder.newJob(ScheduleJob.class).withIdentity(jobKey).build();
        
        JobDataMap dataMap = jobDetail.getJobDataMap();
        dataMap.put(IJob.Key_Job, job);
        
        TriggerKey triggerKey = job.getTriggerKey();
        TriggerBuilder<Trigger> triggerBuilder = TriggerBuilder.newTrigger();
        triggerBuilder.withIdentity(triggerKey);
        triggerBuilder.withSchedule(CronScheduleBuilder.cronSchedule(runTime));
        CronTrigger trigger = (CronTrigger)triggerBuilder.build();
 
        if (!scheduler.checkExists(jobKey)) {
            scheduler.scheduleJob(jobDetail, trigger);
        }
    }
 
    public static void deleteJob(IJob job) throws SchedulerException {
        JobKey jobKey = job.getJobKey();
        
        if (scheduler.checkExists(jobKey)) {
            scheduler.deleteJob(jobKey);
        }
    }
    
    public void start() throws SchedulerException {
        scheduler.start();
    }
    
    public void pause() throws SchedulerException {
        scheduler.pauseAll();
    }
    
    public void clear() throws SchedulerException {
        scheduler.clear();
    }
    
    public void isStarted() throws SchedulerException {
        scheduler.isStarted();
    }
    
    public void isShutdown() throws SchedulerException {
        scheduler.isShutdown();
    }
 
    public static boolean isActive() {
        // TODO Auto-generated method stub
        return false;
    }
    
}