AnnouncementDAO.inc.php

<?php
 
import('lib.pkp.classes.announcement.Announcement');
import('lib.pkp.classes.db.SchemaDAO');
 
class AnnouncementDAO extends SchemaDAO {
   var $schemaName = SCHEMA_ANNOUNCEMENT;
 
   var $tableName = 'announcements';
 
   var $settingsTableName = 'announcement_settings';
 
   var $primaryKeyColumn = 'announcement_id';
 
   var $primaryTableColumns = [
      'id' => 'announcement_id',
      'assocId' => 'assoc_id',
      'assocType' => 'assoc_type',
      'typeId' => 'type_id',
      'dateExpire' => 'date_expire',
      'datePosted' => 'date_posted',
   ];
 
   function getById($announcementId, $assocType = null, $assocId = null) {
      $params = array((int) $announcementId);
      if ($assocType !== null) $params[] = (int) $assocType;
      if ($assocId !== null) $params[] = (int) $assocId;
      $result = $this->retrieve(
         'SELECT  * FROM announcements WHERE announcement_id = ?' .
         ($assocType !== null?' AND assoc_type = ?':'') .
         ($assocId !== null?' AND assoc_id = ?':''),
         $params
      );
 
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = $this->_fromRow($result->GetRowAssoc(false));
      }
      $result->Close();
      return $returner;
   }
 
   function getAnnouncementAssocId($announcementId) {
      $result = $this->retrieve(
         'SELECT assoc_id FROM announcements WHERE announcement_id = ?',
         (int) $announcementId
      );
 
      return isset($result->fields[0]) ? $result->fields[0] : 0;
   }
 
   function getAnnouncementAssocType($announcementId) {
      $result = $this->retrieve(
         'SELECT assoc_type FROM announcements WHERE announcement_id = ?',
         (int) $announcementId
      );
 
      return isset($result->fields[0]) ? $result->fields[0] : 0;
   }
 
   function newDataObject() {
      return new Announcement();
   }
 
   function deleteByTypeId($typeId) {
      $announcements = $this->getByTypeId($typeId);
      while ($announcement = $announcements->next()) {
         $this->deleteObject($announcement);
      }
   }
 
   function deleteByAssoc($assocType, $assocId) {
      $announcements = $this->getByAssocId($assocType, $assocId);
      while ($announcement = $announcements->next()) {
         $this->deleteById($announcement->getId());
      }
      return true;
   }
 
   function getByAssocId($assocType, $assocId, $rangeInfo = null) {
      $result = $this->retrieveRange(
         'SELECT *
         FROM announcements
         WHERE assoc_type = ? AND assoc_id = ?
         ORDER BY date_posted DESC',
         array((int) $assocType, (int) $assocId),
         $rangeInfo
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   function getByTypeId($typeId, $rangeInfo = null) {
      $result = $this->retrieveRange(
         'SELECT * FROM announcements WHERE type_id = ? ORDER BY date_posted DESC',
         (int) $typeId,
         $rangeInfo
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   function getNumAnnouncementsByAssocId($assocType, $assocId, $numAnnouncements, $rangeInfo = null) {
      $result = $this->retrieveRange(
         'SELECT *
         FROM announcements
         WHERE assoc_type = ?
            AND assoc_id = ?
         ORDER BY date_posted DESC LIMIT ?',
         array((int) $assocType, (int) $assocId, (int) $numAnnouncements),
         $rangeInfo
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   function getAnnouncementsNotExpiredByAssocId($assocType, $assocId, $rangeInfo = null) {
      $result = $this->retrieveRange(
         'SELECT *
         FROM announcements
         WHERE assoc_type = ?
            AND assoc_id = ?
            AND (date_expire IS NULL OR DATE(date_expire) > DATE(NOW()))
            AND (DATE(date_posted) <= DATE(NOW()))
         ORDER BY date_posted DESC',
         array((int) $assocType, (int) $assocId),
         $rangeInfo
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   function getNumAnnouncementsNotExpiredByAssocId($assocType, $assocId, $numAnnouncements, $rangeInfo = null) {
      $result = $this->retrieveRange(
         'SELECT *
         FROM announcements
         WHERE assoc_type = ?
            AND assoc_id = ?
            AND (date_expire IS NULL OR DATE(date_expire) > DATE(NOW()))
            AND (DATE(date_posted) <= DATE(NOW()))
         ORDER BY date_posted DESC LIMIT ?',
         array((int) $assocType, (int) $assocId, (int) $numAnnouncements),
         $rangeInfo
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   function getMostRecentAnnouncementByAssocId($assocType, $assocId) {
      $result = $this->retrieve(
         'SELECT *
         FROM announcements
         WHERE assoc_type = ?
            AND assoc_id = ?
         ORDER BY date_posted DESC LIMIT 1',
         array((int) $assocType, (int) $assocId)
      );
 
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = $this->_fromRow($result->GetRowAssoc(false));
      }
      $result->Close();
      return $returner;
   }
 
   function getInsertId() {
      return $this->_getInsertId('announcements', 'announcement_id');
   }
}