classes/journal/JournalDAO.inc.php

<?php

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


import ('journal.Journal');

class JournalDAO extends DAO {
   function &getJournal($journalId) {
      $result = &$this->retrieve(
         'SELECT * FROM journals WHERE journal_id = ?', $journalId
      );

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

   function &getJournalByPath($path) {
      $returner = null;
      $result = &$this->retrieve(
         'SELECT * FROM journals WHERE path = ?', $path
      );

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

   function &_returnJournalFromRow(&$row) {
      $journal = &new Journal();
      $journal->setJournalId($row['journal_id']);
      $journal->setPath($row['path']);
      $journal->setSequence($row['seq']);
      $journal->setEnabled($row['enabled']);
      $journal->setPrimaryLocale($row['primary_locale']);

      HookRegistry::call('JournalDAO::_returnJournalFromRow', array(&$journal, &$row));

      return $journal;
   }

   function insertJournal(&$journal) {
      $this->update(
         'INSERT INTO journals
            (path, seq, enabled, primary_locale)
            VALUES
            (?, ?, ?, ?)',
         array(
            $journal->getPath(),
            $journal->getSequence() == null ? 0 : $journal->getSequence(),
            $journal->getEnabled() ? 1 : 0,
            $journal->getPrimaryLocale()
         )
      );

      $journal->setJournalId($this->getInsertJournalId());
      return $journal->getJournalId();
   }

   function updateJournal(&$journal) {
      return $this->update(
         'UPDATE journals
            SET
               path = ?,
               seq = ?,
               enabled = ?,
               primary_locale = ?
            WHERE journal_id = ?',
         array(
            $journal->getPath(),
            $journal->getSequence(),
            $journal->getEnabled() ? 1 : 0,
            $journal->getPrimaryLocale(),
            $journal->getJournalId()
         )
      );
   }

   function deleteJournal(&$journal) {
      return $this->deleteJournalById($journal->getJournalId());
   }

   function deleteJournalById($journalId) {
      $journalSettingsDao = &DAORegistry::getDAO('JournalSettingsDAO');
      $journalSettingsDao->deleteSettingsByJournal($journalId);

      $sectionDao = &DAORegistry::getDAO('SectionDAO');
      $sectionDao->deleteSectionsByJournal($journalId);

      $issueDao = &DAORegistry::getDAO('IssueDAO');
      $issueDao->deleteIssuesByJournal($journalId);

      $notificationStatusDao = &DAORegistry::getDAO('NotificationStatusDAO');
      $notificationStatusDao->deleteNotificationStatusByJournal($journalId);

      $emailTemplateDao = &DAORegistry::getDAO('EmailTemplateDAO');
      $emailTemplateDao->deleteEmailTemplatesByJournal($journalId);

      $rtDao = &DAORegistry::getDAO('RTDAO');
      $rtDao->deleteVersionsByJournal($journalId);

      $subscriptionDao = &DAORegistry::getDAO('SubscriptionDAO');
      $subscriptionDao->deleteSubscriptionsByJournal($journalId);

      $subscriptionTypeDao = &DAORegistry::getDAO('SubscriptionTypeDAO');
      $subscriptionTypeDao->deleteSubscriptionTypesByJournal($journalId);

      $announcementDao = &DAORegistry::getDAO('AnnouncementDAO');
      $announcementDao->deleteAnnouncementsByJournal($journalId);

      $announcementTypeDao = &DAORegistry::getDAO('AnnouncementTypeDAO');
      $announcementTypeDao->deleteAnnouncementTypesByJournal($journalId);

      $articleDao = &DAORegistry::getDAO('ArticleDAO');
      $articleDao->deleteArticlesByJournalId($journalId);

      $roleDao = &DAORegistry::getDAO('RoleDAO');
      $roleDao->deleteRoleByJournalId($journalId);

      $groupDao = &DAORegistry::getDAO('GroupDAO');
      $groupDao->deleteGroupsByJournalId($journalId);

      $pluginSettingsDao = &DAORegistry::getDAO('PluginSettingsDAO');
      $pluginSettingsDao->deleteSettingsByJournalId($journalId);

      $reviewFormDao =& DAORegistry::getDAO('ReviewFormDAO');
      $reviewFormDao->deleteReviewFormsByJournalId($journalId);

      return $this->update(
         'DELETE FROM journals WHERE journal_id = ?', $journalId
      );
   }

   function &getJournals($rangeInfo = null) {
      $result = &$this->retrieveRange(
         'SELECT * FROM journals ORDER BY seq',
         false, $rangeInfo
      );

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

   function &getEnabledJournals() {
      $result = &$this->retrieve(
         'SELECT * FROM journals WHERE enabled=1 ORDER BY seq'
      );

      $resultFactory = &new DAOResultFactory($result, $this, '_returnJournalFromRow');
      return $resultFactory;
   }

   function &getJournalTitles() {
      $journals = array();

      $journalIterator =& $this->getJournals();
      while ($journal =& $journalIterator->next()) {
         $journals[$journal->getJournalId()] = $journal->getJournalTitle();
         unset($journal);
      }
      unset($journalIterator);

      return $journals;
   }

   function &getEnabledJournalTitles() {
      $journals = array();

      $journalIterator =& $this->getEnabledJournals();
      while ($journal =& $journalIterator->next()) {
         $journals[$journal->getJournalId()] = $journal->getJournalTitle();
         unset($journal);
      }
      unset($journalIterator);

      return $journals;
   }

   function journalExistsByPath($path) {
      $result = &$this->retrieve(
         'SELECT COUNT(*) FROM journals WHERE path = ?', $path
      );
      $returner = isset($result->fields[0]) && $result->fields[0] == 1 ? true : false;

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

      return $returner;
   }

   function resequenceJournals() {
      $result = &$this->retrieve(
         'SELECT journal_id FROM journals ORDER BY seq'
      );

      for ($i=1; !$result->EOF; $i++) {
         list($journalId) = $result->fields;
         $this->update(
            'UPDATE journals SET seq = ? WHERE journal_id = ?',
            array(
               $i,
               $journalId
            )
         );

         $result->moveNext();
      }

      $result->close();
      unset($result);
   }

   function getInsertJournalId() {
      return $this->getInsertId('journals', 'journal_id');
   }
}

?>

---