using System.Data;
using System.Text;
using Milimoe.FunGame.Core.Api.Transmittal;
using Milimoe.FunGame.Core.Api.Utility;
using Milimoe.FunGame.Core.Library.Constant;
using Oshima.FunGame.OshimaServers.Model;
using Oshima.FunGame.WebAPI.Model;

namespace Oshima.FunGame.WebAPI.Services
{
    public class CSBettingService
    {
        public static (string, int) GetEventsOverview(int page, int pageSize)
        {
            using SQLHelper? sql = Factory.OpenFactory.GetSQLHelper();
            if (sql == null) return ("数据库连接失败。", 0);

            UpdateStatuses(sql);

            // 获取总数
            sql.ExecuteDataSet("SELECT COUNT(*) FROM csbetting_events");
            int total = sql.Success ? Convert.ToInt32(sql.DataSet.Tables[0].Rows[0][0]) : 0;
            int totalPages = (int)Math.Ceiling(total / (double)pageSize);
            if (page > totalPages) page = totalPages;
            if (page < 1) page = 1;
            if (total == 0)
                return ("暂无赛事。", 1);

            int offset = (page - 1) * pageSize;
            sql.Parameters["@page_size"] = pageSize;
            sql.Parameters["@offset"] = offset;
            sql.ExecuteDataSet($@"
                SELECT id, name, status, start_time, end_time
                FROM csbetting_events
                ORDER BY 
                    CASE status WHEN 1 THEN 0 WHEN 0 THEN 1 ELSE 2 END,
                    CASE WHEN status = 2 THEN end_time END DESC,
                    CASE WHEN status != 2 THEN start_time END ASC
                LIMIT {pageSize} OFFSET {offset}");

            if (!sql.Success || sql.DataSet.Tables.Count == 0)
                return ("暂无赛事。", 1);

            StringBuilder sb = new();
            sb.AppendLine($"🏆 赛事列表{(totalPages > 1 ? $"（第 {page}/{totalPages} 页）" : "")}");
            foreach (DataRow row in sql.DataSet.Tables[0].Rows)
            {
                int id = Convert.ToInt32(row["id"]);
                string name = row["name"].ToString() ?? "";
                int status = Convert.ToInt32(row["status"]);
                string statusStr = status switch { 0 => "未开始", 1 => "进行中", 2 => "已结束", _ => "未知" };
                DateTime startTime = Convert.ToDateTime(row["start_time"]);
                DateTime endTime = Convert.ToDateTime(row["end_time"]);
                sb.AppendLine($"🏆 [{id}] {name.CreateCmdInput($"赛事详情 {id}")} ({statusStr}：{startTime:yyyy/MM/dd} ~ {endTime:yyyy/MM/dd})");
            }
            return (sb.ToString().TrimEnd(), totalPages);
        }

        public static (string, int) GetEventDetail(int eventId, int page, int pageSize)
        {
            using SQLHelper? sql = Factory.OpenFactory.GetSQLHelper();
            if (sql == null) return ("数据库连接失败。", 0);

            UpdateStatuses(sql);

            // 获取赛事信息
            sql.Parameters["@id"] = eventId;
            sql.ExecuteDataSet("SELECT * FROM csbetting_events WHERE id = @id");
            if (!sql.Success || sql.DataSet.Tables[0].Rows.Count == 0)
                return ("赛事不存在。", 0);
            DataRow evt = sql.DataSet.Tables[0].Rows[0];
            string name = evt["name"].ToString() ?? "";
            int status = Convert.ToInt32(evt["status"]);
            DateTime start = Convert.ToDateTime(evt["start_time"]);
            DateTime end = Convert.ToDateTime(evt["end_time"]);
            string statusStr = status switch { 0 => "未开始", 1 => "进行中", 2 => "已结束", _ => "未知" };

            StringBuilder header = new();
            header.AppendLine($"赛事：{name}");
            header.AppendLine($"状态：{statusStr}");
            header.AppendLine($"时间：{start:yyyy/MM/dd} ~ {end:yyyy/MM/dd}");

            // 比赛总数
            sql.Parameters["@eid"] = eventId;
            sql.ExecuteDataSet("SELECT COUNT(*) FROM csbetting_matches WHERE event_id = @eid");
            int total = sql.Success ? Convert.ToInt32(sql.DataSet.Tables[0].Rows[0][0]) : 0;
            int totalPages = (int)Math.Ceiling(total / (double)pageSize);
            if (page > totalPages) page = totalPages;
            if (page < 1) page = 1;

            header.AppendLine($"比赛列表{(totalPages > 1 ? $"（第 {page}/{totalPages} 页）" : "")}：");

            // 分页查询比赛
            int offset = (page - 1) * pageSize;
            sql.Parameters["@eid"] = eventId;
            sql.ExecuteDataSet($@"
                SELECT id, team1_name, team2_name, status, bet_deadline, stage, start_time, result
                FROM csbetting_matches
                WHERE event_id = @eid
                ORDER BY 
                    CASE status WHEN 1 THEN 0 WHEN 0 THEN 1 ELSE 2 END,
                    CASE WHEN status = 2 THEN start_time END DESC,
                    CASE WHEN status != 2 THEN start_time END ASC
                LIMIT {pageSize} OFFSET {offset}");

            StringBuilder matches = new();
            if (sql.Success && sql.DataSet?.Tables[0].Rows.Count > 0)
            {
                foreach (DataRow row in sql.DataSet.Tables[0].Rows)
                {
                    int mid = Convert.ToInt32(row["id"]);
                    string t1 = row["team1_name"].ToString() ?? "";
                    string t2 = row["team2_name"].ToString() ?? "";
                    int mstatus = Convert.ToInt32(row["status"]);
                    DateTime deadline = Convert.ToDateTime(row["bet_deadline"]);
                    string stage = row["stage"].ToString() ?? "";
                    string result = row["result"] != DBNull.Value ? row["result"].ToString() ?? "" : "";
                    string mStatusStr = mstatus switch { 0 => "未开始", 1 => "进行中", 2 => "已结束", _ => "未知" };
                    string matchLabel = $"{t1} vs {t2}";
                    string clickableMatch = matchLabel.CreateCmdInput($"比赛详情 {mid}");
                    matches.AppendLine($"  [{mid}] {(stage != "" ? $"{stage} " : "")} {clickableMatch} (状态：{mStatusStr}{(result.Trim() != "" ? $", 结果：{result}" : "")}, 截止：{deadline:MM-dd HH:mm})");
                }
            }
            else
            {
                matches.AppendLine("暂无比赛。");
            }

            return (header.ToString() + matches.ToString(), totalPages);
        }

        /// <summary>
        /// 获取所有比赛列表（赛程），按开始时间排序，支持分页
        /// </summary>
        public static (string, int) GetAllMatches(int page, int pageSize)
        {
            using SQLHelper? sql = Factory.OpenFactory.GetSQLHelper();
            if (sql == null) return ("数据库连接失败。", 0);

            UpdateStatuses(sql);

            // 总数
            sql.ExecuteDataSet("SELECT COUNT(*) FROM csbetting_matches");
            int total = sql.Success ? Convert.ToInt32(sql.DataSet.Tables[0].Rows[0][0]) : 0;
            int totalPages = (int)Math.Ceiling(total / (double)pageSize);
            if (page > totalPages) page = totalPages;
            if (page < 1) page = 1;
            if (total == 0)
                return ("暂无比赛赛程。", 1);

            int offset = (page - 1) * pageSize;

            sql.ExecuteDataSet($@"
                SELECT m.id, m.team1_name, m.team2_name, m.status, m.start_time, m.stage,
                       e.name AS event_name, e.id AS event_id, m.result
                FROM csbetting_matches m
                LEFT JOIN csbetting_events e ON m.event_id = e.id
                ORDER BY 
                    CASE m.status WHEN 1 THEN 0 WHEN 0 THEN 1 ELSE 2 END,
                    CASE WHEN m.status = 2 THEN m.start_time END DESC,
                    CASE WHEN m.status != 2 THEN m.start_time END ASC
                LIMIT {pageSize} OFFSET {offset}");

            if (!sql.Success || sql.DataSet.Tables.Count == 0 || sql.DataSet.Tables[0].Rows.Count == 0)
                return ("暂无比赛赛程。", 1);

            StringBuilder sb = new();
            sb.AppendLine($"📅 比赛赛程{(totalPages > 1 ? $"（第 {page}/{totalPages} 页）" : "")}");

            foreach (DataRow row in sql.DataSet.Tables[0].Rows)
            {
                int id = Convert.ToInt32(row["id"]);
                string t1 = row["team1_name"].ToString() ?? "";
                string t2 = row["team2_name"].ToString() ?? "";
                int status = Convert.ToInt32(row["status"]);
                DateTime start = Convert.ToDateTime(row["start_time"]);
                string stage = row["stage"]?.ToString() ?? "";
                string eventName = row["event_name"]?.ToString() ?? "";
                long eventId = Convert.ToInt64(row["event_id"]);
                string result = row["result"] != DBNull.Value ? row["result"].ToString() ?? "" : "";

                string statusStr = status switch { 0 => "未开始", 1 => "进行中", 2 => $"已结束 | {result}", _ => "未知" };
                string matchLabel = $"{t1} vs {t2}".CreateCmdInput($"比赛详情 {id}");

                sb.Append($"[{id}] {matchLabel}");
                if (!string.IsNullOrWhiteSpace(eventName)) sb.Append($" ({eventName.CreateCmdInput($"赛事详情 {eventId}")}{(!string.IsNullOrWhiteSpace(stage) ? $" - {stage}" : "")})");
                sb.AppendLine($" | {statusStr} | {start:MM-dd HH:mm}");
            }

            return (sb.ToString().TrimEnd(), totalPages);
        }

        public static string GetMatchDetail(int matchId, out KeyboardMessage kb)
        {
            kb = new KeyboardMessage();
            using SQLHelper? sql = Factory.OpenFactory.GetSQLHelper();
            if (sql != null)
            {
                UpdateStatuses(sql);

                sql.Parameters["@mid"] = matchId;
                sql.ExecuteDataSet("SELECT * FROM csbetting_matches WHERE id = @mid");
                if (!sql.Success || sql.DataSet.Tables[0].Rows.Count == 0) return "比赛不存在。";
                DataRow row = sql.DataSet.Tables[0].Rows[0];
                long eventId = Convert.ToInt64(row["event_id"]);
                string t1 = row["team1_name"].ToString() ?? "";
                string t2 = row["team2_name"].ToString() ?? "";
                int status = Convert.ToInt32(row["status"]);
                DateTime start = Convert.ToDateTime(row["start_time"]);
                DateTime deadline = Convert.ToDateTime(row["bet_deadline"]);
                string stage = row["stage"].ToString() ?? "";
                string available = row["available_options"]?.ToString() ?? "[]";
                string description = row["description"].ToString() ?? "";
                string result = row["result"] != DBNull.Value ? row["result"].ToString() ?? "" : "";
                long winner = row["winner"] != DBNull.Value ? Convert.ToInt64(row["winner"]) : 0;
                decimal team1Odds = Convert.ToDecimal(row["team1_win_odds"]);
                decimal team2Odds = Convert.ToDecimal(row["team2_win_odds"]);

                string eventName = "";
                sql.Parameters["@eid"] = eventId;
                DataRow? rowEvent = sql.ExecuteDataRow("SELECT name FROM csbetting_events WHERE id = @eid");
                if (rowEvent != null)
                {
                    eventName = rowEvent["name"].ToString() ?? "";
                }

                // 查询各选项统计
                sql.Parameters["@mid"] = matchId;
                DataSet stats = sql.ExecuteDataSet(@"SELECT option_type, 
                    COUNT(*) AS totalRecord, SUM(amount) AS totalAmount 
                    FROM csbetting_bet_records WHERE match_id = @mid GROUP BY option_type");

                // 将统计存入字典便于查找
                Dictionary<int, (int, long)> statDict = [];
                if (sql.Success && stats.Tables[0].Rows.Count > 0)
                {
                    foreach (DataRow srow in stats.Tables[0].Rows)
                    {
                        statDict[Convert.ToInt32(srow["option_type"])] = (Convert.ToInt32(srow["totalRecord"]), Convert.ToInt64(srow["totalAmount"]));
                    }
                }

                string statusStr = status switch { 0 => "未开始", 1 => "进行中", 2 => "已结束", _ => "未知" };
                StringBuilder sb = new();
                sb.AppendLine($"比赛 #{matchId}");
                if (eventName.Trim() != "")
                {
                    sb.AppendLine($"> {eventName.CreateCmdInput($"赛事详情 {eventId}")}");
                    if (stage.Trim() != "") sb.AppendLine($"{stage}");
                    sb.AppendLine();
                }
                sb.AppendLine($"{t1} vs {t2}".CreateCmdInput($"比赛详情 {matchId}"));
                sb.AppendLine($"开赛：{start:yyyy/MM/dd HH:mm}");
                sb.AppendLine($"预测截止：{deadline:yyyy/MM/dd HH:mm}");
                sb.AppendLine($"状态：{statusStr}");

                if (!string.IsNullOrWhiteSpace(description))
                {
                    sb.AppendLine($"> 📝 {description}\r\n");
                }

                DateTime now = DateTime.Now;
                bool canBet = (status == 0 || status == 1) && now < deadline;
                if (canBet) sb.AppendLine($"可用选项：");
                else sb.AppendLine($"该比赛已截止预测。");

                string GetStatString(int opt)
                {
                    if (statDict.TryGetValue(opt, out var stat) && stat.Item1 > 0)
                    {
                        return $" 👥 {stat.Item1} 🔥 {stat.Item2}";
                    }
                    return "";
                };

                string statText = "";
                if (available.Contains("team1_win"))
                {
                    statText = GetStatString(1);
                    sb.AppendLine($"  - {t1} 胜 (x {team1Odds}){statText}");
                    if (canBet) kb.AppendButtons(2, Button.CreateCmdButton($"⚔️ {t1} 胜", $"预测 {matchId} team1 1000", enter: false));
                }
                if (available.Contains("team2_win"))
                {
                    statText = GetStatString(2);
                    sb.AppendLine($"  - {t2} 胜 (x {team2Odds}){statText}");
                    if (canBet) kb.AppendButtons(2, Button.CreateCmdButton($"🛡️ {t2} 胜", $"预测 {matchId} team2 1000", enter: false));
                }
                if (available.Contains("score"))
                {
                    statText = GetStatString(3);
                    sb.AppendLine($"  - 精确比分 (x 4){statText}");
                    if (canBet) kb.AppendButtons(2, Button.CreateCmdButton("🎯 精确比分", $"预测 {matchId} score:", enter: false));
                }
                if (available.Contains("mvp"))
                {
                    statText = GetStatString(4);
                    sb.AppendLine($"  - 赛事MVP (x 3.5){statText}");
                    if (canBet) kb.AppendButtons(2, Button.CreateCmdButton("🏆 MVP", $"预测 {matchId} mvp:", enter: false));
                }
                if (status == 2)
                {
                    string winnerName = winner switch { 1 => t1, 2 => t2, 3 => result, _ => "待定" };
                    sb.AppendLine($"胜者：{winnerName}");
                    if (winner != 3) sb.AppendLine($"结果：{result}");
                }

                if (canBet)
                {
                    sb.AppendLine($"预测指令：{"预测".CreateCmdInput()} <比赛ID> <选项> <{General.GameplayEquilibriumConstant.InGameCurrency}数>\r\n👇🏻 点击下方按钮快速预测");
                }

                return sb.ToString().Trim();
            }
            return "数据库连接失败。";
        }

        public static bool PlaceBet(long uid, int matchId, string option, long amount, out string error)
        {
            error = "";
            using SQLHelper? sql = Factory.OpenFactory.GetSQLHelper();
            if (sql != null)
            {
                // 检查比赛
                sql.Parameters["@mid"] = matchId;
                sql.ExecuteDataSet("SELECT * FROM csbetting_matches WHERE id = @mid");
                if (!sql.Success || sql.DataSet.Tables[0].Rows.Count == 0)
                {
                    error = "比赛不存在。";
                    return false;
                }
                DataRow row = sql.DataSet.Tables[0].Rows[0];
                int status = Convert.ToInt32(row["status"]);
                DateTime deadline = Convert.ToDateTime(row["bet_deadline"]);
                decimal team1Odds = Convert.ToDecimal(row["team1_win_odds"]);
                decimal team2Odds = Convert.ToDecimal(row["team2_win_odds"]);
                if (status == 2 || DateTime.Now > deadline)
                {
                    error = "当前比赛已结束或非可预测阶段。";
                    return false;
                }

                // --- 单场比赛助力上限检查 ---
                long alreadyBet = 0;
                long totalBet = amount;
                sql.Parameters["@uid"] = uid;
                sql.Parameters["@mid"] = matchId;
                sql.ExecuteDataSet("SELECT COALESCE(SUM(amount), 0) AS total FROM csbetting_bet_records WHERE user_id = @uid AND match_id = @mid");
                if (sql.Success && sql.DataSet.Tables[0].Rows.Count > 0)
                {
                    alreadyBet = Convert.ToInt64(sql.DataSet.Tables[0].Rows[0]["total"] ?? 0L);
                    totalBet += alreadyBet;
                }
                if (totalBet > 10000)
                {
                    error = $"本场比赛你的助力总额不能超过 10000 {General.GameplayEquilibriumConstant.InGameCurrency}（已助力 {alreadyBet}）。";
                    return false;
                }

                string available = row["available_options"]?.ToString() ?? "[]";
                int optionType;
                string optionValue = option;
                decimal oddsAtBet = 0;
                if (option == "team1" && available.Contains("team1_win"))
                {
                    optionType = 1;
                    oddsAtBet = team1Odds;
                }
                else if (option == "team2" && available.Contains("team2_win"))
                {
                    optionType = 2;
                    oddsAtBet = team2Odds;
                }
                else if (option.StartsWith("score:") && available.Contains("score"))
                {
                    optionType = 3;
                    optionValue = option.Replace("score:", "").Trim();
                    oddsAtBet = 4.0m;
                }
                else if (option.StartsWith("mvp:") && available.Contains("mvp"))
                {
                    optionType = 4;
                    optionValue = option.Replace("mvp:", "").Trim();
                    oddsAtBet = 3.5m;
                }
                else
                {
                    error = "无效的预测选项。";
                    return false;
                }

                // 写入预测记录
                sql.Parameters["@uid"] = uid;
                sql.Parameters["@mid"] = matchId;
                sql.Parameters["@otype"] = optionType;
                sql.Parameters["@oval"] = optionValue;
                sql.Parameters["@amt"] = amount;
                sql.Parameters["@odds"] = oddsAtBet;
                sql.Parameters["@time"] = DateTime.Now;
                sql.Execute("INSERT INTO csbetting_bet_records (user_id, match_id, option_type, option_value, amount, odds_at_bet, bet_time) VALUES (@uid, @mid, @otype, @oval, @amt, @odds, @time)");
                if (!sql.Success)
                {
                    error = "预测记录写入失败。";
                    return false;
                }
                return true;
            }
            error = "数据库连接失败。";
            return false;
        }

        public static string SettleMatch(int matchId, string winner, string result)
        {
            using SQLHelper? sql = Factory.OpenFactory.GetSQLHelper();
            if (sql != null)
            {
                try
                {
                    sql.NewTransaction();

                    UpdateStatuses(sql);

                    sql.Parameters["@mid"] = matchId;
                    sql.ExecuteDataSet("SELECT * FROM csbetting_matches WHERE id = @mid");
                    if (!sql.Success || sql.DataSet.Tables[0].Rows.Count == 0)
                        return "比赛不存在。";
                    DataRow row = sql.DataSet.Tables[0].Rows[0];
                    string available = row["available_options"]?.ToString() ?? "[]";
                    bool isMvp = available.Contains("mvp", StringComparison.CurrentCultureIgnoreCase);
                    int status = Convert.ToInt32(row["status"]);
                    if (status == 2)
                        return "比赛已结算。";

                    int winTeam = 3;
                    if (!isMvp)
                    {
                        if (winner == "team1") winTeam = 1;
                        else if (winner == "team2") winTeam = 2;
                        else return "请指定获胜方为 team1 或 team2。MVP 赛事获胜方请直接指定选手 ID。";
                    }

                    // 更新比赛结果
                    sql.Parameters["@res"] = result;
                    sql.Parameters["@win"] = winTeam;
                    sql.Parameters["@mid"] = matchId;
                    sql.Execute("UPDATE csbetting_matches SET status=2, result=@res, winner=@win WHERE id=@mid");
                    if (sql.Success)
                    {
                        // 获取所有未结算助力
                        sql.Parameters["@mid"] = matchId;
                        sql.ExecuteDataSet("SELECT * FROM csbetting_bet_records WHERE match_id=@mid AND is_settled=0");
                        if (sql.Success && sql.DataSet.Tables[0].Rows.Count > 0)
                        {
                            decimal team1Odds = Convert.ToDecimal(row["team1_win_odds"]);
                            decimal team2Odds = Convert.ToDecimal(row["team2_win_odds"]);
                            foreach (DataRow bet in sql.DataSet.Tables[0].Rows)
                            {
                                long betId = Convert.ToInt64(bet["id"]);
                                int otype = Convert.ToInt32(bet["option_type"]);
                                string ovalue = bet["option_value"].ToString() ?? "";
                                long amount = Convert.ToInt64(bet["amount"]);
                                decimal oddsAtBet = Convert.ToDecimal(bet["odds_at_bet"]);

                                bool win = false;
                                if (otype == 1 && winTeam == 1) win = true;
                                else if (otype == 2 && winTeam == 2) win = true;
                                else if (otype == 3 && ovalue.Replace("：", ":").Equals(result, StringComparison.CurrentCultureIgnoreCase)) win = true;
                                else if (otype == 4 && ovalue.Equals(result, StringComparison.CurrentCultureIgnoreCase)) win = true;

                                long payout = 0;
                                string note = "未中奖";
                                if (win)
                                {
                                    if (oddsAtBet <= 0)
                                    {
                                        oddsAtBet = otype switch
                                        {
                                            1 => team1Odds,
                                            2 => team2Odds,
                                            3 => 4,
                                            4 => 3.5m,
                                            _ => 2.5m
                                        };
                                    }
                                    payout = (long)(amount * oddsAtBet);
                                    note = "中奖";
                                }
                                sql.Parameters["@payout"] = payout;
                                sql.Parameters["@note"] = note;
                                sql.Parameters["@bid"] = betId;
                                sql.Execute("UPDATE csbetting_bet_records SET is_settled=1, payout=@payout, result_note=@note WHERE id=@bid");
                                if (!sql.Success)
                                {
                                    sql.Rollback();
                                    throw sql.LastException ?? new Milimoe.FunGame.SQLQueryException();
                                }
                            }
                        }
                        sql.Commit();
                        return $"比赛 {matchId} 结算完成。";
                    }
                    else
                    {
                        sql.Rollback();
                        throw sql.LastException ?? new Milimoe.FunGame.SQLQueryException();
                    }
                }
                catch (Exception e)
                {
                    sql.Rollback();
                    return $"比赛 {matchId} 结算失败，发生异常：{e.Message}";
                }
            }
            return "数据库连接失败。";
        }

        public static (string, int) GetMyBets(long uid, long mid = -1, int page = 1, int pageSize = 10)
        {
            using SQLHelper? sql = Factory.OpenFactory.GetSQLHelper();
            if (sql == null) return ("数据库连接失败。", 0);

            UpdateStatuses(sql);

            bool paged = true;
            sql.Parameters["@uid"] = uid;
            string matchFilter = "";
            if (mid > 0)
            {
                sql.Parameters["@mid"] = mid;
                matchFilter = " AND br.match_id = @mid";
                paged = false;
            }

            int totalPages = 0;
            if (paged)
            {
                // 总数查询：不同比赛的数量
                sql.ExecuteDataSet($@"
                SELECT COUNT(DISTINCT br.match_id) 
                FROM csbetting_bet_records br
                JOIN csbetting_matches m ON br.match_id = m.id
                WHERE br.user_id = @uid {matchFilter}");
                int total = sql.Success ? Convert.ToInt32(sql.DataSet.Tables[0].Rows[0][0]) : 0;
                totalPages = (int)Math.Ceiling(total / (double)pageSize);
                if (page > totalPages) page = totalPages;
                if (page < 1) page = 1;
                if (total == 0)
                    return ("你还没有任何预测记录。", 1);
            }

            // 构建分页SQL片段
            string limitClause = "";
            if (paged)
            {
                int offset = (page - 1) * pageSize;
                limitClause = $" LIMIT {pageSize} OFFSET {offset}";
            }

            // 分页聚合查询
            sql.Parameters["@uid"] = uid;
            sql.ExecuteDataSet($@"
                SELECT br.match_id, m.team1_name, m.team2_name, m.status AS match_status, m.start_time,
                       MAX(m.team1_win_odds) AS team1_odds, MAX(m.team2_win_odds) AS team2_odds,
                       GROUP_CONCAT(CONCAT(br.option_type, ':', br.option_value, ':', br.amount, ':', br.odds_at_bet) ORDER BY br.id SEPARATOR '|') AS details,
                       SUM(br.amount) AS total_amount,
                       MIN(br.is_settled) AS all_settled,
                       SUM(CASE WHEN br.is_settled = 1 AND br.payout > 0 AND br.is_claimed = 1 THEN 1 ELSE 0 END) AS claimed_count,
                       SUM(CASE WHEN br.is_settled = 1 AND br.payout > 0 AND br.is_claimed = 0 THEN 1 ELSE 0 END) AS unclaimed_count,
                       SUM(CASE WHEN br.is_settled = 1 AND br.payout = 0 THEN 1 ELSE 0 END) AS lost_count,
                       SUM(CASE WHEN br.is_settled = 1 THEN br.payout ELSE 0 END) AS total_payout
                FROM csbetting_bet_records br
                JOIN csbetting_matches m ON br.match_id = m.id
                WHERE br.user_id = @uid {matchFilter}
                GROUP BY br.match_id, m.team1_name, m.team2_name, m.status, m.start_time
                ORDER BY 
                    MIN(br.is_settled) ASC,
                    CASE WHEN MIN(br.is_settled) = 0 THEN MIN(m.start_time) END ASC,
                    CASE WHEN MIN(br.is_settled) = 1 THEN MIN(m.start_time) END DESC
                {limitClause}");

            if (!sql.Success || sql.DataSet.Tables[0].Rows.Count == 0)
                return ("你还没有任何预测记录。", 1);

            StringBuilder sb = new();
            if (mid > 0) sb.Append("你的本场预测记录：\r\n> ");
            else sb.Append($"我的预测{(paged && totalPages > 1 ? $"（第 {page}/{totalPages} 页）" : "")}\r\n> ");
            foreach (DataRow row in sql.DataSet.Tables[0].Rows)
            {
                int matchId = Convert.ToInt32(row["match_id"]);
                string t1 = row["team1_name"].ToString() ?? "";
                string t2 = row["team2_name"].ToString() ?? "";
                int matchStatus = Convert.ToInt32(row["match_status"]);
                decimal t1Odds = Convert.ToDecimal(row["team1_odds"]);
                decimal t2Odds = Convert.ToDecimal(row["team2_odds"]);
                long totalAmount = Convert.ToInt64(row["total_amount"]);
                long totalPayout = Convert.ToInt64(row["total_payout"]);
                int allSettled = Convert.ToInt32(row["all_settled"]);
                int claimedCount = Convert.ToInt32(row["claimed_count"]);
                int unclaimedCount = Convert.ToInt32(row["unclaimed_count"]);
                int lostCount = Convert.ToInt32(row["lost_count"]);

                // 解析助力详情
                string detailsStr = row["details"].ToString() ?? "";
                string[]? parts = detailsStr.Split('|');
                List<string> summary = [];
                foreach (string part in parts)
                {
                    string[] items = part.Split(':');
                    if (items.Length >= 3)
                    {
                        int otype = int.Parse(items[0]);
                        string ovalue = items[1];
                        long oamount = long.Parse(items[2]);
                        decimal odds = decimal.Parse(items[3]);
                        if (odds <= 0)
                        {
                            odds = otype switch
                            {
                                1 => t1Odds,
                                2 => t2Odds,
                                3 => 4m,
                                4 => 3.5m,
                                _ => 2.5m
                            };
                        }
                        string optStr = otype switch
                        {
                            1 => $"{t1}胜",
                            2 => $"{t2}胜",
                            3 => $"比分 {ovalue}",
                            4 => $"MVP {ovalue}",
                            _ => ovalue
                        };
                        summary.Add($"{optStr} {oamount}G [x {odds}]");
                    }
                }

                string detailLine = string.Join(", ", summary);
                string statusLine;
                if (allSettled == 0)
                {
                    statusLine = "待开奖";
                }
                else
                {
                    if (claimedCount > 0 && unclaimedCount == 0 && lostCount == 0)
                        statusLine = "已领取";
                    else if (unclaimedCount > 0)
                        statusLine = "待领奖";
                    else if (lostCount > 0 && claimedCount == 0 && unclaimedCount == 0)
                        statusLine = "未中奖";
                    else
                        statusLine = "部分已领";
                }

                string matchLabel = $"{t1} vs {t2}".CreateCmdInput($"比赛详情 {matchId}");
                sb.Append($"[比赛{matchId}] {matchLabel} | ");
                sb.Append($"助力：{totalAmount}G ({detailLine}) | ");
                sb.Append($"状态：{statusLine}");
                if (totalPayout > 0)
                    sb.Append($" (+{totalPayout}G)");
                sb.AppendLine();
            }
            return (sb.ToString().TrimEnd(), totalPages);
        }

        /// <summary>
        /// 根据当前时间更新赛事和比赛的状态（仅更新未结束的记录）
        /// </summary>
        private static void UpdateStatuses(SQLHelper sql)
        {
            DateTime now = DateTime.Now;

            // 更新赛事状态：0→1 (进行中)，1→2 (已结束)
            sql.Parameters["@now"] = now;
            sql.Execute("UPDATE csbetting_events SET status = 1 WHERE status = 0 AND start_time <= @now AND end_time > @now");
            sql.Parameters["@now"] = now;
            sql.Execute("UPDATE csbetting_events SET status = 2 WHERE status <= 1 AND end_time <= @now");

            // 根据时间，设置比赛状态为未开始
            sql.Parameters["@now"] = now;
            sql.Execute("UPDATE csbetting_matches SET status = 0 WHERE start_time >= @now");

            // 更新比赛状态：0→1 (进行中)，1→2 (已结束) - 注意不要覆盖已结算的比赛（winner 为 null 时视为未结束）
            sql.Parameters["@now"] = now;
            sql.Execute("UPDATE csbetting_matches SET status = 1 WHERE status = 0 AND start_time <= @now AND bet_deadline < @now AND winner IS NULL");
            // 对于已经过了开始时间但还没有 winner 且状态为 1 的，可保留为进行中；实际上只要 winner 为 null，状态应为 1（进行中）
            // 如果有结果但 winner 不为 null，管理员应该已经手动结算，状态会设为 2，这里不做额外修改。
            // 安全起见，只更新未开始的，以及当比赛时间已过且无 winner 时自动变成进行中。
            // 如果需要自动结束（比如时间过长），可再添加规则，但预测系统通常由管理员手动结算结束。
            // 这里只做基础更新。
        }

        public static long ClaimRewards(long uid)
        {
            // 返回领取的总金币，由上层加到用户身上
            using SQLHelper? sql = Factory.OpenFactory.GetSQLHelper();
            if (sql != null)
            {
                sql.Parameters["@uid"] = uid;
                sql.ExecuteDataSet("SELECT id, payout FROM csbetting_bet_records WHERE user_id=@uid AND is_settled=1 AND payout>0 AND is_claimed=0");
                if (!sql.Success || sql.DataSet.Tables[0].Rows.Count == 0) return 0;

                long total = 0;
                foreach (DataRow row in sql.DataSet.Tables[0].Rows)
                {
                    long bid = Convert.ToInt64(row["id"]);
                    long payout = Convert.ToInt64(row["payout"]);
                    total += payout;
                    sql.Parameters["@bid"] = bid;
                    sql.Execute("UPDATE csbetting_bet_records SET is_claimed=1 WHERE id=@bid");
                }
                return total;
            }
            return 0;
        }

        // 创建赛事
        public static bool CreateEvent(string name, DateTime startTime, DateTime endTime, out string error, out long? newEventId)
        {
            error = "";
            newEventId = null;
            using SQLHelper? sql = Factory.OpenFactory.GetSQLHelper();
            if (sql != null)
            {
                // 简单校验
                if (string.IsNullOrWhiteSpace(name))
                {
                    error = "赛事名称不能为空。";
                    return false;
                }
                if (endTime <= startTime)
                {
                    error = "结束时间必须晚于开始时间。";
                    return false;
                }

                sql.Parameters["@name"] = name;
                sql.Parameters["@start"] = startTime;
                sql.Parameters["@end"] = endTime;
                sql.Execute("INSERT INTO csbetting_events (name, status, start_time, end_time) VALUES (@name, 0, @start, @end)");

                if (sql.Success)
                {
                    newEventId = sql.LastInsertId;
                    return true;
                }
                error = "赛事创建失败，数据库错误。";
                return false;
            }
            error = "数据库连接失败。";
            return false;
        }

        // 创建比赛
        public static bool CreateMatch(int eventId, string team1Name, string team2Name, string stage, DateTime startTime, DateTime betDeadline, string availableOptions, decimal? team1WinOdds, decimal? team2WinOdds, decimal? team1WinProbability, out string error, out long? newMatchId)
        {
            error = "";
            newMatchId = null;
            using var sql = Factory.OpenFactory.GetSQLHelper();
            if (sql != null)
            {
                // 检查赛事存在
                sql.Parameters["@eid"] = eventId;
                sql.ExecuteDataSet("SELECT id FROM csbetting_events WHERE id = @eid");
                if (!sql.Success || sql.DataSet?.Tables[0].Rows.Count == 0)
                {
                    error = "赛事不存在。";
                    return false;
                }

                // 处理可用选项 JSON
                List<string> options = [.. availableOptions.Split(',', StringSplitOptions.RemoveEmptyEntries)
                                              .Select(s => s.Trim())
                                              .Where(s => s.Length > 0)];
                string optionsJson = System.Text.Json.JsonSerializer.Serialize(options);

                // 如果比赛包含比分或 MVP 选项，不允许自定义猜胜者奖励率
                bool hasSpecialOption = options.Contains("score") || options.Contains("mvp");
                if ((team1WinOdds.HasValue || team2WinOdds.HasValue) && hasSpecialOption)
                {
                    error = "比赛包含比分或MVP选项时，不能自定义猜胜者奖励率。";
                    return false;
                }

                // 处理默认奖励率或基于胜率计算
                decimal t1Odds, t2Odds;
                if (team1WinProbability.HasValue)
                {
                    decimal prob = team1WinProbability.Value;
                    try
                    {
                        (t1Odds, t2Odds) = CalculateOdds(prob);
                    }
                    catch (Exception e)
                    {
                        error = e.Message;
                        return false;
                    }
                }
                else if (team1WinOdds.HasValue && team2WinOdds.HasValue)
                {
                    t1Odds = team1WinOdds.Value;
                    t2Odds = team2WinOdds.Value;
                }
                else
                {
                    // 默认双方各 2.0
                    t1Odds = 2.0m;
                    t2Odds = 2.0m;
                }

                // 校验奖励率大于0
                if (t1Odds <= 0 || t2Odds <= 0)
                {
                    error = "奖励率必须大于0。";
                    return false;
                }

                sql.Parameters["@eid"] = eventId;
                sql.Parameters["@t1"] = team1Name;
                sql.Parameters["@t2"] = team2Name;
                sql.Parameters["@stage"] = stage;
                sql.Parameters["@start"] = startTime;
                sql.Parameters["@deadline"] = betDeadline;
                sql.Parameters["@opts"] = optionsJson;
                sql.Parameters["@t1_odds"] = t1Odds;
                sql.Parameters["@t2_odds"] = t2Odds;
                sql.Execute(@"INSERT INTO csbetting_matches 
          (event_id, team1_name, team2_name, stage, start_time, bet_deadline, available_options, team1_win_odds, team2_win_odds, status) 
          VALUES (@eid, @t1, @t2, @stage, @start, @deadline, @opts, @t1_odds, @t2_odds, 0)");

                if (sql.Success)
                {
                    newMatchId = sql.LastInsertId;
                    return true;
                }
                error = "比赛创建失败，数据库错误。";
                return false;
            }
            error = "数据库连接失败。";
            return false;
        }

        /// <summary>
        /// 管理员提前结束预测（将未开始比赛标记为进行中）
        /// </summary>
        public static bool CloseBetting(int matchId, out string message) => UpdateMatch(new()
        {
            MatchId = matchId,
            StartTime = DateTime.Now
        }, out message);

        public static bool UpdateMatch(UpdateMatchRequest request, out string error)
        {
            error = "";
            using SQLHelper? sql = Factory.OpenFactory.GetSQLHelper();
            if (sql == null)
            {
                error = "数据库连接失败。";
                return false;
            }

            // 检查比赛是否存在
            sql.Parameters["@mid"] = request.MatchId;
            sql.ExecuteDataSet("SELECT status, available_options, bet_deadline FROM csbetting_matches WHERE id = @mid");
            if (!sql.Success || sql.DataSet.Tables[0].Rows.Count == 0)
            {
                error = "比赛不存在。";
                return false;
            }
            DataRow row = sql.DataSet.Tables[0].Rows[0];

            int status = Convert.ToInt32(row["status"]);
            if (status == 2)
            {
                error = "比赛已结束，无法修改。";
                return false;
            }

            DateTime deadline = Convert.ToDateTime(row["bet_deadline"]);
            string available = row["available_options"]?.ToString() ?? "[]";
            bool hasSpecial = available.Contains("score", StringComparison.OrdinalIgnoreCase) || available.Contains("mvp", StringComparison.OrdinalIgnoreCase);
            decimal? newTeam1Odds = request.Team1WinOdds;
            decimal? newTeam2Odds = request.Team2WinOdds;

            // 校验奖励率逻辑（同创建比赛）
            if (request.Team1WinProbability.HasValue)
            {
                if (hasSpecial)
                {
                    error = "比赛包含比分或MVP选项，不能修改猜胜者赔率。";
                    return false;
                }
                decimal prob = request.Team1WinProbability.Value;
                try
                {
                    (newTeam1Odds, newTeam2Odds) = CalculateOdds(prob);
                }
                catch (Exception e)
                {
                    error = e.Message;
                    return false;
                }
            }
            else
            {
                if ((newTeam1Odds.HasValue || newTeam2Odds.HasValue) && hasSpecial)
                {
                    error = "比赛包含比分或MVP选项时，不能修改猜胜者奖励率。";
                    return false;
                }
                if ((newTeam1Odds.HasValue && newTeam1Odds <= 0) ||
                    (newTeam2Odds.HasValue && newTeam2Odds <= 0))
                {
                    error = "奖励率必须大于0。";
                    return false;
                }
            }

            // 构建动态UPDATE
            StringBuilder setClause = new();
            if (newTeam1Odds.HasValue)
            {
                sql.Parameters["@t1od"] = newTeam1Odds.Value;
                setClause.Append("team1_win_odds = @t1od, ");
            }
            if (newTeam2Odds.HasValue)
            {
                sql.Parameters["@t2od"] = newTeam2Odds.Value;
                setClause.Append("team2_win_odds = @t2od, ");
            }
            if (request.StartTime.HasValue)
            {
                sql.Parameters["@st"] = request.StartTime.Value;
                setClause.Append("start_time = @st, ");
                if (request.StartTime.Value < deadline && !request.BetDeadline.HasValue)
                {
                    request.BetDeadline = request.StartTime.Value;
                }
            }
            if (request.BetDeadline.HasValue)
            {
                sql.Parameters["@ddl"] = request.BetDeadline.Value;
                setClause.Append("bet_deadline = @ddl, ");
            }
            if (request.Description != null) 
            {
                sql.Parameters["@desc"] = (object?)request.Description ?? "";
                setClause.Append("description = @desc, ");
            }
            if (request.Result != null) 
            {
                sql.Parameters["@result"] = (object?)request.Result ?? "";
                setClause.Append("result = @result, ");
            }
            if (request.Stage != null)
            {
                sql.Parameters["@stage"] = (object?)request.Stage ?? "";
                setClause.Append("stage = @stage, ");
            }

            if (setClause.Length == 0)
            {
                error = "没有提供任何修改参数。";
                return false;
            }

            setClause.Remove(setClause.Length - 2, 2); // 移除最后的 ", "
            sql.Parameters["@mid"] = request.MatchId;
            string updateSql = $"UPDATE csbetting_matches SET {setClause} WHERE id = @mid";

            sql.Execute(updateSql);
            if (!sql.Success)
            {
                error = "修改比赛属性失败。";
                return false;
            }

            return true;
        }

        public static (decimal oddsA, decimal oddsB) CalculateOdds(decimal team1WinProbability, decimal margin = 0.08m)
        {
            if (team1WinProbability <= 0 || team1WinProbability >= 1)
                throw new ArgumentException("胜率必须大于0且小于1。");

            if (margin < 0) margin = 0.08m;

            decimal probB = 1m - team1WinProbability;
            decimal adj = 1m + margin;

            decimal oddsA = Math.Round(1m / (team1WinProbability * adj), 2);
            decimal oddsB = Math.Round(1m / (probB * adj), 2);

            return (oddsA, oddsB);
        }
    }
}