2009-08-22 00:01:09 +03:00
|
|
|
|
<?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
|
|
|
|
|
*
|
|
|
|
|
---------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
set_include_path(get_include_path().PATH_SEPARATOR.dirname(__FILE__));
|
|
|
|
|
require_once('mapper/Favourite.mapper.class.php');
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Модуль для работы с голосованиями
|
|
|
|
|
*
|
|
|
|
|
*/
|
|
|
|
|
class LsFavourite extends Module {
|
|
|
|
|
protected $oMapper;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Инициализация
|
|
|
|
|
*
|
|
|
|
|
*/
|
|
|
|
|
public function Init() {
|
|
|
|
|
$this->oMapper=new Mapper_Favourite($this->Database_GetConnect());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Получает информацию о том, найден ли таргет в избранном или нет
|
|
|
|
|
*
|
|
|
|
|
* @param string $sTargetId
|
|
|
|
|
* @param string $sTargetType
|
|
|
|
|
* @param string $sUserId
|
|
|
|
|
* @return FavouriteEntity_Favourite|null
|
|
|
|
|
*/
|
|
|
|
|
public function GetFavourite($sTargetId,$sTargetType,$sUserId) {
|
|
|
|
|
$data=$this->GetFavouritesByArray($sTargetId,$sTargetType,$sUserId);
|
|
|
|
|
return (isset($data[$sTargetId]))
|
|
|
|
|
? $data[$sTargetId]
|
|
|
|
|
: null;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Получить список избранного по списку айдишников
|
|
|
|
|
*
|
|
|
|
|
* @param array $aTargetId
|
|
|
|
|
* @param string $sTargetType
|
|
|
|
|
* @param string $sUserId
|
|
|
|
|
* @return array
|
|
|
|
|
*/
|
|
|
|
|
public function GetFavouritesByArray($aTargetId,$sTargetType,$sUserId) {
|
|
|
|
|
if (!$aTargetId) {
|
|
|
|
|
return array();
|
2009-08-24 15:23:52 +03:00
|
|
|
|
}
|
2009-10-10 22:13:14 +03:00
|
|
|
|
if (Config::Get('sys.cache.solid')) {
|
2009-08-22 00:01:09 +03:00
|
|
|
|
return $this->GetFavouritesByArraySolid($aTargetId,$sTargetType,$sUserId);
|
|
|
|
|
}
|
|
|
|
|
if (!is_array($aTargetId)) {
|
|
|
|
|
$aTargetId=array($aTargetId);
|
|
|
|
|
}
|
|
|
|
|
$aTargetId=array_unique($aTargetId);
|
|
|
|
|
$aFavourite=array();
|
|
|
|
|
$aIdNotNeedQuery=array();
|
|
|
|
|
/**
|
|
|
|
|
* Делаем мульти-запрос к кешу
|
|
|
|
|
*/
|
|
|
|
|
$aCacheKeys=func_build_cache_keys($aTargetId,"favourite_{$sTargetType}_",'_'.$sUserId);
|
|
|
|
|
if (false !== ($data = $this->Cache_Get($aCacheKeys))) {
|
|
|
|
|
/**
|
|
|
|
|
* проверяем что досталось из кеша
|
|
|
|
|
*/
|
|
|
|
|
foreach ($aCacheKeys as $sValue => $sKey ) {
|
|
|
|
|
if (array_key_exists($sKey,$data)) {
|
|
|
|
|
if ($data[$sKey]) {
|
|
|
|
|
$aFavourite[$data[$sKey]->getTargetId()]=$data[$sKey];
|
|
|
|
|
} else {
|
|
|
|
|
$aIdNotNeedQuery[]=$sValue;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
/**
|
2009-08-22 00:45:31 +03:00
|
|
|
|
* Смотрим чего не было в кеше и делаем запрос в БД
|
2009-08-22 00:01:09 +03:00
|
|
|
|
*/
|
|
|
|
|
$aIdNeedQuery=array_diff($aTargetId,array_keys($aFavourite));
|
|
|
|
|
$aIdNeedQuery=array_diff($aIdNeedQuery,$aIdNotNeedQuery);
|
|
|
|
|
$aIdNeedStore=$aIdNeedQuery;
|
|
|
|
|
if ($data = $this->oMapper->GetFavouriteByArray($aIdNeedQuery,$sTargetType,$sUserId)) {
|
|
|
|
|
foreach ($data as $oFavourite) {
|
|
|
|
|
/**
|
|
|
|
|
* Добавляем к результату и сохраняем в кеш
|
|
|
|
|
*/
|
|
|
|
|
$aFavourite[$oFavourite->getTargetId()]=$oFavourite;
|
2009-08-22 00:45:31 +03:00
|
|
|
|
$this->Cache_Set($oFavourite, "favourite_{$oFavourite->getTargetType()}_{$oFavourite->getTargetId()}_{$sUserId}", array(), 60*60*24*7);
|
2009-08-22 00:01:09 +03:00
|
|
|
|
$aIdNeedStore=array_diff($aIdNeedStore,array($oFavourite->getTargetId()));
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
/**
|
|
|
|
|
* Сохраняем в кеш запросы не вернувшие результата
|
|
|
|
|
*/
|
|
|
|
|
foreach ($aIdNeedStore as $sId) {
|
|
|
|
|
$this->Cache_Set(null, "favourite_{$sTargetType}_{$sId}_{$sUserId}", array(), 60*60*24*7);
|
|
|
|
|
}
|
|
|
|
|
/**
|
|
|
|
|
* Сортируем результат согласно входящему массиву
|
|
|
|
|
*/
|
|
|
|
|
$aFavourite=func_array_sort_by_keys($aFavourite,$aTargetId);
|
|
|
|
|
return $aFavourite;
|
|
|
|
|
}
|
|
|
|
|
/**
|
2009-08-22 00:45:31 +03:00
|
|
|
|
* Получить список избранного по списку айдишников, но используя единый кеш
|
2009-08-22 00:01:09 +03:00
|
|
|
|
*
|
|
|
|
|
* @param array $aTargetId
|
|
|
|
|
* @param string $sTargetType
|
|
|
|
|
* @param string $sUserId
|
|
|
|
|
* @return array
|
|
|
|
|
*/
|
|
|
|
|
public function GetFavouritesByArraySolid($aTargetId,$sTargetType,$sUserId) {
|
|
|
|
|
if (!is_array($aTargetId)) {
|
|
|
|
|
$aTargetId=array($aTargetId);
|
|
|
|
|
}
|
|
|
|
|
$aTargetId=array_unique($aTargetId);
|
|
|
|
|
$aFavourites=array();
|
2009-08-24 15:23:52 +03:00
|
|
|
|
$s=join(',',$aTargetId);
|
2009-08-22 00:01:09 +03:00
|
|
|
|
if (false === ($data = $this->Cache_Get("favourite_{$sTargetType}_{$sUserId}_id_{$s}"))) {
|
|
|
|
|
$data = $this->oMapper->GetFavouritesByArray($aTargetId,$sTargetType,$sUserId);
|
|
|
|
|
foreach ($data as $oFavourite) {
|
|
|
|
|
$aFavourites[$oFavourite->getTargetId()]=$oFavourite;
|
|
|
|
|
}
|
2009-08-22 00:45:31 +03:00
|
|
|
|
$this->Cache_Set($aFavourites, "favourite_{$sTargetType}_{$sUserId}_id_{$s}", array("favourite_{$sTargetType}_change_user_{$sUserId}"), 60*60*24*1);
|
2009-08-22 00:01:09 +03:00
|
|
|
|
return $aFavourites;
|
|
|
|
|
}
|
|
|
|
|
return $data;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Получает список таргеов из избранного
|
|
|
|
|
*
|
|
|
|
|
* @param string $sUserId
|
|
|
|
|
* @param string $sTargetType
|
|
|
|
|
* @param int $iCount
|
|
|
|
|
* @param int $iCurrPage
|
|
|
|
|
* @param int $iPerPage
|
|
|
|
|
* @return array
|
|
|
|
|
*/
|
2009-10-15 02:34:03 +03:00
|
|
|
|
public function GetFavouritesByUserId($sUserId,$sTargetType,$iCurrPage,$iPerPage,$aExcludeTarget=array()) {
|
2009-09-18 23:36:07 +03:00
|
|
|
|
$s=serialize($aExcludeTarget);
|
|
|
|
|
if (false === ($data = $this->Cache_Get("{$sTargetType}_favourite_user_{$sUserId}_{$iCurrPage}_{$iPerPage}_{$s}"))) {
|
2009-08-22 00:01:09 +03:00
|
|
|
|
$data = array(
|
2009-10-15 02:34:03 +03:00
|
|
|
|
'collection' => $this->oMapper->GetFavouritesByUserId($sUserId,$sTargetType,$iCount,$iCurrPage,$iPerPage,$aExcludeTarget),
|
2009-08-22 00:01:09 +03:00
|
|
|
|
'count' => $iCount
|
|
|
|
|
);
|
|
|
|
|
$this->Cache_Set(
|
|
|
|
|
$data,
|
2009-09-19 03:43:00 +03:00
|
|
|
|
"{$sTargetType}_favourite_user_{$sUserId}_{$iCurrPage}_{$iPerPage}_{$s}",
|
2009-08-22 00:01:09 +03:00
|
|
|
|
array(
|
|
|
|
|
"favourite_{$sTargetType}_change",
|
|
|
|
|
"favourite_{$sTargetType}_change_user_{$sUserId}"
|
|
|
|
|
),
|
|
|
|
|
60*60*24*1
|
|
|
|
|
);
|
2009-08-22 00:45:31 +03:00
|
|
|
|
}
|
2009-09-18 23:36:07 +03:00
|
|
|
|
return $data;
|
2009-08-22 00:01:09 +03:00
|
|
|
|
}
|
|
|
|
|
/**
|
|
|
|
|
* Возвращает число таргетов определенного типа в избранном по ID пользователя
|
|
|
|
|
*
|
|
|
|
|
* @param string $sUserId
|
|
|
|
|
* @param string $sTargetType
|
|
|
|
|
* @return array
|
|
|
|
|
*/
|
2009-09-18 23:36:07 +03:00
|
|
|
|
public function GetCountFavouritesByUserId($sUserId,$sTargetType,$aExcludeTarget=array()) {
|
2009-09-19 03:43:00 +03:00
|
|
|
|
$s=serialize($aExcludeTarget);
|
|
|
|
|
if (false === ($data = $this->Cache_Get("{$sTargetType}_count_favourite_user_{$sUserId}_{$s}"))) {
|
2009-09-18 23:36:07 +03:00
|
|
|
|
$data = $this->oMapper->GetCountFavouritesByUserId($sUserId,$sTargetType,$aExcludeTarget);
|
2009-08-22 00:01:09 +03:00
|
|
|
|
$this->Cache_Set(
|
|
|
|
|
$data,
|
2009-09-19 03:43:00 +03:00
|
|
|
|
"{$sTargetType}_count_favourite_user_{$sUserId}_{$s}",
|
2009-08-22 00:01:09 +03:00
|
|
|
|
array(
|
|
|
|
|
"favourite_{$sTargetType}_change",
|
|
|
|
|
"favourite_{$sTargetType}_change_user_{$sUserId}"
|
|
|
|
|
),
|
|
|
|
|
60*60*24*1
|
|
|
|
|
);
|
|
|
|
|
}
|
2009-09-18 23:36:07 +03:00
|
|
|
|
return $data;
|
2009-08-22 00:01:09 +03:00
|
|
|
|
}
|
2009-09-19 13:53:33 +03:00
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Получает список комментариев к записям открытых блогов
|
|
|
|
|
* из избранного указанного пользователя
|
|
|
|
|
*
|
|
|
|
|
* @param string $sUserId
|
|
|
|
|
* @param int $iCurrPage
|
|
|
|
|
* @param int $iPerPage
|
|
|
|
|
* @return array
|
|
|
|
|
*/
|
|
|
|
|
public function GetFavouriteOpenCommentsByUserId($sUserId,$iCurrPage,$iPerPage) {
|
|
|
|
|
if (false === ($data = $this->Cache_Get("comment_favourite_user_{$sUserId}_{$iCurrPage}_{$iPerPage}_open"))) {
|
|
|
|
|
$data = array(
|
|
|
|
|
'collection' => $this->oMapper->GetFavouriteOpenCommentsByUserId($sUserId,$iCount,$iCurrPage,$iPerPage),
|
|
|
|
|
'count' => $iCount
|
|
|
|
|
);
|
|
|
|
|
$this->Cache_Set(
|
|
|
|
|
$data,
|
|
|
|
|
"comment_favourite_user_{$sUserId}_{$iCurrPage}_{$iPerPage}_open",
|
|
|
|
|
array(
|
|
|
|
|
"favourite_comment_change",
|
|
|
|
|
"favourite_comment_change_user_{$sUserId}"
|
|
|
|
|
),
|
|
|
|
|
60*60*24*1
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
return $data;
|
|
|
|
|
}
|
|
|
|
|
/**
|
|
|
|
|
* Возвращает число комментариев к открытым блогам в избранном по ID пользователя
|
|
|
|
|
*
|
|
|
|
|
* @param string $sUserId
|
|
|
|
|
* @return array
|
|
|
|
|
*/
|
|
|
|
|
public function GetCountFavouriteOpenCommentsByUserId($sUserId) {
|
|
|
|
|
if (false === ($data = $this->Cache_Get("comment_count_favourite_user_{$sUserId}_open"))) {
|
|
|
|
|
$data = $this->oMapper->GetCountFavouriteOpenCommentsByUserId($sUserId);
|
|
|
|
|
$this->Cache_Set(
|
|
|
|
|
$data,
|
|
|
|
|
"comment_count_favourite_user_{$sUserId}_open",
|
|
|
|
|
array(
|
|
|
|
|
"favourite_comment_change",
|
|
|
|
|
"favourite_comment_change_user_{$sUserId}"
|
|
|
|
|
),
|
|
|
|
|
60*60*24*1
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
return $data;
|
|
|
|
|
}
|
|
|
|
|
/**
|
|
|
|
|
* Получает список топиков из открытых блогов
|
|
|
|
|
* из избранного указанного пользователя
|
|
|
|
|
*
|
|
|
|
|
* @param string $sUserId
|
|
|
|
|
* @param int $iCurrPage
|
|
|
|
|
* @param int $iPerPage
|
|
|
|
|
* @return array
|
|
|
|
|
*/
|
|
|
|
|
public function GetFavouriteOpenTopicsByUserId($sUserId,$iCurrPage,$iPerPage) {
|
|
|
|
|
if (false === ($data = $this->Cache_Get("topic_favourite_user_{$sUserId}_{$iCurrPage}_{$iPerPage}_open"))) {
|
|
|
|
|
$data = array(
|
|
|
|
|
'collection' => $this->oMapper->GetFavouriteOpenTopicsByUserId($sUserId,$iCount,$iCurrPage,$iPerPage),
|
|
|
|
|
'count' => $iCount
|
|
|
|
|
);
|
|
|
|
|
$this->Cache_Set(
|
|
|
|
|
$data,
|
|
|
|
|
"topic_favourite_user_{$sUserId}_{$iCurrPage}_{$iPerPage}_open",
|
|
|
|
|
array(
|
|
|
|
|
"favourite_topic_change",
|
|
|
|
|
"favourite_topic_change_user_{$sUserId}"
|
|
|
|
|
),
|
|
|
|
|
60*60*24*1
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
return $data;
|
|
|
|
|
}
|
|
|
|
|
/**
|
|
|
|
|
* Возвращает число топиков в открытых блогах
|
|
|
|
|
* из избранного по ID пользователя
|
|
|
|
|
*
|
|
|
|
|
* @param string $sUserId
|
|
|
|
|
* @return array
|
|
|
|
|
*/
|
|
|
|
|
public function GetCountFavouriteOpenTopicsByUserId($sUserId) {
|
|
|
|
|
if (false === ($data = $this->Cache_Get("topic_count_favourite_user_{$sUserId}_open"))) {
|
|
|
|
|
$data = $this->oMapper->GetCountFavouriteOpenTopicsByUserId($sUserId);
|
|
|
|
|
$this->Cache_Set(
|
|
|
|
|
$data,
|
|
|
|
|
"topic_count_favourite_user_{$sUserId}_open",
|
|
|
|
|
array(
|
|
|
|
|
"favourite_topic_change",
|
|
|
|
|
"favourite_topic_change_user_{$sUserId}"
|
|
|
|
|
),
|
|
|
|
|
60*60*24*1
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
return $data;
|
|
|
|
|
}
|
2009-08-22 00:01:09 +03:00
|
|
|
|
/**
|
|
|
|
|
* Добавляет таргет в избранное
|
|
|
|
|
*
|
|
|
|
|
* @param FavouriteEntity_Favourite $oFavourite
|
|
|
|
|
* @return bool
|
|
|
|
|
*/
|
|
|
|
|
public function AddFavourite(FavouriteEntity_Favourite $oFavourite) {
|
|
|
|
|
//чистим зависимые кеши
|
|
|
|
|
$this->Cache_Clean(Zend_Cache::CLEANING_MODE_MATCHING_TAG,array("favourite_{$oFavourite->getTargetType()}_change_user_{$oFavourite->getUserId()}"));
|
|
|
|
|
$this->Cache_Delete("favourite_{$oFavourite->getTargetType()}_{$oFavourite->getTargetId()}_{$oFavourite->getUserId()}");
|
|
|
|
|
return $this->oMapper->AddFavourite($oFavourite);
|
|
|
|
|
}
|
|
|
|
|
/**
|
|
|
|
|
* Удаляет таргет из избранного
|
|
|
|
|
*
|
|
|
|
|
* @param FavouriteEntity_Favourite $oFavourite
|
|
|
|
|
* @return bool
|
|
|
|
|
*/
|
|
|
|
|
public function DeleteFavourite(FavouriteEntity_Favourite $oFavourite) {
|
|
|
|
|
//чистим зависимые кеши
|
|
|
|
|
$this->Cache_Clean(Zend_Cache::CLEANING_MODE_MATCHING_TAG,array("favourite_{$oFavourite->getTargetType()}_change_user_{$oFavourite->getUserId()}"));
|
|
|
|
|
$this->Cache_Delete("favourite_{$oFavourite->getTargetType()}_{$oFavourite->getTargetId()}_{$oFavourite->getUserId()}");
|
|
|
|
|
return $this->oMapper->DeleteFavourite($oFavourite);
|
|
|
|
|
}
|
|
|
|
|
/**
|
|
|
|
|
* Меняет параметры публикации у таргета
|
|
|
|
|
*
|
|
|
|
|
* @param string $sTargetId
|
|
|
|
|
* @param string $sTargetType
|
|
|
|
|
* @param string $iPublish
|
|
|
|
|
* @return bool
|
|
|
|
|
*/
|
2009-11-20 02:59:01 +02:00
|
|
|
|
public function SetFavouriteTargetPublish($aTargetId,$sTargetType,$iPublish) {
|
|
|
|
|
if(!is_array($aTargetId)) $aTargetId = array($aTargetId);
|
|
|
|
|
|
2009-08-22 00:01:09 +03:00
|
|
|
|
$this->Cache_Clean(Zend_Cache::CLEANING_MODE_MATCHING_TAG,array("favourite_{$sTargetType}_change"));
|
2009-11-20 02:59:01 +02:00
|
|
|
|
return $this->oMapper->SetFavouriteTargetPublish($aTargetId,$sTargetType,$iPublish);
|
2009-10-25 22:01:05 +02:00
|
|
|
|
}
|
|
|
|
|
/**
|
|
|
|
|
* Удаляет избранное по списку идентификаторов таргетов
|
|
|
|
|
*
|
|
|
|
|
* @param array|int $aTargetId
|
|
|
|
|
* @param string $sTargetType
|
|
|
|
|
* @return bool
|
|
|
|
|
*/
|
|
|
|
|
public function DeleteFavouriteByTargetId($aTargetId, $sTargetType) {
|
|
|
|
|
if(!is_array($aTargetId)) $aTargetId = array($aTargetId);
|
|
|
|
|
/**
|
|
|
|
|
* Чистим зависимые кеши
|
|
|
|
|
*/
|
|
|
|
|
$this->Cache_Clean(Zend_Cache::CLEANING_MODE_MATCHING_TAG,array("favourite_{$sTargetType}_change"));
|
|
|
|
|
return $this->oMapper->DeleteFavouriteByTargetId($aTargetId,$sTargetType);
|
|
|
|
|
}
|
2009-08-22 00:01:09 +03:00
|
|
|
|
}
|
|
|
|
|
?>
|