import org.quartz.Scheduler;
import org.quartz.ee.servlet.QuartzInitializerListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.config.PropertiesFactoryBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.ClassPathResource;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;
?
import java.io.IOException;
import java.util.Properties;
?
/**
?* quartz配置
?*/
@Configuration
public class SchedulerConfig {
?? ?
? ? @Bean(name="SchedulerFactory")
? ? public SchedulerFactoryBean schedulerFactoryBean() throws IOException {
? ? ? ? SchedulerFactoryBean factory = new SchedulerFactoryBean();
? ? ? ? factory.setAutoStartup(true);
? ? ? ? //factory.setStartupDelay(5);//延時5秒啟動
? ? ? ? return factory;
? ? }
?
? ? /*
? ? ?* quartz初始化監(jiān)聽器
? ? ?*/
? ? @Bean
? ? public QuartzInitializerListener executorListener() {
? ? ? ?return new QuartzInitializerListener();
? ? }
?
? ? /*
? ? ?* 通過SchedulerFactoryBean獲取Scheduler的實例
? ? ?*/
? ? @Bean(name="Scheduler")
? ? public Scheduler scheduler() throws IOException {
? ? ? ? return schedulerFactoryBean().getScheduler();
? ? }
?
}

/**
? ? ?* 新建任務(wù)
? ? ?* **/
? ? @ApiOperation(value = "Test-add", notes = "Test-add")
? ? @ApiImplicitParams({
? ? ? ? ? ? @ApiImplicitParam(name = "cruiseId", value = "巡航線id", required = true, paramType = "path"),
? ? ? ? ? ? @ApiImplicitParam(name = "jobName", value = "任務(wù)名稱", required = true, paramType = "query"),
? ? ? ? ? ? @ApiImplicitParam(name = "jobGroup", value = "任務(wù)分組", required = true, paramType = "query"),
? ? ? ? ? ? @ApiImplicitParam(name = "executeDate", value = "當前時間[yyyy-MM-dd HH:mm:ss]", required = true, paramType = "query", dataType = "Date")})
? ? @PutMapping("/test/add/{cruiseId}")
? ? public ResultBody test(@PathVariable("cruiseId") String cruiseId,@RequestParam("jobName") String jobName,@RequestParam("jobGroup") String jobGroup,
? ? ? ? ? ? ? ? ? ? ? ? ? ?@RequestParam(value = "executeDate")@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") Date executeDate) {
? ? ? ? try {
? ? ? ? ? ? SimpleDateFormat dateFormat1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
? ? ? ? ? ? //構(gòu)建job信息
? ? ? ? ? ? JobDetail job = JobBuilder.newJob(CruisePlanJob.class).withIdentity(jobName, jobGroup)
? ? ? ? ? ? ? ? ? ? ? ? ? ? .withDescription("巡航計劃").build();
? ? ? ? ? ? JobDataMap jobDataMap = job.getJobDataMap();
? ? ? ? ? ? jobDataMap.put("cruiseId", cruiseId);
? ? ? ? ? ? //CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("cron的表達式");
? ? ? ? ? ? Trigger trigger = TriggerBuilder.newTrigger()
? ? ? ? ? ? ? ? ? ? .withIdentity("trigger" + jobName, jobGroup)
? ? ? ? ? ? ? ? ? ? .startAt(executeDate)
? ? ? ? ? ? ? ? ? ? .withSchedule(SimpleScheduleBuilder.simpleSchedule().withRepeatCount(0))
? ? ? ? ? ? ? ? ? ? .build();
? ? ? ? ? ? //SimpleScheduleBuilder.simpleSchedule().withRepeatCount(0).withIntervalInSeconds(20)//每隔多少秒執(zhí)行一次； withRepeatCount 設(shè)置重復的次數(shù)
? ? ? ? ? ? //.startNow().withSchedule(cronScheduleBuilder)
? ? ? ? ? ? //交由Scheduler安排觸發(fā)
? ? ? ? ? ? scheduler.scheduleJob(job, trigger);
? ? ? ? ? ? System.out.println("startJob:"+JobKey.jobKey(jobName));
? ? ? ? } catch (Exception e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? return ResultBody.failed();
? ? ? ? }
? ? ? ? return ResultBody.ok();
? ? }
?
? ? /**
? ? ?* 刪除任務(wù)
? ? ?* **/
? ? @ApiOperation(value = "Test-remove", notes = "Test-remove")
? ? @ApiImplicitParams({
? ? ? ? ? ? @ApiImplicitParam(name = "jobName", value = "任務(wù)名稱", required = true, paramType = "query"),
? ? ? ? ? ? @ApiImplicitParam(name = "jobGroup", value = "任務(wù)分組", required = true, paramType = "query")})
? ? @GetMapping("/test/remove")
? ? public ResultBody remove(@RequestParam("jobName") String jobName,@RequestParam("jobGroup") String jobGroup) {
? ? ? ? try {
? ? ? ? ? ? TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroup);
? ? ? ? ? ? // 停止觸發(fā)器
? ? ? ? ? ? scheduler.pauseTrigger(triggerKey);
? ? ? ? ? ? // 移除觸發(fā)器
? ? ? ? ? ? scheduler.unscheduleJob(triggerKey);
? ? ? ? ? ? // 刪除任務(wù)
? ? ? ? ? ? boolean result = scheduler.deleteJob(JobKey.jobKey(jobName, jobGroup));
? ? ? ? ? ? System.out.println(result);
? ? ? ? ? ? System.out.println("removeJob:"+JobKey.jobKey(jobName));
? ? ? ? } catch (Exception e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? return ResultBody.failed();
? ? ? ? }
? ? ? ? return ResultBody.ok();
? ? }

@Slf4j
public class CruisePlanJob implements Job {
?
? @Override
? public void execute(JobExecutionContext context) {
? ? try{
? ? ? JobDataMap jdMap = context.getJobDetail().getJobDataMap();
? ? ? String cruiseId = (String) jdMap.get("cruiseId");
? ? ? String panId = (String) jdMap.get("panId");
? ? ? String userId = (String) jdMap.get("userId");
? ? ? String appId = (String) jdMap.get("appId");
? ? ? //TODO 邏輯待補充
?
? ? ? log.info("cruisePlan-CruisePlanJob-計劃執(zhí)行開始===>panId:{}---cruiseId:{}---appId:{}---userId:{}---resultBody:{}", panId, cruiseId, ?appId, ?userId, resultBody);
? ? }catch (Exception e){
? ? ? e.printStackTrace();
? ? }
? }
?
}

//恢復任務(wù) ?
scheduler.resumeJob(key);
//停止任務(wù)
scheduler.pauseJob(key);