Prooflytics + Quora Ads: атрибуция B2B-лидов из intent-based рекламы до закрытой сделки

Пользователь кликает на Quora рекламу
  -> URL: yoursite.com/demo?qclid=AaBbCcDd...
  -> Pixel js + кастомный код сохраняют qclid в cookie + localStorage

Форма заявки
  -> qclid передаётся как hidden field
  -> Kommo/HubSpot: сделка создана, qclid сохранён в custom field

Prooflytics
  -> Периодически читает статусы сделок из CRM
  -> При Closed Won: находит сделки с qclid
  -> Quora Conversions API: event "purchase" с qclid
  -> Quora отчитывает реальный CPO

// Добавить на все landing pages
(function() {
    var params = new URLSearchParams(window.location.search);
    var qclid  = params.get("qclid");
    if (qclid) {
        localStorage.setItem("qclid", qclid);
        document.cookie = "qclid=" + qclid + ";path=/;max-age=2592000";  // 30 дней
    }
})();

// При отправке формы
function getQclid() {
    var params = new URLSearchParams(window.location.search);
    return params.get("qclid") || localStorage.getItem("qclid") || getCookie("qclid") || "";
}

function getCookie(name) {
    var match = document.cookie.match(new RegExp("(^| )" + name + "=([^;]+)"));
    return match ? match[2] : "";
}

// В форму заявки добавить hidden input
// <input type="hidden" name="qclid" id="field_qclid" />
document.getElementById("field_qclid").value = getQclid();

import requests, os, hashlib, time
from flask import Flask, request, jsonify

app = Flask(__name__)

QUORA_PIXEL_ID    = os.environ["QUORA_PIXEL_ID"]
QUORA_ACCESS_TOKEN = os.environ["QUORA_ACCESS_TOKEN"]
KOMMO_SUBDOMAIN   = os.environ["KOMMO_SUBDOMAIN"]
KOMMO_TOKEN       = os.environ["KOMMO_ACCESS_TOKEN"]
KOMMO_CF_QCLID    = int(os.environ["KOMMO_CF_QCLID_ID"])
CLOSED_WON_ID     = int(os.environ["KOMMO_CLOSED_WON_ID"])

QUORA_API_BASE = "https://api.quora.com/conversion/pixel/log"
KOMMO_BASE     = f"https://{KOMMO_SUBDOMAIN}.kommo.com/api/v4"
KOMMO_HDR      = {"Authorization": f"Bearer {KOMMO_TOKEN}", "Content-Type": "application/json"}

def sha256_email(email: str) -> str:
    return hashlib.sha256(email.strip().lower().encode()).hexdigest()

def get_lead_qclid_and_email(lead_id: int) -> tuple[str, str]:
    r = requests.get(
        f"{KOMMO_BASE}/leads/{lead_id}",
        headers=KOMMO_HDR,
        params={"with": "contacts,custom_fields_values"},
    )
    lead = r.json()
    qclid = ""
    for cf in lead.get("custom_fields_values", []) or []:
        if cf.get("field_id") == KOMMO_CF_QCLID:
            vals = cf.get("values", [])
            if vals:
                qclid = vals[0].get("value", "")
                break

    email = ""
    contacts = lead.get("_embedded", {}).get("contacts", [])
    if contacts:
        rc = requests.get(
            f"{KOMMO_BASE}/contacts/{contacts[0]['id']}",
            headers=KOMMO_HDR,
            params={"with": "custom_fields_values"},
        )
        for cf in rc.json().get("custom_fields_values", []) or []:
            if cf.get("field_code") == "EMAIL":
                vals = cf.get("values", [])
                if vals:
                    email = vals[0].get("value", "")
                    break

    return qclid, email

def send_quora_conversion(qclid: str, email: str, revenue: float):
    payload = {
        "pixel_id":   QUORA_PIXEL_ID,
        "event_name": "Purchase",
        "event_id":   f"deal_won_{qclid}_{int(time.time())}",
        "event_time": int(time.time()),
        "user_data": {
            "email":   [sha256_email(email)] if email else [],
            "click_id": qclid,
        },
        "custom_data": {
            "currency": "USD",
            "value":    round(revenue, 2),
        },
    }
    r = requests.post(
        QUORA_API_BASE,
        headers={"Authorization": f"Bearer {QUORA_ACCESS_TOKEN}", "Content-Type": "application/json"},
        json=[payload],
    )
    return r.status_code, r.text

@app.route("/webhooks/kommo", methods=["POST"])
def kommo_webhook():
    data = request.json or {}
    for lead_data in data.get("leads", {}).get("status", []):
        lead_id    = lead_data.get("id")
        new_status = lead_data.get("status_id")
        if new_status != CLOSED_WON_ID:
            continue

        r_lead = requests.get(f"{KOMMO_BASE}/leads/{lead_id}", headers=KOMMO_HDR)
        revenue = float(r_lead.json().get("price") or 0)

        qclid, email = get_lead_qclid_and_email(lead_id)
        if not qclid:
            continue  # нет Quora-клика - не отправляем

        status, resp = send_quora_conversion(qclid, email, revenue)
        requests.post(
            f"{KOMMO_BASE}/notes",
            headers=KOMMO_HDR,
            json=[{
                "entity_id":   lead_id,
                "entity_type": "leads",
                "note_type":   "common",
                "params":      {"text": f"Quora Conversions API: event Purchase отправлен. Status: {status}. qclid: {qclid}"},
            }],
        )

    return jsonify({"status": "ok"}), 200