Добавить повторный лид

<script src="https://ajax.googleapis.com/ajax/libs/jquery/3.3.1/jquery.min.js"></script>
<script>
$(document).ready(function() {
    $('#form_to_crm').on( 'submit', function(el) {//event submit form
        el.preventDefault();//the default action of the event will not be triggered
        var formData = $(this).serialize();
        $.ajax({
            'method': 'POST',
            'dataType': 'json',
            'url': '/form', // маршрут обработчика на Flask
            'data': formData,
            success: function(data){//success callback
                alert(data.message);
            }
        });
    });
});
</script>

<form id="form_to_crm">
    <input type="text" name="NAME" placeholder="Name" required>
    <input type="text" name="LAST_NAME" placeholder="Last name">
    <input type="text" name="PHONE" placeholder="Phone">
    <input type="text" name="EMAIL" placeholder="E-mail">
    <input type="submit" value="Submit">
</form>

<script src="https://ajax.googleapis.com/ajax/libs/jquery/3.3.1/jquery.min.js"></script>
<script>
$(document).ready(function() {
    $('#form_to_crm').on( 'submit', function(el) {//event submit form
        el.preventDefault();//the default action of the event will not be triggered
        var formData = $(this).serialize();
        $.ajax({
            'method': 'POST',
            'dataType': 'json',
            'url': 'form.php', // файл для сохранения заполненных форм
            'data': formData,
            success: function(data){//success callback
                alert(data.message);
            }
        });
    });
});
</script>

<form id="form_to_crm">
    <input type="text" name="NAME" placeholder="Name" required>
    <input type="text" name="LAST_NAME" placeholder="Last name">
    <input type="text" name="PHONE" placeholder="Phone">
    <input type="text" name="EMAIL" placeholder="E-mail">
    <input type="submit" value="Submit">
</form>

s_name = request.form.get("NAME", "")
s_last_name = request.form.get("LAST_NAME", "")
s_phone = request.form.get("PHONE", "")
s_email = request.form.get("EMAIL", "")

$sName = htmlspecialchars($_POST["NAME"]);
$sLastName = htmlspecialchars($_POST["LAST_NAME"]);
$sPhone = htmlspecialchars($_POST["PHONE"]);
$sEmail = htmlspecialchars($_POST["EMAIL"]);

ar_fields = {
    "TITLE": "From the site: " + " ".join([s_name, s_last_name]),
    "NAME": s_name or "Empty name",
    "LAST_NAME": s_last_name,
    "PHONE": [{"VALUE": s_phone, "VALUE_TYPE": "HOME"}] if s_phone else [],
    "EMAIL": [{"VALUE": s_email, "VALUE_TYPE": "HOME"}] if s_email else [],
}

$arFields = [
    'TITLE' => 'From the site: ' . implode(' ', [$sName, $sLastName]),
    'NAME' => (!empty($sName)) ? $sName : 'Empty name',
    'LAST_NAME' => $sLastName,
    'PHONE' => (!empty($sPhone)) ? array(array('VALUE' => $sPhone, 'VALUE_TYPE' => 'HOME')) : array(),
    'EMAIL' => (!empty($sEmail)) ? array(array('VALUE' => $sEmail, 'VALUE_TYPE' => 'HOME')) : array()
];

ar_lead_duplicate = []

if s_phone:
    result_duplicate = client.crm.duplicate.findbycomm(
        type="PHONE", values=[s_phone], entity_type="LEAD",
    ).result
    # если совпадений нет, метод возвращает пустой массив, а не объект,
    # поэтому приводим результат к словарю перед обращением по ключу
    found = (result_duplicate or {}).get("LEAD")
    if found:
        ar_lead_duplicate += found

$arLeadDuplicate = [];

if (!empty($sPhone)) {
    $result = $sb->getCRMScope()->duplicate()->findByPhone(
        [$sPhone],
        \Bitrix24\SDK\Services\CRM\Duplicates\Service\EntityType::Lead
    )->getCoreResponse()->getResponseData()->getResult();
    if (!empty($result['LEAD'])) {
        $arLeadDuplicate = array_merge($arLeadDuplicate, $result['LEAD']);
    }
}

if s_email:
    result_duplicate = client.crm.duplicate.findbycomm(
        type="EMAIL", values=[s_email], entity_type="LEAD",
    ).result
    found = (result_duplicate or {}).get("LEAD")
    if found:
        ar_lead_duplicate += found

if (!empty($sEmail)) {
    $result = $sb->getCRMScope()->duplicate()->findByEmail(
        [$sEmail],
        \Bitrix24\SDK\Services\CRM\Duplicates\Service\EntityType::Lead
    )->getCoreResponse()->getResponseData()->getResult();
    if (!empty($result['LEAD'])) {
        $arLeadDuplicate = array_merge($arLeadDuplicate, $result['LEAD']);
    }
}

if ar_lead_duplicate:
    ar_duplicate_lead = client.crm.lead.list(
        filter={"=ID": ar_lead_duplicate, "STATUS_ID": "CONVERTED"},
        select=["ID", "COMPANY_ID", "CONTACT_ID"],
    ).as_list().result

    company = next((r["COMPANY_ID"] for r in ar_duplicate_lead if int(r["COMPANY_ID"] or 0) > 0), None)
    contact = next((r["CONTACT_ID"] for r in ar_duplicate_lead if int(r["CONTACT_ID"] or 0) > 0), None)
    if company:
        ar_fields["COMPANY_ID"] = company
    if contact:
        ar_fields["CONTACT_ID"] = contact

if (!empty($arLeadDuplicate)) {
    $arDuplicateLead = [];
    foreach ($sb->getCRMScope()->lead()->batch->list(
        order: [],
        filter: ['=ID' => $arLeadDuplicate, 'STATUS_ID' => 'CONVERTED'],
        select: ['ID', 'COMPANY_ID', 'CONTACT_ID']
    ) as $lead) {
        $arDuplicateLead[] = $lead;
    }

    foreach ($arDuplicateLead as $lead) {
        if ($lead->COMPANY_ID > 0 && empty($arFields['COMPANY_ID'])) {
            $arFields['COMPANY_ID'] = $lead->COMPANY_ID;
        }
        if ($lead->CONTACT_ID > 0 && empty($arFields['CONTACT_ID'])) {
            $arFields['CONTACT_ID'] = $lead->CONTACT_ID;
        }
    }
}

client.crm.lead.add(fields=ar_fields)

$sb->getCRMScope()->lead()->add($arFields);

lead = client.crm.lead.get(bitrix_id=3289).result

$lead = $sb->getCRMScope()->lead()->get(3289)->lead();

# pip install b24pysdk flask
from flask import Flask, request, jsonify
from b24pysdk import BitrixWebhook, Client

app = Flask(__name__)

client = Client(BitrixWebhook(
    domain="your-domain.bitrix24.ru",
    webhook_token="USER_ID/TOKEN",  # только user_id/token, без https://
))


def find_lead_duplicates(comm_type: str, value: str) -> list:
    """Возвращает идентификаторы лидов с совпадающим телефоном или почтой.

    Если совпадений нет, метод возвращает пустой массив, а не объект,
    поэтому приводим результат к словарю перед обращением по ключу.
    """
    result = client.crm.duplicate.findbycomm(
        type=comm_type, values=[value], entity_type="LEAD",
    ).result
    return (result or {}).get("LEAD") or []


@app.route("/form", methods=["POST"])
def handle_form():
    s_name = request.form.get("NAME", "")
    s_last_name = request.form.get("LAST_NAME", "")
    s_phone = request.form.get("PHONE", "")
    s_email = request.form.get("EMAIL", "")

    ar_fields = {
        "TITLE": "From the site: " + " ".join([s_name, s_last_name]),
        "NAME": s_name or "Empty name",
        "LAST_NAME": s_last_name,
        "PHONE": [{"VALUE": s_phone, "VALUE_TYPE": "HOME"}] if s_phone else [],
        "EMAIL": [{"VALUE": s_email, "VALUE_TYPE": "HOME"}] if s_email else [],
    }

    ar_lead_duplicate = []
    if s_phone:  # поиск дубликатов по телефону
        ar_lead_duplicate += find_lead_duplicates("PHONE", s_phone)

    if s_email:  # поиск дубликатов по email
        ar_lead_duplicate += find_lead_duplicates("EMAIL", s_email)

    if ar_lead_duplicate:  # получение дубликата лида с полями связанных контакта и компании
        ar_duplicate_lead = client.crm.lead.list(
            filter={"=ID": ar_lead_duplicate, "STATUS_ID": "CONVERTED"},
            select=["ID", "COMPANY_ID", "CONTACT_ID"],
        ).as_list().result
        company = next((r["COMPANY_ID"] for r in ar_duplicate_lead if int(r["COMPANY_ID"] or 0) > 0), None)
        contact = next((r["CONTACT_ID"] for r in ar_duplicate_lead if int(r["CONTACT_ID"] or 0) > 0), None)
        if company:
            ar_fields["COMPANY_ID"] = company
        if contact:
            ar_fields["CONTACT_ID"] = contact

    try:
        client.crm.lead.add(fields=ar_fields)  # создание повторного лида
        return jsonify({"message": "Lead add"})
    except Exception as e:
        return jsonify({"message": f"Lead not added: {e}"})

<?php
// composer require bitrix24/b24phpsdk:"^3.0"
require_once 'vendor/autoload.php';

use Bitrix24\SDK\Services\ServiceBuilderFactory;
use Bitrix24\SDK\Services\CRM\Duplicates\Service\EntityType;
use Symfony\Component\EventDispatcher\EventDispatcher;
use Monolog\Logger;
use Monolog\Handler\StreamHandler;

$log = new Logger('b24');
$log->pushHandler(new StreamHandler('php://stdout'));

$sb = (new ServiceBuilderFactory(new EventDispatcher(), $log))
    ->initFromWebhook('https://your-domain.bitrix24.ru/rest/USER_ID/TOKEN/');

$sName = htmlspecialchars($_POST["NAME"]);
$sLastName = htmlspecialchars($_POST["LAST_NAME"]);
$sPhone = htmlspecialchars($_POST["PHONE"]);
$sEmail = htmlspecialchars($_POST["EMAIL"]);

$arFields = [
    'TITLE' => 'From the site: ' . implode(' ', [$sName, $sLastName]),
    'NAME' => (!empty($sName)) ? $sName : 'Empty name',
    'LAST_NAME' => $sLastName,
    'PHONE' => (!empty($sPhone)) ? array(array('VALUE' => $sPhone, 'VALUE_TYPE' => 'HOME')) : array(),
    'EMAIL' => (!empty($sEmail)) ? array(array('VALUE' => $sEmail, 'VALUE_TYPE' => 'HOME')) : array()
];

$arLeadDuplicate = [];
if (!empty($sPhone)) { // поиск дубликатов по телефону
    $r = $sb->getCRMScope()->duplicate()->findByPhone([$sPhone], EntityType::Lead)
        ->getCoreResponse()->getResponseData()->getResult();
    if (!empty($r['LEAD'])) {
        $arLeadDuplicate = array_merge($arLeadDuplicate, $r['LEAD']);
    }
}

if (!empty($sEmail)) { // поиск дубликатов по email
    $r = $sb->getCRMScope()->duplicate()->findByEmail([$sEmail], EntityType::Lead)
        ->getCoreResponse()->getResponseData()->getResult();
    if (!empty($r['LEAD'])) {
        $arLeadDuplicate = array_merge($arLeadDuplicate, $r['LEAD']);
    }
}

if (!empty($arLeadDuplicate)) { // получение дубликата лида с полями связанных контакта и компании
    foreach ($sb->getCRMScope()->lead()->batch->list(
        order: [],
        filter: ['=ID' => $arLeadDuplicate, 'STATUS_ID' => 'CONVERTED'],
        select: ['ID', 'COMPANY_ID', 'CONTACT_ID']
    ) as $lead) {
        if ($lead->COMPANY_ID > 0 && empty($arFields['COMPANY_ID'])) {
            $arFields['COMPANY_ID'] = $lead->COMPANY_ID;
        }
        if ($lead->CONTACT_ID > 0 && empty($arFields['CONTACT_ID'])) {
            $arFields['CONTACT_ID'] = $lead->CONTACT_ID;
        }
    }
}

try {
    $sb->getCRMScope()->lead()->add($arFields); // создание повторного лида
    echo json_encode(['message' => 'Lead add']);
} catch (\Throwable $e) {
    echo json_encode(['message' => 'Lead not added: ' . $e->getMessage()]);
}