43 lines
2.2 KiB
C#

using Application;
using Infrastructure;
class Program
{
static async Task Main()
{
DateTime inicio = DateTime.Now;
string PG_CONN_STRING_PROD = "Server = smart-energia-dev-pgsql.cykff7tj7mik.us-east-1.rds.amazonaws.com; Port = 5432; Database = smartenergiaprod; Username = postgres; Password = VfHml#Z78!%kvvNM; Timeout = 60; CommandTimeout = 60; ApplicationName = new_med_5_min; Connection Lifetime = 120; Minimum Pool Size = 1; Maximum Pool Size = 1;";
// string PG_CONN_STRING_PROD = "Server = 192.168.10.248; Port = 5432; Database = smartenergiadev; Username = postgres; Password = gds21; Timeout = 60; CommandTimeout = 60; ApplicationName = new_med_5_min; Connection Lifetime = 120; Minimum Pool Size = 2; Maximum Pool Size = 4;";
string ACCESS_CONN_STRING = @"Provider=Microsoft.ACE.OLEDB.12.0;Data Source=\\srv-dados\documentos\Middle\Informativo Setorial\Modelo Word\BD1_dados cadastrais e faturas.accdb;Jet OLEDB:Database Password=gds21";
string caminhoLog = $@"\\srv-dados\documentos\Back\Carteira x.x\Codigo\Erros\log_erros_{inicio:MM_dd_HH_mm}.csv";
var calendarioService = new CalendarioService();
var evento = await calendarioService.ObterEventoLimiteColetaAsync(inicio, CancellationToken.None);
//agosto finalizado
DateTime dataIni = new DateTime(inicio.Year, inicio.Month, 01);
DateTime dataFim = inicio.Date;
if (dataFim.Day <= evento + 1)
{
dataIni = dataIni.AddMonths(-1);
}
// Configuração de dependências (pode usar um container DI depois)
var postgresRepo = new PostgresRepository(PG_CONN_STRING_PROD);
var accessRepo = new AccessRepository(ACCESS_CONN_STRING);
var useCase = new ProcessarMedicoesUseCase(postgresRepo, accessRepo);
await useCase.ExecuteAsync(dataIni, dataFim, caminhoLog, CancellationToken.None);
Console.WriteLine($"Concluído. Tempo total: {DateTime.Now - inicio}");
string input = string.Empty;
while (input.ToLower() != "fim")
{
Console.WriteLine("Digite 'fim' para finalizar:");
input = Console.ReadLine();
}
}
}