classes/article/AuthorDAO.inc.php

<?php

// $Id: AuthorDAO.inc.php,v 1.29 2008/07/01 01:16:09 asmecher Exp $


import('article.Author');
import('article.Article');

class AuthorDAO extends DAO {
   function &getAuthor($authorId) {
      $result = &$this->retrieve(
         'SELECT * FROM article_authors WHERE author_id = ?', $authorId
      );

      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = &$this->_returnAuthorFromRow($result->GetRowAssoc(false));
      }

      $result->Close();
      unset($result);

      return $returner;
   }

   function &getAuthorsByArticle($articleId) {
      $authors = array();

      $result = &$this->retrieve(
         'SELECT * FROM article_authors WHERE article_id = ? ORDER BY seq',
         $articleId
      );

      while (!$result->EOF) {
         $authors[] = &$this->_returnAuthorFromRow($result->GetRowAssoc(false));
         $result->moveNext();
      }

      $result->Close();
      unset($result);

      return $authors;
   }

   function &getPublishedArticlesForAuthor($journalId, $firstName, $middleName, $lastName, $affiliation, $country) {
      $publishedArticles = array();
      $publishedArticleDao = &DAORegistry::getDAO('PublishedArticleDAO');
      $params = array($firstName, $middleName, $lastName, $affiliation, $country);
      if ($journalId !== null) $params[] = $journalId;

      $result = &$this->retrieve(
         'SELECT DISTINCT
            aa.article_id
         FROM article_authors aa
            LEFT JOIN articles a ON (aa.article_id = a.article_id)
         WHERE aa.first_name = ?
            AND a.status = ' . STATUS_PUBLISHED . '
            AND (aa.middle_name = ?' . (empty($middleName)?' OR aa.middle_name IS NULL':'') . ')
            AND aa.last_name = ?
            AND (aa.affiliation = ?' . (empty($affiliation)?' OR aa.affiliation IS NULL':'') . ')
            AND (aa.country = ?' . (empty($country)?' OR aa.country IS NULL':'') . ') ' . 
            ($journalId!==null?(' AND a.journal_id = ?'):''),
         $params
      );

      while (!$result->EOF) {
         $row = &$result->getRowAssoc(false);
         $publishedArticle = &$publishedArticleDao->getPublishedArticleByArticleId($row['article_id']);
         if ($publishedArticle) {
            $publishedArticles[] = &$publishedArticle;
         }
         $result->moveNext();
      }

      $result->Close();
      unset($result);

      return $publishedArticles;
   }

   function &getAuthorsAlphabetizedByJournal($journalId = null, $initial = null, $rangeInfo = null) {
      $authors = array();
      $params = array();

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

      $result = &$this->retrieveRange(
         'SELECT DISTINCT
            CAST(\'\' AS CHAR) AS url,
            0 AS author_id,
            0 AS article_id,
            CAST(\'\' AS CHAR) AS email,
            0 AS primary_contact,
            0 AS seq,
            aa.first_name AS first_name,
            aa.middle_name AS middle_name,
            aa.last_name AS last_name,
            aa.affiliation AS affiliation,
            aa.country
         FROM  article_authors aa,
            articles a,
            published_articles pa,
            issues i
         WHERE i.issue_id = pa.issue_id
            AND i.published = 1
            AND aa.article_id = a.article_id ' .
            (isset($journalId)?'AND a.journal_id = ? ':'') . '
            AND pa.article_id = a.article_id
            AND a.status = ' . STATUS_PUBLISHED . '
            AND (aa.last_name IS NOT NULL AND aa.last_name <> \'\')' .
            $initialSql . '
         ORDER BY aa.last_name, aa.first_name',
         empty($params)?false:$params,
         $rangeInfo
      );

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

   function &getAuthorIdsByArticle($articleId) {
      $authors = array();

      $result = &$this->retrieve(
         'SELECT author_id FROM article_authors WHERE article_id = ? ORDER BY seq',
         $articleId
      );

      while (!$result->EOF) {
         $authors[] = $result->fields[0];
         $result->moveNext();
      }

      $result->Close();
      unset($result);

      return $authors;
   }

   function getLocaleFieldNames() {
      return array('biography', 'competingInterests');
   }

   function updateLocaleFields(&$author) {
      $this->updateDataObjectSettings('article_author_settings', $author, array(
         'author_id' => $author->getAuthorId()
      ));

   }

   function &_returnAuthorFromRow(&$row) {
      $author = &new Author();
      $author->setAuthorId($row['author_id']);
      $author->setArticleId($row['article_id']);
      $author->setFirstName($row['first_name']);
      $author->setMiddleName($row['middle_name']);
      $author->setLastName($row['last_name']);
      $author->setAffiliation($row['affiliation']);
      $author->setCountry($row['country']);
      $author->setEmail($row['email']);
      $author->setUrl($row['url']);
      $author->setPrimaryContact($row['primary_contact']);
      $author->setSequence($row['seq']);

      $this->getDataObjectSettings('article_author_settings', 'author_id', $row['author_id'], $author);

      HookRegistry::call('AuthorDAO::_returnAuthorFromRow', array(&$author, &$row));

      return $author;
   }

   function insertAuthor(&$author) {
      $this->update(
         'INSERT INTO article_authors
            (article_id, first_name, middle_name, last_name, affiliation, country, email, url, primary_contact, seq)
            VALUES
            (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)',
         array(
            $author->getArticleId(),
            $author->getFirstName(),
            $author->getMiddleName() . '', // make non-null
            $author->getLastName(),
            $author->getAffiliation() . '', // make non-null
            $author->getCountry(),
            $author->getEmail(),
            $author->getUrl(),
            $author->getPrimaryContact(),
            $author->getSequence()
         )
      );

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

      return $author->getAuthorId();
   }

   function updateAuthor(&$author) {
      $returner = $this->update(
         'UPDATE article_authors
            SET
               first_name = ?,
               middle_name = ?,
               last_name = ?,
               affiliation = ?,
               country = ?,
               email = ?,
               url = ?,
               primary_contact = ?,
               seq = ?
            WHERE author_id = ?',
         array(
            $author->getFirstName(),
            $author->getMiddleName() . '', // make non-null
            $author->getLastName(),
            $author->getAffiliation() . '', // make non-null
            $author->getCountry(),
            $author->getEmail(),
            $author->getUrl(),
            $author->getPrimaryContact(),
            $author->getSequence(),
            $author->getAuthorId()
         )
      );
      $this->updateLocaleFields($author);
      return $returner;
   }

   function deleteAuthor(&$author) {
      return $this->deleteAuthorById($author->getAuthorId());
   }

   function deleteAuthorById($authorId, $articleId = null) {
      $params = array($authorId);
      if ($articleId) $params[] = $articleId;
      $returner = $this->update(
         'DELETE FROM article_authors WHERE author_id = ?' .
         ($articleId?' AND article_id = ?':''),
         $params
      );
      if ($returner) $this->update('DELETE FROM article_author_settings WHERE author_id = ?', array($authorId));
   }

   function deleteAuthorsByArticle($articleId) {
      $authors =& $this->getAuthorsByArticle($articleId);
      foreach ($authors as $author) {
         $this->deleteAuthor($author);
      }
   }

   function resequenceAuthors($articleId) {
      $result = &$this->retrieve(
         'SELECT author_id FROM article_authors WHERE article_id = ? ORDER BY seq', $articleId
      );

      for ($i=1; !$result->EOF; $i++) {
         list($authorId) = $result->fields;
         $this->update(
            'UPDATE article_authors SET seq = ? WHERE author_id = ?',
            array(
               $i,
               $authorId
            )
         );

         $result->moveNext();
      }

      $result->close();
      unset($result);
   }

   function getInsertAuthorId() {
      return $this->getInsertId('article_authors', 'author_id');
   }
}

?>

---