ScheduledTaskTool.inc.php

<?php
 
define('TASKS_REGISTRY_FILE', 'registry/scheduledTasks.xml');
 
import('lib.pkp.classes.scheduledTask.ScheduledTask');
import('lib.pkp.classes.scheduledTask.ScheduledTaskHelper');
import('lib.pkp.classes.scheduledTask.ScheduledTaskDAO');
 
class ScheduledTaskTool extends CommandLineTool {
   var $file;
 
   var $taskDao;
 
   function __construct($argv = array()) {
      parent::__construct($argv);
 
      if (isset($this->argv[0])) {
         $this->file = $this->argv[0];
      } else {
         $this->file = TASKS_REGISTRY_FILE;
      }
 
      if (!file_exists($this->file) || !is_readable($this->file)) {
         printf("Tasks file \"%s\" does not exist or is not readable!\n", $this->file);
         exit(1);
      }
 
      $this->taskDao = DAORegistry::getDAO('ScheduledTaskDAO');
   }
 
   function usage() {
      echo "Script to run a set of scheduled tasks\n"
         . "Usage: {$this->scriptName} [tasks_file]\n";
   }
 
   function execute() {
      $this->parseTasks($this->file);
   }
 
   function parseTasks($file) {
      $xmlParser = new XMLParser();
      $tree = $xmlParser->parse($file);
 
      if (!$tree) {
         printf("Unable to parse file \"%s\"!\n", $file);
         exit(1);
      }
 
      foreach ($tree->getChildren() as $task) {
         $className = $task->getAttribute('class');
 
         $frequency = $task->getChildByName('frequency');
         if (isset($frequency)) {
            $canExecute = ScheduledTaskHelper::checkFrequency($className, $frequency);
         } else {
            // Always execute if no frequency is specified
            $canExecute = true;
         }
 
         if ($canExecute) {
            $this->executeTask($className, ScheduledTaskHelper::getTaskArgs($task));
         }
      }
   }
 
   function executeTask($className, $args) {
      // Load and execute the task
      if (!is_object($task = instantiate($className, null, null, 'execute', $args))) {
         fatalError('Cannot instantiate task class.');
      }
      $this->taskDao->updateLastRunTime($className);
      $task->execute();
   }
}