chatroom/app/Http/Controllers/ChatBotController.php

<?php

/**
 * 文件功能：聊天机器人控制器
 *
 * 处理用户与 AI 机器人的对话请求。
 * 先检查全局开关（sysparam: chatbot_enabled），再调用 AiChatService 获取回复。
 *
 * @author   ChatRoom Laravel
 *
 * @version  1.0.0
 */

namespace App\Http\Controllers;

use App\Enums\CurrencySource;
use App\Events\MessageSent;
use App\Jobs\SaveMessageJob;
use App\Models\Sysparam;
use App\Services\AiChatService;
use App\Services\ChatStateService;
use App\Services\UserCurrencyService;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\Redis;

class ChatBotController extends Controller
{
    /**
     * 构造函数：注入 AI 聊天服务和聊天状态服务
     */
    public function __construct(
        private readonly AiChatService $aiChat,
        private readonly ChatStateService $chatState,
        private readonly UserCurrencyService $currencyService,
    ) {}

    /**
     * 与 AI 机器人对话
     *
     * 接收用户消息，检查全局开关后调用 AI 服务获取回复。
     * 支持自动故障转移：默认厂商失败时自动尝试备用厂商。
     *
     * @param  Request  $request  请求对象，需包含 message 和 room_id
     * @return JsonResponse 机器人回复或错误信息
     */
    public function chat(Request $request): JsonResponse
    {
        // 验证请求参数
        $request->validate([
            'message' => 'required|string|max:2000',
            'room_id' => 'required|integer',
        ]);

        // 检查全局开关
        $enabled = Sysparam::getValue('chatbot_enabled', '0');
        if ($enabled !== '1') {
            return response()->json([
                'status' => 'error',
                'message' => 'AI 机器人功能已关闭，请联系管理员开启。',
            ], 403);
        }

        $user = Auth::user();
        $message = $request->input('message');
        $roomId = $request->input('room_id');

        try {
            // 先广播用户的提问消息
            $userMsg = [
                'id' => $this->chatState->nextMessageId($roomId),
                'room_id' => $roomId,
                'from_user' => $user->username,
                'to_user' => 'AI小班长',
                'content' => $message,
                'is_secret' => false,
                'font_color' => '#000000',
                'action' => '',
                'sent_at' => now()->toDateTimeString(),
            ];
            $this->chatState->pushMessage($roomId, $userMsg);
            broadcast(new MessageSent($roomId, $userMsg));
            SaveMessageJob::dispatch($userMsg);

            $result = $this->aiChat->chat($user->id, $message, $roomId);

            $reply = $result['reply'];

            // 检查 AI 是否决定给用户发金币
            if (str_contains($reply, '[ACTION:GIVE_GOLD]')) {
                $reply = str_replace('[ACTION:GIVE_GOLD]', '', $reply);
                $reply = trim($reply);

                $redisKey = 'ai_chat:give_gold:'.date('Ymd').':'.$user->id;
                // 原子操作，防止并发多次领取
                if (Redis::setnx($redisKey, 1)) {
                    Redis::expire($redisKey, 86400); // 缓存 24 小时

                    // 给用户发放随机 100~5000 金币
                    $goldAmount = rand(100, 5000);
                    $this->currencyService->change(
                        $user,
                        'gold',
                        $goldAmount,
                        CurrencySource::AI_GIFT,
                        'AI小班长发善心赠送的金币福利',
                        $roomId
                    );

                    // 发送全场大广播
                    $sysMsg = [
                        'id' => $this->chatState->nextMessageId($roomId),
                        'room_id' => $roomId,
                        'from_user' => '系统传音',
                        'to_user' => '大家',
                        'content' => "🤖 听闻小萌新哭穷，AI小班长看【{$user->username}】骨骼惊奇，大方地赏赐了 {$goldAmount} 枚金币福利！",
                        'is_secret' => false,
                        'font_color' => '#d97706', // 橙色醒目
                        'action' => '大声宣告',
                        'sent_at' => now()->toDateTimeString(),
                    ];
                    $this->chatState->pushMessage($roomId, $sysMsg);
                    broadcast(new MessageSent($roomId, $sysMsg));
                    SaveMessageJob::dispatch($sysMsg);
                } else {
                    // 如果已经领过了，修改回复提醒
                    $reply = $reply."\n\n(系统提示：你今天已经领过金币福利啦，每天只能领一次哦！)";
                }
            }

            // 广播 AI 回复消息
            $botMsg = [
                'id' => $this->chatState->nextMessageId($roomId),
                'room_id' => $roomId,
                'from_user' => 'AI小班长',
                'to_user' => $user->username,
                'content' => $reply,
                'is_secret' => false,
                'font_color' => '#16a34a',
                'action' => '',
                'sent_at' => now()->toDateTimeString(),
            ];
            $this->chatState->pushMessage($roomId, $botMsg);
            broadcast(new MessageSent($roomId, $botMsg));
            SaveMessageJob::dispatch($botMsg);

            return response()->json([
                'status' => 'success',
                'reply' => $result['reply'],
                'provider' => $result['provider'],
                'model' => $result['model'],
            ]);
        } catch (\Exception $e) {
            return response()->json([
                'status' => 'error',
                'message' => $e->getMessage(),
            ], 500);
        }
    }

    /**
     * 清除当前用户的 AI 对话上下文
     *
     * 用于用户想要重新开始对话时使用。
     *
     * @param  Request  $request  请求对象
     * @return JsonResponse 操作结果
     */
    public function clearContext(Request $request): JsonResponse
    {
        $user = Auth::user();
        $this->aiChat->clearContext($user->id);

        return response()->json([
            'status' => 'success',
            'message' => '对话上下文已清除，可以开始新的对话了。',
        ]);
    }
}