Smart/PI_Assync_SCDE
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Remoção da opção de utilizar argumentos para execução do código e trechos de códigos não utilizados.

Browse Source
This commit is contained in:
Adriano Serighelli 2025-09-17 15:01:01 -03:00
parent 59b8f4bbb9
commit 63ee35b527
1 changed files with 16 additions and 54 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
Program.cs
View File

@ -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<XElement>? 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,18 +45,7 @@ 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);
}
else
{
if (ENVIRONMENT is "dev")
{
data_ini = new DateTime(2021, 3, 1);
@ -74,11 +57,8 @@ internal class Plat_integ
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<Tuple<string, string>> lt_perf_pto, OleDbConnection access_conn, NpgsqlConnection pg_conn, string caminho_log)
public static void req_sincrona(DateTime data_inicial, DateTime data_final, List<Tuple<string, string>> 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();