classes/subscription/SubscriptionTypeDAO.inc.php

<?php

// $Id: SubscriptionTypeDAO.inc.php,v 1.21 2008/07/01 01:16:11 asmecher Exp $


import('subscription.SubscriptionType');

class SubscriptionTypeDAO extends DAO {
   function &getSubscriptionType($typeId) {
      $result = &$this->retrieve(
         'SELECT * FROM subscription_types WHERE type_id = ?', $typeId
      );

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

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

      return $returner;
   }

   function getSubscriptionTypeJournalId($typeId) {
      $result = &$this->retrieve(
         'SELECT journal_id FROM subscription_types WHERE type_id = ?', $typeId
      );

      $returner = isset($result->fields[0]) ? $result->fields[0] : false;  

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

      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(
            $typeId, 'name', Locale::getLocale(),
            $typeId, 'name', Locale::getPrimaryLocale()
         )
      );

      $returner = isset($result->fields[0]) ? $result->fields[0] : false;

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

      return $returner;
   }

   function getSubscriptionTypeInstitutional($typeId) {
      $result = &$this->retrieve(
         'SELECT institutional FROM subscription_types WHERE type_id = ?', $typeId
      );

      $returner = isset($result->fields[0]) ? $result->fields[0] : false;

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

      return $returner;
   }

   function getSubscriptionTypeMembership($typeId) {
      $result = &$this->retrieve(
         'SELECT membership FROM subscription_types WHERE type_id = ?', $typeId
      );

      $returner = isset($result->fields[0]) ? $result->fields[0] : false;

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

      return $returner;
   }

   function getSubscriptionTypeDisablePublicDisplay($typeId) {
      $result = &$this->retrieve(
         'SELECT disable_public_display FROM subscription_types WHERE type_id = ?', $typeId
      );

      $returner = isset($result->fields[0]) ? $result->fields[0] : false;

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

      return $returner;
   }

   function subscriptionTypeExistsByTypeId($typeId, $journalId) {
      $result = &$this->retrieve(
         'SELECT COUNT(*)
            FROM subscription_types
            WHERE type_id = ?
            AND   journal_id = ?',
         array(
            $typeId,
            $journalId
         )
      );
      $returner = isset($result->fields[0]) && $result->fields[0] != 0 ? true : false;

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

      return $returner;
   }

   function &_returnSubscriptionTypeFromRow(&$row) {
      $subscriptionType = &new SubscriptionType();
      $subscriptionType->setTypeId($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::_returnSubscriptionTypeFromRow', array(&$subscriptionType, &$row));

      return $subscriptionType;
   }

   function getLocaleFieldNames() {
      return array('name', 'description');
   }

   function updateLocaleFields(&$subscriptionType) {
      $this->updateDataObjectSettings('subscription_type_settings', $subscriptionType, array(
         'type_id' => $subscriptionType->getTypeId()
      ));
   }

   function insertSubscriptionType(&$subscriptionType) {
      $this->update(
         'INSERT INTO subscription_types
            (journal_id, cost, currency_code_alpha, duration, format, institutional, membership, disable_public_display, seq)
            VALUES
            (?, ?, ?, ?, ?, ?, ?, ?, ?)',
         array(
            $subscriptionType->getJournalId(),
            $subscriptionType->getCost(),
            $subscriptionType->getCurrencyCodeAlpha(),
            $subscriptionType->getDuration(),
            $subscriptionType->getFormat(),
            $subscriptionType->getInstitutional(),
            $subscriptionType->getMembership(),
            $subscriptionType->getDisablePublicDisplay(),
            $subscriptionType->getSequence()
         )
      );

      $subscriptionType->setTypeId($this->getInsertSubscriptionTypeId());
      $this->updateLocaleFields($subscriptionType);
      return $subscriptionType->getTypeId();
   }

   function updateSubscriptionType(&$subscriptionType) {
      $returner = $this->update(
         'UPDATE subscription_types
            SET
               journal_id = ?,
               cost = ?,
               currency_code_alpha = ?,
               duration = ?,
               format = ?,
               institutional = ?,
               membership = ?,
               disable_public_display = ?,
               seq = ?
            WHERE type_id = ?',
         array(
            $subscriptionType->getJournalId(),
            $subscriptionType->getCost(),
            $subscriptionType->getCurrencyCodeAlpha(),
            $subscriptionType->getDuration(),
            $subscriptionType->getFormat(),
            $subscriptionType->getInstitutional(),
            $subscriptionType->getMembership(),
            $subscriptionType->getDisablePublicDisplay(),
            $subscriptionType->getSequence(),
            $subscriptionType->getTypeId()
         )
      );
      $this->updateLocaleFields($subscriptionType);
      return $returner;
   }

   function deleteSubscriptionType(&$subscriptionType) {
      return $this->deleteSubscriptionTypeById($subscriptionType->getTypeId());
   }

   function deleteSubscriptionTypeById($typeId) {
      // Delete subscription type
      $returner = $this->update('DELETE FROM subscription_types WHERE type_id = ?', $typeId);

      // Delete all localization settings and subscriptions for this subscription type
      if ($returner) {
         $this->update('DELETE FROM subscription_type_settings WHERE type_id = ?', $typeId);
         $subscriptionDao = &DAORegistry::getDAO('SubscriptionDAO');
         return $subscriptionDao->deleteSubscriptionByTypeId($typeId);
      } else {
         return $returner;
      }
   }

   function deleteSubscriptionTypesByJournal($journalId) {
      $result = &$this->retrieve(
         'SELECT type_id
          FROM   subscription_types
          WHERE  journal_id = ?',
          $journalId
      );

      $returner = false;

      if ($result->RecordCount() != 0) {
         $returner = true;
         while (!$result->EOF && $returner) {
            $typeId = $result->fields[0];
            $returner = $this->deleteSubscriptionTypeById($typeId);
            $result->moveNext();
         }
      }

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

      return $returner;
   }

   function &getSubscriptionTypesByJournalId($journalId, $rangeInfo = null) {
      $result = &$this->retrieveRange(
         'SELECT * FROM subscription_types WHERE journal_id = ? ORDER BY seq',
         $journalId, $rangeInfo
      );

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

   function getInsertSubscriptionTypeId() {
      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',
         $journalId
      );

      for ($i=1; !$result->EOF; $i++) {
         list($subscriptionTypeId) = $result->fields;
         $this->update(
            'UPDATE subscription_types SET seq = ? WHERE type_id = ?',
            array(
               $i,
               $subscriptionTypeId
            )
         );

         $result->moveNext();
      }

      $result->close();
      unset($result);
   }
}

?>

---