hyperf-chat/app/Service/TalkSessionService.php

<?php
declare(strict_types=1);

namespace App\Service;

use App\Cache\LastMessage;
use App\Cache\ServerRunID;
use App\Cache\UnreadTalkCache;
use App\Constant\TalkModeConstant;
use App\Model\Talk\TalkSession;
use App\Repository\Talk\TalkSessionRepository;
use Carbon\Carbon;

class TalkSessionService extends BaseService
{
    /**
     * @var TalkSessionRepository
     */
    private $repository;

    public function __construct(TalkSessionRepository $repository)
    {
        $this->repository = $repository;
    }

    /**
     * 创建聊天列表记录
     *
     * @param int  $user_id     用户ID
     * @param int  $receiver_id 接收者ID
     * @param int  $talk_type   创建类型[1:私聊;2:群聊;]
     * @param bool $is_robot
     * @return array
     */
    public function create(int $user_id, int $receiver_id, int $talk_type, bool $is_robot = false): array
    {
        $result = $this->repository->updateOrCreate([
            'talk_type'   => $talk_type,
            'user_id'     => $user_id,
            'receiver_id' => $receiver_id,
        ], [
            'is_top'     => 0,
            'is_delete'  => 0,
            'is_disturb' => 0,
            'is_robot'   => intval($is_robot),
        ]);

        return [
            'id'          => $result->id,
            'talk_type'   => $result->talk_type,
            'receiver_id' => $result->receiver_id,
        ];
    }

    /**
     * 聊天对话列表置顶操作
     *
     * @param int  $user_id    用户ID
     * @param int  $session_id 会话列表ID
     * @param bool $is_top     是否置顶（true:是 false:否）
     * @return bool
     */
    public function top(int $user_id, int $session_id, bool $is_top = true): bool
    {
        return (bool)$this->repository->update(['id' => $session_id, 'user_id' => $user_id], ['is_top' => $is_top ? 1 : 0]);
    }

    /**
     * 删除会话列表
     *
     * @param int $user_id    用户ID
     * @param int $session_id 会话列表ID
     * @return bool
     */
    public function delete(int $user_id, int $session_id): bool
    {
        return (bool)$this->repository->update(['id' => $session_id, 'user_id' => $user_id], ['is_delete' => 1]);
    }

    /**
     * 删除会话列表
     *
     * @param int $user_id     用户ID
     * @param int $receiver_id 接受者ID
     * @param int $talk_type   对话类型
     * @return bool
     */
    public function deleteByType(int $user_id, int $receiver_id, int $talk_type): bool
    {
        return (bool)$this->repository->update(['user_id' => $user_id, 'talk_type' => $talk_type, 'receiver_id' => $receiver_id], ['is_delete' => 1]);
    }

    /**
     * 获取用户的聊天列表
     *
     * @param int $user_id 用户ID
     * @return array
     */
    public function getTalkList(int $user_id): array
    {
        $filed = [
            'list.id', 'list.talk_type', 'list.receiver_id', 'list.updated_at', 'list.is_disturb', 'list.is_top', 'list.is_robot',
            'users.avatar as user_avatar', 'users.nickname',
            'group.group_name', 'group.avatar as group_avatar'
        ];

        $rows = TalkSession::from('talk_session as list')
            ->leftJoin('users', function ($join) {
                $join->on('users.id', '=', 'list.receiver_id')->where('list.talk_type', '=', TalkModeConstant::PRIVATE_CHAT);
            })
            ->leftJoin('group', function ($join) {
                $join->on('group.id', '=', 'list.receiver_id')->where('list.talk_type', '=', TalkModeConstant::GROUP_CHAT);
            })
            ->where('list.user_id', $user_id)
            ->where('list.is_delete', 0)
            ->orderBy('list.updated_at', 'desc')
            ->get($filed)
            ->toArray();

        if (!$rows) return [];

        $runIdAll = ServerRunID::getInstance()->getServerRunIdAll();
        return array_map(function ($item) use ($user_id, $runIdAll) {
            $data = TalkSession::item([
                'id'          => $item['id'],
                'talk_type'   => $item['talk_type'],
                'receiver_id' => $item['receiver_id'],
                'is_top'      => $item['is_top'],
                'is_disturb'  => $item['is_disturb'],
                'is_robot'    => $item['is_robot'],
                'updated_at'  => Carbon::parse($item['updated_at'])->toDateTimeString(),
            ]);

            if ($item['talk_type'] == TalkModeConstant::PRIVATE_CHAT) {
                $data['name']        = $item['nickname'];
                $data['avatar']      = $item['user_avatar'];
                $data['unread_num']  = UnreadTalkCache::getInstance()->read($item['receiver_id'], $user_id);
                $data['is_online']   = (int)di()->get(SocketClientService::class)->isOnlineAll($item['receiver_id'], $runIdAll);
                $data['remark_name'] = di()->get(UserFriendService::class)->getFriendRemark($user_id, $item['receiver_id']);
            } else if (TalkModeConstant::GROUP_CHAT) {
                $data['name']   = strval($item['group_name']);
                $data['avatar'] = $item['group_avatar'];
            }

            $records = LastMessage::getInstance()->read($data['talk_type'], $user_id, $data['receiver_id']);
            if ($records) {
                $data['msg_text']   = $records['text'];
                $data['updated_at'] = $records['created_at'];
            }

            return $data;
        }, $rows);
    }

    /**
     * 设置消息免打扰
     *
     * @param int $user_id     用户ID
     * @param int $receiver_id 接收者ID
     * @param int $talk_type   对话类型[1:私信;2:群聊;]
     * @param int $is_disturb  是否免打扰[0:否;1:是;]
     * @return boolean
     */
    public function disturb(int $user_id, int $receiver_id, int $talk_type, int $is_disturb): bool
    {
        $result = $this->repository->first([
            'user_id'     => $user_id,
            'talk_type'   => $talk_type,
            'receiver_id' => $receiver_id,
        ], ['id', 'is_disturb']);

        if (!$result || $is_disturb == $result->is_disturb) {
            return false;
        }

        return (bool)$this->repository->update(['id' => $result->id], ['is_disturb' => $is_disturb]);
    }

    /**
     * 判断是否消息免打扰
     *
     * @param int $user_id     用户ID
     * @param int $receiver_id 接收者ID
     * @param int $talk_type   对话类型[1:私信;2:群聊;]
     * @return bool
     */
    public function isDisturb(int $user_id, int $receiver_id, int $talk_type): bool
    {
        return (bool)$this->repository->value([
            'user_id'     => $user_id,
            'talk_type'   => $talk_type,
            'receiver_id' => $receiver_id,
        ], "is_disturb");
    }
}