Package com.dotmarketing.quartz

Examples of com.dotmarketing.quartz.CronScheduledTask


        Map<String, Object> params = new HashMap<String, Object>();
        params.put( "param1", "value1" );
        params.put( "param2", "value2" );

        //Creating our custom Quartz Job
        CronScheduledTask cronScheduledTask =
                new CronScheduledTask( JOB_NAME, JOB_GROUP, JOB_NAME, JOB_CLASS,
                        new Date(), null, CronTrigger.MISFIRE_INSTRUCTION_FIRE_ONCE_NOW,
                        params, CRON_EXPRESSION );

        //Schedule our custom job
        scheduleQuartzJob( cronScheduledTask );
View Full Code Here


        if(task!=null) {
            // delete the old one
            removeQuartzJob();
        }
        // create it
        task = new CronScheduledTask("timemachine", "timemachine", "Time Machine",
                TimeMachineJob.class.getName(), new Date(), null, 1, config, cronExp);
        try {
            QuartzUtils.scheduleTask(task);
        } catch (Exception ex) {
            throw new RuntimeException(ex);
View Full Code Here

          if (c.getIsRecurrent()) {
            List<ScheduledTask> jobs = QuartzUtils.getStandardScheduledTask(String.valueOf(c.getInode()), "Recurrent Campaign");
           
            if (jobs.size() > 0) {
             
              CronScheduledTask scheduler = (CronScheduledTask) jobs.get(0);
             
              SimpleDateFormat sdf = new SimpleDateFormat(WebKeys.DateFormats.DOTSCHEDULER_DATE2);

              String schedulerEndDateString = sdf.format(scheduler.getEndDate());
              if (!UtilMethods.isSet(schedulerEndDateString) && UtilMethods.isSet(c.getCompletedDate())) {

                Date now = new Date();
                if (now.before(c.getCompletedDate())) {
                  status = LanguageUtil.get(user, "campaign.status_Pending")+": " + modDateFormat.format(c.getCompletedDate());
                }
                else {
                  status = LanguageUtil.get(user, "campaign.status_Expired");
                }
              }
              else {
                String cronExpression = scheduler.getCronExpression();
                if (!UtilMethods.isSet(cronExpression)) {
                  status = LanguageUtil.get(user, "campaign.status_Expired");
                }
                else {
                  if (UtilMethods.isSet(c.getCompletedDate()))
View Full Code Here

      if (jobs.size() > 0) {

        SimpleDateFormat sdf = new SimpleDateFormat(WebKeys.DateFormats.DOTSCHEDULER_DATE2);

        CronScheduledTask job = (CronScheduledTask) jobs.get(0);
       
        String startDateStr = sdf.format(job.getStartDate());
        if (UtilMethods.isSet(startDateStr)) {
          cfform.setHaveStartDate(true);
          cfform.setStartDate(startDateStr);
        }
        else {
          cfform.setHaveStartDate(false);
          cfform.setStartDate(null);
        }

        String endDateStr = sdf.format(job.getEndDate());
        if (UtilMethods.isSet(endDateStr)) {
          cfform.setHaveEndDate(true);
          cfform.setEndDate(endDateStr);
        }
        else {
          cfform.setHaveEndDate(false);
          cfform.setEndDate(null);
        }

        String cronExpression = job.getCronExpression();
       
        if (UtilMethods.isSet(cronExpression)) {
          _populateForm(form, job);
        }
      } else {
View Full Code Here

        Logger.debug(this, "Inside EditSchedulerAction cmd=" + cmd);

    //get the user
    User user = _getUser(req);
   
    CronScheduledTask scheduler = null;
   
    try {
          Logger.debug(this, "I'm retrieving the schedule");
          scheduler = _retrieveScheduledJob(req, res, config, form);
    }
    catch (Exception ae) {
      _handleException(ae, req);
    }

    /*
     *  if we are saving,
     * 
     */
    if ((cmd != null) && cmd.equals(Constants.ADD)) {
      try {
       
        SchedulerForm schedulerForm = (SchedulerForm) form;
        boolean hasErrors = false;
       
        if (!UtilMethods.isSet(schedulerForm.getJobName())) {
          SessionMessages.add(req, "error", "message.Scheduler.invalidJobName");
          hasErrors = true;
        } else if (!schedulerForm.isEditMode() && (scheduler != null)) {
          SessionMessages.add(req, "error", "message.Scheduler.jobAlreadyExists");
          hasErrors = true;
        }
       
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm");
       
        Date endDate = null;
        if (schedulerForm.isHaveEndDate()) {
          try {
            endDate = sdf.parse(schedulerForm.getEndDate());
          } catch (Exception e) {
          }
        }
       
        if ((endDate != null) && !hasErrors) {
          Date startDate = null;
          if (schedulerForm.isHaveStartDate()) {
            try {
              startDate = sdf.parse(schedulerForm.getStartDate());
            } catch (Exception e) {
            }
          }
         
          if (startDate == null) {
            SessionMessages.add(req, "error", "message.Scheduler.startDateNeeded");
            hasErrors = true;
          } else if (endDate.before(startDate)) {
            SessionMessages.add(req, "error", "message.Scheduler.endDateBeforeStartDate");
            hasErrors = true;
          } else if (endDate.before(new Date())) {
            SessionMessages.add(req, "error", "message.Scheduler.endDateBeforeActualDate");
            hasErrors = true;
          }
        }
       
        if ((!UtilMethods.isSet(schedulerForm.getJavaClass())) && !hasErrors) {
          SessionMessages.add(req, "error", "message.Scheduler.invalidJavaClass");
          hasErrors = true;
        }
       
        if (Validator.validate(req,form,mapping) && !hasErrors) {
              Logger.debug(this, "I'm Saving the scheduler");
          if (_saveScheduler(req, res, config, form, user)) {
            scheduler = _retrieveScheduledJob(req, res, config, form);
           
            if (scheduler != null) {
              _populateForm(form, scheduler);
              schedulerForm.setMap(scheduler.getProperties());
            }
           
            String redirect = req.getParameter("referrer");
            if (UtilMethods.isSet(redirect)) {
              redirect = URLDecoder.decode(redirect, "UTF-8") + "&group=" + scheduler.getJobGroup();
              _sendToReferral(req, res, redirect);
              return;
            }
          } else {
            SessionMessages.clear(req);
            SessionMessages.add(req, "error", "message.Scheduler.invalidJobSettings");
            schedulerForm.setMap(getSchedulerProperties(req, schedulerForm));
            loadEveryDayForm(form, req);
          }
        } else {
          schedulerForm.setMap(getSchedulerProperties(req, schedulerForm));
          loadEveryDayForm(form, req);
        }
      }
      catch (Exception ae) {
        if (!ae.getMessage().equals(WebKeys.UNIQUE_SCHEDULER_EXCEPTION)){
          SessionMessages.add(req, "error", ae.getMessage());
          _handleException(ae, req);
        }
      }
    }

    /*
     * deleting the list, return to listing page
     * 
     */
    else if ((cmd != null) && cmd.equals(Constants.DELETE)) {
      try {
            Logger.debug(this, "I'm deleting the scheduler");
        _deleteScheduler(req, res, config, form,user);

      }
      catch (Exception ae) {
        try{
          _forceTodDeleteScheduler(req, res, config, form,user);
        }catch(Exception a){
          _handleException(a, req);
        }
      }
     
      String redirect = req.getParameter("referrer");
      if (UtilMethods.isSet(redirect)) {
        redirect = URLDecoder.decode(redirect, "UTF-8");
        _sendToReferral(req, res, redirect);
        return;
      }
    }

    /*
     * Copy copy props from the db to the form bean
     *
     */
    if ((cmd != null) && cmd.equals(Constants.EDIT)) {
      if (scheduler != null) {
        _populateForm(form, scheduler);
        SchedulerForm schedulerForm = (SchedulerForm) form;
        schedulerForm.setMap(scheduler.getProperties());
        schedulerForm.setEditMode(true);
        if (!UtilMethods.isSet(scheduler.getCronExpression())) {
          SessionMessages.add(req, "message", "message.Scheduler.jobExpired");
        }
      }
    }
   
View Full Code Here

      cronExpression = req.getParameter("cronExpression");
    }else{
      cronExpression =  cronSecondsField + " " + cronMinutesField + " " + cronHoursField + " " + cronDaysOfMonthField + " " + cronMonthsField + " " + cronDaysOfWeekField + " " + cronYearsField;
   

    CronScheduledTask job = new CronScheduledTask();
    job.setJobName(schedulerForm.getJobName());
    job.setJobGroup(schedulerForm.getJobGroup());
    job.setJobDescription(schedulerForm.getJobDescription());
    job.setJavaClassName(schedulerForm.getJavaClass());
    job.setProperties(properties);
    job.setStartDate(startDate);
    job.setEndDate(endDate);
    job.setCronExpression(cronExpression);
   
    try {// DOTCMS - 3897
      QuartzUtils.scheduleTask(job);
    } catch (Exception e) {     
      //e.printStackTrace();
View Full Code Here

TOP

Related Classes of com.dotmarketing.quartz.CronScheduledTask

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.