ProtheusProduto (STATUS: PARCIAL)

Documentação Técnica

Histórico de Versões

Descrição

Esta biblioteca organiza a integração de produtos do LINX para o Protheus, garantindo captura consistente e envio com validação de retorno.

Capturador

Descrição Conceitual

Permite a captura manual (por lista de chaves) e a captura automática (por agendador de tarefas) dos produtos pendentes de integração, consultando a origem e registrando os itens para processamento assíncrono.

A captura automática segue processamento cronológico (ordenação/paginação por data) para priorizar registros mais antigos e manter continuidade por posição; link conceitual: Processamento cronológico.

Fonte

Origem consultada: view WOSK_SERVICO_ENVIA_PROTHEUS_PRODUTO.

Consulta utilizada na captura automática (WHERE e paginação construídos dinamicamente conforme posição e configuração de limite):

SELECT
    B1_COD,
    B1_DESC,
    B1_TIPO,
    B1_UM,
    B1_LOCPAD,
    B1_GRUPO,
    B1_CONTA,
    B1_CONTRAT,
    ASB1_CEST,
    B1_IPI,
    B1_POSIPI,
    B1_PICMRET,
    B1_PICMENT,
    B1_ORIGEM,
    B1_GRTRIB,
    B1_FECP,
    B1_CCCUSTO,
    B1_PESBRU,
    B1_PESO,
    B1_XPRV1,
    B1_MSBLQL,
    DATA_PARA_TRANSFERENCIA
FROM
    WOSK_SERVICO_ENVIA_PROTHEUS_PRODUTO
WHERE
    DATA_PARA_TRANSFERENCIA >= '<DATA_PARA_TRANSFERENCIA>'
ORDER BY
    DATA_PARA_TRANSFERENCIA ASC
OFFSET
    <OFFSET> ROWS FETCH NEXT <LIMITE> ROWS ONLY

Operações com Dados

• Leitura: consulta a view WOSK_SERVICO_ENVIA_PROTHEUS_PRODUTO para obter o registro atual de produto (com chave B1_COD) e encaminhar para processamento assíncrono.

Fila de Processamento

Descrição Conceitual

A fila recupera um registro pendente e utiliza o conteúdo do registro como base do payload de integração. Em seguida, aplica transformações obrigatórias de padronização e realiza a chamada ao Protheus.

Estruturação de Dados

{
  "B1_COD": "",
  "B1_DESC": "",
  "B1_TIPO": "",
  "B1_UM": "",
  "B1_LOCPAD": "",
  "B1_GRUPO": "",
  "B1_CONTA": "",
  "B1_CONTRAT": "",
  "B1_CEST": "",
  "B1_IPI": "",
  "B1_POSIPI": "",
  "B1_PICMRET": "",
  "B1_PICMENT": "",
  "B1_ORIGEM": "",
  "B1_GRTRIB": "",
  "B1_FECP": "",
  "B1_CCCUSTO": "",
  "B1_PESBRU": "",
  "B1_PESO": "",
  "B1_XPRV1": "",
  "B1_MSBLQL": ""
}

Tratamento de Dados

Antes do envio, os seguintes campos numéricos do payload são padronizados por rotina de normalização numérica: B1_IPI, B1_PICMRET, B1_PICMENT, B1_FECP, B1_PESBRU, B1_PESO, B1_XPRV1. 

Integração com o Protheus

Chamada de integração com o Protheus
- Chamada: Requisição HTTP
- Recurso: produto
- Método HTTP: POST
- Cabeçalhos:
  - tenantId: 01,01SD0001
- Tratamento de retorno:
  - Ausência de resposta: registra erro com mensagem de “não houve resposta” e finaliza o item como falha.
  - Resposta inválida/inesperada: se o retorno não puder ser interpretado como estrutura contendo Mensagem, registra erro de decodificação e finaliza como falha.
  - Indicadores de erro: finaliza como falha quando houver code no retorno ou quando Mensagem for ERRO. Quando disponível, utiliza Mensagem Detalhada como mensagem final.
  - Sucesso: quando não houver indicadores de erro, finaliza como sucesso e persiste o retorno para auditoria.

Tratamento de retorno

Ao final do processamento, o item é atualizado na tabela wosk_queue com o retorno do Protheus (quando existir), a mensagem consolidada e a situação final (sucesso/erro). O tempo de processamento é registrado para acompanhamento operacional.

Encaminhamento em cenário de erro

Quando ocorre erro na integração (ausência de resposta, resposta inválida ou retorno com indicador de falha), o item é finalizado como erro e permanece registrado em wosk_queue com detalhes de mensagem e retorno, permitindo acompanhamento e reprocessamento conforme necessidade operacional.

Notificação

Fluxo do Processo

Critérios de Aceitação