classes/monograph/AuthorDAO.inc.php

<?php

import('classes.monograph.Author');
import('classes.monograph.Monograph');
import('lib.pkp.classes.submission.PKPAuthorDAO');

class AuthorDAO extends PKPAuthorDAO {
   function AuthorDAO() {
      parent::PKPAuthorDAO();
   }

   function &getAuthorsAlphabetizedByPress($pressId = null, $initial = null, $rangeInfo = null) {
      $authors = array();
      $params = array(
         'affiliation', AppLocale::getPrimaryLocale(),
         'affiliation', AppLocale::getLocale()
      );

      if (isset($pressId)) $params[] = $pressId;
      if (isset($initial)) {
         $params[] = String::strtolower($initial) . '%';
         $initialSql = ' AND LOWER(ma.last_name) LIKE LOWER(?)';
      } else {
         $initialSql = '';
      }

      $result =& $this->retrieveRange(
         'SELECT DISTINCT
            CAST(\'\' AS CHAR) AS url,
            ma.author_id AS author_id,
            ma.submission_id AS submission_id,
            CAST(\'\' AS CHAR) AS email,
            0 AS primary_contact,
            0 AS seq,
            ma.first_name AS first_name,
            ma.middle_name AS middle_name,
            ma.last_name AS last_name,
            asl.setting_value AS affiliation_l,
            asl.locale,
            aspl.setting_value AS affiliation_pl,
            aspl.locale AS primary_locale,
            ma.suffix AS suffix,
            ma.user_group_id AS user_group_id,
            ma.country
         FROM  authors ma
            LEFT JOIN author_settings aspl ON (ma.author_id = aspl.author_id AND aspl.setting_name = ? AND aspl.locale = ?)
            LEFT JOIN author_settings asl ON (ma.author_id = asl.author_id AND asl.setting_name = ? AND asl.locale = ?)
            JOIN monographs a ON (ma.submission_id = a.monograph_id)
         WHERE a.status = ' . STATUS_PUBLISHED . ' ' .
            (isset($pressId)?'AND a.press_id = ? ':'') . '
            AND (ma.last_name IS NOT NULL AND ma.last_name <> \'\')' .
            $initialSql . '
         ORDER BY ma.last_name, ma.first_name',
         $params,
         $rangeInfo
      );

      $returner = new DAOResultFactory($result, $this, '_returnAuthorFromRow');
      return $returner;
   }

   function newDataObject() {
      return new Author();
   }

   function insertAuthor(&$author) {
      // Set author sequence to end of author list
      if(!$author->getSequence()) {
         $authorCount = $this->getAuthorCountBySubmissionId($author->getSubmissionId());
         $author->setSequence($authorCount + 1);
      }
      // Reset primary contact for monograph to this author if applicable
      if ($author->getPrimaryContact()) {
         $this->resetPrimaryContact($author->getId(), $author->getSubmissionId());
      }

      $this->update(
         'INSERT INTO authors
            (submission_id, first_name, middle_name, last_name, suffix, country, email, url, user_group_id, primary_contact, seq)
            VALUES
            (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)',
         array(
            $author->getSubmissionId(),
            $author->getFirstName(),
            $author->getMiddleName() . '', // make non-null
            $author->getLastName(),
            $author->getSuffix() . '',
            $author->getCountry(),
            $author->getEmail(),
            $author->getUrl(),
            (int) $author->getUserGroupId(),
            (int) $author->getPrimaryContact(),
            (float) $author->getSequence()
         )
      );

      $author->setId($this->getInsertAuthorId());
      $this->updateLocaleFields($author);

      return $author->getId();
   }

   function updateAuthor($author) {
      // Reset primary contact for monograph to this author if applicable
      if ($author->getPrimaryContact()) {
         $this->resetPrimaryContact($author->getId(), $author->getSubmissionId());
      }
      $returner = $this->update(
         'UPDATE  authors
         SET   first_name = ?,
            middle_name = ?,
            last_name = ?,
            suffix = ?,
            country = ?,
            email = ?,
            url = ?,
            user_group_id = ?,
            primary_contact = ?,
            seq = ?
         WHERE author_id = ?',
         array(
            $author->getFirstName(),
            $author->getMiddleName() . '', // make non-null
            $author->getLastName(),
            $author->getSuffix() . '',
            $author->getCountry(),
            $author->getEmail(),
            $author->getUrl(),
            (int) $author->getUserGroupId(),
            (int) $author->getPrimaryContact(),
            (float) $author->getSequence(),
            (int) $author->getId()
         )
      );
      $this->updateLocaleFields($author);
      return $returner;
   }

   function deleteAuthorsByMonograph($submissionId) {
      $authors =& $this->getAuthorsBySubmissionId($submissionId);
      foreach ($authors as $author) {
         $this->deleteAuthor($author);
      }
   }
}

?>