package com.megatim.fdxconvert.service;
|
|
import com.megatim.fdxconvert.model.Tache;
|
import com.megatim.fdxconvert.service.util.SchedulerUtil;
|
import java.util.List;
|
import java.util.logging.Level;
|
import java.util.logging.Logger;
|
import org.quartz.JobBuilder;
|
import org.quartz.JobDetail;
|
import org.quartz.Scheduler;
|
import org.quartz.SchedulerException;
|
import org.quartz.impl.StdSchedulerFactory;
|
|
/**
|
*
|
* @author MGT_DEV3
|
*/
|
public class TacheJobService {
|
|
private TacheJobService() {
|
}
|
|
private static Scheduler scheduler;
|
|
private static TacheJobService tacheJobService;
|
|
public static TacheJobService getInstance() {
|
|
if (tacheJobService == null) {
|
|
try {
|
|
scheduler = StdSchedulerFactory.getDefaultScheduler();
|
tacheJobService = new TacheJobService();
|
|
} catch (SchedulerException ex) {
|
}
|
}
|
|
return tacheJobService;
|
}
|
|
public void startJobs() {
|
|
try {
|
|
scheduler.start();
|
|
List<Tache> taches = TacheService.getInstance().getAll();
|
|
taches.forEach(t -> {
|
|
if (t.isActive()) {
|
|
//Creation concrète du Job (un Job concrèt se matérialise via la classe JobDetail)
|
JobDetail job = JobBuilder
|
.newJob(TacheJob.class)
|
.withIdentity(t.getLibelle())
|
.usingJobData("tacheId", t.getLibelle()).build();
|
|
//Ajout du Job crée dans l'ordonnanceur
|
try {
|
scheduler.scheduleJob(job, SchedulerUtil.buildTriggerForTache(t));
|
} catch (SchedulerException ex) {
|
Logger.getLogger(TacheJobService.class.getName()).log(Level.SEVERE, null, ex);
|
}
|
|
}
|
|
});
|
|
} catch (Exception ex) {
|
Logger.getLogger(TacheJobService.class.getName()).log(Level.SEVERE, null, ex);
|
}
|
|
}
|
|
public void restartJob() {
|
|
try {
|
|
scheduler.clear();
|
this.startJobs();
|
|
} catch (SchedulerException ex) {
|
Logger.getLogger(TacheJobService.class.getName()).log(Level.SEVERE, null, ex);
|
}
|
|
}
|
|
}
|
