PKPPublicationQueryBuilder.inc.php

<?php
namespace PKP\Services\QueryBuilders;
 
use Illuminate\Database\Capsule\Manager as Capsule;
use PKP\Services\QueryBuilders\Interfaces\EntityQueryBuilderInterface;
 
class PKPPublicationQueryBuilder implements EntityQueryBuilderInterface {
 
   protected $contextIds = [];
 
   protected $submissionIds = [];
 
   protected $limit = null;
 
   protected $offset = 0;
 
   public function filterByContextIds($contextIds) {
      $this->contextIds = is_array($contextIds) ? $contextIds : [$contextIds];
      return $this;
   }
 
   public function filterBySubmissionIds($submissionIds) {
      $this->submissionIds = is_array($submissionIds) ? $submissionIds : [$submissionIds];
      return $this;
   }
 
   public function limitTo($count) {
      $this->limit = $count;
      return $this;
   }
 
   public function offsetBy($offset) {
      $this->offset = $offset;
      return $this;
   }
 
   public function getCount() {
      return $this
         ->getQuery()
         ->select('p.publication_id')
         ->get()
         ->count();
   }
 
   public function getIds() {
      return $this
         ->getQuery()
         ->select('p.publication_id')
         ->pluck('p.publication_id')
         ->toArray();
   }
 
   public function getQuery($applyOrder = true) {
      $this->columns = ['*'];
      $q = Capsule::table('publications as p');
 
      if (!empty($this->contextIds)) {
         $q->leftJoin('submissions as s', 's.submission_id', '=', 'p.submission_id')
            ->whereIn('s.context_id', $this->contextIds);
      }
 
      if (!empty($this->submissionIds)) {
         $q->whereIn('p.submission_id', $this->submissionIds);
      }
 
      // Limit and offset results for pagination
      if (!is_null($this->limit)) {
         $q->limit($this->limit);
      }
      if (!empty($this->offset)) {
         $q->offset($this->offset);
      }
 
      if ($applyOrder) {
         // Order by version number
         $q->orderBy('p.version', 'asc');
      }
 
      // Add app-specific query statements
      \HookRegistry::call('Publication::getMany::queryObject', array(&$q, $this));
 
      $q->select($this->columns);
 
      return $q;
   }
 
   public function getDateBoundaries() {
      return $this->getQuery(false)
         ->select([
            Capsule::raw('MIN(p.date_published), MAX(p.date_published)')
         ]);
   }
 
   public function getQueryByUrlPath($urlPath, $contextId) {
      return Capsule::table('publications as p')
         ->leftJoin('submissions as s', 's.submission_id', '=', 'p.submission_id')
         ->where('s.context_id', '=', $contextId)
         ->where('p.url_path', '=', $urlPath);
   }
 
   public function isDuplicateUrlPath($urlPath, $submissionId, $contextId) {
      return (bool) Capsule::table('publications as p')
         ->leftJoin('submissions as s', 's.submission_id', '=', 'p.submission_id')
         ->where('url_path', '=' , $urlPath)
         ->where('p.submission_id', '!=', $submissionId)
         ->where('s.context_id', '=', $contextId)
         ->count();
   }
}