PKPAuthorDAO.inc.php

<?php
 
import('lib.pkp.classes.db.SchemaDAO');
import('lib.pkp.classes.submission.PKPAuthor');
 
abstract class PKPAuthorDAO extends SchemaDAO {
   public $schemaName = SCHEMA_AUTHOR;
 
   public $tableName = 'authors';
 
   public $settingsTableName = 'author_settings';
 
   public $primaryKeyColumn = 'author_id';
 
   public $primaryTableColumns = [
      'id' => 'author_id',
      'email' => 'email',
      'includeInBrowse' => 'include_in_browse',
      'publicationId' => 'publication_id',
      'seq' => 'seq',
      'userGroupId' => 'user_group_id',
   ];
 
   function newDataObject() {
      return new Author();
   }
 
   public function getById($objectId) {
      $result = $this->retrieve(
         'SELECT a.*, p.locale AS submission_locale FROM authors a JOIN publications p ON (a.publication_id = p.publication_id) WHERE author_id = ?',
         (int) $objectId
      );
 
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = $this->_fromRow($result->GetRowAssoc(false));
      }
      $result->Close();
      return $returner;
   }
 
   function getByPublicationId($publicationId, $sortByAuthorId = false, $useIncludeInBrowse = false) {
      $authors = array();
      $params = array((int) $publicationId);
      if ($useIncludeInBrowse) $params[] = 1;
 
      $result = $this->retrieve(
         'SELECT DISTINCT a.*, ug.show_title, p.locale AS submission_locale
         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)
            LEFT JOIN author_settings au ON (au.author_id = a.author_id)
         WHERE a.publication_id = ? ' .
         ($useIncludeInBrowse ? ' AND a.include_in_browse = ?' : '')
         . ' ORDER BY seq',
         $params
      );
 
      while (!$result->EOF) {
         $row = $result->getRowAssoc(false);
         if ($sortByAuthorId) {
            $authorId = $row['author_id'];
            $authors[$authorId] = $this->_fromRow($row);
         } else {
            $authors[] = $this->_fromRow($row);
         }
         $result->MoveNext();
      }
 
      $result->Close();
      return $authors;
   }
 
   function changePublicationLocale($publicationId, $oldLocale, $newLocale) {
      $authors = $this->getByPublicationId($publicationId);
      foreach ($authors as $author) {
         if (empty($author->getGivenName($newLocale))) {
            if (empty($author->getFamilyName($newLocale)) && empty($author->getPreferredPublicName($newLocale))) {
               // if no name exists for the new locale
               // copy all names with the old locale to the new locale
               $author->setGivenName($author->getGivenName($oldLocale), $newLocale);
               $author->setFamilyName($author->getFamilyName($oldLocale), $newLocale);
               $author->setPreferredPublicName($author->getPreferredPublicName($oldLocale), $newLocale);
            } else {
               // if the given name does not exist, but one of the other names do exist
               // copy only the given name with the old locale to the new locale, because the given name is required
               $author->setGivenName($author->getGivenName($oldLocale), $newLocale);
            }
            $this->updateObject($author);
         }
      }
   }
 
 
   public function _fromRow($primaryRow) {
      $author = parent::_fromRow($primaryRow);
      $author->setSubmissionLocale($primaryRow['submission_locale']);
      return $author;
   }
 
   function getInsertId() {
      return $this->_getInsertId('authors', 'author_id');
   }
 
   function deleteBySubmissionId($submissionId) {
      $submissionDao = DAORegistry::getDAO('SubmissionDAO');
      $submission = $submissionDao->getById($submissionId);
      if ($submission) foreach ($submission->getData('publications') as $publication) {
         $authors = $this->getByPublicationId($publication->getId());
         foreach ($authors as $author) {
            $this->deleteObject($author);
         }
      }
   }
}