<?php namespace appcommoncontroller; use thinkApp; use thinkfacadeCache; use thinkfacadeDb; /** * redis 点赞/收藏模块 * @package appadmincontroller * @author 宁佳兵 */ class Praise { private $redis = null; private $member_id; //用户id private $customer_id; //客户id private $article_id; //文章id private $article_type; //文章类型 private $status; //点赞状态 1 点赞 0 取消点赞 private $article_user_like; //hash存放用户点赞记录 private $article_user_like_set; //集合存放该文章下点赞用户ID private $list_article; //队列存放article_id private $article_counts; //文章点赞数 private $praise_table = 'praise'; /** * Praise constructor. * @param string $customer_id 客户id * @param string $member_id 用户id * @param string $article_id 文章id * @param string $article_type 文章类型/表名 */ public function __construct( $customer_id = '', $member_id = '', $article_id = '', $article_type = '') { $this->customer_id = $customer_id; $this->member_id = $member_id; $this->article_id = $article_id; $this->article_type = $article_type; $this->redis = Cache::store("redis"); $this->list_article = 'list_article'; } /** * 点赞入口 * @return bool * @throws PsrSimpleCacheInvalidArgumentException * @throws hinkdbexceptionDataNotFoundException * @throws hinkdbexceptionDbException * @throws hinkdbexceptionModelNotFoundException * @date 2020-07-17 * @author 宁佳兵 */ public function giveFavour() { //判断用户点赞状态 //先从缓存中读取数据，没有 则从mysql中读取数据 $articleUserData = $this->getPraiseStatus(); //存储点赞数据到redis $this->addArticleHash($articleUserData); //存储当前文章下的点赞用户id $this->addUser(); //存储文章点赞数 自增/自减 $this->articleLikeCount(); //文章点赞数量 $dbCount = $this->findMysqlCounts(); //mysql点赞数 $redisCount = $this->findRedisCounts(); //redis点赞数 $data['counts'] = (int)$dbCount + (int)$redisCount; //点赞总数 $data['status'] = $this->status; //文章进入队列 等待同步到mysql $this->queueInto(); return $data; } /** * 将redis 缓存 同步到 mysql中 * @throws Exception * @date 2020-07-17 * @author 宁佳兵 */ public function syncInsertArticle() { $limit = input("limit"); $limit = isset($limit) ? $limit - 1 : '-1'; //取出队列 $article = $this->queueOut($limit); //开启事务 Db::startTrans(); try { foreach ($article as $key => $val) { list($this->article_id, $this->article_type, $this->customer_id, $this->member_id) = explode('_', $val); //获取redis中该文章下所有用户id $user = $this->findUserByNews(); //获取redis中文章点赞数 $redisNum = $this->findRedisCounts(); //更新mysql中文章点赞数 $this->updateDbCount($redisNum); //获取该文章中的用户，循环更新数据到mysql foreach ($user as $k => $v) { $this->member_id = $v; //查询该文章hash数据 $userSatateData = $this->findArticleHash(); //更新mysql中eda_zan表数据 $this->updateDbArticle($userSatateData); //删除该文章下redis中的用户 $this->unsetRedisUserCounts(); //删除redis中该文章hash数据 $this->unsetRedisArticleHash(); } } } catch (Exception $exception) { //事务回滚 Db::rollback(); //写入日志 $this->writeLog(); throw new Exception($exception->getMessage()); } //提交事务 Db::commit(); //TODO 这里暂时删除全部队列，后续需要完善 $this->redis->del($this->list_article); echo 'success'; } /** * 点赞总数 * @return array * @throws PsrSimpleCacheInvalidArgumentException * @throws hinkdbexceptionDataNotFoundException * @throws hinkdbexceptionDbException * @throws hinkdbexceptionModelNotFoundException * @date 2020-07-20 * @author 宁佳兵 */ public function getPraiseCounts() { $this->getPraiseStatus(); return [ 'counts' => ((int)$this->findMysqlCounts() + (int)$this->findRedisCounts()), 'status' => $this->status ? 0 : 1 ]; //点赞总数 } /** * 判断用户点赞状态 先从缓存中读取数据，没有 则从mysql中读取数据 * @return bool * @throws hinkdbexceptionDataNotFoundException * @throws hinkdbexceptionDbException * @throws hinkdbexceptionModelNotFoundException * @date 2020-07-20 * @author 宁佳兵 */ private function getPraiseStatus() { if ($articleUserData = $this->findArticleHash()) { $this->status = $articleUserData['status'] ? 0 : 1; } else { if ($result = $this->findDbArticle()) { $this->status = $result['status'] ? 0 : 1; } else { $this->status = 1; } } return $articleUserData; } /** * 获取redis中用户点赞状态数据 * @return bool * @date 2020-07-17 * @author 宁佳兵 */ private function findArticleHash() { $this->article_user_like = 'article_user_like_' . $this->customer_id . '_' . $this->member_id . '_' . $this->article_id . '_' . $this->article_type; return $this->redis->hGetAll($this->article_user_like) ?: false; } /** * 获取mysql中用户点赞状态 * @return array|bool| hinkModel|null * @throws hinkdbexceptionDataNotFoundException * @throws hinkdbexceptionDbException * @throws hinkdbexceptionModelNotFoundException * @date 2020-07-17 * @author 宁佳兵 */ private function findDbArticle() { if (empty($this->article_type)) { return false; } $data = Db::name($this->praise_table) ->where([ "c_id" => $this->customer_id, "member_id" => $this->member_id, "article_id" => $this->article_id, "type" => $this->article_type, ]) ->find(); return $data ?: false; } /** * 点赞数据写入hash * @param array $articleUserData * @return bool * @date 2020-07-17 * @author 宁佳兵 */ private function addArticleHash($articleUserData = []) { $this->article_user_like = 'article_user_like_' . $this->customer_id . '_' . $this->member_id . '_' . $this->article_id . '_' . $this->article_type; if (!$articleUserData || empty($articleUserData)) { $this->redis->hSet($this->article_user_like, 'article_id', $this->article_id); //文章id $this->redis->hSet($this->article_user_like, 'member_id', $this->member_id); //用户id $this->redis->hSet($this->article_user_like, 'customer_id', $this->customer_id); //客户id $this->redis->hSet($this->article_user_like, 'article_type', $this->article_type); //点赞类型 $this->redis->hSet($this->article_user_like, 'create_time', time()); //点赞时间 } $this->redis->hSet($this->article_user_like, 'update_time', time()); //更新时间 $this->redis->hSet($this->article_user_like, 'status', $this->status); //点赞状态 return true; } /** * 当前文章下的点赞用户id * @return mixed * @date 2020-07-17 * @author 宁佳兵 */ private function addUser() { $this->article_user_like_set = 'article_user_like_set_' . $this->article_id . '_' . $this->article_type; return $this->redis->sAdd($this->article_user_like_set, $this->member_id); } /** * 文章点赞数计数 * @return mixed * @date 2020-07-17 * @author 宁佳兵 */ private function articleLikeCount() { $this->article_counts = 'article_counts_' . $this->article_id . '_' . $this->article_type; if ($this->status) { //点赞数自增 $counts = $this->redis->incr($this->article_counts); } else { //点赞数自减 $counts = $this->redis->decr($this->article_counts); } return $counts; } /** * 文章入队列 * @date 2020-07-17 * @author 宁佳兵 */ private function queueInto() { return $this->redis->rPush($this->list_article, $this->article_id . '_' . $this->article_type . '_' . $this->customer_id . '_' . $this->member_id); } /** * 文章出队列 * @param $limit * @return mixed * @date 2020-07-17 * @author 宁佳兵 */ private function queueOut($limit = '-1') { return $this->redis->Lrange($this->list_article, 0, $limit); } /** * 获取redis中 文章的点赞数量 * @return int|mixed * @throws PsrSimpleCacheInvalidArgumentException * @date 2020-07-17 * @author 宁佳兵 */ private function findRedisCounts() { $this->article_counts = 'article_counts_' . $this->article_id . '_' . $this->article_type; return $this->redis->get($this->article_counts) ?: 0; } /** * 获取mysql文章的点赞数量 * @return mixed * @throws hinkdbexceptionDataNotFoundException * @throws hinkdbexceptionDbException * @throws hinkdbexceptionModelNotFoundException * @date 2020-07-20 * @author 宁佳兵 */ private function findMysqlCounts() { return Db::name($this->article_type) ->where([ 'id' => $this->article_id, ]) ->find()['fabulous']; } /** * 获取redis中该文章下所有用户id * @return mixed * @date 2020-07-17 * @author 宁佳兵 */ private function findUserByNews() { $this->post_user_like_set = 'article_user_like_set_' . $this->article_id . '_' . $this->article_type; return $this->redis->sMembers($this->post_user_like_set); } /** * 更新mysql文章点赞数 * @param $redisNum * @return bool|mixed * @throws hinkdbexceptionDbException * @date 2020-07-17 * @author 宁佳兵 */ private function updateDbCount($redisNum) { //inc 方法不起作用 暂时注释 // $result = Db::name($this->article_type) // ->where([ // 'id' => $this->article_id, // ]) // ->inc('fabulous', (int)$redisNum); $fabulous = Db::name($this->article_type) ->where([ 'id' => $this->article_id, ]) ->find()['fabulous']; $result = Db::name($this->article_type) ->where([ 'id' => $this->article_id, ]) ->update(['fabulous' => (int)$fabulous + (int)$redisNum]); return $result ? $this->unsetRedisArticleCounts() : false; } /** * 更新mysql点赞表 * @param array $userSatateData * @return bool * @throws hinkdbexceptionDataNotFoundException * @throws hinkdbexceptionDbException * @throws hinkdbexceptionModelNotFoundException * @date 2020-07-17 * @author 宁佳兵 */ private function updateDbArticle($userSatateData = []) { //判断用户原来是否点赞过 if ($this->findDbArticle() === false) { $data = Db::name($this->praise_table) ->insert([ 'article_id' => $userSatateData['article_id'], 'type' => $userSatateData['article_type'], 'c_id' => $userSatateData['customer_id'], 'member_id' => $userSatateData['member_id'], 'modified' => $userSatateData['update_time'], 'status' => $userSatateData['status'], //点赞 ]); }else{ $data = Db::name($this->praise_table) ->where([ 'article_id' => $userSatateData['article_id'], 'type' => $userSatateData['article_type'], 'c_id' => $userSatateData['customer_id'], 'member_id' => $userSatateData['member_id'], ]) ->update([ 'modified' => $userSatateData['update_time'], 'status' => $userSatateData['status'], //取消点赞 ]); } return ! empty($data) ? $data : false; } /** * 删除redis文章点赞数 * @return mixed * @date 2020-07-17 * @author 宁佳兵 */ private function unsetRedisArticleCounts() { $this->article_counts = 'article_counts_' . $this->article_id . '_' . $this->article_type; return $this->redis->del($this->article_counts); } /** * 删除该文章下redis中的用户 * @return mixed * @date 2020-07-17 * @author 宁佳兵 */ private function unsetRedisUserCounts() { $this->article_user_like_set = 'article_user_like_set_' . $this->article_id . '_' . $this->article_type; return $this->redis->sRem($this->article_user_like_set, $this->member_id); } /** * 删除redis中该文章hash数据 * @return mixed * @date 2020-07-17 * @author 宁佳兵 */ private function unsetRedisArticleHash() { $this->article_user_like = 'article_user_like_' . $this->customer_id . '_' . $this->member_id . '_' . $this->article_id . '_' . $this->article_type; return $this->redis->del($this->article_user_like); } /** * 记录错误日志 * @date 2020-07-17 * @author 宁佳兵 */ private function writeLog() { $file = '../runtime/log/redis.log'; $content = "操作失败，文章：" . $this->article_id . '---用户：' . $this->member_id . ' '; if (is_file($file)) { file_put_contents($file, $content, FILE_APPEND); } } }
可参考https://blog.csdn.net/MyDream229/article/details/107363287/