SubmissionCommentDAO.inc.php

<?php
 
import('lib.pkp.classes.submission.SubmissionComment');
 
class SubmissionCommentDAO extends DAO {
 
   function getSubmissionComments($submissionId, $commentType = null, $assocId = null) {
      $params = array((int) $submissionId);
      if ($commentType) $params[] = (int) $commentType;
      if ($assocId) $params[] = (int) $assocId;
      $result = $this->retrieve(
         'SELECT  a.*
         FROM  submission_comments a
         WHERE submission_id = ?'
            . ($commentType?' AND comment_type = ?':'')
            . ($assocId?' AND assoc_id = ?':'')
            . ' ORDER BY date_posted',
         $params
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   function getByUserId($userId) {
      $result = $this->retrieve(
         'SELECT a.* FROM submission_comments a WHERE author_id = ? ORDER BY date_posted', (int) $userId
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   function getReviewerCommentsByReviewerId($submissionId, $reviewerId = null, $reviewId = null, $viewable = null) {
      $params = array((int) $submissionId);
      if ($reviewerId) $params[] = (int) $reviewerId;
      if ($reviewId) $params[] = (int) $reviewId;
      return new DAOResultFactory(
         $this->retrieve(
            'SELECT  a.*
            FROM  submission_comments a
            WHERE submission_id = ?
               ' . ($reviewerId?' AND author_id = ?':'') . '
               ' . ($reviewId?' AND assoc_id = ?':'') . '
               ' . ($viewable === true?' AND viewable = 1':'') . '
               ' . ($viewable === false?' AND viewable = 0':'') . '
            ORDER BY date_posted DESC',
            $params
         ),
         $this,
         '_fromRow'
      );
   }
 
   function getById($commentId) {
      $result = $this->retrieve(
         'SELECT * FROM submission_comments WHERE comment_id = ?', (int) $commentId
      );
 
      $submissionComment = $this->_fromRow($result->GetRowAssoc(false));
 
      $result->Close();
      return $submissionComment;
   }
 
   function newDataObject() {
      return new SubmissionComment();
   }
 
   function _fromRow($row) {
      $submissionComment = $this->newDataObject();
      $submissionComment->setId($row['comment_id']);
      $submissionComment->setCommentType($row['comment_type']);
      $submissionComment->setRoleId($row['role_id']);
      $submissionComment->setSubmissionId($row['submission_id']);
      $submissionComment->setAssocId($row['assoc_id']);
      $submissionComment->setAuthorId($row['author_id']);
      $submissionComment->setCommentTitle($row['comment_title']);
      $submissionComment->setComments($row['comments']);
      $submissionComment->setDatePosted($this->datetimeFromDB($row['date_posted']));
      $submissionComment->setDateModified($this->datetimeFromDB($row['date_modified']));
      $submissionComment->setViewable($row['viewable']);
 
      HookRegistry::call('SubmissionCommentDAO::_fromRow', array(&$submissionComment, &$row));
 
      return $submissionComment;
   }
 
   function insertObject($submissionComment) {
      $this->update(
         sprintf('INSERT INTO submission_comments
            (comment_type, role_id, submission_id, assoc_id, author_id, date_posted, date_modified, comment_title, comments, viewable)
            VALUES
            (?, ?, ?, ?, ?, %s, %s, ?, ?, ?)',
            $this->datetimeToDB($submissionComment->getDatePosted()), $this->datetimeToDB($submissionComment->getDateModified())),
         array(
            (int) $submissionComment->getCommentType(),
            (int) $submissionComment->getRoleId(),
            (int) $submissionComment->getSubmissionId(),
            (int) $submissionComment->getAssocId(),
            (int) $submissionComment->getAuthorId(),
            $submissionComment->getCommentTitle(),
            $submissionComment->getComments(),
            (int) $submissionComment->getViewable()
         )
      );
 
      $submissionComment->setId($this->getInsertId());
      return $submissionComment->getId();
   }
 
   function getInsertId() {
      return $this->_getInsertId('submission_comments', 'comment_id');
   }
 
   function deleteObject($submissionComment) {
      $this->deleteById($submissionComment->getId());
   }
 
   function deleteById($commentId) {
      $this->update(
         'DELETE FROM submission_comments WHERE comment_id = ?',
         (int) $commentId
      );
   }
 
   function deleteBySubmissionId($submissionId) {
      return $this->update(
         'DELETE FROM submission_comments WHERE submission_id = ?',
         (int) $submissionId
      );
   }
 
   function updateObject($submissionComment) {
      $this->update(
         sprintf('UPDATE submission_comments
            SET
               comment_type = ?,
               role_id = ?,
               submission_id = ?,
               assoc_id = ?,
               author_id = ?,
               date_posted = %s,
               date_modified = %s,
               comment_title = ?,
               comments = ?,
               viewable = ?
            WHERE comment_id = ?',
            $this->datetimeToDB($submissionComment->getDatePosted()), $this->datetimeToDB($submissionComment->getDateModified())),
         array(
            (int) $submissionComment->getCommentType(),
            (int) $submissionComment->getRoleId(),
            (int) $submissionComment->getSubmissionId(),
            (int) $submissionComment->getAssocId(),
            (int) $submissionComment->getAuthorId(),
            $submissionComment->getCommentTitle(),
            $submissionComment->getComments(),
            $submissionComment->getViewable() === null ? 1 : (int) $submissionComment->getViewable(),
            (int) $submissionComment->getId()
         )
      );
   }
}