GameRoom.GameProcess.cs 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280
  1. using System;
  2. using System.Linq;
  3. using System.Threading;
  4. using System.Threading.Tasks;
  5. using MafiaTelegramBot.Controllers;
  6. using MafiaTelegramBot.CustomCollections.Extensions;
  7. using MafiaTelegramBot.Models;
  8. using MafiaTelegramBot.Resources;
  9. using Telegram.Bot.Types;
  10. using Timer = System.Timers.Timer;
  11. namespace MafiaTelegramBot.Game.GameRooms
  12. {
  13. public partial class GameRoom
  14. {
  15. public void Start()
  16. {
  17. new Task(async () =>
  18. {
  19. IsRunning = true;
  20. await FirstNight();
  21. await FirstDay();
  22. await GameCycle();
  23. await EndOfGame();
  24. }).Start();
  25. }
  26. private async Task FirstDay()
  27. {
  28. IsDay = true;
  29. await PlayersCh.SendSticker(Stickers.Sticker["Day"]);
  30. await PlayersCh.Send(strings.first_day_message);
  31. await Task.Run(async() =>
  32. {
  33. var turnsCount = _turnOrder.Count;
  34. Player firstPlayer = null;
  35. for (var i = 0; i < turnsCount; ++i)
  36. {
  37. var player = _turnOrder.Dequeue();
  38. if(!player.IsPlaying) continue;
  39. await player.CurrentRole.DayAction();
  40. if (firstPlayer != null && player.IsPlaying) _turnOrder.Enqueue(player);
  41. else firstPlayer = player;
  42. }
  43. _turnOrder.Enqueue(firstPlayer);
  44. });
  45. }
  46. private async Task FirstNight()
  47. {
  48. IsFirstCycle = true;
  49. IsDay = false;
  50. await Task.Run(async() =>
  51. {
  52. await PlayersCh.SendSticker(Stickers.Sticker["Night"]);
  53. await PlayersCh.Send(strings.city_falls_asleep);
  54. var mafia = Players.Values.Where(player => player.GetRole() is Roles.Mafia).ToArray();
  55. var don = Players.Values.FirstOrDefault(player => player.GetRole() is Roles.Don);
  56. var message = strings.your_teammates;
  57. if (don != null) message += $"\n\\({don.TurnOrder}\\) {don.NickName} - {roles.Don}";
  58. message = mafia.Aggregate(message, (current, player) => current + $"\n\\({player.TurnOrder}\\) {player.NickName}");
  59. await MafiaCh.Send(message);
  60. var resetEvent = new ManualResetEvent(false);
  61. var timer = new Timer
  62. {
  63. AutoReset = false,
  64. Interval = 10 * 1000
  65. };
  66. timer.Elapsed += (_, _) => resetEvent.Set();
  67. timer.Start();
  68. foreach (var player in Players.Values)
  69. {
  70. player.CurrentRole.KnownRoles.Add(player);
  71. if(player.GetRole() is Roles.Don or Roles.Mafia) player.CurrentRole.KnownRoles.AddRange(
  72. Players.Values.Where(p=> player.Id != p.Id && p.GetRole() is Roles.Mafia or Roles.Don)
  73. );
  74. }
  75. resetEvent.WaitOne();
  76. });
  77. }
  78. private async Task GameCycle()
  79. {
  80. IsFirstCycle = false;
  81. await Task.Run(async () =>
  82. {
  83. var alivePlayers = Players.Values.Where(p => p.IsAlive).ToList();
  84. var aliveMafia = alivePlayers.Where(p => p.GetRole() is Roles.Don or Roles.Mafia).ToList();
  85. var gameNotEnded = alivePlayers.Count > 2 * aliveMafia.Count && aliveMafia.Count > 0;
  86. while (gameNotEnded)
  87. {
  88. await NightPhase();
  89. await SummingUpPhase();
  90. alivePlayers = Players.Values.Where(p => p.IsAlive).ToList();
  91. aliveMafia = alivePlayers.Where(p => p.GetRole() is Roles.Don or Roles.Mafia).ToList();
  92. gameNotEnded = alivePlayers.Count > 2 * aliveMafia.Count && aliveMafia.Count > 0;
  93. if (!gameNotEnded) break;
  94. await DayPhase();
  95. await DefencePhase();
  96. await DispatchPhase();
  97. alivePlayers = Players.Values.Where(p => p.IsAlive).ToList();
  98. aliveMafia = alivePlayers.Where(p => p.GetRole() is Roles.Don or Roles.Mafia).ToList();
  99. gameNotEnded = alivePlayers.Count > 2 * aliveMafia.Count && aliveMafia.Count > 0;
  100. if (!gameNotEnded) break;
  101. }
  102. });
  103. }
  104. private async Task DayPhase()
  105. {
  106. IsDay = true;
  107. var turnsCount = _turnOrder.Count;
  108. Player firstPlayer = null;
  109. for (var i = 0; i < turnsCount; ++i)
  110. {
  111. var player = _turnOrder.Dequeue();
  112. if(!player.IsPlaying || !player.IsAlive) continue;
  113. if (firstPlayer == null) player.IsFirst = true;
  114. await player.CurrentRole.DayAction();
  115. if (player.IsFirst) firstPlayer = player;
  116. else _turnOrder.Enqueue(player);
  117. }
  118. firstPlayer!.IsFirst = false;
  119. _turnOrder.Enqueue(firstPlayer);
  120. }
  121. private async Task NightPhase()
  122. {
  123. IsDay = false;
  124. await PlayersCh.SendSticker(Stickers.Sticker["Night"]);
  125. await PlayersCh.Send(strings.city_falls_asleep);
  126. await Task.Run(async () =>
  127. {
  128. var resetEvent = new ManualResetEvent(false);
  129. var timer = new Timer{ Interval = 60*1000, AutoReset = false };
  130. foreach (var player in Players.Values.Where(p=>p.IsAlive))
  131. {
  132. await player.CurrentRole.NightAction();
  133. }
  134. timer.Elapsed += (_, _) => resetEvent.Set();
  135. timer.Start();
  136. resetEvent.WaitOne();
  137. });
  138. }
  139. public async Task SummingUpPhase()
  140. {
  141. await Task.Run(async () =>
  142. {
  143. long killedPlayerId = -1;
  144. foreach (var (role, players) in PlayersRole)
  145. {
  146. if (role is Roles.Mafia)
  147. {
  148. foreach (var mafia in players) mafia.IsSpeaker = false;
  149. var votes = players.Where(p=> p.IsAlive)
  150. .GroupBy(p => p.CurrentRole.GetNightTarget())
  151. .Select(item => new {id = item.Key, count = item.Count()})
  152. .ToList();
  153. var max = votes.Max(item => item.count);
  154. var maxCount = votes.Count(item => item.count == max);
  155. if (maxCount != 1) continue;
  156. var selected = votes.First(item => item.count == max);
  157. if (selected.id == -1) continue;
  158. killedPlayerId = selected.id;
  159. Players[killedPlayerId].IsAlive = false;
  160. foreach (var mafia in players) await mafia.CurrentRole.ApplyNightActionResult();
  161. }
  162. else if (players.Count == 1)
  163. {
  164. var player = players[0];
  165. if (role != Roles.Doctor) player.CanBeHealed = true;
  166. await player.CurrentRole.ApplyNightActionResult();
  167. }
  168. }
  169. var message = strings.city_wakes_up;
  170. if (killedPlayerId != -1 && !Players[killedPlayerId].IsAlive) message += $"{strings.at_this_night} {Players[killedPlayerId].NickName}";
  171. else message += strings.everyone_survived;
  172. await PlayersCh.SendSticker(Stickers.Sticker["Day"]);
  173. await PlayersCh.Send(message);
  174. });
  175. }
  176. private async Task DefencePhase()
  177. {
  178. await Task.Run( async () =>
  179. {
  180. try
  181. {
  182. var voteUpPlayers = VoteUpList.Where(p => p.VotedCount == LargeVote);
  183. //проверяем есть ли кому защищаться
  184. if (voteUpPlayers.Count() > 1)
  185. {
  186. foreach (var defender in VoteUpList)
  187. {
  188. await defender.CurrentRole.DefenceAction();
  189. }
  190. var alivePlayers = Players.Values.Where(p => p.IsAlive).ToList();
  191. foreach (var player in alivePlayers)
  192. {
  193. if (!player.IsPlaying || !player.IsAlive) continue;
  194. await player.CurrentRole.VotingUpDefenders();
  195. }
  196. }
  197. }
  198. catch (Exception e)
  199. {
  200. Console.WriteLine(e);
  201. throw;
  202. }
  203. });
  204. }
  205. private async Task DispatchPhase()
  206. {
  207. await Task.Run( () =>
  208. {
  209. });
  210. }
  211. public async Task<Message> PutUpVote(long playerId, long targetId)
  212. {
  213. var player = Players[playerId];
  214. VoteUpList.AddUnique(player);
  215. if (playerId != targetId)
  216. {
  217. var target = Players[targetId];
  218. target.VotedCount++;
  219. if (target.VotedCount > LargeVote) LargeVote = target.VotedCount;
  220. await PlayersCh.SendExcept(player.ChatId, $"{player.NickName} {strings.vote_to} {target.NickName}");
  221. return await Bot.SendWithMarkdown2(player.ChatId, $"{strings.you_vote_player} {target.NickName}");
  222. }
  223. await PlayersCh.SendExcept(player.ChatId, $"{player.NickName} {strings.vote_to_self}");
  224. return await Bot.SendWithMarkdown2(player.ChatId, strings.you_vote_to_self);
  225. }
  226. private async Task EndOfGame()
  227. {
  228. await Task.Run(async () =>
  229. {
  230. var aliveMafia = Players.Values.Where(p => p.GetRole() is Roles.Don or Roles.Mafia && p.IsAlive).ToList();
  231. if (aliveMafia.Count == 0)
  232. {
  233. await PlayersCh.Send(strings.villagers_won, exceptDied: false);
  234. await PlayersCh.SendSticker(Stickers.Sticker["VillagerWins"], false);
  235. }
  236. else
  237. {
  238. await PlayersCh.Send(strings.mafia_won, exceptDied: false);
  239. await PlayersCh.SendSticker(Stickers.Sticker["MafiaWins"], false);
  240. }
  241. var rolesMessage = strings.in_this_game_roles;
  242. var sortedPLayers = Players.Values.ToList();
  243. sortedPLayers.Sort((x, y) => x.TurnOrder - y.TurnOrder);
  244. foreach (var player in sortedPLayers)
  245. {
  246. rolesMessage += $"\n\\({player.TurnOrder}\\) {player.NickName} - {player.GetRoleName()}";
  247. player.ResetState();
  248. }
  249. await PlayersCh.Send(rolesMessage);
  250. IsRunning = false;
  251. IsDay = false;
  252. _turnOrder.Clear();
  253. Settings.Clear();
  254. foreach (var (_, list) in PlayersRole) list.Clear();
  255. if (!Players.ContainsKey(Owner.Id) || Players.Count == 0) new Task(async() =>
  256. await RoomController.DissolveRoom(RoomEncrypter.GetCode(RoomName))).Start();
  257. else
  258. {
  259. await Bot.SendWithMarkdown2(Owner.ChatId, strings.thanks_for_game, Keyboard.OwnerGameMenu);
  260. await PlayersCh.SendExcept(Owner.Id, strings.thanks_for_game, Keyboard.PlayerGameMenu, false);
  261. }
  262. });
  263. }
  264. }
  265. }