DOAJInfoSender.inc.php

<?php
 
import('lib.pkp.classes.scheduledTask.ScheduledTask');
 
 
class DOAJInfoSender extends ScheduledTask {
   var $_plugin;
 
   function __construct($args) {
      PluginRegistry::loadCategory('importexport');
      $plugin = PluginRegistry::getPlugin('importexport', 'DOAJExportPlugin'); /* @var $plugin DOAJExportPlugin */
      $this->_plugin = $plugin;
 
      if (is_a($plugin, 'DOAJExportPlugin')) {
         $plugin->addLocaleData();
      }
 
      parent::__construct($args);
   }
 
   function getName() {
      return __('plugins.importexport.doaj.senderTask.name');
   }
 
   function executeActions() {
      if (!$this->_plugin) return false;
 
      $plugin = $this->_plugin;
      $journals = $this->_getJournals();
 
      foreach ($journals as $journal) {
         // Get unregistered articles
         $unregisteredArticles = $plugin->getUnregisteredArticles($journal);
         // If there are articles to be deposited
         if (count($unregisteredArticles)) {
            $this->_registerObjects($unregisteredArticles, 'article=>doaj-json', $journal, 'articles');
         }
      }
      return true;
   }
 
   function _getJournals() {
      $plugin = $this->_plugin;
      $contextDao = Application::getContextDAO(); /* @var $contextDao JournalDAO */
      $journalFactory = $contextDao->getAll(true);
 
      $journals = array();
      while($journal = $journalFactory->next()) {
         $journalId = $journal->getId();
         if (!$plugin->getSetting($journalId, 'apiKey') || !$plugin->getSetting($journalId, 'automaticRegistration')) continue;
         $journals[] = $journal;
      }
      return $journals;
   }
 
 
   function _registerObjects($objects, $filter, $journal, $objectsFileNamePart) {
      $plugin = $this->_plugin;
      foreach ($objects as $object) {
         // Get the JSON
         $exportJson = $plugin->exportJSON($object, $filter, $journal);
         // Deposit the JSON
         $result = $plugin->depositXML($object, $journal, $exportJson);
         if ($result !== true) {
            $this->_addLogEntry($result);
         }
      }
   }
 
   function _addLogEntry($errors) {
      if (is_array($errors)) {
         foreach($errors as $error) {
            assert(is_array($error) && count($error) >= 1);
            $this->addExecutionLogEntry(
               __($error[0], array('param' => (isset($error[1]) ? $error[1] : null))),
               SCHEDULED_TASK_MESSAGE_TYPE_WARNING
            );
         }
      }
   }
 
}