| 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/journal/ |
Upload File : |
<?php
/**
* @file classes/journal/JournalStatisticsDAO.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 JournalStatisticsDAO
* @ingroup journal
*
* @brief Operations for retrieving journal statistics.
*/
define('REPORT_TYPE_JOURNAL', 0x00001);
define('REPORT_TYPE_EDITOR', 0x00002);
define('REPORT_TYPE_REVIEWER', 0x00003);
define('REPORT_TYPE_SECTION', 0x00004);
class JournalStatisticsDAO extends DAO {
/**
* Determine the first date the journal was active.
* (This is an approximation but needs to run quickly.)
* @param $journalId int Journal ID
* @return int|null Date in seconds since the UNIX epoch, or null
* if it could not be determined
*/
function getFirstActivityDate($journalId) {
$result =& $this->retrieve(
'SELECT LEAST(a.date_submitted, COALESCE(pa.date_published, NOW()), COALESCE(i.date_published, NOW())) AS first_date
FROM articles a
LEFT JOIN published_articles pa ON (a.article_id = pa.article_id)
LEFT JOIN issues i ON (pa.issue_id = i.issue_id)
LEFT JOIN articles a2 ON (a2.article_id < a.article_id AND a2.date_submitted IS NOT NULL AND a2.journal_id = ?)
WHERE a2.article_id IS NULL AND
a.date_submitted IS NOT NULL AND
a.journal_id = ?',
array(
(int) $journalId,
(int) $journalId
)
);
$row = $result->GetRowAssoc(false);
$firstActivityDate = $this->datetimeFromDB($row['first_date']);
$result->Close();
// An earlier user registration can override the earliest article activity date
$result =& $this->retrieve(
'SELECT MIN(u.date_registered) AS first_date FROM users u JOIN roles r ON (u.user_id = r.user_id) WHERE r.journal_id = ?',
array(
(int) $journalId
)
);
$row = $result->GetRowAssoc(false);
$firstUserDate = $this->datetimeFromDB($row['first_date']);
if (!$firstActivityDate || ($firstUserDate && $firstActivityDate && strtotime($firstUserDate) < strtotime($firstActivityDate))) {
$firstActivityDate = $firstUserDate;
}
if (!$firstActivityDate) return null;
return strtotime($firstActivityDate);
}
/**
* Get statistics about articles in the system.
* Returns a map of name => value pairs.
* @param $journalId int The journal to fetch statistics for
* @param $sectionId int The section to query stats for (optional)
* @param $dateStart date The submit date to search from; optional
* @param $dateEnd date The submit date to search to; optional
* @return array
*/
function getArticleStatistics($journalId, $sectionIds = null, $dateStart = null, $dateEnd = null) {
// Bring in status constants
import('classes.article.Article');
$params = array($journalId);
if (!empty($sectionIds)) {
$sectionSql = ' AND (a.section_id = ?';
$params[] = array_shift($sectionIds);
foreach ($sectionIds as $sectionId) {
$sectionSql .= ' OR a.section_id = ?';
$params[] = $sectionId;
}
$sectionSql .= ')';
} else $sectionSql = '';
$sql = 'SELECT a.article_id,
a.date_submitted,
pa.date_published,
pa.published_article_id,
d.decision,
a.status
FROM articles a
LEFT JOIN published_articles pa ON (a.article_id = pa.article_id)
LEFT JOIN edit_decisions d ON (d.article_id = a.article_id)
WHERE a.journal_id = ?' .
($dateStart !== null ? ' AND a.date_submitted >= ' . $this->datetimeToDB($dateStart) : '') .
($dateEnd !== null ? ' AND a.date_submitted <= ' . $this->datetimeToDB($dateEnd) : '') .
$sectionSql .
' ORDER BY a.article_id, d.date_decided DESC';
$result =& $this->retrieve($sql, $params);
$returner = array(
'numSubmissions' => 0,
'numReviewedSubmissions' => 0,
'numPublishedSubmissions' => 0,
'submissionsAccept' => 0,
'submissionsDecline' => 0,
'submissionsAcceptPercent' => 0,
'submissionsDeclinePercent' => 0,
'daysToPublication' => 0
);
// Track which articles we're including
$articleIds = array();
$totalTimeToPublication = 0;
$timeToPublicationCount = 0;
while (!$result->EOF) {
$row = $result->GetRowAssoc(false);
// For each article, pick the most recent editor
// decision only and ignore the rest. Depends on sort
// order. FIXME -- there must be a better way of doing
// this that's database independent.
if (!in_array($row['article_id'], $articleIds)) {
$articleIds[] = $row['article_id'];
$returner['numSubmissions']++;
if (!empty($row['published_article_id']) && $row['status'] == STATUS_PUBLISHED) {
$returner['numPublishedSubmissions']++;
}
if (!empty($row['date_submitted']) && !empty($row['date_published']) && $row['status'] == STATUS_PUBLISHED) {
$timeSubmitted = strtotime($this->datetimeFromDB($row['date_submitted']));
$timePublished = strtotime($this->datetimeFromDB($row['date_published']));
if ($timePublished > $timeSubmitted) {
$totalTimeToPublication += ($timePublished - $timeSubmitted);
$timeToPublicationCount++;
}
}
import('classes.submission.common.Action');
switch ($row['decision']) {
case SUBMISSION_EDITOR_DECISION_ACCEPT:
$returner['submissionsAccept']++;
$returner['numReviewedSubmissions']++;
break;
case SUBMISSION_EDITOR_DECISION_DECLINE:
$returner['submissionsDecline']++;
$returner['numReviewedSubmissions']++;
break;
}
}
$result->moveNext();
}
$result->Close();
unset($result);
// Calculate percentages where necessary
if ($returner['numReviewedSubmissions'] != 0) {
$returner['submissionsAcceptPercent'] = round($returner['submissionsAccept'] * 100 / $returner['numReviewedSubmissions']);
$returner['submissionsDeclinePercent'] = round($returner['submissionsDecline'] * 100 / $returner['numReviewedSubmissions']);
}
if ($timeToPublicationCount != 0) {
// Keep one sig fig
$returner['daysToPublication'] = round($totalTimeToPublication / $timeToPublicationCount / 60 / 60 / 24);
}
return $returner;
}
/**
* Get statistics about users in the system.
* Returns a map of name => value pairs.
* @param $journalId int The journal to fetch statistics for
* @param $dateStart date optional
* @param $dateEnd date optional
* @return array
*/
function getUserStatistics($journalId, $dateStart = null, $dateEnd = null) {
$roleDao =& DAORegistry::getDAO('RoleDAO');
// Get count of total users for this journal
$result =& $this->retrieve(
'SELECT COUNT(DISTINCT r.user_id) FROM roles r, users u WHERE r.user_id = u.user_id AND r.journal_id = ?' .
($dateStart !== null ? ' AND u.date_registered >= ' . $this->datetimeToDB($dateStart) : '') .
($dateEnd !== null ? ' AND u.date_registered <= ' . $this->datetimeToDB($dateEnd) : ''),
$journalId
);
$returner = array(
'totalUsersCount' => $result->fields[0]
);
$result->Close();
unset($result);
// Get user counts for each role.
$result =& $this->retrieve(
'SELECT r.role_id, COUNT(r.user_id) AS role_count FROM roles r LEFT JOIN users u ON (r.user_id = u.user_id) WHERE r.journal_id = ?' .
($dateStart !== null ? ' AND u.date_registered >= ' . $this->datetimeToDB($dateStart) : '') .
($dateEnd !== null ? ' AND u.date_registered <= ' . $this->datetimeToDB($dateEnd) : '') .
' GROUP BY r.role_id',
$journalId
);
while (!$result->EOF) {
$row = $result->GetRowAssoc(false);
$returner[$roleDao->getRolePath($row['role_id'])] = $row['role_count'];
$result->moveNext();
}
$result->Close();
unset($result);
return $returner;
}
/**
* Get statistics about subscriptions.
* @param $journalId int The journal to fetch statistics for
* @param $dateStart date optional
* @param $dateEnd date optional
* @return array
*/
function getSubscriptionStatistics($journalId, $dateStart = null, $dateEnd = null) {
$result =& $this->retrieve(
'SELECT st.type_id,
sts.setting_value AS type_name,
count(s.subscription_id) AS type_count
FROM subscription_types st
LEFT JOIN journals j ON (j.journal_id = st.journal_id)
LEFT JOIN subscription_type_settings sts ON (st.type_id = sts.type_id AND sts.setting_name = ? AND sts.locale = j.primary_locale),
subscriptions s
WHERE st.journal_id = ?
AND s.type_id = st.type_id' .
($dateStart !== null ? ' AND s.date_start >= ' . $this->datetimeToDB($dateStart) : '') .
($dateEnd !== null ? ' AND s.date_start <= ' . $this->datetimeToDB($dateEnd) : '') .
' GROUP BY st.type_id, sts.setting_value',
array('name', $journalId)
);
$returner = array();
while (!$result->EOF) {
$row = $result->getRowAssoc(false);
$returner[$row['type_id']] = array(
'name' => $row['type_name'],
'count' => $row['type_count']
);
$result->moveNext();
}
$result->Close();
unset($result);
return $returner;
}
/**
* Get statistics about issues in the system.
* Returns a map of name => value pairs.
* @param $journalId int The journal to fetch statistics for
* @param $dateStart date The publish date to search from; optional
* @param $dateEnd date The publish date to search to; optional
* @return array
*/
function getIssueStatistics($journalId, $dateStart = null, $dateEnd = null) {
$result =& $this->retrieve(
'SELECT COUNT(*) AS count, published FROM issues WHERE journal_id = ?' .
($dateStart !== null ? ' AND date_published >= ' . $this->datetimeToDB($dateStart) : '') .
($dateEnd !== null ? ' AND date_published <= ' . $this->datetimeToDB($dateEnd) : '') .
' GROUP BY published',
$journalId
);
$returner = array(
'numPublishedIssues' => 0,
'numUnpublishedIssues' => 0
);
while (!$result->EOF) {
$row = $result->GetRowAssoc(false);
if ($row['published']) {
$returner['numPublishedIssues'] = $row['count'];
} else {
$returner['numUnpublishedIssues'] = $row['count'];
}
$result->moveNext();
}
$result->Close();
unset($result);
$returner['numIssues'] = $returner['numPublishedIssues'] + $returner['numUnpublishedIssues'];
return $returner;
}
/**
* Get statistics about reviewers in the system.
* Returns a map of name => value pairs.
* @param $journalId int The journal to fetch statistics for
* @param $dateStart date The publish date to search from; optional
* @param $dateEnd date The publish date to search to; optional
* @return array
*/
function getReviewerStatistics($journalId, $sectionIds, $dateStart = null, $dateEnd = null) {
$params = array($journalId);
if (!empty($sectionIds)) {
$sectionSql = ' AND (a.section_id = ?';
$params[] = array_shift($sectionIds);
foreach ($sectionIds as $sectionId) {
$sectionSql .= ' OR a.section_id = ?';
$params[] = $sectionId;
}
$sectionSql .= ')';
} else $sectionSql = '';
$sql = 'SELECT a.article_id,
af.date_uploaded AS date_rv_uploaded,
r.review_id,
u.date_registered,
r.reviewer_id,
r.quality,
r.date_assigned,
r.date_completed
FROM articles a,
article_files af,
review_assignments r
LEFT JOIN users u ON (u.user_id = r.reviewer_id)
WHERE a.journal_id = ?
AND r.submission_id = a.article_id
AND af.article_id = a.article_id
AND af.file_id = a.review_file_id
AND af.revision = 1' .
($dateStart !== null ? ' AND a.date_submitted >= ' . $this->datetimeToDB($dateStart) : '') .
($dateEnd !== null ? ' AND a.date_submitted <= ' . $this->datetimeToDB($dateEnd) : '') .
$sectionSql;
$result =& $this->retrieve($sql, $params);
$returner = array(
'reviewsCount' => 0,
'reviewerScore' => 0,
'daysPerReview' => 0,
'reviewerAddedCount' => 0,
'reviewerCount' => 0,
'reviewedSubmissionsCount' => 0
);
$scoredReviewsCount = 0;
$totalScore = 0;
$completedReviewsCount = 0;
$totalElapsedTime = 0;
$reviewerList = array();
$articleIds = array();
while (!$result->EOF) {
$row = $result->GetRowAssoc(false);
$returner['reviewsCount']++;
if (!empty($row['quality'])) {
$scoredReviewsCount++;
$totalScore += $row['quality'];
}
$articleIds[] = $row['article_id'];
if (!empty($row['reviewer_id']) && !in_array($row['reviewer_id'], $reviewerList)) {
$returner['reviewerCount']++;
$dateRegistered = strtotime($this->datetimeFromDB($row['date_registered']));
if (($dateRegistered >= $dateStart || $dateStart === null) && ($dateRegistered <= $dateEnd || $dateEnd == null)) {
$returner['reviewerAddedCount']++;
}
array_push($reviewerList, $row['reviewer_id']);
}
if (!empty($row['date_assigned']) && !empty($row['date_completed'])) {
$timeReviewVersionUploaded = strtotime($this->datetimeFromDB($row['date_rv_uploaded']));
$timeCompleted = strtotime($this->datetimeFromDB($row['date_completed']));
if ($timeCompleted > $timeReviewVersionUploaded) {
$completedReviewsCount++;
$totalElapsedTime += ($timeCompleted - $timeReviewVersionUploaded);
}
}
$result->moveNext();
}
$result->Close();
unset($result);
if ($scoredReviewsCount > 0) {
// To one decimal place
$returner['reviewerScore'] = round($totalScore * 10 / $scoredReviewsCount) / 10;
}
if ($completedReviewsCount > 0) {
$seconds = $totalElapsedTime / $completedReviewsCount;
$returner['daysPerReview'] = $seconds / 60 / 60 / 24;
}
$articleIds = array_unique($articleIds);
$returner['reviewedSubmissionsCount'] = count($articleIds);
return $returner;
}
}
?>