334 lines
13 KiB
C#
334 lines
13 KiB
C#
using Flandre.Core.Common;
|
|
using Flandre.Core.Messaging.Segments;
|
|
using Flandre.Core.Messaging;
|
|
using Manganese.Text;
|
|
using Microsoft.AspNetCore.Authorization;
|
|
using Microsoft.AspNetCore.Identity;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using Microsoft.EntityFrameworkCore;
|
|
using Mirai.Net.Sessions.Http.Managers;
|
|
using Newtonsoft.Json;
|
|
using System.Security.Claims;
|
|
using static asg_form.Controllers.InviteReferee;
|
|
using Manganese.Array;
|
|
using static asg_form.Controllers.schedule;
|
|
|
|
namespace asg_form.Controllers
|
|
{
|
|
public class Com : ControllerBase
|
|
{
|
|
|
|
private readonly RoleManager<Role> roleManager;
|
|
private readonly UserManager<User> userManager;
|
|
public Com(
|
|
RoleManager<Role> roleManager, UserManager<User> userManager)
|
|
{
|
|
|
|
this.roleManager = roleManager;
|
|
this.userManager = userManager;
|
|
}
|
|
/// <summary>
|
|
/// 获取我的场次
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
[Route("api/v1/com/my")]
|
|
[HttpPost]
|
|
[Authorize]
|
|
public async Task<ActionResult<string>> com_my()
|
|
{
|
|
string id = this.User.FindFirst(ClaimTypes.NameIdentifier)!.Value;
|
|
var user = await userManager.FindByIdAsync(id);
|
|
if (user.officium == "Commentator")
|
|
{
|
|
TestDbContext testDb = new TestDbContext();
|
|
var teamgame = testDb.team_Games.Where(a => a.commentary.IndexOf(id) >= 0).Select(a => new { a.id, a.team1_name, a.team2_name,a.belong,a.tag, a.bilibiliuri, a.commentary, a.referee,a.judge,a.person_type ,a.opentime,a.team1_piaoshu,a.team2_piaoshu}).OrderByDescending(a => a.opentime).ToList();
|
|
|
|
return JsonConvert.SerializeObject(teamgame);
|
|
}
|
|
return BadRequest(new error_mb { code = 400, message = $"你是{user.officium},你不是解说，无法操作" });
|
|
}
|
|
/// <summary>
|
|
/// 选定场次
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
[Route("api/v1/com/")]
|
|
[HttpPost]
|
|
[Authorize]
|
|
public async Task<ActionResult<object>> com_post(long gameid)
|
|
{
|
|
string id = this.User.FindFirst(ClaimTypes.NameIdentifier)!.Value;
|
|
var user = await userManager.FindByIdAsync(id);
|
|
if (user.officium == "Commentator")
|
|
{
|
|
if (user.Integral == null)
|
|
{
|
|
user.Integral = 0;
|
|
await userManager.UpdateAsync(user);
|
|
}
|
|
TestDbContext testDb = new TestDbContext();
|
|
string chinaname = user.chinaname;
|
|
var teamgame = await testDb.team_Games.FirstAsync(a => a.id == gameid);
|
|
if (teamgame.isAllowChoose == 0) return Ok(new error_mb { code = 401, message = "无法选择该比赛" });
|
|
var com = JsonConvert.DeserializeObject<List<com_json>>(teamgame.commentary);
|
|
com.Add(new com_json { id = id.ToInt32(), chinaname = chinaname });
|
|
teamgame.commentary = JsonConvert.SerializeObject(com);
|
|
await testDb.SaveChangesAsync();
|
|
user.Integral = user.Integral+5;
|
|
await userManager.UpdateAsync(user);
|
|
try
|
|
{
|
|
var message = new MessageBuilder().Add(new AtSegment(user.qqnumber??"2667210109")).Text($"解说:\r\n{chinaname}\r\n选择了比赛:\r\n{teamgame.team1_name} VS {teamgame.team2_name}").Build();
|
|
|
|
await runbot.runbotr.SendMessageAsync(MessageEnvironment.Channel, "925510646", null, message, "925510646");
|
|
|
|
}
|
|
catch
|
|
{
|
|
|
|
}
|
|
return "成功";
|
|
}
|
|
return BadRequest(new error_mb { code = 400, message = $"你是{user.officium},你不是解说，无法操作" });
|
|
}
|
|
|
|
public static int[] ConvertStringToIntArray(string input)
|
|
{
|
|
var cleanedInput = input.Trim('[', ']').Replace("'", "");
|
|
int[] result = cleanedInput.Split(',')
|
|
.Select(int.Parse)
|
|
.ToArray();
|
|
|
|
return result;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 导播选定场次
|
|
/// </summary>
|
|
[Route("api/v1/anchor")]
|
|
[HttpPost]
|
|
[Authorize]
|
|
public async Task<ActionResult<object>> anchorPost(string gameIds)
|
|
{
|
|
string id = this.User.FindFirst(ClaimTypes.NameIdentifier)!.Value;
|
|
var user = await userManager.FindByIdAsync(id);
|
|
|
|
if (user.officium != "Anchor")
|
|
{
|
|
return Ok(new error_mb { code = 401, message = $"你是{user.officium},你不是导播，无法操作" });
|
|
}
|
|
|
|
else
|
|
{
|
|
if (user.Integral == null)
|
|
{
|
|
user.Integral = 0;
|
|
await userManager.UpdateAsync(user);
|
|
}
|
|
|
|
TestDbContext testDb = new TestDbContext();
|
|
string chinaname = user.chinaname;
|
|
int[] gameIdArray = ConvertStringToIntArray(gameIds);
|
|
|
|
var message = $"导播:\r\n{chinaname}\r\n选择了比赛:";
|
|
|
|
foreach (var gameId in gameIdArray)
|
|
{
|
|
var teamgame = await testDb.team_Games.FirstOrDefaultAsync(a => a.id == gameId);
|
|
if (teamgame.isAllowChoose == 0) return Ok(new error_mb { code = 401, message = "存在无法选择的比赛" });
|
|
if (teamgame != null)
|
|
{
|
|
teamgame.referee = chinaname;
|
|
teamgame.referee_Id = (int)(user.Id);
|
|
await testDb.SaveChangesAsync();
|
|
user.Integral += 5;
|
|
await userManager.UpdateAsync(user);
|
|
message += $"\r\n{teamgame.team1_name} VS {teamgame.team2_name}";
|
|
}
|
|
}
|
|
try
|
|
{
|
|
var msg = new MessageBuilder().Add(new AtSegment(user.qqnumber ?? "2667210109")).Text(message).Build();
|
|
await runbot.runbotr.SendMessageAsync(MessageEnvironment.Channel, "925510646", null, msg, "925510646");
|
|
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
return Ok(new { code = 500, message = "服务器错误", ex });
|
|
}
|
|
|
|
return Ok(new { code = 200, message = "报名成功"}); ;
|
|
}
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
/// 删除导播选择的比赛
|
|
/// </summary>
|
|
[Route("api/v1/anchor")]
|
|
[HttpDelete]
|
|
[Authorize]
|
|
public async Task<ActionResult<object>> DeleteSelectedGame(int gameId,string reason)
|
|
{
|
|
string userId = this.User.FindFirst(ClaimTypes.NameIdentifier)!.Value;
|
|
var user = await userManager.FindByIdAsync(userId);
|
|
|
|
if (user.officium != "Anchor")
|
|
{
|
|
return Ok(new error_mb { code = 401, message = $"你是{user.officium},你不是导播，无法操作" });
|
|
}
|
|
|
|
TestDbContext testDb = new TestDbContext();
|
|
|
|
var teamGame = await testDb.team_Games.FirstOrDefaultAsync(a => a.id == gameId);
|
|
if (teamGame == null)
|
|
{
|
|
return NotFound(new { code = 404, message = "比赛未找到" });
|
|
}
|
|
|
|
teamGame.referee = null;
|
|
teamGame.referee_Id = null;
|
|
await testDb.SaveChangesAsync();
|
|
|
|
user.Integral = user.Integral - 5 > 0 ? user.Integral - 5 : 0; // 确保积分不会减少到负数
|
|
await userManager.UpdateAsync(user);
|
|
|
|
try
|
|
{
|
|
var message = new MessageBuilder()
|
|
.Add(new AtSegment(user.qqnumber ?? "2667210109"))
|
|
.Text($"导播 {user.chinaname} 已取消比赛 {teamGame.team1_name} VS {teamGame.team2_name} 的选择,\n原因是{reason}")
|
|
.Build();
|
|
|
|
await runbot.runbotr.SendMessageAsync(MessageEnvironment.Channel, "925510646", null, message, "925510646");
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
return StatusCode(500, new { code = 500, message = "服务器错误", ex });
|
|
}
|
|
return Ok(new { code = 200, message = "删除成功" });
|
|
}
|
|
|
|
|
|
public class com_json
|
|
{
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
public int id { get; set; }
|
|
/// <summary>
|
|
/// 老恐龙
|
|
/// </summary>
|
|
public string chinaname { get; set; }
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
/// 取消选班
|
|
/// </summary>
|
|
/// <param name="gameid"></param>
|
|
/// <returns></returns>
|
|
[Route("api/v1/com/")]
|
|
[HttpDelete]
|
|
[Authorize]
|
|
public async Task<ActionResult<string>> com_del(long gameid,string Cancellation_Reason )
|
|
{
|
|
string id = this.User.FindFirst(ClaimTypes.NameIdentifier)!.Value;
|
|
var user = await userManager.FindByIdAsync(id);
|
|
if (user.Integral == null)
|
|
{
|
|
user.Integral = 0;
|
|
await userManager.UpdateAsync(user);
|
|
}
|
|
if (user.officium == "Commentator")
|
|
{
|
|
TestDbContext testDb = new TestDbContext();
|
|
string chinaname = user.chinaname;
|
|
var teamgame = await testDb.team_Games.FirstAsync(a => a.id == gameid);
|
|
var com = JsonConvert.DeserializeObject<List<com_json>>(teamgame.commentary);
|
|
com.Remove(com.First(a => a.id == id.ToInt32()));
|
|
try{
|
|
user.Integral = cut_value((long)user.Integral);
|
|
await userManager.UpdateAsync(user);
|
|
}
|
|
catch{
|
|
return BadRequest(new error_mb { code = 400, message = $"你的金钱无法满足你完成以下操作" });
|
|
|
|
}
|
|
teamgame.commentary = JsonConvert.SerializeObject(com);
|
|
await testDb.SaveChangesAsync();
|
|
try
|
|
{
|
|
var message = new MessageBuilder().Add(new AtSegment(user.qqnumber ?? "2667210109")).Text($"解说:\r\n{chinaname}\r\n取消了比赛:\r\n{teamgame.team1_name} VS {teamgame.team2_name}\r\n原因:{Cancellation_Reason}").Build();
|
|
|
|
await runbot.runbotr.SendMessageAsync(MessageEnvironment.Channel, "925510646", null, message, "925510646");
|
|
|
|
}
|
|
catch
|
|
{
|
|
|
|
}
|
|
return "成功";
|
|
}
|
|
return BadRequest(new error_mb { code = 400, message = $"你是{user.officium},你不是解说，无法操作" });
|
|
}
|
|
|
|
[Route("api/v1/com/search_ok_regist")]
|
|
[HttpPost]
|
|
[Authorize]
|
|
[ResponseCache(Duration = 60)]
|
|
public async Task<ActionResult<string>> Search()
|
|
{
|
|
TestDbContext testDb = new TestDbContext();
|
|
var team = await testDb.team_Games.Select(a => new { a.id, a.commentary, a.opentime, a.team1_name, a.team2_name, a.belong }).ToListAsync();
|
|
var team1 = team.Where(a => a.commentary.Split(",").Length <= 1);
|
|
return JsonConvert.SerializeObject(team1);
|
|
}
|
|
|
|
|
|
[Route("api/v1/com/Integral/ranking")]
|
|
[HttpPost]
|
|
[Authorize]
|
|
[ResponseCache(Duration = 60)]
|
|
public async Task<ActionResult<object>> ranking()
|
|
{
|
|
object user= await userManager.Users.OrderByDescending(a => a.Integral).Select(a=>new{a.Id,a.chinaname,a.Integral}).Take(10).ToListAsync();
|
|
return user;
|
|
}
|
|
|
|
public long cut_value(long value)
|
|
{
|
|
long _value = value;
|
|
value = value - 5;
|
|
if (value < 0)
|
|
{
|
|
throw new ArgumentException("你已经没钱啦！");
|
|
|
|
}
|
|
return value;
|
|
}
|
|
|
|
[Route("api/v1/com/")]
|
|
[HttpGet]
|
|
[Authorize]
|
|
public async Task<ActionResult<int>> com_cout(long gameid)
|
|
{
|
|
string id = this.User.FindFirst(ClaimTypes.NameIdentifier)!.Value;
|
|
var user = await userManager.FindByIdAsync(id);
|
|
if (user.officium == "Commentator")
|
|
{
|
|
var chinaname = user.chinaname;
|
|
TestDbContext testDb = new TestDbContext();
|
|
int a = await testDb.team_Games.CountAsync(a => a.commentary.IndexOf(id) >= 0);
|
|
return a;
|
|
}
|
|
return BadRequest(new error_mb { code = 400, message = $"你是{user.officium},你不是解说，无法操作" });
|
|
}
|
|
|
|
}
|
|
}
|
|
|
|
|