classes/article/SuppFileDAO.inc.php

<?php

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


import('article.SuppFile');

class SuppFileDAO extends DAO {
   function &getSuppFile($suppFileId, $articleId = null) {
      $params = array($suppFileId);
      if ($articleId) $params[] = $articleId;

      $result = &$this->retrieve(
         'SELECT s.*, a.file_name, a.original_file_name, a.file_type, a.file_size, a.status, a.date_uploaded, a.date_modified FROM article_supplementary_files s LEFT JOIN article_files a ON (s.file_id = a.file_id) WHERE s.supp_id = ?' . ($articleId?' AND s.article_id = ?':''),
         $params
      );

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

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

      return $returner;
   }

   function &getSuppFileByPublicSuppFileId($publicSuppId, $articleId) {
      $result = &$this->retrieve(
         'SELECT s.*, a.file_name, a.original_file_name, a.file_type, a.file_size, a.status, a.date_uploaded, a.date_modified FROM article_supplementary_files s LEFT JOIN article_files a ON (s.file_id = a.file_id) WHERE s.public_supp_file_id = ? AND s.article_id = ?',
         array($publicSuppId, $articleId)
      );

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

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

      return $returner;
   }

   function &getSuppFilesByArticle($articleId) {
      $suppFiles = array();

      $result = &$this->retrieve(
         'SELECT s.*, a.file_name, a.original_file_name, a.file_type, a.file_size, a.status, a.date_uploaded, a.date_modified FROM article_supplementary_files s LEFT JOIN article_files a ON (s.file_id = a.file_id) WHERE s.article_id = ? ORDER BY s.seq',
         $articleId
      );

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

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

      return $suppFiles;
   }

   function getLocaleFieldNames() {
      return array('title', 'creator', 'subject', 'typeOther', 'description', 'publisher', 'sponsor', 'source');
   }

   function updateLocaleFields(&$suppFile) {
      $this->updateDataObjectSettings('article_supp_file_settings', $suppFile, array(
         'supp_id' => $suppFile->getSuppFileId()
      ));
   }

   function &_returnSuppFileFromRow(&$row) {
      $suppFile = &new SuppFile();
      $suppFile->setSuppFileID($row['supp_id']);
      $suppFile->setPublicSuppFileID($row['public_supp_file_id']);
      $suppFile->setFileId($row['file_id']);
      $suppFile->setArticleId($row['article_id']);
      $suppFile->setType($row['type']);
      $suppFile->setDateCreated($this->dateFromDB($row['date_created']));
      $suppFile->setLanguage($row['language']);
      $suppFile->setShowReviewers($row['show_reviewers']);
      $suppFile->setDateSubmitted($this->datetimeFromDB($row['date_submitted']));
      $suppFile->setSequence($row['seq']);

      //ArticleFile set methods
      $suppFile->setFileName($row['file_name']);
      $suppFile->setOriginalFileName($row['original_file_name']);
      $suppFile->setFileType($row['file_type']);
      $suppFile->setFileSize($row['file_size']);
      $suppFile->setStatus($row['status']);
      $suppFile->setDateModified($this->datetimeFromDB($row['date_modified']));
      $suppFile->setDateUploaded($this->datetimeFromDB($row['date_uploaded']));

      $this->getDataObjectSettings('article_supp_file_settings', 'supp_id', $row['supp_id'], $suppFile);

      HookRegistry::call('SuppFileDAO::_returnSuppFileFromRow', array(&$suppFile, &$row));

      return $suppFile;
   }

   function insertSuppFile(&$suppFile) {
      if ($suppFile->getDateSubmitted() == null) {
         $suppFile->setDateSubmitted(Core::getCurrentDate());
      }
      if ($suppFile->getSequence() == null) {
         $suppFile->setSequence($this->getNextSuppFileSequence($suppFile->getArticleID()));
      }
      $this->update(
         sprintf('INSERT INTO article_supplementary_files
            (public_supp_file_id, file_id, article_id, type, date_created, language, show_reviewers, date_submitted, seq)
            VALUES
            (?, ?, ?, ?, %s, ?, ?, %s, ?)',
            $this->dateToDB($suppFile->getDateCreated()), $this->datetimeToDB($suppFile->getDateSubmitted())),
         array(
            $suppFile->getPublicSuppFileId(),
            $suppFile->getFileId(),
            $suppFile->getArticleId(),
            $suppFile->getType(),
            $suppFile->getLanguage(),
            $suppFile->getShowReviewers(),
            $suppFile->getSequence()
         )
      );
      $suppFile->setSuppFileId($this->getInsertSuppFileId());
      $this->updateLocaleFields($suppFile);
      return $suppFile->getSuppFileId();
   }

   function updateSuppFile(&$suppFile) {
      $returner = $this->update(
         sprintf('UPDATE article_supplementary_files
            SET
               public_supp_file_id = ?,
               file_id = ?,
               type = ?,
               date_created = %s,
               language = ?,
               show_reviewers = ?,
               seq = ?
            WHERE supp_id = ?',
            $this->dateToDB($suppFile->getDateCreated())),
         array(
            $suppFile->getPublicSuppFileId(),
            $suppFile->getFileId(),
            $suppFile->getType(),
            $suppFile->getLanguage(),
            $suppFile->getShowReviewers(),
            $suppFile->getSequence(),
            $suppFile->getSuppFileId()
         )
      );
      $this->updateLocaleFields($suppFile);
      return $returner;
   }

   function deleteSuppFile(&$suppFile) {
      return $this->deleteSuppFileById($suppFile->getSuppFileId());
   }

   function deleteSuppFileById($suppFileId, $articleId = null) {
      if (isset($articleId)) {
         $returner = $this->update('DELETE FROM article_supplementary_files WHERE supp_id = ? AND article_id = ?', array($suppFileId, $articleId));
         if ($returner) $this->update('DELETE FROM article_supp_file_settings WHERE supp_id = ?', $suppFileId);
         return $returner;

      } else {
         $this->update('DELETE FROM article_supp_file_settings WHERE supp_id = ?', $suppFileId);
         return $this->update(
            'DELETE FROM article_supplementary_files WHERE supp_id = ?', $suppFileId
         );
      }
   }

   function deleteSuppFilesByArticle($articleId) {
      $suppFiles =& $this->getSuppFilesByArticle($articleId);
      foreach ($suppFiles as $suppFile) {
         $this->deleteSuppFile($suppFile);
      }
   }

   function suppFileExistsByFileId($articleId, $fileId) {
      $result = &$this->retrieve(
         'SELECT COUNT(*) FROM article_supplementary_files
         WHERE article_id = ? AND file_id = ?',
         array($articleId, $fileId)
      );

      $returner = isset($result->fields[0]) && $result->fields[0] == 1 ? true : false;

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

      return $returner;
   }

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

      for ($i=1; !$result->EOF; $i++) {
         list($suppId) = $result->fields;
         $this->update(
            'UPDATE article_supplementary_files SET seq = ? WHERE supp_id = ?',
            array($i, $suppId)
         );
         $result->moveNext();
      }

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

   function getNextSuppFileSequence($articleId) {
      $result = &$this->retrieve(
         'SELECT MAX(seq) + 1 FROM article_supplementary_files WHERE article_id = ?',
         $articleId
      );
      $returner = floor($result->fields[0]);

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

      return $returner;
   }

   function getInsertSuppFileId() {
      return $this->getInsertId('article_supplementary_files', 'supp_id');
   }

   function &getSuppFileByBestSuppFileId($articleId, $suppId) {
      $suppFile = &$this->getSuppFileByPublicSuppFileId($suppId, $articleId);
      if (!isset($suppFile)) $suppFile = &$this->getSuppFile((int) $suppId, $articleId);
      return $suppFile;
   }

   function suppFileExistsByPublicId($publicSuppFileId, $suppId, $journalId) {
      $result = &$this->retrieve(
         'SELECT COUNT(*) FROM article_supplementary_files f, articles a WHERE f.article_id = a.article_id AND f.public_supp_file_id = ? AND f.supp_id <> ? AND a.journal_id = ?', array($publicSuppFileId, $suppId, $journalId)
      );
      $returner = $result->fields[0] ? true : false;

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

      return $returner;
   }
}

?>

---