classes/spotlight/SpotlightDAO.inc.php

<?php

import('classes.spotlight.Spotlight');

class SpotlightDAO extends DAO {
   function SpotlightDAO() {
      parent::DAO();
   }

   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
      );

      return isset($result->fields[0]) ? $result->fields[0] : 0;
   }

   function getSpotlightAssocType($spotlightId) {
      $result =& $this->retrieve(
         'SELECT assoc_type FROM spotlights WHERE spotlight_id = ?',
         (int) $spotlightId
      );

      return isset($result->fields[0]) ? $result->fields[0] : 0;
   }

   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->getInsertSpotlightId());
      $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);
         unset($spotlight);
      }
   }

   function deleteByAssoc($assocType, $assocId) {
      $spotlights =& $this->getByAssocId($assocType, $assocId);
      while (($spotlight =& $spotlights->next())) {
         $this->deleteById($spotlight->getId());
         unset($spotlight);
      }
      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 &getByTypeId($typeId, $rangeInfo = null) {
      $result =& $this->retrieveRange(
         'SELECT * FROM spotlights WHERE type_id = ? ORDER BY spotlight_id DESC',
         (int) $typeId,
         $rangeInfo
      );

      $returner = new DAOResultFactory($result, $this, '_fromRow');
      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
      );

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

   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
      );

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

   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 getInsertSpotlightId() {
      return $this->getInsertId('spotlights', 'spotlight_id');
   }
}

?>