classes/article/log/ArticleEventLogDAO.inc.php

<?php

// $Id: ArticleEventLogDAO.inc.php,v 1.21 2008/07/01 01:16:09 asmecher Exp $


import ('article.log.ArticleEventLogEntry');

class ArticleEventLogDAO extends DAO {
   function &getLogEntry($logId, $articleId = null) {
      if (isset($articleId)) {
         $result = &$this->retrieve(
            'SELECT * FROM article_event_log WHERE log_id = ? AND article_id = ?',
            array($logId, $articleId)
         );
      } else {
         $result = &$this->retrieve(
            'SELECT * FROM article_event_log WHERE log_id = ?', $logId
         );
      }

      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = &$this->_returnLogEntryFromRow($result->GetRowAssoc(false));
      }

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

      return $returner;
   }

   function &getArticleLogEntries($articleId, $rangeInfo = null) {
      $returner = &$this->getArticleLogEntriesByAssoc($articleId, null, null, $rangeInfo);
      return $returner;
   }

   function &getArticleLogEntriesByAssoc($articleId, $assocType = null, $assocId = null, $rangeInfo = null) {
      $params = array($articleId);
      if (isset($assocType)) {
         array_push($params, $assocType);
         if (isset($assocId)) {
            array_push($params, $assocId);
         }
      }

      $result = &$this->retrieveRange(
         'SELECT * FROM article_event_log WHERE article_id = ?' . (isset($assocType) ? ' AND assoc_type = ?' . (isset($assocId) ? ' AND assoc_id = ?' : '') : '') . ' ORDER BY log_id DESC',
         $params, $rangeInfo
      );

      $returner = &new DAOResultFactory($result, $this, '_returnLogEntryFromRow');
      return $returner;
   }

   function &_returnLogEntryFromRow(&$row) {
      $entry = &new ArticleEventLogEntry();
      $entry->setLogId($row['log_id']);
      $entry->setArticleId($row['article_id']);
      $entry->setUserId($row['user_id']);
      $entry->setDateLogged($this->datetimeFromDB($row['date_logged']));
      $entry->setIPAddress($row['ip_address']);
      $entry->setLogLevel($row['log_level']);
      $entry->setEventType($row['event_type']);
      $entry->setAssocType($row['assoc_type']);
      $entry->setAssocId($row['assoc_id']);
      $entry->setMessage($row['message']);

      HookRegistry::call('ArticleEventLogDAO::_returnLogEntryFromRow', array(&$entry, &$row));

      return $entry;
   }

   function insertLogEntry(&$entry) {
      if ($entry->getDateLogged() == null) {
         $entry->setDateLogged(Core::getCurrentDate());
      }
      if ($entry->getIPAddress() == null) {
         $entry->setIPAddress(Request::getRemoteAddr());
      }
      $this->update(
         sprintf('INSERT INTO article_event_log
            (article_id, user_id, date_logged, ip_address, log_level, event_type, assoc_type, assoc_id, message)
            VALUES
            (?, ?, %s, ?, ?, ?, ?, ?, ?)',
            $this->datetimeToDB($entry->getDateLogged())),
         array(
            $entry->getArticleId(),
            $entry->getUserId(),
            $entry->getIPAddress(),
            $entry->getLogLevel(),
            $entry->getEventType(),
            $entry->getAssocType(),
            $entry->getAssocId(),
            $entry->getMessage()
         )
      );

      $entry->setLogId($this->getInsertLogId());
      return $entry->getLogId();
   }

   function deleteLogEntry($logId, $articleId = null) {
      if (isset($articleId)) {
         return $this->update(
            'DELETE FROM article_event_log WHERE log_id = ? AND article_id = ?',
            array($logId, $articleId)
         );

      } else {
         return $this->update(
            'DELETE FROM article_event_log WHERE log_id = ?', $logId
         );
      }
   }

   function deleteArticleLogEntries($articleId) {
      return $this->update(
         'DELETE FROM article_event_log WHERE article_id = ?', $articleId
      );
   }

   function transferArticleLogEntries($oldUserId, $newUserId) {
      return $this->update(
         'UPDATE article_event_log SET user_id = ? WHERE user_id = ?',
         array($newUserId, $oldUserId)
      );
   }

   function getInsertLogId() {
      return $this->getInsertId('article_event_log', 'log_id');
   }
}

?>

---