第一下载redis包
代码语言：javascript复制"predis/predis": "^1.1",
<?php
/**
* 点赞
*/
namespace applikeservice;
use appcommonDataService;
use appcommonRedis;
class LikeService
{
const LIKE_TYPE_ALL = 4; //全部
const LIKE_USER_GIVE_SHOW_CHINESENAME = '赞了您这条';
const LIKE_USER_RECEIVE_SHOW_CHINESENAME = '我点赞了这条';
const BLOG_CHINESENAME = '资讯';
/**
* 点赞资讯
* @param int $userId 用户ID
* @param int $blogId 资讯ID
*/
public function addLikeBlog($userId, $blogId, $sys)
{
$blogInfo = $this->_getBlogInfo($blogId, $sys);
if (!$blogInfo) return false;
if ($blogInfo['author_id']) {
//(资讯创建人)我收到点赞全部列表
$key = $this->_getMyAllReceiveLikeListKey($blogInfo['author_id'], $sys);
Redis::getInstance()->redisZadd($key, time(), $blogId . ':blog:' . $userId . ':likeuserid');
}
//资讯点赞列表
$key = $this->_getBlogListKey($blogId, $sys);
Redis::getInstance()->redisZadd($key, time(), $userId);
//我的点赞资讯列表
$key = $this->_getMyLikeBlogListKey($userId, $sys);
Redis::getInstance()->redisZadd($key, time(), $blogId);
//我发出点赞全部列表
$key = $this->_getMyAllGiveLikeListKey($userId, $sys);
Redis::getInstance()->redisZadd($key, time(), $blogId . ":blog");
return true;
}
/**
* 取消点赞资讯
* @param int $userId 用户ID
* @param int $BlogId 资讯ID
*/
public function unLikeBlog($userId, $blogId, $sys)
{
$blogInfo = $this->_getBlogInfo($blogId, $sys);
if (!$blogInfo) return false;
if ($blogInfo['author_id']) {
//(资讯创建人)我收到点赞全部列表
$key = $this->_getMyAllReceiveLikeListKey($blogInfo['author_id'], $sys);
Redis::getInstance()->redisZrem($key, $blogId . ':blog:' . $userId . ':likeuserid');
}
//资讯点赞列表
$key = $this->_getBlogListKey($blogId, $sys);
Redis::getInstance()->redisZrem($key, $userId);
//我的点赞资讯列表
$key = $this->_getMyLikeBlogListKey($userId, $sys);
Redis::getInstance()->redisZrem($key, $blogId);
//我的点赞全部列表
$key = $this->_getMyAllGiveLikeListKey($userId, $sys);
Redis::getInstance()->redisZrem($key, $blogId . ":blog");
return true;
}
/**
* 判断资讯是否被点赞
* @param int $userId 登录用户ID
* @param int $blogId 资讯ID
*/
public function isLikeBlog($userId, $blogId, $sys)
{
$key = $this->_getMyLikeBlogListKey($userId, $sys);
$score = Redis::getInstance()->redisZscore($key, $blogId);
if (empty($score)) {
return false;
}
return true;
}
/**
* 获取资讯点赞数量
*/
public function getBlogLikeCount($blogId, $sys)
{
$key = $this->_getBlogListKey($blogId, $sys);
$count = (int)Redis::getInstance()->redisZcard($key);
return ['count' => $count];
}
/**
* 获取资讯评论点赞排序，从高到低排序
* 返回排序好后评论id数组
*/
public function getBlogCommentLikeSort($blogId, $sys)
{
$key = $this->_getCommentTypeListKey($blogId, 'blog', $sys);
$list = Redis::getInstance()->redisZRevRange($key, 0, -1, ['WITHSCORES']);
return $list;
}
/**
* 获取我发出的点赞列表
* @param int $type 1 帖子 2 资讯 3评论 4全部
*/
public function getMyAllGiveLikeList($userId, $sys, $type, $pageNo = 1, $pageCount = 10)
{
switch ($type) {
case self::LIKE_TYPE_BLOG:
$key = $this->_getMyLikeBlogListKey($userId, $sys);
break;
default:
$key = $this->_getMyAllGiveLikeListKey($userId, $sys);
break;
}
$list = Redis::getInstance()->redisZRevRange($key, 0, -1);
$list = isset($list['data']) ? $list['data'] : [];
//只展示显示每页数量
$result = array_slice($list, ($pageNo - 1) * $pageCount, $pageCount);
$data = [];
if ($type == self::LIKE_TYPE_ALL) {
//获取全部信息
foreach ($result as $k => $value) {
$detail = explode(':', $value);
//适应前端数据格式
$score = Redis::getInstance()->redisZscore($key, $value);
$likeTime = date("Y-m-d H:i:s", $score);
$likeTime = DataService::getInstance()->_handleCreateTimeTwo($likeTime);
$data[$k]['likeTime'] = $likeTime;
$data[$k]['titleId'] = $detail[0];
$data[$k]['commentId'] = 0;
$data[$k]['comment'] = '';
if (isset($detail[1]) && $detail[1] == 'blog') {
$blogInfo = $this->_getBlogInfo($detail[0], $sys);
$blogAuthorId = isset($blogInfo['author_id']) ? $blogInfo['author_id'] : 0;
$authorInfo = $this->_getAuthorInfo($blogAuthorId, $sys);
$data[$k]['sourceUserId'] = $blogAuthorId;
$data[$k]['sourceUserNickName'] = isset($authorInfo['author_name']) ? $authorInfo['author_name'] : '';
$data[$k]['sourceUserHeadimgurl'] = isset($authorInfo['author_headimgurl']) ? $authorInfo['author_headimgurl'] : '';
$data[$k]['likeShowName'] = self::LIKE_USER_RECEIVE_SHOW_CHINESENAME . self::BLOG_CHINESENAME;
//点赞来源类型id,1帖子2资讯
$data[$k]['likeSourceTypeId'] = self::LIKE_TYPE_BLOG;
$data[$k]['likeTypeName'] = self::BLOG_CHINESENAME;
$data[$k]['title'] = isset($blogInfo['title']) ? $blogInfo['title'] : '';
//评论创建者信息设置为空
$data[$k]['commentUserId'] = 0;
$data[$k]['commentUserNickName'] = '';
$data[$k]['commentUserHeadimgurl'] = '';
}
}
}
$count = count($data);
$pagerInfo = [
"total" => $count,
"page_no" => $pageNo,
"page_count" => $pageCount,
"page_total" => ceil($count / $pageCount)
];
return ["code" => _MSG_SYSTEM_SUCCESS, "msg" => "查询成功", "data" => ["page_info" => $pagerInfo, "list" => $data]];
}
/**
* 获取我收到的点赞列表
* @param int $type 1 帖子 2 资讯 3评论 4全部
*/
public function getMyAllReceiveLikeList($userId, $sys, $type, $pageNo = 1, $pageCount = 10)
{
switch ($type) {
case self::LIKE_TYPE_BLOG:
$key = $this->_getMyLikeBlogListKey($userId, $sys);
break;
default:
$key = $this->_getMyAllReceiveLikeListKey($userId, $sys);
break;
}
$list = Redis::getInstance()->redisZRevRange($key, 0, -1);
$list = isset($list['data']) ? $list['data'] : [];
//只展示显示每页数量
$result = array_slice($list, ($pageNo - 1) * $pageCount, $pageCount);
$data = [];
if ($type == self::LIKE_TYPE_ALL) {
//获取全部信息
foreach ($result as $k => $value) {
$detail = explode(':', $value);
//适应前端数据格式
$score = Redis::getInstance()->redisZscore($key, $value);
$likeTime = date("Y-m-d H:i:s", $score);
$likeTime = DataService::getInstance()->_handleCreateTimeTwo($likeTime);
$data[$k]['likeTime'] = $likeTime;
$data[$k]['titleId'] = $detail[0];
$data[$k]['commentId'] = 0;
$data[$k]['comment'] = '';
if (isset($detail[1]) && $detail[1] == 'blog') {
$blogInfo = $this->_getBlogInfo($detail[0], $sys);
$blogAuthorId = isset($blogInfo['author_id']) ? $blogInfo['author_id'] : 0;
$authorInfo = $this->_getAuthorInfo($blogAuthorId, $sys);
$data[$k]['sourceUserId'] = $blogAuthorId;
$data[$k]['sourceUserNickName'] = isset($authorInfo['author_name']) ? $authorInfo['author_name'] : '';
$data[$k]['sourceUserHeadimgurl'] = isset($authorInfo['author_headimgurl']) ? $authorInfo['author_headimgurl'] : '';
$data[$k]['likeShowName'] = self::LIKE_USER_GIVE_SHOW_CHINESENAME . self::BLOG_CHINESENAME;
//点赞来源类型id,1帖子2资讯
$data[$k]['likeSourceTypeId'] = self::LIKE_TYPE_BLOG;
$data[$k]['likeTypeName'] = self::BLOG_CHINESENAME;
$data[$k]['title'] = isset($blogInfo['title']) ? $blogInfo['title'] : '';
//评论创建者信息
$data[$k]['commentUserId'] = 0;
$data[$k]['commentUserNickName'] = '';
$data[$k]['commentUserHeadimgurl'] = '';
}
//点赞者信息
$userInfo = $this->_getUserInfo($detail[2], $sys);
$data[$k]['userId'] = $detail[2];
$data[$k]['userNickName'] = isset($userInfo['nickname']) ? $userInfo['nickname'] : '';
$data[$k]['userHeadimgurl'] = isset($userInfo['headimgurl']) ? $userInfo['headimgurl'] : '';
}
}
$count = count($data);
$pagerInfo = [
"total" => $count,
"page_no" => $pageNo,
"page_count" => $pageCount,
"page_total" => ceil($count / $pageCount)
];
return ["code" => _MSG_SYSTEM_SUCCESS, "msg" => "查询成功", "data" => ["page_info" => $pagerInfo, "list" => $data]];
}
/**
* 获取资讯点赞列表的key
*/
private function _getBlogListKey($blogId, $sys)
{
return "Like:{$sys}:blog:{$blogId}";
}
/**
* 获取我的点赞资讯的key
*/
private function _getMyLikeBlogListKey($userId, $sys)
{
return "Like:{$sys}:users:blogs:{$userId}";
}
/**
* 获取我的全部发出点赞列表的key
* Like:343:users:all:give:1
* 在343系统下用户id=1全部发出点赞列表(value=2:blog(文章id为2),score=time时间戳)
*/
private function _getMyAllGiveLikeListKey($userId, $sys)
{
return "Like:{$sys}:users:all:give:{$userId}";
}
/**
* 获取我的全部收到点赞列表的key
* Like:343:users:all:receive:1
* 在343系统下用户id=1全部收到点赞列表(value=2:blog(文章id为2),score=time时间戳)
*/
private function _getMyAllReceiveLikeListKey($userId, $sys)
{
return "Like:{$sys}:users:all:receive:{$userId}";
}
/**
* 获取资讯信息
*/
private function _getBlogInfo($blogId, $sys)
{
if (empty($blogId)) {
return [];
}
$blogInfo = BlogInstanceModel::getInstance()->getOneById($blogId, $sys);
return $blogInfo['data'];
}
}
复制代码
