AnnouncementTypeDAO.inc.php

<?php
 
import('lib.pkp.classes.announcement.AnnouncementType');
 
class AnnouncementTypeDAO extends DAO {
 
   function newDataObject() {
      return new AnnouncementType();
   }
 
   function getById($typeId, $assocType = null, $assocId = null) {
      $params = array((int) $typeId);
      if ($assocType !== null) $params[] = (int) $assocType;
      if ($assocId !== null) $params[] = (int) $assocId;
      $result = $this->retrieve(
         'SELECT * FROM announcement_types WHERE type_id = ?' .
         ($assocType !== null?' AND assoc_type = ?':'') .
         ($assocId !== null?' AND assoc_id = ?':''),
         $params
      );
 
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = $this->_fromRow($result->GetRowAssoc(false));
      }
      $result->Close();
      return $returner;
   }
 
   function getAnnouncementTypeAssocId($typeId) {
      $result = $this->retrieve(
         'SELECT assoc_id FROM announcement_types WHERE type_id = ?',
         (int) $typeId
      );
 
      return isset($result->fields[0]) ? $result->fields[0] : 0;
   }
 
   function getAnnouncementTypeName($typeId) {
      $result = $this->retrieve(
         'SELECT COALESCE(l.setting_value, p.setting_value) FROM announcement_type_settings p LEFT JOIN announcement_type_settings l ON (l.type_id = ? AND l.setting_name = ? AND l.locale = ?) WHERE p.type_id = ? AND p.setting_name = ? AND p.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 announcementTypeExistsByTypeId($typeId, $assocType, $assocId) {
      $result = $this->retrieve(
         'SELECT COUNT(*)
         FROM  announcement_types
         WHERE type_id = ? AND
            assoc_type = ? AND
            assoc_id = ?',
         array(
            (int) $typeId,
            (int) $assocType,
            (int) $assocId
         )
      );
      $returner = isset($result->fields[0]) && $result->fields[0] != 0 ? true : false;
 
      $result->Close();
      return $returner;
   }
 
   function getLocaleFieldNames() {
      return array('name');
   }
 
   function getByTypeName($typeName, $assocType, $assocId) {
      $result = $this->retrieve(
         'SELECT ats.type_id
            FROM announcement_type_settings AS ats
            LEFT JOIN announcement_types at ON ats.type_id = at.type_id
            WHERE ats.setting_name = \'name\'
            AND ats.setting_value = ?
            AND at.assoc_type = ?
            AND at.assoc_id = ?',
         array(
            $typeName,
            (int) $assocType,
            (int) $assocId
         )
      );
      $returner = isset($result->fields[0]) ? $result->fields[0] : 0;
 
      $result->Close();
      return $returner;
   }
 
   function _fromRow($row) {
      $announcementType = $this->newDataObject();
      $announcementType->setId($row['type_id']);
      $announcementType->setAssocType($row['assoc_type']);
      $announcementType->setAssocId($row['assoc_id']);
      $this->getDataObjectSettings('announcement_type_settings', 'type_id', $row['type_id'], $announcementType);
 
      return $announcementType;
   }
 
   function updateLocaleFields($announcementType) {
      $this->updateDataObjectSettings('announcement_type_settings', $announcementType, array(
         'type_id' => (int) $announcementType->getId()
      ));
   }
 
   function insertObject($announcementType) {
      $this->update(
         sprintf('INSERT INTO announcement_types
            (assoc_type, assoc_id)
            VALUES
            (?, ?)'),
         array(
            (int) $announcementType->getAssocType(),
            (int) $announcementType->getAssocId()
         )
      );
      $announcementType->setId($this->getInsertId());
      $this->updateLocaleFields($announcementType);
      return $announcementType->getId();
   }
 
   function updateObject($announcementType) {
      $returner = $this->update(
         'UPDATE  announcement_types
         SET   assoc_type = ?,
            assoc_id = ?
         WHERE type_id = ?',
         array(
            (int) $announcementType->getAssocType(),
            (int) $announcementType->getAssocId(),
            (int) $announcementType->getId()
         )
      );
 
      $this->updateLocaleFields($announcementType);
      return $returner;
   }
 
   function deleteObject($announcementType) {
      return $this->deleteById($announcementType->getId());
   }
 
   function deleteById($typeId) {
      $this->update('DELETE FROM announcement_type_settings WHERE type_id = ?', (int) $typeId);
      $this->update('DELETE FROM announcement_types WHERE type_id = ?', (int) $typeId);
 
      $announcementDao = DAORegistry::getDAO('AnnouncementDAO'); /* @var $announcementDao AnnouncementDAO */
      $announcementDao->deleteByTypeId($typeId);
   }
 
   function deleteByAssoc($assocType, $assocId) {
      $types = $this->getByAssoc($assocType, $assocId);
      while ($type = $types->next()) {
         $this->deleteObject($type);
      }
   }
 
   function getByAssoc($assocType, $assocId, $rangeInfo = null) {
      $result = $this->retrieveRange(
         'SELECT * FROM announcement_types WHERE assoc_type = ? AND assoc_id = ? ORDER BY type_id',
         array((int) $assocType, (int) $assocId),
         $rangeInfo
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   function getInsertId() {
      return $this->_getInsertId('announcement_types', 'type_id');
   }
}