pluck('user_id')->first(); $isExists = Model::where('posts_id', $posts_id) ->where('user_id', $uid) ->exists(); if (!$isExists) { // 收藏 $wxLike = new Model(); $wxLike->posts_user_id = $posts_user_id; $wxLike->posts_id = $posts_id; $wxLike->user_id = $uid; $wxLike->save(); if($uid != $posts_user_id){ $user = UserUtils::get_cached_user($uid); UserUtils::add_user_notice(2006, $posts_user_id, '收到了一个收藏', '您的笔记被「' . ''.$user['user_name'].'' . '」收藏啦！', 101, $posts_id); } } Redis::sadd('realtime:post:set', $posts_id); DB::commit(); return true; } catch (\Exception $e) { DB::rollBack(); _logger_(__file__, __line__, $e->getMessage()); return false; } } public static function uncollect($uid, $posts_id) { DB::beginTransaction(); try { $posts_user_id = WxPost::where('id', $posts_id)->pluck('user_id')->first(); // 取消收藏 (new Model())->where('posts_id', $posts_id) ->where('user_id', $uid) ->delete(); (new WxNotice())->where('posts_id', $posts_id) ->where('user_id', $posts_user_id) ->where('notice_type', 3) ->delete(); Redis::sadd('realtime:post:set', $posts_id); DB::commit(); return true; } catch (\Exception $e) { DB::rollBack(); _logger_(__file__, __line__, $e->getMessage()); return false; } } }