1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768 |
- <?php
- namespace App\Services;
- use Illuminate\Support\Facades\Cache;
- use Illuminate\Support\Facades\Redis;
- use App\Status;
- class ReblogService
- {
- const CACHE_KEY = 'pf:services:reblogs:';
- const REBLOGS_KEY = 'pf:services:reblogs:v1:post:';
- const COLDBOOT_KEY = 'pf:services:reblogs:v1:post_:';
- public static function get($profileId, $statusId)
- {
- if (!Redis::zcard(self::CACHE_KEY . $profileId)) {
- return false;
- }
- return Redis::zscore(self::CACHE_KEY . $profileId, $statusId) != null;
- }
- public static function add($profileId, $statusId)
- {
- return Redis::zadd(self::CACHE_KEY . $profileId, $statusId, $statusId);
- }
- public static function del($profileId, $statusId)
- {
- return Redis::zrem(self::CACHE_KEY . $profileId, $statusId);
- }
- public static function getPostReblogs($id, $start = 0, $stop = 10)
- {
- if(!Redis::zcard(self::REBLOGS_KEY . $id)) {
- return Cache::remember(self::COLDBOOT_KEY . $id, 86400, function() use($id) {
- return Status::whereReblogOfId($id)
- ->pluck('id')
- ->each(function($reblog) use($id) {
- self::addPostReblog($id, $reblog);
- })
- ->map(function($reblog) {
- return (string) $reblog;
- });
- });
- }
- return Redis::zrange(self::REBLOGS_KEY . $id, $start, $stop);
- }
- public static function addPostReblog($parentId, $reblogId)
- {
- $pid = intval($parentId);
- $id = intval($reblogId);
- if($pid && $id) {
- return Redis::zadd(self::REBLOGS_KEY . $pid, $id, $id);
- }
- }
- public static function removePostReblog($parentId, $reblogId)
- {
- $pid = intval($parentId);
- $id = intval($reblogId);
- if($pid && $id) {
- return Redis::zrem(self::REBLOGS_KEY . $pid, $id);
- }
- }
- }
|