source: trunk/Modules/Scheduler/Scheduler.php@ 781

<?php

class ModuleScheduler extends AppModule
{
  function __construct($System)
  {
    parent::__construct($System);
    $this->Name = 'Scheduler';
    $this->Version = '1.0';
    $this->Creator = 'Chronos';
    $this->License = 'GNU/GPL';
    $this->Description = 'Allow to setup and execute planned and recurring tasks';
    $this->Dependencies = array();
  }

  function DoStart()
  {
    $this->System->FormManager->RegisterClass('Scheduler', array(
      'Title' => 'Plánovač',
      'Table' => 'Scheduler',
      'DefaultSortColumn' => 'ScheduledTime',
      'Items' => array(
        'Name' => array('Type' => 'String', 'Caption' => 'Jméno', 'Default' => ''),
        'Enabled' => array('Type' => 'Boolean', 'Caption' => 'Povoleno', 'Default' => '0'),
        'ScheduledTime' => array('Type' => 'DateTime', 'Caption' => 'Plánovaný čas', 'Default' => ''),
        'Action' => array('Type' => 'TSchedulerAction', 'Caption' => 'Akce', 'Default' => ''),
        'Period' => array('Type' => 'Integer', 'Caption' => 'Opakovat po', 'Default' => '', 'Null' => true, 'Suffix' => 'sekund'),
        'LastExecutedTime' => array('Type' => 'DateTime', 'Caption' => 'Čas posledního spuštění', 'Default' => '', 'ReadOnly' => true),
        'Duration' => array('Type' => 'TimeDiff', 'Caption' => 'Trvání', 'Default' => '', 'ReadOnly' => true),
        'Log' => array('Type' => 'Text', 'Caption' => 'Poslední záznam', 'Default' => '', 'ReadOnly' => true, 'NotInList' => true),
      ),
    ));
    $this->System->FormManager->RegisterClass('SchedulerAction', array(
      'Title' => 'Akce plánovače',
      'Table' => 'SchedulerAction',
      'DefaultSortColumn' => 'Name',
      'ReadOnly' => true,
      'Items' => array(
        'Name' => array('Type' => 'String', 'Caption' => 'Jméno', 'Default' => '', 'ReadOnly' => true),
        'Class' => array('Type' => 'String', 'Caption' => 'Vykonat třídu', 'Default' => '', 'ReadOnly' => true),
      ),
    ));
    $this->System->FormManager->RegisterFormType('TSchedulerAction', array(
      'Type' => 'Reference',
      'Table' => 'SchedulerAction',
      'Id' => 'Id',
      'Name' => 'Name',
      'Filter' => '1',
    ));
    $this->System->RegisterCommandLine('run-scheduler', array('ModuleScheduler', 'Run'));
  }

  function DoInstall()
  {
  }

  function DoUnInstall()
  {
  }

  function Run($Parameters)
  {
    while(true)
    {
      $DbResult = $this->Database->query('SELECT `Scheduler`.*, `SchedulerAction`.`Class` AS `Class` FROM `Scheduler` '.
        'LEFT JOIN `SchedulerAction` ON `SchedulerAction`.`Id` = `Scheduler`.`Action` '.
        'WHERE (`Scheduler`.`Enabled`=1) AND ( '.
        '(`Scheduler`.`ScheduledTime` < "'.TimeToMysqlDateTime(time()).'") OR '.
        '(`Scheduler`.`ScheduledTime` IS NULL))');
      while($DbRow = $DbResult->fetch_assoc())
      {
        echo('Executing '.$DbRow['Name']."\n");
        $Output = '';
        $StartTime = time();
        if(class_exists($DbRow['Class']))
        {
          $Class = new $DbRow['Class']($this->System);
          $Output = $Class->Execute();
          echo($Output);
        } else echo('Class '.$DbRow['Class'].' not found'."\n");
        $StopTime = time();
        $Duration = $StopTime - $StartTime;
        $this->Database->update('Scheduler', 'Id='.$DbRow['Id'],
          array('Log' => $Output, 'LastExecutedTime' => TimeToMysqlDateTime($StartTime),
            'Duration' => $Duration));
        if($DbRow['Period'] != '') {
          if($DbRow['ScheduledTime'] == '') $NewScheduledTime = $StartTime + $DbRow['Period'];
            else $NewScheduledTime = MysqlDateTimeToTime($DbRow['ScheduledTime']) + $DbRow['Period'];
          if($NewScheduledTime < $StopTime) $NewScheduledTime = $StopTime + $DbRow['Period'];
          $this->Database->update('Scheduler', 'Id='.$DbRow['Id'],
            array('ScheduledTime' => TimeToMysqlDateTime($NewScheduledTime)));
        }
      }
      echo('.');
      sleep(1);
    }
  }
}

class SchedulerTask extends Model
{
  function Execute()
  {
  }
}


class ScheduleTaskTest extends SchedulerTask
{
  function Execute()
  {
    $Output = '#';
    return($Output);
  }
}