classes/monograph/MonographCommentDAO.inc.php

<?php

import('classes.monograph.MonographComment');

class MonographCommentDAO extends DAO {
   function MonographCommentDAO() {
      parent::DAO();
   }

   function &getMonographComments($monographId, $commentType = null, $assocId = null) {
      if ($commentType == null) {
         $result =& $this->retrieve(
            'SELECT a.* FROM monograph_comments a WHERE monograph_id = ? ORDER BY date_posted', $monographId
         );
      } else {
         if ($assocId == null) {
            $result =& $this->retrieve(
               'SELECT a.* FROM monograph_comments a WHERE monograph_id = ? AND comment_type = ? ORDER BY date_posted',
               array($monographId, $commentType)
            );
         } else {
            $result =& $this->retrieve(
               'SELECT a.* FROM monograph_comments a WHERE monograph_id = ? AND comment_type = ? AND assoc_id = ? ORDER BY date_posted',
               array($monographId, $commentType, $assocId)
            );
         }
      }

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

   function &getByUserId($userId) {
      $result =& $this->retrieve(
         'SELECT a.* FROM monograph_comments a WHERE author_id = ? ORDER BY date_posted', $userId
      );

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

   function &getReviewerCommentsByReviewerId($reviewerId, $monographId, $reviewId = null) {
      $params = array($reviewerId, $monographId);
      if (isset($reviewId)) {
         $params[] = $reviewId;
      }
      $result =& $this->retrieve(
         'SELECT a.* FROM monograph_comments a WHERE author_id = ? AND monograph_id = ?' . (isset($reviewId) ? ' AND assoc_id = ?' : '') . ' ORDER BY date_posted DESC',
         $params
      );

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

   function getMostRecentMonographComment($monographId, $commentType = null, $assocId = null) {
      if ($commentType == null) {
         $result =& $this->retrieveLimit(
            'SELECT a.* FROM monograph_comments a WHERE monograph_id = ? ORDER BY date_posted DESC',
            $monographId,
            1
         );
      } else {
         if ($assocId == null) {
            $result =& $this->retrieveLimit(
               'SELECT a.* FROM monograph_comments a WHERE monograph_id = ? AND comment_type = ? ORDER BY date_posted DESC',
               array($monographId, $commentType),
               1
            );
         } else {
            $result =& $this->retrieveLimit(
               'SELECT a.* FROM monograph_comments a WHERE monograph_id = ? AND comment_type = ? AND assoc_id = ? ORDER BY date_posted DESC',
               array($monographId, $commentType, $assocId),
               1
            );
         }
      }

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

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

      return $returner;
   }

   function &getById($commentId) {
      $result =& $this->retrieve(
         'SELECT a.* FROM monograph_comments a WHERE comment_id = ?', $commentId
      );

      $monographComment =& $this->_returnMonographCommentFromRow($result->GetRowAssoc(false));

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

      return $monographComment;
   }

   function &_returnMonographCommentFromRow($row) {
      $monographComment = new MonographComment();
      $monographComment->setCommentId($row['comment_id']);
      $monographComment->setCommentType($row['comment_type']);
      $monographComment->setRoleId($row['role_id']);
      $monographComment->setMonographId($row['monograph_id']);
      $monographComment->setAssocId($row['assoc_id']);
      $monographComment->setAuthorId($row['author_id']);
      $monographComment->setCommentTitle($row['comment_title']);
      $monographComment->setComments($row['comments']);
      $monographComment->setDatePosted($this->datetimeFromDB($row['date_posted']));
      $monographComment->setDateModified($this->datetimeFromDB($row['date_modified']));
      $monographComment->setViewable($row['viewable']);

      HookRegistry::call('MonographCommentDAO::_returnMonographCommentFromRow', array(&$monographComment, &$row));

      return $monographComment;
   }

   function insertMonographComment(&$monographComment) {
      $this->update(
         sprintf('INSERT INTO monograph_comments
            (comment_type, role_id, monograph_id, assoc_id, author_id, date_posted, date_modified, comment_title, comments, viewable)
            VALUES
            (?, ?, ?, ?, ?, %s, %s, ?, ?, ?)',
            $this->datetimeToDB($monographComment->getDatePosted()), $this->datetimeToDB($monographComment->getDateModified())),
         array(
            $monographComment->getCommentType(),
            $monographComment->getRoleId(),
            $monographComment->getMonographId(),
            $monographComment->getAssocId(),
            $monographComment->getAuthorId(),
            $monographComment->getCommentTitle(),
            $monographComment->getComments(),
            $monographComment->getViewable() === null ? 0 : $monographComment->getViewable()
         )
      );

      $monographComment->setCommentId($this->getInsertMonographCommentId());
      return $monographComment->getCommentId();
   }

   function getInsertMonographCommentId() {
      return $this->getInsertId('monograph_comments', 'comment_id');
   }

   function deleteObject($monographComment) {
      $this->deleteById($monographComment->getCommentId());
   }

   function deleteById($commentId) {
      $this->update(
         'DELETE FROM monograph_comments WHERE comment_id = ?', $commentId
      );
   }

   function deleteByMonographId($monographId) {
      return $this->update(
         'DELETE FROM monograph_comments WHERE monograph_id = ?', $monographId
      );
   }

   function updateObject($monographComment) {
      $this->update(
         sprintf('UPDATE monograph_comments
            SET
               comment_type = ?,
               role_id = ?,
               monograph_id = ?,
               assoc_id = ?,
               author_id = ?,
               date_posted = %s,
               date_modified = %s,
               comment_title = ?,
               comments = ?,
               viewable = ?
            WHERE comment_id = ?',
            $this->datetimeToDB($monographComment->getDatePosted()), $this->datetimeToDB($monographComment->getDateModified())),
         array(
            $monographComment->getCommentType(),
            $monographComment->getRoleId(),
            $monographComment->getMonographId(),
            $monographComment->getAssocId(),
            $monographComment->getAuthorId(),
            $monographComment->getCommentTitle(),
            $monographComment->getComments(),
            $monographComment->getViewable() === null ? 1 : $monographComment->getViewable(),
            $monographComment->getCommentId()
         )
      );
   }
}

?>