reallife-gamemode/ReallifeGamemode.Server/Managers/ManagerOfInventory.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Timers;
using GTANetworkAPI;
using Newtonsoft.Json;
using ReallifeGamemode.Server.Entities;
using ReallifeGamemode.Server.Extensions;
using ReallifeGamemode.Server.Models;
using ReallifeGamemode.Server.Services;

namespace ReallifeGamemode.Server.Managers
{
  class ManagerOfInventory : Script
  {
    private static Dictionary<int, (int[],int[])> TradeItems { get; set; } = new Dictionary<int, (int[], int[])>();
    private static Dictionary<int, Timer> TradeTimer { get; set; } = new Dictionary<int,Timer>(); 
    private static Dictionary<int, int> TradeValue { get; set; } = new Dictionary<int, int>();

    public static void GetUserItems(Client client)
    {
      User user = client.GetUser();

      List<int> ItemId = new List<int>();
      List<int> amount = new List<int>();

      using (var context = new DatabaseContext())
      {
        List<UserItem> userItems = context.UserItems.ToList().FindAll(i => i.UserId == user.Id);

        foreach (var item in userItems)
        {
          ItemId.Add(item.ItemId);
          amount.Add(item.Amount);
        }
        client.TriggerEvent("inventoryShow", ItemId.ToArray(), amount.ToArray());
      }
    }

    [RemoteEvent("invUseItem")]
    public void ServerEvent_invUseItem(Client client, int itemId)
    {
      User user = client.GetUser();

      using (var context = new DatabaseContext())
      {
        UserItem item = context.UserItems.Where(u => u.UserId == user.Id && u.ItemId == itemId).FirstOrDefault();
        if (item.Amount > 1)
        {
          item.Amount -= 1;
        }
        else
        {
          context.UserItems.Remove(item);
        }
        context.SaveChanges();
        return;
      }
    }

    [RemoteEvent("tradeItem")]
    public void ServerEvent_tradeItem(Client client, int value, string nameOrId, string itemIdArrStr, string itemAmountArrStr)
    {
      int[] itemIdArr = JsonConvert.DeserializeObject<int[]>(itemIdArrStr);
      int[] itemAmountArr = JsonConvert.DeserializeObject<int[]>(itemAmountArrStr);
      User user = client.GetUser();
      Client target = ClientService.GetClientByNameOrId(nameOrId);
      if (target == null || !target.IsLoggedIn())
      {
        ChatService.PlayerNotFound(client);
        return;
      }
      if (target.HasData("inTrade") && target.GetData("inTrade") == true)
      {
        ChatService.SendMessage(client, $"~r~[FEHLER] ~w~{target.Name} befindet sich bereits in einem Handel.");
        return;
      }
      using (var context = new DatabaseContext())
      {
        for (int x = 0; x < itemIdArr.Length; x++)
        {
          int itemId = itemIdArr[x];
          int itemAmount = itemAmountArr[x];
          UserItem item = context.UserItems.Where(u => u.UserId == user.Id && u.ItemId == itemId).FirstOrDefault();
          if (item.Amount - itemAmount > 0)
          {
            item.Amount -= itemAmount;
          }
          else
          {
            context.UserItems.Remove(item);
          }
          context.SaveChanges();
        }
      }
      TradeItems[user.Id] = (itemIdArr, itemAmountArr);
      TradeValue[user.Id] = value;
      target.SetData("tradePartner", user.Id);
      target.SetData("trade", client.Name);
      SendTradeOffer(target,client);
    }

    public void SendTradeOffer(Client client, Client sender)
    {
      client.SetData("inTrade", true);
      sender.SetData("inTrade", true);
      ChatService.SendMessage(client, $"~b~ Du hast eine Handelsanfrage von {sender.Name} bekommen.");
      ChatService.SendMessage(client, $"~b~ Drücke '~w~N~b~' um die Handelsanfrage zu akzeptieren.");
      User user = sender.GetUser();
      Timer tradeTimer = new Timer(30000);
      TradeTimer[user.Id] = tradeTimer;
      tradeTimer.Start();
      tradeTimer.Elapsed += (s, e) => { SendBackToSender(sender); client.SetData("inTrade", false); };
    }


    public void SendBackToSender(Client client)
    {
      User user = client.GetUser();
      ChatService.SendMessage(client, "Dein Handelpartner hat die Anfrage nicht angenommen.");
      (int[] itemIdArr, int[] itemAmountArr) = TradeItems[user.Id];
      Timer timer = TradeTimer[user.Id];
      timer.Stop();
      using (var context = new DatabaseContext())
      {
        for (int x = 0; x < itemIdArr.Length; x++)
        {
          int itemId = itemIdArr[x];
          int itemAmount = itemAmountArr[x];
          UserItem item = context.UserItems.Where(u => u.UserId == user.Id && u.ItemId == itemId).FirstOrDefault();
          if (item != null)
          {
            item.Amount += itemAmount;
          }
          else
          {
            var newItem = new UserItem
            {
              ItemId = itemId,
              UserId = user.Id,
              Amount = itemAmount,
              Slot = -1
            };

            context.UserItems.Add(newItem);
          }
          context.SaveChanges();
        }
      }
    }

    [RemoteEvent("declineTrade")]
    public void ServerEvent_declineTrade(Client client)
    {
      string name = client.GetData("trade");
      Client target = ClientService.GetClientByNameOrId(name);
      if (target == null || !target.IsLoggedIn())
      {
        ChatService.PlayerNotFound(client);
        return;
      }
      client.SetData("inTrade", false);
      target.SetData("inTrade", false);
      SendBackToSender(target);
    }

    public static void OpenTradeAccept(Client client)
    {
      User user = client.GetUser();
      int id = client.GetData("tradePartner");
      (int[] itemIdArr, int[] itemAmountArr) = TradeItems[id];
      Timer tradeTimer = TradeTimer[id];
      tradeTimer.Stop();
      tradeTimer.Start();
      client.TriggerEvent("openTradeWindow", TradeValue[id], itemIdArr, itemAmountArr);
    }

    [RemoteEvent("acceptTrade")]
    public void ServerEvent_AcceptTrade(Client client)
    {
      client.SetData("inTrade", false);
      
      User user = client.GetUser();
      int id = client.GetData("tradePartner");
      (int[] itemIdArr, int[] itemAmountArr) = TradeItems[id];
      Timer tradeTimer = TradeTimer[id];
      tradeTimer.Stop();
      string name = client.GetData("trade");
      Client target = ClientService.GetClientByNameOrId(name);
      if (target == null || !target.IsLoggedIn())
      {
        ChatService.PlayerNotFound(client);
        return;
      }
      target.SetData("inTrade", false);
      ChatService.SendMessage(target, $"{client.Name} hat deine Anfrage angenommen.");
      using (var context = new DatabaseContext())
      {
        for (int x = 0; x < itemIdArr.Length; x++)
        {
          int itemId = itemIdArr[x];
          int itemAmount = itemAmountArr[x];
          UserItem item = context.UserItems.Where(u => u.UserId == user.Id && u.ItemId == itemId).FirstOrDefault();
          if (item != null)
          {
            item.Amount += itemAmount;
          }
          else
          {
            var newItem = new UserItem
            {
              ItemId = itemId,
              UserId = user.Id,
              Amount = itemAmount,
              Slot = -1
            };

            context.UserItems.Add(newItem);
          }
          context.SaveChanges();
        }
      }
    }
  }
}