今天完成的事情: 

将定时任务demo 做修改融入到项目框架里面,

    /**
    * 更改任务状态
    *
    * @throws SchedulerException
    */
   @Override
   public void changeStatus(Long jobId, String cmd) throws SchedulerException,ServiceException, ServiceDaoException {
      ScheduleJob job = null;

         job = getObjectById(jobId);

      if (job == null) {
         return;
      }
      if ("stop".equals(cmd)) {
         deleteJob(job);
         job.setJobStatus(Integer.valueOf(Constant.STATUS_NOT_RUNNING));
      } else if ("start".equals(cmd)) {
         job.setJobStatus(Integer.valueOf(Constant.STATUS_RUNNING));
         addJob(job);
      }
      scheduleJobService.update(job);
   }

   /**
    * 更改任务 cron表达式
    *
    * @throws SchedulerException
    */
   @Override
   public void updateCron(Long jobId, String cron) throws SchedulerException,ServiceException, ServiceDaoException {
      ScheduleJob job = getObjectById(jobId);
      if (job == null) {
         return;
      }
      job.setCronExpression(Long.valueOf(cron));
      if (Constant.STATUS_RUNNING.equals(job.getJobStatus())) {
         updateJobCron(job);
      }
      scheduleJobService.update(job);

   }

   /**
    * 添加任务
    *
    * @param
    * @throws SchedulerException
    */
   @Override
   public void addJob(ScheduleJob job) throws SchedulerException,ServiceException, ServiceDaoException {
      if (job == null || !Constant.STATUS_RUNNING.equals(job.getJobStatus())) {
         return;
      }

      Scheduler scheduler = schedulerFactoryBean.getScheduler();
      log.debug(scheduler + ".......................................................................................add");
      TriggerKey triggerKey = TriggerKey.triggerKey(job.getJobName(), job.getJobGroup());

      CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);

      // 不存在，创建一个
      if (null == trigger) {
         Class clazz = Constant.CONCURRENT_IS.equals(job.getIsConcurrent()) ? QuartzJobFactory.class : QuartzJobFactoryDisallowConcurrentExecution.class;

         JobDetail jobDetail = JobBuilder.newJob(clazz).withIdentity(job.getJobName(), job.getJobGroup()).build();

         jobDetail.getJobDataMap().put("scheduleJob", job);

         CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(String.valueOf(job.getCronExpression()));

         trigger = TriggerBuilder.newTrigger().withIdentity(job.getJobName(), job.getJobGroup()).withSchedule(scheduleBuilder).build();

         scheduler.scheduleJob(jobDetail, trigger);
      } else {
         // Trigger已存在，那么更新相应的定时设置
         CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(String.valueOf(job.getCronExpression()));

         // 按新的cronExpression表达式重新构建trigger
         trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build();

         // 按新的trigger重新设置job执行
         scheduler.rescheduleJob(triggerKey, trigger);
      }
   }


   @Override
   @PostConstruct
   public void init() throws Exception ,ServiceException, ServiceDaoException{

      Scheduler scheduler = schedulerFactoryBean.getScheduler();

      // 这里获取任务信息数据
      List<ScheduleJob> jobList = scheduleJobService.getAllJob();

      for (ScheduleJob job : jobList) {
         addJob(job);
      }
   }

   /**
    * 获取所有计划中的任务列表
    *
    * @return
    * @throws SchedulerException
    */
   @Override
   public List<ScheduleJob> getAllJob() throws SchedulerException ,ServiceException, ServiceDaoException{
      Scheduler scheduler = schedulerFactoryBean.getScheduler();
      GroupMatcher<JobKey> matcher = GroupMatcher.anyJobGroup();
      Set<JobKey> jobKeys = scheduler.getJobKeys(matcher);
      List<ScheduleJob> jobList = new ArrayList<ScheduleJob>();
      for (JobKey jobKey : jobKeys) {
         List<? extends Trigger> triggers = scheduler.getTriggersOfJob(jobKey);
         for (Trigger trigger : triggers) {
            ScheduleJob job = new ScheduleJob();
            job.setJobName(jobKey.getName());
            job.setJobGroup(jobKey.getGroup());
            job.setDescription("触发器:" + trigger.getKey());
            Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());
            job.setJobStatus(Integer.valueOf(triggerState.name()));
            if (trigger instanceof CronTrigger) {
               CronTrigger cronTrigger = (CronTrigger) trigger;
               String cronExpression = cronTrigger.getCronExpression();
               job.setCronExpression(Long.valueOf(cronExpression));
            }
            jobList.add(job);
         }
      }
      return jobList;
   }

   /**
    * 所有正在运行的job
    *
    * @return
    * @throws SchedulerException
    */
   @Override
   public List<ScheduleJob> getRunningJob() throws SchedulerException,ServiceException, ServiceDaoException {
      Scheduler scheduler = schedulerFactoryBean.getScheduler();
      List<JobExecutionContext> executingJobs = scheduler.getCurrentlyExecutingJobs();
      List<ScheduleJob> jobList = new ArrayList<ScheduleJob>(executingJobs.size());
      for (JobExecutionContext executingJob : executingJobs) {
         ScheduleJob job = new ScheduleJob();
         JobDetail jobDetail = executingJob.getJobDetail();
         JobKey jobKey = jobDetail.getKey();
         Trigger trigger = executingJob.getTrigger();
         job.setJobName(jobKey.getName());
         job.setJobGroup(jobKey.getGroup());
         job.setDescription("触发器:" + trigger.getKey());
         Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());
         job.setJobStatus(Integer.valueOf(triggerState.name()));
         if (trigger instanceof CronTrigger) {
            CronTrigger cronTrigger = (CronTrigger) trigger;
            String cronExpression = cronTrigger.getCronExpression();
            job.setCronExpression(Long.valueOf(cronExpression));
         }
         jobList.add(job);
      }
      return jobList;
   }

   /**
    * 暂停一个job
    *
    * @param scheduleJob
    * @throws SchedulerException
    */
   @Override
   public void pauseJob(ScheduleJob scheduleJob) throws SchedulerException,ServiceException, ServiceDaoException {
      Scheduler scheduler = schedulerFactoryBean.getScheduler();
      JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());
      scheduler.pauseJob(jobKey);
   }

   /**
    * 恢复一个job
    *
    * @param scheduleJob
    * @throws SchedulerException
    */
   @Override
   public void resumeJob(ScheduleJob scheduleJob) throws SchedulerException,ServiceException, ServiceDaoException {
      Scheduler scheduler = schedulerFactoryBean.getScheduler();
      JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());
      scheduler.resumeJob(jobKey);
   }

   /**
    * 删除一个job
    *
    * @param scheduleJob
    * @throws SchedulerException
    */
   @Override
   public void deleteJob(ScheduleJob scheduleJob) throws SchedulerException ,ServiceException, ServiceDaoException{
      Scheduler scheduler = schedulerFactoryBean.getScheduler();
      JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());
      scheduler.deleteJob(jobKey);

   }

   /**
    * 立即执行job
    *
    * @param scheduleJob
    * @throws SchedulerException
    */
   @Override
   public void runAJobNow(ScheduleJob scheduleJob) throws SchedulerException,ServiceException, ServiceDaoException {
      Scheduler scheduler = schedulerFactoryBean.getScheduler();
      JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());
      scheduler.triggerJob(jobKey);
   }

   /**
    * 更新job时间表达式
    *
    * @param scheduleJob
    * @throws SchedulerException
    */
   @Override
   public void updateJobCron(ScheduleJob scheduleJob) throws SchedulerException,ServiceException, ServiceDaoException {
      Scheduler scheduler = schedulerFactoryBean.getScheduler();

      TriggerKey triggerKey = TriggerKey.triggerKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());

      CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);

      CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(String.valueOf(scheduleJob.getCronExpression()));

      trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build();

      scheduler.rescheduleJob(triggerKey, trigger);
   }


}

明天计划的事情:

跑通定时任务,准备小课堂

遇到的困难:

暂无.

任务进度：接口编写

任务开始时间：2017-12-12

预计demo时间:2017-02-09

是否有延期风险：暂无

禅道地址:http://task.ptteng.com/zentao/task-view-17095.html