package org.apache.turbine.services.schedule;
   
   /*
    * Licensed to the Apache Software Foundation (ASF) under one
    * or more contributor license agreements.  See the NOTICE file
    * distributed with this work for additional information
    * regarding copyright ownership.  The ASF licenses this file
    * to you under the Apache 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.apache.org/licenses/LICENSE-2.0
   *
   * 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.
   */
  
  import java.util.Date;
  import java.util.concurrent.atomic.AtomicBoolean;
  
  import org.apache.commons.lang3.StringUtils;
  import org.apache.turbine.modules.ScheduledJobLoader;
  import org.apache.turbine.util.TurbineException;
  import org.quartz.Job;
  import org.quartz.JobBuilder;
  import org.quartz.JobDetail;
  import org.quartz.JobExecutionContext;
  import org.quartz.JobExecutionException;
  import org.quartz.Trigger;
  import org.quartz.core.QuartzScheduler;
  
  /**
   * This implements a Turbine scheduled job model for the {@link QuartzScheduler}.
   *
   * @author <a href="mailto:tv@apache.org">Thomas Vandahl</a>
   */
  public class JobEntryQuartz implements JobEntry, Job
  {
      private int jobId;
      private Trigger jobTrigger;
      private JobDetail jobDetail;
      private String task;
      private boolean isnew = true;
      private AtomicBoolean active = new AtomicBoolean(false);
  
      /**
       * the default Quartz schedule group name for Turbine jobs
       */
      public static final String DEFAULT_JOB_GROUP_NAME = "TURBINE";
  
      /**
       * Default constructor
       */
      public JobEntryQuartz()
      {
          super();
      }
  
      /**
       * Constructor
       *
       * @param jobTrigger Job time table
       */
      public JobEntryQuartz(Trigger jobTrigger)
      {
          this(jobTrigger, JobBuilder
                  .newJob(JobEntryQuartz.class)
                  .withIdentity(jobTrigger.getJobKey().getName(), DEFAULT_JOB_GROUP_NAME).build());
      }
  
      /**
       * Constructor
       *
       * @param jobTrigger Job time table
       * @param jobDetail job details
       */
      public JobEntryQuartz(Trigger jobTrigger, JobDetail jobDetail)
      {
          this();
          setTask(jobTrigger.getJobKey().getName());
          this.jobTrigger = jobTrigger;
          this.jobDetail = jobDetail;
      }
  
      /**
       * Return true, if the entry is not yet persisted
       */
      @Override
      public boolean isNew()
      {
          boolean _isnew = isnew;
          isnew = false;
          return _isnew;
      }
  
     /**
      * Get the value of jobId.
      *
      * @return int
      */
     @Override
     public int getJobId()
     {
         return jobId;
     }
 
     /**
      * Set the value of jobId.
      *
      * @param v new value
      */
     @Override
     public void setJobId(int v)
     {
         this.jobId = v;
     }
 
     /**
      * Get the value of task.
      *
      * @return String
      */
     @Override
     public String getTask()
     {
         return task;
     }
 
     /**
      * Set the value of task.
      *
      * @param v new value
      */
     @Override
     public void setTask(String v)
     {
         this.task = v;
     }
 
     /**
      * @return the jobTrigger
      */
     public Trigger getJobTrigger()
     {
         return jobTrigger;
     }
 
     /**
      * @param jobTrigger the jobTrigger to set
      */
     public void setJobTrigger(Trigger jobTrigger)
     {
         this.jobTrigger = jobTrigger;
     }
 
     /**
      * @return the jobDetail
      */
     public JobDetail getJobDetail()
     {
         return jobDetail;
     }
 
     /**
      * @see java.lang.Comparable#compareTo(java.lang.Object)
      */
     @Override
     public int compareTo(JobEntry o)
     {
         return jobTrigger.compareTo(((JobEntryQuartz)o).getJobTrigger());
     }
 
     /**
      * @see org.apache.turbine.services.schedule.JobEntry#setActive(boolean)
      */
     @Override
     public void setActive(boolean isActive)
     {
         this.active.set(isActive);
     }
 
     /**
      * @see org.apache.turbine.services.schedule.JobEntry#isActive()
      */
     @Override
     public boolean isActive()
     {
         return active.get();
     }
 
     /**
      * @see org.apache.turbine.services.schedule.JobEntry#getNextRuntime()
      */
     @Override
     public long getNextRuntime()
     {
         return getNextRunDate().getTime();
     }
 
     /**
      * @see org.apache.turbine.services.schedule.JobEntry#getNextRunDate()
      */
     @Override
     public Date getNextRunDate()
     {
         return jobTrigger.getNextFireTime();
     }
 
     /**
      * @see org.apache.turbine.services.schedule.JobEntry#getNextRunAsString()
      */
     @Override
     public String getNextRunAsString()
     {
         return getNextRunDate().toString();
     }
 
     /**
      * @see org.apache.turbine.services.schedule.JobEntry#calcRunTime()
      */
     @Override
     public void calcRunTime() throws TurbineException
     {
         // do nothing
     }
 
     /**
      * @see org.quartz.Job#execute(org.quartz.JobExecutionContext)
      */
     @Override
     public void execute(JobExecutionContext context) throws JobExecutionException
     {
         if (active.compareAndSet(false, true) == false)
         {
             return;
         }
 
         try
         {
             String task = getTask();
             if (StringUtils.isEmpty(task))
             {
                 // This happens when the job is configured in the Quartz configuration file
                 task = context.getJobDetail().getKey().getName();
             }
             ScheduledJobLoader.getInstance().exec(this, task);
         }
         catch (Exception e)
         {
             throw new JobExecutionException("Error executing scheduled job #" +
                     getJobId() + ", task: " + getTask(), e);
         }
         finally
         {
             active.compareAndSet(true, false);
         }
     }
 }