| Server IP : 104.20.45.2 / Your IP : 172.16.20.3 Web Server : Apache/2.4.25 (Debian) System : Linux f64a392e70de 5.4.0-216-generic #236-Ubuntu SMP Fri Apr 11 19:53:21 UTC 2025 x86_64 User : application ( 1000) PHP Version : 5.6.40 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /app/classes/article/ |
Upload File : |
<?php
/**
* @file classes/articleArticleFileDAO.inc.php
*
* Copyright (c) 2013-2019 Simon Fraser University
* Copyright (c) 2003-2019 John Willinsky
* Distributed under the GNU GPL v2. For full terms see the file docs/COPYING.
*
* @class ArticleFileDAO
* @ingroup article
* @see ArticleFile
*
* @brief Operations for retrieving and modifying ArticleFile objects.
*/
import('lib.pkp.classes.file.PKPFileDAO');
import('classes.article.ArticleFile');
class ArticleFileDAO extends PKPFileDAO {
/**
* Retrieve an article by ID.
* @param $fileId int
* @param $revision int optional, if omitted latest revision is used
* @param $articleId int optional
* @return ArticleFile
*/
function &getArticleFile($fileId, $revision = null, $articleId = null) {
if ($fileId === null) {
$returner = null;
return $returner;
}
if ($revision == null) {
if ($articleId != null) {
$result =& $this->retrieveLimit(
'SELECT a.* FROM article_files a WHERE file_id = ? AND article_id = ? ORDER BY revision DESC',
array($fileId, $articleId),
1
);
} else {
$result =& $this->retrieveLimit(
'SELECT a.* FROM article_files a WHERE file_id = ? ORDER BY revision DESC',
$fileId,
1
);
}
} else {
if ($articleId != null) {
$result =& $this->retrieve(
'SELECT a.* FROM article_files a WHERE file_id = ? AND revision = ? AND article_id = ?',
array($fileId, $revision, $articleId)
);
} else {
$result =& $this->retrieve(
'SELECT a.* FROM article_files a WHERE file_id = ? AND revision = ?',
array($fileId, $revision)
);
}
}
$returner = null;
if (isset($result) && $result->RecordCount() != 0) {
$returner =& $this->_returnArticleFileFromRow($result->GetRowAssoc(false));
}
$result->Close();
unset($result);
return $returner;
}
/**
* Retrieve all revisions of an article file.
* @param $articleId int
* @return ArticleFile
*/
function &getArticleFileRevisions($fileId, $round = null) {
if ($fileId === null) {
$returner = null;
return $returner;
}
$articleFiles = array();
// FIXME If "round" is review-specific, it shouldn't be in this table
if ($round == null) {
$result =& $this->retrieve(
'SELECT a.* FROM article_files a WHERE file_id = ? ORDER BY revision',
$fileId
);
} else {
$result =& $this->retrieve(
'SELECT a.* FROM article_files a WHERE file_id = ? AND round = ? ORDER BY revision',
array($fileId, $round)
);
}
while (!$result->EOF) {
$articleFiles[] =& $this->_returnArticleFileFromRow($result->GetRowAssoc(false));
$result->moveNext();
}
$result->Close();
unset($result);
return $articleFiles;
}
/**
* Retrieve revisions of an article file in a range.
* @param $articleId int
* @return ArticleFile
*/
function &getArticleFileRevisionsInRange($fileId, $start = 1, $end = null) {
if ($fileId === null) {
$returner = null;
return $returner;
}
$articleFiles = array();
if ($end == null) {
$result =& $this->retrieve(
'SELECT a.* FROM article_files a WHERE file_id = ? AND revision >= ?',
array($fileId, $start)
);
} else {
$result =& $this->retrieve(
'SELECT a.* FROM article_files a WHERE file_id = ? AND revision >= ? AND revision <= ?',
array($fileId, $start, $end)
);
}
while (!$result->EOF) {
$articleFiles[] =& $this->_returnArticleFileFromRow($result->GetRowAssoc(false));
$result->moveNext();
}
$result->Close();
unset($result);
return $articleFiles;
}
/**
* Retrieve the current revision number for a file.
* @param $fileId int
* @return int
*/
function &getRevisionNumber($fileId) {
if ($fileId === null) {
$returner = null;
return $returner;
}
$result =& $this->retrieve(
'SELECT MAX(revision) AS max_revision FROM article_files a WHERE file_id = ?',
$fileId
);
if ($result->RecordCount() == 0) {
$returner = null;
} else {
$row = $result->FetchRow();
$returner = $row['max_revision'];
}
$result->Close();
unset($result);
return $returner;
}
/**
* Retrieve all article files for an article.
* @param $articleId int
* @return array ArticleFiles
*/
function &getArticleFilesByArticle($articleId) {
$articleFiles = array();
$result =& $this->retrieve(
'SELECT * FROM article_files WHERE article_id = ?',
$articleId
);
while (!$result->EOF) {
$articleFiles[] =& $this->_returnArticleFileFromRow($result->GetRowAssoc(false));
$result->moveNext();
}
$result->Close();
unset($result);
return $articleFiles;
}
/**
* Retrieve all article files for a file stage and assoc ID.
* @param $assocId int
* @param $fileStage int
* @return array ArticleFiles
*/
function &getArticleFilesByAssocId($assocId, $fileStage) {
import('classes.file.ArticleFileManager');
$articleFiles = array();
$result =& $this->retrieve(
'SELECT * FROM article_files WHERE assoc_id = ? AND file_stage = ?',
array($assocId, $fileStage)
);
while (!$result->EOF) {
$articleFiles[] =& $this->_returnArticleFileFromRow($result->GetRowAssoc(false));
$result->moveNext();
}
$result->Close();
unset($result);
return $articleFiles;
}
/**
* Internal function to return an ArticleFile object from a row.
* @param $row array
* @return ArticleFile
*/
function &_returnArticleFileFromRow(&$row) {
$articleFile = new ArticleFile();
$articleFile->setFileId($row['file_id']);
$articleFile->setSourceFileId($row['source_file_id']);
$articleFile->setSourceRevision($row['source_revision']);
$articleFile->setRevision($row['revision']);
$articleFile->setArticleId($row['article_id']);
$articleFile->setFileName($row['file_name']);
$articleFile->setFileType($row['file_type']);
$articleFile->setFileSize($row['file_size']);
$articleFile->setOriginalFileName($row['original_file_name']);
$articleFile->setFileStage($row['file_stage']);
$articleFile->setAssocId($row['assoc_id']);
$articleFile->setDateUploaded($this->datetimeFromDB($row['date_uploaded']));
$articleFile->setDateModified($this->datetimeFromDB($row['date_modified']));
$articleFile->setRound($row['round']);
$articleFile->setViewable($row['viewable']);
HookRegistry::call('ArticleFileDAO::_returnArticleFileFromRow', array(&$articleFile, &$row));
return $articleFile;
}
/**
* Insert a new ArticleFile.
* @param $articleFile ArticleFile
* @return int
*/
function insertArticleFile(&$articleFile) {
$fileId = $articleFile->getFileId();
$params = array(
$articleFile->getRevision() === null ? 1 : $articleFile->getRevision(),
(int) $articleFile->getArticleId(),
$articleFile->getSourceFileId()?$articleFile->getSourceFileId():null,
$articleFile->getSourceRevision()?$articleFile->getSourceRevision():null,
$articleFile->getFileName(),
$articleFile->getFileType(),
$articleFile->getFileSize(),
$articleFile->getOriginalFileName(),
$articleFile->getFileStage(),
(int) $articleFile->getRound(),
$articleFile->getViewable(),
$articleFile->getAssocId()
);
if ($fileId) {
array_unshift($params, $fileId);
}
$this->update(
sprintf('INSERT INTO article_files
(' . ($fileId ? 'file_id, ' : '') . 'revision, article_id, source_file_id, source_revision, file_name, file_type, file_size, original_file_name, file_stage, date_uploaded, date_modified, round, viewable, assoc_id)
VALUES
(' . ($fileId ? '?, ' : '') . '?, ?, ?, ?, ?, ?, ?, ?, ?, %s, %s, ?, ?, ?)',
$this->datetimeToDB($articleFile->getDateUploaded()), $this->datetimeToDB($articleFile->getDateModified())),
$params
);
if (!$fileId) {
$articleFile->setFileId($this->getInsertArticleFileId());
}
return $articleFile->getFileId();
}
/**
* Update an existing article file.
* @param $article ArticleFile
*/
function updateArticleFile(&$articleFile) {
$this->update(
sprintf('UPDATE article_files
SET
article_id = ?,
source_file_id = ?,
source_revision = ?,
file_name = ?,
file_type = ?,
file_size = ?,
original_file_name = ?,
file_stage = ?,
date_uploaded = %s,
date_modified = %s,
round = ?,
viewable = ?,
assoc_id = ?
WHERE file_id = ? AND revision = ?',
$this->datetimeToDB($articleFile->getDateUploaded()), $this->datetimeToDB($articleFile->getDateModified())),
array(
(int) $articleFile->getArticleId(),
$articleFile->getSourceFileId()?$articleFile->getSourceFileId():null,
$articleFile->getSourceRevision()?$articleFile->getSourceRevision():null,
$articleFile->getFileName(),
$articleFile->getFileType(),
$articleFile->getFileSize(),
$articleFile->getOriginalFileName(),
$articleFile->getFileStage(),
(int) $articleFile->getRound(),
$articleFile->getViewable(),
$articleFile->getAssocId(),
$articleFile->getFileId(),
$articleFile->getRevision()
)
);
return $articleFile->getFileId();
}
/**
* Delete an article file.
* @param $article ArticleFile
*/
function deleteArticleFile(&$articleFile) {
return $this->deleteArticleFileById($articleFile->getFileId(), $articleFile->getRevision());
}
/**
* Delete an article file by ID.
* @param $articleId int
* @param $revision int
*/
function deleteArticleFileById($fileId, $revision = null) {
if ($revision == null) {
return $this->update(
'DELETE FROM article_files WHERE file_id = ?', $fileId
);
} else {
return $this->update(
'DELETE FROM article_files WHERE file_id = ? AND revision = ?', array($fileId, $revision)
);
}
}
/**
* Delete all article files for an article.
* @param $articleId int
*/
function deleteArticleFiles($articleId) {
return $this->update(
'DELETE FROM article_files WHERE article_id = ?', $articleId
);
}
/**
* Get the ID of the last inserted article file.
* @return int
*/
function getInsertArticleFileId() {
return $this->getInsertId('article_files', 'file_id');
}
}
?>