//// See https://aka.ms/new-console-template for more information
//using Newtonsoft.Json;
//using System;
//using System;
//using System.Collections.Generic;
//using System.ComponentModel;
//using System.Data;
//using System.Data.OleDb;
//using System.Data.SqlClient;
//using System.Diagnostics;
//using System.Drawing;
//using System.Globalization;
//using System.Linq;
//using System.Net.Http;
//using System.Security.Authentication;
//using System.Security.Cryptography.X509Certificates;
//using System.Text;
//using System.Threading;
//using System.Threading.Tasks;
//using System.Xml;
//using Npgsql;

//internal class Plat_integ
//{
//    //tempo medio de execucao para processamente sincrono: 15 dias: 5,4s / 30 dias:10,0s / 60 dias:16,2s
//    static string PG_CONN_STRING_DEV = "Server = smart-energia-dev-pgsql.cykff7tj7mik.us-east-1.rds.amazonaws.com; Port = 5432; Database = smartimptest; User Id = postgres; Password = VfHml#Z78!%kvvNM;";
//    static string PG_CONN_STRING_PROD = "Server = smart-energia-dev-pgsql.cykff7tj7mik.us-east-1.rds.amazonaws.com; Port = 5432; Database = smartenergiaprod; User Id = postgres; Password = VfHml#Z78!%kvvNM;";

//    static string ENVIRONMENT = "prod"; // "dev" | "prod"

//    static string BUILD_FOR = "access"; // "access" | "postgres"

//    static void Main()
//    {
//        MainAsync().Wait();
//    }

//    private static async Task<int> MainAsync()
//    {
//        string caminho_BD;
//        int max_i;
//        DateTime data_inicial;
//        DateTime tempo_cod, tempo_ini;

//        Thread.CurrentThread.CurrentCulture = CultureInfo.CreateSpecificCulture("en-GB");

//        //auxiliar para calculo do tempo de execucao do codigo
//        tempo_ini = DateTime.Now;
//        tempo_cod = DateTime.Now;

//        //caminho do BD em que sera salvo os valores de PLD
//        caminho_BD = @"X:\Middle\Informativo Setorial\Modelo Word\BD_SCDE.accdb";

//        //data inicial conforme ultimo valor salvo no BD
//        data_inicial = data_inicio_BD(caminho_BD);

//        DateTime data_final = DateTime.Now.AddDays(1);

//        if (data_inicial.Year != data_final.Year)
//        {
//            data_final = new DateTime(data_inicial.Year, 12, 31);
//        }

//        //roda a requisicao de forma sincrona para obter o numero total de paginas - tambem busca os dados da primeira pagina
//        max_i = processar_XML_sync(requisicao_http_sync(xml_requisicao(1, data_inicial, data_final)), caminho_BD);
//        Console.Write("Tempo de execucao da etapa inicial: {0}", DateTime.Now - tempo_cod);
//        Console.WriteLine("\nHavera {0} processos rodando em paralelo", max_i - 1);
//        tempo_cod = DateTime.Now;

//        if (BUILD_FOR == "postgres")
//        {
//            int pagesN;
//            for (int i = 2; i <= max_i; i++)
//            {
//                pagesN = processar_XML_sync(requisicao_http_sync(xml_requisicao(i, data_inicial, data_final)), caminho_BD);
//            }
//        }
//        else
//        {
//            //abre a conexao com o BD
//            OleDbConnection access_conn = new("Provider=Microsoft.ACE.OLEDB.12.0;Data Source=" + caminho_BD + ";Jet OLEDB:Database Password=gds21");
//            access_conn.Open();
//            await Task.WhenAll(assync_requisicao_http(data_inicial, max_i, caminho_BD, access_conn));
//            Thread.Sleep(2000);
//            Console.WriteLine("Concluido. Tempo TOTAL de execucao: {0}", DateTime.Now - tempo_ini);
//            //repete a requisicao de forma assincrona para as demais paginas
//            access_conn.Close();
//        }
//        return 0;
//    }

//    public static async Task<int> assync_requisicao_http(DateTime data_inicial, int max_i, string caminho_BD, OleDbConnection access_conn)
//    {
//        int i;
//        var handler = new HttpClientHandler();
//        Task<HttpResponseMessage>[] arr_Tks = new Task<HttpResponseMessage>[max_i - 1];
//        Task[] arr_Tks_gen = new Task[max_i - 1];
//        var arr_Var = new HttpResponseMessage[max_i - 1];

//        // Carrega o certificado do arquivo .pfx
//        X509Certificate2 cert = new X509Certificate2("X:\\Back\\APP Smart\\Certificado\\Certificado Fernando.pfx", "appsmart");
//        handler.ClientCertificates.Add(cert);

//        DateTime data_final = DateTime.Now;
//        if (data_inicial.Year != data_final.Year)
//        {
//            data_final = new DateTime(data_inicial.Year, 12, 31);
//        }

//        DateTime aux_tempo = DateTime.Now;
//        var client = new HttpClient(handler);
//        client.DefaultRequestHeaders.Add("SOAPAction", "listarPLD");
//        var endpoint = new Uri("https://servicos.ccee.org.br:443/ws/prec/PLDBSv1");
//        Parallel.For(2, max_i + 1, (i) =>
//        {
//            var payload = new StringContent(xml_requisicao(i, data_inicial, data_final), Encoding.UTF8, "application/json");
//            arr_Tks[i - 2] = client.PostAsync(endpoint, payload);
//        });

//        Parallel.For(2, max_i + 1, (i, state) =>
//        {
//            var retorno = arr_Tks[i - 2].Result;
//            try
//            {
//                arr_Tks_gen[i - 2] = processar_XML_assync(retorno.Content.ReadAsStringAsync().Result, caminho_BD, access_conn);
//            }
//            catch (AggregateException ae)
//            {
//                Task.Delay(100);
//                arr_Tks_gen[i - 2] = processar_XML_assync(retorno.Content.ReadAsStringAsync().Result, caminho_BD, access_conn);
//            }
//        });
//        await Task.WhenAll(arr_Tks_gen.ToArray());
//        return 2;
//    }

//    //processa as respostas de forma assincrona
//    public static async Task processar_XML_assync(string entrada, string caminho_BD, OleDbConnection access_conn)
//    {
//        XmlDocument doc = new XmlDocument();
//        doc.LoadXml(entrada);
//        //doc.Save(@"X:\Back\PLD Horário\xmlresposta.xml");
//        int hora = 0, dia_semana = 0;
//        int j;
//        int num_pag;
//        double dia = 0;
//        string submercado = "", mes = "", access_strCOM, pg_strCOM;
//        double valor = 0;
//        DateTime aux_data = new DateTime(2005, 01, 01);
//        DateTime tempo_xml;

//        XmlNamespaceManager nsmgr = new XmlNamespaceManager(doc.NameTable);
//        nsmgr.AddNamespace("bm", "http://xmlns.energia.org.br/BM/v1");
//        nsmgr.AddNamespace("bo", "http://xmlns.energia.org.br/BO/v1");
//        nsmgr.AddNamespace("hdr", "http://xmlns.energia.org.br/MH/v1");
//        nsmgr.AddNamespace("soapenv", "http://schemas.xmlsoap.org/soap/envelope");
//        nsmgr.AddNamespace("xsi", "http://www.w3.org/2001/XMLSchema-instance");

//        tempo_xml = DateTime.Now;

//        int.TryParse(doc.SelectSingleNode("//hdr:totalPaginas", nsmgr).InnerText, out num_pag);
//        //Console.WriteLine("Total paginas " + num_pag);

//        await Task.Run(() =>
//        {
//            //START PGSQL
//            NpgsqlConnection pg_conn;
//            if (ENVIRONMENT is "dev")
//            {
//                pg_conn = new(PG_CONN_STRING_DEV);
//            }
//            else
//            {
//                pg_conn = new(PG_CONN_STRING_PROD);
//            }
//            if (BUILD_FOR != "access")
//            {
//                pg_conn.Open();
//            }

//            foreach (XmlNode n1 in doc.SelectNodes("//bm:plds//bm:pld", nsmgr))
//            {
//                XmlNode n2 = n1;
//                aux_data = DateTime.ParseExact(n2.SelectSingleNode("bo:vigencia//bo:inicio", nsmgr).InnerText, "yyyy-MM-dd'T'HH:mm:ss'-03:00'", null);
//                dia = (aux_data.ToOADate() - aux_data.ToOADate() % 1);
//                hora = aux_data.Hour;
//                mes = aux_data.ToString("yyMM");
//                dia_semana = (int)aux_data.DayOfWeek;
//                if (dia_semana == 0)
//                {
//                    dia_semana = 7;
//                }
//                for (j = 0; j <= 3; j++)
//                {
//                    submercado = n2.SelectNodes("bo:valores//bo:valor//bo:submercado//bo:nome", nsmgr)[j].InnerText;
//                    Double.TryParse(n2.SelectNodes("bo:valores//bo:valor//bo:valor//bo:valor", nsmgr)[j].InnerText, out valor);

//                    if (BUILD_FOR == "access")
//                    {
//                        //START ACCESS
//                        access_strCOM = "INSERT INTO PLD_comp (Data, Hora, Submercado, Valor, Mes_ref, Dia_da_semana)";
//                        access_strCOM += " VALUES (" + dia + "," + (hora + 1) + ",\"" + submercado + "\"," + valor + "," + mes + "," + dia_semana + ")";
//                        OleDbCommand tbPLD = new(access_strCOM, access_conn);
//                        OleDbDataReader reader = tbPLD.ExecuteReader();
//                        //END ACCESS
//                    }
//                    else
//                    {
//                        pg_strCOM = "INSERT INTO pld (dia_num, hora, submercado, valor, mes_ref, dia_da_semana) ";
//                        pg_strCOM += "VALUES (" + dia + ", " + (hora + 1) + ", '" + submercado + "', " + valor + ", '" + mes + "', " + dia_semana + ")";
//                        NpgsqlCommand pg_tcSCDE = new(pg_strCOM, pg_conn);
//                        NpgsqlDataReader pg_reader = pg_tcSCDE.ExecuteReader();
//                        pg_reader.Close();
//                        //END PGSQL
//                    }
//                }
//            }
//            pg_conn.Close();
//        });
//        foreach (XmlNode n1 in doc.GetElementsByTagName("hdr:numero"))
//        {
//            Console.WriteLine("Processando pagina {0} de {1} - tempo de execucao {2}", n1.InnerText, num_pag, DateTime.Now - tempo_xml);
//        }
//    }

//    //prepara o xml de entrada a ser enviado à CCEE
//    public static string xml_requisicao(int pag, DateTime dat_ini, DateTime dat_fim)
//    {
//        string cam_ent, tex_req, sdat_ini, sdat_fim;
//        cam_ent = @"X:\Back\PLD Horário\listarPLD.txt";

//        sdat_ini = dat_ini.ToString("yyyy-MM-ddT00:00:00"); //2022-12-31T00:00:00
//        sdat_fim = dat_fim.ToString("yyyy-MM-ddT00:00:00");
//        tex_req = File.ReadAllText(cam_ent);
//        tex_req = tex_req.Replace("DATA_INI", sdat_ini);
//        tex_req = tex_req.Replace("DATA_FIM", sdat_fim);
//        tex_req = tex_req.Replace("PAG_NUM", pag.ToString());
//        return tex_req;
//    }

//    //calcula a data de inicio da solicitacao do PLD, utilizando como base o ultimo dia de valor do PLD salvo no BD
//    public static DateTime data_inicio_BD(string caminho_BD)
//    {
//        string access_strCOM, pg_strCOM;
//        DateTime saida_ult_dia = DateTime.Now;

//        if (BUILD_FOR == "access")
//        {
//            access_strCOM = "SELECT MAX(Data) As ultimo_dia FROM PLD_comp";

//            OleDbConnection access_conn = new("Provider=Microsoft.ACE.OLEDB.12.0;Data Source=" + caminho_BD + ";Jet OLEDB:Database Password=gds21");
//            access_conn.Open();
//            OleDbCommand access_tbPLD = new(access_strCOM, access_conn);
//            OleDbDataReader access_reader = access_tbPLD.ExecuteReader();

//            access_reader.Read();

//            DateTime.TryParse(access_reader["ultimo_dia"].ToString(), out saida_ult_dia);
//            access_conn.Close();
//            saida_ult_dia = saida_ult_dia.AddDays(1);
//            Console.WriteLine("Importando dados a partir de:" + saida_ult_dia);
//        }
//        else
//        {
//            pg_strCOM = "SELECT TO_DATE('1899-12-30', 'YYYY-MM-DD') + INTERVAL '1' DAY * MAX(dia_num) AS ultimo_dia FROM pld";

//            NpgsqlConnection pg_conn;
//            if (ENVIRONMENT is "dev")
//            {
//                pg_conn = new(PG_CONN_STRING_DEV);
//            }
//            else
//            {
//                pg_conn = new(PG_CONN_STRING_PROD);
//            }
//            if (BUILD_FOR != "access")
//            {
//                pg_conn.Open();
//            }
//            NpgsqlCommand pg_tcSCDE = new(pg_strCOM, pg_conn);
//            NpgsqlDataReader pg_reader = pg_tcSCDE.ExecuteReader();
//            pg_reader.Read();
//            Console.WriteLine("" + pg_reader["ultimo_dia"].ToString());
//            if (pg_reader["ultimo_dia"].ToString().Length > 0)
//            {
//                DateTime.TryParse(pg_reader["ultimo_dia"].ToString(), out saida_ult_dia);
//                pg_reader.Close();
//                saida_ult_dia = saida_ult_dia.AddDays(1);
//                Console.WriteLine("Importando dados a partir de:" + saida_ult_dia);
//            }
//            else
//            {
//                saida_ult_dia = DateTime.Now.AddYears(-2);
//                Console.WriteLine("Importando dados a partir de:" + saida_ult_dia);
//            }
//        }
//        return saida_ult_dia;
//    }

//    //requisicao sincrona de valor do PLD
//    public static string requisicao_http_sync(string tex_req)
//    {
//        var handler = new HttpClientHandler();

//        // Carrega o certificado do arquivo .pfx
//        X509Certificate2 cert = new X509Certificate2("X:\\Back\\APP Smart\\Certificado\\Certificado Fernando.pfx", "appsmart");
//        handler.ClientCertificates.Add(cert);

//        using (var client = new HttpClient(handler))
//        {
//            client.DefaultRequestHeaders.Add("SOAPAction", "listarPLD");
//            var endpoint = new Uri("https://servicos.ccee.org.br:443/ws/prec/PLDBSv1");
//            var newPostJson = JsonConvert.ToString(tex_req);
//            var payload = new StringContent(tex_req, Encoding.UTF8, "application/json");

//            //modificar a proxima linha para transformar em assincrono
//            //var retorno = client.PostAsync(endpoint, payload).Result.Content.ReadAsStringAsync().Result;
//            var retorno = client.PostAsync(endpoint, payload).Result.Content.ReadAsStringAsync().Result;
//            //https://stackoverflow.com/questions/642293/how-do-i-read-and-parse-an-xml-file-in
//            return retorno;
//        }
//    }

//    //processa os dados da resposta de forma sincrona, retorna o numero total de paginas da requisicao 
//    public static int processar_XML_sync(string entrada, string caminho_BD)
//    {
//        XmlDocument doc = new XmlDocument();
//        doc.LoadXml(entrada);
//        doc.Save(@"X:\Back\PLD Horário\xmlresposta.xml");
//        int hora = 0, dia_semana = 0;
//        int num_pag;
//        double dia = 0;
//        string submercado = "", mes = "", access_strCOM, pg_strCOM;
//        double valor = 0;
//        DateTime aux_data = new DateTime(2005, 01, 01);

//        //abre a conexao com o BD
//        OleDbConnection access_conn = new("Provider=Microsoft.ACE.OLEDB.12.0;Data Source=" + caminho_BD + ";Jet OLEDB:Database Password=gds21");
//        access_conn.Open();

//        NpgsqlConnection pg_conn;
//        if (ENVIRONMENT is "dev")
//        {
//            pg_conn = new(PG_CONN_STRING_DEV);
//        }
//        else
//        {
//            pg_conn = new(PG_CONN_STRING_PROD);
//        }
//        if (BUILD_FOR != "access")
//        {
//            pg_conn.Open();
//        }
//        Thread.CurrentThread.CurrentCulture = CultureInfo.CreateSpecificCulture("en-GB");

//        num_pag = 1;
//        foreach (XmlNode n1 in doc.GetElementsByTagName("hdr:totalPaginas"))
//        {
//            int.TryParse(n1.InnerText, out num_pag);
//        }

//        foreach (XmlNode n1 in doc.GetElementsByTagName("hdr:numero"))
//        {
//            Console.WriteLine("Processando pagina {0} de {1}", n1.InnerText, num_pag);
//        }

//        foreach (XmlNode n1 in doc.GetElementsByTagName("bm:pld"))
//        {
//            foreach (XmlNode n2 in n1.ChildNodes)
//            {
//                foreach (XmlNode n3 in n2.ChildNodes)
//                {
//                    if (n3.Name == "bo:inicio")
//                    {
//                        aux_data = DateTime.ParseExact(n3.InnerText, "yyyy-MM-dd'T'HH:mm:ss'-03:00'", null);
//                        dia = (aux_data.ToOADate() - aux_data.ToOADate() % 1);
//                        hora = aux_data.Hour;
//                        mes = aux_data.ToString("yyMM");
//                        dia_semana = (int)aux_data.DayOfWeek;
//                        if (dia_semana == 0)
//                        {
//                            dia_semana = 7;
//                        }
//                    }
//                    if (n3.Name == "bo:valor")
//                    {
//                        foreach (XmlNode n4 in n3.ChildNodes)
//                        {
//                            if (n4.Name == "bo:submercado" || n4.Name == "bo:valor")
//                            {
//                                foreach (XmlNode n5 in n4.ChildNodes)
//                                {
//                                    switch (n5.Name)
//                                    {
//                                        case "bo:nome":
//                                            submercado = n5.InnerText;
//                                            break;
//                                        case "bo:valor":
//                                            Double.TryParse(n5.InnerText, out valor);
//                                            //Console.WriteLine("Mes:" + mes + " - Dia da semana:" + dia_semana + " - Dia:" + dia + " - Hora:" + hora + "- Submercado:" + submercado + "- Valor:" + valor + "\n");
//                                            //Escreva as informacoes no BD
//                                            if (BUILD_FOR == "access")
//                                            {
//                                                access_strCOM = "INSERT INTO PLD_comp (Data, Hora, Submercado, Valor, Mes_ref, Dia_da_semana)";
//                                                access_strCOM += " VALUES (" + dia + "," + (hora + 1) + ",\"" + submercado + "\"," + valor + "," + mes + "," + dia_semana + ")";
//                                                //Console.WriteLine(strCOM);
//                                                OleDbCommand access_tbPLD = new(access_strCOM, access_conn);
//                                                OleDbDataReader access_reader = access_tbPLD.ExecuteReader();
//                                                access_reader.Close();
//                                            }
//                                            else
//                                            {
//                                                pg_strCOM = "INSERT INTO pld " +
//                                                "(dia_num, hora, submercado, valor, mes_ref, dia_da_semana) ";
//                                                pg_strCOM += "VALUES (" + dia + ", " + (hora + 1) + ", '" + submercado + "', " + valor + ", '" + mes + "', " + dia_semana + ")";
//                                                NpgsqlCommand pg_tcSCDE = new(pg_strCOM, pg_conn);
//                                                NpgsqlDataReader pg_reader = pg_tcSCDE.ExecuteReader();
//                                                pg_reader.Close();
//                                            }
//                                            break;
//                                        default:
//                                            break;
//                                    }
//                                }
//                            }
//                        }
//                    }
//                }
//            }
//        }
//        access_conn.Close();
//        pg_conn.Close();
//        return num_pag;
//    }

//}