Добавить дело в новый лид или сделку в зависимости от режима CRM

<form id="form_to_crm">
    <!-- Имя (обязательное поле) -->
    <input type="text" name="NAME" placeholder="Имя" required>
    <!-- Фамилия -->
    <input type="text" name="LAST_NAME" placeholder="Фамилия">
    <!-- Название компании -->
    <input type="text" name="COMPANY_TITLE" placeholder="Название компании">
    <!-- Email -->
    <input type="text" name="EMAIL" placeholder="Почта">
    <!-- Телефон -->
    <input type="text" name="PHONE" placeholder="Телефон">
    <!-- Кнопка отправки -->
    <input type="submit" value="Отправить">
</form>

<!-- Подключаем jQuery для AJAX-запроса -->
<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) {
            el.preventDefault(); // Отменяем стандартную отправку формы
            var formData = $(this).serialize(); // Собираем данные формы
            // Отправляем данные на сервер (маршрут обработчика на Flask)
            $.ajax({
                'method': 'POST',
                'dataType': 'json',
                'url': '/form', // Маршрут-обработчик
                'data': formData,
                success: function(data) {
                    alert(data.message); // Показываем результат
                }
            });
        });
    });
</script>

<form id="form_to_crm" method="POST" action="form.php">
    <!-- Имя (обязательное поле) -->
    <input type="text" name="NAME" placeholder="Имя" required>
    <!-- Фамилия -->
    <input type="text" name="LAST_NAME" placeholder="Фамилия">
    <!-- Название компании -->
    <input type="text" name="COMPANY_TITLE" placeholder="Название компании">
    <!-- Email -->
    <input type="text" name="EMAIL" placeholder="Почта">
    <!-- Телефон -->
    <input type="text" name="PHONE" placeholder="Телефон">
    <!-- Кнопка отправки -->
    <input type="submit" value="Отправить">
</form>

<!-- Подключаем jQuery для AJAX-запроса -->
<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) {
            el.preventDefault(); // Отменяем стандартную отправку формы
            var formData = $(this).serialize(); // Собираем данные формы
            // Отправляем данные на сервер
            $.ajax({
                'method': 'POST',
                'dataType': 'json',
                'url': 'form.php', // Файл-обработчик
                'data': formData,
                success: function(data) {
                    alert(data.message); // Показываем результат
                }
            });
        });
    });
</script>

# Получаем данные из формы
s_name = request.form.get("NAME", "")
s_last_name = request.form.get("LAST_NAME", "")
s_company_title = request.form.get("COMPANY_TITLE", "")
s_phone = request.form.get("PHONE", "")
s_email = request.form.get("EMAIL", "")

// Получаем и очищаем данные из формы
$sName = htmlspecialchars($_POST["NAME"]);
$sLastName = htmlspecialchars($_POST["LAST_NAME"]);
$sCompanyTitle = htmlspecialchars($_POST["COMPANY_TITLE"]);
$sPhone = htmlspecialchars($_POST["PHONE"]);
$sEmail = htmlspecialchars($_POST["EMAIL"]);

# Форматируем телефон и почту для Битрикс24 в формат crm_multifield
ar_phone = [{"VALUE": s_phone, "VALUE_TYPE": "WORK"}] if s_phone else []
ar_email = [{"VALUE": s_email, "VALUE_TYPE": "HOME"}] if s_email else []

// Форматируем телефон и почту для Битрикс24 в формат crm_multifield
$arPhone = (!empty($sPhone)) ? array(array('VALUE' => $sPhone, 'VALUE_TYPE' => 'WORK')) : array();
$arEmail = (!empty($sEmail)) ? array(array('VALUE' => $sEmail, 'VALUE_TYPE' => 'HOME')) : array();

# Формируем заголовок лида из имени и фамилии
s_title = "С сайта: " + f"{s_name} {s_last_name}".strip()
# Если есть название компании — добавляем его через тире после имени и фамилии
if s_company_title:
    s_title += " — " + s_company_title

// Формируем заголовок лида из имени и фамилии
$sTitle = 'С сайта: ' . trim($sName . ' ' . $sLastName);
// Если есть название компании — добавляем его через тире после имени и фамилии
if (!empty($sCompanyTitle)) {
    $sTitle .= ' — ' . $sCompanyTitle;
}

lead_id = client.crm.lead.add(fields={
    "TITLE": s_title,  # Заголовок лида
    "NAME": s_name,  # Имя
    "LAST_NAME": s_last_name,  # Фамилия
    "COMPANY_TITLE": s_company_title,  # Название компании
    "PHONE": ar_phone,  # Телефон
    "EMAIL": ar_email,  # Email
}).result

$leadId = $sb->getCRMScope()->lead()->add([
    'TITLE' => $sTitle, // Заголовок лида
    'NAME' => $sName, // Имя
    'LAST_NAME' => $sLastName, // Фамилия
    'COMPANY_TITLE' => $sCompanyTitle, // Название компании
    'PHONE' => $arPhone, // Телефон
    'EMAIL' => $arEmail, // Email
])->getId();

lead = client.crm.lead.get(bitrix_id=lead_id).result  # ID из результата crm.lead.add
lead_status = lead["STATUS_ID"]

$lead = $sb->getCRMScope()->lead()->get($leadId)->lead(); // ID из результата crm.lead.add
$leadStatus = $lead->STATUS_ID;

# Простой режим: ищем сделку, созданную из лида
deals = client.crm.deal.list(
    filter={"LEAD_ID": lead_id}, select=["ID"],
).as_list().result

// Простой режим: ищем сделку, созданную из лида
$deals = $sb->getCRMScope()->deal()->list(
    order: [],
    filter: ['LEAD_ID' => $leadId],
    select: ['ID']
)->getDeals();

from datetime import datetime, timedelta

if deals:
    deal_id = deals[0]["ID"]
    deadline = (datetime.now() + timedelta(hours=1)).strftime("%Y-%m-%d %H:%M:%S")  # +1 час
    # Привязываем дело к сделке — метод crm.activity.todo.add вызываем напрямую
    token.call_method("crm.activity.todo.add", {
        "ownerTypeId": 2,  # тип объекта — сделка
        "ownerId": int(deal_id),  # идентификатор сделки
        "deadline": deadline,
        "title": "Позвонить клиенту",
        "description": "Заполнил заявку на сайте",
    })

if (!empty($deals)) {
    $dealId = $deals[0]->ID;
    // Привязываем дело к сделке — для crm.activity.todo.add в SDK нет обертки, вызываем напрямую
    $sb->core->call('crm.activity.todo.add', [
        'ownerTypeId' => 2, // тип объекта — сделка
        'ownerId' => $dealId, // идентификатор сделки
        'deadline' => date("Y-m-d H:i:s", time() + 3600), // текущее время + 1 час
        'title' => 'Позвонить клиенту',
        'description' => 'Заполнил заявку на сайте',
    ]);
}

from datetime import datetime, timedelta

deadline = (datetime.now() + timedelta(hours=1)).strftime("%Y-%m-%d %H:%M:%S")  # +1 час
# Классический режим: привязываем дело к лиду — метод crm.activity.todo.add вызываем напрямую
token.call_method("crm.activity.todo.add", {
    "ownerTypeId": 1,  # тип объекта — лид
    "ownerId": lead_id,  # идентификатор лида
    "deadline": deadline,
    "title": "Позвонить клиенту",
    "description": "Заполнил заявку на сайте",
})

// Классический режим: привязываем дело к лиду
$sb->core->call('crm.activity.todo.add', [
    'ownerTypeId' => 1, // тип объекта — лид
    'ownerId' => $leadId, // идентификатор лида
    'deadline' => date("Y-m-d H:i:s", time() + 3600), // текущее время + 1 час
    'title' => 'Позвонить клиенту',
    'description' => 'Заполнил заявку на сайте',
]);

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

app = Flask(__name__)

token = BitrixWebhook(
    domain="your-domain.bitrix24.ru",
    webhook_token=os.environ["B24_HOOK_TOKEN"],
)
# B24_HOOK_TOKEN = 'USER_ID/TOKEN' — только user_id и токен, без https://
client = Client(token)


@app.route("/form", methods=["POST"])
def handle_form():
    # Получаем и очищаем данные из формы
    s_name = request.form.get("NAME", "")
    s_last_name = request.form.get("LAST_NAME", "")
    s_company_title = request.form.get("COMPANY_TITLE", "")
    s_phone = request.form.get("PHONE", "")
    s_email = request.form.get("EMAIL", "")

    # Форматируем телефон и почту для Битрикс24 в формат crm_multifield
    ar_phone = [{"VALUE": s_phone, "VALUE_TYPE": "WORK"}] if s_phone else []
    ar_email = [{"VALUE": s_email, "VALUE_TYPE": "HOME"}] if s_email else []

    # Формируем заголовок лида из имени и фамилии
    s_title = "С сайта: " + f"{s_name} {s_last_name}".strip()
    if s_company_title:
        s_title += " — " + s_company_title

    try:
        # Создаем лид
        lead_id = client.crm.lead.add(fields={
            "TITLE": s_title, "NAME": s_name, "LAST_NAME": s_last_name,
            "COMPANY_TITLE": s_company_title, "PHONE": ar_phone, "EMAIL": ar_email,
        }).result

        # Получаем данные лида
        lead_status = client.crm.lead.get(bitrix_id=lead_id).result["STATUS_ID"]

        deadline = (datetime.now() + timedelta(hours=1)).strftime("%Y-%m-%d %H:%M:%S")  # +1 час

        if lead_status == "CONVERTED":
            # Простой режим: ищем сделку, созданную из лида
            deals = client.crm.deal.list(filter={"LEAD_ID": lead_id}, select=["ID"]).as_list().result
            if deals:
                # Добавляем дело в сделку (crm.activity.todo.add — вызываем напрямую)
                token.call_method("crm.activity.todo.add", {
                    "ownerTypeId": 2, "ownerId": int(deals[0]["ID"]), "deadline": deadline,
                    "title": "Позвонить клиенту", "description": "Заполнил заявку на сайте",
                })
        else:
            # Классический режим: добавляем дело в новый лид
            token.call_method("crm.activity.todo.add", {
                "ownerTypeId": 1, "ownerId": lead_id, "deadline": deadline,
                "title": "Позвонить клиенту", "description": "Заполнил заявку на сайте",
            })

        return jsonify({"message": "Дело добавлено в лид или сделку"})
    except Exception as e:
        return jsonify({"message": str(e)})

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

use Bitrix24\SDK\Services\ServiceBuilderFactory;
use Symfony\Component\EventDispatcher\EventDispatcher;
use Psr\Log\NullLogger;

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

// Получаем и очищаем данные из формы
$sName = htmlspecialchars($_POST["NAME"]);
$sLastName = htmlspecialchars($_POST["LAST_NAME"]);
$sCompanyTitle = htmlspecialchars($_POST["COMPANY_TITLE"]);
$sPhone = htmlspecialchars($_POST["PHONE"]);
$sEmail = htmlspecialchars($_POST["EMAIL"]);

// Форматируем телефон и почту для Битрикс24 в формат crm_multifield
$arPhone = (!empty($sPhone)) ? array(array('VALUE' => $sPhone, 'VALUE_TYPE' => 'WORK')) : array();
$arEmail = (!empty($sEmail)) ? array(array('VALUE' => $sEmail, 'VALUE_TYPE' => 'HOME')) : array();

// Формируем заголовок лида из имени и фамилии
$sTitle = 'С сайта: ' . trim($sName . ' ' . $sLastName);
if (!empty($sCompanyTitle)) {
    $sTitle .= ' — ' . $sCompanyTitle;
}

try {
    // Создаем лид
    $leadId = $crm->lead()->add([
        'TITLE' => $sTitle, 'NAME' => $sName, 'LAST_NAME' => $sLastName,
        'COMPANY_TITLE' => $sCompanyTitle, 'PHONE' => $arPhone, 'EMAIL' => $arEmail,
    ])->getId();

    // Получаем данные лида
    $leadStatus = $crm->lead()->get($leadId)->lead()->STATUS_ID;

    $deadline = date("Y-m-d H:i:s", time() + 3600); // текущее время + 1 час

    if ($leadStatus == 'CONVERTED') {
        // Простой режим: ищем сделку, созданную из лида
        $deals = $crm->deal()->list(order: [], filter: ['LEAD_ID' => $leadId], select: ['ID'])->getDeals();
        if (!empty($deals)) {
            // Добавляем дело в сделку — у crm.activity.todo.add нет обертки, вызываем напрямую
            $sb->core->call('crm.activity.todo.add', [
                'ownerTypeId' => 2, 'ownerId' => $deals[0]->ID, 'deadline' => $deadline,
                'title' => 'Позвонить клиенту', 'description' => 'Заполнил заявку на сайте',
            ]);
        }
    } else {
        // Классический режим: добавляем дело в новый лид
        $sb->core->call('crm.activity.todo.add', [
            'ownerTypeId' => 1, 'ownerId' => $leadId, 'deadline' => $deadline,
            'title' => 'Позвонить клиенту', 'description' => 'Заполнил заявку на сайте',
        ]);
    }

    echo json_encode(['message' => 'Дело добавлено в лид или сделку']);
} catch (\Throwable $e) {
    echo json_encode(['message' => $e->getMessage()]);
}

activities = client.crm.activity.list(
    filter={"OWNER_TYPE_ID": 1, "OWNER_ID": lead_id},
    select=["ID", "SUBJECT", "OWNER_TYPE_ID", "OWNER_ID"],
).response.result

$activities = $sb->getCRMScope()->activity()->list(
    [],
    ['OWNER_TYPE_ID' => 1, 'OWNER_ID' => $leadId],
    ['ID', 'SUBJECT', 'OWNER_TYPE_ID', 'OWNER_ID'],
    0
)->getActivities();