chatroom/app/Http/Controllers/FishingController.php

<?php

/**
 * 文件功能：钓鱼小游戏控制器
 *
 * 新增随机浮漂点击防挂机机制：
 * - 抛竿时生成一次性 token 和随机浮漂坐标（百分比），返回给前端
 * - 前端显示漂浮动画，等待下沉后用户点击，将 token 随收竿请求提交
 * - 若持有有效「自动钓鱼卡」，前端直接自动点击，无需手动操作
 * - 服务端验证 token 有效性，防止脚本直接调用收竿接口
 *
 * @author   ChatRoom Laravel
 *
 * @version  2.0.0
 */

namespace App\Http\Controllers;

use App\Enums\CurrencySource;
use App\Events\MessageSent;
use App\Models\Sysparam;
use App\Services\ChatStateService;
use App\Services\ShopService;
use App\Services\UserCurrencyService;
use App\Services\VipService;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\Redis;
use Illuminate\Support\Str;

class FishingController extends Controller
{
    public function __construct(
        private readonly ChatStateService $chatState,
        private readonly VipService $vipService,
        private readonly UserCurrencyService $currencyService,
        private readonly ShopService $shopService,
    ) {}

    /**
     * 抛竿 — 检查冷却和金币，扣除金币，生成浮漂 token 和随机坐标。
     *
     * 返回：
     *   wait_time     — 等待秒数（前端倒数后触发下沉动画）
     *   bobber_x/y    — 浮漂随机位置（0-100 百分比）
     *   token         — 本次钓鱼唯一令牌（收竿时必须携带）
     *   auto_fishing  — 是否持有有效自动钓鱼卡（前端据此自动点击）
     *
     * @param  int  $id  房间ID
     */
    public function cast(Request $request, int $id): JsonResponse
    {
        $user = Auth::user();
        if (! $user) {
            return response()->json(['status' => 'error', 'message' => '请先登录'], 401);
        }

        // 1. 检查冷却时间（Redis TTL）
        $cooldownKey = "fishing:cd:{$user->id}";
        if (Redis::exists($cooldownKey)) {
            $ttl = Redis::ttl($cooldownKey);

            return response()->json([
                'status' => 'error',
                'message' => "钓鱼冷却中，还需等待 {$ttl} 秒。",
                'cooldown' => $ttl,
            ], 429);
        }

        // 2. 检查金币是否足够
        $cost = (int) Sysparam::getValue('fishing_cost', '5');
        if (($user->jjb ?? 0) < $cost) {
            return response()->json([
                'status' => 'error',
                'message' => "金币不足！钓鱼需要 {$cost} 金币，您当前只有 {$user->jjb} 金币。",
            ], 422);
        }

        // 3. 扣除金币
        $this->currencyService->change(
            $user, 'gold', -$cost,
            CurrencySource::FISHING_COST,
            "钓鱼抛竿消耗 {$cost} 金币",
            $id,
        );
        $user->refresh();

        // 4. 生成一次性 token，存入 Redis（TTL = 等待时间 + 收竿窗口 + 缓冲）
        $waitMin = (int) Sysparam::getValue('fishing_wait_min', '8');
        $waitMax = (int) Sysparam::getValue('fishing_wait_max', '15');
        $waitTime = rand($waitMin, $waitMax);
        $token = Str::random(32);
        $tokenKey = "fishing:token:{$user->id}";
        // token 有效期 = 等待时间 + 10秒点击窗口 + 5秒缓冲
        Redis::setex($tokenKey, $waitTime + 15, $token);

        // 5. 生成随机浮漂坐标（百分比，避开边缘）
        $bobberX = rand(15, 85); // 左右 15%~85%
        $bobberY = rand(20, 65); // 上下 20%~65%

        // 6. 检查是否持有有效自动钓鱼卡
        $autoFishingMinutes = $this->shopService->getActiveAutoFishingMinutesLeft($user);

        return response()->json([
            'status' => 'success',
            'message' => "已花费 {$cost} 金币，鱼竿已抛出！等待鱼儿上钩...",
            'wait_time' => $waitTime,
            'bobber_x' => $bobberX,
            'bobber_y' => $bobberY,
            'token' => $token,
            'auto_fishing' => $autoFishingMinutes > 0,
            'auto_fishing_minutes_left' => $autoFishingMinutes,
            'cost' => $cost,
            'jjb' => $user->jjb,
        ]);
    }

    /**
     * 收竿 — 验证浮漂 token，随机计算钓鱼结果，更新经验/金币，广播到聊天室。
     *
     * 必须携带 token（从抛竿接口获取），否则判定为非法收竿。
     *
     * @param  int  $id  房间ID
     */
    public function reel(Request $request, int $id): JsonResponse
    {
        $user = Auth::user();
        if (! $user) {
            return response()->json(['status' => 'error', 'message' => '请先登录'], 401);
        }

        // 1. 验证 token（防止脚本绕过浮漂直接收竿）
        $tokenKey = "fishing:token:{$user->id}";
        $storedToken = Redis::get($tokenKey);
        $clientToken = $request->input('token', '');

        if (! $storedToken || $storedToken !== $clientToken) {
            return response()->json([
                'status' => 'error',
                'message' => '鱼儿跑了！浮漂已超时或令牌无效，请重新抛竿。',
            ], 422);
        }

        // 清除 token（一次性）
        Redis::del($tokenKey);

        // 2. 设置冷却时间
        $cooldown = (int) Sysparam::getValue('fishing_cooldown', '300');
        Redis::setex("fishing:cd:{$user->id}", $cooldown, time());

        // 3. 随机决定钓鱼结果
        $result = $this->randomFishResult();

        // 4. 通过统一积分服务更新经验和金币
        $expMul = $this->vipService->getExpMultiplier($user);
        $jjbMul = $this->vipService->getJjbMultiplier($user);
        if ($result['exp'] !== 0) {
            $finalExp = $result['exp'] > 0 ? (int) round($result['exp'] * $expMul) : $result['exp'];
            $this->currencyService->change(
                $user, 'exp', $finalExp, CurrencySource::FISHING_GAIN,
                "钓鱼收竿：{$result['message']}", $id,
            );
        }
        if ($result['jjb'] !== 0) {
            $finalJjb = $result['jjb'] > 0 ? (int) round($result['jjb'] * $jjbMul) : $result['jjb'];
            $this->currencyService->change(
                $user, 'gold', $finalJjb, CurrencySource::FISHING_GAIN,
                "钓鱼收竿：{$result['message']}", $id,
            );
        }
        $user->refresh();

        // 5. 广播钓鱼结果到聊天室
        $sysMsg = [
            'id' => $this->chatState->nextMessageId($id),
            'room_id' => $id,
            'from_user' => '钓鱼播报',
            'to_user' => '大家',
            'content' => "{$result['emoji']} 【{$user->username}】{$result['message']}",
            'is_secret' => false,
            'font_color' => $result['exp'] >= 0 ? '#16a34a' : '#dc2626',
            'action' => '',
            'sent_at' => now()->toDateTimeString(),
        ];

        $this->chatState->pushMessage($id, $sysMsg);
        broadcast(new MessageSent($id, $sysMsg));

        return response()->json([
            'status' => 'success',
            'result' => $result,
            'exp_num' => $user->exp_num,
            'jjb' => $user->jjb,
            'cooldown_seconds' => $cooldown, // 前端自动钓鱼卡循环等待用
        ]);
    }

    /**
     * 随机钓鱼结果（复刻原版概率分布）
     *
     * @return array{emoji: string, message: string, exp: int, jjb: int}
     */
    private function randomFishResult(): array
    {
        $roll = rand(1, 100);

        return match (true) {
            $roll <= 15 => [
                'emoji' => '🦈',
                'message' => '钓到一条大鲨鱼！增加经验100、金币20',
                'exp' => 100,
                'jjb' => 20,
            ],
            $roll <= 30 => [
                'emoji' => '🐟',
                'message' => '钓到一条娃娃鱼，到集市卖得30个金币',
                'exp' => 0,
                'jjb' => 30,
            ],
            $roll <= 50 => [
                'emoji' => '🐠',
                'message' => '钓到一只大草鱼，吃下增加经验50',
                'exp' => 50,
                'jjb' => 0,
            ],
            $roll <= 70 => [
                'emoji' => '🐡',
                'message' => '钓到一条小鲤鱼，增加经验50、金币10',
                'exp' => 50,
                'jjb' => 10,
            ],
            $roll <= 85 => [
                'emoji' => '💧',
                'message' => '鱼没钓到，摔到河里经验减少50',
                'exp' => -50,
                'jjb' => 0,
            ],
            $roll <= 95 => [
                'emoji' => '👊',
                'message' => '偷钓鱼塘被主人发现，一阵殴打！经验减少20、金币减少3',
                'exp' => -20,
                'jjb' => -3,
            ],
            default => [
                'emoji' => '🎉',
                'message' => '运气爆棚！钓到大鲨鱼、大草鱼、小鲤鱼各一条！经验+150，金币+50！',
                'exp' => 150,
                'jjb' => 50,
            ],
        };
    }
}