mex_api/app/Services/SuperballActivityService.php

<?php

namespace App\Services;

use App\Facade\TableName;
use App\Game\Services\OuroGameService;
use App\Http\helper\NumConfig;
use Carbon\Carbon;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Redis;

/**
 * Superball Activity: recharge + turnover task, balls, lucky number, prize pool.
 * All amounts in internal units (NUM_VALUE) where needed for DB/score.
 */
class SuperballActivityService
{
    public const TIER_MAX = 'A';
    public const MULTIPLIER_MIN = 1.0;
    public const MULTIPLIER_MAX = 3.0;
    public const MULTIPLIER_STEP = 0.5;
    public const LUCKY_REWARD_PER_BALL = 10; // display unit per matching ball

    /**
     * Get full activity info: yesterday data, today data, tiers, user task, multiplier.
     */
    public function getInfo(int $userId): array
    {
        $today = Carbon::today()->format('Y-m-d');
        $yesterday = Carbon::yesterday()->format('Y-m-d');

        $tiers = $this->getTierConfig();
        $yesterdayDaily = $this->getOrCreateDaily($yesterday);
        $todayDaily = $this->getOrCreateDaily($today);
        $userTask = $this->getUserTask($userId, $today);
        $multiplierRow = $this->getUserMultiplier($userId);

        $rechargeToday = $this->getUserRechargeForDate($userId, $today);
        $turnoverToday = $this->getUserTotalBetForDate($userId, $today);
        $turnoverProgress = (int) $turnoverToday;

        $tierConfig = $userTask ? $this->getTierConfigByTier($userTask->tier) : null;
        $rechargeRequired = $tierConfig ? (int) $tierConfig->recharge_required : 0;
        $turnoverRequired = $tierConfig ? (int) $tierConfig->turnover_required : 0;
        $rechargeDisplay = $rechargeToday;
        $turnoverDisplay = $turnoverProgress / NumConfig::NUM_VALUE;
        $taskCompleted = $tierConfig && $rechargeDisplay >= $rechargeRequired && $turnoverDisplay >= $turnoverRequired;
        $canUpgrade = $userTask && $userTask->tier !== self::TIER_MAX && $taskCompleted;
        $canClaim = $taskCompleted && $userTask && (int) $userTask->status === 0;

        $yesterdayBalls = $this->getUserBalls($userId, $yesterday);
        $yesterdayLucky = (int) ($yesterdayDaily->lucky_number ?? 0);
        $yesterdayPrizeLog = $this->getUserPrizeLog($userId, $yesterday);
        $yesterdayBasePerBall = 0;
        if ($yesterdayDaily->total_balls > 0 && $yesterdayDaily->pool_amount > 0) {
            $yesterdayBasePerBall = (int) ($yesterdayDaily->pool_amount / $yesterdayDaily->total_balls);
        }
        $yesterdayMyPrize = $yesterdayPrizeLog ? (int) $yesterdayPrizeLog->total_amount : 0;
        $yesterdayMultiplier = $yesterdayPrizeLog ? (float) $yesterdayPrizeLog->multiplier : 1.0;
        $canClaimYesterday = false;
        $yesterdayPendingPrize = 0;
        if (!$yesterdayPrizeLog && count($yesterdayBalls) > 0) {
            $canClaimYesterday = true;
            $yesterdayPendingPrize = $this->calculateYesterdayPrizeForUser($userId, $yesterday);
        }

        $todayBasePerBall = 0;
        if ($todayDaily->total_balls > 0 && $todayDaily->pool_amount > 0) {
            $todayBasePerBall = (int) ($todayDaily->pool_amount / $todayDaily->total_balls);
        }

        $todayBalls = $this->getUserBalls($userId, $today);
        $todayMyBallsList = array_map(function ($b) {
            return ['ball_index' => (int) $b->ball_index, 'number' => (int) $b->number];
        }, $todayBalls);
        $todayNumberCounts = [];
        foreach ($todayBalls as $b) {
            $n = (int) $b->number;
            $todayNumberCounts[$n] = ($todayNumberCounts[$n] ?? 0) + 1;
        }

        // 0 点到 1 点前，前端展示的今日整体数据全部置为 0（不影响实际统计与任务进度）
        $hour = (int) Carbon::now()->format('G'); // 0-23
        if ($hour < 1) {
            $todayDisplayPoolAmount = 0;
            $todayDisplayCompleted = 0;
            $todayDisplayTotalBalls = 0;
            $todayDisplayBasePerBall = 0;
            $todayDisplayMyBalls = [];
            $todayDisplayNumberCounts = [];
        } else {
            $todayDisplayPoolAmount = (int) $todayDaily->pool_amount;
            $todayDisplayCompleted = (int) ($todayDaily->completed_count ?? 0);
            $todayDisplayTotalBalls = (int) ($todayDaily->total_balls ?? 0);
            $todayDisplayBasePerBall = $todayBasePerBall;
            $todayDisplayMyBalls = $todayMyBallsList;
            $todayDisplayNumberCounts = $todayNumberCounts;
        }

        $last7Lucky = $this->getLast7DaysLuckyNumbersPrivate();

        return [
            'yesterday' => [
                'pool_amount' => (int) $yesterdayDaily->pool_amount,
                'pool_amount_display' => (int) $yesterdayDaily->pool_amount / NumConfig::NUM_VALUE,
                'base_reward_per_ball' => $yesterdayBasePerBall,
                'base_reward_per_ball_display' => $yesterdayBasePerBall / NumConfig::NUM_VALUE,
                'lucky_number' => $yesterdayLucky,
                'completed_count' => (int) ($yesterdayDaily->completed_count ?? 0),
                'total_balls' => (int) ($yesterdayDaily->total_balls ?? 0),
                'my_balls' => $yesterdayBalls,
                'my_balls_with_lucky' => array_map(function ($b) use ($yesterdayLucky) {
                    return ['number' => (int) $b->number, 'is_lucky' => (int) $b->number === $yesterdayLucky];
                }, $yesterdayBalls),
                'my_prize' => $yesterdayMyPrize,
                'my_prize_display' => $yesterdayMyPrize / NumConfig::NUM_VALUE,
                'my_multiplier' => $yesterdayMultiplier,
                'can_claim_yesterday' => $canClaimYesterday,
                'pending_prize' => $yesterdayPendingPrize,
                'pending_prize_display' => $yesterdayPendingPrize / NumConfig::NUM_VALUE,
            ],
            'today' => [
                'pool_amount' => $todayDisplayPoolAmount,
                'pool_amount_display' => $todayDisplayPoolAmount / NumConfig::NUM_VALUE,
                'completed_count' => $todayDisplayCompleted,
                'total_balls' => $todayDisplayTotalBalls,
                'base_reward_per_ball' => $todayDisplayBasePerBall,
                'base_reward_per_ball_display' => $todayDisplayBasePerBall / NumConfig::NUM_VALUE,
                'my_balls' => $todayDisplayMyBalls,
                'number_counts' => $todayDisplayNumberCounts,
            ],
            'tiers' => $tiers,
            'user_task' => $userTask ? [
                'tier' => $userTask->tier,
                'recharge_required' => $rechargeRequired,
                'turnover_required' => $turnoverRequired,
                'recharge_progress' => $rechargeDisplay,
                'turnover_progress' => $turnoverDisplay,
                'task_completed' => $taskCompleted,
                'status' => (int) $userTask->status,
                'can_claim' => $canClaim,
                'can_upgrade' => $canUpgrade,
                'ball_count' => $tierConfig ? (int) $tierConfig->ball_count : 0,
            ] : null,
            'multiplier' => [
                'value' => (float) ($multiplierRow->multiplier ?? 1.0),
                'consecutive_days' => (int) ($multiplierRow->consecutive_days ?? 0),
                'min' => self::MULTIPLIER_MIN,
                'max' => self::MULTIPLIER_MAX,
                'step' => self::MULTIPLIER_STEP,
            ],
            'lucky_reward_per_ball' => self::LUCKY_REWARD_PER_BALL,
            'lucky_numbers_7_days' => $last7Lucky,
        ];
    }

    /**
     * Select task tier for today (with optional confirm). Creates or updates user task.
     * @return array success: ['success' => true] | failure: ['success' => false, 'message' => ['key', 'fallback']]
     */
    public function selectTier(int $userId, string $tier): array
    {
        $today = Carbon::today()->format('Y-m-d');
        $config = $this->getTierConfigByTier($tier);
        if (!$config) {
            return ['success' => false, 'message' => ['web.superball.activity_not_found', 'Activity not found']];
        }

        $existing = $this->getUserTask($userId, $today);
        if ($existing) {
            return ['success' => false, 'message' => ['web.superball.tier_already_selected', 'Already selected tier for today']];
        }

        DB::connection('write')->table(TableName::agent() . 'superball_user_task')->insert([
            'user_id' => $userId,
            'task_date' => $today,
            'tier' => $tier,
            'total_bet_snapshot' => 0,
            'status' => 0,
            'created_at' => now()->format('Y-m-d H:i:s'),
            'updated_at' => now()->format('Y-m-d H:i:s'),
        ]);
        return ['success' => true];
    }

    /**
     * Upgrade to higher tier (keep progress). Only allowed when task completed and not A.
     * @return array success: ['success' => true] | failure: ['success' => false, 'message' => [...]]
     */
    public function upgradeTier(int $userId, string $newTier): array
    {
        $today = Carbon::today()->format('Y-m-d');
        $task = $this->getUserTask($userId, $today);
        if (!$task) {
            return ['success' => false, 'message' => ['web.superball.no_task_today', 'No task for today']];
        }
        if ((int) $task->status === 1) {
            return ['success' => false, 'message' => ['web.superball.already_claimed', 'Already claimed']];
        }

        $tierOrder = ['E' => 1, 'D' => 2, 'C' => 3, 'B' => 4, 'A' => 5];
        $currentOrder = $tierOrder[$task->tier] ?? 0;
        $newOrder = $tierOrder[$newTier] ?? 0;
        if ($newOrder <= $currentOrder) {
            return ['success' => false, 'message' => ['web.superball.cannot_downgrade', 'Can only upgrade to higher tier']];
        }

        $rechargeToday = $this->getUserRechargeForDate($userId, $today);
        $turnoverToday = $this->getUserTotalBetForDate($userId, $today);
        $newConfig = $this->getTierConfigByTier($task->tier);
        $rechargeOk = $rechargeToday >= (int) $newConfig->recharge_required;
        $turnoverOk = ($turnoverToday / NumConfig::NUM_VALUE) >= (int) $newConfig->turnover_required;

//        var_dump($rechargeToday,$turnoverToday,$newConfig);
        if (!$rechargeOk || !$turnoverOk) {
            return ['success' => false, 'message' => ['web.superball.task_not_completed', 'Task not completed']];
        }

        DB::connection('write')->table(TableName::agent() . 'superball_user_task')
            ->where('user_id', $userId)
            ->where('task_date', $today)
            ->update(['tier' => $newTier, 'updated_at' => now()->format('Y-m-d H:i:s')]);
        return ['success' => true,'user_id' => $userId, 'new_tier' => $newTier,'task_date'=>$today];
    }

    /**
     * Claim reward: grant balls, update daily total_balls/completed_count, update multiplier, mark task claimed.
     * @return array success: ['ball_count' => n, 'message' => ...] | failure: ['success' => false, 'message' => [...]]
     */
    public function claimReward(int $userId): array
    {
        $today = Carbon::today()->format('Y-m-d');
        $task = $this->getUserTask($userId, $today);
        if (!$task) {
            return ['success' => false, 'message' => ['web.superball.no_task_today', 'No task for today']];
        }
        if ((int) $task->status === 1) {
            return ['success' => false, 'message' => ['web.superball.already_claimed', 'Already claimed']];
        }

        $tierConfig = $this->getTierConfigByTier($task->tier);
        if (!$tierConfig) {
            return ['success' => false, 'message' => ['web.superball.activity_not_found', 'Activity not found']];
        }
        $rechargeToday = $this->getUserRechargeForDate($userId, $today);
        $turnoverToday = $this->getUserTotalBetForDate($userId, $today);
        $rechargeOk = ($rechargeToday) >= (int) $tierConfig->recharge_required;
        $turnoverOk = ($turnoverToday / NumConfig::NUM_VALUE) >= (int) $tierConfig->turnover_required;
        if (!$rechargeOk || !$turnoverOk) {
            return ['success' => false, 'message' => ['web.superball.task_not_completed', 'Task not completed']];
        }

        $ballCount = (int) $tierConfig->ball_count;

        DB::connection('write')->transaction(function () use ($userId, $today, $task, $ballCount) {
            DB::connection('write')->table(TableName::agent() . 'superball_user_task')
                ->where('user_id', $userId)
                ->where('task_date', $today)
                ->update(['status' => 1, 'updated_at' => now()->format('Y-m-d H:i:s')]);

            // Perform atomic increments in a single query to avoid holding an explicit row lock via SELECT ... FOR UPDATE.
            // This is safe because we only increment if the record already exists (same behavior as before).
            DB::connection('write')->table(TableName::agent() . 'superball_daily')
                ->where('pool_date', $today)
                ->update([
                    'total_balls' => DB::raw("total_balls + {$ballCount}"),
                    'completed_count' => DB::raw('completed_count + 1'),
                    'updated_at' => now()->format('Y-m-d H:i:s'),
                ]);

            $this->updateUserMultiplier($userId, $today);
        });

        return [
            'ball_count' => $ballCount,
            'message' => 'Claim success, please select numbers for your balls',
        ];
    }

    /**
     * Submit numbers for all balls (0-9 per ball). Must have claimed and not yet submitted.
     * @return array success: ['success' => true] | failure: ['success' => false, 'message' => [...]]
     */
    public function submitNumbers(int $userId, array $numbers): array
    {
        $today = Carbon::today()->format('Y-m-d');
        $task = $this->getUserTask($userId, $today);
        if (!$task || (int) $task->status !== 1) {
            return ['success' => false, 'message' => ['web.superball.no_claimed_task', 'No claimed task for today']];
        }

        $tierConfig = $this->getTierConfigByTier($task->tier);
        if (!$tierConfig) {
            return ['success' => false, 'message' => ['web.superball.activity_not_found', 'Activity not found']];
        }
        $ballCount = (int) $tierConfig->ball_count;
        if (count($numbers) !== $ballCount) {
            return ['success' => false, 'message' => ['web.superball.number_count_mismatch', 'Number count mismatch']];
        }

        $existing = DB::connection('write')->table(TableName::agent() . 'superball_user_balls')
            ->where('user_id', $userId)
            ->where('ball_date', $today)
            ->count();
        if ($existing > 0) {
            return ['success' => false, 'message' => ['web.superball.numbers_already_submitted', 'Numbers already submitted']];
        }

        DB::connection('write')->transaction(function () use ($userId, $today, $numbers) {
            // 写入用户今日所有球号
            foreach ($numbers as $index => $num) {
                $n = (int) $num;
                if ($n < 0 || $n > 9) {
                    throw new \RuntimeException('Number must be 0-9');
                }
                DB::connection('write')->table(TableName::agent() . 'superball_user_balls')->insert([
                    'user_id' => $userId,
                    'ball_date' => $today,
                    'ball_index' => $index + 1,
                    'number' => $n,
                    'created_at' => now()->format('Y-m-d H:i:s'),
                ]);
            }

            // 若用户选择的号码等于当日 lucky_number，则把 superball_daily.lucky_count 累加（使用原子自增，避免锁住整行）
            $daily = DB::connection('write')
                ->table(TableName::agent() . 'superball_daily')
                ->lock('with(nolock)')
                ->where('pool_date', $today)
                ->first();

            if ($daily) {
                $luckyNumber = (int) $daily->lucky_number;
                $matched = 0;
                foreach ($numbers as $num) {
                    if ((int) $num === $luckyNumber) {
                        $matched++;
                    }
                }
                if ($matched > 0) {
                    DB::connection('write')
                        ->table(TableName::agent() . 'superball_daily')
                        ->where('pool_date', $today)
                        ->update([
                            'lucky_count' => DB::raw("lucky_count + {$matched}"),
                            'updated_at' => now()->format('Y-m-d H:i:s'),
                        ]);
                }
            }
        });

        return ['success' => true];
    }

    /**
     * Get user's balls for a date (for number selection page or display).
     */
    public function getMyBalls(int $userId, string $date): array
    {
        $rows = DB::table(TableName::agent() . 'superball_user_balls')
            ->where('user_id', $userId)
            ->where('ball_date', $date)
            ->orderBy('ball_index')
            ->get();
        return array_map(function ($r) {
            return ['ball_index' => (int) $r->ball_index, 'number' => (int) $r->number];
        }, $rows->all());
    }

    /**
     * User claims yesterday's reward (next-day claim, no auto distribution).
     * Formula: base = pool / total_balls * ball_count, lucky = 10 * matched_balls (display), total = base * multiplier + lucky.
     * @return array success: data with total_amount etc. | failure: ['success' => false, 'message' => [...]]
     */
    public function claimYesterdayReward(int $userId): array
    {
        $yesterday = Carbon::yesterday()->format('Y-m-d');
        $existing = $this->getUserPrizeLog($userId, $yesterday);
        if ($existing) {
            return ['success' => false, 'message' => ['web.superball.yesterday_already_claimed', 'Yesterday reward already claimed']];
        }

        $balls = $this->getUserBalls($userId, $yesterday);
        if (count($balls) === 0) {
            return ['success' => false, 'message' => ['web.superball.no_balls_yesterday', 'No balls for yesterday, nothing to claim']];
        }

        $daily = DB::table(TableName::agent() . 'superball_daily')->where('pool_date', $yesterday)->first();
        if (!$daily || (int) $daily->total_balls <= 0) {
            return ['success' => false, 'message' => ['web.superball.pool_not_ready', 'Yesterday pool not ready']];
        }

        $basePerBall = (int) ($daily->pool_amount / $daily->total_balls);
        $luckyNumber = (int) $daily->lucky_number;
        $multiplierRow = $this->getUserMultiplier($userId);
        $multiplier = (float) ($multiplierRow->multiplier ?? 1.0);

        // 选号可重复：每个球单独比对幸运号，中奖球数 = 号码等于幸运号的球个数（同一号码可多球）
        $matched = 0;
        foreach ($balls as $b) {
            if ((int) $b->number === $luckyNumber) {
                $matched++;
            }
        }
        $baseAmount = $basePerBall * count($balls);
        $luckyAmountDisplay = self::LUCKY_REWARD_PER_BALL * $matched;
        $luckyAmountInternal = $luckyAmountDisplay * NumConfig::NUM_VALUE;
        $totalAmount = (int) round($baseAmount * $multiplier) + $luckyAmountInternal;

        DB::connection('write')->table(TableName::agent() . 'superball_prize_log')->insert([
            'user_id' => $userId,
            'settle_date' => $yesterday,
            'base_amount' => $baseAmount,
            'lucky_amount' => $luckyAmountInternal,
            'multiplier' => $multiplier,
            'total_amount' => $totalAmount,
            'created_at' => now()->format('Y-m-d H:i:s'),
        ]);
        OuroGameService::AddScore($userId, $totalAmount, 90);

        return [
            'total_amount' => $totalAmount,
            'total_amount_display' => $totalAmount / NumConfig::NUM_VALUE,
            'base_amount' => $baseAmount,
            'lucky_amount' => $luckyAmountInternal,
            'multiplier' => $multiplier,
        ];
    }

    /**
     * Calculate yesterday prize for user (for display only, no claim).
     */
    public function calculateYesterdayPrizeForUser(int $userId, string $yesterday): int
    {
        $daily = DB::table(TableName::agent() . 'superball_daily')->where('pool_date', $yesterday)->first();
        if (!$daily || (int) $daily->total_balls <= 0) {
            return 0;
        }
        $balls = $this->getUserBalls($userId, $yesterday);
        if (count($balls) === 0) {
            return 0;
        }
        $basePerBall = (int) ($daily->pool_amount / $daily->total_balls);
        $luckyNumber = (int) $daily->lucky_number;
        $multiplierRow = $this->getUserMultiplier($userId);
        $multiplier = (float) ($multiplierRow->multiplier ?? 1.0);
        // 选号可重复：按球逐个比对幸运号，中奖球数 = 号码等于幸运号的球个数
        $matched = 0;
        foreach ($balls as $b) {
            if ((int) $b->number === $luckyNumber) {
                $matched++;
            }
        }
        $baseAmount = $basePerBall * count($balls);
        $luckyAmountInternal = self::LUCKY_REWARD_PER_BALL * $matched * NumConfig::NUM_VALUE;
        return (int) round($baseAmount * $multiplier) + $luckyAmountInternal;
    }

    /**
     * Get last 7 days lucky numbers (for display).
     */
    public function getLast7DaysLuckyNumbers(): array
    {
        return $this->getLast7DaysLuckyNumbersPrivate();
    }

    /**
     * Ensure daily row and lucky number for date (idempotent).
     */
    public function getOrCreateDaily(string $date): \stdClass
    {
        $row = DB::table(TableName::agent() . 'superball_daily')->where('pool_date', $date)->first();
        if ($row) {
            return $row;
        }
        $lucky = mt_rand(0, 9);
        DB::connection('write')->table(TableName::agent() . 'superball_daily')->insert([
            'pool_date' => $date,
            'pool_amount' => 0,
            'total_balls' => 0,
            'lucky_number' => $lucky,
            'completed_count' => 0,
            'lucky_count' => 0,
            'created_at' => now()->format('Y-m-d H:i:s'),
            'updated_at' => now()->format('Y-m-d H:i:s'),
        ]);
        return DB::table(TableName::agent() . 'superball_daily')->where('pool_date', $date)->first();
    }

    /**
     * Update pool amount for a date (call from job that aggregates daily turnover).
     */
    public function updatePoolAmount(string $date, int $poolAmountInternal): void
    {
        DB::connection('write')->table(TableName::agent() . 'superball_daily')
            ->where('pool_date', $date)
            ->update(['pool_amount' => $poolAmountInternal, 'updated_at' => now()->format('Y-m-d H:i:s')]);
    }

    // --- private helpers ---

    private function getTierConfig(): array
    {
        $rows = DB::table(TableName::agent() . 'superball_tier_config')
            ->orderBy('sort_index')
            ->get();
        return array_map(function ($r) {
            return [
                'tier' => $r->tier,
                'recharge_required' => (int) $r->recharge_required,
                'turnover_required' => (int) $r->turnover_required,
                'ball_count' => (int) $r->ball_count,
            ];
        }, $rows->all());
    }

    private function getTierConfigByTier(string $tier): ?\stdClass
    {
        return DB::table(TableName::agent() . 'superball_tier_config')->where('tier', $tier)->first();
    }

    private function getUserTask(int $userId, string $date): ?\stdClass
    {
        return DB::table(TableName::agent() . 'superball_user_task')
            ->where('user_id', $userId)
            ->where('task_date', $date)
            ->first();
    }

    private function getUserRechargeForDate(int $userId, string $date): int
    {
        $dateId = str_replace('-', '', $date);
        $row = DB::table(TableName::QPRecordDB() . 'RecordUserDataStatisticsNew')
            ->where('UserID', $userId)
            ->where('DateID', $dateId)
            ->first();
        return $row ? (int) $row->Recharge : 0;
    }

    /** 当日流水：从按日统计表取当天 TotalBet（内部单位） */
    private function getUserTotalBetForDate(int $userId, string $date): int
    {
        $dateId = str_replace('-', '', $date);
        $row = DB::table(TableName::QPRecordDB() . 'RecordUserDataStatisticsNew')
            ->where('UserID', $userId)
            ->where('DateID', $dateId)
            ->first();
        return $row && isset($row->TotalBet) ? (int) $row->TotalBet : 0;
    }

    private function getUserTotalBet(int $userId): int
    {
        $row = DB::table(TableName::QPRecordDB() . 'RecordUserTotalStatistics')
            ->where('UserID', $userId)
            ->first();
        return $row ? (int) $row->TotalBet : 0;
    }

    private function getUserBalls(int $userId, string $date): array
    {
        return DB::table(TableName::agent() . 'superball_user_balls')
            ->where('user_id', $userId)
            ->where('ball_date', $date)
            ->orderBy('ball_index')
            ->get()
            ->all();
    }

    private function    getUserMultiplier(int $userId): ?\stdClass
    {
        return DB::table(TableName::agent() . 'superball_user_multiplier')->where('user_id', $userId)->first();
    }

    private function getUserPrizeLog(int $userId, string $date): ?\stdClass
    {
        return DB::table(TableName::agent() . 'superball_prize_log')
            ->where('user_id', $userId)
            ->where('settle_date', $date)
            ->first();
    }

    private function getLast7DaysLuckyNumbersPrivate(): array
    {
        $dates = [];
        for ($i = 0; $i < 7; $i++) {
            $dates[] = Carbon::today()->subDays($i)->format('Y-m-d');
        }
        $rows = DB::table(TableName::agent() . 'superball_daily')
            ->whereIn('pool_date', $dates)
            ->orderBy('pool_date', 'desc')
            ->get();
        $map = [];
        foreach ($rows as $r) {
            $map[$r->pool_date] = (int) $r->lucky_number;
        }
        return array_map(function ($d) use ($map) {
            return ['date' => $d, 'lucky_number' => $map[$d] ?? null];
        }, $dates);
    }

    private function updateUserMultiplier(int $userId, string $taskDate): void
    {
        $row = DB::connection('write')->table(TableName::agent() . 'superball_user_multiplier')
            ->where('user_id', $userId)
            ->lockForUpdate()
            ->first();

        $multiplier = self::MULTIPLIER_MIN;
        $consecutive = 1;

        if ($row) {
            $last = $row->last_task_date ? (string) $row->last_task_date : null;
            $prev = Carbon::parse($taskDate)->subDay()->format('Y-m-d');
            if ($last === $prev) {
                $consecutive = (int) $row->consecutive_days + 1;
                $multiplier = min(self::MULTIPLIER_MAX, (float) $row->multiplier + self::MULTIPLIER_STEP);
            } elseif ($last !== null && $last !== $taskDate) {
                $daysDiff = (int) Carbon::parse($taskDate)->diffInDays(Carbon::parse($last));
                if ($daysDiff > 1) {
                    $multiplier = max(self::MULTIPLIER_MIN, (float) $row->multiplier - self::MULTIPLIER_STEP);
                    $consecutive = 1;
                } else {
                    $multiplier = (float) $row->multiplier;
                    $consecutive = (int) $row->consecutive_days + 1;
                }
            }
        }

        DB::connection('write')->table(TableName::agent() . 'superball_user_multiplier')->updateOrInsert(
            ['user_id' => $userId],
            [
                'consecutive_days' => $consecutive,
                'last_task_date' => $taskDate,
                'multiplier' => $multiplier,
                'updated_at' => now()->format('Y-m-d H:i:s'),
            ]
        );
    }
}