<?php
declare(strict_types=1);

namespace app\api\logic;

use app\api\cache\UserCache;
use app\api\service\LotteryService;
use app\dice\model\lottery_config\DiceLotteryConfig;
use app\dice\model\play_record\DicePlayRecord;
use app\dice\model\player\DicePlayer;
use app\dice\model\player_ticket_record\DicePlayerTicketRecord;
use app\dice\model\player_wallet_record\DicePlayerWalletRecord;
use app\dice\model\reward_config\DiceRewardConfig;
use plugin\saiadmin\exception\ApiException;
use support\Log;
use support\think\Cache;
use support\think\Db;

/**
 * 开始游戏 / 抽奖一局
 */
class PlayStartLogic
{
    /** 抽奖类型：付费 */
    public const LOTTERY_TYPE_PAID = 0;
    /** 抽奖类型：免费 */
    public const LOTTERY_TYPE_FREE = 1;
    /** 钱包流水类型：抽奖 */
    public const WALLET_TYPE_DRAW = 5;
    /** 对局状态：成功 */
    public const RECORD_STATUS_SUCCESS = 1;
    /** 对局状态：超时/失败 */
    public const RECORD_STATUS_TIMEOUT = 0;

    /** 开启对局最低余额 = |DiceRewardConfig 最小 real_ev + 100| */
    private const MIN_COIN_EXTRA = 100;

    /**
     * 执行一局游戏
     * @param int $playerId 玩家ID
     * @param int $direction 方向 0=无/顺时针 1=中奖/逆时针（前端 direction）
     * @return array 成功返回 DicePlayRecord 数据；余额不足时抛 ApiException，message 为约定文案
     */
    public function run(int $playerId, int $direction): array
    {
        $player = DicePlayer::find($playerId);
        if (!$player) {
            throw new ApiException('用户不存在');
        }

        $minEv = DiceRewardConfig::getCachedMinRealEv();
        $minCoin = abs($minEv + self::MIN_COIN_EXTRA);
        $coin = (float) $player->coin;
        if ($coin < $minCoin) {
            throw new ApiException('当前玩家余额'.$coin.'小于'.$minCoin.'无法继续游戏');
        }

        $paid = (int) ($player->paid_ticket_count ?? 0);
        $free = (int) ($player->free_ticket_count ?? 0);
        if ($paid + $free <= 0) {
            throw new ApiException('抽奖券不足');
        }

        $lotteryService = LotteryService::getOrCreate($playerId);
        $ticketType = LotteryService::drawTicketType($paid, $free);
        $config = $ticketType === self::LOTTERY_TYPE_PAID
            ? ($lotteryService->getConfigType0Id() ? DiceLotteryConfig::find($lotteryService->getConfigType0Id()) : null)
            : ($lotteryService->getConfigType1Id() ? DiceLotteryConfig::find($lotteryService->getConfigType1Id()) : null);
        if (!$config) {
            throw new ApiException('奖池配置不存在');
        }

        // 按玩家权重抽取档位；若该档位无奖励或该方向下均无可用路径则重新摇取档位
        $maxTierRetry = 10;
        $chosen = null;
        $startCandidates = [];
        $tier = null;
        for ($tierAttempt = 0; $tierAttempt < $maxTierRetry; $tierAttempt++) {
            $tier = LotteryService::drawTierByPlayerWeights($player);
            $tierRewards = DiceRewardConfig::getCachedByTier($tier);
            if (empty($tierRewards)) {
                Log::warning("档位 {$tier} 无任何奖励配置，重新摇取档位");
                continue;
            }
            $maxRewardRetry = count($tierRewards);
            for ($attempt = 0; $attempt < $maxRewardRetry; $attempt++) {
                $chosen = $tierRewards[array_rand($tierRewards)];
                $chosenId = (int) ($chosen['id'] ?? 0);
                if ($direction === 0) {
                    $startCandidates = DiceRewardConfig::getCachedBySEndIndex($chosenId);
                } else {
                    $startCandidates = DiceRewardConfig::getCachedByNEndIndex($chosenId);
                }
                if (!empty($startCandidates)) {
                    break 2;
                }
                Log::warning("方向 {$direction} 下无 s_end_index/n_end_index={$chosenId} 的配置，重新摇取");
            }
            Log::warning("方向 {$direction} 下档位 {$tier} 所有奖励均无可用路径配置，重新摇取档位");
        }
        if (empty($startCandidates)) {
            Log::error("方向 {$direction} 下多次摇取档位后仍无可用路径配置");
            throw new ApiException('该方向下暂无可用路径配置');
        }
        $chosenId = (int) ($chosen['id'] ?? 0);
        $startRecord = $startCandidates[array_rand($startCandidates)];

        $startIndex = (int) ($startRecord['id'] ?? 0);
        $targetIndex = $direction === 0
            ? (int) ($startRecord['s_end_index'] ?? 0)
            : (int) ($startRecord['n_end_index'] ?? 0);
        $rollNumber = (int) ($startRecord['grid_number'] ?? 0);
        $rollArray = $this->generateRollArrayFromSum($rollNumber);

        Log::info(sprintf(
            '摇取点数 roll_number=%d, 方向=%d, start_index=%d, target_index=%d',
            $rollNumber,
            $direction,
            $startIndex,
            $targetIndex
        ));
        $realEv = (float) ($chosen['real_ev'] ?? 0);
        $winCoin = 100 + $realEv; // 赢取平台币 = 100 + DiceRewardConfig.real_ev

        $record = null;
        $configId = (int) $config->id;
        $rewardId = $chosenId;
        $configName = (string) ($config->name ?? '');
        $isTierT5 = (string) ($chosen['tier'] ?? '') === 'T5';
        try {
            Db::transaction(function () use (
                $playerId,
                $configId,
                $rewardId,
                $configName,
                $ticketType,
                $winCoin,
                $realEv,
                $direction,
                $startIndex,
                $targetIndex,
                $rollArray,
                $isTierT5,
                &$record
            ) {
                $record = DicePlayRecord::create([
                    'player_id'          => $playerId,
                    'lottery_config_id'  => $configId,
                    'lottery_type'       => $ticketType,
                    'win_coin'           => $winCoin,
                    'direction'          => $direction,
                    'reward_config_id'   => $rewardId,
                    'start_index'        => $startIndex,
                    'target_index'       => $targetIndex,
                    'roll_array'         => is_array($rollArray) ? json_encode($rollArray) : $rollArray,
                    'lottery_name'       => $configName,
                    'status'             => self::RECORD_STATUS_SUCCESS,
                ]);

                $p = DicePlayer::find($playerId);
                if (!$p) {
                    throw new \RuntimeException('玩家不存在');
                }
                $coinBefore = (float) $p->coin;
                $coinAfter = $coinBefore + $winCoin;
                $p->coin = $coinAfter;
                $p->total_ticket_count = max(0, (int) $p->total_ticket_count - 1);
                if ($ticketType === self::LOTTERY_TYPE_PAID) {
                    $p->paid_ticket_count = max(0, (int) $p->paid_ticket_count - 1);
                } else {
                    $p->free_ticket_count = max(0, (int) $p->free_ticket_count - 1);
                }

                // 若本局中奖档位为 T5，则额外赠送 1 次免费抽奖次数（总次数也 +1），并记录抽奖券获取记录
                if ($isTierT5) {
                    $p->free_ticket_count = (int) $p->free_ticket_count + 1;
                    $p->total_ticket_count = (int) $p->total_ticket_count + 1;

                    DicePlayerTicketRecord::create([
                        'player_id'       => $playerId,
                        'free_ticket_count' => 1,
                        'remark'          => '中奖结果为T5',
                    ]);
                }

                $p->save();

                // 累加彩金池盈利额度（累加值为 -real_ev）。若 dice_lottery_config 表有 ev 字段则执行
                try {
                    DiceLotteryConfig::where('id', $configId)->update([
                        'ev' => Db::raw('IFNULL(ev,0) - ' . (float) $realEv),
                    ]);
                } catch (\Throwable $_) {
                }

                DicePlayerWalletRecord::create([
                    'player_id'      => $playerId,
                    'coin'           => $winCoin,
                    'type'           => self::WALLET_TYPE_DRAW,
                    'wallet_before'  => $coinBefore,
                    'wallet_after'   => $coinAfter,
                    'remark'         => '抽奖|play_record_id=' . $record->id,
                ]);
            });
        } catch (\Throwable $e) {
            if ($record === null) {
                try {
                    $record = DicePlayRecord::create([
                        'player_id'          => $playerId,
                        'lottery_config_id'  => $configId ?? 0,
                        'lottery_type'       => $ticketType,
                        'win_coin'           => 0,
                        'direction'          => $direction,
                        'reward_config_id'   => 0,
                        'start_index'        => $startIndex,
                        'target_index'       => 0,
                        'roll_array'         => '[]',
                        'status'             => self::RECORD_STATUS_TIMEOUT,
                    ]);
                } catch (\Throwable $_) {
                    // 表可能无 status 字段时忽略
                }
            }
            throw $e;
        }

        $updated = DicePlayer::find($playerId);
        if ($updated) {
            UserCache::setUser($playerId, $updated->hidden(['password'])->toArray());
        }

        if (!$record instanceof DicePlayRecord) {
            throw new \RuntimeException('对局记录创建失败');
        }
        $arr = $record->toArray();
        if (isset($arr['roll_array']) && is_string($arr['roll_array'])) {
            $arr['roll_array'] = json_decode($arr['roll_array'], true) ?? [];
        }
        $arr['roll_number'] = is_array($arr['roll_array'] ?? null) ? array_sum($arr['roll_array']) : 0;
        return $arr;
    }

    /**
     * 根据摇取点数（5-30）生成 5 个色子数组，每个 1-6，总和为 $sum
     * @return int[] 如 [1,2,3,4,5]
     */
    private function generateRollArrayFromSum(int $sum): array
    {
        $sum = max(5, min(30, $sum));
        $arr = [1, 1, 1, 1, 1];
        $remain = $sum - 5;
        for ($i = 0; $i < $remain; $i++) {
            $candidates = array_keys(array_filter($arr, function ($v) {
                return $v < 6;
            }));
            if (empty($candidates)) {
                break;
            }
            $idx = $candidates[array_rand($candidates)];
            $arr[$idx]++;
        }
        shuffle($arr);
        return array_values($arr);
    }
}