Class ProcessamentoProcessador

java.lang.Object

br.com.vantroba.bi.transporte.processamento.ProcessamentoProcessador

@Singleton
public class ProcessamentoProcessador
extends Object

Execução assíncrona do processamento (fora do ProcessamentoService para o @Async ser aplicado via proxy).

Constructor Summary

Constructors

Constructor	Description
ProcessamentoProcessador(ProcessamentoRepository processamentoRepository, ProcessamentoTransactionalHelper transactionalHelper, ExcelProcessor excelProcessor, ProcessamentoNotificador notificador, ArmazenamentoArquivoService armazenamento, ConjuntoLoteService conjuntoLoteService, LogsConfig logs)	Cria o processador assíncrono com suas dependências.

Method Summary

Modifier and Type	Method	Description
void	executar(Long id)	Executa o processamento de forma assíncrona: lê o arquivo, processa o XLS, mescla os dados e registra o resultado (sucesso ou erro) com notificação via Telegram.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ProcessamentoProcessador

public ProcessamentoProcessador(ProcessamentoRepository processamentoRepository,
 ProcessamentoTransactionalHelper transactionalHelper,
 ExcelProcessor excelProcessor,
 ProcessamentoNotificador notificador,
 ArmazenamentoArquivoService armazenamento,
 ConjuntoLoteService conjuntoLoteService,
 LogsConfig logs)

Cria o processador assíncrono com suas dependências.

Parameters:

processamentoRepository - repositório de acesso aos registros de processamento

transactionalHelper - helper transacional de mescla dos dados do período

excelProcessor - processador do arquivo XLS

notificador - formata e dispara as notificações Telegram do processamento

armazenamento - coordenador de armazenamento do binário XLS (Postgres/Garage)

conjuntoLoteService - fecha o lote (.zip) e dispara o resumo quando todas as entradas terminam

logs - configuração do diretório de logs (app.logs.*)

Method Details

executar

@Async("processamento")
public void executar(Long id)

Executa o processamento de forma assíncrona: lê o arquivo, processa o XLS, mescla os dados e registra o resultado (sucesso ou erro) com notificação via Telegram.

Parameters:

id - identificador do processamento a executar