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
  • Monitor
  • Queue
• Fluxo do Processo
• Critérios de Aceitação

Histórico de Versões

Descrição Geral dos Processos

ElaEste separaprocesso realiza a integração trabalho em duas etapas: uma etapacompleta de captura (Monitor) e outracadastros de processamentoclientes, assíncronogarantindo (Queue).

Na prática, o Monitor localizaque os dados estejam consistentes antes do clienteenvio eme que o acompanhamento do processamento seja rastreável.

A captura de registros é feita de forma periódica (cron), a partir de uma visão de serviçodados disponível no ambiente de origem, e criaos (ouitens atualiza)capturados umsão itemencaminhados napara processamento assíncrono por fila.

Em seguida, a fila paraprocessa integração. Depois, a Queue consome essecada item, preparaaplica ajustes de padronização de texto, envia ao destino e atualiza o payloadstatus finaldo eprocessamento, realizapermitindo o envio para o Protheus, registrando o resultado parareprocessamento, auditoria e acompanhamento.

O objetivo do fluxo é garantir que o envio ocorra de forma controlada, com rastreabilidade de erros e possibilidade de reprocessamento, sem depender de uma execuçnotificação únicaquando ehouver sincrona.falhas.

Monitor

Conceito:Descrição MonitorConceitual

Processo:

Descrição
Classe:do WOSK\ProtheusClienteFull\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}<A1_LOJA>'
    AND A1_COD = '{A1_COD}<A1_COD>';

tenantId: "01,01SD0001"

- Resposta esperada: array

Operações com Mensagemdados e opcionalmente Mensagem Detalhada.

5) Decisão(Banco de situação (pós-envio):
- Sucesso: situacao = 2 (quando não há code e Mensagem != "ERRO").
- Erro: situacao = 4 (quando Mensagem == "ERRO" ou quando existe code na resposta, ou exceção no processamento).

6) Ações e persistências (por situação):

Dados)

• QuandoLeitura: sucesso (situacao = 2): chama setProtheusClienteIntegrado(chave, true). Alémconsumo de atualizaritens oda statustabela wosk_queue (banco do item, o fluxo padrão registra auditoria de integração em OSK_LOG_INTEGRACAO_PROTHEUS.
• Quando erro (situacao = 4): tenta capturar o mesmo cliente no processo ProtheusClientePadrao (Monitor correspondente) e verifica se um item foi criado em wosk_queue. Se o item do ProtheusClientePadrao existir, esta fila pode marcar o item atual para remoção e chamar setProtheusExcluir(["ProtheusClienteFull"], "chave", chave)integrador).
• Atualização: gravação do retorno, mensagem e status final dona item:tabela wosk_queue.
• Log de falhas: quando nãoaplicável, for removido, atualiza wosk_queue com retorno, mensagem, dumpregistro de requisiçãodetalhes ede tempoerro total.de banco na tabela wosk_queue_log.

Resultado do processamento

• RegraSucesso: o cliente é considerado integrado e o item é finalizado com status de deduplicaçsucesso.
• Erro: o item é finalizado com status de erro e mensagem explicativa; o processo pode acionar notificação (pré-inserte/ou naevitar fila):
  Ao inserir itens com situacao = 0, o mecanismo padrão da Queue compara o conteudoduplicidade com o quefluxo já existe para a mesma acao e chave. Se o conteúdo for igual, a inserção pode ser ignorada. O campo DATA_PARA_TRANSFERENCIA é desconsiderado nessa comparação, evitando reprocessos apenas por variação de data/hora.
  
  Tabelas envolvidas (persistência e auditoria):
  • wosk_queue: fila principal do processo (acao = ProtheusClienteFull)
  • wosk_queue_log: log de falhas de SQL durante escrita de auditoria
  • OSK_LOG_INTEGRACAO_PROTHEUS: auditoria de integração para ações que casam com /Protheus/padrão.

  Notificação de erros (consolidação via query):
  A rotina Queue::notificar() consulta os erros deste processo diretamente na tabela wosk_queue e envia e-mail para destinatários configurados.

  SELECT
      `token`,
      `acao`,
      `chave`,
      `data_adicionado`,
      `data`,
      `mensagem` AS 'ERRO'
  FROM `{$this->bancoIntegrador}`.`wosk_queue`
  WHERE `acao` = 'ProtheusClienteFull'
    AND `situacao` = 4
  ORDER BY `data` ASC

  Fluxo do Processo

  Encadeamento obrigatório: Monitor → Queue.

  1. Monitor (cron/on-demand): recebe a chave A1_LOJA-A1_COD, consulta a view WOSK_SERVICO_ENVIA_PROTHEUS_CLIENTES_FULL e grava/atualiza o item na tabela wosk_queue com situacao = 0.
  2. Queue (cron/worker): seleciona itens pendentes (situacao = 0), marca como em envio (situacao = 1), monta payload A1_*, envia para o Protheus e grava o resultado (situacao = 2 ou 4).
  3. Notificação: erros (situacao = 4) podem ser consolidados e enviados por e-mail via Queue::notificar().
  4. Fallback: em erro, pode acionar captura do mesmo cliente em ProtheusClientePadrao e remover o item desta fila quando aplicável.

  
  

  Critérios de Aceitação

        =omesmo

  Processo	Subprocesso	Descrição	Situação esperada
  Monitor	Captura	Quando acionado por cron, deve obter o registro do cliente na visão de origem e gerar uma chave	Aoúnica informarno formato A1_LOJA-A1_COD, o Monitor deve montar o WHERE dinamicamente e consultar a view de serviço..	Registro encontradoidentificado →e itempronto criado/atualizadopara encaminhamento.
  Monitor	Enfileiramento	O registro capturado deve ser enfileirado para processamento assíncrono, com status inicial e agendamento baseado em wosk_queueDATA_PARA_TRANSFERENCIA com(conceito situacaocronológico).	Item 0.persistido em wosk_queue e ordenado/agendado conforme a data.
  Queue	Envio ao ProtheusProcessamento	OAo workerconsumir o item, deve mapear dados para A1_*, aplicar normalizações e executar POST no serviçpadronização de cliente.texto e enviar ao destino; em seguida, deve atualizar o resultado na fila.	RespostaFila OKatualizada →com situacaostatus =de 2sucesso ou erro e auditoriamensagem registrada.correspondente, mantendo rastreabilidade.
  Queue	TratamentoControle de erroduplicidade	Quando houver falha deno integraçãenvio e o mesmo cliente já existir no fluxo padrão, o itemregistro do fluxo Full deve permanecerser rastreável e elegíveldescartado para notificação.evitar processamento duplicado.	situacaoSem = 4, mensagem registrada e opçãoduplicidade de fallbackregistros na fila para ProtheusClientePadrao.
  Notificação	Consolidação	Listar erros pendentes do processo e enviar e-mail aos destinatários configurados.	Relatório enviado com chave, datas e mensagem de erro normalizada.cliente.