NewReleaseDAO.inc.php

<?php
 
class NewReleaseDAO extends DAO {
   function __construct() {
      parent::__construct();
   }
 
   function getMonographIdsByAssoc($assocType, $assocId) {
      $returner = array();
      $result = $this->retrieve(
         'SELECT submission_id FROM new_releases WHERE assoc_type = ? AND assoc_id = ?',
         array((int) $assocType, (int) $assocId)
      );
 
      while (!$result->EOF) {
         list($monographId) = $result->fields;
         $returner[$monographId] = true;
         $result->MoveNext();
      }
 
      $result->Close();
      return $returner;
   }
 
   function getMonographsByAssoc($assocType, $assocId) {
      // import STATUS_PUBLISHED constant
      import('classes.submission.Submission');
      $result = $this->retrieve(
         'SELECT  n.submission_id
         FROM  new_releases n,
            submissions s,
            publications p
         WHERE n.submission_id = s.submission_id
            AND p.publication_id = s.current_publication_id
            AND n.assoc_type = ? AND n.assoc_id = ?
            AND s.status = ?
         ORDER BY p.date_published DESC',
         array((int) $assocType, (int) $assocId, STATUS_PUBLISHED)
      );
 
      $returner = array();
      while (!$result->EOF) {
         list($monographId) = $result->fields;
         $returner[] = Services::get('submission')->get($monographId);
         $result->MoveNext();
      }
      $result->Close();
      return $returner;
   }
 
   function insertNewRelease($monographId, $assocType, $assocId) {
      $this->update(
         'INSERT INTO new_releases
            (submission_id, assoc_type, assoc_id)
            VALUES
            (?, ?, ?)',
         array(
            (int) $monographId,
            (int) $assocType,
            (int) $assocId
         )
      );
   }
 
   function deleteByMonographId($monographId) {
      $this->update(
         'DELETE FROM new_releases WHERE submission_id = ?',
         (int) $monographId
      );
   }
 
   function deleteByAssoc($assocType, $assocId) {
      $this->update(
         'DELETE FROM new_releases WHERE assoc_type = ? AND assoc_id = ?',
         array((int) $assocType, (int) $assocId)
      );
   }
 
   function deleteNewRelease($monographId, $assocType, $assocId) {
      $this->update(
         'DELETE FROM new_releases
         WHERE submission_id = ? AND
            assoc_type = ? AND
            assoc_id = ?',
         array(
            (int) $monographId,
            (int) $assocType,
            (int) $assocId
         )
      );
   }
 
   function isNewRelease($monographId, $assocType, $assocId) {
      $result = $this->retrieve(
         'SELECT submission_id FROM new_releases WHERE submission_id = ? AND assoc_type = ? AND assoc_id = ?',
         array((int) $monographId, (int) $assocType, (int) $assocId)
      );
      if ($result->RecordCount() > 0) {
         return true;
      }
 
      return false;
   }
 
   function getNewReleaseAll($monographId) {
      $result = $this->retrieve(
         'SELECT assoc_type, assoc_id FROM new_releases WHERE submission_id = ?',
         array((int) $monographId)
      );
 
      $newRelease = array();
      while (!$result->EOF) {
         $newRelease[] = array(
            'assoc_type' => (int) $result->fields['assoc_type'],
            'assoc_id' => (int) $result->fields['assoc_id'],
         );
         $result->MoveNext();
      }
 
      return $newRelease;
   }
}