hyperf-chat/app/Service/Message/FormatMessageService.php

<?php
declare(strict_types=1);

namespace App\Service\Message;

use App\Cache\VoteCache;
use App\Cache\VoteStatisticsCache;
use App\Constants\TalkMessageType;
use App\Model\Talk\TalkRecordsCode;
use App\Model\Talk\TalkRecordsFile;
use App\Model\Talk\TalkRecordsForward;
use App\Model\Talk\TalkRecordsInvite;
use App\Model\Talk\TalkRecordsLogin;
use App\Model\Talk\TalkRecordsVote;
use App\Model\User;

class FormatMessageService
{
    /**
     * 格式化对话的消息体
     *
     * @param array $data 对话的消息
     * @return array
     */
    private function formatTalkMessage(array $data): array
    {
        $message = [
            "id"           => 0,  // 消息记录ID
            "talk_type"    => 1,  // 消息来源[1:私信;2:群聊]
            "msg_type"     => 1,  // 消息类型
            "user_id"      => 0,  // 发送者用户ID
            "receiver_id"  => 0,  // 接收者ID[好友ID或群ID]

            // 发送消息人的信息
            "nickname"     => '', // 用户昵称
            "avatar"       => '', // 用户头像
            "group_name"   => '', // 群组名称
            "group_avatar" => '', // 群组头像

            // 不同的消息类型
            "file"         => [], // 文件消息
            "code_block"   => [], // 代码消息
            "forward"      => [], // 转发消息
            "invite"       => [], // 邀请消息
            "vote"         => [], // 投票消息
            "login"        => [], // 登录消息

            // 消息创建时间
            "content"      => '', // 文本消息
            "created_at"   => '', // 发送时间

            // 消息属性
            "is_revoke"    => 0,  // 消息是否撤销
            "is_mark"      => 0,  // 消息是否重要
            "is_read"      => 0,  // 消息是否已读
        ];

        return array_merge($message, array_intersect_key($data, $message));
    }

    /**
     * 处理聊天记录信息
     *
     * @param array $rows 聊天记录
     * @return array
     */
    public function handleChatRecords(array $rows): array
    {
        if (!$rows) return [];

        $files = $codes = $forwards = $invites = $votes = $logins = [];
        foreach ($rows as $value) {
            switch ($value['msg_type']) {
                case TalkMessageType::FILE_MESSAGE:
                    $files[] = $value['id'];
                    break;
                case TalkMessageType::GROUP_INVITE_MESSAGE:
                    $invites[] = $value['id'];
                    break;
                case TalkMessageType::FORWARD_MESSAGE:
                    $forwards[] = $value['id'];
                    break;
                case TalkMessageType::CODE_MESSAGE:
                    $codes[] = $value['id'];
                    break;
                case TalkMessageType::VOTE_MESSAGE:
                    $votes[] = $value['id'];
                    break;
                case TalkMessageType::USER_LOGIN_MESSAGE:
                    $logins[] = $value['id'];
                    break;
                default:
            }
        }

        // 查询聊天文件信息
        if ($files) {
            $files = TalkRecordsFile::whereIn('record_id', $files)->get([
                'id', 'record_id', 'user_id', 'source', 'type', 'drive',
                'original_name', 'suffix', 'size', 'path'
            ])->keyBy('record_id')->toArray();
        }

        // 查询群聊邀请信息
        if ($invites) {
            $invites = TalkRecordsInvite::whereIn('record_id', $invites)->get([
                'record_id', 'type', 'operate_user_id', 'user_ids'
            ])->keyBy('record_id')->toArray();
        }

        // 查询代码块消息
        if ($codes) {
            $codes = TalkRecordsCode::whereIn('record_id', $codes)->get([
                'record_id', 'lang', 'code'
            ])->keyBy('record_id')->toArray();
        }

        // 查询消息转发信息
        if ($forwards) {
            $forwards = TalkRecordsForward::whereIn('record_id', $forwards)->get([
                'record_id', 'records_id', 'text'
            ])->keyBy('record_id')->toArray();
        }

        // 查询投票消息
        if ($votes) {
            $votes = TalkRecordsVote::whereIn('record_id', $votes)->get([
                'id', 'record_id', 'title', 'answer_mode', 'status', 'answer_option', 'answer_num', 'answered_num'
            ])->keyBy('record_id')->toArray();
        }

        // 登录消息
        if ($logins) {
            $logins = TalkRecordsLogin::whereIn('record_id', $logins)->get([
                'id', 'record_id', 'ip', 'platform', 'agent', 'address', 'reason', 'created_at'
            ])->keyBy('record_id')->toArray();
        }

        foreach ($rows as $k => $row) {
            $rows[$k]['file']       = [];
            $rows[$k]['code_block'] = [];
            $rows[$k]['forward']    = [];
            $rows[$k]['invite']     = [];
            $rows[$k]['vote']       = [];
            $rows[$k]['login']      = [];

            switch ($row['msg_type']) {
                // 文件消息
                case TalkMessageType::FILE_MESSAGE:
                    $rows[$k]['file'] = $files[$row['id']] ?? [];
                    if ($rows[$k]['file']) {
                        $rows[$k]['file']['file_url'] = get_media_url($rows[$k]['file']['path']);
                    }
                    break;

                // 会话记录消息
                case TalkMessageType::FORWARD_MESSAGE:
                    if (isset($forwards[$row['id']])) {
                        $rows[$k]['forward'] = [
                            'num'  => substr_count($forwards[$row['id']]['records_id'], ',') + 1,
                            'list' => json_decode($forwards[$row['id']]['text'], true) ?? []
                        ];
                    }
                    break;

                // 代码块消息
                case TalkMessageType::CODE_MESSAGE:
                    $rows[$k]['code_block'] = $codes[$row['id']] ?? [];
                    if ($rows[$k]['code_block']) {
                        $rows[$k]['code_block']['code'] = htmlspecialchars_decode($rows[$k]['code_block']['code']);
                        unset($rows[$k]['code_block']['record_id']);
                    }
                    break;

                // 投票消息
                case TalkMessageType::VOTE_MESSAGE:
                    $options = [];
                    foreach ($votes[$row['id']]['answer_option'] as $k2 => $value) {
                        $options[] = [
                            'key'   => $k2,
                            'value' => $value
                        ];
                    }

                    $votes[$row['id']]['answer_option'] = $options;
                    $rows[$k]['vote']                   = [
                        'statistics' => VoteStatisticsCache::getInstance()->getOrSetVoteCache($votes[$row['id']]['id']),
                        'vote_users' => VoteCache::getInstance()->getOrSetCache($votes[$row['id']]['id']),
                        'detail'     => $votes[$row['id']],
                    ];
                    break;

                // 登录消息
                case TalkMessageType::USER_LOGIN_MESSAGE:
                    if (isset($logins[$row['id']])) {
                        $rows[$k]['login'] = $logins[$row['id']];
                    }

                    break;

                // 入群消息/退群消息
                case TalkMessageType::GROUP_INVITE_MESSAGE:
                    if (isset($invites[$row['id']])) {
                        $rows[$k]['invite'] = [
                            'type'         => $invites[$row['id']]['type'],
                            'operate_user' => [
                                'id'       => $invites[$row['id']]['operate_user_id'],
                                'nickname' => User::where('id', $invites[$row['id']]['operate_user_id'])->value('nickname')
                            ],
                            'users'        => []
                        ];

                        if ($rows[$k]['invite']['type'] == 1 || $rows[$k]['invite']['type'] == 3) {
                            $rows[$k]['invite']['users'] = User::select(['id', 'nickname'])->whereIn('id', parse_ids($invites[$row['id']]['user_ids']))->get()->toArray();
                        } else {
                            $rows[$k]['invite']['users'] = $rows[$k]['invite']['operate_user'];
                        }
                    }
                    break;
            }

            $rows[$k] = $this->formatTalkMessage($rows[$k]);
        }

        return $rows;
    }
}