InterestDAO.inc.php

<?php
 
import('lib.pkp.classes.controlledVocab.ControlledVocabDAO');
 
define('CONTROLLED_VOCAB_INTEREST', 'interest');
 
class InterestDAO extends ControlledVocabDAO {
 
   function build() {
      return parent::_build(CONTROLLED_VOCAB_INTEREST);
   }
 
   function getUserInterestIds($userId) {
      $controlledVocab = $this->build();
      $result = $this->retrieveRange(
         'SELECT cve.controlled_vocab_entry_id FROM controlled_vocab_entries cve, user_interests ui WHERE cve.controlled_vocab_id = ? AND ui.controlled_vocab_entry_id = cve.controlled_vocab_entry_id AND ui.user_id = ?',
         array((int) $controlledVocab->getId(), (int) $userId)
      );
 
      $ids = array();
      while (!$result->EOF) {
         $row = $result->GetRowAssoc(false);
         $ids[] = $row['controlled_vocab_entry_id'];
         $result->MoveNext();
      }
      $result->Close();
 
      return $ids;
   }
 
   function getUserIdsByInterest($interest) {
      $result = $this->retrieve('
         SELECT ui.user_id
         FROM user_interests ui
            INNER JOIN controlled_vocab_entry_settings cves ON (ui.controlled_vocab_entry_id = cves.controlled_vocab_entry_id)
         WHERE cves.setting_name = ? AND cves.setting_value = ?',
         array('interest', $interest)
      );
 
      $returner = array();
      while (!$result->EOF) {
         $row = $result->GetRowAssoc(false);
         $returner[] = $row['user_id'];
         $result->MoveNext();
      }
      $result->Close();
      return $returner;
 
   }
 
   function getAllInterests($filter = null) {
      $controlledVocab = $this->build();
      $interestEntryDao = DAORegistry::getDAO('InterestEntryDAO'); /* @var $interestEntryDao InterestEntryDAO */
      $iterator = $interestEntryDao->getByControlledVocabId($controlledVocab->getId(), null, $filter);
 
      // Sort by name.
      $interests = $iterator->toArray();
      usort($interests, function($s1, $s2) {
         return strcmp($s1->getInterest(), $s2->getInterest());
      });
 
      // Turn back into an iterator.
      import('lib.pkp.classes.core.ArrayItemIterator');
      return new ArrayItemIterator($interests);
   }
 
   function setUserInterests($interests, $userId) {
      // Remove duplicates
      $interests = isset($interests) ? $interests : array();
      $interests = array_unique($interests);
 
      // Trim whitespace
      $interests = array_map('trim', $interests);
 
      // Delete the existing interests association.
      $this->update(
         'DELETE FROM user_interests WHERE user_id = ?',
         array((int) $userId)
      );
 
      $interestEntryDao = DAORegistry::getDAO('InterestEntryDAO'); /* @var $interestEntryDao InterestEntryDAO */
      $controlledVocab = $this->build();
 
      // Store the new interests.
      foreach ((array) $interests as $interest) {
         $interestEntry = $interestEntryDao->getBySetting($interest, $controlledVocab->getSymbolic(),
            $controlledVocab->getAssocId(), $controlledVocab->getAssocType(), $controlledVocab->getSymbolic()
         );
 
         if(!$interestEntry) {
            $interestEntry = $interestEntryDao->newDataObject(); /* @var $interestEntry InterestEntry */
            $interestEntry->setInterest($interest);
            $interestEntry->setControlledVocabId($controlledVocab->getId());
            $interestEntry->setId($interestEntryDao->insertObject($interestEntry));
         }
 
         $this->update(
            'INSERT INTO user_interests (user_id, controlled_vocab_entry_id) VALUES (?, ?)',
            array((int) $userId, (int) $interestEntry->getId())
         );
      }
   }
}