CounterReportJR1.inc.php

<?php
 
import('plugins.reports.counter.classes.CounterReport');
 
class CounterReportJR1 extends CounterReport {
   function getTitle() {
      return __('plugins.reports.counter.jr1.title');
   }
 
   /*
    * Convert an OJS metrics request to COUNTER ReportItems
    * @param $columns string|array column (aggregation level) selection
    * @param $filters array report-level filter selection
    * @param $orderBy array order criteria
    * @param $range null|DBResultRange paging specification
    * @see ReportPlugin::getMetrics for more details
    * @return array COUNTER\ReportItem array
    */
   function getReportItems($columns = array(), $filters = array(), $orderBy = array(), $range = null) {
      $metricsDao = DAORegistry::getDAO('MetricsDAO'); /* @var $metricsDao MetricsDAO */
 
      // Columns are fixed for this report
      $defaultColumns = array(STATISTICS_DIMENSION_MONTH, STATISTICS_DIMENSION_FILE_TYPE, STATISTICS_DIMENSION_CONTEXT_ID);
      if ($columns && array_diff($columns, $defaultColumns)) {
         $this->setError(new Exception(__('plugins.reports.counter.exception.column'), COUNTER_EXCEPTION_WARNING | COUNTER_EXCEPTION_BAD_COLUMNS));
      }
      // Check filters for correct context(s)
      $validFilters = $this->filterForContext($filters);
      // Filters defaults to last month, but can be provided by month or by day
      if (!isset($filters[STATISTICS_DIMENSION_MONTH]) && !isset($filters[STATISTICS_DIMENSION_DAY])) {
         $validFilters[STATISTICS_DIMENSION_MONTH] = array(
            'from' => date_format(date_create("first day of previous month"), 'Ymd'),
            'to' => date_format(date_create("last day of previous month"), 'Ymd')
            );
      } elseif (isset($filters[STATISTICS_DIMENSION_MONTH])) {
         $validFilters[STATISTICS_DIMENSION_MONTH] = $filters[STATISTICS_DIMENSION_MONTH];
         unset($filters[STATISTICS_DIMENSION_MONTH]);
      } elseif (isset($filters[STATISTICS_DIMENSION_DAY])) {
         $validFilters[STATISTICS_DIMENSION_DAY] = $filters[STATISTICS_DIMENSION_DAY];
         unset($filters[STATISTICS_DIMENSION_DAY]);
      }
      if (!isset($filters[STATISTICS_DIMENSION_ASSOC_TYPE])) {
         $validFilters[STATISTICS_DIMENSION_ASSOC_TYPE] = ASSOC_TYPE_SUBMISSION_FILE;
         unset($filters[STATISTICS_DIMENSION_ASSOC_TYPE]);
      } elseif ($filters[STATISTICS_DIMENSION_ASSOC_TYPE] != ASSOC_TYPE_SUBMISSION_FILE) {
         $this->setError(new Exception(__('plugins.reports.counter.exception.filter'), COUNTER_EXCEPTION_ERROR | COUNTER_EXCEPTION_BAD_FILTERS));
      }
      // Any further filters aren't recognized (at this time, at least)
      if (array_keys($filters)) {
         $this->setError(new Exception(__('plugins.reports.counter.exception.filter'), COUNTER_EXCEPTION_WARNING | COUNTER_EXCEPTION_BAD_FILTERS));
      }
      // Metric type is ojs::counter
      $metricType = METRIC_TYPE_COUNTER;
      // Ordering must be by Journal (ReportItem), and by Month (ItemPerformance) for JR1
      $validOrder = array(STATISTICS_DIMENSION_CONTEXT_ID => STATISTICS_ORDER_DESC, STATISTICS_DIMENSION_MONTH => STATISTICS_ORDER_ASC);
      // TODO: range
      $results = $metricsDao->getMetrics($metricType, $defaultColumns, $validFilters, $validOrder);
      $reportItems = array();
      if ($results) {
         // We'll create a new Report Item with these Metrics on a journal change
         $metrics = array();
         // We'll create a new Metric with these Performance Counters on a period change
         $counters = array();
         $lastPeriod = 0;
         $lastJournal = 0;
         foreach ($results as $rs) {
            // Identify the type of request
            $metricTypeKey = $this->getKeyForFiletype($rs[STATISTICS_DIMENSION_FILE_TYPE]);
            // Period changes or greater trigger a new ItemPerformace metric
            if ($lastPeriod != $rs[STATISTICS_DIMENSION_MONTH] || $lastJournal != $rs[STATISTICS_DIMENSION_CONTEXT_ID]) {
               if ($lastPeriod != 0) {
                  $metrics[] = $this->createMetricByMonth($lastPeriod, $counters);
                  $counters = array();
               }
            }
            $lastPeriod = $rs[STATISTICS_DIMENSION_MONTH];
            $counters[] = new COUNTER\PerformanceCounter($metricTypeKey, $rs[STATISTICS_METRIC]);
            // Journal changes trigger a new ReportItem
            if ($lastJournal != $rs[STATISTICS_DIMENSION_CONTEXT_ID]) {
               if ($lastJournal != 0 && $metrics) {
                  $item = $this->_createReportItem($lastJournal, $metrics);
                  if ($item) {
                     $reportItems[] = $item;
                  } else {
                     $this->setError(new Exception(__('plugins.reports.counter.exception.partialData'), COUNTER_EXCEPTION_WARNING | COUNTER_EXCEPTION_PARTIAL_DATA));
                  }
                  $metrics = array();
               }
            }
            $lastJournal = $rs[STATISTICS_DIMENSION_CONTEXT_ID];
         }
         // Capture the last unprocessed ItemPerformance and ReportItem entries, if applicable
         if ($counters) {
            $metrics[] = $this->createMetricByMonth($lastPeriod, $counters);
         }
         if ($metrics) {
            $item = $this->_createReportItem($lastJournal, $metrics);
            if ($item) {
               $reportItems[] = $item;
            } else {
               $this->setError(new Exception(__('plugins.reports.counter.exception.partialData'), COUNTER_EXCEPTION_WARNING | COUNTER_EXCEPTION_PARTIAL_DATA));
            }
         }
      } else {
         $this->setError(new Exception(__('plugins.reports.counter.exception.noData'), COUNTER_EXCEPTION_ERROR | COUNTER_EXCEPTION_NO_DATA));
      }
      return $reportItems;
   }
 
   private function _createReportItem($journalId, $metrics) {
      $journalDao = DAORegistry::getDAO('JournalDAO'); /* @var $journalDao JournalDAO */
      $journal = $journalDao->getById($journalId);
      if (!$journal) {
         return false;
      }
      $journalName = $journal->getLocalizedName();
      $journalPubIds = array();
      foreach (array('print', 'online') as $issnType) {
         if ($journal->getData($issnType.'Issn')) {
            try {
               $journalPubIds[] = new COUNTER\Identifier(ucfirst($issnType).'_ISSN', $journal->getData($issnType.'Issn'));
            } catch (Exception $ex) {
               // Just ignore it
            }
         }
      }
      $journalPubIds[] = new COUNTER\Identifier(COUNTER_LITERAL_PROPRIETARY, $journal->getPath());
      $reportItem = array();
      try {
         $reportItem = new COUNTER\ReportItems(__('common.software'), $journalName, COUNTER_LITERAL_JOURNAL, $metrics, NULL, $journalPubIds);
      } catch (Exception $e) {
         $this->setError($e, COUNTER_EXCEPTION_ERROR | COUNTER_EXCEPTION_INTERNAL);
      }
      return $reportItem;
   }
 
}