SpotlightDAO.inc.php

<?php
 
import('classes.spotlight.Spotlight');
 
class SpotlightDAO extends DAO {
   function __construct() {
      parent::__construct();
   }
 
   function getById($spotlightId) {
      $result = $this->retrieve(
         'SELECT * FROM spotlights WHERE spotlight_id = ?',
         (int) $spotlightId
      );
 
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = $this->_fromRow($result->GetRowAssoc(false));
      }
      $result->Close();
      return $returner;
   }
 
   function getSpotlightAssocId($spotlightId) {
      $result = $this->retrieve(
         'SELECT assoc_id FROM spotlights WHERE spotlight_id = ?',
         (int) $spotlightId
      );
 
      $returner = isset($result->fields[0]) ? $result->fields[0] : 0;
      $result->Close();
      return $returner;
   }
 
   function getSpotlightAssocType($spotlightId) {
      $result = $this->retrieve(
         'SELECT assoc_type FROM spotlights WHERE spotlight_id = ?',
         (int) $spotlightId
      );
 
      $returner = isset($result->fields[0]) ? $result->fields[0] : 0;
      $result->Close();
      return $returner;
   }
 
   function getLocaleFieldNames() {
      return array('title', 'description');
   }
 
   function newDataObject() {
      return new Spotlight();
   }
 
   function _fromRow($row) {
      $spotlight = $this->newDataObject();
      $spotlight->setId($row['spotlight_id']);
      $spotlight->setAssocType($row['assoc_type']);
      $spotlight->setAssocId($row['assoc_id']);
      $spotlight->setPressId($row['press_id']);
 
      $this->getDataObjectSettings('spotlight_settings', 'spotlight_id', $row['spotlight_id'], $spotlight);
 
      return $spotlight;
   }
 
   function updateLocaleFields(&$spotlight) {
      $this->updateDataObjectSettings('spotlight_settings', $spotlight, array(
         'spotlight_id' => $spotlight->getId()
      ));
   }
 
   function insertObject($spotlight) {
      $this->update(
         'INSERT INTO spotlights
            (assoc_type, assoc_id, press_id)
            VALUES
            (?, ?, ?)',
         array(
            (int) $spotlight->getAssocType(),
            (int) $spotlight->getAssocId(),
            (int) $spotlight->getPressId(),
         )
      );
      $spotlight->setId($this->getInsertId());
      $this->updateLocaleFields($spotlight);
      return $spotlight->getId();
   }
 
   function updateObject($spotlight) {
      $returner = $this->update(
         'UPDATE spotlights
            SET
               assoc_type = ?,
               assoc_id = ?,
               press_id = ?
            WHERE spotlight_id = ?',
         array(
            (int) $spotlight->getAssocType(),
            (int) $spotlight->getAssocId(),
            (int) $spotlight->getPressId(),
            (int) $spotlight->getId()
         )
      );
      $this->updateLocaleFields($spotlight);
      return $returner;
   }
 
   function deleteObject($spotlight) {
      return $this->deleteById($spotlight->getId());
   }
 
   function deleteById($spotlightId) {
      $this->update('DELETE FROM spotlight_settings WHERE spotlight_id = ?', (int) $spotlightId);
      return $this->update('DELETE FROM spotlights WHERE spotlight_id = ?', (int) $spotlightId);
   }
 
   function deleteByTypeId($typeId) {
      $spotlights = $this->getByTypeId($typeId);
      while (($spotlight = $spotlights->next())) {
         $this->deleteObject($spotlight);
      }
   }
 
   function deleteByAssoc($assocType, $assocId) {
      $spotlights = $this->getByAssocId($assocType, $assocId);
      while ($spotlight = $spotlights->next()) {
         $this->deleteById($spotlight->getId());
      }
      return true;
   }
 
   function getByPressId($pressId, $rangeInfo = null) {
      $result = $this->retrieveRange(
         'SELECT *
         FROM spotlights
         WHERE press_id = ?
         ORDER BY spotlight_id DESC',
         array((int) $pressId),
         $rangeInfo
      );
 
      $spotlightFactory = new DAOResultFactory($result, $this, '_fromRow');
      $returner = array();
 
      // Avoid spotlights without items.
      while ($spotlight = $spotlightFactory->next()) {
         $spotlightItem = $spotlight->getSpotlightItem();
         if ($spotlightItem) {
            $returner[$spotlight->getId()] = $spotlight;
         }
      }
 
      return $returner;
   }
 
   function getRandomByPressId($pressId, $quantity = 1) {
      $spotlights = array_values($this->getByPressId($pressId));
      $returner = array();
      if (count($spotlights) > 0) {
         if (count($spotlights) <= $quantity) {
            // Return the ones that we have.
            $returner = $spotlights;
         } else {
            // Get the random spotlights.
            for($quantity; $quantity > 0; $quantity--) {
               $randNumber = rand(0, count($spotlights) - 1);
               $returner[] = $spotlights[$randNumber];
               unset($spotlights[$randNumber]);
               // Reset spotlights array index.
               $spotlights = array_values($spotlights);
            }
         }
      }
 
      if (count($returner) == 0) {
         $returner = null;
      }
 
      return $returner;
   }
 
   function getByAssoc($assocType, $assocId, $rangeInfo = null) {
      $result = $this->retrieveRange(
         'SELECT *
         FROM spotlights
         WHERE assoc_type = ? AND assoc_id = ?
         ORDER BY spotlight_id DESC',
         array((int) $assocType, (int) $assocId),
         $rangeInfo
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   function getNumSpotlightsByAssoc($assocType, $assocId, $rangeInfo = null) {
      $result = $this->retrieveRange(
         'SELECT *
         FROM spotlights
         WHERE assoc_type = ?
            AND assoc_id = ?
         ORDER BY spotlight_id DESC',
         array((int) $assocType, (int) $assocId),
         $rangeInfo
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   function getMostRecentSpotlightByAssoc($assocType, $assocId) {
      $result = $this->retrieve(
         'SELECT *
         FROM spotlights
         WHERE assoc_type = ?
            AND assoc_id = ?
         ORDER BY spotlight_id DESC LIMIT 1',
         array((int) $assocType, (int) $assocId)
      );
 
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = $this->_fromRow($result->GetRowAssoc(false));
      }
      $result->Close();
      return $returner;
   }
 
   function getInsertId() {
      return $this->_getInsertId('spotlights', 'spotlight_id');
   }
}