ResolverPlugin.inc.php

<?php
 
import('lib.pkp.classes.plugins.GatewayPlugin');
 
class ResolverPlugin extends GatewayPlugin {
   function register($category, $path, $mainContextId = null) {
      $success = parent::register($category, $path, $mainContextId);
      $this->addLocaleData();
      return $success;
   }
 
   function getContextSpecificPluginSettingsFile() {
      return $this->getPluginPath() . '/settings.xml';
   }
 
   function getName() {
      return 'ResolverPlugin';
   }
 
   function getDisplayName() {
      return __('plugins.gateways.resolver.displayName');
   }
 
   function getDescription() {
      return __('plugins.gateways.resolver.description');
   }
 
   function fetch($args, $request) {
      if (!$this->getEnabled()) {
         return false;
      }
 
      $scheme = array_shift($args);
      switch ($scheme) {
         case 'doi':
            $doi = implode('/', $args);
            $submissionDao = DAORegistry::getDAO('SubmissionDAO'); /* @var $submissionDao SubmissionDAO */
            $article = $submissionDao->getByPubId('doi', $doi, $request->getJournal());
            if($article) {
               $request->redirect(null, 'article', 'view', $article->getBestId());
            }
            break;
         case 'vnp': // Volume, number, page
         case 'ynp': // Volume, number, year, page
            // This can only be used from within a journal context
            $journal = $request->getJournal();
            if (!$journal) break;
 
            if ($scheme == 'vnp') {
               $volume = (int) array_shift($args);
               $year = null;
            } elseif ($scheme == 'ynp') {
               $year = (int) array_shift($args);
               $volume = null;
            } else {
               return; // Suppress scrutinizer warn
            }
            $number = array_shift($args);
            $page = (int) array_shift($args);
 
            $issueDao = DAORegistry::getDAO('IssueDAO'); /* @var $issueDao IssueDAO */
            $issues = $issueDao->getPublishedIssuesByNumber($journal->getId(), $volume, $number, $year);
 
            // Ensure only one issue matched, and fetch it.
            $issue = $issues->next();
            if (!$issue || $issues->next()) break;
            unset($issues);
 
            $submissionsIterator = Services::get('submission')->getMany([
               'issueIds' => $issue->getId(),
            ]);
            foreach ($submissionsIterator as $submission) {
               // Look for the correct page in the list of articles.
               $matches = null;
               if (PKPString::regexp_match_get('/^[Pp][Pp]?[.]?[ ]?(\d+)$/', $submission->getPages(), $matches)) {
                  $matchedPage = $matches[1];
                  if ($page == $matchedPage) $request->redirect(null, 'article', 'view', $submission->getBestId());
               }
               if (PKPString::regexp_match_get('/^[Pp][Pp]?[.]?[ ]?(\d+)[ ]?-[ ]?([Pp][Pp]?[.]?[ ]?)?(\d+)$/', $submission->getPages(), $matches)) {
                  $matchedPageFrom = $matches[1];
                  $matchedPageTo = $matches[3];
                  if ($page >= $matchedPageFrom && ($page < $matchedPageTo || ($page == $matchedPageTo && $matchedPageFrom = $matchedPageTo))) $request->redirect(null, 'article', 'view', $submission->getBestId());
               }
               unset($submission);
            }
            break;
      }
 
      // Failure.
      header('HTTP/1.0 404 Not Found');
      $templateMgr = TemplateManager::getManager($request);
      AppLocale::requireComponents(LOCALE_COMPONENT_APP_COMMON);
      $templateMgr->assign('message', 'plugins.gateways.resolver.errors.errorMessage');
      $templateMgr->display('frontend/pages/message.tpl');
      exit;
   }
 
   function sanitize($string) {
      return str_replace("\t", " ", strip_tags($string));
   }
 
   function exportHoldings() {
      $journalDao = DAORegistry::getDAO('JournalDAO'); /* @var $journalDao JournalDAO */
      $issueDao = DAORegistry::getDAO('IssueDAO'); /* @var $issueDao IssueDAO */
      $journals = $journalDao->getAll(true);
      $request = Application::get()->getRequest();
      header('content-type: text/plain');
      header('content-disposition: attachment; filename=holdings.txt');
      echo "title\tissn\te_issn\tstart_date\tend_date\tembargo_months\tembargo_days\tjournal_url\tvol_start\tvol_end\tiss_start\tiss_end\n";
      while ($journal = $journals->next()) {
         $issues = $issueDao->getPublishedIssues($journal->getId());
         $startDate = $endDate = null;
         $startNumber = $endNumber = null;
         $startVolume = $endVolume = null;
         while ($issue = $issues->next()) {
            $datePublished = $issue->getDatePublished();
            if ($datePublished !== null) $datePublished = strtotime($datePublished);
            if ($startDate === null || $startDate > $datePublished) $startDate = $datePublished;
            if ($endDate === null || $endDate < $datePublished) $endDate = $datePublished;
            $volume = $issue->getVolume();
            if ($startVolume === null || $startVolume > $volume) $startVolume = $volume;
            if ($endVolume === null || $endVolume < $volume) $endVolume = $volume;
            $number = $issue->getNumber();
            if ($startNumber === null || $startNumber > $number) $startNumber = $number;
            if ($endNumber === null || $endNumber < $number) $endNumber = $number;
         }
 
         echo $this->sanitize($journal->getLocalizedName()) . "\t";
         echo $this->sanitize($journal->getData('printIssn')) . "\t";
         echo $this->sanitize($journal->getData('onlineIssn')) . "\t";
         echo $this->sanitize($startDate===null?'':strftime('%Y-%m-%d', $startDate)) . "\t"; // start_date
         echo $this->sanitize($endDate===null?'':strftime('%Y-%m-%d', $endDate)) . "\t"; // end_date
         echo $this->sanitize('') . "\t"; // embargo_months
         echo $this->sanitize('') . "\t"; // embargo_days
         echo $request->url($journal->getPath()) . "\t"; // journal_url
         echo $this->sanitize($startVolume) . "\t"; // vol_start
         echo $this->sanitize($endVolume) . "\t"; // vol_end
         echo $this->sanitize($startNumber) . "\t"; // iss_start
         echo $this->sanitize($endNumber) . "\n"; // iss_end
 
      }
   }
}