mirror of
https://github.com/oshima-studios/OshimaGameModule.git
synced 2026-06-04 19:42:13 +00:00
400 lines
19 KiB
C#
400 lines
19 KiB
C#
using System.Data;
|
|
using System.Security.Cryptography;
|
|
using System.Text;
|
|
using Milimoe.FunGame.Core.Api.Transmittal;
|
|
using Milimoe.FunGame.Core.Api.Utility;
|
|
using Oshima.FunGame.OshimaServers.Model;
|
|
|
|
namespace Oshima.FunGame.WebAPI.Services
|
|
{
|
|
public class CSBettingSQLService
|
|
{
|
|
public static string GetEventsOverview()
|
|
{
|
|
using SQLHelper? sql = Factory.OpenFactory.GetSQLHelper();
|
|
if (sql != null)
|
|
{
|
|
sql.ExecuteDataSet("SELECT id, name, status, start_time FROM csbetting_events ORDER BY start_time DESC");
|
|
if (!sql.Success || sql.DataSet.Tables.Count == 0) return "暂无赛事。";
|
|
StringBuilder sb = new();
|
|
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 => "已结束", _ => "未知" };
|
|
sb.AppendLine($"🏆 [{id}] {name.CreateCmdInput($"赛事详情 {id}")} ({statusStr})");
|
|
}
|
|
return sb.ToString().TrimEnd();
|
|
}
|
|
return "数据库连接失败。";
|
|
}
|
|
|
|
public static string GetEventDetail(int eventId)
|
|
{
|
|
using SQLHelper? sql = Factory.OpenFactory.GetSQLHelper();
|
|
if (sql != null)
|
|
{
|
|
sql.Parameters["@id"] = eventId;
|
|
sql.ExecuteDataSet("SELECT * FROM csbetting_events WHERE id = @id");
|
|
if (!sql.Success || sql == null || sql.DataSet.Tables[0].Rows.Count == 0) return "赛事不存在。";
|
|
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 sb = new();
|
|
sb.AppendLine($"赛事：{name}");
|
|
sb.AppendLine($"状态：{statusStr}");
|
|
sb.AppendLine($"时间：{start:yyyy/MM/dd} ~ {end:yyyy/MM/dd}");
|
|
sb.AppendLine("比赛列表：");
|
|
|
|
sql.Parameters["@eid"] = eventId;
|
|
sql.ExecuteDataSet("SELECT id, team1_name, team2_name, status, bet_deadline, stage FROM csbetting_matches WHERE event_id = @eid ORDER BY start_time");
|
|
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 mStatusStr = mstatus switch { 0 => "未开始", 1 => "进行中", 2 => "已结束", _ => "未知" };
|
|
string matchLabel = $"{t1} vs {t2}";
|
|
string clickableMatch = matchLabel.CreateCmdInput($"比赛详情 {mid}");
|
|
sb.AppendLine($" [{mid}] {(stage != "" ? $"{stage} - " : "")} {clickableMatch} (状态：{mStatusStr}, 截止：{deadline:MM-dd HH:mm})");
|
|
}
|
|
}
|
|
return sb.ToString();
|
|
}
|
|
return "数据库连接失败。";
|
|
}
|
|
|
|
public static string GetMatchDetail(int matchId)
|
|
{
|
|
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) 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 eventName = "";
|
|
sql.Parameters["@eid"] = eventId;
|
|
DataRow? rowEvent = sql.ExecuteDataRow("SELECT name FROM csbetting_events WHERE id = @eid");
|
|
if (rowEvent != null)
|
|
{
|
|
eventName = rowEvent["name"].ToString() ?? "";
|
|
}
|
|
|
|
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}");
|
|
sb.AppendLine($"可用选项：");
|
|
if (available.Contains("team1_win")) sb.AppendLine($" - {t1}胜 (x 2.5)");
|
|
if (available.Contains("team2_win")) sb.AppendLine($" - {t2}胜 (x 2.5)");
|
|
if (available.Contains("score")) sb.AppendLine($" - 精确比分 (x 3.5)");
|
|
if (available.Contains("mvp")) sb.AppendLine($" - 赛事MVP (x 3.5)");
|
|
return sb.ToString();
|
|
}
|
|
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"]);
|
|
if (status != 0 || DateTime.Now > deadline)
|
|
{
|
|
error = "当前比赛已截止或非投注期。";
|
|
return false;
|
|
}
|
|
|
|
string available = row["available_options"]?.ToString() ?? "[]";
|
|
int optionType;
|
|
string optionValue = option;
|
|
if (option == "team1" && available.Contains("team1_win"))
|
|
optionType = 1;
|
|
else if (option == "team2" && available.Contains("team2_win"))
|
|
optionType = 2;
|
|
else if (option.StartsWith("score:") && available.Contains("score"))
|
|
{
|
|
optionType = 3;
|
|
optionValue = option.Replace("score:", "").Trim();
|
|
}
|
|
else if (option.StartsWith("mvp:") && available.Contains("mvp"))
|
|
{
|
|
optionType = 4;
|
|
optionValue = option.Replace("mvp:", "").Trim();
|
|
}
|
|
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["@time"] = DateTime.Now;
|
|
sql.Execute("INSERT INTO csbetting_bet_records (user_id, match_id, option_type, option_value, amount, bet_time) VALUES (@uid, @mid, @otype, @oval, @amt, @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)
|
|
{
|
|
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];
|
|
int status = Convert.ToInt32(row["status"]);
|
|
if (status == 2)
|
|
return "比赛已结算。";
|
|
|
|
int winTeam;
|
|
if (winner == "team1") winTeam = 1;
|
|
else if (winner == "team2") winTeam = 2;
|
|
else return "请指定获胜方为 team1 或 team2。";
|
|
|
|
// 更新比赛结果
|
|
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");
|
|
|
|
// 获取所有未结算投注
|
|
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)
|
|
{
|
|
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"]);
|
|
|
|
bool win = false;
|
|
if (otype == 1 && winTeam == 1) win = true;
|
|
else if (otype == 2 && winTeam == 2) win = true;
|
|
else if (otype == 3 && ovalue == result) win = true;
|
|
|
|
long payout = 0;
|
|
string note = "未中奖";
|
|
if (win)
|
|
{
|
|
double odds = otype switch { 2 or 3 => 3.5, _ => 2.5 };
|
|
payout = (long)(amount * odds);
|
|
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");
|
|
}
|
|
}
|
|
return $"比赛 {matchId} 结算完成。";
|
|
}
|
|
return "数据库连接失败。";
|
|
}
|
|
|
|
public static string GetMyBets(long uid)
|
|
{
|
|
using SQLHelper? sql = Factory.OpenFactory.GetSQLHelper();
|
|
if (sql != null)
|
|
{
|
|
sql.Parameters["@uid"] = uid;
|
|
sql.ExecuteDataSet(@"
|
|
SELECT br.id, br.match_id, br.option_type, br.option_value, br.amount, br.bet_time,
|
|
br.is_settled, br.payout, br.is_claimed, br.result_note,
|
|
m.team1_name, m.team2_name
|
|
FROM csbetting_bet_records br
|
|
JOIN csbetting_matches m ON br.match_id = m.id
|
|
WHERE br.user_id = @uid
|
|
ORDER BY br.bet_time DESC");
|
|
if (!sql.Success || sql.DataSet.Tables[0].Rows.Count == 0) return "你还没有任何竞猜记录。";
|
|
StringBuilder sb = new();
|
|
foreach (DataRow row in sql.DataSet.Tables[0].Rows)
|
|
{
|
|
long bid = Convert.ToInt64(row["id"]);
|
|
long mid = Convert.ToInt64(row["match_id"]);
|
|
string t1 = row["team1_name"].ToString() ?? "";
|
|
string t2 = row["team2_name"].ToString() ?? "";
|
|
int otype = Convert.ToInt32(row["option_type"]);
|
|
string ovalue = row["option_value"].ToString() ?? "";
|
|
long amt = Convert.ToInt64(row["amount"]);
|
|
bool settled = Convert.ToBoolean(row["is_settled"]);
|
|
long? payout = row["payout"] as long?;
|
|
bool claimed = Convert.ToBoolean(row["is_claimed"]);
|
|
|
|
string optStr = otype switch { 1 => $"{t1}胜", 2 => $"{t2}胜", 3 => $"比分 {ovalue}", 4 => $"MVP {ovalue}", _ => ovalue };
|
|
string statusStr = settled ? (payout > 0 ? (claimed ? $"+{payout} (已领)" : $"+{payout} (可领)") : "未中奖") : "进行中";
|
|
string matchLabel = $"{t1} vs {t2}";
|
|
string clickableMatch = matchLabel.CreateCmdInput($"比赛详情 {mid}");
|
|
sb.AppendLine($"[{bid}] {clickableMatch} | 选项：{optStr} | 投注：{amt} | 状态：{statusStr}");
|
|
}
|
|
return sb.ToString();
|
|
}
|
|
return "数据库连接失败。";
|
|
}
|
|
|
|
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, 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);
|
|
|
|
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.Execute(@"INSERT INTO csbetting_matches
|
|
(event_id, team1_name, team2_name, stage, start_time, bet_deadline, available_options, status)
|
|
VALUES (@eid, @t1, @t2, @stage, @start, @deadline, @opts, 0)");
|
|
|
|
if (sql.Success)
|
|
{
|
|
newMatchId = sql.LastInsertId;
|
|
return true;
|
|
}
|
|
error = "比赛创建失败，数据库错误。";
|
|
return false;
|
|
}
|
|
error = "数据库连接失败。";
|
|
return false;
|
|
}
|
|
}
|
|
}
|