/**
    * Copyright 2004-2013 The Kuali Foundation
    *
    * Licensed under the Educational Community License, Version 2.0 (the "License");
    * you may not use this file except in compliance with the License.
    * You may obtain a copy of the License at
    *
    * http://www.opensource.org/licenses/ecl2.php
    *
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS,
   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   * See the License for the specific language governing permissions and
   * limitations under the License.
   */
  package org.kuali.hr.time.batch;
  
  import java.util.ArrayList;
  import java.util.Date;
  import java.util.List;
  
  import org.apache.commons.lang.StringUtils;
  import org.apache.log4j.Logger;
  import org.kuali.hr.time.calendar.CalendarEntries;
  import org.kuali.hr.time.service.base.TkServiceLocator;
  import org.kuali.hr.time.util.TKUtils;
  import org.kuali.hr.time.util.TkConstants;
  
  public class BatchJobManagerThread extends Thread {
      private static final Logger LOG = Logger.getLogger(BatchJobManagerThread.class);
  
      int startupSleep = 120;
      //This represents a number of days on both sides of today
      int numOfDaysToPoll = 30;
      int secondsToSleep = 120;
  
      public BatchJobManagerThread(int secondsToSleep, int numberOfDaysToPoll, int startupSleep) {
          this.numOfDaysToPoll = numberOfDaysToPoll;
          this.secondsToSleep = secondsToSleep;
          this.startupSleep = startupSleep;
      }
  
      @Override
      public void run() {
  
          try {
              Thread.sleep(1000 * startupSleep);
          } catch (Exception e) {
              LOG.error(e);
          }
  
          while (true) {
              Date asOfDate = TKUtils.getCurrentDate();
              List<CalendarEntries> calendarEntries = TkServiceLocator.getCalendarEntriesService().getCurrentCalendarEntryNeedsScheduled(numOfDaysToPoll, asOfDate);
  
              LOG.info("Scanning for batch jobs to run: (" + asOfDate.toString() + ")");
  
              List<BatchJob> batchJobs = new ArrayList<BatchJob>();
              for (CalendarEntries calendarEntry : calendarEntries) {
                  List<BatchJob> existingBatchJobs = TkServiceLocator.getBatchJobService().getBatchJobs(calendarEntry.getHrCalendarEntriesId());
  
                  if (calendarEntry.getBeginPeriodDateTime() != null && calendarEntry.getEndPeriodDateTime() != null && !jobExists(existingBatchJobs, TkConstants.BATCH_JOB_NAMES.BATCH_APPROVE_MISSED_PUNCH)) {
                      BatchJob job = new BatchApproveMissedPunchJob(calendarEntry);
                      TkServiceLocator.getBatchJobService().saveBatchJob(job);
                      batchJobs.add(job);
                  }
                  
                  if (calendarEntry.getBatchInitiateDate() != null && !jobExists(existingBatchJobs, TkConstants.BATCH_JOB_NAMES.INITIATE)) {
                      BatchJob job = new InitiateBatchJob(calendarEntry);
                      TkServiceLocator.getBatchJobService().saveBatchJob(job);
                      batchJobs.add(job);
                  }
                  
                  if (calendarEntry.getBatchEndPayPeriodDate() != null && !jobExists(existingBatchJobs, TkConstants.BATCH_JOB_NAMES.PAY_PERIOD_END)) {
                      BatchJob job = new PayPeriodEndBatchJob(calendarEntry);
                      TkServiceLocator.getBatchJobService().saveBatchJob(job);
                      batchJobs.add(job);
                  }
  
  // TODO: Batch jobs going to exception status
  //                if (calendarEntry.getBatchEmployeeApprovalDate() != null && !jobExists(existingBatchJobs, TkConstants.BATCH_JOB_NAMES.APPROVE)) {
  //                    BatchJob job = new EmployeeApprovalBatchJob(calendarEntry);
  //                    TkServiceLocator.getBatchJobService().saveBatchJob(job);
  //                    batchJobs.add(job);
  //                }
  //
  //                if (calendarEntry.getBatchSupervisorApprovalDate() != null && !jobExists(existingBatchJobs, TkConstants.BATCH_JOB_NAMES.SUPERVISOR_APPROVAL)) {
  //                    BatchJob job = new SupervisorApprovalBatchJob(calendarEntry);
  //                    TkServiceLocator.getBatchJobService().saveBatchJob(job);
  //                    batchJobs.add(job);
  //                }
              }
  
              for (BatchJob batchJob : batchJobs) {
              	batchJob.runJob();
              }
  
              try {
                  Thread.sleep(1000 * secondsToSleep);
             } catch (Exception e) {
                 LOG.error(e);
             }
         }
     }
 
     private boolean jobExists(List<BatchJob> batchJobs, String batchJobName) {
         for (BatchJob batchJob : batchJobs) {
             if (StringUtils.equals(batchJob.getBatchJobName(), batchJobName)) {
                 return true;
             }
         }
 
         return false;
     }
 
 
 
 }