classes/monograph/PublishedMonographDAO.inc.php

<?php

import('classes.monograph.PublishedMonograph');
import('classes.monograph.MonographDAO');

class PublishedMonographDAO extends MonographDAO {
   function PublishedMonographDAO() {
      parent::MonographDAO();
   }

   function &getByPressId($pressId, $searchText = null, $rangeInfo = null) {
      $primaryLocale = AppLocale::getPrimaryLocale();
      $locale = AppLocale::getLocale();

      $params = array(
         REALLY_BIG_NUMBER,
         'title', $primaryLocale, // Series title
         'title', $locale, // Series title
         'abbrev', $primaryLocale, // Series abbreviation
         'abbrev', $locale, // Series abbreviation
         ASSOC_TYPE_PRESS,
         (int) $pressId
      );

      if ($searchText !== null) {
         $params[] = $params[] = $params[] = "%$searchText%";
      }

      $result =& $this->retrieveRange(
         'SELECT  ' . ($searchText !== null?'DISTINCT ':'') . '
            pm.*,
            m.*,
            COALESCE(stl.setting_value, stpl.setting_value) AS series_title,
            COALESCE(sal.setting_value, sapl.setting_value) AS series_abbrev,
            COALESCE(f.seq, ?) AS order_by
         FROM  published_monographs pm
            JOIN monographs m ON pm.monograph_id = m.monograph_id
            LEFT JOIN series s ON s.series_id = m.series_id
            LEFT JOIN series_settings stpl ON (s.series_id = stpl.series_id AND stpl.setting_name = ? AND stpl.locale = ?)
            LEFT JOIN series_settings stl ON (s.series_id = stl.series_id AND stl.setting_name = ? AND stl.locale = ?)
            LEFT JOIN series_settings sapl ON (s.series_id = sapl.series_id AND sapl.setting_name = ? AND sapl.locale = ?)
            LEFT JOIN series_settings sal ON (s.series_id = sal.series_id AND sal.setting_name = ? AND sal.locale = ?)
            ' . ($searchText !== null?'
               LEFT JOIN authors a ON m.monograph_id = a.submission_id
               LEFT JOIN monograph_settings mt ON (mt.monograph_id = m.monograph_id AND mt.setting_name = \'title\')
            ':'') . '
            LEFT JOIN features f ON (f.monograph_id = m.monograph_id AND f.assoc_type = ? AND f.assoc_id = m.press_id)
         WHERE pm.date_published IS NOT NULL AND m.press_id = ?
            ' . ($searchText !== null?' AND (mt.setting_value LIKE ? OR a.first_name LIKE ? OR a.last_name LIKE ?)':'') . '
         ORDER BY order_by, pm.date_published',
         $params,
         $rangeInfo
      );

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

   function &getPressFeatures($pressId, $rangeInfo = null) {
      $primaryLocale = AppLocale::getPrimaryLocale();
      $locale = AppLocale::getLocale();

      $result =& $this->retrieveRange(
         'SELECT  pm.*,
            m.*,
            COALESCE(stl.setting_value, stpl.setting_value) AS series_title,
            COALESCE(sal.setting_value, sapl.setting_value) AS series_abbrev
         FROM  published_monographs pm
            JOIN monographs m ON pm.monograph_id = m.monograph_id
            LEFT JOIN series s ON s.series_id = m.series_id
            LEFT JOIN series_settings stpl ON (s.series_id = stpl.series_id AND stpl.setting_name = ? AND stpl.locale = ?)
            LEFT JOIN series_settings stl ON (s.series_id = stl.series_id AND stl.setting_name = ? AND stl.locale = ?)
            LEFT JOIN series_settings sapl ON (s.series_id = sapl.series_id AND sapl.setting_name = ? AND sapl.locale = ?)
            LEFT JOIN series_settings sal ON (s.series_id = sal.series_id AND sal.setting_name = ? AND sal.locale = ?)
            JOIN features f ON (f.monograph_id = m.monograph_id AND f.assoc_type = ? AND f.assoc_id = m.press_id)
         WHERE pm.date_published IS NOT NULL AND m.press_id = ?
         ORDER BY f.seq, pm.date_published',
         array(
            'title', $primaryLocale, // Series title
            'title', $locale, // Series title
            'abbrev', $primaryLocale, // Series abbreviation
            'abbrev', $locale, // Series abbreviation
            ASSOC_TYPE_PRESS,
            (int) $pressId
         ),
         $rangeInfo
      );

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

   function &getBySeriesId($seriesId, $pressId = null, $rangeInfo = null) {
      $primaryLocale = AppLocale::getPrimaryLocale();
      $locale = AppLocale::getLocale();

      $params = array(
         'title', $primaryLocale, // Series title
         'title', $locale, // Series title
         'abbrev', $primaryLocale, // Series abbreviation
         'abbrev', $locale, // Series abbreviation
         ASSOC_TYPE_SERIES,
         (int) $seriesId
      );

      if ($pressId) $params[] = (int) $pressId;

      $params[] = REALLY_BIG_NUMBER; // For feature sorting

      $result =& $this->retrieveRange(
         'SELECT  pm.*,
            m.*,
            COALESCE(stl.setting_value, stpl.setting_value) AS series_title,
            COALESCE(sal.setting_value, sapl.setting_value) AS series_abbrev
         FROM  published_monographs pm
            JOIN monographs m ON pm.monograph_id = m.monograph_id
            JOIN series s ON s.series_id = m.series_id
            LEFT JOIN series_settings stpl ON (s.series_id = stpl.series_id AND stpl.setting_name = ? AND stpl.locale = ?)
            LEFT JOIN series_settings stl ON (s.series_id = stl.series_id AND stl.setting_name = ? AND stl.locale = ?)
            LEFT JOIN series_settings sapl ON (s.series_id = sapl.series_id AND sapl.setting_name = ? AND sapl.locale = ?)
            LEFT JOIN series_settings sal ON (s.series_id = sal.series_id AND sal.setting_name = ? AND sal.locale = ?)
            LEFT JOIN features f ON (f.monograph_id = m.monograph_id AND f.assoc_type = ? AND f.assoc_id = s.series_id)
         WHERE pm.date_published IS NOT NULL AND s.series_id = ?
            ' . ($pressId?' AND m.press_id = ?':'' ) . '
         ORDER BY COALESCE(f.seq, ?) ASC, pm.date_published',
         $params,
         $rangeInfo
      );

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

   function &getByCategoryId($categoryId, $pressId = null, $rangeInfo = null) {
      $primaryLocale = AppLocale::getPrimaryLocale();
      $locale = AppLocale::getLocale();

      $params = array(
         REALLY_BIG_NUMBER,
         'title', $primaryLocale, // Series title
         'title', $locale, // Series title
         'abbrev', $primaryLocale, // Series abbreviation
         'abbrev', $locale, // Series abbreviation
         (int) $categoryId, (int) $categoryId, (int) $categoryId,
         ASSOC_TYPE_SERIES
      );

      if ($pressId) $params[] = (int) $pressId;

      $result =& $this->retrieveRange(
         'SELECT  DISTINCT pm.*,
            m.*,
            COALESCE(stl.setting_value, stpl.setting_value) AS series_title,
            COALESCE(sal.setting_value, sapl.setting_value) AS series_abbrev,
            COALESCE(f.seq, ?) AS order_by
         FROM  published_monographs pm
            JOIN monographs m ON pm.monograph_id = m.monograph_id
            LEFT JOIN series s ON s.series_id = m.series_id
            LEFT JOIN series_settings stpl ON (s.series_id = stpl.series_id AND stpl.setting_name = ? AND stpl.locale = ?)
            LEFT JOIN series_settings stl ON (s.series_id = stl.series_id AND stl.setting_name = ? AND stl.locale = ?)
            LEFT JOIN series_settings sapl ON (s.series_id = sapl.series_id AND sapl.setting_name = ? AND sapl.locale = ?)
            LEFT JOIN series_settings sal ON (s.series_id = sal.series_id AND sal.setting_name = ? AND sal.locale = ?)
            LEFT JOIN monograph_categories mc ON (mc.monograph_id = m.monograph_id AND mc.category_id = ?)
            LEFT JOIN series_categories sca ON (sca.series_id = s.series_id)
            LEFT JOIN categories sc ON (sc.category_id = sca.category_id AND sc.category_id = ?)
            LEFT JOIN features f ON (f.monograph_id = m.monograph_id AND f.assoc_type = ? AND f.assoc_id = ?)
         WHERE pm.date_published IS NOT NULL AND (sc.category_id IS NOT NULL OR mc.category_id IS NOT NULL)
            ' . ($pressId?' AND m.press_id = ?':'' ) . '
         ORDER BY order_by, pm.date_published',
         $params,
         $rangeInfo
      );

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

   function &getById($monographId, $pressId = null, $metadataApprovedOnly = true) {
      $primaryLocale = AppLocale::getPrimaryLocale();
      $locale = AppLocale::getLocale();
      $params = array(
         'title', $primaryLocale, // Series title
         'title', $locale, // Series title
         'abbrev', $primaryLocale, // Series abbreviation
         'abbrev', $locale, // Series abbreviation
         (int) $monographId
      );
      if ($pressId) $params[] = (int) $pressId;

      $result =& $this->retrieve(
         'SELECT  m.*,
            pm.*,
            COALESCE(stl.setting_value, stpl.setting_value) AS series_title,
            COALESCE(sal.setting_value, sapl.setting_value) AS series_abbrev
         FROM  monographs m
            JOIN published_monographs pm ON (pm.monograph_id = m.monograph_id)
            LEFT JOIN series s ON s.series_id = m.series_id
            LEFT JOIN series_settings stpl ON (s.series_id = stpl.series_id AND stpl.setting_name = ? AND stpl.locale = ?)
            LEFT JOIN series_settings stl ON (s.series_id = stl.series_id AND stl.setting_name = ? AND stl.locale = ?)
            LEFT JOIN series_settings sapl ON (s.series_id = sapl.series_id AND sapl.setting_name = ? AND sapl.locale = ?)
            LEFT JOIN series_settings sal ON (s.series_id = sal.series_id AND sal.setting_name = ? AND sal.locale = ?)
         WHERE m.monograph_id = ?
            ' . ($pressId?' AND m.press_id = ?':'')
            . ($metadataApprovedOnly?' AND pm.date_published IS NOT NULL':''),
         $params
      );

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

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

      return $returner;
   }

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

   function &_fromRow($row, $callHooks = true) {
      // Get the PublishedMonograph object, populated with Monograph data
      $publishedMonograph =& parent::_fromRow($row, $callHooks);

      // Add the additional PublishedMonograph data
      $publishedMonograph->setDatePublished($this->datetimeFromDB($row['date_published']));
      $publishedMonograph->setAudience($row['audience']);
      $publishedMonograph->setAudienceRangeQualifier($row['audience_range_qualifier']);
      $publishedMonograph->setAudienceRangeFrom($row['audience_range_from']);
      $publishedMonograph->setAudienceRangeTo($row['audience_range_to']);
      $publishedMonograph->setAudienceRangeExact($row['audience_range_exact']);
      $publishedMonograph->setCoverImage(unserialize($row['cover_image']));

      if ($callHooks) HookRegistry::call('PublishedMonographDAO::_fromRow', array(&$publishedMonograph, &$row));
      return $publishedMonograph;
   }


   function insertObject(&$publishedMonograph) {

      $this->update(
         sprintf('INSERT INTO published_monographs
            (monograph_id, date_published, audience, audience_range_qualifier, audience_range_from, audience_range_to, audience_range_exact, cover_image)
            VALUES
            (?, %s, ?, ?, ?, ?, ?, ?)',
            $this->datetimeToDB($publishedMonograph->getDatePublished())),
         array(
            (int) $publishedMonograph->getId(),
            $publishedMonograph->getAudience(),
            $publishedMonograph->getAudienceRangeQualifier(),
            $publishedMonograph->getAudienceRangeFrom(),
            $publishedMonograph->getAudienceRangeTo(),
            $publishedMonograph->getAudienceRangeExact(),
            serialize($publishedMonograph->getCoverImage() ? $publishedMonograph->getCoverImage() : array()),
         )
      );
   }

   function deleteById($monographId) {
      $this->update(
         'DELETE FROM published_monographs WHERE monograph_id = ?',
         (int) $monographId
      );
   }

   function updateObject($publishedMonograph) {
      $this->update(
         sprintf('UPDATE   published_monographs
            SET   date_published = %s,
               audience = ?,
               audience_range_qualifier = ?,
               audience_range_from = ?,
               audience_range_to = ?,
               audience_range_exact = ?,
               cover_image = ?
            WHERE monograph_id = ?',
            $this->datetimeToDB($publishedMonograph->getDatePublished())),
         array(
            $publishedMonograph->getAudience(),
            $publishedMonograph->getAudienceRangeQualifier(),
            $publishedMonograph->getAudienceRangeFrom(),
            $publishedMonograph->getAudienceRangeTo(),
            $publishedMonograph->getAudienceRangeExact(),
            serialize($publishedMonograph->getCoverImage() ? $publishedMonograph->getCoverImage() : array()),
            (int) $publishedMonograph->getId()
         )
      );
   }
}

?>