Class ProcessamentoConsultaService

java.lang.Object
br.com.vantroba.bi.transporte.processamento.ProcessamentoConsultaService
@Singleton public class ProcessamentoConsultaService extends Object
Consultas de processamento: listagem paginada, detalhe, leitura do arquivo de log em disco e download do XLS original.

  • Constructor Details

    • ProcessamentoConsultaService

      public ProcessamentoConsultaService(ProcessamentoRepository processamentoRepository, ArmazenamentoArquivoService armazenamento)
      Cria o serviço de consultas de processamento.
      Parameters:
      processamentoRepository - repositório de acesso aos registros de processamento
      armazenamento - coordenador de armazenamento do binário XLS (Postgres/Garage)

  • Method Details

    • listar

      public ProcessamentoListResponse listar(int page, int size, String status)
      Lista processamentos de forma paginada, opcionalmente filtrando por status.
      Parameters:
      page - número da página (base conforme o repositório)
      size - quantidade de itens por página
      status - status para filtrar; null ou vazio retorna todos
      Returns:
      resposta paginada com os resumos dos processamentos e o total de registros

    • detalhe

      public Optional<ProcessamentoDetalheResponse> detalhe(Long id)
      Busca o detalhe completo de um processamento por id.
      Parameters:
      id - identificador do processamento
      Returns:
      o detalhe do processamento, ou Optional.empty() se não existir

    • lerLogConteudo

      public Optional<String> lerLogConteudo(Long id)
      Lê o conteúdo do arquivo de log associado ao processamento. Retorna vazio se o arquivo ainda não existir ou não puder ser lido.
      Parameters:
      id - identificador do processamento
      Returns:
      o conteúdo do log; Optional.empty() se o processamento não existir; ou string vazia se o log ainda não estiver disponível

    • baixarArquivo

      public Optional<ArquivoXlsDownload> baixarArquivo(Long id)
      Recupera o binário do XLS original de um processamento para download. Lê do backend conforme o modo de armazenamento configurado (Postgres e/ou Garage).
      Parameters:
      id - identificador do processamento
      Returns:
      o arquivo (nome saneado + bytes); Optional.empty() se o processamento não existir
      Throws:
      StorageIndisponivelException - se o binário não puder ser recuperado do storage