package org.kuali.ole.batch.rule;
   
   import org.apache.log4j.Logger;
   import org.kuali.ole.OLEConstants;
   import org.kuali.ole.deliver.bo.OleBatchJobBo;
   import org.kuali.rice.core.api.resourceloader.GlobalResourceLoader;
   import org.kuali.rice.krad.maintenance.MaintenanceDocument;
   import org.kuali.rice.krad.rules.MaintenanceDocumentRuleBase;
   import org.quartz.JobDetail;
  import org.quartz.SchedulerException;
  import org.quartz.impl.StdScheduler;
  import org.springframework.scheduling.quartz.CronTriggerBean;
  
  /**
   * Created with IntelliJ IDEA.
   * User: ?
   * Date: 3/1/13
   * Time: 8:18 PM
   * To change this template use File | Settings | File Templates.
   */
  public class OleBatchJobRule extends MaintenanceDocumentRuleBase {
  
      private static final Logger LOG = Logger.getLogger(OleBatchJobRule.class);
      @Override
      protected boolean processCustomSaveDocumentBusinessRules(MaintenanceDocument document) {
          boolean isValid = true;
          OleBatchJobBo oleBatchJobBo = (OleBatchJobBo) document.getNewMaintainableObject().getDataObject();
  
          isValid &= validateCronExpression(oleBatchJobBo);
          return isValid;
      }
  
      /**
       *  This method  validates duplicate completeness Id and return boolean value.
       * @param oleBatchJobBo
       * @return  boolean
       */
      private boolean validateCronExpression(OleBatchJobBo oleBatchJobBo) {
  
          boolean isJobModified=true;
          StdScheduler scheduler = (StdScheduler) GlobalResourceLoader.getService("scheduler");
  
          if(!oleBatchJobBo.isJobEnableStatus()){
              JobDetail jobDetail = (JobDetail) GlobalResourceLoader.getService(oleBatchJobBo.getJobTriggerName());
              try {
                  scheduler.deleteJob(jobDetail.getName(),jobDetail.getGroup()) ;
              } catch (SchedulerException e) {
                  isJobModified=false;
                  e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
              }
          }
          else {
              try {
  
                  JobDetail jobDetail = (JobDetail) GlobalResourceLoader.getService(oleBatchJobBo.getJobTriggerName());
                  CronTriggerBean cronTriggerBean = new CronTriggerBean();
                  boolean valid=   org.quartz.CronExpression.isValidExpression(oleBatchJobBo.getJobCronExpression());
                  if(valid){
                      cronTriggerBean.setName(oleBatchJobBo.getJobTriggerName()+"Trigger");
                      cronTriggerBean.setCronExpression(oleBatchJobBo.getJobCronExpression());
                      cronTriggerBean.setJobName(jobDetail.getName());
                      cronTriggerBean.setJobGroup(jobDetail.getGroup());
                      cronTriggerBean.setJobDetail(jobDetail);
                      String [] jobNames=scheduler.getJobNames(jobDetail.getGroup());
                      for (String jobName:jobNames){
                          if(jobName.equals(jobDetail.getName())) {
                              scheduler.deleteJob(jobDetail.getName(),jobDetail.getGroup());
                          }
                      }
  
                      try{
                          scheduler.scheduleJob(jobDetail, cronTriggerBean);
                      }
                      catch (Exception e){
                          isJobModified=false;
                          LOG.error("Batch Job Exception :: "+e);
                      }
  
  
                  }else {
                      isJobModified=false;
                      this.putFieldError(OLEConstants.INVALID_CRON, "error.invalid.cron");
                  }
  
              }
              catch (Exception e) {
                  isJobModified=false;
                  LOG.error("Batch Job Exception :: "+e);
              }
  
  
  
          }
  
          return isJobModified;
      }
  }