SubscriptionTypeDAO.inc.php

<?php
 
import('classes.subscription.SubscriptionType');
 
class SubscriptionTypeDAO extends DAO {
   function newDataObject() {
      return new SubscriptionType();
   }
 
   function getById($typeId, $journalId = null) {
      $params = array((int) $typeId);
      if ($journalId) $params[] = (int) $journalId;
 
      $result = $this->retrieve(
         'SELECT * FROM subscription_types WHERE type_id = ?' .
         ($journalId?' AND journal_id = ?':''),
         $params
      );
 
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = $this->_fromRow($result->GetRowAssoc(false));
      }
 
      $result->Close();
      return $returner;
   }
 
   function getSubscriptionTypeName($typeId) {
      $result = $this->retrieve(
         'SELECT COALESCE(l.setting_value, p.setting_value) FROM subscription_type_settings l LEFT JOIN subscription_type_settings p ON (p.type_id = ? AND p.setting_name = ? AND p.locale = ?) WHERE l.type_id = ? AND l.setting_name = ? AND l.locale = ?', 
         array(
            (int) $typeId, 'name', AppLocale::getLocale(),
            (int) $typeId, 'name', AppLocale::getPrimaryLocale()
         )
      );
 
      $returner = isset($result->fields[0]) ? $result->fields[0] : false;
 
      $result->Close();
      return $returner;
   }
 
   function getSubscriptionTypeInstitutional($typeId) {
      $result = $this->retrieve(
         'SELECT institutional FROM subscription_types WHERE type_id = ?', (int) $typeId
      );
 
      $returner = isset($result->fields[0]) ? $result->fields[0] : false;
 
      $result->Close();
      return $returner;
   }
 
   function getSubscriptionTypeMembership($typeId) {
      $result = $this->retrieve(
         'SELECT membership FROM subscription_types WHERE type_id = ?', (int) $typeId
      );
 
      $returner = isset($result->fields[0]) ? $result->fields[0] : false;
 
      $result->Close();
      return $returner;
   }
 
   function getSubscriptionTypeDisablePublicDisplay($typeId) {
      $result = $this->retrieve(
         'SELECT disable_public_display FROM subscription_types WHERE type_id = ?', (int) $typeId
      );
 
      $returner = isset($result->fields[0]) ? $result->fields[0] : false;
 
      $result->Close();
      return $returner;
   }
 
   function subscriptionTypeExistsByTypeId($typeId, $journalId) {
      $result = $this->retrieve(
         'SELECT COUNT(*)
            FROM subscription_types
            WHERE type_id = ?
            AND   journal_id = ?',
         array(
            (int) $typeId,
            (int) $journalId
         )
      );
      $returner = isset($result->fields[0]) && $result->fields[0] != 0 ? true : false;
 
      $result->Close();
      return $returner;
   }
 
   function _fromRow($row) {
      $subscriptionType = $this->newDataObject();
      $subscriptionType->setId($row['type_id']);
      $subscriptionType->setJournalId($row['journal_id']);
      $subscriptionType->setCost($row['cost']);
      $subscriptionType->setCurrencyCodeAlpha($row['currency_code_alpha']);
      $subscriptionType->setDuration($row['duration']);
      $subscriptionType->setFormat($row['format']);
      $subscriptionType->setInstitutional($row['institutional']);
      $subscriptionType->setMembership($row['membership']);
      $subscriptionType->setDisablePublicDisplay($row['disable_public_display']);
      $subscriptionType->setSequence($row['seq']);
 
      $this->getDataObjectSettings('subscription_type_settings', 'type_id', $row['type_id'], $subscriptionType);
 
      HookRegistry::call('SubscriptionTypeDAO::_fromRow', array(&$subscriptionType, &$row));
 
      return $subscriptionType;
   }
 
   function getLocaleFieldNames() {
      return array('name', 'description');
   }
 
   function updateLocaleFields($subscriptionType) {
      $this->updateDataObjectSettings('subscription_type_settings', $subscriptionType, array(
         'type_id' => $subscriptionType->getId()
      ));
   }
 
   function insertObject($subscriptionType) {
      $this->update(
         'INSERT INTO subscription_types
            (journal_id, cost, currency_code_alpha, duration, format, institutional, membership, disable_public_display, seq)
            VALUES
            (?, ?, ?, ?, ?, ?, ?, ?, ?)',
         array(
            (int) $subscriptionType->getJournalId(),
            (float) $subscriptionType->getCost(),
            $subscriptionType->getCurrencyCodeAlpha(),
            $subscriptionType->getDuration(),
            $subscriptionType->getFormat(),
            (int) $subscriptionType->getInstitutional(),
            $subscriptionType->getMembership(),
            (int) $subscriptionType->getDisablePublicDisplay(),
            (float) $subscriptionType->getSequence(),
         )
      );
 
      $subscriptionType->setId($this->getInsertId());
      $this->updateLocaleFields($subscriptionType);
      return $subscriptionType->getId();
   }
 
   function updateObject($subscriptionType) {
      $this->update(
         'UPDATE subscription_types
            SET
               journal_id = ?,
               cost = ?,
               currency_code_alpha = ?,
               duration = ?,
               format = ?,
               institutional = ?,
               membership = ?,
               disable_public_display = ?,
               seq = ?
            WHERE type_id = ?',
         array(
            (int) $subscriptionType->getJournalId(),
            $subscriptionType->getCost(),
            $subscriptionType->getCurrencyCodeAlpha(),
            $subscriptionType->getDuration(),
            $subscriptionType->getFormat(),
            (int) $subscriptionType->getInstitutional(),
            $subscriptionType->getMembership(),
            (int) $subscriptionType->getDisablePublicDisplay(),
            (float) $subscriptionType->getSequence(),
            (int) $subscriptionType->getId(),
         )
      );
      $this->updateLocaleFields($subscriptionType);
   }
 
   function deleteById($typeId, $journalId = null) {
      $subscriptionType = $this->getById($typeId, $journalId);
      if ($subscriptionType) {
         $subscriptionDao = DAORegistry::getDAO($subscriptionType->getInstitutional()?'InstitutionalSubscriptionDAO':'IndividualSubscriptionDAO');
         $subscriptionDao->deleteById($typeId);
         $this->update('DELETE FROM subscription_types WHERE type_id = ?', (int) $typeId);
         $this->update('DELETE FROM subscription_type_settings WHERE type_id = ?', (int) $typeId);
      }
   }
 
   function deleteByJournal($journalId) {
      $result = $this->retrieve(
         'SELECT type_id
          FROM   subscription_types
          WHERE  journal_id = ?',
          (int) $journalId
      );
      if ($result->RecordCount() != 0) {
         while (!$result->EOF && $returner) {
            $typeId = $result->fields[0];
            $returner = $this->deleteSubscriptionTypeById($typeId);
            $result->MoveNext();
         }
      }
      $result->Close();
   }
 
   function getByJournalId($journalId, $rangeInfo = null) {
      $result = $this->retrieveRange(
         'SELECT * FROM subscription_types WHERE journal_id = ? ORDER BY seq',
         (int) $journalId, $rangeInfo
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   function getByInstitutional($journalId, $institutional = false, $disablePublicDisplay = null, $rangeInfo = null) {
      $result = $this->retrieveRange(
         'SELECT  *
         FROM subscription_types
         WHERE journal_id = ?
            AND institutional = ?
            ' . ($disablePublicDisplay===true?'AND disable_public_display = 1':'') . '
            ' . ($disablePublicDisplay===false?'AND disable_public_display = 0':'') . '
         ORDER BY seq',
         array((int) $journalId, (int) $institutional),
         $rangeInfo
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   function subscriptionTypesExistByInstitutional($journalId, $institutional = false) {
      $result = $this->retrieve(
         'SELECT COUNT(*)
         FROM
         subscription_types st
         WHERE st.journal_id = ?
         AND st.institutional = ?',
         array((int) $journalId, (int) $institutional)
      );
      $returner = isset($result->fields[0]) && $result->fields[0] != 0 ? true : false;
      $result->Close();
      return $returner;
   }
 
   function getInsertId() {
      return $this->_getInsertId('subscription_types', 'type_id');
   }
 
   function resequenceSubscriptionTypes($journalId) {
      $result = $this->retrieve(
         'SELECT type_id FROM subscription_types WHERE journal_id = ? ORDER BY seq',
         (int) $journalId
      );
 
      for ($i=1; !$result->EOF; $i++) {
         list($subscriptionTypeId) = $result->fields;
         $this->update(
            'UPDATE subscription_types SET seq = ? WHERE type_id = ?',
            array(
               (int) $i,
               (int) $subscriptionTypeId
            )
         );
 
         $result->MoveNext();
      }
 
      $result->Close();
   }
}