classes/oai/omp/OAIDAO.inc.php

<?php

import('lib.pkp.classes.oai.PKPOAIDAO');

class OAIDAO extends PKPOAIDAO {

   var $_publicationFormatDao;

   var $_publishedMonographDao;

   var $_seriesDao;

   var $_pressDao;

   var $_pressCache;

   var $_seriesCache;

   function OAIDAO() {
      parent::PKPOAIDAO();

      $this->_publicationFormatDao = DAORegistry::getDAO('PublicationFormatDAO');
      $this->_publishedMonographDao = DAORegistry::getDAO('PublishedMonographDAO');
      $this->_seriesDao = DAORegistry::getDAO('SeriesDAO');
      $this->_pressDao = DAORegistry::getDAO('PressDAO');
   }

   function getEarliestDatestamp($setIds) {
      return parent::getEarliestDatestamp('SELECT  MIN(COALESCE(dot.date_deleted, ms.last_modified))', $setIds);
   }

   function &getPress($pressId) {
      if (!isset($this->_pressCache[$pressId])) {
         $this->_pressCache[$pressId] =& $this->_pressDao->getById($pressId);
      }
      return $this->_pressCache[$pressId];
   }

   function &getSeries($seriesId) {
      if (!isset($this->_seriesCache[$seriesId])) {
         $this->_seriesCache[$seriesId] =& $this->_seriesDao->getById($seriesId);
      }
      return $this->_seriesCache[$seriesId];
   }

   //
   // Sets
   //

   function &getSets($pressId = null, $offset, $limit, &$total) {
      if (isset($pressId)) {
         $presses = array($this->getPress($pressId));
      } else {
         $pressFactory =& $this->_pressDao->getPresses();
         $presses =& $pressFactory->toArray();
      }

      // FIXME Set descriptions
      $sets = array();
      foreach ($presses as $press) {
         $title = $press->getLocalizedName();
         $abbrev = $press->getPath();
         array_push($sets, new OAISet(urlencode($abbrev), $title, ''));

         $dataObjectTombstoneDao =& DAORegistry::getDAO('DataObjectTombstoneDAO');
         $publicationFormatSets = $dataObjectTombstoneDao->getSets(ASSOC_TYPE_PRESS, $press->getId());

         $seriesFactory =& $this->_seriesDao->getByPressId($press->getId());
         foreach ($seriesFactory->toArray() as $series) {
            if (array_key_exists(urlencode($abbrev) . ':' . urlencode($series->getPath()), $publicationFormatSets)) {
               unset($publicationFormatSets[urlencode($abbrev) . ':' . urlencode($series->getPath())]);
            }
            array_push($sets, new OAISet(urlencode($abbrev) . ':' . urlencode($series->getPath()), $series->getLocalizedTitle(), ''));
         }
         foreach ($publicationFormatSets as $publicationFormatSetSpec => $publicationFormatSetName) {
            array_push($sets, new OAISet($publicationFormatSetSpec, $publicationFormatSetName, ''));
         }
      }

      HookRegistry::call('OAIDAO::getSets', array(&$this, $pressId, $offset, $limit, $total, &$sets));

      $total = count($sets);
      $sets = array_slice($sets, $offset, $limit);

      return $sets;
   }

   function getSetPressSeriesId($pressSpec, $seriesSpec, $restrictPressId = null) {
      $pressId = null;

      $press =& $this->_pressDao->getPressByPath($pressSpec);
      if (!isset($press) || (isset($restrictPressId) && $press->getId() != $restrictPressId)) {
         return array(0, 0);
      }

      $pressId = $press->getId();
      $seriesId = null;

      if (isset($seriesSpec)) {
         $series =& $this->_seriesDao->getByPath($seriesSpec, $press->getId());
         if (is_a($series, 'Series')) {
            $seriesId = $series->getId();
         } else {
            $seriesId = 0;
         }
      }

      return array($pressId, $seriesId);
   }


   //
   // Protected methods.
   //
   function getRecordSelectStatement() {
      return 'SELECT COALESCE(dot.date_deleted, ms.last_modified) AS last_modified,
         COALESCE(pf.publication_format_id, dot.data_object_id) AS data_object_id,
         COALESCE(p.press_id, tsop.assoc_id) AS press_id,
         COALESCE(tsos.assoc_id, s.series_id) AS series_id,
         dot.tombstone_id,
         dot.set_spec,
         dot.oai_identifier';
   }

   function getRecordJoinClause($publicationFormatId = null, $setIds = array(), $set = null) {
      assert(is_array($setIds));
      list($pressId, $seriesId) = $setIds;
      return 'LEFT JOIN publication_formats pf ON (m.i=0' . (isset($publicationFormatId) ? ' AND pf.publication_format_id = ?' : '') . ')
         LEFT JOIN published_monographs pm ON (pm.monograph_id = pf.monograph_id)
         LEFT JOIN monographs ms ON (ms.monograph_id = pm.monograph_id' . (isset($pressId) ? ' AND ms.press_id = ?' : '') . (isset($seriesId) && $seriesId != 0 ? ' AND ms.series_id = ?' : '') .')
         LEFT JOIN series s ON (s.series_id = ms.series_id)
         LEFT JOIN presses p ON (p.press_id = ms.press_id)
         LEFT JOIN data_object_tombstones dot ON (m.i = 1' . (isset($publicationFormatId) ? ' AND dot.data_object_id = ?' : '') . (isset($set) ? ' AND dot.set_spec = ?' : '') . ')
         LEFT JOIN data_object_tombstone_oai_set_objects tsop ON ' . (isset($pressId) ? '(tsop.tombstone_id = dot.tombstone_id AND tsop.assoc_type = ' . ASSOC_TYPE_PRESS . ' AND tsop.assoc_id = ?)' : 'tsop.assoc_id = null') .
         ' LEFT JOIN data_object_tombstone_oai_set_objects tsos ON ' . (isset($seriesId) ? '(tsos.tombstone_id = dot.tombstone_id AND tsos.assoc_type = ' . ASSOC_TYPE_SERIES . ' AND tsos.assoc_id = ?)' : 'tsos.assoc_id = null');
   }

   function getAccessibleRecordWhereClause() {
      return 'WHERE ((p.enabled = 1 AND ms.status <> ' . STATUS_ARCHIVED . ' AND pf.is_available = 1) OR dot.data_object_id IS NOT NULL)';
   }

   function getDateRangeWhereClause($from, $until) {
      return (isset($from) ? ' AND ((dot.date_deleted IS NOT NULL AND dot.date_deleted >= '. $this->datetimeToDB($from) .') OR (dot.date_deleted IS NULL AND ms.last_modified >= ' . $this->datetimeToDB($from) .'))' : '')
         . (isset($until) ? ' AND ((dot.date_deleted IS NOT NULL AND dot.date_deleted <= ' .$this->datetimeToDB($until) .') OR (dot.date_deleted IS NULL AND ms.last_modified <= ' . $this->datetimeToDB($until) .'))' : '')
         . ' ORDER BY press_id';
   }

   function &setOAIData(&$record, &$row, $isRecord = true) {
      $press =& $this->getPress($row['press_id']);
      $series =& $this->getSeries($row['series_id']);
      $publicationFormatId = $row['data_object_id'];

      $record->identifier = $this->oai->publicationFormatIdToIdentifier($publicationFormatId);
      $record->sets = array(urlencode($press->getPath()) . ($series?':' . urlencode($series->getPath()):''));

      if ($isRecord) {
         $publicationFormat =& $this->_publicationFormatDao->getById($publicationFormatId);
         $monograph =& $this->_publishedMonographDao->getById($publicationFormat->getMonographId());
         $record->setData('publicationFormat', $publicationFormat);
         $record->setData('monograph', $monograph);
         $record->setData('press', $press);
         $record->setData('series', $series);
      }

      return $record;
   }
}

?>