classes/press/SeriesDAO.inc.php

<?php

import ('classes.press.Series');

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

   function &getById($seriesId, $pressId = null) {
      $params = array((int) $seriesId);
      if ($pressId) $params[] = (int) $pressId;

      $result =& $this->retrieve(
         'SELECT  *
         FROM  series
         WHERE series_id = ?
         ' . ($pressId?' AND press_id = ?':''),
         $params
      );

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

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

      return $returner;
   }

   function &getByPath($path, $pressId) {
      $returner = null;
      $result =& $this->retrieve(
         'SELECT * FROM series WHERE path = ? AND press_id = ?',
         array((string) $path, (int) $pressId)
      );

      if ($result->RecordCount() != 0) {
         $returner =& $this->_fromRow($result->GetRowAssoc(false));
      }

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

      return $returner;
   }

   function newDataObject() {
      return new Series();
   }

   function _fromRow(&$row) {
      $series = $this->newDataObject();

      $series->setId($row['series_id']);
      $series->setPressId($row['press_id']);
      $series->setFeatured($row['featured']);
      $series->setPath($row['path']);
      $series->setImage(unserialize($row['image']));

      $this->getDataObjectSettings('series_settings', 'series_id', $row['series_id'], $series);

      HookRegistry::call('SeriesDAO::_fromRow', array(&$series, &$row));

      return $series;
   }

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

   function updateLocaleFields(&$series) {
      $this->updateDataObjectSettings(
         'series_settings',
         $series,
         array('series_id' => (int) $series->getId())
      );
   }

   function insertObject(&$series) {
      $this->update(
         'INSERT INTO series
            (press_id, featured, path, image)
         VALUES
            (?, ?, ?, ?)',
         array(
            (int) $series->getPressId(),
            (int) $series->getFeatured(),
            (string) $series->getPath(),
            serialize($series->getImage() ? $series->getImage() : array()),
         )
      );

      $series->setId($this->getInsertSeriesId());
      $this->updateLocaleFields($series);
      return $series->getId();
   }

   function updateObject($series) {
      $returner = $this->update(
         'UPDATE series
         SET   press_id = ?,
            featured = ?,
            path = ?,
            image = ?
         WHERE series_id = ?',
         array(
            (int) $series->getPressId(),
            (int) $series->getFeatured(),
            (string) $series->getPath(),
            serialize($series->getImage() ? $series->getImage() : array()),
            (int) $series->getId(),
         )
      );
      $this->updateLocaleFields($series);
      return $returner;
   }

   function deleteObject(&$series) {
      return $this->deleteById($series->getId(), $series->getPressId());
   }

   function deleteById($seriesId, $pressId = null) {
      // Validate the $pressId, if supplied.
      if (!$this->seriesExists($seriesId, $pressId)) return false;

      $seriesEditorsDao =& DAORegistry::getDAO('SeriesEditorsDAO');
      $seriesEditorsDao->deleteEditorsBySeriesId($seriesId, $pressId);

      // Remove monographs from this series
      $monographDao =& DAORegistry::getDAO('MonographDAO');
      $monographDao->removeMonographsFromSeries($seriesId);

      // Delete the series and settings.
      $this->update('DELETE FROM series WHERE series_id = ?', (int) $seriesId);
      $this->update('DELETE FROM series_settings WHERE series_id = ?', (int) $seriesId);
   }

   function deleteByPressId($pressId) {
      $series =& $this->getByPressId($pressId);
      while (($series =& $series->next())) {
         $this->deleteObject($series);
         unset($series);
      }
   }

   function &getEditorSeries($pressId) {
      $result =& $this->retrieve(
         'SELECT  a.*,
            ae.user_id AS editor_id
         FROM  series_editors ae,
            series a
         WHERE ae.series_id = a.series_id AND
            a.press_id = ae.press_id AND
            a.press_id = ?',
         (int) $pressId
      );

      $returner = array();
      while (!$result->EOF) {
         $row = $result->GetRowAssoc(false);
         $series =& $this->_fromRow($row);
         if (!isset($returner[$row['editor_id']])) {
            $returner[$row['editor_id']] = array($series);
         } else {
            $returner[$row['editor_id']][] = $series;
         }
         $result->MoveNext();
         unset($series);
      }

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

      return $returner;
   }

   function &getByPressId($pressId, $rangeInfo = null) {
      $result =& $this->retrieveRange(
         'SELECT * FROM series WHERE press_id = ?',
         (int) $pressId,
         $rangeInfo
      );

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

   function &getTitlesByPressId($pressId, $submittableOnly = false) {
      $seriesTitles = array();

      $seriesIterator =& $this->getByPressId($pressId, null);
      while (($series =& $seriesIterator->next())) {
         if ($submittableOnly) {
            if (!$series->getEditorRestricted()) {
               $seriesTitles[$series->getId()] = join(' ', array($series->getLocalizedPrefix(), $series->getLocalizedTitle()));
            }
         } else {
            $seriesTitles[$series->getId()] = join(' ', array($series->getLocalizedPrefix(), $series->getLocalizedTitle()));
         }
         unset($series);
      }

      return $seriesTitles;
   }

   function seriesExists($seriesId, $pressId) {
      $result =& $this->retrieve(
         'SELECT COUNT(*) FROM series WHERE series_id = ? AND press_id = ?',
         array((int) $seriesId, (int) $pressId)
      );
      $returner = isset($result->fields[0]) && $result->fields[0] == 1 ? true : false;

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

      return $returner;
   }

   function getInsertSeriesId() {
      return $this->getInsertId('series', 'series_id');
   }

   function addCategory($seriesId, $categoryId) {
      $this->update(
         'INSERT INTO series_categories
            (series_id, category_id)
         VALUES
            (?, ?)',
         array(
            (int) $seriesId,
            (int) $categoryId
         )
      );
   }

   function removeCategory($seriesId, $categoryId) {
      $this->update(
         'DELETE FROM series_categories WHERE series_id = ? AND category_id = ?',
         array(
            (int) $seriesId,
            (int) $categoryId
         )
      );
   }

   function getCategories($seriesId, $pressId = null) {
      $params = array((int) $seriesId);
      if ($pressId) $params[] = (int) $pressId;

      $categoryDao =& DAORegistry::getDAO('CategoryDAO');
      $result =& $this->retrieve(
         'SELECT  c.*
         FROM  categories c,
            series_categories sc,
            series s
         WHERE c.category_id = sc.category_id AND
            s.series_id = ? AND
         ' . ($pressId?' c.press_id = s.press_id AND s.press_id = ? AND':'') . '
            s.series_id = sc.series_id',
         $params
      );

      // Delegate category creation to the category DAO.
      $returner = new DAOResultFactory($result, $categoryDao, '_fromRow');
      return $returner;
   }

   function getUnassignedCategories($seriesId, $pressId = null) {
      $params = array((int) $seriesId);
      if ($pressId) $params[] = (int) $pressId;

      $categoryDao =& DAORegistry::getDAO('CategoryDAO');
      $result =& $this->retrieve(
         'SELECT  c.*
         FROM  series s
            JOIN categories c ON (c.press_id = s.press_id)
            LEFT JOIN series_categories sc ON (s.series_id = sc.series_id AND sc.category_id = c.category_id)
         WHERE s.series_id = ? AND
            ' . ($pressId?' s.press_id = ? AND':'') . '
            sc.series_id IS NULL',
         $params
      );

      // Delegate category creation to the category DAO.
      $returner = new DAOResultFactory($result, $categoryDao, '_fromRow');
      return $returner;
   }

   function categoryAssociationExists($seriesId, $categoryId) {
      $result =& $this->retrieve(
         'SELECT COUNT(*) FROM series_categories WHERE series_id = ? AND category_id = ?',
         array((int) $seriesId, (int) $categoryId)
      );
      $returner = isset($result->fields[0]) && $result->fields[0] == 1 ? true : false;

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

      return $returner;
   }
}

?>