diff --git a/Program.cs b/Program.cs index ebf3bec..82dad0c 100644 --- a/Program.cs +++ b/Program.cs @@ -13,15 +13,9 @@ internal class Plat_integ 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; Timeout = 300;CommandTimeout = 300"; static string ENVIRONMENT = "dev"; // "dev" | "prod" public static IEnumerable? pag_ant; - static void Main(string[] args) + static void Main() { - bool loadFromArgs = false; - if (args.Length > 0) - { - loadFromArgs = true; - } - - down_sync(loadFromArgs, args); //metodo sincrono + down_sync(); //metodo sincrono Console.WriteLine("" + "Pressione qualquer tecla para finalizar"); @@ -29,7 +23,7 @@ internal class Plat_integ Environment.Exit(0); return; } - public static void down_sync(bool loadFromArgs, string[] args) + public static void down_sync() { string caminho_BD, caminho_log, caminho_log_sec; DateTime tempo_ini; @@ -51,34 +45,20 @@ internal class Plat_integ //PROD DateTime data_ini; DateTime data_fim; - if (loadFromArgs) - { - int ano_ini = Int32.Parse(args[0]); - int mes_ini = Int32.Parse(args[1]); - int ano_fim = Int32.Parse(args[2]); - int mes_fim = Int32.Parse(args[3]); - data_ini = new DateTime(ano_ini, mes_ini, 1); - data_fim = new DateTime(ano_fim, mes_fim, 1).AddMonths(1); + if (ENVIRONMENT is "dev") + { + data_ini = new DateTime(2021, 3, 1); + data_fim = new DateTime(2021, 3, 2); } else { - if (ENVIRONMENT is "dev") - { - data_ini = new DateTime(2021, 3, 1); - data_fim = new DateTime(2021, 3, 2); - } - else - { - //configuração mês atual - data_ini = new DateTime(now.Year, now.Month, 1); - data_fim = new DateTime(now.Year, now.Month, now.Day); - } + //configuração mês atual + data_ini = new DateTime(now.Year, now.Month, 1); + data_fim = new DateTime(now.Year, now.Month, now.Day); } + Exclui_med(data_ini.ToOADate(), data_fim.ToOADate(), caminho_BD); - //abre a conexao com o BD onde serao salvos os dados - caminho_BD = @"\\srv-dados\documentos\Back\Carteira x.x\Gestão Geral v1\Access\BDs teste\DB_med_5min.accdb"; - OleDbConnection access_conn = new("Provider=Microsoft.ACE.OLEDB.12.0;Data Source=" + caminho_BD + ";Jet OLEDB:Database Password=gds21"); NpgsqlConnection pg_conn; if (ENVIRONMENT is "dev") @@ -91,7 +71,7 @@ internal class Plat_integ } //loop para cada dia e cada cod ponto salvando os dados no BD - req_sincrona(data_ini, data_fim, lt_perf_pto, access_conn, pg_conn, caminho_log); + req_sincrona(data_ini, data_fim, lt_perf_pto, pg_conn, caminho_log); Console.WriteLine("Concluido. Tempo TOTAL de execucao: {0}", DateTime.Now - tempo_ini); } @@ -126,16 +106,6 @@ internal class Plat_integ //Exlclui dados do mes atual no BD medicoes public static void Exclui_med(double data_ini, double data_fim, string caminho_BD) { - //ACCESS DB - string strCOM; - //strCOM = "DELETE FROM Med_5min WHERE Data >= " + data_ini + " AND Data <= "+data_fim; - //OleDbConnection conn = new("Provider=Microsoft.ACE.OLEDB.12.0;Data Source=" + caminho_BD + ";Jet OLEDB:Database Password=gds21"); - //conn.Open(); - //OleDbCommand tcSCDE = new(strCOM, conn); - //tcSCDE.ExecuteReader(); - //conn.Close(); - - //POSTGRE NpgsqlConnection pg_conn; if (ENVIRONMENT is "dev") { @@ -156,7 +126,7 @@ internal class Plat_integ return; } - public static void req_sincrona(DateTime data_inicial, DateTime data_final, List> lt_perf_pto, OleDbConnection access_conn, NpgsqlConnection pg_conn, string caminho_log) + public static void req_sincrona(DateTime data_inicial, DateTime data_final, List> lt_perf_pto, NpgsqlConnection pg_conn, string caminho_log) { string log_erros; int i; @@ -188,15 +158,11 @@ internal class Plat_integ var payload = new StringContent(Xml_requisicao(data_inicial, item.Item1, item.Item2, pagina), Encoding.UTF8, "application/json"); var retorno = client.PostAsync(endpoint, payload).Result.Content.ReadAsStringAsync().Result.ToString(); Console.WriteLine("Processando requisicao {0,5}, Perf: {1,6}, Ponto: {2,10}, Página: {3}", i, item.Item1, item.Item2, pagina); - if (access_conn != null && access_conn.State == ConnectionState.Closed) - { - access_conn.Open(); - } if (pg_conn != null && pg_conn.State == ConnectionState.Closed) { pg_conn.Open(); } - paginasTotal = processar_XML_sincrono(retorno, access_conn, pg_conn); + paginasTotal = processar_XML_sincrono(retorno, pg_conn); pagina++; } @@ -236,13 +202,13 @@ internal class Plat_integ tex_req = tex_req.Replace("PAGNUM", pagina.ToString()); return tex_req; } - public static int processar_XML_sincrono(string entrada, OleDbConnection access_conn, NpgsqlConnection pg_conn) + public static int processar_XML_sincrono(string entrada, NpgsqlConnection pg_conn) { XmlDocument doc = new XmlDocument(); doc.LoadXml(entrada); DateTime aux_data = new DateTime(2005, 01, 01); DateTime tempo_xml; - string access_strCOM, pg_strCOM, log_erros; + string access_strCOM, log_erros; XElement pag_atual; pag_atual = XElement.Parse(entrada); @@ -259,10 +225,6 @@ internal class Plat_integ nsmgr.AddNamespace("bmv2", "http://xmlns.energia.org.br/BM/v2"); nsmgr.AddNamespace("bov2", "http://xmlns.energia.org.br/BO/v2"); - if (access_conn.State != ConnectionState.Open) - { - access_conn.Open(); - } if (pg_conn.State != ConnectionState.Open) { pg_conn.Open();