IssueGalleyDAO.inc.php

<?php
 
import('classes.issue.IssueGalley');
 
class IssueGalleyDAO extends DAO {
 
   function getById($galleyId, $issueId = null) {
      $params = array((int) $galleyId);
      if ($issueId !== null) $params[] = (int) $issueId;
      $result = $this->retrieve(
         'SELECT
            g.*,
            f.file_name,
            f.original_file_name,
            f.file_type,
            f.file_size,
            f.content_type,
            f.date_uploaded,
            f.date_modified
         FROM issue_galleys g
            LEFT JOIN issue_files f ON (g.file_id = f.file_id)
         WHERE g.galley_id = ?' .
         ($issueId !== null?' AND g.issue_id = ?':''),
         $params
      );
 
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = $this->_fromRow($result->GetRowAssoc(false));
      } else {
         HookRegistry::call('IssueGalleyDAO::getById', array(&$galleyId, &$issueId, &$returner));
      }
      $result->Close();
      return $returner;
   }
 
   function pubIdExists($pubIdType, $pubId, $galleyId, $journalId) {
      $result = $this->retrieve(
         'SELECT COUNT(*)
         FROM issue_galley_settings igs
            INNER JOIN issue_galleys ig ON igs.galley_id = ig.galley_id
            INNER JOIN issues i ON ig.issue_id = i.issue_id
         WHERE igs.setting_name = ? AND igs.setting_value = ? AND igs.galley_id <> ? AND i.journal_id = ?',
         array(
            'pub-id::'.$pubIdType,
            $pubId,
            (int) $galleyId,
            (int) $journalId
         )
      );
      $returner = $result->fields[0] ? true : false;
      $result->Close();
      return $returner;
   }
 
   function getByPubId($pubIdType, $pubId, $issueId) {
      $result = $this->retrieve(
         'SELECT
            g.*,
            f.file_name,
            f.original_file_name,
            f.file_type,
            f.file_size,
            f.content_type,
            f.date_uploaded,
            f.date_modified
         FROM issue_galleys g
            INNER JOIN issue_galley_settings gs ON g.galley_id = gs.galley_id
            LEFT JOIN issue_files f ON (g.file_id = f.file_id)
         WHERE gs.setting_name = ? AND
            gs.setting_value = ? AND
            g.issue_id = ?',
         array('pub-id::'.$pubIdType, (string) $pubId, (int) $issueId)
      );
 
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = $this->_fromRow($result->GetRowAssoc(false));
      } else {
         HookRegistry::call('IssueGalleyDAO::getByPubId', array(&$pubIdType, &$pubId, &$issueId, &$returner));
      }
      $result->Close();
      return $returner;
   }
 
   function getByIssueId($issueId) {
      $galleys = array();
 
      $result = $this->retrieve(
         'SELECT
            g.*,
            f.file_name,
            f.original_file_name,
            f.file_type,
            f.file_size,
            f.content_type,
            f.date_uploaded,
            f.date_modified
         FROM issue_galleys g
            LEFT JOIN issue_files f ON (g.file_id = f.file_id)
         WHERE g.issue_id = ? ORDER BY g.seq',
         (int) $issueId
      );
 
      while (!$result->EOF) {
         $issueGalley = $this->_fromRow($result->GetRowAssoc(false));
         $galleys[$issueGalley->getId()] = $issueGalley;
         $result->MoveNext();
      }
 
      $result->Close();
      HookRegistry::call('IssueGalleyDAO::getGalleysByIssue', array(&$galleys, &$issueId));
      return $galleys;
   }
 
   function getByBestId($galleyId, $issueId) {
      $result = $this->retrieve(
         'SELECT
            g.*,
            f.file_name,
            f.original_file_name,
            f.file_type,
            f.file_size,
            f.content_type,
            f.date_uploaded,
            f.date_modified
         FROM issue_galleys g
            LEFT JOIN issue_files f ON (g.file_id = f.file_id)
         WHERE g.url_path = ? AND
            g.issue_id = ?',
         [
            $galleyId,
            (int) $issueId,
         ]
      );
 
      if ($result->RecordCount() != 0) {
         $issueGalley = $this->_fromRow($result->GetRowAssoc(false));
      } else {
         $issueGalley = $this->getById($galleyId, $issueId);
      }
      $result->Close();
 
      return $issueGalley;
   }
 
   function getLocaleFieldNames() {
      return array();
   }
 
   function getAdditionalFieldNames() {
      $additionalFields = parent::getAdditionalFieldNames();
      // FIXME: Move this to a PID plug-in.
      $additionalFields[] = 'pub-id::publisher-id';
      return $additionalFields;
   }
 
   function updateLocaleFields($galley) {
      $this->updateDataObjectSettings('issue_galley_settings', $galley, array(
         'galley_id' => $galley->getId()
      ));
   }
 
   function newDataObject() {
      return new IssueGalley();
   }
 
   function _fromRow($row) {
      $galley = $this->newDataObject();
 
      $galley->setId($row['galley_id']);
      $galley->setIssueId($row['issue_id']);
      $galley->setLocale($row['locale']);
      $galley->setFileId($row['file_id']);
      $galley->setLabel($row['label']);
      $galley->setSequence($row['seq']);
      $galley->setData('urlPath', $row['url_path']);
 
      // IssueFile set methods
      $galley->setServerFileName($row['file_name']);
      $galley->setOriginalFileName($row['original_file_name']);
      $galley->setFileType($row['file_type']);
      $galley->setFileSize($row['file_size']);
      $galley->setContentType($row['content_type']);
      $galley->setDateModified($this->datetimeFromDB($row['date_modified']));
      $galley->setDateUploaded($this->datetimeFromDB($row['date_uploaded']));
 
      $this->getDataObjectSettings('issue_galley_settings', 'galley_id', $row['galley_id'], $galley);
 
      HookRegistry::call('IssueGalleyDAO::_fromRow', array(&$galley, &$row));
 
      return $galley;
   }
 
   function insertObject($galley) {
      $this->update(
         'INSERT INTO issue_galleys
            (issue_id,
            file_id,
            label,
            locale,
            seq,
            url_path)
            VALUES
            (?, ?, ?, ?, ?, ?)',
         array(
            (int) $galley->getIssueId(),
            (int) $galley->getFileId(),
            $galley->getLabel(),
            $galley->getLocale(),
            $galley->getSequence() == null ? $this->getNextGalleySequence($galley->getIssueId()) : $galley->getSequence(),
            $galley->getData('urlPath'),
         )
      );
      $galley->setId($this->getInsertId());
      $this->updateLocaleFields($galley);
 
      HookRegistry::call('IssueGalleyDAO::insertObject', array(&$galley, $galley->getId()));
 
      return $galley->getId();
   }
 
   function updateObject($galley) {
      $this->update(
         'UPDATE issue_galleys
            SET
               file_id = ?,
               label = ?,
               locale = ?,
               seq = ?,
               url_path = ?
            WHERE galley_id = ?',
         array(
            (int) $galley->getFileId(),
            $galley->getLabel(),
            $galley->getLocale(),
            $galley->getSequence(),
            $galley->getData('urlPath'),
            (int) $galley->getId()
         )
      );
      $this->updateLocaleFields($galley);
   }
 
   function deleteObject($galley) {
      return $this->deleteById($galley->getId(), $galley->getIssueId());
   }
 
   function deleteById($galleyId, $issueId = null) {
      HookRegistry::call('IssueGalleyDAO::deleteById', array(&$galleyId, &$issueId));
 
      if (isset($issueId)) {
         $this->update(
            'DELETE FROM issue_galleys WHERE galley_id = ? AND issue_id = ?',
            array((int) $galleyId, (int) $issueId)
         );
      } else {
         $this->update(
            'DELETE FROM issue_galleys WHERE galley_id = ?', (int) $galleyId
         );
      }
      if ($this->getAffectedRows()) {
         $this->update('DELETE FROM issue_galley_settings WHERE galley_id = ?', array((int) $galleyId));
      }
   }
 
   function deleteByIssueId($issueId) {
      $galleys = $this->getByIssueId($issueId);
      foreach ($galleys as $galley) {
         $this->deleteById($galley->getId(), $issueId);
      }
   }
 
   function resequence($issueId) {
      $result = $this->retrieve(
         'SELECT galley_id FROM issue_galleys WHERE issue_id = ? ORDER BY seq',
         (int) $issueId
      );
 
      for ($i=1; !$result->EOF; $i++) {
         list($galleyId) = $result->fields;
         $this->update(
            'UPDATE issue_galleys SET seq = ? WHERE galley_id = ?',
            array($i, $galleyId)
         );
         $result->MoveNext();
      }
 
      $result->Close();
   }
 
   function getNextGalleySequence($issueId) {
      $result = $this->retrieve(
         'SELECT MAX(seq) + 1 FROM issue_galleys WHERE issue_id = ?',
         (int) $issueId
      );
      $returner = floor($result->fields[0]);
      $result->Close();
      return $returner;
   }
 
   function getInsertId() {
      return $this->_getInsertId('issue_galleys', 'galley_id');
   }
}