D-Net

<?php

defined('_JEXEC') or die('Access denied');

jimport('joomla.application.component.helper');

jimport('joomla.application.component.model');

jimport('joomla.base.object');

jimport('joomla.cache.cache');

jimport('joomla.log.log');

$GLOBALS['THRIFT_ROOT'] = dirname(__FILE__) . DS . 'thrift';

require_once($GLOBALS['THRIFT_ROOT'] . DS . 'Thrift.php');

require_once($GLOBALS['THRIFT_ROOT'] . DS . 'protocol' . DS . 'TBinaryProtocol.php');

require_once($GLOBALS['THRIFT_ROOT'] . DS . 'transport' . DS . 'TSocket.php');

require_once($GLOBALS['THRIFT_ROOT'] . DS . 'transport' . DS . 'TBufferedTransport.php');

require_once($GLOBALS['THRIFT_ROOT'] . DS . 'packages' . DS . 'OpenAIREConnector' . DS . 'OpenAIREConnector.php');

// This model manages statistics.

class OpenAireModelStatistics extends JModelItem {

	const STATISTICS_CACHE_ID = 'statistics';

	const PUBLICATIONS_BY_PROGRAMME_CACHE_ID = 'publications.programme';

	const PUBLICATIONS_BY_SCIENTIFIC_AREA_CACHE_ID = 'publications.scientific.area';

	const PUBLICATIONS_BY_COUNTRY_CACHE_ID = 'publications.country';

	const PUBLICATIONS_BY_INSTITUTION_CACHE_ID = 'publications.institution';

	const CACHE_GROUP = 'openaire.statistics';

	const LOG = 'openaire';

	private $transport;

	private $client;

	private $cache;

	// Construct a new OpenAireModelStatistics.

	// $configuration the configuration to use

	public function __construct($configuration) {

		parent :: __construct($configuration);

		$parameters = JComponentHelper :: getParams('com_openaire');

		$socket = new TSocket($parameters -> get('thriftHost'), intval($parameters -> get('thriftPort')));

		$socket -> setRecvTimeout(intval($parameters -> get('thriftTimeout')));

		$this -> transport = new TBufferedTransport($socket);

		$this -> client = new OpenAIREConnectorClient(new TBinaryProtocol($this -> transport));

		$this -> cache = JCache :: getInstance();

		$this -> transport -> open();

	}

	// Close Thrift transport.

	public function __destruct() {

		$this -> transport -> close();

	}

	// Retrieve statistics using cache if enabled.

	// return statistics (object)

	public function getStatistics() {

/*

		if ($this -> cache -> getCaching()) {

			$statistics = $this -> cache -> get(self :: STATISTICS_CACHE_ID, self :: CACHE_GROUP);

			if ($statistics === NULL) {

				$statistics = $this -> _getStatistics();

				$this -> cache -> store($statistics, self :: STATISTICS_CACHE_ID, self :: CACHE_GROUP);

			}

		} else

*/

			$statistics = $this -> _getStatistics();

		return $statistics;

	}

	// Retrieve publications by access mode using cache if enabled.

	// return publications by access mode (array)

	public function getPublicationsByAccessMode() {

/*

		if ($this -> cache -> getCaching()) {

			$publicationsByAccessMode = $this -> cache -> get(self :: PUBLICATIONS_BY_ACCESS_MODE_CACHE_ID, self :: CACHE_GROUP);

			if ($publications === NULL) {

				$publicationsByAccessMode = $this -> _getPublicationsByAccessMode();

				$this -> cache -> store($publicationsByAccessMode, self :: PUBLICATIONS_BY_ACCESS_MODE_CACHE_ID, self :: CACHE_GROUP);

			}

		} else

*/

			$publicationsByAccessMode = $this -> _getPublicationsByAccessMode();

		return $publicationsByAccessMode;

	}

	// Retrieve publications by programme using cache if enabled.

	// limit the maximum number of programmes to retrieve

	// return publications by programme (array)

	public function getPublicationsByProgramme($limit) {

/*

		if ($this -> cache -> getCaching()) {

			$id = self :: PUBLICATIONS_BY_PROGRAMME_CACHE_ID . '.' . $limit;

			$publicationsByProgramme = $this -> cache -> get($id, self :: CACHE_GROUP);

			if ($publicationsByProgramme === NULL) {

				$publicationsByProgramme = $this -> _getPublicationsByProgramme($limit);

				$this -> cache -> store($publicationsByProgramme, $id, self :: CACHE_GROUP);

			}

		} else

*/

			$publicationsByProgramme = $this -> _getPublicationsByProgramme($limit);

		return $publicationsByProgramme;

	}

	// Retrieve publications by scientific area using cache if enabled.

	// limit the maximum number of scientific areas to retrieve

	// return publications by scientific area (array)

	public function getPublicationsByScientificArea($limit) {

/*

		if ($this -> cache -> getCaching()) {

			$id = self :: PUBLICATIONS_BY_SCIENTIFIC_AREA_CACHE_ID . '.' . $limit;

			$publicationsByScientificArea = $this -> cache -> get($id, self :: CACHE_GROUP);

			if ($publicationsByScientificArea === NULL) {

				$publicationsByScientificArea = $this -> _getPublicationsByScientificArea($limit);

				$this -> cache -> store($publicationsByScientificArea, $limit, self :: CACHE_GROUP);

			}

		} else

*/

			$publicationsByScientificArea = $this -> _getPublicationsByScientificArea($limit);

		return $publicationsByScientificArea;

	}

	// Retrieve publications by country using cache if enabled.

	// limit the maximum number of countries to retrieve

	// return publications by country (array)

	public function getPublicationsByCountry($limit) {

/*

		if ($this -> cache -> getCaching()) {

			$id = self :: PUBLICATIONS_BY_COUNTRY_CACHE_ID . '.' . $limit;

			$publicationsByCountry = $this -> cache -> get($id, self :: CACHE_GROUP);

			if ($publicationsByCountry === NULL) {

				$publicationsByCountry = $this -> _getPublicationsByCountry($limit);

				$this -> cache -> store($publicationsByCountry, $id, self :: CACHE_GROUP);

			}

		} else

*/

			$publicationsByCountry = $this -> _getPublicationsByCountry($limit);

		return $publicationsByCountry;

	}

	// Retrieve publications by institution using cache if enabled.

	// limit the maximum number of institutions to retrieve

	// return publications by institution (array)

	public function getPublicationsByInstitution($limit) {

/*

		if ($this -> cache -> getCaching()) {

			$id = self :: PUBLICATIONS_BY_INSTITUTION_CACHE_ID . '.' . $limit;

			$publicationsByInstitution = $this -> cache -> get($id, self :: CACHE_GROUP);

			if ($publicationsByInstitution === NULL) {

				$publicationsByInstitution = $this -> _getPublicationsByInstitution($limit);

				$this -> cache -> store($publicationsByInstitution, $id, self :: CACHE_GROUP);

			}

		} else

*/

			$publicationsByInstitution = $this -> _getPublicationsByInstitution($limit);

		return $publicationsByInstitution;

	}

	// Retrieve statistics.

	// return the statistics (object) or NULL if any errors occur

	private function _getStatistics() {

		try {

			$time = microtime(TRUE);

			$statistics = $this -> client -> getStatistics();

			JLog :: add('Retrieved statistics in ' . (microtime(TRUE) - $time) . ' s', JLog :: INFO, self :: LOG);

			return $statistics;

		} catch (Exception $e) {

			JLog :: add('Error retrieving statistics: ' . $e -> getMessage(), JLog :: ERROR, self :: LOG);

			return NULL;

		}

	}

	// Retrieve publications by access mode.

	// return publications by access mode (array) or NULL if any errors occur

	private function _getPublicationsByAccessMode() {

		try {

			$time = microtime(TRUE);

			$publicationsByAccessMode = $this -> client -> getPublicationsByAccessMode();

			JLog :: add('Retrieved ' . count($publicationsByAccessMode) . ' publications by access mode entries in ' . (microtime(TRUE) - $time) . ' s', JLog :: INFO, self :: LOG);

			return $publicationsByAccessMode;

		} catch (Exception $e) {

			JLog :: add('Error retrieving publications by acces mode: ' . $e -> getMessage());

			return NULL;

		}

	}

	// Retrieve publications by programme.

	// limit the maximum number of programmes to retrieve

	// return publications by programme (array) or NULL if any errors occur

	private function _getPublicationsByProgramme($limit) {

		try {

			$time = microtime(TRUE);

			$publicationsByProgramme = $this -> client -> getPublicationsByProgramme($limit);

			JLog :: add('Retrieved ' . count($publicationsByProgramme) . ' publications by programme entries in ' . (microtime(TRUE) - $time) . ' s (limit: ' . $limit . ')', JLog :: INFO, self :: LOG);

			return $publicationsByProgramme;

		} catch (Exception $e) {

			JLog :: add('Error retrieving publications by programme (limit: ' . $limit . '): ' . $e -> getMessage(), JLog :: ERROR, self :: LOG);

			return NULL;

		}

	}

	// Retrieve publications by scientific area.

	// limit the maximum number of scientific areas to retrieve

	// return publications by scientific area (array) or NULL if any errors occur

	private function _getPublicationsByScientificArea($limit) {

		try {

			$time = microtime(TRUE);

			$publicationsByScientificArea = $this -> client -> getPublicationsByScientificArea($limit);

			JLog :: add('Retrieved ' . count($publicationsByScientificArea) . ' publications by scientific area entries in ' . (microtime(TRUE) - $time) . ' s (limit: ' . $limit . ')', JLog :: INFO, self :: LOG);

			return $publicationsByScientificArea;

		} catch (Exception $e) {

			JLog :: add('Error retrieving publications by scientific area (limit: ' . $limit . '): ' . $e -> getMessage(), JLog :: ERROR, self :: LOG);

			return NULL;

		}

	}

	// Retrieve publications by country.

	// limit the maximum number of countries to retrieve

	// return publications by country (array) or NULL if any errors occur

	private function _getPublicationsByCountry($limit) {

		try {

			$time = microtime(TRUE);

			$publicationsByCountry = $this -> client -> getPublicationsByCountry($limit);

			JLog :: add('Retrieved ' . count($publicationsByCountry) . ' publications by country entries in ' . (microtime(TRUE) - $time) . ' s (limit: ' . $limit . ')', JLog :: INFO, self :: LOG);

			return $publicationsByCountry;

		} catch (Exception $e) {

			JLog :: add('Error retrieving publications by country (limit: ' . $limit . '): ' . $e -> getMessage(), JLog :: ERROR, self :: LOG);

			return NULL;

		}

	}

	// Retrieve publications by institution.

	// limit the maximum number of institutions to retrieve

	// return publications by institution (array) or NULL if any errors occur

	private function _getPublicationsByInstitution($limit) {

		try {

			$time = microtime(TRUE);

			$publicationsByInstitution = $this -> client -> getPublicationsByInstitution($limit);

			JLog :: add('Retrieved ' . count($publicationsByInstitution) . ' publications by institution entries in ' . (microtime(TRUE) - $time) . ' s (limit: ' . $limit . ')', JLog :: INFO, self :: LOG);

			return $publicationsByInstitution;

		} catch (Exception $e) {

			JLog :: add('Error retrieving publications by institution (limit: ' . $limit . '): ' . $e -> getMessage(), JLog :: ERROR, self :: LOG);

			return NULL;

		}

	}

}