classes/journal/NotificationStatusDAO.inc.php

<?php

// $Id: NotificationStatusDAO.inc.php,v 1.14 2008/07/01 01:16:10 asmecher Exp $


class NotificationStatusDAO extends DAO {
   function &getJournalNotifications($userId) {
      $returner = array();

      $result = &$this->retrieve(
         'SELECT j.journal_id AS journal_id, n.journal_id AS notification FROM journals j LEFT JOIN notification_status n ON j.journal_id = n.journal_id AND n.user_id = ? ORDER BY j.seq',
         $userId
      );

      while (!$result->EOF) {
         $row = &$result->GetRowAssoc(false);
         $returner[$row['journal_id']] = $row['notification'];
         $result->moveNext();
      }

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

      return $returner;
   }

   function setJournalNotifications($journalId, $userId, $notificationStatus) {
      return $this->update(
         ($notificationStatus?'INSERT INTO notification_status (user_id, journal_id) VALUES (?, ?)':
         'DELETE FROM notification_status WHERE user_id = ? AND journal_id = ?'),
         array($userId, $journalId)
      );
   }

   function deleteNotificationStatusByJournal($journalId) {
      return $this->update(
         'DELETE FROM notification_status WHERE journal_id = ?', $journalId
      );
   }

   function deleteNotificationStatusByUserId($userId) {
      return $this->update(
         'DELETE FROM notification_status WHERE user_id = ?', $userId
      );
   }

   function &getNotifiableUsersByJournalId($journalId) {
      $userDao = &DAORegistry::getDAO('UserDAO');

      $result = &$this->retrieve(
         'SELECT u.* FROM users u, notification_status n WHERE u.user_id = n.user_id AND n.journal_id = ?',
         $journalId
      );

      $returner = &new DAOResultFactory($result, $userDao, '_returnUserFromRow');
      return $returner;
   }

   function getNotifiableUsersCount($journalId) {
      $userDao = &DAORegistry::getDAO('UserDAO');

      $result = &$this->retrieve(
         'SELECT count(*) FROM notification_status n WHERE n.journal_id = ?',
         $journalId
      );

      $returner = $result->fields[0];

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

      return $returner;
   }
}

?>

---