Notification.php

<?php
/**
 * Notifications Model
 *
 * @author Noriko Arai <arai@nii.ac.jp>
 * @author Shohei Nakajima <nakajimashouhei@gmail.com>
 * @link http://www.netcommons.org NetCommons Project
 * @license http://www.netcommons.org/license.txt NetCommons License
 * @copyright Copyright 2014, NetCommons Project
 */

App::uses('NotificationsAppModel', 'Notifications.Model');

/**
 * Notification Model
 *
 * @author Shohei Nakajima <nakajimashouhei@gmail.com>
 * @package NetCommons\Notifications\Model
 */
class Notification extends NotificationsAppModel {

/**
 * Cache time
 *
 * @var string
 */
	const CACHE_TIME = 'PT1H';

/**
 * Max row
 *
 * @var string
 */
	const MAX_ROW = 20;

/**
 * Notification url
 *
 * @var string
 */
	const NOTIFICATION_PING_URL = 'www.netcommons.org';

/**
 * Notification url
 *
 * @var string
 */
	const NOTIFICATION_URL = 'https://www.netcommons.org/topics/topics/index.xml?frame_id=12';

/**
 * PING
 *
 * @param string|null $url pingのURL(テストで使用する)
 * @return mixed fsockopenの結果
 */
	public function ping($url = null) {
		//サイトの生死確認
		$errno = 0;
		$errstr = null;
		if (! $url) {
			$url = self::NOTIFICATION_PING_URL;
		}

		CakeLog::info('Execute ping ' . $url);
		try {
			$resource = fsockopen($url, 80, $errno, $errstr, 3);
		} catch (Exception $ex) {
			$resource = false;
			CakeLog::error($ex);
		}

		if (! $resource) {
			CakeLog::info('Failure ping ' . $url);
			$result = false;
		} else {
			fclose($resource);
			$result = true;
			CakeLog::info('Success ping ' . $url);
		}

		return $result;
	}

/**
 * Serialize to array data from xml
 *
 * @param string|null $url XMLのURL(テストで使用する)
 * @return array Xml serialize array data
 * @SuppressWarnings(PHPMD.CyclomaticComplexity)
 */
	public function serialize($url = null) {
		if (! $url) {
			$url = self::NOTIFICATION_URL;
		}
		$xmlData = Xml::toArray(Xml::build($url));

		// rssの種類によってタグ名が異なる
		if (isset($xmlData['feed'])) {
			$items = Hash::get($xmlData, 'feed.entry');
			$dateKey = 'published';
			$linkKey = 'link.@href';
			$summaryKey = 'summary';
		} elseif (Hash::get($xmlData, 'rss.@version') === '2.0') {
			$items = Hash::get($xmlData, 'rss.channel.item');
			$dateKey = 'pubDate';
			$linkKey = 'link';
			$summaryKey = 'description';
		} elseif (isset($xmlData['RDF'])) {
			$items = Hash::get($xmlData, 'RDF.item');
			$dateKey = 'dc:date';
			$linkKey = 'link';
			$summaryKey = 'description';
		} else {
			return false;
		}
		if (! isset($items[0]) && is_array($items)) {
			$items = array($items);
		}

		$data = array();
		foreach ($items as $item) {
			if (! $item['title']) {
				continue;
			}
			$date = new DateTime($item[$dateKey]);
			$summary = Hash::get($item, $summaryKey);
			$data[] = array(
				'title' => $item['title'],
				'link' => Hash::get($item, $linkKey),
				'summary' => $summary ? strip_tags($summary) : '',
				'last_updated' => $date->format('Y-m-d H:i:s'),
				'key' => Security::hash(Hash::get($item, $linkKey), 'md5')
			);
		}
		return $data;
	}

/**
 * Update notifications
 *
 * @param array $data received post data
 * @return bool true on success, exception on error
 * @throws InternalErrorException
 */
	public function updateNotifications($data) {
		if (! $data['Notification']) {
			return true;
		}
		//トランザクションBegin
		$this->begin();

		//Notificationsのvalidate
		if (! $this->validateMany($data['Notification'])) {
			$this->rollback();
			return false;
		}

		try {
			//既存データの削除
			$conditions = Hash::extract($data, 'Notification.{n}.Notification.key');
			if (! $this->deleteAll(array($this->alias . '.key' => $conditions), true, false)) {
				throw new InternalErrorException(__d('net_commons', 'Internal Server Error'));
			}

			//Notificationsの登録
			if (! $this->saveMany($data['Notification'], array('validate' => false))) {
				throw new InternalErrorException(__d('net_commons', 'Internal Server Error'));
			}

			$this->commit();

		} catch (Exception $ex) {
			$this->rollback($ex);
		}

		return true;
	}

/**
 * Valide cache time
 *
 * @return bool True on valid time, false on no valid
 */
	public function validCacheTime() {
		$date = new DateTime();
		$now = $date->format('Y-m-d H:i:s');

		$notification = $this->find('first', array(
			'recursive' => -1,
			'fields' => 'modified',
			'order' => array('modified' => 'desc'),
		));
		if (! $notification) {
			return false;
		}

		$date = new DateTime($notification['Notification']['modified']);
		$date->add(new DateInterval(self::CACHE_TIME));
		$modified = $date->format('Y-m-d H:i:s');

		if ($now < $modified) {
			return true;
		}
		return false;
	}

}