elephant-scheduler/src/main/java/org/turro/scheduler/motor/DefaultTask.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2011 Lluis Turró Cutiller <http://www.turro.org/>
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */
package  org.turro.scheduler.motor;
 
import java.time.Duration;
import java.util.Date;
import java.util.concurrent.ScheduledFuture;
import org.turro.string.ObjectString;
import org.jdom.Element;
import org.turro.elephant.context.IConstructor;
import org.turro.elephant.impl.abstracts.AbstractImplementation;
 
@Deprecated
public abstract class DefaultTask extends AbstractImplementation implements ScheduledTask {
 
  private ScheduledFuture<?> future;
  private String description, implementation, data;
  private boolean active;
  private Date startDate, endDate, lastExecuted;
  private Constraints constraints = new Constraints();
 
  @Override
  public boolean isSystem() {
    return false;
  }
 
  @Override
  public boolean isDone() {
    return future == null ? true : future.isDone();
  }
 
  @Override
  public boolean isActive() {
    return active;
  }
 
  @Override
  public void setActive(boolean active) {
    this.active = active;
  }
 
  public Constraints getConstraints() {
    return constraints;
  }
 
  @Override
  public IConstructor getConstructor() {
    return constructor;
  }
 
  @Override
  public String getData() {
    return data;
  }
 
  @Override
  public void setData(String data) {
    this.data = data;
  }
 
  @Override
  public String getDescription() {
    return description;
  }
 
  @Override
  public void setDescription(String value) {
    description = value;
  }
 
  @Override
  public Date getEndDate() {
    return endDate;
  }
 
  @Override
  public void setEndDate(Date endDate) {
    this.endDate = endDate;
  }
 
  @Override
  public String getImplementation() {
    return implementation;
  }
 
  @Override
  public void setImplementation(String value) {
    implementation = value;
  }
 
  @Override
  public Date getStartDate() {
    return startDate;
  }
 
  @Override
  public void setStartDate(Date startDate) {
    this.startDate = startDate;
  }
 
  public void setLastExecuted(Date lastExecuted) {
    this.lastExecuted = lastExecuted;
  }
 
  @Override
  public boolean shouldRun(Date now) {
    if(enoughTimeLapse(now) && 
            (startDate == null || now.after(startDate)) &&
            (endDate == null || now.before(endDate)) && 
            constraints.isValid(now)) {
      return constraints.needsRefresh();
    }
    return false;
  }
 
  @Override
  public void doRun(Motor motor) {
    lastExecuted = new Date();
    //future = motor.runTask(this);
  }
 
  @Override
  public void stop() {
    if(future != null && !future.isDone()) {
      future.cancel(true);
    }
  }
 
  @Override
  public void readXML(Element root) {
    setImplementation(root.getAttributeValue("implementation"));
    String s = root.getAttributeValue("active");
    active = "true".equals(s);
    if(root.getAttributeValue("description") != null)
      setDescription(root.getAttributeValue("description"));
    if(root.getAttributeValue("start-date") != null)
      setStartDate((Date) ObjectString.parseString(root.getAttributeValue("start-date"), ObjectString.COMPRESSED_DATE_PATTERN, Date.class, false));
    if(root.getAttributeValue("end-date") != null)
      setEndDate((Date) ObjectString.parseString(root.getAttributeValue("end-date"), ObjectString.COMPRESSED_DATE_PATTERN, Date.class, false));
    if(root.getAttributeValue("data") != null)
      setData(root.getAttributeValue("data"));
    constraints.readXML(root);
  }
 
  @Override
  public void writeXML(Element root) {
    Element el = new Element("scheduled-task");
    el.setAttribute("name", getName());
    el.setAttribute("implementation", getImplementation());
    if(getDescription() != null) el.setAttribute("description", getDescription());
    el.setAttribute("active", active ? "true" : "false");
    if(getStartDate() != null) el.setAttribute("start-date", ObjectString.formatObject(getStartDate(), ObjectString.COMPRESSED_DATE_PATTERN, false));
    if(getEndDate() != null) el.setAttribute("end-date", ObjectString.formatObject(getEndDate(), ObjectString.COMPRESSED_DATE_PATTERN, false));
    if(getData() != null) el.setAttribute("data", getData());
    root.addContent(el);
    constraints.writeXML(el);
  }
  
  @Override
  public abstract String getName();
  @Override
  public abstract void run();
  @Override
  public abstract String getDataLabel();
 
  private boolean enoughTimeLapse(Date now) {
    return lastExecuted == null || (Duration.between(lastExecuted.toInstant(), now.toInstant()).getSeconds() >  (60 * 5));
  }
 
}