classes/article/log/ArticleEmailLogDAO.inc.php

<?php

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


import ('article.log.ArticleEmailLogEntry');

class ArticleEmailLogDAO extends DAO {
   function &getLogEntry($logId, $articleId = null) {
      if (isset($articleId)) {
         $result = &$this->retrieve(
            'SELECT * FROM article_email_log WHERE log_id = ? AND article_id = ?',
            array($logId, $articleId)
         );
      } else {
         $result = &$this->retrieve(
            'SELECT * FROM article_email_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_email_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 ArticleEmailLogEntry();
      $entry->setLogId($row['log_id']);
      $entry->setArticleId($row['article_id']);
      $entry->setSenderId($row['sender_id']);
      $entry->setDateSent($this->datetimeFromDB($row['date_sent']));
      $entry->setIPAddress($row['ip_address']);
      $entry->setEventType($row['event_type']);
      $entry->setAssocType($row['assoc_type']);
      $entry->setAssocId($row['assoc_id']);
      $entry->setFrom($row['from_address']);
      $entry->setRecipients($row['recipients']);
      $entry->setCcs($row['cc_recipients']);
      $entry->setBccs($row['bcc_recipients']);
      $entry->setSubject($row['subject']);
      $entry->setBody($row['body']);

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

      return $entry;
   }

   function insertLogEntry(&$entry) {
      if ($entry->getDateSent() == null) {
         $entry->setDateSent(Core::getCurrentDate());
      }
      if ($entry->getIPAddress() == null) {
         $entry->setIPAddress(Request::getRemoteAddr());
      }
      $this->update(
         sprintf('INSERT INTO article_email_log
            (article_id, sender_id, date_sent, ip_address, event_type, assoc_type, assoc_id, from_address, recipients, cc_recipients, bcc_recipients, subject, body)
            VALUES
            (?, ?, %s, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)',
            $this->datetimeToDB($entry->getDateSent())),
         array(
            $entry->getArticleId(),
            $entry->getSenderId(),
            $entry->getIPAddress(),
            $entry->getEventType(),
            $entry->getAssocType(),
            $entry->getAssocId(),
            $entry->getFrom(),
            $entry->getRecipients(),
            $entry->getCcs(),
            $entry->getBccs(),
            $entry->getSubject(),
            $entry->getBody()
         )
      );

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

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

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

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

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

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

?>

---