R/stj_baixar_por_publicacao.R

In jjesusfilho/stj: Baixa e organiza decisões do Superior Tribunal de Justiça

#' Baixa consulta de processos do STJ por data da publicação
#'
#' @param data_inicial Data inicial no formato dd/mm/aaaa.
#' @param data_final Data final no formato dd/mm/aaaa.
#' @param origem Sigla do(s) estado(s) de origem.
#' @param ramo Sigla do ramo do direito. Verifique o ramo
#'      por meio do dataset incluso ramo.
#' @param n Número de páginas.
#' @param diretorio Diretório. Se não informado, atual.
#'
#' @return Html
#' @export
#'
#' @examples
#' \dontrun{
#' stj_baixar_por_publicacao(data_inicial = "01/01/2019",
#'                           data_final = "30/01/2019",
#'                           origem = c("SP", "AC"))
#' }
#'
stj_baixar_por_publicacao <- function(data_inicial,
                                    data_final,
                                    origem = "",
                                    ramo = "",
                                    n = NULL,
                                    diretorio = "."){


  origem <- origem |>
            toupper() |>
            stringr::str_c(collapse= ",")


  ramo <- ramo |>
    toupper() |>
    stringr::str_c(collapse= ",")

  ## Essa url servirá como referer
  url2 <- "https://processo.stj.jus.br/processo/pesquisa/?aplicacao=processos.ea"

  url <- "https://processo.stj.jus.br/processo/pesquisa/"

  httr::set_config(httr::config(ssl_verifypeer = 0L))


  if (is.null(n)){

  corpo <-
    list(
      aplicacao = "processos.ea",
      acao = "pushconsultarprocessoconsultalimitenaoatendidasjaincluidas",
      descemail = "",
      senha = "",
      totalRegistrosPorPagina = "1",
      tipoPesquisaSecundaria = "",
      sequenciaisParteAdvogado = "-1",
      refinamentoAdvogado = "",
      refinamentoParte = "",
      tipoOperacaoFonetica = "",
      tipoOperacaoFoneticaPhonos = "2",
      origemOrgaosSelecionados = "",
      origemUFSelecionados = origem,
      julgadorOrgaoSelecionados = "",
      tipoRamosDireitoSelecionados = ramo,
      situacoesSelecionadas = "",
      num_processo = "",
      num_registro = "",
      numeroUnico = "",
      numeroOriginario = "",
      advogadoCodigo = "",
      dataAutuacaoInicial = "",
      dataAutuacaoFinal = "",
      pautaPublicacaoDataInicial = "",
      pautaPublicacaoDataFinal = "",
      dataPublicacaoInicial = data_inicial,
      dataPublicacaoFinal = data_final,
      parteAutor = "FALSE",
      parteReu = "FALSE",
      parteOutros = "FALSE",
      parteNome = "",
      opcoesFoneticaPhonosParte = "2",
      quantidadeMinimaTermosPresentesParte = "1",
      advogadoNome = "",
      opcoesFoneticaPhonosAdvogado = "2",
      quantidadeMinimaTermosPresentesAdvogado = "1",
      conectivo = "OU",
      listarProcessosOrdemDescrecente = "TRUE",
      listarProcessosOrdemDescrecenteTemp = "TRUE",
      listarProcessosAtivosSomente = "FALSE",
      listarProcessosEletronicosSomente = "FALSE"
    )


  resposta<-  httr::RETRY("POST", url = url, body = corpo,  encode="form",
                          httr::add_headers(`Referer` = url2),
                          httr::timeout(30))


  total  <- resposta |>
            httr::content()|>
            xml2::xml_find_first("//div[@class='clsMensagemLinha']") |>
            xml2::xml_text(trim = TRUE) |>
            stringr::str_extract("\\d+") |>
            as.integer()

  dividir <- \(x) x/100

  paginas <- total |>
            dividir() |>
            ceiling()

  } else {

    paginas <- n

  }

 corpo <-  list(
    aplicacao = "processos.ea",
    acao = "pushconsultarprocessoconsultalimitenaoatendidasjaincluidas",
    descemail = "",
    senha = "",
    NumPaginaAtual = "1",
    NumTotalRegistros = total,
    VaiParaPaginaAnterior = "false",
    VaiParaPaginaSeguinte = "true",
    ComProximaPagina = "TRUE",
    totalRegistrosPorPagina = 100,
    tipoPesquisaSecundaria = "",
    sequenciaisParteAdvogado = "-1",
    refinamentoAdvogado = "",
    refinamentoParte = "",
    tipoOperacaoFonetica = "",
    tipoOperacaoFoneticaPhonos = "2",
    origemOrgaosSelecionados = "",
    origemUFSelecionados = origem,
    julgadorOrgaoSelecionados = "",
    tipoRamosDireitoSelecionados = ramo,
    situacoesSelecionadas = "",
    num_processo = "",
    num_registro = "",
    numeroUnico = "",
    numeroOriginario = "",
    advogadoCodigo = "",
    dataAutuacaoInicial = "",
    dataAutuacaoFinal = "",
    pautaPublicacaoDataInicial = "",
    pautaPublicacaoDataFinal = "",
    dataPublicacaoInicial = data_inicial,
    dataPublicacaoFinal = data_final,
    parteAutor = "FALSE",
    parteReu = "FALSE",
    parteOutros = "FALSE",
    parteNome = "",
    opcoesFoneticaPhonosParte = "2",
    quantidadeMinimaTermosPresentesParte = "1",
    advogadoNome = "",
    opcoesFoneticaPhonosAdvogado = "2",
    quantidadeMinimaTermosPresentesAdvogado = "1",
    conectivo = "OU",
    listarProcessosOrdemDescrecente = "TRUE",
    listarProcessosOrdemDescrecenteTemp = "TRUE",
    listarProcessosAtivosSomente = "FALSE",
    listarProcessosEletronicosSomente = "FALSE"
  )

  pb <- progress::progress_bar$new(total = paginas)

  di <- data_inicial |>
        stringr::str_replace_all("/","_")

  df <- data_final |>
    stringr::str_replace_all("/","_")

  purrr::walk(1:paginas,purrr::possibly(~{

    pb$tick()



    arquivo <- file.path(diretorio, paste0("stj_por_pub_data_inicial_",di,"_data_final_",df,"_pagina_",.x, ".html"))

    corpo$NumPaginaAtual <- .x


    httr::RETRY("POST", url = url, body = corpo,  encode="form",
                            httr::add_headers(`Referer` = url2),
                            httr::timeout(30), httr::write_disk(arquivo))



  }, NULL))
}