ifhub.club/classes/modules/subscribe/Subscribe.class.php

<?php
/*-------------------------------------------------------
*
*   LiveStreet Engine Social Networking
*   Copyright © 2008 Mzhelskiy Maxim
*
*--------------------------------------------------------
*
*   Official site: www.livestreet.ru
*   Contact e-mail: rus.engine@gmail.com
*
*   GNU General Public License, version 2:
*   http://www.gnu.org/licenses/old-licenses/gpl-2.0.html
*
---------------------------------------------------------
*/

/**
 * Модуль Subscribe - подписки пользователей
 *
 */
class ModuleSubscribe extends Module {	
			
	protected $oMapper;
	protected $oUserCurrent;
	/**
	 * Список доступных объектов подписок с параметрами
	 * На данный момент допустим параметр allow_for_guest=>1 - указывает на возможность создавать подписку для гостя
	 *
	 * @var array
	 */
	protected $aTargetTypes=array(
		'topic_new_comment' => array(),
	);
			
	/**
	 * Инициализация
	 *
	 */
	public function Init() {		
		$this->oMapper=Engine::GetMapper(__CLASS__);
		$this->oUserCurrent=$this->User_GetUserCurrent();
	}

	/**
	 * Возвращает список типов объектов для облаты
	 */
	public function GetTargetTypes() {
		return $this->aTargetTypes;
	}

	/**
	 * Добавляет в разрешенные новый тип
	 * @param unknown_type $sTargetType
	 */
	public function AddTargetType($sTargetType,$aParams=array()) {
		if (!array_key_exists($sTargetType,$this->aTargetTypes)) {
			$this->aTargetTypes[$sTargetType]=$aParams;
			return true;
		}
		return false;
	}

	/**
	 * Проверяет разрешен ли данный тип в подписке
	 *
	 * @param $sTargetType
	 * @return bool
	 */
	public function IsAllowTargetType($sTargetType) {
		return in_array($sTargetType,array_keys($this->aTargetTypes));
	}

	/**
	 * Проверка объекта подписки
	 *
	 * @param string $sTargetType
	 * @param int $iTargetId
	 * @param int $iCheckType
	 */
	public function CheckTarget($sTargetType,$iTargetId,$iStatus=null) {
		$sMethod = 'CheckTarget'.func_camelize($sTargetType);
		if (method_exists($this,$sMethod)) {
			return $this->$sMethod($iTargetId,$iStatus);
		}
		return false;
	}

	/**
	 * Возвращает URL страницы с объектом подписки
	 * Актуально при переходе по ссылки с отпиской от рассылки и последующим редиректом
	 *
	 * @param string $sTargetType
	 * @param int $iTargetId
	 */
	public function GetUrlTarget($sTargetType,$iTargetId) {
		$sMethod = 'GetUrlTarget'.func_camelize($sTargetType);
		if (method_exists($this,$sMethod)) {
			return $this->$sMethod($iTargetId);
		}
		return false;
	}

	/**
	 * Проверка на подписку для гостей
	 *
	 * @param $sTargetType
	 * @return bool
	 */
	public function IsAllowTargetForGuest($sTargetType) {
		if ($this->IsAllowTargetType($sTargetType)) {
			if (isset($this->aTargetTypes[$sTargetType]['allow_for_guest']) and $this->aTargetTypes[$sTargetType]['allow_for_guest']) {
				return true;
			}
		}
		return false;
	}

	/**
	 * Добавляет подписку в БД
	 *
	 * @param $oSubscribe
	 * @return ModuleSubscribe_EntitySubscribe | bool
	 */
	public function AddSubscribe($oSubscribe) {
		if ($sId=$this->oMapper->AddSubscribe($oSubscribe)) {
			$oSubscribe->setId($sId);
			return $oSubscribe;
		}
		return false;
	}

	/**
	 * Создает подписку, если уже есть, то возвращает существующую
	 *
	 * @param $sTargetType
	 * @param $sTargetId
	 * @param $sMail
	 * @return ModuleSubscribe_EntitySubscribe
	 */
	public function AddSubscribeSimple($sTargetType,$sTargetId,$sMail) {
		if (!($oSubscribe=$this->Subscribe_GetSubscribeByTargetAndMail($sTargetType,$sTargetId,$sMail))) {
			$oSubscribe=Engine::GetEntity('Subscribe');
			$oSubscribe->setTargetType($sTargetType);
			$oSubscribe->setTargetId($sTargetId);
			$oSubscribe->setMail($sMail);
			$oSubscribe->setDateAdd(date("Y-m-d H:i:s"));
			$oSubscribe->setKey(func_generator(32));
			$oSubscribe->setIp(func_getIp());
			$oSubscribe->setStatus(1);
			$this->Subscribe_AddSubscribe($oSubscribe);
		}
		return $oSubscribe;
	}

	public function UpdateSubscribe($oSubscribe) {
		return $this->oMapper->UpdateSubscribe($oSubscribe);
	}

	/**
	 * Возвращает список подписок по фильтру
	 *
	 * @param $aFilter
	 * @param $aOrder
	 * @param $iCurrPage
	 * @param $iPerPage
	 * @return array
	 */
	public function GetSubscribes($aFilter,$aOrder,$iCurrPage,$iPerPage) {
		return array('collection'=>$this->oMapper->GetSubscribes($aFilter,$aOrder,$iCount,$iCurrPage,$iPerPage),'count'=>$iCount);
	}

	/**
	 * Возвращает подписку по объекту подписки и емайлу
	 *
	 * @param $sTargetType
	 * @param $iTargetId
	 * @param $sMail
	 * @return ModuleSubscribe_EntitySubscribe
	 */
	public function GetSubscribeByTargetAndMail($sTargetType,$iTargetId,$sMail) {
		$aRes=$this->GetSubscribes(array('target_type'=>$sTargetType,'target_id'=>$iTargetId,'mail'=>$sMail),array(),1,1);
		if (isset($aRes['collection'][0])) {
			return $aRes['collection'][0];
		}
		return null;
	}

	/**
	 * Возвращает подписку по ключу
	 *
	 * @param $sKey
	 * @return ModuleSubscribe_EntitySubscribe
	 */
	public function GetSubscribeByKey($sKey) {
		$aRes=$this->GetSubscribes(array('key'=>$sKey),array(),1,1);
		if (isset($aRes['collection'][0])) {
			return $aRes['collection'][0];
		}
		return null;
	}


	/**
	 * Производит отправку писем по подписчикам подписки
	 *
	 * @param $sTargetType	Тип объекта подписки
	 * @param $iTargetId	ID объекта подписки
	 * @param $sTemplate	Имя шаблона письма, например, notify.mail.tpl
	 * @param $sTitle		Заголовок письма
	 * @param array $aParams	Параметра для передачи в шаблон письма
	 * @param array $aExcludeMail	Список емайлов на которые НЕ нужно отправлять
	 */
	public function Send($sTargetType,$iTargetId,$sTemplate,$sTitle,$aParams=array(),$aExcludeMail=array(),$sPluginName=null) {
		$iPage=1;
		$aSubscribes=$this->Subscribe_GetSubscribes(array('target_type'=>$sTargetType,'target_id'=>$iTargetId,'status'=>1,'exclude_mail'=>$aExcludeMail),array(),$iPage,20);
		while ($aSubscribes['collection']) {
			$iPage++;
			foreach ($aSubscribes['collection'] as $oSubscribe) {
				$aParams['sSubscribeKey']=$oSubscribe->getKey();
				$this->Notify_Send(
					$oSubscribe->getMail(),
					$sTemplate,
					$sTitle,
					$aParams,
					$sPluginName
				);
			}
			$aSubscribes=$this->Subscribe_GetSubscribes(array('target_type'=>$sTargetType,'target_id'=>$iTargetId,'status'=>1),array(),$iPage,20);
		}
	}


	/**
	 * Проверка объекта подписки с типом "topic_new_comment"
	 * Название метода формируется автоматически
	 *
	 * @param int $iTargetId
	 * @param int $iStatus
	 */
	public function CheckTargetTopicNewComment($iTargetId,$iStatus) {
		if ($oTopic=$this->Topic_GetTopicById($iTargetId)) {
			/**
			 * Топик может быть в закрытом блоге, поэтому необходимо разрешить подписку только если пользователь в нем состоит
			 * Отписываться разрешаем с любого топика
			 */
			if ($iStatus==1 and $oTopic->getBlog()->getType()=='close') {
				if (!$this->oUserCurrent or !$this->Blog_GetBlogUserByBlogIdAndUserId($oTopic->getBlogId(),$this->oUserCurrent->getId())) {
					return false;
				}
			}
			return true;
		}
		return false;
	}

	/**
	 * Возвращает URL на страницы объекта подписки с типом "topic_new_comment"
	 * Название метода формируется автоматически
	 *
	 * @param $iTargetId
	 * @return bool
	 */
	public function GetUrlTargetTopicNewComment($iTargetId) {
		if ($oTopic=$this->Topic_GetTopicById($iTargetId) and $oTopic->getPublish()) {
			return $oTopic->getUrl();
		}
		return false;
	}
}
?>