classes/press/NotificationStatusDAO.inc.php

<?php

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

   function &getPressNotifications($userId) {
      $returner = array();

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

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

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

      return $returner;
   }

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

   function deleteNotificationStatusByPress($pressId) {
      return $this->update(
         'DELETE FROM notification_status WHERE press_id = ?', $pressId
      );
   }

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

   function &getNotifiableUsersByPressId($pressId) {
      $userDao =& DAORegistry::getDAO('UserDAO');

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

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

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

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

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

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

      return $returner;
   }
}

?>