invicodatr: INVICO's Data Manipulation

#' @importFrom magrittr %>%
#' @importFrom rlang .data
NULL

read_siif_ppto_gtos_fte_rf602 <- function(path){

  required_ext <- "xls"
  required_ncol <- 23
  required_title <- "DETALLE DE LA EJECUCION PRESUESTARIA"
  required_nvar <- 15

  if (!file.exists(path)) {
    abort_bad_path(path)
  }

  if (tools::file_ext(path) != required_ext) {
    abort_bad_ext(path, required_ext)
  }

  suppressMessages(
    db <- readxl::read_excel(path,
                             col_types = "text",
                             col_names = FALSE)
  )

  read_ncol <- ncol(db)

  if (read_ncol != required_ncol) {
    abort_bad_ncol(path, read_ncol, required_ncol)
  }

  read_title <- (db$...1[4])
  read_title <- stringr::str_sub(read_title, 1,
                                  (stringr::str_length(read_title) - 5))

  if (is.na(read_title) | (read_title != required_title)) {
    abort_bad_title(path, read_title, required_title)
  }

  db <- db %>%
    dplyr::transmute(ejercicio = stringr::str_sub(...1[4], -4),
                     programa = stringr::str_pad(...1, 2, pad = "0"),
                     subprograma = stringr::str_pad(...2, 2, pad = "0"),
                     proyecto = stringr::str_pad(...5, 2, pad = "0"),
                     actividad = stringr::str_pad(...6, 2, pad = "0"),
                     partida = ...7,
                     grupo = stringr::str_c(stringr::str_sub(.data$partida, 1,1), "00", ""),
                     fuente = ...8,
                     org = ...9,
                     credito_original = ...12,
                     credito_vigente = ...13,
                     comprometido = ...14,
                     ordenado = ...15,
                     saldo = ...17,
                     pendiente = ...19) %>%
    utils::tail(-13) %>%
    dplyr::filter(.data$programa != is.na(.data$programa)) %>%
    dplyr::mutate_at(c("credito_original", "credito_vigente", "comprometido",
                       "ordenado", "saldo", "pendiente"),
                     readr::parse_number,
                     locale = readr::locale(decimal_mark = "."))

  process_nvar <- ncol(db)

  if (process_nvar != required_nvar) {
    abort_bad_nvar(path, process_nvar, required_nvar)
  }

  invisible(db)

}

read_siif_ppto_gtos_desc_rf610 <- function(path){

  required_ext <- "xls"
  required_ncol <- 65
  required_title <- "LISTADO DE EJECUCION DE GASTOS POR PARTIDA"
  required_nvar <- 18

  if (!file.exists(path)) {
    abort_bad_path(path)
  }

  if (tools::file_ext(path) != required_ext) {
    abort_bad_ext(path, required_ext)
  }

  suppressMessages(
    db <- readxl::read_excel(path,
                             col_types = "text",
                             col_names = FALSE)
  )

  read_ncol <- ncol(db)

  if (read_ncol != required_ncol) {
    abort_bad_ncol(path, read_ncol, required_ncol)
  }

  read_title <- stringr::str_c(db$...32[1], db$...32[3], sep = " ")

  if (is.na(read_title) | (read_title != required_title)) {
    abort_bad_title(path, read_title, required_title)
  }

  db <- db %>%
    dplyr::transmute(ejercicio = stringr::str_sub(...33[8], -4),
                     programa = ...5,
                     subprograma = ...9,
                     proyecto = ...14,
                     actividad =  ...17,
                     grupo = ...20,
                     partida = ...21,
                     desc_part = ...24,
                     credito_original = ...38,
                     credito_vigente = ...44,
                     comprometido = ...49,
                     ordenado = ...55,
                     saldo = ...60) %>%
    utils::tail(-28) %>%
    dplyr::mutate(programa = zoo::na.locf(.data$programa),
                  subprograma = zoo::na.locf(.data$subprograma, F),
                  proyecto = zoo::na.locf(.data$proyecto, F),
                  actividad = zoo::na.locf(.data$actividad, F),
                  grupo = zoo::na.locf(.data$grupo, F),
                  partida = zoo::na.locf(.data$partida, F),
                  desc_part = zoo::na.locf(.data$desc_part, F)) %>%
    dplyr::filter(.data$credito_original != is.na(.data$credito_original)) %>%
    dplyr::mutate_at(c("credito_original", "credito_vigente",
                       "comprometido", "ordenado", "saldo"),
                     readr::parse_number,
                     locale = readr::locale(decimal_mark = ".")) %>%
    tidyr::separate(.data$programa, c("programa", "desc_prog"),
                    remove = T, extra = "merge") %>%
    tidyr::separate(.data$subprograma, c("subprograma", "desc_subprog"),
                    remove = T, extra = "merge") %>%
    tidyr::separate(.data$proyecto, c("proyecto", "desc_proy"),
                    remove = T, extra = "merge") %>%
    tidyr::separate(.data$actividad, c("actividad", "desc_act"),
                    remove = T, extra = "merge") %>%
    tidyr::separate(.data$grupo, c("grupo", "desc_gpo"),
                    remove = T, extra = "merge") %>%
    dplyr::mutate_at(c("programa", "subprograma",
                       "proyecto", "actividad"),
                     stringr::str_pad, width = 2, pad = "0")

  process_nvar <- ncol(db)

  if (process_nvar != required_nvar) {
    abort_bad_nvar(path, process_nvar, required_nvar)
  }

  invisible(db)

}

read_siif_comprobantes_gtos_rcg01_uejp <- function(path){

  required_ext <- "xls"
  required_ncol <- 19
  required_title <- "Resumen Diario de Comprobantes de Gastos Ingresados"
  required_nvar <- 19

  if (!file.exists(path)) {
    abort_bad_path(path)
  }

  if (tools::file_ext(path) != required_ext) {
    abort_bad_ext(path, required_ext)
  }

  suppressMessages(
    db <- readxl::read_excel(path,
                             col_types = "text",
                             col_names = FALSE)
  )

  read_ncol <- ncol(db)

  if (read_ncol != required_ncol) {
    abort_bad_ncol(path, read_ncol, required_ncol)
  }

  read_title <- (db$...1[4])

  if (is.na(read_title) | (read_title != required_title)) {
    abort_bad_title(path, read_title, required_title)
  }

  db <- db %>%
    dplyr::mutate(ejercicio = stringr::str_sub(...1[2], -4)) %>%
    dplyr::select(-...18, -...19)

  names(db) <- c("nro_entrada", "nro_origen", "fuente", "clase_reg",
                 "clase_mod", "clase_gto", "fecha", "monto",
                 "cuit", "beneficiario", "nro_expte","cta_cte",
                 "comprometido", "verificado", "aprobado", "pagado",
                 "nro_fondo", "ejercicio")

  db <- db %>%
    utils::tail(-15) %>%
    dplyr::filter(.data$cuit != is.na(.data$cuit)) %>%
    dplyr::filter(.data$nro_entrada != is.na(.data$nro_entrada)) %>%
    dplyr::mutate(fecha = as.Date(readr::parse_integer(.data$fecha),
                                  origin = "1899-12-30"),
                  mes =  stringr::str_c(stringr::str_pad(lubridate::month(.data$fecha), 2, pad = "0"),
                                        lubridate::year(.data$fecha), sep = "/"),
                  nro_entrada = readr::parse_integer(.data$nro_entrada),
                  nro_origen = readr::parse_integer(.data$nro_origen),
                  monto = readr::parse_number(.data$monto,
                                              locale = readr::locale(decimal_mark = ".")),
                  comprometido = ifelse(.data$comprometido == "S", T, F),
                  verificado = ifelse(.data$verificado == "S", T, F),
                  aprobado = ifelse(.data$aprobado == "S", T, F),
                  pagado = ifelse(.data$pagado == "S", T, F))

  process_nvar <- ncol(db)

  if (process_nvar != required_nvar) {
    abort_bad_nvar(path, process_nvar, required_nvar)
  }

  invisible(db)

}

read_siif_comprobantes_gtos_partida_rcg01_par <- function(path){

  required_ext <- "xls"
  required_ncol <- 19
  required_title <- "Resumen de Comprobantes de Gastos (excepto REM) con detalle de partidas"
  required_nvar <- 19

  if (!file.exists(path)) {
    abort_bad_path(path)
  }

  if (tools::file_ext(path) != required_ext) {
    abort_bad_ext(path, required_ext)
  }

  suppressMessages(
    db <- readxl::read_excel(path,
                             col_types = "text",
                             col_names = FALSE)
  )

  read_ncol <- ncol(db)

  if (read_ncol != required_ncol) {
    abort_bad_ncol(path, read_ncol, required_ncol)
  }

  read_title <- stringr::str_c(db$...1[4], db$...1[5], sep = " ")

  if (is.na(read_title) | (read_title != required_title)) {
    abort_bad_title(path, read_title, required_title)
  }

  db <- db %>%
    dplyr::mutate(ejercicio = stringr::str_sub(...1[2], -4)) %>%
    dplyr::select(-...2, -...4, -...9) %>%
    utils::tail(-14) %>%
    dplyr::filter(...1 != is.na(...1)) %>%
    dplyr::transmute(ejercicio = .data$ejercicio,
                     nro_entrada = readr::parse_integer(...1),
                     nro_origen = readr::parse_integer(...3),
                     fuente =  ...5,
                     clase_reg =  ...6,
                     clase_gto =  ...7,
                     fecha = as.Date(readr::parse_integer(...8),
                                     origin = "1899-12-30"),
                     mes =  stringr::str_c(stringr::str_pad(lubridate::month(.data$fecha), 2, pad = "0"),
                                           lubridate::year(.data$fecha), sep = "/"),
                     partida =  ...10,
                     grupo = stringr::str_c(
                       stringr::str_sub(.data$partida, 1,1), "00", ""),
                     monto = readr::parse_number(...11,
                                                 locale = readr::locale(decimal_mark = ".")),
                     cuit =  ...12,
                     beneficiario =  ...13,
                     nro_expte = ...14,
                     cta_cte =  ...15,
                     comprometido = ifelse(...16 == "S", T, F),
                     verificado = ifelse(...17 == "S", T, F),
                     aprobado = ifelse(...18 == "S", T, F),
                     pagado = ifelse(...19 == "S", T, F))

  process_nvar <- ncol(db)

  if (process_nvar != required_nvar) {
    abort_bad_nvar(path, process_nvar, required_nvar)
  }

  invisible(db)

}

read_siif_comprobantes_gtos_gpo_partida_gto_rpa03g <- function(path){

  required_ext <- "xls"
  required_ncol <- 30
  required_title <- "DETALLE DE DOCUMENTOS ORDENADOS. PARTIDA"
  required_nvar <- 11

  if (!file.exists(path)) {
    abort_bad_path(path)
  }

  if (tools::file_ext(path) != required_ext) {
    abort_bad_ext(path, required_ext)
  }

  suppressMessages(
    db <- readxl::read_excel(path,
                             col_types = "text",
                             col_names = FALSE)
  )

  read_ncol <- ncol(db)

  if (read_ncol != required_ncol) {
    abort_bad_ncol(path, read_ncol, required_ncol)
  }

  read_title <- stringr::str_sub(db$...18[4], 1,
                                 stringr::str_length(db$...18[4]) - 10)

  if (is.na(read_title) | (read_title != required_title)) {
    abort_bad_title(path, read_title, required_title)
  }

  db <- db %>%
    dplyr::mutate(ejercicio = stringr::str_sub(...18[2], -4)) %>%
    dplyr::select(.data$ejercicio, ...1, ...5, ...8, ...11,
                  ...14, ...17, ...19, ...21, ...23) %>%
    utils::tail(-20) %>%
    dplyr::filter(...1 != is.na(...1)) %>%
    dplyr::transmute(ejercicio = .data$ejercicio,
                     nro_entrada = readr::parse_integer(...1),
                     nro_origen = readr::parse_integer(...5),
                     monto = readr::parse_number(...8,
                                                 locale = readr::locale(decimal_mark = ".")),
                     fecha = as.Date(readr::parse_integer(...14),
                                     origin = "1899-12-30"),
                     mes =  stringr::str_c(stringr::str_pad(lubridate::month(.data$fecha), 2, pad = "0"),
                                           lubridate::year(.data$fecha), sep = "/"),
                     partida =  ...17,
                     grupo = stringr::str_c(
                       stringr::str_sub(.data$partida, 1,1), "00", ""),
                     nro_expte = ...19,
                     glosa = ...21,
                     beneficiario = ...23)

  process_nvar <- ncol(db)

  # if (process_nvar != required_nvar) {
  #   abort_bad_nvar(path, process_nvar, required_nvar)
  # }

  invisible(db)

}

read_siif_retenciones_por_codigo_rao01 <- function(path){

  required_ext <- "xls"
  required_ncol <- 20
  required_title <- "Provincia de Corrientes"
  required_nvar <- 8

  if (!file.exists(path)) {
    abort_bad_path(path)
  }

  if (tools::file_ext(path) != required_ext) {
    abort_bad_ext(path, required_ext)
  }

  suppressMessages(
    db <- readxl::read_excel(path,
                             col_types = "text",
                             col_names = FALSE)
  )

  read_ncol <- ncol(db)

  if (read_ncol != required_ncol) {
    abort_bad_ncol(path, read_ncol, required_ncol)
  }

  read_title <- db$...2[2]

  if (is.na(read_title) | (read_title != required_title)) {
    abort_bad_title(path, read_title, required_title)
  }

  db <- db %>%
    utils::tail(-16) %>%
    dplyr::filter(...1 != is.na(...1)) %>%
    dplyr::transmute(fecha = as.Date(readr::parse_integer(...12),
                                     origin = "1899-12-30"),
                     mes =  stringr::str_c(stringr::str_pad(lubridate::month(.data$fecha), 2, pad = "0"),
                                           lubridate::year(.data$fecha), sep = "/"),
                     ejercicio = as.character(lubridate::year(.data$fecha)),
                     nro_entrada = readr::parse_integer(...1),
                     cod_retencion = ...4,
                     desc_retencion =  ...7,
                     monto = readr::parse_number(...11,
                                                 locale = readr::locale(decimal_mark = ".")),
                     cta_cte =  ...14)

  process_nvar <- ncol(db)

  if (process_nvar != required_nvar) {
    abort_bad_nvar(path, process_nvar, required_nvar)
  }

  invisible(db)

}

read_siif_resumen_fdos_rfondo07tp <- function(path){

  required_ext <- "xls"
  required_ncol <- 20
  required_title <- "RESUMEN DE FONDOS DEL EJERCICIO"
  required_nvar <- 9

  if (!file.exists(path)) {
    abort_bad_path(path)
  }

  if (tools::file_ext(path) != required_ext) {
    abort_bad_ext(path, required_ext)
  }

  suppressMessages(
    db <- readxl::read_excel(path,
                             col_types = "text",
                             col_names = FALSE)
  )

  read_ncol <- ncol(db)

  if (read_ncol != required_ncol) {
    abort_bad_ncol(path, read_ncol, required_ncol)
  }

  read_title <- stringr::str_sub(db$...1[3], 1,
                                 stringr::str_length(db$...1[3]) - 5)

  if (is.na(read_title) | (read_title != required_title)) {
    abort_bad_title(path, read_title, required_title)
  }

  db <- db %>%
    dplyr::mutate(ejercicio = stringr::str_sub(...1[3], -4),
                  tipo_comprobante = stringr::str_sub(...2[10], - (length(...2[10]) - 72)))

  db <- db %>%
    utils::tail(-14) %>%
    dplyr::filter(...10 != is.na(...10)) %>%
    dplyr::transmute(tipo_comprobante = .data$tipo_comprobante,
                     ejercicio = .data$ejercicio,
                     fecha = as.Date(readr::parse_integer(...10),
                                     origin = "1899-12-30"),
                     mes =  stringr::str_c(stringr::str_pad(lubridate::month(.data$fecha), 2, pad = "0"),
                                           lubridate::year(.data$fecha), sep = "/"),
                     nro_fondo = readr::parse_integer(...3),
                     glosa = ...6,
                     ingresos = readr::parse_number(...12,
                                                    locale = readr::locale(decimal_mark = ".")),
                     egresos = readr::parse_number(...15,
                                                   locale = readr::locale(decimal_mark = ".")),
                     saldo = readr::parse_number(...18,
                                                 locale = readr::locale(decimal_mark = ".")))


  process_nvar <- ncol(db)

  if (process_nvar != required_nvar) {
    abort_bad_nvar(path, process_nvar, required_nvar)
  }

  invisible(db)

}

read_siif_deuda_flotante_rdeu012 <- function(path){

  required_ext <- "xls"
  required_ncol <- 23
  required_title <- "DETALLE DE COMPROBANTES DE GASTOS ORDENADOS Y NO PAGADOS (DEUDA FLOTANTE)"
  required_nvar <- 15

  if (!file.exists(path)) {
    abort_bad_path(path)
  }

  if (tools::file_ext(path) != required_ext) {
    abort_bad_ext(path, required_ext)
  }

  suppressMessages(
    db <- readxl::read_excel(path,
                             col_types = "text",
                             col_names = FALSE)
  )

  read_ncol <- ncol(db)

  if (read_ncol != required_ncol) {
    abort_bad_ncol(path, read_ncol, required_ncol)
  }

  read_title <- (db$...1[8])

  if (is.na(read_title) | (read_title != required_title)) {
    abort_bad_title(path, read_title, required_title)
  }

  suppressWarnings(
    db <- db %>%
      dplyr::mutate(fuente = ifelse(...5 == "27", NA, as.numeric(...5)),
                    fecha_desde = stringr::str_sub(...1[14], 7 ,17),
                    fecha_hasta = stringr::str_sub(...1[14], -10))
  )

  db <- db %>%
    utils::tail(-11) %>%
    dplyr::transmute(fuente = zoo::na.locf(.data$fuente),
                     fecha_desde = lubridate::dmy(.data$fecha_desde),
                     fecha_hasta = lubridate::dmy(.data$fecha_hasta),
                     mes_hasta = stringr::str_c(stringr::str_pad(lubridate::month(.data$fecha_hasta),
                                                                 2, pad = "0"),
                                                lubridate::year(.data$fecha_hasta), sep = "/"),
                     nro_entrada = ...1,
                     nro_origen = ...3,
                     fecha_aprobado = ...6,
                     org_fin = ...8,
                     monto = ...9,
                     saldo = ...12,
                     nro_expte = ...13,
                     cta_cte = ...14,
                     referencia = ...16,
                     cuit = ...17,
                     beneficiario = ...18) %>%
    dplyr::filter(!is.na(.data$cuit),
                  !is.na(.data$nro_entrada)) %>%
    dplyr::mutate(fecha_aprobado = as.Date(readr::parse_integer(.data$fecha_aprobado),
                                           origin = "1899-12-30"),
                  nro_entrada = readr::parse_integer(.data$nro_entrada),
                  nro_origen = readr::parse_integer(.data$nro_origen),
                  monto = round(readr::parse_double(.data$monto), 2),
                  saldo = round(readr::parse_double(.data$saldo), 2))

  process_nvar <- ncol(db)

  if (process_nvar != required_nvar) {
    abort_bad_nvar(path, process_nvar, required_nvar)
  }

  invisible(db)

}

read_siif_deuda_flotante_tg_rdeu012b2_c <- function(path){

  required_ext <- "csv"
  required_ncol <- 12
  required_title <- "DETALLE DE COMPROBANTES DE GASTOS ORDENADOS Y NO PAGADOS (DEUDA FLOTANTE)"
  required_nvar <- 14

  if (!file.exists(path)) {
    abort_bad_path(path)
  }

  if (tools::file_ext(path) != required_ext) {
    abort_bad_ext(path, required_ext)
  }

  # db <- readr::read_csv(x, col_names = FALSE,
  #                       col_types = readr::cols(.default = "c"),
  #                       locale = readr::locale(encoding = stringi::stri_enc_get()))

  suppressMessages(
    db <- vroom::vroom(path, col_names = FALSE, delim = ",",
                       col_types = vroom::cols(.default = "c"),
                       locale = vroom::locale(encoding = stringi::stri_enc_get()))
  )

  read_ncol <- ncol(db)

  if (read_ncol != required_ncol) {
    abort_bad_ncol(path, read_ncol, required_ncol)
  }

  read_title <- (db$X5[4])

  if (is.na(read_title) | (read_title != required_title)) {
    abort_bad_title(path, read_title, required_title)
  }

  db <- db %>%
    dplyr::mutate(fecha_desde = stringr::str_sub(X1[7], 7 ,17),
                  fecha_hasta = stringr::str_sub(X1[7], -10)) %>%
    dplyr::filter(!is.na(X6)) %>%
    utils::head(-2) %>%
    dplyr::mutate(ejercicio = ifelse(is.na(X1), stringr::str_sub(X2[], -4), NA)) %>%
    dplyr::transmute(ejercicio = zoo::na.locf(.data$ejercicio, fromLast = TRUE),
                     fuente = X3,
                     fecha_desde = lubridate::dmy(.data$fecha_desde),
                     fecha_hasta = lubridate::dmy(.data$fecha_hasta),
                     mes_hasta = stringr::str_c(stringr::str_pad(lubridate::month(.data$fecha_hasta),
                                                                 2, pad = "0"),
                                                lubridate::year(.data$fecha_hasta), sep = "/"),
                     nro_entrada = X1,
                     nro_origen = X2,
                     cc = stringr::str_c(.data$nro_entrada,
                                         stringr::str_sub(.data$ejercicio, -2), sep = "/"),
                     org_fin = X4,
                     monto = X5,
                     saldo = X6,
                     nro_expte = X7,
                     cta_cte = X8,
                     glosa = X9) %>%
    dplyr::filter(!is.na(.data$fuente),
                  .data$fuente != "Fte") %>%
    dplyr::mutate(nro_entrada = readr::parse_integer(.data$nro_entrada),
                  nro_origen = readr::parse_integer(.data$nro_origen)) %>%
    dplyr::mutate_at(c("monto", "saldo"),
                     ~round(readr::parse_number(.,
                                                locale = readr::locale(decimal_mark = ",")), 2))

  process_nvar <- ncol(db)

  if (process_nvar != required_nvar) {
    abort_bad_nvar(path, process_nvar, required_nvar)
  }

  invisible(db)

}

read_siif_pagos_rtr03 <- function(path){

  required_ext <- "xls"
  required_ncol <- 42
  required_title <- "- RENDICION DE CUENTAS -"
  required_nvar <- 14

  if (!file.exists(path)) {
    abort_bad_path(path)
  }

  if (tools::file_ext(path) != required_ext) {
    abort_bad_ext(path, required_ext)
  }

  suppressMessages(
    db <- readxl::read_excel(path,
                             col_types = "text",
                             col_names = FALSE)
  )

  read_ncol <- ncol(db)

  if (read_ncol != required_ncol) {
    abort_bad_ncol(path, read_ncol, required_ncol)
  }

  read_title <- (db$...22[3])

  if (is.na(read_title) | (read_title != required_title)) {
    abort_bad_title(path, read_title, required_title)
  }

  db <- db %>%
    utils::tail(-18) %>%
    dplyr::mutate_all(stringr::str_replace_all,
                      pattern = "[\r\n]", replacement = "") %>%
    dplyr::transmute(ejercicio = ...9,
                     entidad = ...6,
                     nro_entrada = ...8,
                     ejercicio_origen = ...1,
                     nro_cap = ...10,
                     fuente = ...12,
                     fecha_pago = ...13,
                     cta_cte_pago = ...16,
                     nro_interno = ...18,
                     chq_bco = ...19,
                     tipo = ...21,
                     cuit_pago = ...23,
                     beneficiario = ...25,
                     glosa = ...27,
                     monto = ...29,
                     ingresos = ...38,
                     uej = ...42) %>%
    dplyr::filter(!is.na(.data$ejercicio_origen)) %>%
    dplyr::mutate(fecha_pago = as.Date(readr::parse_integer(.data$fecha_pago),
                                       origin = "1899-12-30"),
                  mes =  stringr::str_c(stringr::str_pad(lubridate::month(.data$fecha_pago), 2, pad = "0"),
                                        lubridate::year(.data$fecha_pago), sep = "/"),
                  monto = round(readr::parse_double(.data$monto), 2),
                  ingresos = round(readr::parse_double(.data$ingresos), 2))

  #Deleting some cols
  db <- db %>%
    dplyr::select(-.data$ingresos, -.data$uej, -.data$chq_bco,
                  -.data$nro_interno, -.data$ejercicio_origen, -.data$entidad)

  #ERROR con los ANP (el reporte solo trae un CAP por lo que el mov. queda anulado)
  db <- db %>%
    dplyr::filter(.data$tipo != "ANP")

  # #Transformamos los ANP en CAP
  # BD <- BD %>%
  #   mutate(Tipo = ifelse(Tipo == "ANP", "CAP", Tipo))

  #Generamos un proxy del Cta Cte Gasto
  carga_gasto <- db %>%
    dplyr::filter(!.data$cuit_pago %in% c(30709110078, 33693450239)) %>%
    dplyr::group_by(.data$nro_entrada, .data$tipo) %>%
    dplyr::filter(.data$monto == max(.data$monto)) %>%
    dplyr::select(.data$nro_entrada, .data$tipo,
                  cta_cte = .data$cta_cte_pago, cuit = .data$cuit_pago) %>%
    unique()

  db <- db %>%
    dplyr::left_join(carga_gasto, by = c("nro_entrada", "tipo")) %>%
    dplyr::mutate(cta_cte = dplyr::if_else(is.na(.data$cta_cte),
                                           .data$cta_cte_pago, .data$cta_cte),
                  cuit = dplyr::if_else(is.na(.data$cuit),
                                        .data$cuit_pago, .data$cuit))

  # #Volvemos a crear el Tipo ANP
  # BD <- BD %>%
  #   mutate(Tipo = ifelse(Monto < 0, "ANP", Tipo))

  db <- db %>%
    dplyr::select(.data$ejercicio, .data$mes, .data$nro_entrada, .data$tipo,
                  .data$fuente, .data$fecha_pago, .data$cta_cte,
                  .data$cuit, .data$cta_cte_pago, .data$cuit_pago,
                  .data$beneficiario, .data$monto, dplyr::everything())

  process_nvar <- ncol(db)

  if (process_nvar != required_nvar) {
    abort_bad_nvar(path, process_nvar, required_nvar)
  }

  invisible(db)

}