mirror of
https://github.com/oshima-studios/OshimaGameModule.git
synced 2026-06-04 19:42:13 +00:00
1114 lines
51 KiB
C#
1114 lines
51 KiB
C#
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 => "已结束", 3 => "已取消", _ => "未知" };
|
||
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 => "已结束", 3 => "已取消", _ => "未知" };
|
||
|
||
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 => "已结束", 3 => "已取消", _ => "未知" };
|
||
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}", 3 => "已取消", _ => "未知" };
|
||
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"]);
|
||
bool bettingEnabled = Convert.ToBoolean(row["betting_enabled"]);
|
||
|
||
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 => "已结束", 3 => "已取消", _ => "未知" };
|
||
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 && bettingEnabled;
|
||
if (canBet) sb.AppendLine($"可用选项：");
|
||
else if (!bettingEnabled) 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"]);
|
||
bool bettingEnabled = Convert.ToBoolean(row["betting_enabled"]);
|
||
if (!bettingEnabled)
|
||
{
|
||
error = "该比赛不开放预测。";
|
||
return false;
|
||
}
|
||
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 "比赛已结算，无法再次结算。";
|
||
if (status == 3)
|
||
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 AND status != 3");
|
||
|
||
// 更新比赛状态：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 AND status != 3");
|
||
// 对于已经过了开始时间但还没有 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,
|
||
BetDeadline = 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"] = request.Description ?? "";
|
||
setClause.Append("description = @desc, ");
|
||
}
|
||
if (request.Result != null)
|
||
{
|
||
sql.Parameters["@result"] = request.Result ?? "";
|
||
setClause.Append("result = @result, ");
|
||
}
|
||
if (request.Stage != null)
|
||
{
|
||
sql.Parameters["@stage"] = request.Stage ?? "";
|
||
setClause.Append("stage = @stage, ");
|
||
}
|
||
if (request.Team1 != null)
|
||
{
|
||
sql.Parameters["@t1"] = request.Team1 ?? "";
|
||
setClause.Append("team1_name = @t1, ");
|
||
}
|
||
if (request.Team2 != null)
|
||
{
|
||
sql.Parameters["@t2"] = request.Team2 ?? "";
|
||
setClause.Append("team2_name = @t2, ");
|
||
}
|
||
if (request.BettingEnabled.HasValue)
|
||
{
|
||
sql.Parameters["@betting_enabled"] = request.BettingEnabled.Value ? 1 : 0;
|
||
setClause.Append("betting_enabled = @betting_enabled, ");
|
||
}
|
||
|
||
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;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 取消比赛（管理员操作），退还所有未结算投注的本金，标记比赛状态为已取消
|
||
/// </summary>
|
||
/// <param name="matchId">比赛ID</param>
|
||
/// <param name="error">错误信息</param>
|
||
/// <returns>是否成功</returns>
|
||
public static bool CancelMatch(int matchId, out string error)
|
||
{
|
||
error = "";
|
||
using SQLHelper? sql = Factory.OpenFactory.GetSQLHelper();
|
||
if (sql == null)
|
||
{
|
||
error = "数据库连接失败。";
|
||
return false;
|
||
}
|
||
|
||
try
|
||
{
|
||
sql.NewTransaction();
|
||
|
||
// 1. 获取比赛信息
|
||
sql.Parameters["@mid"] = matchId;
|
||
sql.ExecuteDataSet("SELECT id, status FROM csbetting_matches WHERE id = @mid");
|
||
if (!sql.Success || sql.DataSet.Tables[0].Rows.Count == 0)
|
||
{
|
||
error = "比赛不存在。";
|
||
sql.Rollback();
|
||
return false;
|
||
}
|
||
DataRow row = sql.DataSet.Tables[0].Rows[0];
|
||
int status = Convert.ToInt32(row["status"]);
|
||
if (status == 2)
|
||
{
|
||
error = "比赛已结束，无法取消。";
|
||
sql.Rollback();
|
||
return false;
|
||
}
|
||
if (status == 3)
|
||
{
|
||
error = "比赛已经是取消状态。";
|
||
sql.Rollback();
|
||
return false;
|
||
}
|
||
|
||
// 2. 获取该比赛所有未结算的投注记录
|
||
sql.Parameters["@mid"] = matchId;
|
||
sql.ExecuteDataSet("SELECT id, amount FROM csbetting_bet_records WHERE match_id = @mid AND is_settled = 0");
|
||
if (sql.Success && sql.DataSet.Tables[0].Rows.Count > 0)
|
||
{
|
||
foreach (DataRow bet in sql.DataSet.Tables[0].Rows)
|
||
{
|
||
long betId = Convert.ToInt64(bet["id"]);
|
||
long amount = Convert.ToInt64(bet["amount"]);
|
||
|
||
// 退还本金（payout = amount），标记为已结算，注明取消，但不自动领取
|
||
sql.Parameters["@bid"] = betId;
|
||
sql.Parameters["@payout"] = amount;
|
||
sql.Execute("UPDATE csbetting_bet_records SET is_settled = 1, payout = @payout, result_note = '比赛取消，退还本金' WHERE id = @bid");
|
||
if (!sql.Success)
|
||
{
|
||
sql.Rollback();
|
||
error = "退还投注本金失败。";
|
||
return false;
|
||
}
|
||
}
|
||
}
|
||
|
||
// 3. 更新比赛状态为 3（已取消），并禁止继续投注
|
||
sql.Parameters["@mid"] = matchId;
|
||
sql.Execute("UPDATE csbetting_matches SET status = 3, betting_enabled = 0 WHERE id = @mid");
|
||
if (!sql.Success)
|
||
{
|
||
sql.Rollback();
|
||
error = "更新比赛状态失败。";
|
||
return false;
|
||
}
|
||
|
||
sql.Commit();
|
||
error = $"比赛 {matchId} 已取消，所有未结算投注的本金已退还，请用户通过【预测领奖】领取。";
|
||
return true;
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
sql.Rollback();
|
||
error = $"取消比赛异常：{ex.Message}";
|
||
return false;
|
||
}
|
||
}
|
||
|
||
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);
|
||
}
|
||
}
|
||
}
|