diff --git a/src/addon/aikefu/api/controller/WebSocket.php b/src/addon/aikefu/api/controller/WebSocket.php
new file mode 100644
index 000000000..416692304
--- /dev/null
+++ b/src/addon/aikefu/api/controller/WebSocket.php
@@ -0,0 +1,972 @@
+params = [];
+ $this->token = '';
+ $this->member_id = 0;
+ $this->site_id = 0;
+ $this->uniacid = 0;
+ $this->app_type = 'weapp'; // 默认微信小程序
+ }
+
+ /**
+ * 当有新客户端连接时调用
+ * @param ConnectionInterface $conn
+ */
+ public function onOpen(ConnectionInterface $conn)
+ {
+ // 存储新连接的客户端
+ $this->clients->attach($conn);
+ $this->clientData[$conn->resourceId] = [
+ 'connection' => $conn,
+ 'site_id' => null,
+ 'member_id' => null,
+ 'token' => null,
+ 'is_authenticated' => false,
+ 'conversation_id' => null,
+ ];
+
+ echo "New connection! ({$conn->resourceId})
+";
+ }
+
+ /**
+ * 当从客户端收到消息时调用
+ * @param ConnectionInterface $conn
+ * @param string $message
+ */
+ public function onMessage(ConnectionInterface $conn, $message)
+ {
+ $numRecv = count($this->clients) - 1;
+ echo sprintf('Connection %d sending message "%s" to %d other connection%s' . "\n",
+ $conn->resourceId, $message, $numRecv, $numRecv == 1 ? '' : 's');
+
+ // 解析消息
+ try {
+ $data = json_decode($message, true);
+ if (json_last_error() !== JSON_ERROR_NONE) {
+ throw new \Exception('Invalid JSON format');
+ }
+
+ // 处理认证
+ if (isset($data['action']) && $data['action'] === 'auth') {
+ $this->handleAuth($conn, $data);
+ return;
+ }
+
+ // 检查是否已认证
+ if (!$this->clientData[$conn->resourceId]['is_authenticated']) {
+ $conn->send(json_encode(['type' => 'error', 'message' => 'Not authenticated']));
+ return;
+ }
+
+ // 处理聊天消息
+ if (isset($data['action']) && $data['action'] === 'chat') {
+ $this->handleChat($conn, $data);
+ return;
+ }
+
+ // 处理心跳
+ if (isset($data['action']) && $data['action'] === 'ping') {
+ $conn->send(json_encode(['type' => 'pong']));
+ return;
+ }
+
+ $conn->send(json_encode(['type' => 'error', 'message' => 'Unknown action']));
+ } catch (\Exception $e) {
+ $conn->send(json_encode(['type' => 'error', 'message' => $e->getMessage()]));
+ }
+ }
+
+ /**
+ * 当客户端连接关闭时调用
+ * @param ConnectionInterface $conn
+ */
+ public function onClose(ConnectionInterface $conn)
+ {
+ // 移除连接
+ $this->clients->detach($conn);
+ unset($this->clientData[$conn->resourceId]);
+
+ echo "Connection {$conn->resourceId} has disconnected\n";
+ }
+
+ /**
+ * 当连接发生错误时调用
+ * @param ConnectionInterface $conn
+ * @param \Exception $e
+ */
+ public function onError(ConnectionInterface $conn, \Exception $e)
+ {
+ echo "An error has occurred: {$e->getMessage()}\n";
+
+ $conn->close();
+ }
+
+ /**
+ * 处理客户端认证
+ * @param ConnectionInterface $conn
+ * @param array $data
+ */
+ protected function handleAuth(ConnectionInterface $conn, $data)
+ {
+ try {
+ $site_id = $data['site_id'] ?? null;
+ $member_id = $data['member_id'] ?? null;
+ $token = $data['token'] ?? null;
+
+ if (empty($site_id) || empty($member_id) || empty($token)) {
+ throw new \Exception('Missing authentication parameters');
+ }
+
+ // 这里可以添加更严格的认证逻辑，例如验证token的有效性
+ // 为了简单起见，我们暂时只检查参数是否存在
+
+ $this->clientData[$conn->resourceId]['site_id'] = $site_id;
+ $this->clientData[$conn->resourceId]['member_id'] = $member_id;
+ $this->clientData[$conn->resourceId]['token'] = $token;
+ $this->clientData[$conn->resourceId]['is_authenticated'] = true;
+
+ $conn->send(json_encode(['type' => 'auth_success', 'message' => 'Authenticated successfully']));
+ } catch (\Exception $e) {
+ $conn->send(json_encode(['type' => 'auth_error', 'message' => $e->getMessage()]));
+ }
+ }
+
+ /**
+ * 处理聊天消息
+ * @param ConnectionInterface $conn
+ * @param array $data
+ */
+ protected function handleChat(ConnectionInterface $conn, $data)
+ {
+ try {
+ $clientInfo = $this->clientData[$conn->resourceId];
+
+ // 获取请求参数
+ $message = $data['message'] ?? '';
+ $user_id = $data['user_id'] ?? $clientInfo['member_id'];
+ $conversation_id = $data['conversation_id'] ?? '';
+ $stream = $data['stream'] ?? true; // WebSocket默认使用流式响应
+
+ // 设置当前控制器的属性
+ $this->site_id = $clientInfo['site_id'];
+ $this->member_id = $clientInfo['member_id'];
+ $this->token = $clientInfo['token'];
+ $this->params = [
+ 'message' => $message,
+ 'user_id' => $user_id,
+ 'conversation_id' => $conversation_id,
+ 'stream' => $stream,
+ ];
+
+ // 验证参数并获取配置
+ $config = $this->validateAndGetConfig([
+ 'message' => ['required' => true, 'message' => '请求参数 `message` 不能为空. 为消息内容', 'description' => '消息内容'],
+ 'user_id' => ['required' => true, 'message' => '请求参数 `user_id` 不能为空', 'description' => '用户ID']
+ ]);
+
+ // 构建请求数据和请求头
+ $requestData = $this->buildRequestData($message, $user_id, $conversation_id, $stream);
+ $headers = $this->buildRequestHeaders($config['api_key']);
+
+ // 发送请求到Dify API
+ $url = $config['base_url'] . $config['chat_endpoint'];
+
+ if ($stream) {
+ // 处理流式响应
+ $this->handleStreamingResponse($conn, $url, $requestData, $headers, $message, $user_id);
+ } else {
+ // 处理非流式响应
+ $response = $this->handleBlockingResponse($url, $requestData, $headers, $message, $user_id, $conversation_id);
+ $conn->send(json_encode(['type' => 'message', 'data' => $response]));
+ }
+ } catch (\Exception $e) {
+ $conn->send(json_encode(['type' => 'error', 'message' => '请求失败：' . $e->getMessage()]));
+ }
+ }
+
+ /**
+ * 处理流式响应
+ * @param ConnectionInterface $conn
+ * @param string $url
+ * @param array $requestData
+ * @param array $headers
+ * @param string $message
+ * @param string $user_id
+ */
+ private function handleStreamingResponse(ConnectionInterface $conn, $url, $requestData, $headers, $message, $user_id)
+ {
+ try {
+ // 记录开始处理流式请求
+ $this->log('AI客服WebSocket流式请求开始处理，用户ID：' . $user_id . '，请求消息：' . $message, 'info');
+
+ // 初始化模型
+ $kefu_conversation_model = new KefuConversationModel();
+ $kefu_message_model = new KefuMessageModel();
+ $site_id = $this->site_id;
+ $current_user_id = $this->member_id;
+
+ // 定义变量
+ $real_conversation_id = '';
+ $real_assistant_message_id = '';
+ $real_user_message_id = '';
+ $assistant_content = '';
+ $user_message_saved = false;
+ $user_message_content = $message;
+ $temp_conversation_id = 'temp_' . uniqid() . '_' . time(); // 临时会话ID，用于失败回滚
+
+ // 立即保存用户消息，使用临时会话ID
+ $this->saveUserMessage($kefu_message_model, $site_id, $current_user_id, $temp_conversation_id, '', $user_message_content);
+ $this->log('用户消息已立即保存，临时会话ID：' . $temp_conversation_id, 'info');
+
+ // 创建或更新临时会话
+ $this->updateOrCreateConversation($kefu_conversation_model, $site_id, $current_user_id, $temp_conversation_id);
+ $this->log('临时会话已创建，ID：' . $temp_conversation_id, 'info');
+
+ // WebSocket消息回调
+ $on_data = function ($data) use (
+ $conn,
+ &$real_conversation_id,
+ &$real_assistant_message_id,
+ &$real_user_message_id,
+ &$assistant_content,
+ &$user_message_saved,
+ $user_message_content,
+ $kefu_message_model,
+ $kefu_conversation_model,
+ $site_id,
+ $current_user_id,
+ $temp_conversation_id
+ ) {
+ try {
+ // 解析Dify的流式响应
+ $lines = explode("\n", $data);
+ foreach ($lines as $line) {
+ $line = trim($line);
+ if (empty($line))
+ continue;
+
+ // 查找以"data: "开头的行
+ if (strpos($line, 'data: ') === 0) {
+ $json_data = substr($line, 6);
+ $event_data = json_decode($json_data, true);
+
+ if (json_last_error() === JSON_ERROR_NONE && isset($event_data['event'])) {
+ $event = $event_data['event'];
+ $this->log('处理AI客服事件：' . $event, 'info');
+
+ switch ($event_data['event']) {
+ case 'message':
+ // LLM返回文本块事件
+ if (isset($event_data['conversation_id'])) {
+ $real_conversation_id = $event_data['conversation_id'];
+ $this->log('获取到会话ID：' . $real_conversation_id, 'info');
+ }
+ if (isset($event_data['message_id'])) {
+ $real_assistant_message_id = $event_data['message_id'];
+ $this->log('获取到助手消息ID：' . $real_assistant_message_id, 'info');
+ }
+ // 积累助手回复内容
+ if (isset($event_data['answer'])) {
+ $assistant_content .= $event_data['answer'];
+ $this->log('积累助手回复内容：' . $event_data['answer'], 'debug');
+
+ // 通过WebSocket发送消息
+ $conn->send(json_encode([
+ 'type' => 'message',
+ 'event' => 'message',
+ 'conversation_id' => $real_conversation_id,
+ 'message_id' => $real_assistant_message_id,
+ 'answer' => $event_data['answer'],
+ 'full_content' => $assistant_content
+ ]));
+
+ // 实时保存助手回复内容（流式过程中）
+ if (!empty($real_conversation_id) && !empty($real_assistant_message_id)) {
+ $this->saveStreamingAssistantMessage($kefu_message_model, $site_id, $current_user_id, $real_conversation_id, $real_assistant_message_id, $assistant_content, 'streaming');
+ $this->log('助手回复内容已实时保存，字数：' . strlen($assistant_content), 'debug');
+ }
+ }
+ // 更新用户消息的会话ID（仅在第一次获取到真实会话ID时）
+ if (!$user_message_saved && !empty($real_conversation_id)) {
+ // 将临时会话ID更新为真实会话ID
+ $kefu_message_model->updateMessage(['conversation_id' => $real_conversation_id], [
+ ['site_id', '=', $site_id],
+ ['user_id', '=', $current_user_id],
+ ['conversation_id', '=', $temp_conversation_id],
+ ['role', '=', 'user']
+ ]);
+
+ $kefu_conversation_model->updateConversation(['conversation_id' => $real_conversation_id], [
+ ['site_id', '=', $site_id],
+ ['user_id', '=', $current_user_id],
+ ['conversation_id', '=', $temp_conversation_id]
+ ]);
+
+ $user_message_saved = true;
+ $this->log('用户消息会话ID已更新为真实ID：' . $real_conversation_id, 'info');
+ }
+ break;
+
+ case 'agent_message':
+ // Agent模式下返回文本块事件
+ if (isset($event_data['conversation_id'])) {
+ $real_conversation_id = $event_data['conversation_id'];
+ $this->log('获取到Agent模式会话ID：' . $real_conversation_id, 'info');
+ }
+ if (isset($event_data['message_id'])) {
+ $real_assistant_message_id = $event_data['message_id'];
+ $this->log('获取到Agent模式助手消息ID：' . $real_assistant_message_id, 'info');
+ }
+ // 积累助手回复内容
+ if (isset($event_data['answer'])) {
+ $assistant_content .= $event_data['answer'];
+ $this->log('积累Agent回复内容：' . $event_data['answer'], 'debug');
+
+ // 通过WebSocket发送消息
+ $conn->send(json_encode([
+ 'type' => 'message',
+ 'event' => 'agent_message',
+ 'conversation_id' => $real_conversation_id,
+ 'message_id' => $real_assistant_message_id,
+ 'answer' => $event_data['answer'],
+ 'full_content' => $assistant_content
+ ]));
+
+ // 实时保存助手回复内容（Agent模式流式过程中）
+ if (!empty($real_conversation_id) && !empty($real_assistant_message_id)) {
+ $this->saveStreamingAssistantMessage($kefu_message_model, $site_id, $current_user_id, $real_conversation_id, $real_assistant_message_id, $assistant_content, 'streaming');
+ $this->log('Agent模式助手回复内容已实时保存，字数：' . strlen($assistant_content), 'debug');
+ }
+ }
+ // 更新用户消息的会话ID（仅在第一次获取到真实会话ID时）
+ if (!$user_message_saved && !empty($real_conversation_id)) {
+ // 将临时会话ID更新为真实会话ID
+ $kefu_message_model->updateMessage(['conversation_id' => $real_conversation_id], [
+ ['site_id', '=', $site_id],
+ ['user_id', '=', $current_user_id],
+ ['conversation_id', '=', $temp_conversation_id],
+ ['role', '=', 'user']
+ ]);
+
+ $kefu_conversation_model->updateConversation(['conversation_id' => $real_conversation_id], [
+ ['site_id', '=', $site_id],
+ ['user_id', '=', $current_user_id],
+ ['conversation_id', '=', $temp_conversation_id]
+ ]);
+
+ $user_message_saved = true;
+ $this->log('Agent模式下用户消息会话ID已更新为真实ID：' . $real_conversation_id, 'info');
+ }
+ break;
+
+ case 'agent_thought':
+ if (isset($event_data['thought'])) {
+ // 格式化思考过程
+ $thought_content = "\n[思考过程]: " . $event_data['thought'];
+ if (isset($event_data['tool'])) {
+ $thought_content .= "\n[使用工具]: " . $event_data['tool'];
+ }
+ if (isset($event_data['observation'])) {
+ $thought_content .= "\n[观察结果]: " . $event_data['observation'];
+ }
+ $assistant_content .= $thought_content;
+ $this->log('Agent思考过程：' . $thought_content, 'debug');
+
+ // 通过WebSocket发送思考过程
+ $conn->send(json_encode([
+ 'type' => 'message',
+ 'event' => 'agent_thought',
+ 'thought' => $event_data['thought'],
+ 'tool' => $event_data['tool'] ?? null,
+ 'observation' => $event_data['observation'] ?? null
+ ]));
+ }
+ break;
+
+ case 'file':
+ if (isset($event_data['id']) && isset($event_data['type']) && isset($event_data['url'])) {
+ $file_id = $event_data['id'];
+ $file_type = $event_data['type'];
+ $file_url = $event_data['url'];
+ // 可以将文件信息作为特殊内容添加到回复中
+ $file_content = "\n[文件]: " . $file_type . " - " . $file_url;
+ $assistant_content .= $file_content;
+ $this->log('收到文件事件：' . $file_type . ' - ' . $file_url, 'info');
+
+ // 通过WebSocket发送文件信息
+ $conn->send(json_encode([
+ 'type' => 'message',
+ 'event' => 'file',
+ 'id' => $file_id,
+ 'type' => $file_type,
+ 'url' => $file_url
+ ]));
+ }
+ break;
+
+ case 'message_start':
+ if (isset($event_data['conversation_id'])) {
+ $real_conversation_id = $event_data['conversation_id'];
+ $this->log('消息开始事件，会话ID：' . $real_conversation_id, 'info');
+
+ // 通过WebSocket发送消息开始事件
+ $conn->send(json_encode([
+ 'type' => 'message',
+ 'event' => 'message_start',
+ 'conversation_id' => $real_conversation_id
+ ]));
+ }
+ break;
+
+ case 'message_delta':
+ if (isset($event_data['delta']['content'])) {
+ $assistant_content .= $event_data['delta']['content'];
+ $this->log('积累增量内容：' . $event_data['delta']['content'], 'debug');
+
+ // 通过WebSocket发送增量内容
+ $conn->send(json_encode([
+ 'type' => 'message',
+ 'event' => 'message_delta',
+ 'delta' => $event_data['delta'],
+ 'full_content' => $assistant_content
+ ]));
+
+ // 实时保存助手回复内容（增量流式过程中）
+ if (!empty($real_conversation_id) && !empty($real_assistant_message_id)) {
+ $this->saveStreamingAssistantMessage($kefu_message_model, $site_id, $current_user_id, $real_conversation_id, $real_assistant_message_id, $assistant_content, 'streaming');
+ $this->log('助手增量回复内容已实时保存，字数：' . strlen($assistant_content), 'debug');
+ }
+ }
+ break;
+
+ case 'message_end':
+ // 最终内容已通过message或message_delta事件积累
+ $this->log('消息结束事件，会话ID：' . $real_conversation_id . '，消息ID：' . $real_assistant_message_id, 'info');
+
+ // 通过WebSocket发送消息结束事件
+ $conn->send(json_encode([
+ 'type' => 'message',
+ 'event' => 'message_end',
+ 'conversation_id' => $real_conversation_id,
+ 'message_id' => $real_assistant_message_id,
+ 'content' => $assistant_content
+ ]));
+ break;
+
+ case 'error':
+ $error_message = isset($event_data['message']) ? $event_data['message'] : '流式输出异常';
+ $assistant_content .= "\n[错误]: " . $error_message;
+ $this->log('AI客服错误事件：' . $error_message, 'error');
+
+ // 通过WebSocket发送错误事件
+ $conn->send(json_encode([
+ 'type' => 'message',
+ 'event' => 'error',
+ 'message' => $error_message
+ ]));
+ break;
+
+ case 'ping':
+ // 保持连接存活的ping事件
+ // 无需特殊处理，继续保持连接
+ $this->log('收到ping事件', 'debug');
+ break;
+ }
+ } else {
+ $this->log('AI客服事件解析失败：' . $json_data, 'error');
+ }
+ }
+ }
+ } catch (\Exception $e) {
+ $this->log('AI客服事件处理异常：' . $e->getMessage(), 'error');
+ $conn->send(json_encode(['type' => 'error', 'message' => $e->getMessage()]));
+ }
+ };
+
+ // 错误处理回调函数
+ $on_error = function ($error) use ($user_id, $conn) {
+ $this->log('AI客服请求错误，用户ID：' . $user_id . '，错误信息：' . json_encode($error), 'error');
+ $conn->send(json_encode(['type' => 'error', 'message' => $error]));
+ };
+
+ // 调用curl流式请求
+ $this->curlRequestStreaming($url, 'POST', $requestData, $headers, $on_data, $on_error);
+ $this->log('AI客服请求成功，用户ID：' . $user_id . '，会话ID：' . $real_conversation_id, 'info');
+
+ // 数据流结束时发送明确的"done"事件
+ $done_data = [
+ 'conversation_id' => $real_conversation_id,
+ 'message_id' => $real_assistant_message_id,
+ 'content' => $assistant_content,
+ ];
+ $conn->send(json_encode(['type' => 'message', 'event' => 'done', 'data' => $done_data]));
+
+ // 流式正常完成，标记助手消息为已完成状态
+ if (!empty($real_conversation_id) && !empty($real_assistant_message_id) && !empty($assistant_content)) {
+ $this->saveStreamingAssistantMessage($kefu_message_model, $site_id, $current_user_id, $real_conversation_id, $real_assistant_message_id, $assistant_content, 'completed');
+ $this->log('AI客服回复已标记为完成状态，会话ID：' . $real_conversation_id . '，总字数：' . strlen($assistant_content), 'info');
+ }
+
+ // 清理临时数据
+ $this->cleanupTempData($kefu_message_model, $kefu_conversation_model, $site_id, $current_user_id, $temp_conversation_id);
+
+ } catch (\Exception $e) {
+ $error_msg = 'AI客服请求异常：' . $e->getMessage() . '，错误行：' . $e->getLine() . '，错误文件：' . $e->getFile();
+ $this->log($error_msg, 'error');
+ $conn->send(json_encode(['type' => 'error', 'message' => $error_msg]));
+
+ // 异常时清理临时数据
+ try {
+ $kefu_conversation_model = new KefuConversationModel();
+ $kefu_message_model = new KefuMessageModel();
+ $site_id = $this->site_id;
+ $current_user_id = $this->member_id;
+ $this->cleanupTempData($kefu_message_model, $kefu_conversation_model, $site_id, $current_user_id, $temp_conversation_id);
+ } catch (\Exception $cleanupException) {
+ $this->log('清理临时数据时也发生异常：' . $cleanupException->getMessage(), 'error');
+ }
+ }
+ }
+
+ /**
+ * 通用的curl流式请求函数
+ * @param string $url 请求URL
+ * @param string $method 请求方法
+ * @param array $data 请求数据
+ * @param array $headers 请求头
+ * @param callable|null $on_data 数据回调函数，接收原始数据
+ * @param callable|null $on_error 错误回调函数，接收错误信息
+ * @return bool 请求是否成功
+ */
+ private function curlRequestStreaming($url, $method = 'GET', $data = [], $headers = [], $on_data = null, $on_error = null)
+ {
+ try {
+ $ch = curl_init();
+
+ // 设置URL
+ curl_setopt($ch, CURLOPT_URL, $url);
+
+ // 设置请求方法
+ curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method);
+
+ // 设置POST数据
+ if ($method === 'POST' && !empty($data)) {
+ curl_setopt($ch, CURLOPT_POSTFIELDS, is_array($data) ? json_encode($data) : $data);
+ }
+
+ // 设置请求头
+ if (!empty($headers)) {
+ curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
+ } else {
+ // 默认请求头
+ curl_setopt($ch, CURLOPT_HTTPHEADER, [
+ 'Content-Type: application/json',
+ ]);
+ }
+
+ // 设置cURL选项以支持流式输出
+ curl_setopt($ch, CURLOPT_RETURNTRANSFER, false); // 不返回结果，直接输出
+ curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
+ curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
+ curl_setopt($ch, CURLOPT_TIMEOUT, 0); // 无超时限制，适用于长时间流式响应
+ curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 30);
+ curl_setopt($ch, CURLOPT_WRITEFUNCTION, function ($curl, $data) use ($on_data) {
+ // 调用自定义数据处理回调
+ if (is_callable($on_data)) {
+ $on_data($data);
+ }
+
+ return strlen($data);
+ });
+
+ // 执行请求并流式输出响应
+ curl_exec($ch);
+
+ if (curl_errno($ch)) {
+ $error = curl_error($ch);
+ $this->log('Curl请求错误：' . $error, 'error');
+
+ if (is_callable($on_error)) {
+ $on_error($error);
+ }
+ curl_close($ch);
+ return false;
+ }
+
+ curl_close($ch);
+ return true;
+ } catch (\Exception $e) {
+ $this->log(json_encode(["event" => "error", "data" => $e->getMessage(), "line" => $e->getLine(), "file" => $e->getFile()]), 'error');
+ if (is_callable($on_error)) {
+ $on_error($e->getMessage());
+ }
+ return false;
+ }
+ }
+
+ /**
+ * 封装curl请求方法
+ * @param string $url 请求URL
+ * @param string $method 请求方法
+ * @param array $data 请求数据
+ * @param array $headers 请求头
+ * @return string 响应内容
+ */
+ private function curlRequest($url, $method = 'GET', $data = [], $headers = [])
+ {
+ $ch = curl_init();
+
+ // 设置URL
+ curl_setopt($ch, CURLOPT_URL, $url);
+
+ // 设置请求方法
+ curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method);
+
+ // 设置POST数据
+ if ($method === 'POST' && !empty($data)) {
+ curl_setopt($ch, CURLOPT_POSTFIELDS, is_array($data) ? json_encode($data) : $data);
+ }
+
+ // 设置请求头
+ if (!empty($headers)) {
+ curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
+ }
+
+ // 设置返回值
+ curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
+ curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
+ curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
+ curl_setopt($ch, CURLOPT_TIMEOUT, 30);
+
+ // 执行请求
+ $response = curl_exec($ch);
+ $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
+
+ // 关闭连接
+ curl_close($ch);
+
+ if ($response === false) {
+ throw new \Exception('Curl请求失败');
+ }
+
+ if ($httpCode >= 400) {
+ throw new \Exception('HTTP请求失败，状态码：' . $httpCode);
+ }
+
+ return $response;
+ }
+
+ /**
+ * 验证参数并获取配置
+ * @param array $params_rules 参数验证规则
+ * @return array
+ * @throws \Exception
+ */
+ private function validateAndGetConfig($params_rules = [])
+ {
+ // 参数验证规则
+ $rules = [];
+
+ // 合并参数验证规则
+ $rules = array_merge($rules, $params_rules);
+
+ // 验证参数
+ foreach ($rules as $field => $rule) {
+ if (isset($rule['required']) && $rule['required'] && empty($this->params[$field])) {
+ throw new \Exception($rule['message']);
+ }
+ }
+
+ // 获取智能客服配置
+ $kefu_config_model = new KefuConfigModel();
+ $config_info = $kefu_config_model->getConfig($this->site_id)['data']['value'] ?? [];
+
+ if (empty($config_info) || $config_info['status'] != 1) {
+ throw new \Exception('智能客服暂未启用');
+ }
+
+ return $config_info;
+ }
+
+ /**
+ * 构建请求数据
+ * @param string $message 用户消息
+ * @param string $user_id 用户ID
+ * @param string $conversation_id 会话ID
+ * @param bool $stream 是否使用流式响应
+ * @return array
+ */
+ private function buildRequestData($message, $user_id, $conversation_id, $stream)
+ {
+ $requestData = [
+ 'inputs' => [],
+ 'query' => $message,
+ 'response_mode' => $stream ? 'streaming' : 'blocking',
+ 'user' => $user_id,
+ ];
+
+ // 如果有会话ID，添加到请求中
+ if (!empty($conversation_id)) {
+ $requestData['conversation_id'] = $conversation_id;
+ }
+
+ return $requestData;
+ }
+
+ /**
+ * 构建请求头
+ * @param string $api_key API密钥
+ * @return array
+ */
+ private function buildRequestHeaders($api_key)
+ {
+ return [
+ 'Content-Type: application/json',
+ 'Authorization: Bearer ' . $api_key,
+ ];
+ }
+
+ /**
+ * 保存用户消息
+ * @param KefuMessageModel $message_model 消息模型
+ * @param string $site_id 站点ID
+ * @param string $user_id 用户ID
+ * @param string $conversation_id 会话ID
+ * @param string $message_id 消息ID
+ * @param string $content 消息内容
+ * @return void
+ */
+ private function saveUserMessage($message_model, $site_id, $user_id, $conversation_id, $message_id, $content)
+ {
+ $message_model->addMessage([
+ 'site_id' => $site_id,
+ 'user_id' => $user_id,
+ 'conversation_id' => $conversation_id,
+ 'message_id' => $message_id,
+ 'role' => 'user',
+ 'content' => $content,
+ ]);
+ }
+
+ /**
+ * 保存助手消息
+ * @param KefuMessageModel $message_model 消息模型
+ * @param string $site_id 站点ID
+ * @param string $user_id 用户ID
+ * @param string $conversation_id 会话ID
+ * @param string $message_id 消息ID
+ * @param string $content 消息内容
+ * @return void
+ */
+ private function saveAssistantMessage($message_model, $site_id, $user_id, $conversation_id, $message_id, $content)
+ {
+ $message_model->addMessage([
+ 'site_id' => $site_id,
+ 'user_id' => $user_id,
+ 'conversation_id' => $conversation_id,
+ 'message_id' => $message_id,
+ 'role' => 'assistant',
+ 'content' => $content,
+ ]);
+ }
+
+ /**
+ * 更新或创建会话
+ * @param KefuConversationModel $conversation_model 会话模型
+ * @param string $site_id 站点ID
+ * @param string $user_id 用户ID
+ * @param string $conversation_id 会话ID
+ * @return void
+ */
+ private function updateOrCreateConversation($conversation_model, $site_id, $user_id, $conversation_id)
+ {
+ $conversation_info = $conversation_model->getConversationInfo([
+ ['site_id', '=', $site_id],
+ ['user_id', '=', $user_id],
+ ['conversation_id', '=', $conversation_id],
+ ]);
+
+ if (empty($conversation_info['data'])) {
+ // 创建新会话
+ $conversation_model->addConversation([
+ 'site_id' => $site_id,
+ 'user_id' => $user_id,
+ 'conversation_id' => $conversation_id,
+ 'name' => '智能客服会话',
+ ]);
+ } else {
+ // 更新会话状态
+ $conversation_model->updateConversation([
+ 'status' => 1,
+ 'update_time' => date('Y-m-d H:i:s')
+ ], [
+ ['id', '=', $conversation_info['data']['id']],
+ ]);
+ }
+ }
+
+ /**
+ * 实时保存助手消息内容（流式过程中）
+ * @param KefuMessageModel $message_model 消息模型
+ * @param string $site_id 站点ID
+ * @param string $user_id 用户ID
+ * @param string $conversation_id 会话ID
+ * @param string $message_id 消息ID
+ * @param string $content 消息内容
+ * @param string $status 消息状态：streaming（流式中）、completed（已完成）
+ * @return void
+ */
+ private function saveStreamingAssistantMessage($message_model, $site_id, $user_id, $conversation_id, $message_id, $content, $status = 'streaming')
+ {
+ // 检查是否已存在该消息（用于更新）
+ $existing_message = $message_model->getMessageInfo([
+ ['site_id', '=', $site_id],
+ ['user_id', '=', $user_id],
+ ['conversation_id', '=', $conversation_id],
+ ['message_id', '=', $message_id],
+ ['role', '=', 'assistant']
+ ]);
+
+ $message_data = [
+ 'site_id' => $site_id,
+ 'user_id' => $user_id,
+ 'conversation_id' => $conversation_id,
+ 'message_id' => $message_id,
+ 'role' => 'assistant',
+ 'content' => $content,
+ 'status' => $status, // 新增状态字段
+ 'update_time' => date('Y-m-d H:i:s')
+ ];
+
+ if (empty($existing_message['data'])) {
+ // 新增消息
+ $message_model->addMessage($message_data);
+ } else {
+ // 更新消息内容
+ $message_model->updateMessage($message_data, [
+ ['site_id', '=', $site_id],
+ ['user_id', '=', $user_id],
+ ['conversation_id', '=', $conversation_id],
+ ['message_id', '=', $message_id],
+ ['role', '=', 'assistant']
+ ]);
+ }
+ }
+
+ /**
+ * 清理临时消息和会话
+ * @param KefuMessageModel $message_model 消息模型
+ * @param KefuConversationModel $conversation_model 会话模型
+ * @param string $site_id 站点ID
+ * @param string $user_id 用户ID
+ * @param string $temp_conversation_id 临时会话ID
+ * @return void
+ */
+ private function cleanupTempData($message_model, $conversation_model, $site_id, $user_id, $temp_conversation_id)
+ {
+ // 删除临时消息
+ $message_model->deleteMessage([
+ ['site_id', '=', $site_id],
+ ['user_id', '=', $user_id],
+ ['conversation_id', '=', $temp_conversation_id]
+ ]);
+
+ // 删除临时会话
+ $conversation_model->deleteConversation([
+ ['site_id', '=', $site_id],
+ ['user_id', '=', $user_id],
+ ['conversation_id', '=', $temp_conversation_id]
+ ]);
+
+ $this->log('临时数据已清理，会话ID：' . $temp_conversation_id, 'info');
+ }
+
+ /**
+ * 日志记录封装方法
+ * @param string $message 日志内容
+ * @param string $level 日志级别，默认为info
+ * @return void
+ */
+ private function log($message, $level = 'info')
+ {
+ // 只允许info、error级别
+ if (!in_array($level, ['info', 'error'])) {
+ return;
+ }
+ log_write($message, $level, '', 2);
+ }
+
+ /**
+ * 处理非流式响应
+ * @param string $url 请求URL
+ * @param array $requestData 请求数据
+ * @param array $headers 请求头
+ * @param string $message 用户消息
+ * @param string $user_id 用户ID
+ * @param string $conversation_id 会话ID
+ * @return array
+ * @throws \Exception
+ */
+ private function handleBlockingResponse($url, $requestData, $headers, $message, $user_id, $conversation_id)
+ {
+ // 发送请求
+ $response = $this->curlRequest($url, 'POST', $requestData, $headers);
+ $response_data = json_decode($response, true);
+
+ // 初始化模型
+ $kefu_conversation_model = new KefuConversationModel();
+ $kefu_message_model = new KefuMessageModel();
+ $site_id = $this->site_id;
+ $current_user_id = $this->member_id;
+
+ // 保存用户消息
+ $this->saveUserMessage($kefu_message_model, $site_id, $current_user_id, $conversation_id, '', $message);
+
+ // 更新或创建会话
+ $real_conversation_id = $response_data['conversation_id'] ?? $conversation_id;
+ $this->updateOrCreateConversation($kefu_conversation_model, $site_id, $current_user_id, $real_conversation_id);
+
+ // 保存助手消息
+ $assistant_content = $response_data['answer'] ?? '';
+ $real_assistant_message_id = $response_data['message_id'] ?? '';
+ $this->saveAssistantMessage($kefu_message_model, $site_id, $current_user_id, $real_conversation_id, $real_assistant_message_id, $assistant_content);
+
+ // 返回响应
+ return [
+ 'conversation_id' => $real_conversation_id,
+ 'message_id' => $real_assistant_message_id,
+ 'content' => $assistant_content,
+ 'answer' => $assistant_content,
+ 'status' => 'completed'
+ ];
+ }
+}
\ No newline at end of file
diff --git a/src/addon/aikefu/docs/ws_multi_addon_test.html b/src/addon/aikefu/docs/ws_multi_addon_test.html
new file mode 100644
index 000000000..ee3961f5e
--- /dev/null
+++ b/src/addon/aikefu/docs/ws_multi_addon_test.html
@@ -0,0 +1,223 @@
+
+
+
+
+
+ WebSocket多addon测试
+
+
+
+
+
WebSocket多addon测试
+
+
+
+
aikefu Addon (ws://localhost:8080/ws/aikefu)
+
未连接
+
+
+
+
+
+
+
+
+
+
默认路径 (ws://localhost:8080/ws)
+
未连接
+
+
+
+
+
+
+