classes/paper/log/PaperEmailLogDAO.inc.php

Go to the documentation of this file.

<?php

//$Id$

import ('paper.log.PaperEmailLogEntry');

class PaperEmailLogDAO extends DAO {
   function &getLogEntry($logId, $paperId = null) {
      if (isset($paperId)) {
         $result =& $this->retrieve(
            'SELECT * FROM paper_email_log WHERE log_id = ? AND paper_id = ?',
            array($logId, $paperId)
         );
      } else {
         $result =& $this->retrieve(
            'SELECT * FROM paper_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 &getPaperLogEntries($paperId, $rangeInfo = null) {
      $returner =& $this->getPaperLogEntriesByAssoc($paperId, null, null, $rangeInfo);
      return $returner;
   }

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

      $result =& $this->retrieveRange(
         'SELECT * FROM paper_email_log WHERE paper_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 PaperEmailLogEntry();
      $entry->setLogId($row['log_id']);
      $entry->setPaperId($row['paper_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('PaperEmailLogDAO::_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 paper_email_log
            (paper_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->getPaperId(),
            $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, $paperId = null) {
      if (isset($paperId)) {
         return $this->update(
            'DELETE FROM paper_email_log WHERE log_id = ? AND paper_id = ?',
            array($logId, $paperId)
         );

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

   function deletePaperLogEntries($paperId) {
      return $this->update(
         'DELETE FROM paper_email_log WHERE paper_id = ?', $paperId
      );
   }

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

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

?>

---