parseCitations.php

<?php
 
require(dirname(dirname(dirname(dirname(__FILE__)))) . '/tools/bootstrap.inc.php');
 
class CitationsParsingTool extends CommandLineTool {
 
   function __construct($argv = array()) {
      parent::__construct($argv);
 
      if (!sizeof($this->argv)) {
         $this->usage();
         exit(1);
      }
 
      $this->parameters = $this->argv;
   }
 
   function usage() {
      echo "Parse and save submission(s) citations.\n"
         . "Usage:\n"
         . "{$this->scriptName} all\n"
         . "{$this->scriptName} context context_id [...]\n"
         . "{$this->scriptName} submission submission_id [...]\n";
   }
 
   function execute() {
      $submissionDao = DAORegistry::getDAO('SubmissionDAO'); /* @var $submissionDao SubmissionDAO */
      $citationDao = DAORegistry::getDAO('CitationDAO');
      $contextDao = Application::getContextDAO();
 
      switch(array_shift($this->parameters)) {
         case 'all':
            $contexts = $contextDao->getAll();
            while ($context = $contexts->next()) {
               $submissions = $submissionDao->getByContextId($context->getId());
               while ($submission = $submissions->next()) {
                  $this->_parseSubmission($submission);
               }
            }
            break;
         case 'context':
            foreach($this->parameters as $contextId) {
               $context = $contextDao->getById($contextId);
               if(!isset($context)) {
                  printf("Error: Skipping $contextId. Unknown context.\n");
                  continue;
               }
               $submissions = $submissionDao->getByContextId($contextId);
               while ($submission = $submissions->next()) {
                  $this->_parseSubmission($submission);
               }
            }
            break;
         case 'submission':
            foreach($this->parameters as $submissionId) {
               $submission = $submissionDao->getById($submissionId);
               if(!isset($submission)) {
                  printf("Error: Skipping $submissionId. Unknown submission.\n");
                  continue;
               }
               $this->_parseSubmission($submission);
            }
            break;
         default:
            $this->usage();
            break;
      }
   }
 
   private function _parseSubmission($submission) {
      foreach ((array) $submission->getData('publications') as $publication) {
         if (!empty($publication->getData('citationsRaw'))) {
            DAORegistry::getDAO('CitationDAO')->importCitations($publication->getId(), $publication->getData('citationsRaw'));
         }
      }
   }
}
 
$tool = new CitationsParsingTool(isset($argv) ? $argv : array());
$tool->execute();