BUC - Processa Disparo: Abandono de Oferta

Visão Geral

Este fluxo é responsável pelo disparo ativo de mensagens de recuperação para usuários que abandonaram uma oferta. Ele consome dados da fila RabbitMQ, realiza simulações em tempo real para múltiplos produtos (Crédito Novo, Cartão Consignado, etc.), garante a governança no HubSpot (via subflows de contato/negócio) e realiza o disparo final através da API da Colmeia.

Objetivo

• Recuperação de Conversão: Retomar o contato com leads com oportunidade que abandonaram o carrinho.
• Personalização Dinâmica: Simular as melhores condições de oferta disponíveis no momento do disparo.
• Sincronização de CRM: Manter o HubSpot atualizado com os dados da campanha e o ID do negócio.
• Valor gerado: Aumento direto no volume de negócios criados.

Diagrama de Fluxo

graph TD
    1["1-rabbitmq---start"] --> 2["2-execution-data---execution-data"]
    2 --> 3["3-flow-variable---set-initial-data"]
    3 --> 4["4-execute-workflow---verificar-bloqueio"]
    4 --> 5{"5-conditional---if-prevent-deal-creation"}
    
    5 -- "False" --> 6{"6-switch---switch-offers"}
    5 -- "True" --> End((Fim))
    
    6 --> 7a["7a-http-request---generate-credito-novo-simulation"]
    6 --> 7b["7b-http-request---generate-cartao-consignado-simulation"]
    6 --> 7c["7c-http-request---generate-cartao-beneficio-simulation"]
    6 --> 7d["7d-http-request---generate-emprestimo-clt-simulation"]
    6 --> 7e["7e-http-request---generate-port-troco-max"]

    7a --> 8a["8a-flow-variable---set-opportunity-type"]
    7b --> 8b["8b-flow-variable---set-opportunity-type1"]
    7c --> 8c["8c-flow-variable---set-opportunity-type2"]
    7d --> 8d["8d-flow-variable---set-opportunity-type3"]
    7e --> 8e["8e-flow-variable---set-opportunity-type4"]

    8a & 8b & 8c & 8d & 8e --> 9c["9c-flow-variable---add-content-to-array"]
    9c --> 10["10-flow-variable---set-content"]
    10 --> 11["11-code---format-offer-v2"]
    11 --> 12["12-execute-workflow---subworkflow-id-covenant"]
    12 --> 13["13-flow-variable---create-tag-campaign"]
    13 --> 14{"14-conditional---if-valor-liberado-existe"}
    
    14 -- "Sim" --> 15["15-crypto---set-correlation-id"]
    14 -- "Não" --> End
    
    15 --> 16["16-flow-variable---set-campaign-trigger-v2"]
    16 --> 17["17-mongo---create-campaign-trigger-v2"]
    17 --> 18["18-flow-variable---split-ab-template"]
    18 --> 19["19-flow-variable---set-user-app-data"]
    19 --> 20["20-code---modelar-user-unifiedlead"]
    20 --> 21["21-flow-variable---set-unified-lead"]
    21 --> 22["22-code---atualiza-opportunities-campaign-values"]
    22 --> 23["23-execute-workflow---modelar-dados-criar-negocio"]
    23 --> 24["24-flow-variable---definir-source"]
    24 --> 25["25-jump---criar-negocio-e-contato-check"]
    
    25 --> 26{"26-conditional---se-deal-id-existe"}
    
    26 -- "Sim" --> 27["27-flow-variable---set-campaign-trigger-v2-update"]
    27 --> 28["28-mongo---find-deal-id-on-campaign-trigger"]
    28 --> 29["29-flow-variable---set-update-campaign-trigger-v2"]
    29 --> 30["30-mongo---add-deal-id-on-campaign-trigger"]
    30 --> 31["31-request---send-message1"]
    
    26 -- "Não" --> 31

Variáveis do Fluxo

Variáveis de Entrada (RabbitMQ)

Variáveis Internas

Fluxo Detalhado

Fase 1: Simulação Dinâmica de Ofertas

O fluxo analisa qual produto o lead abandonou e realiza uma chamada de API de simulação em tempo real (Nós 7a-7e) para obter os valores atualizados de margem e liberação.

Fase 2: Enriquecimento e Governança

Após obter a oferta, o fluxo gera uma tag_campaign única e um correlation_id. Ele interage com o MongoDB para registrar o disparo (Nó 17) e prepara para atualizar os dados na Unified Lead.

Fase 3: Integração HubSpot e Envio

O fluxo chama o subflow de Criar Negócio e Contato Check (Nó 25). Caso um negócio antigo seja identificado, ele atualiza os registros no MongoDB para manter o vínculo entre o disparo e o Deal ID do HubSpot. Por fim, dispara o template de mensagem via API Colmeia (Nó 31).

Dependências Externas

• MongoDB: Coleção campaign_triggers_v2.
• API Simulation: Endpoints de simulação de produtos.
• API Colmeia: Disparo de campanhas via Whatsapp.
• Subflows HubSpot: Governança de contatos e negócios.

Changelog