AuthorDAO.inc.php

<?php
 
import('classes.article.Author');
import('classes.submission.Submission');
import('lib.pkp.classes.submission.PKPAuthorDAO');
 
class AuthorDAO extends PKPAuthorDAO {
 
   function getAuthorsAlphabetizedByJournal($journalId = null, $initial = null, $rangeInfo = null, $includeEmail = false) {
      $locale = AppLocale::getLocale();
      $params = array(
         IDENTITY_SETTING_GIVENNAME, $locale,
         IDENTITY_SETTING_GIVENNAME,
         IDENTITY_SETTING_FAMILYNAME, $locale,
         IDENTITY_SETTING_FAMILYNAME,
         'issueId',
      );
      if (isset($journalId)) $params[] = $journalId;
 
      $supportedLocales = array();
      if ($journalId !== null) {
         $journalDao = DAORegistry::getDAO('JournalDAO'); /* @var $journalDao JournalDAO */
         $journal = $journalDao->getById($journalId);
         $supportedLocales = $journal->getSupportedLocales();
      } else {
         $site = Application::get()->getRequest()->getSite();
         $supportedLocales = $site->getSupportedLocales();
      }
      $supportedLocalesCount = count($supportedLocales);
      $sqlJoinAuthorSettings = $sqlColumnsAuthorSettings = $initialSql = '';
      if (isset($initial)) {
         $initialSql = ' AND (';
      }
      $index = 0;
      foreach ($supportedLocales as $locale) {
         $localeStr = str_replace('@', '_', $locale);
         $sqlColumnsAuthorSettings .= ",
            COALESCE(asg$index.setting_value, ''), ' ',
            COALESCE(asf$index.setting_value, ''), ' ',
            COALESCE(SUBSTRING(asa$index.setting_value FROM 1 FOR 255), ''), ' '
         ";
         $sqlJoinAuthorSettings .= "
            LEFT JOIN author_settings asg$index ON (asg$index.author_id  = aa.author_id AND asg$index.setting_name = '" . IDENTITY_SETTING_GIVENNAME . "' AND asg$index.locale = '$locale')
            LEFT JOIN author_settings asf$index ON (asf$index.author_id  = aa.author_id AND asf$index.setting_name = '" . IDENTITY_SETTING_FAMILYNAME . "' AND asf$index.locale = '$locale')
            LEFT JOIN author_settings asa$index ON (asa$index.author_id  = aa.author_id AND asa$index.setting_name = 'affiliation' AND asa$index.locale = '$locale')
         ";
         if (isset($initial)) {
            if ($initial == '-') {
               $initialSql .= "(asf$index.setting_value IS NULL OR asf$index.setting_value = '')";
               if ($index < $supportedLocalesCount - 1) {
                  $initialSql .= ' AND ';
               }
            } else {
               $params[] = PKPString::strtolower($initial) . '%';
               $initialSql .= "LOWER(asf$index.setting_value) LIKE LOWER(?)";
               if ($index < $supportedLocalesCount - 1) {
                  $initialSql .= ' OR ';
               }
            }
         }
         $index++;
      }
      if (isset($initial)) {
         $initialSql .= ')';
      }
 
      $result = $this->retrieveRange(
         'SELECT a.*, ug.show_title, p.locale,
            COALESCE(agl.setting_value, agpl.setting_value) AS author_given,
            CASE WHEN agl.setting_value <> \'\' THEN afl.setting_value ELSE afpl.setting_value END AS author_family
         FROM  authors a
            JOIN user_groups ug ON (a.user_group_id = ug.user_group_id)
            JOIN publications p ON (p.publication_id = a.publication_id)
            JOIN submissions s ON (s.current_publication_id = p.publication_id)
            LEFT JOIN author_settings agl ON (a.author_id = agl.author_id AND agl.setting_name = ? AND agl.locale = ?)
            LEFT JOIN author_settings agpl ON (a.author_id = agpl.author_id AND agpl.setting_name = ? AND agpl.locale = p.locale)
            LEFT JOIN author_settings afl ON (a.author_id = afl.author_id AND afl.setting_name = ? AND afl.locale = ?)
            LEFT JOIN author_settings afpl ON (a.author_id = afpl.author_id AND afpl.setting_name = ? AND afpl.locale = p.locale)
            JOIN (
               SELECT
               MIN(aa.author_id) as author_id,
               CONCAT(
               ' . ($includeEmail ? 'aa.email,' : 'CAST(\'\' AS CHAR),') . '
               \' \',
               ac.setting_value,
               \' \'
               ' . $sqlColumnsAuthorSettings . '
               ) as names
               FROM authors aa
               JOIN publications pp ON (pp.publication_id = aa.publication_id)
               LEFT JOIN publication_settings ppss ON (ppss.publication_id = pp.publication_id)
               JOIN submissions ss ON (ss.submission_id = pp.submission_id AND ss.current_publication_id = pp.publication_id AND ss.status = ' . STATUS_PUBLISHED . ')
               JOIN journals j ON (ss.context_id = j.journal_id)
               JOIN issues i ON (ppss.setting_name = ? AND ppss.setting_value = CAST(i.issue_id AS CHAR) AND i.published = 1)
               LEFT JOIN author_settings ac ON (ac.author_id = aa.author_id AND ac.setting_name = \'country\')
               ' . $sqlJoinAuthorSettings . '
               WHERE j.enabled = 1
               ' . (isset($journalId) ? ' AND j.journal_id = ?' : '')
               . $initialSql . '
               GROUP BY names
            ) as t1 ON (t1.author_id = a.author_id)
            ORDER BY author_family, author_given',
         $params,
         $rangeInfo
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
}