mirror of
https://github.com/Oreolek/ifhub.club.git
synced 2024-07-05 07:54:24 +03:00
498 lines
14 KiB
PHP
498 lines
14 KiB
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
|
||
*
|
||
---------------------------------------------------------
|
||
*/
|
||
|
||
/**
|
||
* Модуль потока событий на сайте
|
||
*
|
||
*/
|
||
class ModuleStream extends Module {
|
||
|
||
protected $oMapper = null;
|
||
|
||
/**
|
||
* Список дефолтных типов событий, они добавляются каждому пользователю при регистрации
|
||
*
|
||
* @var array
|
||
*/
|
||
protected $aEventDefaultTypes=array(
|
||
'add_wall','add_topic','add_comment','add_blog','vote_topic','add_friend'
|
||
);
|
||
/**
|
||
* Типы событий
|
||
*
|
||
* @var array
|
||
*/
|
||
protected $aEventTypes = array(
|
||
'add_wall' => array('related' => 'wall','unique'=>true),
|
||
'add_topic' => array('related' => 'topic','unique'=>true),
|
||
'add_comment' => array('related' => 'comment','unique'=>true),
|
||
'add_blog' => array('related' => 'blog','unique'=>true),
|
||
'vote_topic' => array('related' => 'topic'),
|
||
'vote_comment' => array('related' => 'comment'),
|
||
'vote_blog' => array('related' => 'blog'),
|
||
'vote_user' => array('related' => 'user'),
|
||
'add_friend' => array('related' => 'user','unique_user'=>true),
|
||
'join_blog' => array('related' => 'blog','unique_user'=>true)
|
||
);
|
||
|
||
public function Init() {
|
||
$this->oMapper=Engine::GetMapper(__CLASS__);
|
||
}
|
||
|
||
/**
|
||
* Возвращает все типы событий
|
||
*
|
||
* @return unknown
|
||
*/
|
||
public function getEventTypes() {
|
||
return $this->aEventTypes;
|
||
}
|
||
|
||
/**
|
||
* Возвращает типы событий с учетом фильтра(доступности)
|
||
*
|
||
* @param null $aTypes
|
||
* @return null|unknown
|
||
*/
|
||
public function getEventTypesFilter($aTypes=null) {
|
||
if (is_null($aTypes)) {
|
||
$aTypes=array_keys($this->getEventTypes());
|
||
}
|
||
if (Config::Get('module.stream.disable_vote_events')) {
|
||
foreach ($aTypes as $i => $sType) {
|
||
if (substr($sType, 0, 4) == 'vote') {
|
||
unset ($aTypes[$i]);
|
||
}
|
||
}
|
||
}
|
||
return $aTypes;
|
||
}
|
||
/**
|
||
* Добавляет новый тип события, метод для расширения списка событий плагинами
|
||
*
|
||
* @param unknown_type $sName
|
||
* @param unknown_type $aParams
|
||
* @return unknown
|
||
*/
|
||
public function AddEventType($sName,$aParams) {
|
||
if (!array_key_exists($sName,$this->aEventTypes)) {
|
||
$this->aEventTypes[$sName]=$aParams;
|
||
return true;
|
||
}
|
||
return false;
|
||
}
|
||
/**
|
||
* Проверка допустимого типа событий
|
||
*
|
||
* @param string $sType
|
||
*/
|
||
public function IsAllowEventType($sType) {
|
||
return array_key_exists($sType,$this->aEventTypes);
|
||
}
|
||
/**
|
||
* Добавление события в БД
|
||
*
|
||
* @param unknown_type $oObject
|
||
* @return unknown
|
||
*/
|
||
public function AddEvent($oObject) {
|
||
if ($iId=$this->oMapper->AddEvent($oObject)) {
|
||
$oObject->setId($iId);
|
||
return $oObject;
|
||
}
|
||
return false;
|
||
}
|
||
/**
|
||
* Обновление события
|
||
*
|
||
* @param unknown_type $oObject
|
||
* @return unknown
|
||
*/
|
||
public function UpdateEvent($oObject) {
|
||
return $this->oMapper->UpdateEvent($oObject);
|
||
}
|
||
/**
|
||
* Получает событие по типу и его ID
|
||
*
|
||
* @param unknown_type $sEventType
|
||
* @param unknown_type $iTargetId
|
||
* @return unknown
|
||
*/
|
||
public function GetEventByTarget($sEventType, $iTargetId, $iUserId=null) {
|
||
return $this->oMapper->GetEventByTarget($sEventType, $iTargetId, $iUserId);
|
||
}
|
||
/**
|
||
* Запись события в ленту
|
||
* @param type $oUser
|
||
* @param type $iEventType
|
||
* @param type $iTargetId
|
||
*/
|
||
public function Write($iUserId, $sEventType, $iTargetId, $iPublish=1) {
|
||
if (!$this->IsAllowEventType($sEventType)) {
|
||
return false;
|
||
}
|
||
$aParams=$this->aEventTypes[$sEventType];
|
||
if (isset($aParams['unique']) and $aParams['unique']) {
|
||
/**
|
||
* Проверяем на уникальность
|
||
*/
|
||
if ($oEvent=$this->GetEventByTarget($sEventType, $iTargetId)) {
|
||
/**
|
||
* Событие уже было
|
||
*/
|
||
if ($oEvent->getPublish()!=$iPublish) {
|
||
$oEvent->setPublish($iPublish);
|
||
$this->UpdateEvent($oEvent);
|
||
}
|
||
return true;
|
||
}
|
||
}
|
||
if (isset($aParams['unique_user']) and $aParams['unique_user']) {
|
||
/**
|
||
* Проверяем на уникальность для конкретного пользователя
|
||
*/
|
||
if ($oEvent=$this->GetEventByTarget($sEventType, $iTargetId, $iUserId)) {
|
||
/**
|
||
* Событие уже было
|
||
*/
|
||
if ($oEvent->getPublish()!=$iPublish) {
|
||
$oEvent->setPublish($iPublish);
|
||
$this->UpdateEvent($oEvent);
|
||
}
|
||
return true;
|
||
}
|
||
}
|
||
|
||
if ($iPublish) {
|
||
/**
|
||
* Создаем новое событие
|
||
*/
|
||
$oEvent=Engine::GetEntity('Stream_Event');
|
||
$oEvent->setEventType($sEventType);
|
||
$oEvent->setUserId($iUserId);
|
||
$oEvent->setTargetId($iTargetId);
|
||
$oEvent->setDateAdded(date("Y-m-d H:i:s"));
|
||
$oEvent->setPublish($iPublish);
|
||
$this->AddEvent($oEvent);
|
||
}
|
||
return true;
|
||
}
|
||
/**
|
||
* Чтение потока пользователя
|
||
*
|
||
* @param int $iCount
|
||
* @param int $iFromId
|
||
* @param int $iUserId
|
||
* @return array
|
||
*/
|
||
public function Read($iCount=null,$iFromId=null,$iUserId=null) {
|
||
if (!$iUserId) {
|
||
if ($this->User_getUserCurrent()) {
|
||
$iUserId=$this->User_getUserCurrent()->getId();
|
||
} else {
|
||
return array();
|
||
}
|
||
}
|
||
/**
|
||
* Получаем типы событий
|
||
*/
|
||
$aEventTypes = $this->getTypesList($iUserId);
|
||
/**
|
||
* Получаем список тех на кого подписан
|
||
*/
|
||
$aUsersList = $this->getUsersList($iUserId);
|
||
|
||
return $this->ReadEvents($aEventTypes,$aUsersList,$iCount,$iFromId);
|
||
}
|
||
|
||
/**
|
||
* Чтение всей активности на сайте
|
||
*
|
||
* @param int $iCount
|
||
* @param int $iFromId
|
||
* @return array
|
||
*/
|
||
public function ReadAll($iCount=null,$iFromId=null) {
|
||
/**
|
||
* Получаем типы событий
|
||
*/
|
||
$aEventTypes=array_keys($this->getEventTypes());
|
||
|
||
return $this->ReadEvents($aEventTypes,null,$iCount,$iFromId);
|
||
}
|
||
/**
|
||
* Чтение активности конкретного пользователя
|
||
*
|
||
* @param int $iCount
|
||
* @param int $iUserId
|
||
* @return array
|
||
*/
|
||
public function ReadByUserId($iUserId,$iCount=null,$iFromId=null) {
|
||
/**
|
||
* Получаем типы событий
|
||
*/
|
||
$aEventTypes=array_keys($this->getEventTypes());
|
||
/**
|
||
* Получаем список тех на кого подписан
|
||
*/
|
||
$aUsersList = array($iUserId);
|
||
|
||
return $this->ReadEvents($aEventTypes,$aUsersList,$iCount,$iFromId);
|
||
}
|
||
|
||
/**
|
||
* Количество событий конкретного пользователя
|
||
*
|
||
* @param $iUserId
|
||
* @return int
|
||
*/
|
||
public function GetCountByUserId($iUserId) {
|
||
/**
|
||
* Получаем типы событий
|
||
*/
|
||
$aEventTypes=$this->getEventTypesFilter();
|
||
if (!count($aEventTypes)) return 0;
|
||
|
||
return $this->oMapper->GetCount($aEventTypes, $iUserId);
|
||
}
|
||
|
||
/**
|
||
* Количество событий на которые подписан пользователь
|
||
*
|
||
* @param $iUserId
|
||
* @return int
|
||
*/
|
||
public function GetCountByReaderId($iUserId) {
|
||
/**
|
||
* Получаем типы событий
|
||
*/
|
||
$aEventTypes=$this->getEventTypesFilter($this->getTypesList($iUserId));
|
||
/**
|
||
* Получаем список тех на кого подписан
|
||
*/
|
||
$aUsersList = $this->getUsersList($iUserId);
|
||
if (!count($aEventTypes)) return 0;
|
||
|
||
return $this->oMapper->GetCount($aEventTypes, $aUsersList);
|
||
}
|
||
|
||
/**
|
||
* Количество событий на всем сайте
|
||
*
|
||
* @return int
|
||
*/
|
||
public function GetCountAll() {
|
||
/**
|
||
* Получаем типы событий
|
||
*/
|
||
$aEventTypes=$this->getEventTypesFilter();
|
||
if (!count($aEventTypes)) return 0;
|
||
|
||
return $this->oMapper->GetCount($aEventTypes, null);
|
||
}
|
||
|
||
public function GetCount($aEventTypes, $aUserId=null) {
|
||
return $this->oMapper->GetCount($aEventTypes, $aUserId);
|
||
}
|
||
/**
|
||
* @param array $aEventTypes
|
||
* @param array | null $aUsersList
|
||
* @param int $iCount
|
||
* @param int $iFromId
|
||
* @return array
|
||
*/
|
||
public function ReadEvents($aEventTypes,$aUsersList,$iCount=null,$iFromId=null) {
|
||
if (!is_null($aUsersList) and !count($aUsersList)) {
|
||
return array();
|
||
}
|
||
if (!$iCount) $iCount = Config::Get('module.stream.count_default');
|
||
|
||
$aEventTypes=$this->getEventTypesFilter($aEventTypes);
|
||
if (!count($aEventTypes)) return array();
|
||
|
||
/**
|
||
* Получаем список событий
|
||
*/
|
||
$aEvents = $this->oMapper->Read($aEventTypes, $aUsersList, $iCount, $iFromId);
|
||
/**
|
||
* Составляем список объектов для загрузки
|
||
*/
|
||
$aNeedObjects=array();
|
||
foreach ($aEvents as $oEvent) {
|
||
if (isset($this->aEventTypes[$oEvent->getEventType()]['related'])) {
|
||
$aNeedObjects[$this->aEventTypes[$oEvent->getEventType()]['related']][]=$oEvent->getTargetId();
|
||
}
|
||
$aNeedObjects['user'][]=$oEvent->getUserId();
|
||
}
|
||
/**
|
||
* Получаем объекты
|
||
*/
|
||
$aObjects=array();
|
||
foreach ($aNeedObjects as $sType => $aListId) {
|
||
if (count($aListId)) {
|
||
$aListId=array_unique($aListId);
|
||
$sMethod = 'loadRelated' . ucfirst($sType);
|
||
if (method_exists($this, $sMethod)) {
|
||
if ($aRes=$this->$sMethod($aListId)) {
|
||
foreach ($aRes as $oObject) {
|
||
$aObjects[$sType][$oObject->getId()]=$oObject;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
/**
|
||
* Формируем результирующий поток
|
||
*/
|
||
foreach ($aEvents as $key => $oEvent) {
|
||
/**
|
||
* Жестко вытаскиваем автора события
|
||
*/
|
||
if (isset($aObjects['user'][$oEvent->getUserId()])) {
|
||
$oEvent->setUser($aObjects['user'][$oEvent->getUserId()]);
|
||
/**
|
||
* Аттачим объекты
|
||
*/
|
||
if (isset($this->aEventTypes[$oEvent->getEventType()]['related'])) {
|
||
$sTypeObject=$this->aEventTypes[$oEvent->getEventType()]['related'];
|
||
if (isset($aObjects[$sTypeObject][$oEvent->getTargetId()])) {
|
||
$oEvent->setTarget($aObjects[$sTypeObject][$oEvent->getTargetId()]);
|
||
} else {
|
||
unset($aEvents[$key]);
|
||
}
|
||
} else {
|
||
unset($aEvents[$key]);
|
||
}
|
||
} else {
|
||
unset($aEvents[$key]);
|
||
}
|
||
}
|
||
return $aEvents;
|
||
}
|
||
|
||
/**
|
||
* Получение типов событий, на которые подписан пользователь
|
||
* @param type $iUserId
|
||
* @return type
|
||
*/
|
||
public function getTypesList($iUserId) {
|
||
return $this->oMapper->getTypesList($iUserId);
|
||
}
|
||
/**
|
||
* Получение списка id пользователей, на которых подписан пользователь
|
||
* @return type
|
||
*/
|
||
protected function getUsersList($iUserId) {
|
||
return $this->oMapper->getUserSubscribes($iUserId);
|
||
}
|
||
/**
|
||
* Получение списка пользователей, на которых подписан пользователь
|
||
* @param type $iUserId
|
||
* @return type
|
||
*/
|
||
public function getUserSubscribes($iUserId) {
|
||
$aIds = $this->oMapper->getUserSubscribes($iUserId);
|
||
return $this->User_GetUsersAdditionalData($aIds);
|
||
}
|
||
/**
|
||
* Редактирование списка событий, на которые подписан юзер
|
||
* @param int $iUserId
|
||
* @param string $sType
|
||
* @return type
|
||
*/
|
||
public function switchUserEventType($iUserId, $sType) {
|
||
if ($this->IsAllowEventType($sType)) {
|
||
return $this->oMapper->switchUserEventType($iUserId, $sType);
|
||
}
|
||
return false;
|
||
}
|
||
/**
|
||
* Переключает дефолтный список типов событий у пользователя
|
||
*
|
||
* @param int $iUserId
|
||
*/
|
||
public function switchUserEventDefaultTypes($iUserId) {
|
||
foreach($this->aEventDefaultTypes as $sType) {
|
||
$this->switchUserEventType($iUserId,$sType);
|
||
}
|
||
}
|
||
/**
|
||
* Подписать пользователя
|
||
* @param type $iUserId Id подписываемого пользователя
|
||
* @param type $iSubscribeType Тип подписки (см. константы класса)
|
||
* @param type $iTargetId Id цели подписки
|
||
*/
|
||
public function subscribeUser($iUserId, $iTargetUserId) {
|
||
return $this->oMapper->subscribeUser($iUserId, $iTargetUserId);
|
||
}
|
||
/**
|
||
* Отписать пользователя
|
||
* @param type $iUserId Id подписываемого пользователя
|
||
* @param type $iSubscribeType Тип подписки (см. константы класса)
|
||
* @param type $iTargetId Id цели подписки
|
||
*/
|
||
public function unsubscribeUser($iUserId, $iTargetUserId) {
|
||
return $this->oMapper->unsubscribeUser($iUserId, $iTargetUserId);
|
||
}
|
||
|
||
/**
|
||
* Получает список записей на стене
|
||
*
|
||
* @param unknown_type $aIds
|
||
* @return unknown
|
||
*/
|
||
protected function loadRelatedWall($aIds) {
|
||
return $this->Wall_GetWallAdditionalData($aIds);
|
||
}
|
||
/**
|
||
* Получает список топиков
|
||
*
|
||
* @param unknown_type $aIds
|
||
* @return unknown
|
||
*/
|
||
protected function loadRelatedTopic($aIds) {
|
||
return $this->Topic_GetTopicsAdditionalData($aIds);
|
||
}
|
||
/**
|
||
* Получает список блогов
|
||
*
|
||
* @param unknown_type $aIds
|
||
* @return unknown
|
||
*/
|
||
protected function loadRelatedBlog($aIds) {
|
||
return $this->Blog_GetBlogsAdditionalData($aIds);
|
||
}
|
||
/**
|
||
* Получает список комментариев
|
||
*
|
||
* @param unknown_type $aIds
|
||
* @return unknown
|
||
*/
|
||
protected function loadRelatedComment($aIds) {
|
||
return $this->Comment_GetCommentsAdditionalData($aIds);
|
||
|
||
}
|
||
/**
|
||
* Получает список пользователей
|
||
*
|
||
* @param unknown_type $aIds
|
||
* @return unknown
|
||
*/
|
||
protected function loadRelatedUser($aIds) {
|
||
return $this->User_GetUsersAdditionalData($aIds);
|
||
}
|
||
} |