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
|
|
|
|
*
|
|
|
|
---------------------------------------------------------
|
|
|
|
*/
|
|
|
|
|
|
|
|
class Mapper_Favourite extends Mapper {
|
|
|
|
|
|
|
|
public function AddFavourite(FavouriteEntity_Favourite $oFavourite) {
|
|
|
|
$sql = "
|
|
|
|
INSERT INTO ".Config::Get('db.table.favourite')."
|
|
|
|
( target_id, target_type, user_id )
|
|
|
|
VALUES
|
|
|
|
(?d, ?, ?d)
|
|
|
|
";
|
|
|
|
if ($this->oDb->query(
|
|
|
|
$sql,
|
|
|
|
$oFavourite->getTargetId(),
|
|
|
|
$oFavourite->getTargetType(),
|
|
|
|
$oFavourite->getUserId()
|
|
|
|
)===0) {
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
public function GetFavouritesByArray($aArrayId,$sTargetType,$sUserId) {
|
|
|
|
if (!is_array($aArrayId) or count($aArrayId)==0) {
|
|
|
|
return array();
|
|
|
|
}
|
|
|
|
$sql = "SELECT *
|
|
|
|
FROM ".Config::Get('db.table.favourite')."
|
|
|
|
WHERE
|
|
|
|
target_id IN(?a)
|
|
|
|
AND
|
|
|
|
target_type = ?
|
|
|
|
AND
|
|
|
|
user_id = ?d";
|
|
|
|
$aFavourites=array();
|
|
|
|
if ($aRows=$this->oDb->select($sql,$aArrayId,$sTargetType,$sUserId)) {
|
|
|
|
foreach ($aRows as $aRow) {
|
2009-09-08 15:02:51 +03:00
|
|
|
$aFavourites[]=Engine::GetEntity('Favourite',$aRow);
|
2009-08-22 00:01:09 +03:00
|
|
|
}
|
|
|
|
}
|
|
|
|
return $aFavourites;
|
|
|
|
}
|
|
|
|
|
|
|
|
public function DeleteFavourite(FavouriteEntity_Favourite $oFavourite) {
|
|
|
|
$sql = "
|
|
|
|
DELETE FROM ".Config::Get('db.table.favourite')."
|
|
|
|
WHERE
|
|
|
|
user_id = ?d
|
|
|
|
AND
|
|
|
|
target_id = ?d
|
|
|
|
AND
|
|
|
|
target_type = ?
|
|
|
|
";
|
|
|
|
if ($this->oDb->query(
|
|
|
|
$sql,
|
|
|
|
$oFavourite->getUserId(),
|
|
|
|
$oFavourite->getTargetId(),
|
|
|
|
$oFavourite->getTargetType()
|
|
|
|
)) {
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
2009-11-20 02:59:01 +02:00
|
|
|
public function SetFavouriteTargetPublish($aTargetId,$sTargetType,$iPublish) {
|
2009-08-22 00:01:09 +03:00
|
|
|
$sql = "
|
|
|
|
UPDATE ".Config::Get('db.table.favourite')."
|
|
|
|
SET
|
2009-09-02 23:36:44 +03:00
|
|
|
target_publish = ?d
|
2009-08-22 00:01:09 +03:00
|
|
|
WHERE
|
2009-11-20 02:59:01 +02:00
|
|
|
target_id IN(?a)
|
2009-08-22 00:01:09 +03:00
|
|
|
AND
|
|
|
|
target_type = ?
|
|
|
|
";
|
2009-11-20 02:59:01 +02:00
|
|
|
return $this->oDb->query($sql,$iPublish,$aTargetId,$sTargetType);
|
2009-08-22 00:01:09 +03:00
|
|
|
}
|
|
|
|
|
2009-10-15 02:34:03 +03:00
|
|
|
public function GetFavouritesByUserId($sUserId,$sTargetType,&$iCount,$iCurrPage,$iPerPage,$aExcludeTarget=array()) {
|
2009-08-22 00:01:09 +03:00
|
|
|
$sql = "
|
|
|
|
SELECT target_id
|
|
|
|
FROM ".Config::Get('db.table.favourite')."
|
|
|
|
WHERE
|
|
|
|
user_id = ?
|
|
|
|
AND
|
|
|
|
target_publish = 1
|
|
|
|
AND
|
2009-09-18 23:36:07 +03:00
|
|
|
target_type = ?
|
|
|
|
{ AND target_id NOT IN (?a) }
|
2009-08-22 00:01:09 +03:00
|
|
|
ORDER BY target_id DESC
|
|
|
|
LIMIT ?d, ?d ";
|
|
|
|
|
|
|
|
$aFavourites=array();
|
|
|
|
if ($aRows=$this->oDb->selectPage(
|
|
|
|
$iCount,
|
|
|
|
$sql,
|
|
|
|
$sUserId,
|
|
|
|
$sTargetType,
|
2009-09-18 23:36:07 +03:00
|
|
|
(count($aExcludeTarget) ? $aExcludeTarget : DBSIMPLE_SKIP),
|
2009-08-22 00:01:09 +03:00
|
|
|
($iCurrPage-1)*$iPerPage,
|
|
|
|
$iPerPage
|
|
|
|
)) {
|
|
|
|
foreach ($aRows as $aFavourite) {
|
|
|
|
$aFavourites[]=$aFavourite['target_id'];
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return $aFavourites;
|
|
|
|
}
|
2009-09-19 13:53:33 +03:00
|
|
|
|
2009-09-18 23:36:07 +03:00
|
|
|
public function GetCountFavouritesByUserId($sUserId,$sTargetType,$aExcludeTarget) {
|
2009-08-22 00:01:09 +03:00
|
|
|
$sql = "SELECT
|
|
|
|
count(target_id) as count
|
|
|
|
FROM
|
|
|
|
".Config::Get('db.table.favourite')."
|
|
|
|
WHERE
|
|
|
|
user_id = ?
|
|
|
|
AND
|
|
|
|
target_publish = 1
|
|
|
|
AND
|
2009-09-18 23:36:07 +03:00
|
|
|
target_type = ?
|
|
|
|
{ AND target_id NOT IN (?a) }
|
2010-03-12 23:52:31 +02:00
|
|
|
;";
|
2009-09-18 23:36:07 +03:00
|
|
|
return ( $aRow=$this->oDb->selectRow(
|
|
|
|
$sql,$sUserId,
|
|
|
|
$sTargetType,
|
|
|
|
(count($aExcludeTarget) ? $aExcludeTarget : DBSIMPLE_SKIP)
|
|
|
|
)
|
|
|
|
)
|
2009-08-22 00:01:09 +03:00
|
|
|
? $aRow['count']
|
|
|
|
: false;
|
|
|
|
}
|
2009-09-19 13:53:33 +03:00
|
|
|
|
|
|
|
public function GetFavouriteOpenCommentsByUserId($sUserId,&$iCount,$iCurrPage,$iPerPage) {
|
|
|
|
$sql = "
|
|
|
|
SELECT f.target_id
|
|
|
|
FROM
|
|
|
|
".Config::Get('db.table.favourite')." AS f,
|
|
|
|
".Config::Get('db.table.comment')." AS c,
|
|
|
|
".Config::Get('db.table.topic')." AS t,
|
|
|
|
".Config::Get('db.table.blog')." AS b
|
|
|
|
WHERE
|
|
|
|
f.user_id = ?d
|
|
|
|
AND
|
|
|
|
f.target_publish = 1
|
|
|
|
AND
|
|
|
|
f.target_type = 'comment'
|
|
|
|
AND
|
|
|
|
f.target_id = c.comment_id
|
|
|
|
AND
|
|
|
|
c.target_id = t.topic_id
|
|
|
|
AND
|
|
|
|
t.blog_id = b.blog_id
|
|
|
|
AND
|
|
|
|
b.blog_type IN ('open', 'personal')
|
|
|
|
ORDER BY target_id DESC
|
|
|
|
LIMIT ?d, ?d ";
|
|
|
|
|
|
|
|
$aFavourites=array();
|
|
|
|
if ($aRows=$this->oDb->selectPage(
|
|
|
|
$iCount, $sql, $sUserId,
|
|
|
|
($iCurrPage-1)*$iPerPage, $iPerPage
|
|
|
|
)) {
|
|
|
|
foreach ($aRows as $aFavourite) {
|
|
|
|
$aFavourites[]=$aFavourite['target_id'];
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return $aFavourites;
|
|
|
|
}
|
|
|
|
|
|
|
|
public function GetCountFavouriteOpenCommentsByUserId($sUserId) {
|
|
|
|
$sql = "SELECT
|
|
|
|
count(f.target_id) as count
|
|
|
|
FROM
|
|
|
|
".Config::Get('db.table.favourite')." AS f,
|
|
|
|
".Config::Get('db.table.comment')." AS c,
|
|
|
|
".Config::Get('db.table.topic')." AS t,
|
|
|
|
".Config::Get('db.table.blog')." AS b
|
|
|
|
WHERE
|
|
|
|
f.user_id = ?d
|
|
|
|
AND
|
|
|
|
f.target_publish = 1
|
|
|
|
AND
|
|
|
|
f.target_type = 'comment'
|
|
|
|
AND
|
|
|
|
f.target_id = c.comment_id
|
|
|
|
AND
|
|
|
|
c.target_id = t.topic_id
|
|
|
|
AND
|
|
|
|
t.blog_id = b.blog_id
|
|
|
|
AND
|
|
|
|
b.blog_type IN ('open', 'personal')
|
|
|
|
;";
|
|
|
|
return ( $aRow=$this->oDb->selectRow($sql,$sUserId) )
|
|
|
|
? $aRow['count']
|
|
|
|
: false;
|
|
|
|
}
|
|
|
|
|
|
|
|
public function GetFavouriteOpenTopicsByUserId($sUserId,&$iCount,$iCurrPage,$iPerPage) {
|
|
|
|
$sql = "
|
|
|
|
SELECT f.target_id
|
|
|
|
FROM
|
|
|
|
".Config::Get('db.table.favourite')." AS f,
|
|
|
|
".Config::Get('db.table.topic')." AS t,
|
|
|
|
".Config::Get('db.table.blog')." AS b
|
|
|
|
WHERE
|
|
|
|
f.user_id = ?d
|
|
|
|
AND
|
|
|
|
f.target_publish = 1
|
|
|
|
AND
|
2010-03-12 23:52:31 +02:00
|
|
|
f.target_type = 'topic'
|
2009-09-19 13:53:33 +03:00
|
|
|
AND
|
|
|
|
f.target_id = t.topic_id
|
|
|
|
AND
|
|
|
|
t.blog_id = b.blog_id
|
|
|
|
AND
|
|
|
|
b.blog_type IN ('open', 'personal')
|
|
|
|
ORDER BY target_id DESC
|
|
|
|
LIMIT ?d, ?d ";
|
|
|
|
|
|
|
|
$aFavourites=array();
|
|
|
|
if ($aRows=$this->oDb->selectPage(
|
|
|
|
$iCount, $sql, $sUserId,
|
|
|
|
($iCurrPage-1)*$iPerPage, $iPerPage
|
|
|
|
)) {
|
|
|
|
foreach ($aRows as $aFavourite) {
|
|
|
|
$aFavourites[]=$aFavourite['target_id'];
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return $aFavourites;
|
|
|
|
}
|
|
|
|
|
|
|
|
public function GetCountFavouriteOpenTopicsByUserId($sUserId) {
|
|
|
|
$sql = "SELECT
|
|
|
|
count(f.target_id) as count
|
|
|
|
FROM
|
|
|
|
".Config::Get('db.table.favourite')." AS f,
|
|
|
|
".Config::Get('db.table.topic')." AS t,
|
|
|
|
".Config::Get('db.table.blog')." AS b
|
|
|
|
WHERE
|
|
|
|
f.user_id = ?d
|
|
|
|
AND
|
|
|
|
f.target_publish = 1
|
|
|
|
AND
|
2010-03-12 23:52:31 +02:00
|
|
|
f.target_type = 'topic'
|
2009-09-19 13:53:33 +03:00
|
|
|
AND
|
|
|
|
f.target_id = t.topic_id
|
|
|
|
AND
|
|
|
|
t.blog_id = b.blog_id
|
|
|
|
AND
|
|
|
|
b.blog_type IN ('open', 'personal')
|
|
|
|
;";
|
|
|
|
return ( $aRow=$this->oDb->selectRow($sql,$sUserId) )
|
|
|
|
? $aRow['count']
|
|
|
|
: false;
|
|
|
|
}
|
2009-10-25 22:01:05 +02:00
|
|
|
|
|
|
|
public function DeleteFavouriteByTargetId($aTargetId,$sTargetType) {
|
|
|
|
$sql = "
|
|
|
|
DELETE FROM ".Config::Get('db.table.favourite')."
|
|
|
|
WHERE
|
|
|
|
target_id IN(?a)
|
|
|
|
AND
|
|
|
|
target_type = ? ";
|
|
|
|
if ($this->oDb->query($sql,$aTargetId,$sTargetType)) {
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
return false;
|
|
|
|
}
|
2009-08-22 00:01:09 +03:00
|
|
|
}
|
|
|
|
?>
|