Как автоматически заполнить зависимое поле CRM после изменения основного поля

<?php
$handlerUrl = 'https://your-domain.example/crm-deal-update';

// У event.bind нет обертки в SDK — вызываем метод напрямую
$response = $b24->core->call('event.bind', [
    'event' => 'ONCRMDEALUPDATE',
    'handler' => $handlerUrl,
]);

print_r($response->getResponseData()->getResult());

handler_url = "https://your-domain.example/crm-deal-update"

response = client.event.bind(
    event="ONCRMDEALUPDATE",
    handler=handler_url,
).response

print(response.result)

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

use Bitrix24\SDK\Core\Credentials\ApplicationProfile;
use Bitrix24\SDK\Core\Credentials\AuthToken;
use Bitrix24\SDK\Core\Credentials\DefaultOAuthServerUrl;
use Bitrix24\SDK\Services\ServiceBuilderFactory;
use Monolog\Handler\StreamHandler;
use Monolog\Logger;
use Symfony\Component\EventDispatcher\EventDispatcher;
use Symfony\Component\HttpFoundation\Request;

$request = Request::createFromGlobals();
$auth = $request->request->all('auth');
$applicationToken = getenv('B24_APPLICATION_TOKEN');

if (!$applicationToken || (($auth['application_token'] ?? '') !== $applicationToken)) {
    http_response_code(403);
    return;
}

$appProfile = ApplicationProfile::initFromArray([
    'BITRIX24_PHP_SDK_APPLICATION_CLIENT_ID' => getenv('B24_CLIENT_ID'),
    'BITRIX24_PHP_SDK_APPLICATION_CLIENT_SECRET' => getenv('B24_CLIENT_SECRET'),
    'BITRIX24_PHP_SDK_APPLICATION_SCOPE' => 'crm',
]);

$authToken = AuthToken::initFromEventRequest($request);
$domain = (string)$auth['domain'];

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

$b24 = (new ServiceBuilderFactory(new EventDispatcher(), $log))
    ->init($appProfile, $authToken, $domain, DefaultOAuthServerUrl::default());

$eventData = $request->request->all('data');
$dealId = (int)$eventData['FIELDS']['ID'];

// Параметр useOriginalUfNames передаем прямым вызовом через ядро SDK
$response = $b24->core->call('crm.item.get', [
    'entityTypeId' => 2,
    'id' => $dealId,
    'useOriginalUfNames' => 'Y',
]);
$deal = $response->getResponseData()->getResult()['item'];

echo $deal['UF_CRM_SERVICE'];

# pip install flask b24pysdk
import os
from flask import Flask, request
from b24pysdk import BitrixApp, BitrixToken

app = Flask(__name__)

APP = BitrixApp(
    client_id=os.environ["B24_CLIENT_ID"],
    client_secret=os.environ["B24_CLIENT_SECRET"],
)
APPLICATION_TOKEN = os.environ["B24_APPLICATION_TOKEN"]

def make_token(auth: dict) -> BitrixToken:
    return BitrixToken(
        domain=auth["domain"],
        auth_token=auth["access_token"],
        refresh_token=auth.get("refresh_token", ""),
        bitrix_app=APP,
    )

def get_nested(prefix: str) -> dict:
    result = {}
    for key, value in request.form.items():
        if key.startswith(prefix + "[") and key.endswith("]"):
            path = key[len(prefix) + 1 : -1].split("][")
            cursor = result
            for part in path[:-1]:
                cursor = cursor.setdefault(part, {})
            cursor[path[-1]] = value
    return result

@app.post("/crm-deal-update")
def handle_deal_update():
    auth = get_nested("auth")
    event_data = get_nested("data")
    deal_id = int(event_data["FIELDS"]["ID"])
    if auth.get("application_token") != APPLICATION_TOKEN:
        return "", 403

    token = make_token(auth)
    # Параметр useOriginalUfNames передаем прямым вызовом через SDK
    deal = token.call_method("crm.item.get", {
        "entityTypeId": 2,
        "id": deal_id,
        "useOriginalUfNames": "Y",
    })["result"]["item"]

    print(deal["UF_CRM_SERVICE"])
    return "", 200

<?php
// Параметр useOriginalUfNames передаем прямым вызовом через ядро SDK
$b24->core->call('crm.item.update', [
    'entityTypeId' => 2,
    'id' => $dealId,
    'fields' => [
        'UF_CRM_DOCUMENTS' => $documents,
    ],
    'useOriginalUfNames' => 'Y',
]);

# Параметр useOriginalUfNames передаем прямым вызовом через SDK
token.call_method("crm.item.update", {
    "entityTypeId": 2,
    "id": deal_id,
    "fields": {
        "UF_CRM_DOCUMENTS": documents,
    },
    "useOriginalUfNames": "Y",
})

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

use Bitrix24\SDK\Core\Credentials\ApplicationProfile;
use Bitrix24\SDK\Core\Credentials\AuthToken;
use Bitrix24\SDK\Core\Credentials\DefaultOAuthServerUrl;
use Bitrix24\SDK\Services\ServiceBuilderFactory;
use Monolog\Handler\StreamHandler;
use Monolog\Logger;
use Symfony\Component\EventDispatcher\EventDispatcher;
use Symfony\Component\HttpFoundation\Request;

$request = Request::createFromGlobals();
$auth = $request->request->all('auth');
$applicationToken = getenv('B24_APPLICATION_TOKEN');

if (!$applicationToken || (($auth['application_token'] ?? '') !== $applicationToken)) {
    http_response_code(403);
    return;
}

$appProfile = ApplicationProfile::initFromArray([
    'BITRIX24_PHP_SDK_APPLICATION_CLIENT_ID' => getenv('B24_CLIENT_ID'),
    'BITRIX24_PHP_SDK_APPLICATION_CLIENT_SECRET' => getenv('B24_CLIENT_SECRET'),
    'BITRIX24_PHP_SDK_APPLICATION_SCOPE' => 'crm',
]);

$authToken = AuthToken::initFromEventRequest($request);
$domain = (string)$auth['domain'];

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

$b24 = (new ServiceBuilderFactory(new EventDispatcher(), $log))
    ->init($appProfile, $authToken, $domain, DefaultOAuthServerUrl::default());

$entityTypeId = 2;
$serviceField = 'UF_CRM_SERVICE';
$documentsField = 'UF_CRM_DOCUMENTS';
$documentsByService = [
    '102' => 'Паспорт, заявление, договор',
    '103' => 'ИНН, доверенность, акт',
];

try {
    $eventData = $request->request->all('data');
    $dealId = (int)$eventData['FIELDS']['ID'];

    // Параметр useOriginalUfNames передаем прямым вызовом через ядро SDK
    $resultDeal = $b24->core->call('crm.item.get', [
        'entityTypeId' => $entityTypeId,
        'id' => $dealId,
        'useOriginalUfNames' => 'Y',
    ]);
    $deal = $resultDeal->getResponseData()->getResult()['item'];

    $serviceId = (string)$deal[$serviceField];
    $documents = $documentsByService[$serviceId] ?? null;

    if ($documents === null || $deal[$documentsField] === $documents) {
        http_response_code(200);
        return;
    }

    // Параметр useOriginalUfNames передаем прямым вызовом через ядро SDK
    $b24->core->call('crm.item.update', [
        'entityTypeId' => $entityTypeId,
        'id' => $dealId,
        'fields' => [
            $documentsField => $documents,
        ],
        'useOriginalUfNames' => 'Y',
    ]);

    http_response_code(200);
} catch (\Throwable $e) {
    error_log($e->getMessage());
    http_response_code(500);
}

# pip install flask b24pysdk
import os
from flask import Flask, request
from b24pysdk import BitrixApp, BitrixToken

app = Flask(__name__)

APP = BitrixApp(
    client_id=os.environ["B24_CLIENT_ID"],
    client_secret=os.environ["B24_CLIENT_SECRET"],
)
APPLICATION_TOKEN = os.environ["B24_APPLICATION_TOKEN"]

ENTITY_TYPE_ID = 2
SERVICE_FIELD = "UF_CRM_SERVICE"
DOCUMENTS_FIELD = "UF_CRM_DOCUMENTS"
DOCUMENTS_BY_SERVICE = {
    "102": "Паспорт, заявление, договор",
    "103": "ИНН, доверенность, акт",
}

def make_token(auth: dict) -> BitrixToken:
    return BitrixToken(
        domain=auth["domain"],
        auth_token=auth["access_token"],
        refresh_token=auth.get("refresh_token", ""),
        bitrix_app=APP,
    )

def get_nested(prefix: str) -> dict:
    result = {}
    for key, value in request.form.items():
        if key.startswith(prefix + "[") and key.endswith("]"):
            path = key[len(prefix) + 1 : -1].split("][")
            cursor = result
            for part in path[:-1]:
                cursor = cursor.setdefault(part, {})
            cursor[path[-1]] = value
    return result

@app.post("/crm-deal-update")
def handle_deal_update():
    try:
        auth = get_nested("auth")
        event_data = get_nested("data")
        deal_id = int(event_data["FIELDS"]["ID"])
        if auth.get("application_token") != APPLICATION_TOKEN:
            return "", 403

        token = make_token(auth)
        # Параметр useOriginalUfNames передаем прямым вызовом через SDK
        deal = token.call_method("crm.item.get", {
            "entityTypeId": ENTITY_TYPE_ID,
            "id": deal_id,
            "useOriginalUfNames": "Y",
        })["result"]["item"]

        service_id = str(deal[SERVICE_FIELD])
        documents = DOCUMENTS_BY_SERVICE.get(service_id)

        if documents is None or deal[DOCUMENTS_FIELD] == documents:
            return "", 200

        # Параметр useOriginalUfNames передаем прямым вызовом через SDK
        token.call_method("crm.item.update", {
            "entityTypeId": ENTITY_TYPE_ID,
            "id": deal_id,
            "fields": {
                DOCUMENTS_FIELD: documents,
            },
            "useOriginalUfNames": "Y",
        })

        return "", 200
    except Exception as error:
        print(error)
        return "", 500