Recebimento Fisico Odoo

QUANDO NAO USAR ESTA SKILL

• Match NF x PO (Fase 2, anterior ao recebimento fisico)
• Split/consolidar PO (Fase 3, anterior ao recebimento fisico)
• Operacoes financeiras como pagamentos ou reconciliacao de extratos
• Rastrear fluxo documental completo de NF/PO/SO (esta skill opera o armazem, nao rastreia)

Recebimento Fisico - Odoo (Fase 4)

Skill para operar o modulo de Recebimento Fisico: preencher lotes, quantidades e quality checks, com processamento assincrono no Odoo via Redis Queue (RQ).

Contexto

Quando um picking de compra (incoming) chega ao armazem, o operador precisa:

1. Informar os lotes e quantidades de cada produto recebido
2. Executar quality checks (aprovacao pass/fail ou medicao)
3. Validar o picking no Odoo (button_validate → state=done)

O sistema sincroniza pickings do Odoo para cache local (APScheduler 30min), salva LOCALMENTE (imediato) e processa no Odoo via worker RQ (assincrono).

Arquitetura

APScheduler (30 min)              TELA 1 (pickings)              WORKER RQ
    Sync Odoo → Local         ─┐     Lista (cache local)         Processar pendentes
    4 tabelas normalizadas     │     Ao clicar → refresh Odoo    Enviar para Odoo
    Incremental (write_date)   │     Preencher lotes + QC        button_validate
                               └┐    SALVAR (banco local)    ────┘
                                │
TELA 2 (status)                 │
    Consultar Odoo              │
    Mostrar status              │
    Retry erros                 │

Arquivos Principais

• Sync (cache): app/recebimento/services/picking_recebimento_sync_service.py
• Service local: app/recebimento/services/recebimento_fisico_service.py
• Service Odoo: app/recebimento/services/recebimento_fisico_odoo_service.py
• Worker RQ: app/recebimento/workers/recebimento_fisico_jobs.py
• Scheduler: app/scheduler/sincronizacao_incremental_definitiva.py (variavel: picking_recebimento_sync_service)

Classe Principal

from app.recebimento.services.recebimento_fisico_service import RecebimentoFisicoService
from app.recebimento.services.recebimento_fisico_odoo_service import RecebimentoFisicoOdooService

service = RecebimentoFisicoService()
odoo_service = RecebimentoFisicoOdooService()

Fluxo do Worker (8 Passos)

ENTRADA:
  - recebimento_id (RecebimentoFisico com status='pendente')

PASSO 1: Conectar Odoo e verificar picking (state=assigned)
  → get_odoo_connection() + authenticate()
  → Ler picking_data → se state != assigned, erro

PASSO 2: Resolver lotes com expiration_date (stock.lot manual)
  → Para cada lote com data_validade + use_expiration_date=True:
    a) Verificar se stock.lot ja existe (name + product_id + company_id)
    b) Se NAO: create('stock.lot', {name, product_id, company_id, expiration_date})
    c) Se SIM: write('stock.lot', lot_id, {expiration_date})
    d) Usar lot_id no passo 3 (em vez de lot_name)

PASSO 3: Preencher lotes (stock.move.line)
  → Para cada lote do recebimento:
    a) 1o lote: write(move_line_id, {lot_id/lot_name, quantity})
    b) Lotes extras: create('stock.move.line', {picking_id, move_id, product_id, lot_id/lot_name, quantity, locations})

PASSO 4: Quality checks passfail
  → execute_kw('quality.check', 'do_pass', [[check_id]])
  → execute_kw('quality.check', 'do_fail', [[check_id]])

PASSO 5: Quality checks measure
  → write('quality.check', check_id, {'measure': valor})
  → execute_kw('quality.check', 'do_measure', [[check_id]])

PASSO 6: Validar picking
  → execute_kw('stock.picking', 'button_validate', [[picking_id]])
  → Tratar "cannot marshal None" como sucesso

PASSO 7: Verificar resultado
  → Ler picking: state='done' = sucesso

PASSO 8: Atualizar status local
  → recebimento.status = 'processado' / 'erro'
  → Marcar lotes e checks como processado=True

Operacoes Suportadas

Tabelas de Cache (Sync APScheduler - 4 tabelas normalizadas)

Sync: APScheduler a cada 30 min, janela 90 min (env: JANELA_PICKINGS) Filtro: picking_type_code='incoming' AND purchase_id != False Dedup: Por write_date (mais recente por PO)

Tabelas de Trabalho (Recebimento local)

Modelos Odoo Envolvidos

Campos stock.move.line (ATENCAO - Versao Odoo)

IMPORTANTE: O campo reserved_uom_qty NAO existe nesta versao do Odoo.

Coluna local reserved_uom_qty: Armazena valor de qty_done do Odoo (nome historico mantido por compatibilidade).

Metodo de Conexao Odoo

from app.odoo.utils.connection import get_odoo_connection

odoo = get_odoo_connection()
odoo.authenticate()

# UNICO metodo generico:
resultado = odoo.execute_kw(modelo, metodo, args, kwargs)

# Helpers (wrappers de execute_kw):
odoo.search(modelo, domain, limit=None)
odoo.read(modelo, ids, fields)
odoo.write(modelo, id_ou_ids, values)
odoo.create(modelo, values)

NUNCA usar odoo.execute() — nao existe, causa AttributeError.

Redis (Worker RQ)

Queue: 'recebimento' (dedicada, timeout 10min por job)

APIs Disponiveis

Tracking de Produtos

• 73.6% dos produtos tem tracking='lot' (1191 de 1618)
• Produtos com tracking='lot' EXIGEM lote no recebimento
• Produtos com tracking='none' usam 'SEM_LOTE' como placeholder (nao cria lote no Odoo)

Cenarios de Uso

Recebimento simples (1 lote por produto)

Picking IN/00123: 500 un produto X (tracking=lot)
Operador preenche: Lote "L2026-001", Qtd 500

Worker:
  1. write(move_line_id, {lot_name: 'L2026-001', quantity: 500})
  2. button_validate → state=done
  3. Odoo cria stock.lot automaticamente

Recebimento multi-lote (N lotes por produto)

Picking IN/00124: 1000 un produto Y (tracking=lot)
Operador preenche:
  - Lote "L2026-A", Qtd 600
  - Lote "L2026-B", Qtd 400

Worker:
  1. write(move_line_existente, {lot_name: 'L2026-A', quantity: 600})
  2. create('stock.move.line', {..., lot_name: 'L2026-B', quantity: 400})
  3. button_validate → state=done

Recebimento com data de validade (expiration_date)

Picking IN/00125: 500 un produto W (tracking=lot, use_expiration_date=True)
Operador preenche: Lote "L2026-VAL", Qtd 500, Validade 15/06/2026

Worker (_resolver_lote):
  1. Buscar stock.lot existente: search([name='L2026-VAL', product_id=W])
  2. NAO existe → create('stock.lot', {name, product_id, company_id, expiration_date: '2026-06-15 00:00:00'})
  3. write(move_line, {lot_id: novo_lot_id, quantity: 500})  ← usa lot_id, NAO lot_name
  4. button_validate → state=done (lote JA existe com validade)

Recebimento com quality check (measure)

Picking IN/00126: 200 kg produto Z + check de umidade
  - Quality check: measure, tolerance 10-15%

Operador: Valor medido = 12.5% → PASS

Worker:
  1. Preencher lotes
  2. write('quality.check', check_id, {'measure': 12.5})
  3. execute_kw('quality.check', 'do_measure', [[check_id]])
  4. button_validate

Validacao Cross-Phase (Pipeline Obrigatorio)

A Fase 4 (Recebimento Fisico) e a etapa FINAL de um pipeline sequencial obrigatorio:

Fase 1 (Fiscal) → Fase 2 (Match NF×PO) → Fase 3 (Consolidacao PO) → Fase 4 (Recebimento)

Service: CrossPhaseValidationService

Arquivo: app/recebimento/services/cross_phase_validation_service.py

from app.recebimento.services.cross_phase_validation_service import CrossPhaseValidationService

service = CrossPhaseValidationService()

# Validar 1 picking
phase_status = service.validar_fases_picking(purchase_order_id, origin)
# → PhaseStatus: pode_receber, tipo_liberacao, bloqueio_motivo, contato_resolucao, diagnostico

# Validar batch (lista de pickings, 2 queries max)
results = service.validar_fases_batch(pickings)
# → Dict: {odoo_picking_id: PhaseStatus}

Tipos de Liberacao

Bloqueios Possiveis

REGRA CRITICA: status='aprovado' NAO e pass-through

ValidacaoNfPoDfe.status='aprovado' significa "pronto para consolidar" — a Fase 3 AINDA NAO foi executada. A consolidacao SEMPRE cria um PO Conciliador novo. Pular causa: NF desvinculada, estoque duplicado.

Pontos de Integracao

Lookup Chain

PickingRecebimento.odoo_purchase_order_id
    → ValidacaoNfPoDfe.odoo_po_vinculado_id (ou po_consolidado_id)
        → ValidacaoFiscalDfe.odoo_dfe_id

Indice de Performance

CREATE INDEX idx_validacao_nf_po_po_consolidado
ON validacao_nf_po_dfe (po_consolidado_id)
WHERE po_consolidado_id IS NOT NULL;

Script de migration: scripts/add_index_po_consolidado.py

Pre-requisitos para Processar

1. Validacao cross-phase aprovada (Fases 1→2→3 concluidas)
2. Picking com state='assigned'
3. picking_type_code='incoming'
4. Soma dos lotes == product_uom_qty do move
5. TODOS os quality checks com resultado definido
6. Conexao Odoo funcional

Referencia Cruzada com Outras Skills