Package br.com.vantroba.bi.transporte.processamento

package br.com.vantroba.bi.transporte.processamento

Pipeline de processamento da planilha XLS — a feature central do app. Carrega todas as suas camadas: controllers REST + views, services (recebimento, execução assíncrona, recovery na inicialização, armazenamento do binário, notificação), repositórios JDBC e as entidades dos fatos bi_* e do controle xls_*.

O upload responde 202 Accepted na hora e o trabalho pesado roda num pool dedicado; o subpacote processing faz a leitura do Excel (FastExcel, em streaming) e o mapeamento de colunas, sem conhecer a camada HTTP.

Related Packages

Package	Description
br.com.vantroba.bi.transporte	Raiz do bi-transporte-xls: serviço Micronaut que recebe a planilha XLS de transporte, processa as abas em registros bi_*/xls_* no PostgreSQL e expõe o resultado por API REST e views server-rendered, sincronizando para clientes Dart via PowerSync.
br.com.vantroba.bi.transporte.processamento.processing	Leitura do arquivo Excel — parsing em streaming via FastExcel (StAX, decisão 0026) e mapeamento das colunas das abas para os registros do domínio.
br.com.vantroba.bi.transporte.configuracao	Configuração global de runtime do app, editável pelo admin e persistida em banco — distinta da configuração estática de deploy (application.yml/env).
br.com.vantroba.bi.transporte.powersync	Reset da replicação PowerSync — orquestra os steps que pausam a replicação, derrubam o estado no MongoDB do PowerSync, recriam o slot no PostgreSQL e sinalizam os clientes Dart a refazerem o bootstrap (disconnectAndClear).
br.com.vantroba.bi.transporte.seguranca	Camada de segurança específica do app (decisão 0011 / etapa 07): a policy de proteção das views e o fluxo de login Google.

Class	Description
ArmazenamentoArquivoService	Coordena o armazenamento do binário XLS entre o Postgres (coluna arquivo_bytes) e o object storage Garage, conforme o ArmazenamentoModo configurado em app.storage.modo.
ArquivoBytesLegado	Projeção de coluna única: o binário legado arquivo_bytes.
ArquivoXlsDownload	Conteúdo de um arquivo XLS recuperado do storage para download.
BulkUpserter	Caminho idempotente UPSERT diff-aware + DELETE seletivo (spec 004).
ColunasConteudo	Fonte de verdade única das colunas relevantes ao caminho idempotente UPSERT diff-aware (spec 004 — § 4.2 e § 5.4).
ConjuntoLote	Tabela xls_conjunto_lote: rastreia um lote de arquivos enviados juntos num .zip.
ConjuntoLoteRepository	Persistência de ConjuntoLote (lote por zip).
ConjuntoLoteService	Coordena o ciclo de vida de um lote (.zip).
Faturamento	Linha de faturamento importada da aba 20 do Excel — tabela bi_faturamento.
FaturamentoRepository	Repositório CRUD de bi_faturamento.
LoteRecebimentoBody	Resposta do POST /api/xls/processar: id do lote, total e status por entrada.
LoteRecebimentoBody.Item	Status de um arquivo do lote.
MesclaResumo	Agregado das métricas de uma execução do orquestrador (spec 004 § 5.5): contém o UpsertResultado de cada tabela alvo.
Movimento	Linha de movimento contábil importada da aba 30 — tabela bi_movimento.
MovimentoRepository	Repositório CRUD de bi_movimento.
ProcessamentoConsultaService	Consultas de processamento: listagem paginada, detalhe, leitura do arquivo de log em disco e download do XLS original.
ProcessamentoDetalheResponse	Detalhe de um processamento para API e tela de detalhe (metadados, contagens e métricas de idempotência da spec 004; sem bytes do XLS).
ProcessamentoListResponse	Resposta paginada do endpoint de listagem de processamentos.
ProcessamentoNotificador	Formata e dispara as notificações Telegram do pipeline de processamento.
ProcessamentoProcessador	Execução assíncrona do processamento (fora do ProcessamentoService para o @Async ser aplicado via proxy).
ProcessamentoRepository	Persistência JDBC de ProcessamentoXls e atualizações de status.
ProcessamentoResponse	Resposta do recebimento síncrono (o controller HTTP mapeia httpStatus para o status da resposta).
ProcessamentoResumoDto	Linha da lista de processamentos (JTE e GET /api/transporte/processamentos).
ProcessamentoService	Orquestra recepção de arquivos, deduplicação por checksum e agendamento do processamento assíncrono.
ProcessamentoService.ItemLote	Status de uma entrada .xlsx do lote (id nulo quando não gerou processamento).
ProcessamentoService.LoteResultado	Resultado do recebimento de um lote (.zip).
ProcessamentoStatus	Estados de um processamento de XLS (xls_processamento.status).
ProcessamentoTransactionalHelper	Operações transacionais sobre os dados do BI por período (evita problemas de proxy com @Async).
ProcessamentoXls	Entidade da tabela xls_processamento: metadados do envio, referência ao objeto XLS no MinIO e resultado do job.
StorageBackfillService	Backfill dos blobs legados (arquivo_bytes) para o object storage Garage, dirigido pelo ArmazenamentoModo configurado em app.storage.modo: PSQL — não faz nada (tudo permanece no Postgres).
TransporteController	API REST de transporte: envio de XLS (Bearer), listagem e consulta pública de processamentos.
UpsertResultado	Métricas de uma operação UPSERT diff-aware + DELETE seletivo no caminho idempotente (spec 004 — § 4.7).
ViewController	Rotas HTML (JTE) para histórico e detalhe de processamentos — acesso anônimo conforme configuração de segurança.
XlsController	Porta única de envio de XLS — padrão da casa, idêntico entre todos os clientes.
ZipXlsExtrator	Desempacota o .zip de lote em suas entradas .xlsx (o zip É o lote).
ZipXlsExtrator.EntradaXls	Uma entrada .xlsx do zip.