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
  • Capturador Manual / Automático
  • Queue
• Fluxo do Processo
• Critérios de Aceitação

Histórico de Versões

Descrição Geral dos Processos

Esta biblioteca organiza a integração de cadastros de clientes do LINX para o Protheus, garantindo que cada cliente seja identificado, preparado e encaminhado para envio.

O processo separa duas responsabilidades: um componente de captura, que localiza os registros elegíveis e os coloca em uma fila, e um componente de processamento, que consome a fila e executa a integração com o Protheus.

Ao longo do fluxo, o sistema registra o andamento e o resultado de cada item, permitindo rastreabilidade, reprocessamento e notificação de falhas quando necessário.

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

Capturador Manual / Automático

Descrição Conceitual

Descrição do fluxo

Entrada de dados (consulta completa)

A origem dos dados é a view WOSK_SERVICO_ENVIA_PROTHEUS_CLIENTES_FULL, consultada com a projeção 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>'

Operações com dados (Banco de Dados)

Resultado do processamento

Ao final, os clientes elegíveis ficam registrados na fila para integração, e o controle de continuidade permite que o processo retome sem perder a referência de 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 datas), o fluxo consulta a mesma tabela filtrando por ação e, quando aplicável, por token ou chave.

SELECT
    /*+ SQL_BIG_RESULT */
    /*+ SQL_NO_CACHE */
    `token`,
    `acao`,
    `chave`,
    `conteudo`,
    `retorno`,
    `requisicao`,
    `mensagem`,
    `tempo`,
    `situacao`,
    `data_adicionado`,
    `data`
FROM
    `<BANCO_INTEGRADOR>`.`wosk_queue`
WHERE
    `acao` = '<PROCESSO>'
    -- filtros opcionais:
    -- AND `token` = '<TOKEN>'
    -- AND `chave` = '<A1_LOJA-A1_COD>'
ORDER BY
    `data_adicionado` ASC,
    `data` ASC,
    `chave` ASC
LIMIT 1

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:

{
    "A1_COD": "157612267",
    "A1_LOJA": "01",
  "A1_COD": "000123"03",
    "A1_CGC": "99999999999"15763336703",
    "A1_NOME": "CLIENTETESTE",
    SEM"A1_PESSOA": ACENTO""F",
    "A1_NREDUZ": "CLIENTE"TESTE",
    "A1_END": "RUA EXEMPLO"SILVIA POZZANO, 2820",
    "A1_BAIRRO": "CENTRO"RECREIO DOS BANDEIRANTES",
    "A1_COMPLEM": "B1 AP 811,",
    "A1_TIPO": "F",
    "A1_EST": "RJ",
    "A1_COD_MUN": "02257",
    "A1_CEP": "00000000"22790622",
    "A1_DDI": "",
    "A1_DDD": "99",
    "A1_TEL": "993207988",
    "A1_CONTATO": "TESTE",
    "A1_PFISICA": "",
    "A1_INSCR": "ISENTO",
    "A1_INSCRM": "",
    "A1_DTNASC": "06/05/9999",
    "A1_EMAIL": "cliente@exemplo.com"TESTE",
    "A1_PAIS": "105",
    "A1_CODPAIS": "00055"01099",
    "A1_CONTA": "220301040199",
    "A1_CONTRIB": "2",
    "A1_TPESSOA": "",
    "A1_SUFRAMA": "",
    "A1_CALCSUF": "",
    "A1_CODMUN": "",
    "A1_MSBLQL": "2"
}