IndividualSubscriptionDAO.inc.php

<?php
 
import('classes.subscription.SubscriptionDAO');
import('classes.subscription.IndividualSubscription');
 
class IndividualSubscriptionDAO extends SubscriptionDAO {
   function getById($subscriptionId, $journalId = null) {
      $params = array((int) $subscriptionId);
      if ($journalId) $params[] = (int) $journalId;
      $result = $this->retrieve(
         'SELECT  s.*
         FROM  subscriptions s
            JOIN subscription_types st ON (s.type_id = st.type_id)
         WHERE st.institutional = 0
            AND s.subscription_id = ?
            ' . ($journalId?' AND s.journal_id = ?':''),
         $params
      );
 
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = $this->_fromRow($result->GetRowAssoc(false));
      }
 
      $result->Close();
      return $returner;
   }
 
   function getByUserIdForJournal($userId, $journalId) {
      $result = $this->retrieveRange(
         'SELECT s.*
         FROM
         subscriptions s,
         subscription_types st
         WHERE s.type_id = st.type_id
         AND st.institutional = 0
         AND s.user_id = ?
         AND s.journal_id = ?',
         array(
            (int) $userId,
            (int) $journalId
         )
      );
 
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = $this->_fromRow($result->GetRowAssoc(false));
      }
 
      $result->Close();
      return $returner;
   }
 
   function getByUserId($userId, $rangeInfo = null) {
      $result = $this->retrieveRange(
         'SELECT s.*
         FROM
         subscriptions s,
         subscription_types st
         WHERE s.type_id = st.type_id
         AND st.institutional = 0
         AND s.user_id = ?',
         (int) $userId,
         $rangeInfo
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   function getStatusCount($journalId, $status = null) {
      $params = array((int) $journalId);
      if ($status !== null) $params[] = (int) $status;
 
      $result = $this->retrieve(
         'SELECT  COUNT(*)
         FROM  subscriptions s,
            subscription_types st
         WHERE s.type_id = st.type_id AND
            st.institutional = 0 AND
            s.journal_id = ?
         ' . ($status !== null?' AND s.status = ?':''),
         $params
      );
 
      $returner = isset($result->fields[0]) ? $result->fields[0] : 0;
 
      $result->Close();
      return $returner;
   }
 
   function getSubscribedUserCount($journalId) {
      return $this->getStatusCount($journalId);
   }
 
   function subscriptionExists($subscriptionId) {
      $result = $this->retrieve(
         'SELECT COUNT(*)
         FROM
         subscriptions s,
         subscription_types st
         WHERE s.type_id = st.type_id
         AND st.institutional = 0
         AND s.subscription_id = ?',
         (int) $subscriptionId
      );
 
      $returner = isset($result->fields[0]) && $result->fields[0] != 0 ? true : false;
 
      $result->Close();
      return $returner;
   }
 
   function subscriptionExistsByUser($subscriptionId, $userId) {
      $result = $this->retrieve(
         'SELECT COUNT(*)
         FROM
         subscriptions s,
         subscription_types st
         WHERE s.type_id = st.type_id
         AND st.institutional = 0
         AND s.subscription_id = ?
         AND s.user_id = ?',
         array(
            (int) $subscriptionId,
            (int) $userId
         )
      );
 
      $returner = isset($result->fields[0]) && $result->fields[0] != 0 ? true : false;
 
      $result->Close();
      return $returner;
   }
 
   function subscriptionExistsByUserForJournal($userId, $journalId) {
      $result = $this->retrieve(
         'SELECT COUNT(*)
         FROM
         subscriptions s,
         subscription_types st
         WHERE s.type_id = st.type_id
         AND st.institutional = 0
         AND s.user_id = ?
         AND s.journal_id = ?',
         array(
            (int) $userId,
            (int) $journalId
         )
      );
 
      $returner = isset($result->fields[0]) && $result->fields[0] != 0 ? true : false;
 
      $result->Close();
      return $returner;
   }
 
   function newDataObject() {
      return new IndividualSubscription();
   }
 
   function _fromRow($row) {
      $individualSubscription = parent::_fromRow($row);
      HookRegistry::call('IndividualSubscriptionDAO::_fromRow', array(&$individualSubscription, &$row));
 
      return $individualSubscription;
   }
 
   function insertObject($individualSubscription) {
      return $this->_insertObject($individualSubscription);
   }
 
   function updateObject($individualSubscription) {
      $this->_updateObject($individualSubscription);
   }
 
   function deleteById($subscriptionId, $journalId = null) {
      $params = array((int) $subscriptionId);
      if ($journalId) $params[] = (int) $journalId;
      $this->update(
         'DELETE FROM subscriptions
         WHERE subscription_id = ?'
         .($journalId ? ' AND journal_id = ?' : ''),
         $params
      );
   }
 
   function deleteByJournalId($journalId) {
      $result = $this->retrieve(
         'SELECT s.subscription_id
         FROM
         subscriptions s
         WHERE s.journal_id = ?',
         (int) $journalId
      );
 
      $returner = true;
      if ($result->RecordCount() != 0) {
         while (!$result->EOF) {
            $subscriptionId = $result->fields[0];
            $returner = $this->deleteById($subscriptionId);
            if (!$returner) {
               break;
            }
            $result->MoveNext();
         }
      }
 
      $result->Close();
      return $returner;
   }
 
   function deleteByUserId($userId) {
      $result = $this->retrieve(
         'SELECT s.subscription_id
         FROM
         subscriptions s
         WHERE s.user_id = ?',
         (int) $userId
      );
 
      $returner = true;
      if ($result->RecordCount() != 0) {
         while (!$result->EOF) {
            $subscriptionId = $result->fields[0];
            $returner = $this->deleteById($subscriptionId);
            if (!$returner) {
               break;
            }
            $result->MoveNext();
         }
      }
 
      $result->Close();
      return $returner;
   }
 
   function deleteByUserIdForJournal($userId, $journalId) {
      $result = $this->retrieve(
         'SELECT s.subscription_id
         FROM
         subscriptions s
         WHERE s.user_id = ?
         AND s.journal_id = ?',
         array (
            (int) $userId,
            (int) $journalId
         )
      );
 
      $returner = true;
      if ($result->RecordCount() != 0) {
         while (!$result->EOF) {
            $subscriptionId = $result->fields[0];
            $returner = $this->deleteById($subscriptionId);
            if (!$returner) {
               break;
            }
            $result->MoveNext();
         }
      }
 
      $result->Close();
      return $returner;
   }
 
   function deleteByTypeId($subscriptionTypeId) {
      $result = $this->retrieve(
         'SELECT s.subscription_id
         FROM
         subscriptions s
         WHERE s.type_id = ?',
         (int) $subscriptionTypeId
      );
 
      $returner = true;
      if ($result->RecordCount() != 0) {
         while (!$result->EOF) {
            $subscriptionId = $result->fields[0];
            $returner = $this->deleteById($subscriptionId);
            if (!$returner) {
               break;
            }
            $result->MoveNext();
         }
      }
 
      $result->Close();
      return $returner;
   }
 
   function getAll($rangeInfo = null) {
      $userDao = DAORegistry::getDAO('UserDAO'); /* @var $userDao UserDAO */
      $result = $this->retrieveRange(
         'SELECT s.*,
         ' . $userDao->getFetchColumns() .'
         FROM
         subscriptions s,
         subscription_types st,
         users u,
         ' . $userDao->getFetchJoins() .'
         WHERE s.type_id = st.type_id
         AND st.institutional = 0
         AND s.user_id = u.user_id
         ' . $userDao->getOrderBy() .',
         s.subscription_id',
         $userDao->getFetchParameters(),
         $rangeInfo
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   function getByJournalId($journalId, $status = null, $searchField = null, $searchMatch = null, $search = null, $dateField = null, $dateFrom = null, $dateTo = null, $rangeInfo = null) {
      $userDao = DAORegistry::getDAO('UserDAO'); /* @var $userDao UserDAO */
      $params = array_merge($userDao->getFetchParameters(), array((int) $journalId));
      $result = $this->retrieveRange(
         'SELECT  s.*,
         ' . $userDao->getFetchColumns() . '
         FROM  subscriptions s
            JOIN subscription_types st ON (s.type_id = st.type_id)
            JOIN users u ON (s.user_id = u.user_id)
            ' . $userDao->getFetchJoins() . '
         WHERE st.institutional = 0
            AND s.journal_id = ? ' .
         parent::_generateSearchSQL($status, $searchField, $searchMatch, $search, $dateField, $dateFrom, $dateTo, $params) . ' ' .
         $userDao->getOrderBy() .', s.subscription_id',
         $params,
         $rangeInfo
      );
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   function isValidIndividualSubscription($userId, $journalId, $check = SUBSCRIPTION_DATE_BOTH, $checkDate = null) {
      if (empty($userId) || empty($journalId)) {
         return false;
      }
 
      $today = $this->dateToDB(Core::getCurrentDate());
 
      if ($checkDate == null) {
         $checkDate = $today;
      } else {
         $checkDate = $this->dateToDB($checkDate);
      }
 
      switch($check) {
         case SUBSCRIPTION_DATE_START:
            $dateSql = sprintf('%s >= s.date_start AND %s >= s.date_start', $checkDate, $today);
            break;
         case SUBSCRIPTION_DATE_END:
            $dateSql = sprintf('%s <= s.date_end AND %s >= s.date_start', $checkDate, $today);
            break;
         default:
            $dateSql = sprintf('%s >= s.date_start AND %s <= s.date_end', $checkDate, $checkDate);
      }
 
      $result = $this->retrieve('
         SELECT   s.subscription_id
         FROM  subscriptions s
            JOIN subscription_types st ON (s.type_id = st.type_id)
         WHERE s.user_id = ?
            AND s.journal_id = ?
            AND s.status = ' . SUBSCRIPTION_STATUS_ACTIVE . '
            AND st.institutional = 0
            AND ((st.non_expiring = 1) OR (st.non_expiring = 0 AND (' . $dateSql . ')))
            AND (st.format = ' . SUBSCRIPTION_TYPE_FORMAT_ONLINE . '
            OR st.format = ' . SUBSCRIPTION_TYPE_FORMAT_PRINT_ONLINE . ')',
         array(
            (int) $userId,
            (int) $journalId
         )
      );
 
      if ($result->RecordCount() != 0) $returner = (boolean) $result->fields[0];
      else $returner = false;
 
      $result->Close();
      return $returner;
   }
 
   function getByDateEnd($dateEnd, $journalId, $rangeInfo = null) {
      $userDao = DAORegistry::getDAO('UserDAO'); /* @var $userDao UserDAO */
      $dateEnd = explode('-', $dateEnd);
      $params = array_merge(
         $userDao->getFetchParameters(),
         array(
            $dateEnd[0],
            $dateEnd[1],
            $dateEnd[2],
            (int) $journalId
      ));
 
      $result = $this->retrieveRange(
         'SELECT  s.*,
         ' . $userDao->getFetchColumns() .'
         FROM  subscriptions s
            JOIN subscription_types st ON (s.type_id = st.type_id)
            JOIN users u ON (u.user_id = s.user_id)
            ' . $userDao->getFetchJoins() .'
         WHERE s.status = ' . SUBSCRIPTION_STATUS_ACTIVE . '
            AND st.institutional = 0
            AND EXTRACT(YEAR FROM s.date_end) = ?
            AND EXTRACT(MONTH FROM s.date_end) = ?
            AND EXTRACT(DAY FROM s.date_end) = ?
            AND s.journal_id = ?
         ' . $userDao->getOrderBy() .', s.subscription_id',
         $params,
         $rangeInfo
      );
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   function renewSubscription($individualSubscription) {
      return $this->_renewSubscription($individualSubscription);
   }
}