PKPAuthorQueryBuilder.inc.php

<?php
namespace PKP\Services\QueryBuilders;
 
use Illuminate\Database\Capsule\Manager as Capsule;
use PKP\Services\QueryBuilders\Interfaces\EntityQueryBuilderInterface;
 
class PKPAuthorQueryBuilder implements EntityQueryBuilderInterface {
 
   protected $contextIds = [];
 
   protected $familyName = '';
 
   protected $givenName = '';
 
   protected $publicationIds = [];
 
   protected $country = '';
 
   protected $affiliation = '';
 
   public function filterByContextIds($contextIds) {
      $this->contextIds = is_array($contextIds) ? $contextIds : [$contextIds];
      return $this;
   }
 
   public function filterByName($givenName, $familyName) {
      $this->givenName = $givenName;
      $this->familyName = $familyName;
      return $this;
   }
 
   public function filterByCountry($country) {
      $this->country = $country;
      return $this;
   }
 
   public function filterByAffiliation($affiliation) {
      $this->affiliation = $affiliation;
      return $this;
   }
 
   public function filterByPublicationIds($publicationIds) {
      $this->publicationIds = is_array($publicationIds) ? $publicationIds : [$publicationIds];
      return $this;
   }
 
   public function getCount() {
      return $this
         ->getQuery()
         ->select('a.author_id')
         ->get()
         ->count();
   }
 
   public function getIds() {
      return $this
         ->getQuery()
         ->select('a.author_id')
         ->pluck('a.author_id')
         ->toArray();
   }
 
   public function getQuery() {
      $this->columns = ['*', 'p.locale AS submission_locale'];
      $q = Capsule::table('authors as a');
      $q->leftJoin('publications as p', 'a.publication_id', '=', 'p.publication_id');
 
      if (!empty($this->contextIds)) {
         $q->leftJoin('submissions as s', 'p.submission_id', '=', 's.submission_id')
            ->whereIn('s.context_id', $this->contextIds);
      }
 
      if (!empty($this->familyName) || !empty($this->givenName)) {
         $familyName = $this->familyName;
         $givenName = $this->givenName;
         $q->leftJoin('author_settings as fn', 'a.author_id', '=', 'fn.author_id')
            ->where(function($q) use ($familyName) {
               $q->where('fn.setting_name', '=', 'familyName');
               $q->where('fn.setting_value', '=', $familyName);
            });
         $q->leftJoin('author_settings as gn', 'a.author_id', '=', 'gn.author_id')
            ->where(function($q) use ($givenName) {
               $q->where('gn.setting_name', '=', 'givenName');
               $q->where('gn.setting_value', '=', $givenName);
            });
      }
 
      if (!empty($this->publicationIds)) {
         $q->whereIn('a.publication_id', $this->publicationIds);
      }
 
      if (!empty($this->country)) {
         $country = $this->country;
         $q->join('author_settings as cs', 'a.author_id', '=', 'cs.author_id')
            ->where(function($q) use ($country) {
               $q->where('cs.setting_name', '=', 'country');
               $q->where('cs.setting_value', '=', $country);
            });
      }
 
      if (!empty($this->affiliation)) {
         $affiliation = $this->affiliation;
         $q->join('author_settings as afs', 'a.author_id', '=', 'afs.author_id')
            ->where(function($q) use ($affiliation) {
               $q->where('afs.setting_name', '=', 'affiliation');
               $q->where('afs.setting_value', '=', $affiliation);
            });
      }
 
      $q->orderBy('a.seq', 'ASC');
 
      // Add app-specific query statements
      \HookRegistry::call('Author::getMany::queryObject', array(&$q, $this));
 
      $q->select($this->columns);
 
      return $q;
   }
}