infantServiceApi/app/services/workerman/chat/ChatHandle.php

<?php
// +----------------------------------------------------------------------
// | Chat 消息处理类
// +----------------------------------------------------------------------
namespace app\services\workerman\chat;

use app\services\workerman\Response;
use Workerman\Connection\TcpConnection;

class ChatHandle
{
    protected $service;

    public function __construct(ChatService &$service)
    {
        $this->service = &$service;
    }

    /**
     * 客服登录
     */
    public function kefu_login(TcpConnection &$connection, array $res, Response $response)
    {
        if (!isset($res['data']) || !$token = $res['data']) {
            return $response->close(['msg' => '授权失败!']);
        }

        // TODO: 根据你的系统实现客服token验证
        // 示例：$kefuInfo = your_kefu_auth_service::parseToken($token);
        
        // 临时示例
        $kefuInfo = [
            'uid' => $res['data']['uid'] ?? 1,
            'name' => $res['data']['name'] ?? '客服',
        ];

        $connection->kefuUser = (object)$kefuInfo;
        $connection->user = (object)['uid' => $kefuInfo['uid'], 'nickname' => $kefuInfo['name'] ?? '客服'];
        $this->service->setKefuUser($connection);

        return $response->success();
    }

    /**
     * 用户登录
     */
    public function login(TcpConnection &$connection, array $res, Response $response)
    {
        if (!isset($res['data']) || !$token = $res['data']) {
            return $response->close(['msg' => '授权失败!']);
        }

        // TODO: 根据你的系统实现用户token验证
        // 示例：$authInfo = your_user_auth_service::parseToken($token);
        
        // 临时示例
        $userInfo = [
            'uid' => $res['data']['uid'] ?? 1,
            'nickname' => $res['data']['nickname'] ?? '用户',
            'avatar' => $res['data']['avatar'] ?? '',
        ];

        $connection->user = (object)$userInfo;
        
        // 从 URL 参数获取聊天对象 UID（在 socket.php onWebSocketConnect 中设置）
        $connection->chatToUid = $connection->to_uid ?? 0;
        
        $this->service->setUser($connection);

        return $response->success([
            'msg' => '登录成功',
            'to_uid' => $connection->chatToUid,  // 返回当前聊天对象
        ]);
    }

    /**
     * 发送消息
     */
    public function chat(TcpConnection &$connection, array $res, Response $response)
    {
        // 检查用户是否已登录
        if (!isset($connection->user) || !$connection->user) {
            return $response->send('err_tip', ['msg' => '请先登录']);
        }

        // 优先从消息数据获取 to_uid，其次从 URL 参数获取（聊天对象UID）
        $to_uid = $res['data']['to_uid'] ?? $connection->chatToUid ?? 0;
        $msn = $res['data']['msn'] ?? '';
        $msn_type = $res['data']['type'] ?? 1; // 1=文字, 2=语音, 3=图片

        if (!$to_uid) {
            return $response->send('err_tip', ['msg' => '用户不存在']);
        }

        if ($to_uid == ($connection->user->uid ?? 0)) {
            return $response->send('err_tip', ['msg' => '不能和自己聊天']);
        }

        $uid = $connection->user->uid ?? 0;
        
        $data = [
            'from_uid' => $uid,
            'to_uid' => $to_uid,
            'msn' => $msn,
            'type' => $msn_type,
            'add_time' => time(),
            'nickname' => $connection->user->nickname ?? '用户',
            'avatar' => $connection->user->avatar ?? '',
        ];

        // 给自己回复
        $response->send('chat', $data);

        // 发送给目标用户
        if (isset($this->service->user()[$to_uid])) {
            $response->connection($this->service->user()[$to_uid])->send('reply', $data);
        }
    }
}