ProtheusClienteFull (STATUS: PARCIAL)

Documentação Técnica

Sumário

• Documentação Técnica
  
• Sumário
• Histórico de Versões
• Descrição Geral dos Processos
  • MonitorCapturador Manual / Automático
  • Queue
• Fluxo do Processo
• Critérios de Aceitação

Histórico de Versões

Descrição Geral dos Processos

EsteEsta processobiblioteca realizaorganiza a integração completa de cadastros de clientes,clientes do LINX para o Protheus, garantindo que oscada dadoscliente estejamseja consistentesidentificado, antes do enviopreparado e queencaminhado opara acompanhamentoenvio.

O doprocesso processamentosepara sejaduas rastreável.

Aum capturacomponente de captura, que localiza os registros é feita de forma periódica (cron), a partir de uma visão de dados disponível no ambiente de origem,elegíveis e os itenscoloca capturadosem sãouma encaminhadosfila, parae processamentoum assíncronocomponente porde fila.

Emque seguida,consome a fila processae executa a integração com o Protheus.

Ao longo do fluxo, o sistema registra o andamento e o resultado de cada item, aplica ajustes de padronização de texto, envia ao destino e atualiza o status do processamento, permitindo reprocessamento,rastreabilidade, auditoriareprocessamento e notificação de falhas quando houvernecessário.

O falhas.objetivo é manter consistência no envio e transparência no acompanhamento, com dados preparados no formato esperado pelo destino.

MonitorCapturador Manual / Automático

Descrição Conceitual

Descrição do fluxo

Entrada de dados (query)consulta completa)

A entradaorigem dos dados é realizada via query sobre a visãoview WOSK_SERVICO_ENVIA_PROTHEUS_CLIENTES_FULL., O WHERE é construído dinamicamente de acordoconsultada com a chaveprojeção recebida.abaixo. O filtro por loja e código do cliente é acrescentado dinamicamente durante o fluxo.

SELECT
    A1_COD,
    A1_LOJA,
    CGC_CPF,
    NOME,
    PESSOA,
    NOME_REDUZ,
    ENDERECO,
    BAIRRO,
    COMPLEMENTO,
    TIPO,
    UF,
    COD_MUNICIPIO_IBGE,
    CEP,
    DDI,
    DDD,
    TELEFONE,
    CONTATO,
    A1_PFISICA,
    A1_INSCR,
    INSC_MUNICIPAL,
    DATA_NASC,
    EMAIL,
    COD_PAIS_SISCOMEX,
    COD_PAIS_BC,
    A1_CONTA,
    A1_CONTRIB,
    A1_TPESSOA,
    A1_SUFRAMA,
    A1_CALCSUF,
    A1_CODMUN,
    STATUS,
    DATA_PARA_TRANSFERENCIA
FROM
    WOSK_SERVICO_ENVIA_PROTHEUS_CLIENTES_FULL
WHERE
    A1_LOJA = '<A1_LOJA>'
    AND A1_COD = '<A1_COD>';

Reestruturação e alteração de dados

Operações com dados (Banco de Dados)

Resultado do processamento

Ao final, oos registroclientes ficaelegíveis disponívelficam registrados na fila para processamentointegração, assíncrono,e iniciadoo com statuscontrole de aguardandocontinuidade integraçãpermite que o eprocesso dataretome desem perder a referência para ordem de processamento.posição quando aplicável.

Queue

Descrição Conceitual

Descrição do fluxo

Entrada de dados (consultas)

A seleção de itens pendentes ocorre na tabela wosk_queue. O fluxo pode aplicar uma condição adicional de atraso (comparando a coluna data) para evitar processar itens recém-atualizados.

SELECT
    /*+ SQL_BIG_RESULT */
    /*+ SQL_NO_CACHE */
    `token`
FROM
    `<BANCO_INTEGRADOR>`.`wosk_queue`
WHERE
    `acao` = '<PROCESSO>'
    AND `situacao` = 0
    -- opcional (atraso configurável):
    -- AND `data` <= '<DATA_LIMITE>'
ORDER BY
    `data_adicionado` ASC

Para obter os detalhes do item (conteúdo, retorno, mensagem e detalhes de retorno.

SELECT
    evitar/*+ duplicidade.

Reestruturação e alteração de dados

O conteúdo do item é convertido do padrão de origem (campos mais descritivos) para o padrão esperado pelo Protheus (campos A1_*). A seguir está o mapeamento de campos aplicado:

Após o mapeamento, são aplicadas as seguintes alterações no payload:

Chamada de integração com o Protheus

Exemplo de payload enviado (valores ilustrativos):

{
  "A1_LOJA": "01",
  "A1_COD": "000123",
  "A1_CGC": "99999999999",
  "A1_NOME": "CLIENTE SEM ACENTO",
  "A1_NREDUZ": "CLIENTE",
  "A1_END": "RUA EXEMPLO",
  "A1_BAIRRO": "CENTRO",
  "A1_EST": "RJ",
  "A1_CEP": "00000000",
  "A1_EMAIL": "cliente@exemplo.com",
  "A1_CODPAIS": "00055"
}

Tratamento de retorno

Encaminhamento em cenário de erro

Operações com dados (Banco de Dados)

Notificação de erros

Resultado do processamento

Fluxo do Processo

Critérios de Aceitação