App\Repository\Front\CommentRepository

Complexity

Total Complexity

20

Size/Duplication

Total Lines	139
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	2

8 Methods

Rating	Name	Duplication	Size	Complexity
A	addReplyCount()	0	3	1
A	list()	0	22	2
A	info()	0	26	4
A	reply()	0	5	1
A	neutral()	0	22	5
A	dislike()	0	4	1
A	like()	0	4	1
A	operate()	0	28	5

<?php

namespace App\Repository\Front;

use App\Model\Admin\Comment;
use App\Model\Admin\CommentOperateLog;
use App\Repository\Searchable;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Cache;

class CommentRepository
{
    public static function list($perPage = 10, $condition = [])
    {
        $data = Comment::query()
            ->where(function ($query) use ($condition) {
                Searchable::buildQuery($query, $condition);
            })
            ->with('user:id,name,avatar')
            ->orderBy('id', 'desc')
            ->paginate($perPage);

        if ($condition['rid'][1] > 0) {
            // 接口直接请求评论的回复数据，则直接返回
            return $data;
        }

        $data->transform(function ($item) use ($perPage) {
            // 获取评论回复
            $reply = self::reply($item->id, $perPage);
            $item->reply = $reply;
            return $item;
        });
        return $data;
    }

    public static function reply($id, $perPage = 10)
    {
        return Cache::rememberForever('comment_replay:' . $id, function () use ($id, $perPage) {
            return Comment::query()->where('rid', $id)->orderBy('id', 'desc')
                ->with('user:id,name,avatar')->with('replyUser:id,name,avatar')->paginate($perPage, ['*'], 'page', 1);
        });
    }

    public static function like(int $id, int $uid)
    {
        self::operate($id, $uid, 'like');
        return self::info($id, $uid);
    }

    public static function dislike(int $id, int $uid)
    {
        self::operate($id, $uid, 'dislike');
        return self::info($id, $uid);
    }

    public static function neutral(int $id, int $uid)
    {
        DB::transaction(function () use ($id, $uid) {
            $logs = CommentOperateLog::query()->select('operate')->
                where('user_id', $uid)->where('comment_id', $id)->get();
            if ($logs->isEmpty()) {
                // 未操作则直接返回
                return true;
            }

            foreach ($logs as $log) {
                if ($log->operate === 'like') {
                    Comment::query()->where('id', $id)->decrement('like');
                } elseif ($log->operate === 'dislike') {
                    Comment::query()->where('id', $id)->decrement('dislike');
                }
            }

            return CommentOperateLog::query()->where('user_id', $uid)->where('comment_id', $id)->delete();
        });

        return self::info($id, $uid);
    }

    public static function operate(int $id, int $uid, string $operate)
    {
        return DB::transaction(function () use ($id, $uid, $operate) {
            $log = CommentOperateLog::query()->where('user_id', $uid)->where('comment_id', $id)
                ->where('operate', $operate)->lockForUpdate()->first();
            if ($log) {
                // 已操作则直接返回
                return true;
            }

            $oppositeOperate = $operate === 'like' ? 'dislike' : 'like';
            $log = CommentOperateLog::query()->where('user_id', $uid)->where('comment_id', $id)
                ->where('operate', $oppositeOperate)->lockForUpdate()->first();
            if ($log) {
                // 存在反操作则递减数量并更新操作类型
                Comment::query()->where('id', $id)->decrement($oppositeOperate);
                $log->operate = $operate;
                $log->save();
            } else {
                CommentOperateLog::query()->create(['user_id' => $uid, 'comment_id' => $id, 'operate' => $operate]);
            }
            Comment::query()->where('id', $id)->increment($operate);

            $comment = Comment::query()->select('rid')->find($id);
            if ($comment->rid > 0) {
                Cache::forget('comment_replay:' . $comment->rid);
            }
            return true;
        });
    }

    /**
     * 返回指定用户对评论的操作情况及评论操作数据
     *
     * @param int $id
     * @param int $uid
     * @return array
     */
    public static function info(int $id, int $uid = 0)
    {
        $data = [
            'like' => 0,
            'dislike' => 0,
        ];
        $comment = Comment::query()->select(['like', 'dislike'])->where('id', $id)->first();
        if (!$comment) {
            return $data;
        }
        $data['like'] = $comment->like;
        $data['dislike'] = $comment->dislike;

        if ($uid > 0) {
            $data['operate'] = [
                'like' => false,
                'dislike' => false,
            ];
            $operates = CommentOperateLog::query()->select('operate')
                ->where('user_id', $uid)->where('comment_id', $id)->get();
            foreach ($operates as $operate) {
                $data['operate'][$operate->operate] = true;
            }
        }

        return $data;
    }

    public static function addReplyCount($id)
    {
        return Comment::query()->where('id', $id)->increment('reply_count');
    }
}