Class ConjuntoLoteService

java.lang.Object

br.com.vantroba.bi.transporte.processamento.ConjuntoLoteService

@Singleton
public class ConjuntoLoteService
extends Object

Coordena o ciclo de vida de um lote (.zip). Após cada arquivo terminar (ou ser duplicata, ou não-processável), verifica atomicamente se o lote fechou e, se sim, dispara o resumo Telegram. Espelha o ConjuntoLoteService do bi-comercial-xls.

Constructor Summary

Constructors

Constructor	Description
ConjuntoLoteService(ConjuntoLoteRepository loteRepository, ProcessamentoRepository processamentoRepository, ProcessamentoNotificador notificador)

Method Summary

Modifier and Type	Method	Description
void	contabilizarNaoProcessado(String conjuntoId)	Entrada do zip que não gerou processamento nem era duplicata-sucesso (rejeitada por tipo/magic, ou já em andamento): conta para o lote fechar mesmo assim.
void	registrar(String conjuntoId, int total)	Registra o lote na primeira chamada (idempotente).
void	registrarDuplicado(String conjuntoId)	Arquivo já existente no banco (HTTP 200): conta e verifica se o lote fechou.
void	verificarENotificar(String conjuntoId)	Verifica atomicamente se o lote fechou; o thread vencedor dispara o resumo Telegram.

Methods inherited from class Object

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

Constructor Details

ConjuntoLoteService

public ConjuntoLoteService(ConjuntoLoteRepository loteRepository,
 ProcessamentoRepository processamentoRepository,
 ProcessamentoNotificador notificador)

Method Details

registrar

public void registrar(String conjuntoId,
 int total)

Registra o lote na primeira chamada (idempotente).

registrarDuplicado

public void registrarDuplicado(String conjuntoId)

Arquivo já existente no banco (HTTP 200): conta e verifica se o lote fechou.

contabilizarNaoProcessado

public void contabilizarNaoProcessado(String conjuntoId)

Entrada do zip que não gerou processamento nem era duplicata-sucesso (rejeitada por tipo/magic, ou já em andamento): conta para o lote fechar mesmo assim.

verificarENotificar

public void verificarENotificar(String conjuntoId)

Verifica atomicamente se o lote fechou; o thread vencedor dispara o resumo Telegram. Chamar após cada processamento (SUCESSO/ERRO) de um arquivo que pertence a um lote.