using System;
using AlmaMagicaMerge.Utilidades;
using MySql.Data.MySqlClient;
using System.Collections.Generic;
using System.Linq;

namespace AlmaMagicaMerge
{
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("========== Alma magica mergeator ==========");
            Console.WriteLine("1- Obtener todos los ids de cuenta e introducirlos en custom_player_alma_template");
            Console.WriteLine("2- Crear nueva tabla con todo los niveles sumados y solo por id de cuenta custom_player_alma_template_merge");

            int l_Option = Convert.ToInt32(Console.ReadLine());

            switch(l_Option)
            {
                case 1:
                    SetAccountIds();
                    break;

                case 2:
                    MergeLevels();
                    break;
            }
            Console.ReadKey();
        }

        static void SetAccountIds()
        {
            MySqlDataReader l_DataReaderAlma;
            MySqlDataReader l_DataReaderAccounts;

            DBConnect l_DbCharacters = new DBConnect("127.0.0.1", "personajes", "root", "88REALre");

            DBConnect l_DbAccounts = new DBConnect("127.0.0.1", "personajes", "root", "88REALre");

            l_DbCharacters.ExecuteQuery("DROP TABLE IF EXISTS custom_player_alma_template_merge");
            l_DbCharacters.ExecuteQuery("CREATE TABLE `custom_player_alma_template_merge` (`id` int(11) NOT NULL AUTO_INCREMENT,`accountId` int(255) NOT NULL, `almaLevel` int(2) NOT NULL, PRIMARY KEY(`id`)) ENGINE = InnoDB AUTO_INCREMENT = 133 DEFAULT CHARSET = latin1");

            l_DataReaderAlma = l_DbCharacters.SelectTabla("SELECT * FROM custom_player_alma_template");

            List<string> l_Fields = new List<string>();
            List<string> l_Values = new List<string>();

            l_Fields.Add("accountId");
            l_Fields.Add("almaLevel");

            if (l_DataReaderAlma.HasRows)
            {
                while(l_DataReaderAlma.Read())
                {
                    Int64 l_CharacterId = Convert.ToInt64(l_DataReaderAlma["playerGuid"]);
                    Int64 l_Level = Convert.ToInt64(l_DataReaderAlma["almaLevel"]);

                    l_DataReaderAccounts = l_DbAccounts.SelectTabla("SELECT account FROM characters WHERE guid='" + l_CharacterId + "'");

                    l_Values.Clear();

                    if (l_DataReaderAccounts.HasRows)
                    {
                        l_DataReaderAccounts.Read();
                        Int64 l_Account = Convert.ToInt64(l_DataReaderAccounts["account"]);

                        l_Values.Add(l_Account.ToString());

                        l_Values.Add(l_Level.ToString()); ;

                        l_DataReaderAccounts.Close();
                        l_DbAccounts.Insert("custom_player_alma_template_merge", l_Fields, l_Values);
                    }
                    else
                    {
                        l_DataReaderAccounts.Close();
                    }
                }
            }
        }

        static void MergeLevels()
        {
            MySqlDataReader l_DataReaderAlmaLevel;
            MySqlDataReader l_DataLevelMerge;

            DBConnect l_DbCharacters = new DBConnect("127.0.0.1", "personajes", "root", "88REALre");

            l_DataReaderAlmaLevel = l_DbCharacters.SelectTabla("SELECT * FROM custom_player_alma_template_merge");

            List<Int64> l_AccountsIds = new List<Int64>();

            if (l_DataReaderAlmaLevel.HasRows)
            {
                while (l_DataReaderAlmaLevel.Read())
                {
                    l_AccountsIds.Add(Convert.ToInt64(l_DataReaderAlmaLevel["accountId"]));
                }
            }

            l_DataReaderAlmaLevel.Close();
            IEnumerable<Int64> l_AccountsIdsDistinct = l_AccountsIds.Distinct();

            Int64 l_Level = 0;

            foreach (int account in l_AccountsIdsDistinct)
            {
                l_DataLevelMerge = l_DbCharacters.SelectTabla("SELECT * FROM custom_player_alma_template_merge where accountid='" + account + "'");

                l_Level = 0;

                if (l_DataLevelMerge.HasRows)
                {
                    while (l_DataLevelMerge.Read())
                    {
                        l_Level += Convert.ToInt64(l_DataLevelMerge["almaLevel"]);
                    }
                }

                l_DataLevelMerge.Close();

                if (l_Level > 50)
                {
                    l_Level = 50;

                    List<string> l_Fields2 = new List<string>();
                    List<string> l_Values2 = new List<string>();

                    l_Fields2.Add("accountId");
                    l_Values2.Add(account.ToString());
                    l_DbCharacters.Insert("custom_alma_mas", l_Fields2, l_Values2);
                }

                List<string> l_Fields = new List<string>();
                List<string> l_Values = new List<string>();

                l_Fields.Add("accountId");
                l_Fields.Add("almaLevel");

                l_Values.Add(account.ToString());
                l_Values.Add(l_Level.ToString());
                l_DbCharacters.ExecuteQuery("DELETE FROM custom_player_alma_template_merge WHERE accountid='" + account + "'");

                l_DbCharacters.Insert("custom_player_alma_template_merge", l_Fields, l_Values);
            }
        }
    }
}