ControlledVocabEntryDAO.inc.php

<?php
 
import('lib.pkp.classes.controlledVocab.ControlledVocabEntry');
 
class ControlledVocabEntryDAO extends DAO {
 
   function getSettingsDAO() {
      return DAORegistry::getDAO('ControlledVocabEntrySettingsDAO');
   }
 
   function getById($controlledVocabEntryId, $controlledVocabId = null) {
      $params = array((int) $controlledVocabEntryId);
      if (!empty($controlledVocabId)) $params[] = (int) $controlledVocabId;
 
      $result = $this->retrieve(
         'SELECT * FROM controlled_vocab_entries WHERE controlled_vocab_entry_id = ?' .
         (!empty($controlledVocabId)?' AND controlled_vocab_id = ?':''),
         $params
      );
 
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = $this->_fromRow($result->GetRowAssoc(false));
      }
      $result->Close();
      return $returner;
   }
 
   function getBySetting($settingValue, $symbolic, $assocType = 0, $assocId = 0, $settingName = 'name', $locale = '') {
      $result = $this->retrieve(
         'SELECT cve.*
          FROM controlled_vocabs cv
          INNER JOIN controlled_vocab_entries cve ON cv.controlled_vocab_id = cve.controlled_vocab_id
          INNER JOIN controlled_vocab_entry_settings cves ON cve.controlled_vocab_entry_id = cves.controlled_vocab_entry_id
          WHERE   cves.setting_name = ? AND
            cves.locale = ? AND
            cves.setting_value = ? AND
            cv.symbolic = ? AND
            cv.assoc_type = ? AND
            cv.assoc_id = ?',
         array($settingName, $locale, $settingValue, $symbolic, $assocType, $assocId)
      );
 
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = $this->_fromRow($result->GetRowAssoc(false));
      }
      $result->Close();
      return $returner;
   }
 
   function newDataObject() {
      return new ControlledVocabEntry();
   }
 
   function _fromRow($row) {
      $controlledVocabEntry = $this->newDataObject();
      $controlledVocabEntry->setControlledVocabId($row['controlled_vocab_id']);
      $controlledVocabEntry->setId($row['controlled_vocab_entry_id']);
      $controlledVocabEntry->setSequence($row['seq']);
 
      $this->getDataObjectSettings('controlled_vocab_entry_settings', 'controlled_vocab_entry_id', $row['controlled_vocab_entry_id'], $controlledVocabEntry);
 
      return $controlledVocabEntry;
   }
 
   function getLocaleFieldNames() {
      return array('name');
   }
 
   function updateLocaleFields($controlledVocabEntry) {
      $this->updateDataObjectSettings('controlled_vocab_entry_settings', $controlledVocabEntry, array(
         'controlled_vocab_entry_id' => $controlledVocabEntry->getId()
      ));
   }
 
   function insertObject($controlledVocabEntry) {
      $this->update(
         'INSERT INTO controlled_vocab_entries (controlled_vocab_id, seq)
         VALUES (?, ?)',
         array(
            (int) $controlledVocabEntry->getControlledVocabId(),
            (float) $controlledVocabEntry->getSequence()
         )
      );
      $controlledVocabEntry->setId($this->getInsertId());
      $this->updateLocaleFields($controlledVocabEntry);
      return (int)$controlledVocabEntry->getId();
   }
 
   function deleteObject($controlledVocabEntry) {
      $this->deleteObjectById($controlledVocabEntry->getId());
   }
 
   function deleteObjectById($controlledVocabEntryId) {
      $params = array((int) $controlledVocabEntryId);
      $this->update('DELETE FROM controlled_vocab_entry_settings WHERE controlled_vocab_entry_id = ?', $params);
      $this->update('DELETE FROM controlled_vocab_entries WHERE controlled_vocab_entry_id = ?', $params);
   }
 
   function getByControlledVocabId($controlledVocabId, $rangeInfo = null, $filter = null) {
      $params = array((int) $controlledVocabId);
      if (!empty($filter)) $params[] = "%$filter%";
 
      $result = $this->retrieveRange(
         'SELECT *
          FROM controlled_vocab_entries cve '.
          (!empty($filter) ? 'INNER JOIN controlled_vocab_entry_settings cves ON cve.controlled_vocab_entry_id = cves.controlled_vocab_entry_id ' : '') .
         'WHERE controlled_vocab_id = ? ' .
          (!empty($filter) ? 'AND cves.setting_value LIKE ? ' : '') .
         'ORDER BY seq',
         $params,
         $rangeInfo
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   public function getByContextId($symbolic, $contextId, $locale) {
      $result = $this->retrieve(
         'SELECT cve.*
            FROM controlled_vocab_entries AS cve
            LEFT JOIN controlled_vocabs AS cv ON (cv.controlled_vocab_id = cve.controlled_vocab_id)
            LEFT JOIN controlled_vocab_entry_settings AS cves ON (cves.controlled_vocab_entry_id = cve.controlled_vocab_entry_id)
            LEFT JOIN publications as p ON (p.publication_id = cv.assoc_id)
            LEFT JOIN submissions AS s ON (s.submission_id = p.submission_id)
            WHERE cv.symbolic = ?
               AND cv.assoc_type = ?
               AND s.context_id = ?
               AND cves.locale = ?
            ORDER BY cve.seq DESC',
         [
            $symbolic,
            ASSOC_TYPE_PUBLICATION,
            $contextId,
            $locale
         ]
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   function updateObject($controlledVocabEntry) {
      $this->update(
         'UPDATE  controlled_vocab_entries
         SET   controlled_vocab_id = ?,
            seq = ?
         WHERE controlled_vocab_entry_id = ?',
         array(
            (int) $controlledVocabEntry->getControlledVocabId(),
            (float) $controlledVocabEntry->getSequence(),
            (int) $controlledVocabEntry->getId()
         )
      );
      $this->updateLocaleFields($controlledVocabEntry);
   }
 
   function resequence($controlledVocabId) {
      $result = $this->retrieve(
         'SELECT controlled_vocab_entry_id FROM controlled_vocab_entries WHERE controlled_vocab_id = ? ORDER BY seq',
         array((int) $controlledVocabId)
      );
 
      for ($i=1; !$result->EOF; $i++) {
         list($controlledVocabEntryId) = $result->fields;
         $this->update(
            'UPDATE controlled_vocab_entries SET seq = ? WHERE controlled_vocab_entry_id = ?',
            array(
               (int) $i,
               (int) $controlledVocabEntryId
            )
         );
 
         $result->MoveNext();
      }
 
      $result->Close();
   }
 
   function getInsertId() {
      return parent::_getInsertId('controlled_vocab_entries', 'controlled_vocab_entry_id');
   }
}