#include <sourcemod>

enum STATS_NAMES
{
  K,
  D,
  TK
}
new bool:OnDB[MAXPLAYERS+1];
new Handle:g_hStatsDb;
new String:g_sSQLTable[100];
new String:g_sSqlInsert[] = "INSERT INTO `%s` VALUES (NULL,'%s','0','0','0');";
new String:g_sSqlCreate[] = "CREATE TABLE IF NOT EXISTS `%s` (id INTEGER PRIMARY KEY, steam TEXT, KILLS NUMERIC, DEATHS NUMERIC, TEAMKILLS NUMERIC)";
new String:g_sSqlSave[] = "UPDATE `%s` SET KILLS = '%i', DEATHS = '%i', TEAMKILLS='%i';";
new String:g_sSqlRetrieveClient[] = "SELECT * FROM `%s` WHERE steam='%s';";
new String:g_aClientSteam[MAXPLAYERS+1][64];  
new g_aSession[MAXPLAYERS+1][STATS_NAMES];
new g_aStats[MAXPLAYERS+1][STATS_NAMES];
new bool:g_iReady[MAXPLAYERS + 1];

public OnPluginStart()
{
  HookEvent("player_death",    player_death);
  RegConsoleCmd("mystats",    mystats_cmd);
   
  DB_Connect();
}

public DB_Connect()
{
  decl String:sError[256];
  g_hStatsDb = SQLite_UseDatabase("Stats",sError,sizeof(sError));
  if(g_hStatsDb == INVALID_HANDLE)
  {
   SetFailState("[Stats] Не удается подключиться к базе данных (%s)",sError);
  }
  SQL_LockDatabase(g_hStatsDb);
  new String:sQuery[1200];
  Format(sQuery,sizeof(sQuery),g_sSqlCreate,g_sSQLTable);
  SQL_FastQuery(g_hStatsDb,sQuery);
  SQL_UnlockDatabase(g_hStatsDb);

  for(new i=1;i<=MaxClients;i++)
  {
   if(IsClientInGame(i))
   {
    OnClientPutInServer(i);
   }
  }
}

public OnClientPutInServer(client)
{
  if(g_hStatsDb != INVALID_HANDLE)
  {
   LoadPlayer(client);
  }
}

public OnClientDisconnect(client)
{
  if(IsFakeClient(client))  
  {
   return;
  }
  SalvarPlayer(client);
  OnDB[client] = false;
}

public OnConfigsExecuted()  
{
  DB_Connect();
}

public LoadPlayer(client)
{

  OnDB[client]=false;
   
  for(new i=1;i<=3;i++)
  {
   g_aSession[client][i] = 0;
   g_aStats[client][i] = 0;
  }
   
  new String:auth[64];
  GetClientAuthString(client,auth,sizeof(auth));
  strcopy(g_aClientSteam[client],64,auth);
  new String:query[500];

  Format(query,sizeof(query),g_sSqlRetrieveClient,g_sSQLTable,auth);  
  if(g_hStatsDb != INVALID_HANDLE)
  {
   SQL_TQuery(g_hStatsDb,SQL_LoadPlayerCallback,query,client);
  }
}

public SQL_LoadPlayerCallback(Handle:owner, Handle:hndl, const String:error[], any:client)
{
   
  if(hndl == INVALID_HANDLE)
  {
   LogError("[Stats] Загрузка игрока: Провал (%s)", error);
   return;
  }
  if(!IsClientInGame(client))
  {
   return;
  }

  new String:auth[64];
  GetClientAuthString(client,auth,sizeof(auth));
  if(!StrEqual(auth,g_aClientSteam[client]))
  {
   return;
  }

  if(SQL_HasResultSet(hndl) && SQL_FetchRow(hndl))
  {
   for(new i=1;i<=3;i++)
   {
    g_aStats[client][i]=SQL_FetchInt(hndl,i);
   }
  }  
  else
  {
   new String:query[500];
   Format(query,sizeof(query),g_sSqlInsert ,g_sSQLTable,g_aClientSteam[client]);
   SQL_TQuery(g_hStatsDb,SQL_NothingCallback,query,_,DBPrio_High);
  }
  OnDB[client] = true;
}

public SQL_NothingCallback(Handle:owner, Handle:hndl, const String:error[], any:client)
{
  if(hndl == INVALID_HANDLE)
  {
   LogError("[Stats] Запрос:Провал (%s)", error);
   return;
  }
}

public SalvarPlayer(client)
{
  if(IsFakeClient(client))  
  {
   return;
  }
  if(!OnDB[client])
  {
   return;
  }
   
  new String:query[1500];
  Format(query,sizeof(query),g_sSqlSave,g_sSQLTable,g_aClientSteam[client],g_aStats[client][K],g_aStats[client][D],g_aStats[client][TK]);
  SQL_TQuery(g_hStatsDb,SQL_SaveCallback,query,client,DBPrio_High);
}

public SQL_SaveCallback(Handle:owner, Handle:hndl, const String:error[], any:client)
{
  if(hndl == INVALID_HANDLE)
  {
   LogError("[Stats] Сохранить игрока:провал (%s)", error);
   return;
  }  
}

public player_death(Handle:event, const String:name[], bool:dontBroadcast)
{
  new killer = GetClientOfUserId(GetEventInt(event, "attacker"));
  if (killer < 1 || IsFakeClient(killer))
  {
   return;
  }
  new victim = GetClientOfUserId(GetEventInt(event, "userid"));
  if (GetClientTeam(killer) == GetClientTeam(victim))
  {
   g_aStats[killer][TK]++;
  }
  g_aStats[killer][K]++;
  g_aStats[victim][D]++;
}

public Action:mystats_cmd(client, args)
{
  if (0 < client <= MaxClients)
  {
   if (g_iReady[client])  
   {
    PrintToChat(client, "Убийств: %d", g_aStats[client][K]);
    PrintToChat(client, "Смертей: %d", g_aStats[client][D]);
    PrintToChat(client, "Тим кил: %d", g_aStats[client][TK]);
   }
   else PrintToChat(client, "Вы не авторизованы");
  }
  return Plugin_Handled;
}

public OnMapEnd()
{

}

public OnPluginEnd()
{

}