classes/monograph/MonographSubjectDAO.inc.php

<?php

import('lib.pkp.classes.controlledVocab.ControlledVocabDAO');

define('CONTROLLED_VOCAB_MONOGRAPH_SUBJECT', 'monographSubject');

class MonographSubjectDAO extends ControlledVocabDAO {
   function MonographSubjectDAO() {
      parent::ControlledVocabDAO();
   }

   function build($monographId) {
      // may return an array of ControlledVocabs
      return parent::build(CONTROLLED_VOCAB_MONOGRAPH_SUBJECT, ASSOC_TYPE_MONOGRAPH, $monographId);
   }

   function getLocaleFieldNames() {
      return array('monographSubject');
   }

   function getSubjects($monographId, $locales) {

      $returner = array();
      foreach ($locales as $locale) {
         $returner[$locale] = array();
         $subjects = $this->build($monographId);
         $monographSubjectEntryDao =& DAORegistry::getDAO('MonographSubjectEntryDAO');
         $monographSubjects = $monographSubjectEntryDao->getByControlledVocabId($subjects->getId());

         while ($subject =& $monographSubjects->next()) {
            $subject = $subject->getSubject();
            if (array_key_exists($locale, $subject)) { // quiets PHP when there are no Subjects for a given locale
               $returner[$locale][] = $subject[$locale];
               unset($subject);
            }
         }
      }
      return $returner;
   }

   function getAllUniqueSubjects() {
      $subjects = array();

      $result =& $this->retrieve(
         'SELECT DISTINCT setting_value FROM controlled_vocab_entry_settings WHERE setting_name = ?', CONTROLLED_VOCAB_MONOGRAPH_SUBJECT
      );

      while (!$result->EOF) {
         $subjects[] = $result->fields[0];
         $result->MoveNext();
      }

      $result->Close();
      unset($result);

      return $subjects;
   }

   function getMonographIdsBySubject($subject) {
      $result =& $this->retrieve(
         'SELECT assoc_id
          FROM controlled_vocabs cv
          LEFT 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.setting_value = ?',
         array(CONTROLLED_VOCAB_MONOGRAPH_SUBJECT, $subject)
      );

      $returner = array();
      while (!$result->EOF) {
         $row = $result->GetRowAssoc(false);
         $returner[] = $row['assoc_id'];
         $result->MoveNext();
      }
      $result->Close();
      return $returner;
   }

   function insertSubjects($subjects, $monographId, $deleteFirst = true) {
      $subjectDao =& DAORegistry::getDAO('MonographSubjectDAO');
      $monographSubjectEntryDao =& DAORegistry::getDAO('MonographSubjectEntryDAO');
      $currentSubjects = $this->build($monographId);

      if ($deleteFirst) {
         $existingEntries = $subjectDao->enumerate($currentSubjects->getId(), CONTROLLED_VOCAB_MONOGRAPH_SUBJECT);

         foreach ($existingEntries as $id => $entry) {
            $entry = trim($entry);
            $monographSubjectEntryDao->deleteObjectById($id);
         }
      }
      if (is_array($subjects)) { // localized, array of arrays

         foreach ($subjects as $locale => $list) {
            if (is_array($list)) {
               $list = array_unique($list); // Remove any duplicate Subjects
               $i = 1;
               foreach ($list as $subject) {
                  $subjectEntry = $monographSubjectEntryDao->newDataObject();
                  $subjectEntry->setControlledVocabId($currentSubjects->getID());
                  $subjectEntry->setSubject(urldecode($subject), $locale);
                  $subjectEntry->setSequence($i);
                  $i ++;
                  $subjectEntryId = $monographSubjectEntryDao->insertObject($subjectEntry);
               }
            }
         }
      }
   }
}
?>