classes/scheduledTask/ScheduledTaskDAO.inc.php

<?php

// $Id: ScheduledTaskDAO.inc.php,v 1.12 2008/07/01 01:16:10 asmecher Exp $


import('scheduledTask.ScheduledTask');

class ScheduledTaskDAO extends DAO {
   function getLastRunTime($className) {
      $result = &$this->retrieve(
         'SELECT last_run FROM scheduled_tasks WHERE class_name = ?',
         $className
      );

      if ($result->RecordCount() == 0) {
         $returner = 0;
      } else {
         $returner = strtotime($this->datetimeFromDB($result->fields[0]));
      }

      $result->Close();
      unset($result);

      return $returner;
   }

   function updateLastRunTime($className, $timestamp = null) {
      $result = &$this->retrieve(
         'SELECT COUNT(*) FROM scheduled_tasks WHERE class_name = ?',
         $className
      );

      if (isset($result->fields[0]) && $result->fields[0] != 0) {
         if (isset($timestamp)) {
            $returner = $this->update(
               'UPDATE scheduled_tasks SET last_run = ' . $this->datetimeToDB($timestamp) . ' WHERE class_name = ?',
               array($className)
            );
         } else {
            $returner = $this->update('UPDATE scheduled_tasks SET last_run = NOW() WHERE class_name = ?', array($className));
         }

      } else {
         if (isset($timestamp)) {
            $returner = $this->update(
               sprintf('INSERT INTO scheduled_tasks (class_name, last_run)
               VALUES (?, %s)', $this->datetimeToDB($timestamp)),
               array($className)
            );
         } else {
            $returner = $this->update(
               'INSERT INTO scheduled_tasks (class_name, last_run)
               VALUES (?, NOW())',
               $className
            );
         }
      }

      $result->Close();
      unset($result);

      return $returner;
   }
}

?>

---