Transfer_ac_pg/Program.cs

// See https://aka.ms/new-console-template for more information
using Newtonsoft.Json;
using Npgsql;
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.Net.Sockets;
using System.Security.Authentication;
using System.Security.Cryptography.X509Certificates;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Xml;

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 ACCESS_DB_LOCATION = @"X:\Middle\Informativo Setorial\Modelo Word\BD1_dados cadastrais e faturas.accdb";

    static string ACCESS_DB_LOCATION_APP = @"X:\Middle\Informativo Setorial\Modelo Word\BD_APP.accdb";

    static void Main(string[] args)
    {
        DateTime searchFrom = new DateTime((DateTime.Now.Year) - 2, 1, 1);
        string searchFromString = searchFrom.ToString("yMM");

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

        Console.WriteLine("Iniciando importação dos dados cadastrais");
        TransfereDC();
        Console.WriteLine("Finalizando importação dos dados cadastrais");

        Console.WriteLine("Iniciando importação dos dados TE");
        transfere_TE(searchFromString);
        Console.WriteLine("Finalizando importação dos dados TE");

        Console.WriteLine("Iniciando importação dos dados de economia");
        transfere_econ(searchFromString);
        Console.WriteLine("Finalizando importação dos dados de economia");

        Console.WriteLine("Iniciando importação dos dados estimados de economia");
        transfere_econ_estimado(searchFromString);
        Console.WriteLine("Finalizando importação dos dados estimados de economia");

        Environment.Exit(0);
        return;
    }

    private static void transfere_econ(string searchFromString)
    {
        string strCOM_ac, strCOM_ac_list;

        long cod_econ, cod_smart_unidade;
        string mes;
        double custo_cativo, custo_livre, economia_mensal, economia_acumulada, custo_unit_temp;
        double? custo_unit;

        //abre conexao com o Accesss
        OleDbConnection conn_access = new("Provider=Microsoft.ACE.OLEDB.12.0;Data Source=" + ACCESS_DB_LOCATION + ";Jet OLEDB:Database Password=gds21");
        conn_access.Open();

        strCOM_ac_list =    "SELECT DISTINCT dados_cadastrais.cod_smart_unidade " +
                            "FROM dados_cadastrais RIGHT JOIN Economia ON dados_cadastrais.Cod_Smart_unidade = Economia.Cod_Smart_unidade " +
                            "WHERE unidade_gerenciada AND mes >= " + searchFromString;

        OleDbCommand tbList = new(strCOM_ac_list, conn_access);
        OleDbDataReader reader_access_list = tbList.ExecuteReader();

        //abre a conexao com o PG
        NpgsqlConnection conn_pg;
        if (ENVIRONMENT is "dev")
        {
            conn_pg = new(PG_CONN_STRING_DEV);
        }
        else
        {
            conn_pg = new(PG_CONN_STRING_PROD);
        }
        conn_pg.Open();

        Console.WriteLine("Excluindo dados existentes de economia");
        string pg_strCOM = $"DELETE FROM economia"; //TODO: ESTUDAR TROCA PARA TRUNCATE
        NpgsqlCommand pg_tcSCDE = new(pg_strCOM, conn_pg);
        NpgsqlDataReader pg_reader = pg_tcSCDE.ExecuteReader();
        pg_reader.Close();
        Console.WriteLine("Dados de economia excluídos");

        using (var pg_writer = conn_pg.BeginBinaryImport("COPY economia (cod_econ, cod_smart_unidade, mes, custo_cativo, custo_livre, economia_mensal, economia_acumulada, custo_unit, dad_estimado) FROM STDIN (FORMAT BINARY)"))
        {
            while (reader_access_list.Read())
            {
                string idUni = reader_access_list["cod_smart_unidade"].ToString()!;
                strCOM_ac = $"SELECT calendario_aamm.data, IIf(a.custo_cativo IS NULL, 0.001, a.custo_cativo) AS custo_cativo, IIf(a.custo_livre IS NULL, 0.001, a.custo_livre) AS custo_livre, IIf(a.economia_mensal IS NULL, 0, a.economia_mensal) AS economia_mensal, IIf(a.economia_acumul IS NULL, 0, a.economia_acumul) AS economia_acumul, a.Custo_unit AS Custo_unit FROM calendario_aamm LEFT JOIN (SELECT * FROM economia WHERE cod_smart_unidade = {idUni} ORDER BY mes) AS a ON calendario_aamm.data = a.mes WHERE calendario_aamm.data >= {searchFromString} And calendario_aamm.data <= (SELECT MAX(mes) FROM economia WHERE cod_smart_unidade = {idUni})";

                OleDbCommand tbEC = new(strCOM_ac, conn_access);
                OleDbDataReader reader_access = tbEC.ExecuteReader();
                while (reader_access.Read())
                {
                    mes = reader_access["data"].ToString()!;

                    double.TryParse(reader_access["Custo_cativo"].ToString(), out custo_cativo);
                    double.TryParse(reader_access["Custo_livre"].ToString(), out custo_livre);
                    double.TryParse(reader_access["Economia_mensal"].ToString(), out economia_mensal);
                    double.TryParse(reader_access["Economia_acumul"].ToString(), out economia_acumulada);
                    if (!double.TryParse(reader_access["Custo_unit"].ToString(), out custo_unit_temp))
                    {
                        custo_unit = null;
                    }
                    else
                    {
                        custo_unit = custo_unit_temp;
                    }

                    long.TryParse(String.Concat(idUni, mes), out cod_econ);
                    long.TryParse(idUni, out cod_smart_unidade);

                    pg_writer.StartRow();
                    pg_writer.Write(cod_econ, NpgsqlTypes.NpgsqlDbType.Bigint);
                    pg_writer.Write(cod_smart_unidade, NpgsqlTypes.NpgsqlDbType.Bigint);
                    pg_writer.Write(mes);
                    pg_writer.Write(custo_cativo, NpgsqlTypes.NpgsqlDbType.Numeric);
                    pg_writer.Write(custo_livre, NpgsqlTypes.NpgsqlDbType.Numeric);
                    pg_writer.Write(economia_mensal, NpgsqlTypes.NpgsqlDbType.Numeric);
                    pg_writer.Write(economia_acumulada, NpgsqlTypes.NpgsqlDbType.Numeric);
                    if (custo_unit is null)
                    {
                        pg_writer.WriteNull();
                    }
                    else
                    {
                        pg_writer.Write((double)custo_unit, NpgsqlTypes.NpgsqlDbType.Numeric);
                    }
                    pg_writer.Write(false, NpgsqlTypes.NpgsqlDbType.Boolean);
                }
                reader_access.Close();
            }
            pg_writer.Complete();
        }

        conn_access.Close();
        conn_pg.Close();
    }

    private static void transfere_TE(string searchFromString)
    {
        string strCOM_ac, strCOM_pg;

        long cod_TE, cod_smart_unidade;
        string mes, operacao, tipo, perfil_contr;
        double montante_nf, preco_nf, nf_c_icms;

        //abre conexao com o Accesss
        OleDbConnection conn_access = new("Provider=Microsoft.ACE.OLEDB.12.0;Data Source=" + ACCESS_DB_LOCATION + ";Jet OLEDB:Database Password=gds21");
        conn_access.Open();

        strCOM_ac = "SELECT Dados_TE.* " +
                    "FROM Dados_cadastrais RIGHT JOIN Dados_TE ON Dados_cadastrais.Cod_Smart_unidade = Dados_TE.Cod_Smart_unidade " +
                    "WHERE unidade_gerenciada AND mes >= " + searchFromString;

        OleDbCommand tbTE = new(strCOM_ac, conn_access);
        OleDbDataReader reader_access = tbTE.ExecuteReader();

        //abre a conexao com o PG
        NpgsqlConnection conn_pg;
        if (ENVIRONMENT is "dev")
        {
            conn_pg = new(PG_CONN_STRING_DEV);
        }
        else
        {
            conn_pg = new(PG_CONN_STRING_PROD);
        }
        conn_pg.Open();

        Console.WriteLine("Excluindo dados existentes de TE");
        string pg_strCOM = $"DELETE FROM dados_te"; //TODO: ESTUDAR TROCA PARA TRUNCATE
        NpgsqlCommand pg_tcSCDE = new(pg_strCOM, conn_pg);
        NpgsqlDataReader pg_reader = pg_tcSCDE.ExecuteReader();
        pg_reader.Close();
        Console.WriteLine("Dados de TE excluídos");

        using (var pg_writer = conn_pg.BeginBinaryImport("COPY dados_te (cod_te, cod_smart_unidade, mes, operacao, tipo, montante_nf, preco_nf, nf_c_icms, perfil_contr) FROM STDIN (FORMAT BINARY)"))
        {
            while (reader_access.Read())
            { 
                mes = reader_access["Mes"].ToString();
                operacao = reader_access["Operacao"].ToString();
                tipo = reader_access["Tipo"].ToString();
                perfil_contr = reader_access["Perfil_Contr"].ToString();

                double.TryParse(reader_access["Montante_NF"].ToString(), out montante_nf);
                double.TryParse(reader_access["Preco_NF"].ToString(), out preco_nf);
                double.TryParse(reader_access["NF_c_ICMS"].ToString(), out nf_c_icms);
                long.TryParse(reader_access["Cod_TE"].ToString(), out cod_TE);
                long.TryParse(reader_access["Cod_Smart_unidade"].ToString(), out cod_smart_unidade);

                pg_writer.StartRow();
                pg_writer.Write(cod_TE, NpgsqlTypes.NpgsqlDbType.Bigint);
                pg_writer.Write(cod_smart_unidade, NpgsqlTypes.NpgsqlDbType.Bigint);
                pg_writer.Write(mes);
                pg_writer.Write(operacao);
                pg_writer.Write(tipo);
                pg_writer.Write(montante_nf, NpgsqlTypes.NpgsqlDbType.Numeric);
                pg_writer.Write(preco_nf, NpgsqlTypes.NpgsqlDbType.Numeric);
                pg_writer.Write(nf_c_icms, NpgsqlTypes.NpgsqlDbType.Numeric);
                pg_writer.Write(perfil_contr);

            }
            pg_writer.Complete();
        }

        conn_access.Close();
        conn_pg.Close();

    }

    private static void TransfereDC()
    {
        string accessConnectionString = $"Provider=Microsoft.ACE.OLEDB.12.0;Data Source={ACCESS_DB_LOCATION};Jet OLEDB:Database Password=gds21";
        string pgConnectionString = ENVIRONMENT == "dev" ? PG_CONN_STRING_DEV : PG_CONN_STRING_PROD;

        try
        {
            using (OleDbConnection accessConn = new(accessConnectionString))
            using (NpgsqlConnection pgConn = new(pgConnectionString))
            {
                accessConn.Open();
                pgConn.Open();

                string selectAccessQuery = "SELECT * FROM Dados_cadastrais";
                OleDbCommand accessCommand = new(selectAccessQuery, accessConn);

                using (OleDbDataReader accessReader = accessCommand.ExecuteReader())
                {
                    while (accessReader.Read())
                    {
                        try
                        {
                            // Leitura dos dados do Access
                            string cliente = accessReader["Cliente"].ToString() ?? string.Empty;
                            string unidade = accessReader["Unidade"].ToString() ?? string.Empty;
                            string codigoScde = (accessReader["Codigo_SCDE"].ToString() ?? string.Empty) + "P";
                            string statusEmpresa = accessReader["Status_empresa"].ToString() ?? string.Empty;
                            string statusUnidade = accessReader["Status_unidade"].ToString() ?? string.Empty;
                            bool unidadeGerenciada = Convert.ToBoolean(accessReader["Unidade_gerenciada"]);

                            long.TryParse(accessReader["Cod_Smart_unidade"].ToString(), out long codSmartUnidade);
                            long.TryParse(accessReader["Cod_Smart_cliente"].ToString(), out long codSmartCliente);
                            double.TryParse(accessReader["Demanda_P"].ToString(), out double demandaP);
                            double.TryParse(accessReader["Demanda_FP"].ToString(), out double demandaFp);

                            DateTime.TryParse(accessReader["Data_de_migracao"].ToString(), out DateTime dataMigracao);

                            if (unidadeGerenciada)
                            {
                                // UPSERT
                                string upsertQuery = @" INSERT INTO dados_cadastrais 
                                                        (cod_smart_unidade, cod_smart_cliente, cliente, unidade, codigo_scde, 
                                                         status_empresa, status_unidade, demanda_p, demanda_fp, data_de_migracao) 
                                                        VALUES 
                                                        (@CodSmartUnidade, @CodSmartCliente, @Cliente, @Unidade, @CodigoScde, 
                                                         @StatusEmpresa, @StatusUnidade, @DemandaP, @DemandaFp, @DataMigracao)
                                                        ON CONFLICT (cod_smart_unidade) 
                                                        DO UPDATE SET 
                                                            cod_smart_cliente = EXCLUDED.cod_smart_cliente,
                                                            cliente = EXCLUDED.cliente,
                                                            unidade = EXCLUDED.unidade,
                                                            codigo_scde = EXCLUDED.codigo_scde,
                                                            status_empresa = EXCLUDED.status_empresa,
                                                            status_unidade = EXCLUDED.status_unidade,
                                                            demanda_p = EXCLUDED.demanda_p,
                                                            demanda_fp = EXCLUDED.demanda_fp,
                                                            data_de_migracao = EXCLUDED.data_de_migracao;";

                                using (NpgsqlCommand upsertCommand = new(upsertQuery, pgConn))
                                {
                                    AddParameters(upsertCommand, codSmartUnidade, codSmartCliente, cliente, unidade, codigoScde, statusEmpresa, statusUnidade, demandaP, demandaFp, dataMigracao);
                                    upsertCommand.ExecuteNonQuery();
                                    Console.WriteLine($"Unidade {codSmartUnidade} processada (inserida ou atualizada).");
                                }
                            }
                            else
                            {
                                // DELETE
                                string deleteQuery = "DELETE FROM dados_cadastrais WHERE cod_smart_unidade = @CodSmartUnidade";

                                using (NpgsqlCommand deleteCommand = new(deleteQuery, pgConn))
                                {
                                    deleteCommand.Parameters.AddWithValue("@CodSmartUnidade", codSmartUnidade);
                                    deleteCommand.ExecuteNonQuery();
                                    Console.WriteLine($"Unidade {codSmartUnidade} deletada.");
                                }
                            }
                        }
                        catch (Exception ex)
                        {
                            Console.WriteLine($"Erro ao processar registro: {ex.Message}");
                        }
                    }
                }

                selectAccessQuery = "SELECT public_dados_cadastrais.cod_smart_unidade\r\nFROM Dados_cadastrais \r\nRIGHT JOIN public_dados_cadastrais ON Dados_cadastrais.Cod_Smart_unidade = public_dados_cadastrais.cod_smart_unidade\r\nWHERE Dados_cadastrais.Cod_Smart_unidade Is Null;";
                accessCommand = new(selectAccessQuery, accessConn);

                using (OleDbDataReader accessReader = accessCommand.ExecuteReader())
                {
                    while (accessReader.Read())
                    {
                        try
                        {
                            // Leitura dos dados do Access
                            long.TryParse(accessReader["Cod_Smart_unidade"].ToString(), out long codSmartUnidade);

                            // DELETE
                            string deleteQuery = "DELETE FROM dados_cadastrais WHERE cod_smart_unidade = @CodSmartUnidade";

                            using (NpgsqlCommand deleteCommand = new(deleteQuery, pgConn))
                            {
                                deleteCommand.Parameters.AddWithValue("@CodSmartUnidade", codSmartUnidade);
                                deleteCommand.ExecuteNonQuery();
                                Console.WriteLine($"Unidade {codSmartUnidade} deletada.");
                            }
                        }
                        catch (Exception ex)
                        {
                            Console.WriteLine($"Erro ao processar registro: {ex.Message}");
                        }
                    }
                }
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine($"Erro na operação geral: {ex.Message}");
        }
    }

    private static void AddParameters(NpgsqlCommand command, long codSmartUnidade, long codSmartCliente, string cliente, string unidade, string codigoScde, string statusEmpresa, string statusUnidade, double demandaP, double demandaFp, DateTime dataMigracao)
    {
        command.Parameters.AddWithValue("@CodSmartUnidade", codSmartUnidade);
        command.Parameters.AddWithValue("@CodSmartCliente", codSmartCliente);
        command.Parameters.AddWithValue("@Cliente", cliente ?? (object)DBNull.Value);
        command.Parameters.AddWithValue("@Unidade", unidade ?? (object)DBNull.Value);
        command.Parameters.AddWithValue("@CodigoScde", codigoScde ?? (object)DBNull.Value);
        command.Parameters.AddWithValue("@StatusEmpresa", statusEmpresa ?? (object)DBNull.Value);
        command.Parameters.AddWithValue("@StatusUnidade", statusUnidade ?? (object)DBNull.Value);
        command.Parameters.AddWithValue("@DemandaP", demandaP);
        command.Parameters.AddWithValue("@DemandaFp", demandaFp);
        command.Parameters.AddWithValue("@DataMigracao", dataMigracao != default ? dataMigracao : DBNull.Value);
    }

    //private static void transfere_PLD() {
    //   string strCOM_ac, caminho_BD, strCOM_pg;
    //   double valor_pld, dia_num, hora, dia_da_semana;
    //   string submercado, mes_ref;


    //   caminho_BD = @"X:\Middle\Informativo Setorial\Modelo Word\BD_SCDE.accdb";


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

    //   //dados >= 2022-01-01
    //   strCOM_ac = "SELECT * FROM PLD_comp WHERE data >= 44562";
    //   OleDbCommand tbPLD = new(strCOM_ac, conn_access);
    //   OleDbDataReader reader_access = tbPLD.ExecuteReader();

    //   //abre a conexao com o PG
    //   NpgsqlConnection conn_pg = new("Server = 127.0.0.1; Port = 5432; Database = development_db; User Id = postgres; Password = bdnp;");
    //   conn_pg.Open();

    //   while (reader_access.Read()) {
    //      submercado= reader_access["Submercado"].ToString();
    //      mes_ref = reader_access["Mes_ref"].ToString();
    //      //Console.WriteLine(reader_access["Data"]);
    //      //Console.ReadKey();
    //      double.TryParse(reader_access["Data"].ToString(), out dia_num);
    //      double.TryParse(reader_access["Hora"].ToString(), out hora);
    //      double.TryParse(reader_access["Dia_da_semana"].ToString(), out dia_da_semana);
    //      double.TryParse(reader_access["Valor"].ToString(), out valor_pld);

    //      strCOM_pg = "INSERT INTO pld (dia_num, hora, submercado, valor, mes_ref, dia_da_semana)";
    //      strCOM_pg += $" VALUES ({dia_num}, {hora} ,'{submercado}', {valor_pld},'{mes_ref}', {dia_da_semana});";

    //      NpgsqlCommand tcMed = new(strCOM_pg, conn_pg);
    //      using (NpgsqlDataReader reader = tcMed.ExecuteReader()) {
    //      };
    //   }

    //   conn_access.Close();
    //   conn_pg.Close();

    //}

    //private static void transfere_Med5min() {
    //   string strCOM_ac, caminho_BD, strCOM_pg;
    //   double valor_pld, dia_num, hora, dia_da_semana;
    //   string submercado, mes_ref;

    //   caminho_BD = @"X:\Middle\Informativo Setorial\Modelo Word\BD_SCDE.accdb"; //TODO CHANGE

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

    //   //dados >= 2022-01-01
    //   strCOM_ac = "SELECT * FROM PLD_comp WHERE data >= 44562";
    //   OleDbCommand tbPLD = new(strCOM_ac, conn_access);
    //   OleDbDataReader reader_access = tbPLD.ExecuteReader();

    //   //abre a conexao com o PG
    //   NpgsqlConnection conn_pg;
    //   if (ENVIRONMENT is "dev") {
    //      conn_pg = new(PG_CONN_STRING_DEV);
    //   } else {
    //      conn_pg = new(PG_CONN_STRING_PROD);
    //   }
    //   conn_pg.Open();

    //   using (var pg_writer = conn_pg.BeginBinaryImport("COPY dados_te (cod_te, cod_smart_unidade, mes, operacao, tipo, montante_nf, preco_nf, nf_c_icms, perfil_contr) FROM STDIN (FORMAT BINARY)")) {
    //      while (reader_access.Read()) {
    //         submercado = reader_access["Submercado"].ToString();
    //         mes_ref = reader_access["Mes_ref"].ToString();
    //         //Console.WriteLine(reader_access["Data"]);
    //         //Console.ReadKey();
    //         double.TryParse(reader_access["Data"].ToString(), out dia_num);
    //         double.TryParse(reader_access["Hora"].ToString(), out hora);
    //         double.TryParse(reader_access["Dia_da_semana"].ToString(), out dia_da_semana);
    //         double.TryParse(reader_access["Valor"].ToString(), out valor_pld);

    //         //strCOM_pg = "INSERT INTO pld (dia_num, hora, submercado, valor, mes_ref, dia_da_semana)";
    //         //strCOM_pg += $" VALUES ({dia_num}, {hora} ,'{submercado}', {valor_pld},'{mes_ref}', {dia_da_semana});";

    //         pg_writer.StartRow();
    //         pg_writer.Write(dia_num);
    //         pg_writer.Write(hora, NpgsqlTypes.NpgsqlDbType.Numeric);
    //         pg_writer.Write(submercado, NpgsqlTypes.NpgsqlDbType.Integer);
    //         pg_writer.Write(valor_pld, NpgsqlTypes.NpgsqlDbType.Numeric);
    //         pg_writer.Write(mes_ref, NpgsqlTypes.NpgsqlDbType.Numeric);
    //         pg_writer.Write(dia_da_semana, NpgsqlTypes.NpgsqlDbType.Numeric);
    //         //NpgsqlCommand tcMed = new(strCOM_pg, conn_pg);
    //         //using (NpgsqlDataReader reader = tcMed.ExecuteReader()) {
    //         //};
    //      }
    //      pg_writer.Complete();
    //   }

    //   conn_access.Close();
    //   conn_pg.Close();

    //}

    /*
       - mes -> DateTime.Now.toString("y") + (
       - Jan -> 01
       - Fev -> 02
       - Mar -> 03
       - Abr -> 04
       - Mai -> 05
       - Jun -> 06
       - Jul -> 07
       - Ago -> 08
       - Set -> 09
       - Out -> 10
       - Nov -> 11
       - Dez -> 12
       )

       COLUNAS DE INTERESSE
       ECONOMIA ACUMULADA
       - EA_Jan
       - EA_Fev
       - EA_Mar
       - EA_Abr
       - EA_Mai
       - EA_Jun
       - EA_Jul
       - EA_Ago
       - EA_Set
       - EA_Out
       - EA_Nov
       - EA_Dez

       ECONOMIA MENSAL
       - EM_Jan
       - EM_Fev
       - EM_Mar
       - EM_Abr
       - EM_Mai
       - EM_Jun
       - EM_Jul
       - EM_Ago
       - EM_Set
       - EM_Out
       - EM_Nov
       - EM_Dez

       CUSTO CATIVO ESTIMADO
       - CCE_Jan
       - CCE_Fev
       - CCE_Mar
       - CCE_Abr
       - CCE_Mai
       - CCE_Jun
       - CCE_Jul
       - CCE_Ago
       - CCE_Set
       - CCE_Out
       - CCE_Nov
       - CCE_Dez

       CUSTO LIVRE ESTIMADO
       - CLE_Jan
       - CLE_Fev
       - CLE_Mar
       - CLE_Abr
       - CLE_Mai
       - CLE_Jun
       - CLE_Jul
       - CLE_Ago
       - CLE_Set
       - CLE_Out
       - CLE_Nov
       - CLE_Dez

       Custo estimado?
       */

    /*
    CONDIÇÕES SELEÇÃO
    - Ult_ver <> 0

    Passos

    Para cada unidade (Postgres)
    -> Puxar maior dado consolidado de economia disponível
    -> -> A partir de dado consolidado, carregar dados de economia estimados (BD_APP ACCESS DB)
    -> -> Gravar registros (Postgres)
    -> -> -> custo_unit = 0
    -> -> -> dad_estimado = true
    */
    //IMPORTANTE, DEVE RODAR APOS IMPORTACAO DE ECONOMIA CONSOLIDADA
    private static void transfere_econ_estimado(string searchFromString)
    {
        //abre conexao com o Accesss
        OleDbConnection conn_access = new("Provider=Microsoft.ACE.OLEDB.12.0;Data Source=" + ACCESS_DB_LOCATION_APP + ";Jet OLEDB:Database Password=gds21");
        conn_access.Open();

        List<string> acc_months = new List<string>();
        acc_months.Add("Jan");
        acc_months.Add("Fev");
        acc_months.Add("Mar");
        acc_months.Add("Abr");
        acc_months.Add("Mai");
        acc_months.Add("Jun");
        acc_months.Add("Jul");
        acc_months.Add("Ago");
        acc_months.Add("Set");
        acc_months.Add("Out");
        acc_months.Add("Nov");
        acc_months.Add("Dez");

        NpgsqlConnection conn_pg, conn_writer, conn_check_last;
        if (ENVIRONMENT is "dev")
        {
            conn_pg = new(PG_CONN_STRING_DEV);
            conn_writer = new(PG_CONN_STRING_DEV);
            conn_check_last = new(PG_CONN_STRING_DEV);
        }
        else
        {
            conn_pg = new(PG_CONN_STRING_PROD);
            conn_writer = new(PG_CONN_STRING_PROD);
            conn_check_last = new(PG_CONN_STRING_PROD);
        }
        conn_pg.Open();
        conn_writer.Open();
        conn_check_last.Open();

        Console.WriteLine("Excluindo dados existentes de economia estimada");
        string pg_strCOM_delete = $"DELETE FROM economia WHERE dad_estimado = true AND mes::INTEGER >= {searchFromString}";
        NpgsqlCommand pg_tcSCDE_delete = new(pg_strCOM_delete, conn_pg);
        NpgsqlDataReader pg_reader_delete = pg_tcSCDE_delete.ExecuteReader();
        pg_reader_delete.Close();
        Console.WriteLine("Dados de economia estimada excluídos");

        string pgsql_select_units = "SELECT dc.cod_smart_cliente, dc.cod_smart_unidade, dc.unidade, e.max_month " +
                                    "FROM dados_cadastrais dc " +
                                    "LEFT JOIN ( " +
                                    "   SELECT cod_smart_unidade, TO_CHAR(MAX(TO_DATE(mes, 'YYMM')), 'MM')::INTEGER AS max_month " +
                                    "   FROM economia" +
                                    "   WHERE dad_estimado = false " +
                                    "   GROUP BY cod_smart_unidade" +
                                    ") e ON dc.cod_smart_unidade = e.cod_smart_unidade;";
        NpgsqlCommand pg_tc_units = new(pgsql_select_units, conn_pg);
        NpgsqlDataReader pg_reader_units = pg_tc_units.ExecuteReader();

        string unidade, cod_smart_unidade, cod_smart_cliente;
        int last_month;
        int i = 0;
        try
        {
            using (var pg_writer = conn_writer.BeginBinaryImport("COPY economia (cod_econ, cod_smart_unidade, mes, custo_cativo, custo_livre, economia_mensal, economia_acumulada, custo_unit, dad_estimado) FROM STDIN (FORMAT BINARY)"))
            {
                while (pg_reader_units.Read())
                {
                    unidade = pg_reader_units["unidade"].ToString();
                    cod_smart_unidade = pg_reader_units["cod_smart_unidade"].ToString();
                    cod_smart_cliente = pg_reader_units["cod_smart_cliente"].ToString();
                    if (!Int32.TryParse(pg_reader_units["max_month"].ToString(), out last_month))
                    {
                        continue;
                    }

                    i++;
                    if (last_month < 12)
                    {
                        //BASE SELECT
                        Console.WriteLine("Lendo dados do cliente {0} unidade {1} - Operação {2}", cod_smart_cliente, cod_smart_unidade, i);
                        string accessdb_select_last_data_month = $"TRANSFORM SUM(Valor) AS SomaDeValor " +
                            $"SELECT Cod_Smart_cliente, Unidade, Mes " +
                            $"FROM Dados_APP " +
                            $"WHERE Mes = (SELECT MAX(Mes)" +
                            $"              FROM Dados_APP" +
                            $"              WHERE Cod_Smart_cliente = {cod_smart_cliente} AND Unidade = '{unidade}')" +
                            $"  AND Cod_Smart_cliente = {cod_smart_cliente} AND Unidade = '{unidade}' AND (Tipo_dado = 'EM_REPLACEMONTH' OR Tipo_dado = 'EE_REPLACEMONTH' OR Tipo_dado = 'CCE_REPLACEMONTH' OR Tipo_dado = 'CLE_REPLACEMONTH') " +
                            $"GROUP BY Cod_Smart_cliente, Unidade, Mes " +
                            $"PIVOT Tipo_dado";

                        //PARA CADA MÊS ATÉ O FINAL DO ANO
                        for (int month = last_month; month < 12; month++)
                        {
                            Console.WriteLine("Buscando dados de economia a partir do mês {0}", month + 1);

                            string accessdb_select = accessdb_select_last_data_month.Replace("REPLACEMONTH", acc_months[month]);
                            OleDbCommand access_select = new(accessdb_select, conn_access);
                            OleDbDataReader reader_access = access_select.ExecuteReader();

                            string value_ea = "0";
                            string value_em = "0";
                            string value_cle = "0";
                            string value_cce = "0";

                            while (reader_access.Read())
                            {
                                value_ea = reader_access["EE_" + acc_months[month]].ToString();
                                value_em = reader_access["EM_" + acc_months[month]].ToString();
                                value_cle = reader_access["CLE_" + acc_months[month]].ToString();
                                value_cce = reader_access["CCE_" + acc_months[month]].ToString();
                            }
                            reader_access.Close();

                            DateTime currentMonthInserted = new DateTime(DateTime.Now.Year, month + 1, 1);
                            string currentMonthString = currentMonthInserted.ToString("yMM");

                            double cce = value_cce == "" ? 0 : Double.Parse(value_cce.Replace(",", "."));
                            double cle = value_cle == "" ? 0 : Double.Parse(value_cle.Replace(",", "."));
                            double em = value_em == "" ? 0 : Double.Parse(value_em.Replace(",", "."));
                            double ea = value_ea == "" ? 0 : Double.Parse(value_ea.Replace(",", "."));

                            //INSERE DADOS DE ECONOMIA ESTIMADA
                            pg_writer.StartRow();
                            pg_writer.Write(Int64.Parse(cod_smart_unidade + currentMonthString), NpgsqlTypes.NpgsqlDbType.Bigint);
                            pg_writer.Write(Int64.Parse(cod_smart_unidade), NpgsqlTypes.NpgsqlDbType.Bigint);
                            pg_writer.Write(currentMonthString);
                            pg_writer.Write(cce, NpgsqlTypes.NpgsqlDbType.Numeric);
                            pg_writer.Write(cle, NpgsqlTypes.NpgsqlDbType.Numeric);
                            pg_writer.Write(em, NpgsqlTypes.NpgsqlDbType.Numeric);
                            pg_writer.Write(ea, NpgsqlTypes.NpgsqlDbType.Numeric);
                            pg_writer.Write(0, NpgsqlTypes.NpgsqlDbType.Numeric);
                            pg_writer.Write(true, NpgsqlTypes.NpgsqlDbType.Boolean);
                        }
                    }
                    //ECONOMIA PROXIMOS 5 ANOS
                    string accessdb_select_last_data_year = $"TRANSFORM SUM(Valor) AS SomaDeValor " +
                            $"SELECT Cod_Smart_cliente, Unidade, Mes " +
                            $"FROM Dados_APP " +
                            $"WHERE Mes = (SELECT MAX(Mes)" +
                            $"              FROM Dados_APP" +
                            $"              WHERE Cod_Smart_cliente = {cod_smart_cliente} AND Unidade = '{unidade}')" +
                            $"  AND Cod_Smart_cliente = {cod_smart_cliente} AND Unidade = '{unidade}' AND (Tipo_dado = 'EM_REPLACEYEAR' OR Tipo_dado = 'EE_REPLACEYEAR' OR Tipo_dado = 'CCE_REPLACEYEAR' OR Tipo_dado = 'CLE_REPLACEYEAR') " +
                            $"GROUP BY Cod_Smart_cliente, Unidade, Mes " +
                            $"PIVOT Tipo_dado";

                    for (int year = 1; year < 6; year++)
                    {
                        Console.WriteLine("Buscando dados de economia a partir do ano {0}", year);
                        //CARREGA ECONOMIA ACUMULADA
                        //Console.WriteLine("Iniciando EA do mês {0}", month + 1);
                        string accessdb_select = accessdb_select_last_data_year.Replace("REPLACEYEAR", "Ano" + year);
                        OleDbCommand access_select = new(accessdb_select, conn_access);
                        OleDbDataReader reader_access = access_select.ExecuteReader();

                        string value_ea = "0";
                        string value_em = "0";
                        string value_cle = "0";
                        string value_cce = "0";

                        while (reader_access.Read())
                        {
                            value_ea = reader_access["EE_" + "Ano" + year].ToString();
                            value_em = reader_access["EM_" + "Ano" + year].ToString();
                            value_cle = reader_access["CLE_" + "Ano" + year].ToString();
                            value_cce = reader_access["CCE_" + "Ano" + year].ToString();
                        }
                        reader_access.Close();

                        DateTime currentMonthInserted = new DateTime((DateTime.Now.Year + year), 12, 1);
                        string currentMonthString = currentMonthInserted.ToString("yMM");

                        double cce = value_cce == "" ? 0 : Double.Parse(value_cce.Replace(",", "."));
                        double cle = value_cle == "" ? 0 : Double.Parse(value_cle.Replace(",", "."));
                        double em = value_em == "" ? 0 : Double.Parse(value_em.Replace(",", "."));
                        double ea = value_ea == "" ? 0 : Double.Parse(value_ea.Replace(",", "."));

                        //INSERE DADOS DE ECONOMIA ESTIMADA
                        pg_writer.StartRow();
                        pg_writer.Write(Int64.Parse(cod_smart_unidade + currentMonthString), NpgsqlTypes.NpgsqlDbType.Bigint);
                        pg_writer.Write(Int64.Parse(cod_smart_unidade), NpgsqlTypes.NpgsqlDbType.Bigint);
                        pg_writer.Write(currentMonthString);
                        pg_writer.Write(cce, NpgsqlTypes.NpgsqlDbType.Numeric);
                        pg_writer.Write(cle, NpgsqlTypes.NpgsqlDbType.Numeric);
                        pg_writer.Write(em, NpgsqlTypes.NpgsqlDbType.Numeric);
                        pg_writer.Write(ea, NpgsqlTypes.NpgsqlDbType.Numeric);
                        pg_writer.Write(0, NpgsqlTypes.NpgsqlDbType.Numeric);
                        pg_writer.Write(true, NpgsqlTypes.NpgsqlDbType.Boolean);
                        //Console.WriteLine("Dados do mês {0} adicionados para o Writer", month + 1);
                    }
                }
                var a = pg_writer.Complete();
            }
        }
        catch (Exception e)
        {
            Console.WriteLine(e.Message);
        }
        pg_reader_units.Close();

        conn_access.Close();
        conn_pg.Close();
        conn_writer.Close();
    }

}