classes/announcement/AnnouncementDAO.inc.php

<?php

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


import('announcement.Announcement');

class AnnouncementDAO extends DAO {
   function &getAnnouncement($announcementId) {
      $result = &$this->retrieve(
         'SELECT * FROM announcements WHERE announcement_id = ?', $announcementId
      );

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

   function getAnnouncementJournalId($announcementId) {
      $result = &$this->retrieve(
         'SELECT journal_id FROM announcements WHERE announcement_id = ?', $announcementId
      );

      return isset($result->fields[0]) ? $result->fields[0] : 0;  
   }

   function getLocaleFieldNames() {
      return array('title', 'descriptionShort', 'description');
   }

   function &_returnAnnouncementFromRow(&$row) {
      $announcement = &new Announcement();
      $announcement->setAnnouncementId($row['announcement_id']);
      $announcement->setJournalId($row['journal_id']);
      $announcement->setTypeId($row['type_id']);
      $announcement->setDateExpire($this->dateFromDB($row['date_expire']));
      $announcement->setDatePosted($this->datetimeFromDB($row['date_posted']));

      $this->getDataObjectSettings('announcement_settings', 'announcement_id', $row['announcement_id'], $announcement);

      return $announcement;
   }

   function updateLocaleFields(&$announcement) {
      $this->updateDataObjectSettings('announcement_settings', $announcement, array(
         'announcement_id' => $announcement->getAnnouncementId()
      ));
   }

   function insertAnnouncement(&$announcement) {
      $this->update(
         sprintf('INSERT INTO announcements
            (journal_id, type_id, date_expire, date_posted)
            VALUES
            (?, ?, %s, %s)',
            $this->dateToDB($announcement->getDateExpire()), $this->dateToDB($announcement->getDatetimePosted())),
         array(
            $announcement->getJournalId(),
            $announcement->getTypeId()
         )
      );
      $announcement->setAnnouncementId($this->getInsertAnnouncementId());
      $this->updateLocaleFields($announcement);
      return $announcement->getAnnouncementId();
   }

   function updateAnnouncement(&$announcement) {
      $returner = $this->update(
         sprintf('UPDATE announcements
            SET
               journal_id = ?,
               type_id = ?,
               date_expire = %s
            WHERE announcement_id = ?',
            $this->dateToDB($announcement->getDateExpire())),
         array(
            $announcement->getJournalId(),
            $announcement->getTypeId(),
            $announcement->getAnnouncementId()
         )
      );
      $this->updateLocaleFields($announcement);
      return $returner;
   }

   function deleteAnnouncement($announcement) {
      return $this->deleteAnnouncementById($announcement->getAnnouncementId());
   }

   function deleteAnnouncementById($announcementId) {
      $this->update('DELETE FROM announcement_settings WHERE announcement_id = ?', $announcementId);
      return $this->update('DELETE FROM announcements WHERE announcement_id = ?', $announcementId);
   }

   function deleteAnnouncementByTypeId($typeId) {
      $announcements =& $this->getAnnouncementsByTypeId($typeId);
      while (($announcement =& $announcements->next())) {
         $this->deleteAnnouncement($announcement->getAnnouncementId());
         unset($announcement);
      }
   }

   function deleteAnnouncementsByJournal($journalId) {
      $announcements =& $this->getAnnouncementsByJournalId($journalId);
      while (($announcement =& $announcements->next())) {
         $this->deleteAnnouncementById($announcement->getAnnouncementId());
         unset($announcement);
      }
   }

   function &getAnnouncementsByJournalId($journalId, $rangeInfo = null) {
      $result = &$this->retrieveRange(
         'SELECT * FROM announcements WHERE journal_id = ? ORDER BY announcement_id DESC', $journalId, $rangeInfo
      );

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

   function &getAnnouncementsByTypeId($typeId, $rangeInfo = null) {
      $result = &$this->retrieveRange(
         'SELECT * FROM announcements WHERE type_id = ? ORDER BY announcement_id DESC', $typeId, $rangeInfo
      );

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

   function &getNumAnnouncementsByJournalId($journalId, $numAnnouncements, $rangeInfo = null) {
      $result = &$this->retrieveRange(
         'SELECT * FROM announcements WHERE journal_id = ? ORDER BY announcement_id DESC LIMIT ?', array($journalId, $numAnnouncements), $rangeInfo
      );

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

   function &getAnnouncementsNotExpiredByJournalId($journalId, $rangeInfo = null) {
      $result = &$this->retrieveRange(
         'SELECT * FROM announcements WHERE journal_id = ? AND (date_expire IS NULL OR date_expire > CURRENT_DATE) ORDER BY announcement_id DESC', $journalId, $rangeInfo
      );

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

   function &getNumAnnouncementsNotExpiredByJournalId($journalId, $numAnnouncements, $rangeInfo = null) {
      $result = &$this->retrieveRange(
         'SELECT * FROM announcements WHERE journal_id = ? AND (date_expire IS NULL OR date_expire > CURRENT_DATE) ORDER BY announcement_id DESC LIMIT ?', array($journalId, $numAnnouncements), $rangeInfo
      );

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

   function &getMostRecentAnnouncementByJournalId($journalId) {
      $result = &$this->retrieve(
         'SELECT * FROM announcements WHERE journal_id = ? ORDER BY announcement_id DESC LIMIT 1', $journalId
      );

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

   function getInsertAnnouncementId() {
      return $this->getInsertId('announcements', 'announcement_id');
   }
}

?>

---