129 lines
3.8 KiB
PHP
129 lines
3.8 KiB
PHP
<?php
|
|
|
|
namespace Modules\SystemAgent\Http\Controllers;
|
|
|
|
use Illuminate\Http\JsonResponse;
|
|
use Illuminate\Http\Request;
|
|
use Laravel\Ai\Responses\StreamableAgentResponse;
|
|
use Modules\AnnoRoute\Attribute\DeleteRoute;
|
|
use Modules\AnnoRoute\Attribute\GetRoute;
|
|
use Modules\AnnoRoute\Attribute\PostRoute;
|
|
use Modules\AnnoRoute\Attribute\RequestAttribute;
|
|
use Modules\Common\Http\Controllers\BaseController;
|
|
use Modules\SystemAgent\Ai\Agents\XinChatAgent;
|
|
use Modules\SystemAgent\Models\AgentModel;
|
|
|
|
#[RequestAttribute('/ai/chat', 'ai.chat')]
|
|
class ChatController extends BaseController
|
|
{
|
|
/**
|
|
* 发送消息并返回 SSE 流式响应
|
|
*/
|
|
#[PostRoute('/send', 'send')]
|
|
public function send(Request $request): StreamableAgentResponse|JsonResponse
|
|
{
|
|
$request->validate([
|
|
'message' => 'required|string|max:10000',
|
|
'conversation_id' => 'nullable|string|max:36',
|
|
'agent_id' => 'nullable|integer|exists:agents,id',
|
|
]);
|
|
|
|
$message = $request->input('message');
|
|
$conversationId = $request->input('conversation_id');
|
|
$agentId = $request->input('agent_id');
|
|
$user = $request->user();
|
|
|
|
try {
|
|
if ($agentId) {
|
|
$agentModel = AgentModel::findOrFail($agentId);
|
|
$agentClass = $agentModel->namespace;
|
|
$agent = $agentClass::make();
|
|
} else {
|
|
$agent = XinChatAgent::make();
|
|
}
|
|
|
|
if ($conversationId) {
|
|
// 继续已有会话
|
|
$response = $agent
|
|
->continue($conversationId, as: $user)
|
|
->stream($message);
|
|
} else {
|
|
// 新建会话
|
|
$response = $agent
|
|
->forUser($user)
|
|
->stream($message);
|
|
}
|
|
|
|
return $response;
|
|
} catch (\Throwable $e) {
|
|
return $this->error('AI 响应失败：' . $e->getMessage());
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 获取当前用户的会话列表
|
|
*/
|
|
#[GetRoute('/conversations', 'conversations')]
|
|
public function conversations(Request $request): JsonResponse
|
|
{
|
|
$user = $request->user();
|
|
|
|
$conversations = $user->conversations()
|
|
->latest('updated_at')
|
|
->get()
|
|
->map(fn ($conversation) => [
|
|
'key' => $conversation->id,
|
|
'label' => $conversation->title,
|
|
'updated_at' => $conversation->updated_at->toISOString(),
|
|
]);
|
|
|
|
return $this->success($conversations->toArray());
|
|
}
|
|
|
|
/**
|
|
* 获取指定会话的消息列表
|
|
*/
|
|
#[GetRoute('/messages/{conversationId}', 'messages')]
|
|
public function messages(Request $request, string $conversationId): JsonResponse
|
|
{
|
|
$user = $request->user();
|
|
|
|
$conversation = $user->conversations()->find($conversationId);
|
|
|
|
if (! $conversation) {
|
|
return $this->error('会话不存在');
|
|
}
|
|
|
|
$messages = $conversation->messages()
|
|
->oldest()
|
|
->get()
|
|
->map(fn ($msg) => [
|
|
'key' => $msg->id,
|
|
'role' => $msg->role,
|
|
'content' => $msg->content,
|
|
'created_at' => $msg->created_at->toISOString(),
|
|
]);
|
|
|
|
return $this->success($messages->toArray());
|
|
}
|
|
|
|
/**
|
|
* 删除指定会话
|
|
*/
|
|
#[DeleteRoute('/messages/{conversationId}', 'delete')]
|
|
public function deleteConversation(Request $request, string $conversationId): JsonResponse
|
|
{
|
|
$user = $request->user();
|
|
|
|
$conversation = $user->conversations()->find($conversationId);
|
|
|
|
if (! $conversation) {
|
|
return $this->error('会话不存在');
|
|
}
|
|
|
|
$conversation->delete();
|
|
|
|
return $this->success('会话已删除');
|
|
}
|
|
}
|