');
        $text = preg_replace("/\<(blockquote|strong|pre|ol|ul|li|em|p|s|u).*?\>/is", "<$1>", $text);    // 不用去除a标签，上面已经处理过了
        $text = preg_replace_callback("/\[:LINK:(.*?):(.*?):\]/i", function (array $match) {
            return "" . base64_decode($match[2]) . "";
        }, $text);
        $text = preg_replace_callback("/\[:IMAGE:(.*?):(.*?):(.*?):(.*?):(.*?):\]/i", function (array $match) {
            $wh = $match[2] === 'auto' ? "" : " width=\"{$match[2]}\" height=\"{$match[3]}\"";
            $src = str_starts_with($match[4], "base64-") ? base64_decode(substr($match[4], 7)) : "{{RemoteURL}}{$match[4]}";
            return "";
        }, $text);
        $text = preg_replace("/\[:@:(.*?):(.*?):\]/i", "@$2", $text);
        $text = preg_replace("/\[:#:(.*?):(.*?):\]/is", "#$2", $text);
        $text = preg_replace("/\[:~:(.*?):(.*?):\]/i", "~$2", $text);
        $text = preg_replace("/\[:QUICK:(.*?):(.*?):\]/i", "$2", $text);
        return preg_replace("/^(
<\/p>)+|(
<\/p>)+$/i", "", $text);
    }

    /**
     * 发送消息、修改消息
     * @param string $action            动作
     * - reply-98：回复消息ID=98
     * - update-99：更新消息ID=99（标记修改）
     * - change-99：更新消息ID=99（不标记修改）
     * - forward-99：转发消息ID=99
     * @param int $dialog_id            会话ID（即 聊天室ID）
     * @param string $type              消息类型
     * @param array $msg                发送的消息
     * @param int|null $sender          发送的会员ID（默认自己，0为系统）
     * @param bool $push_self           推送-是否推给自己
     * @param bool $push_retry          推送-失败后重试1次（有时候在事务里执行，数据还没生成时会出现找不到消息的情况）
     * @param bool|null $push_silence   推送-静默
     * - type = [text|file|record|meeting]  默认为：false
     * @return array
     */
    public static function sendMsg($action, $dialog_id, $type, $msg, $sender = null, $push_self = false, $push_retry = false, $push_silence = null)
    {
        $link = 0;
        $mtype = $type;
        if ($type === 'text') {
            if (str_contains($msg['text'], ' $item) {
                $aiUser = User::whereEmail($matchs[1][$key])->whereDisableAt(null)->first();
                if ($aiUser) {
                    $msg['text'] = str_replace($item, "userid}\">@{$aiUser->nickname}", $msg['text']);
                }
            }
        } elseif ($type === 'file') {
            if (in_array($msg['ext'], ['jpg', 'jpeg', 'webp', 'png', 'gif'])) {
                $mtype = 'image';
            }
        }
        if ($push_silence === null) {
            $push_silence = !in_array($type, ["text", "file", "record", "meeting"]);
        }
        //
        $update_id = preg_match("/^update-(\d+)$/", $action, $match) ? $match[1] : 0;
        $change_id = preg_match("/^change-(\d+)$/", $action, $match) ? $match[1] : 0;
        $reply_id = preg_match("/^reply-(\d+)$/", $action, $match) ? $match[1] : 0;
        $forward_id = preg_match("/^forward-(\d+)-(\d+)$/", $action, $match) ? $match[2] : 0;
        $sender = $sender === null ? User::userid() : $sender;
        //
        $dialog = WebSocketDialog::find($dialog_id);
        if (empty($dialog)) {
            throw new ApiException('获取会话失败');
        }
        if ($sender > 0) {
            $dialog->checkMute($sender);
        }
        //
        $modify = 1;
        if ($change_id) {
            $modify = 0;
            $update_id = $change_id;
        }
        if ($update_id) {
            // 修改
            $dialogMsg = self::whereId($update_id)->whereDialogId($dialog_id)->first();
            if (empty($dialogMsg)) {
                throw new ApiException('消息不存在');
            }
            if ($dialogMsg->type !== 'text' && $dialogMsg->type !== 'vote') {
                throw new ApiException('此消息不支持此操作');
            }
            if ($dialogMsg->userid != $sender && $dialogMsg->type !== 'vote') {
                throw new ApiException('仅支持修改自己的消息');
            }
            //
            $updateData = [
                'mtype' => $mtype,
                'link' => $link,
                'msg' => $msg,
                'modify' => $modify,
            ];
            $dialogMsg->updateInstance($updateData);
            $dialogMsg->key = $dialogMsg->generateMsgKey();
            $dialogMsg->save();
            //
            $dialogMsg->msgJoinGroup($dialog);
            //
            $dialog->pushMsg('update', array_merge($updateData, [
                'id' => $dialogMsg->id
            ]));
            //
            return Base::retSuccess('修改成功', $dialogMsg);
        } else {
            // 发送
            if ($reply_id && !self::whereId($reply_id)->increment('reply_num')) {
                throw new ApiException('回复的消息不存在');
            }
            // 转发
            if ($forward_id && !self::whereId($forward_id)->increment('forward_num')) {
                throw new ApiException('转发的消息不存在');
            }
            //
            $dialogMsg = self::createInstance([
                'dialog_id' => $dialog_id,
                'dialog_type' => $dialog->type,
                'reply_id' => $reply_id,
                'userid' => $sender,
                'type' => $type,
                'mtype' => $mtype,
                'link' => $link,
                'msg' => $msg,
                'read' => 0,
                'forward_id' => $forward_id,
                'forward_show' => $forward_id ? $match[1] : 1,
            ]);
            AbstractModel::transaction(function () use ($dialog, $dialogMsg) {
                $dialog->last_at = Carbon::now();
                $dialog->save();
                $dialogMsg->send = 1;
                $dialogMsg->key = $dialogMsg->generateMsgKey();
                $dialogMsg->save();
                WebSocketDialogUser::whereDialogId($dialog->id)->change(['updated_at' => Carbon::now()->toDateTimeString('millisecond')]);
            });
            //
            $task = new WebSocketDialogMsgTask($dialogMsg->id);
            if ($push_self) {
                $task->setIgnoreFd(null);
            }
            if ($push_retry) {
                $task->setMsgNotExistRetry(true);
            }
            if ($push_silence) {
                $task->setSilence($push_silence);
            }
            Task::deliver($task);
            //
            return Base::retSuccess('发送成功', $dialogMsg);
        }
    }

    /**
     * 将被@的人加入群
     * @param WebSocketDialog $dialog 对话
     * @return array
     */
    public function msgJoinGroup(WebSocketDialog $dialog)
    {
        $updateds = [];
        $silences = [];
        foreach ($dialog->dialogUser as $dialogUser) {
            $updateds[$dialogUser->userid] = $dialogUser->updated_at;
            $silences[$dialogUser->userid] = $dialogUser->silence;
        }
        $userids = array_keys($silences);

        // 提及会员
        $mentions = [];
        if ($this->type === 'text') {
            preg_match_all("//", $this->msg['text'], $matchs);
            if ($matchs) {
                $mentions = array_values(array_filter(array_unique($matchs[1])));
            }
        }

        // 将会话以外的成员加入会话内
        $diffids = array_values(array_diff($mentions, $userids));
        if ($diffids) {
            // 仅(群聊)且(是群主或没有群主)才可以@成员以外的人
            if ($dialog->type === 'group' && in_array($dialog->owner_id, [0, $this->userid])) {
                $dialog->joinGroup($diffids, $this->userid);
                $dialog->pushMsg("groupJoin", null, $diffids);
                $userids = array_values(array_unique(array_merge($mentions, $userids)));
            }
        }

        return compact('updateds', 'silences', 'userids', 'mentions');
    }
}