package org.kuali.ole.deliver.service;
   
   import org.apache.log4j.Logger;
   import org.kuali.ole.deliver.bo.OleBatchJobBo;
   import org.kuali.rice.core.api.resourceloader.GlobalResourceLoader;
   import org.kuali.rice.krad.service.KRADServiceLocator;
   import org.quartz.JobDetail;
   import org.quartz.impl.StdScheduler;
   import org.springframework.scheduling.quartz.CronTriggerBean;
  
  import java.util.HashMap;
  import java.util.List;
  import java.util.Map;
  
  /**
   * Created with IntelliJ IDEA.
   * User: ?
   * Date: 3/5/13
   * Time: 5:28 PM
   * To change this template use File | Settings | File Templates.
   */
  public class OleBatchJobService {
  
      private static final Logger LOG = Logger.getLogger(OleBatchJobService.class);
  
      public OleBatchJobService() {
          addAvailableJobsToScheduler();
      }
  
      /*
       This method is used to add the active job  to the scheduler.
       */
      public void addAvailableJobsToScheduler() {
  
          Map<String, String> batchMap = new HashMap<String, String>();
          batchMap.put("jobEnableStatus", "true");
          List<OleBatchJobBo> oleDeliverBatchJobBoList = (List<OleBatchJobBo>) KRADServiceLocator.getBusinessObjectService().findMatching(OleBatchJobBo.class, batchMap);
          StdScheduler scheduler = (StdScheduler) GlobalResourceLoader.getService("scheduler");
  
          if (oleDeliverBatchJobBoList.size() > 0) {
              for (OleBatchJobBo oleDeliverBatchJobBo : oleDeliverBatchJobBoList) {
  
                  try {
                      JobDetail jobDetail = (JobDetail) GlobalResourceLoader.getService(oleDeliverBatchJobBo.getJobTriggerName());
                      CronTriggerBean cronTriggerBean = new CronTriggerBean();
                      cronTriggerBean.setName(oleDeliverBatchJobBo.getJobTriggerName() + "Trigger");
                      cronTriggerBean.setCronExpression(oleDeliverBatchJobBo.getJobCronExpression());
                      cronTriggerBean.setJobName(jobDetail.getName());
                      cronTriggerBean.setJobGroup(jobDetail.getGroup());
                      cronTriggerBean.setJobDetail(jobDetail);
                      try {
                          scheduler.scheduleJob(jobDetail, cronTriggerBean);
                          if (LOG.isInfoEnabled()){
                              LOG.info(jobDetail.getName() + " job is scheduled");
                          }
                      } catch (Exception e) {
                          scheduler.rescheduleJob(oleDeliverBatchJobBo.getJobTriggerName(), jobDetail.getName(), cronTriggerBean);
                      }
                  } catch (Exception e) {
                      LOG.error(e.getMessage() + " : Unable to schedule the job", e);
                      //To change body of catch statement use File | Settings | File Templates.
                  }
              }
          }
  
      }
  }