Как добавить действие для создания смарт-счета на основании лида или сделки

# pip install b24pysdk
from b24pysdk import BitrixApp, BitrixToken, Client

APP = BitrixApp(client_id="local.xxxxxxxx.xxxxxxxx", client_secret="yyyyyyyy")

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

auth = request.json["auth"]  # словарь auth из тела запроса обработчика
client, token = make_client(auth)

<?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();
$appProfile = ApplicationProfile::initFromArray([
    'BITRIX24_PHP_SDK_APPLICATION_CLIENT_ID' => 'local.xxxxxxxx.xxxxxxxx',
    'BITRIX24_PHP_SDK_APPLICATION_CLIENT_SECRET' => 'yyyyyyyy',
    'BITRIX24_PHP_SDK_APPLICATION_SCOPE' => 'bizproc,crm',
]);

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

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

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

# pip install b24pysdk

# client построен на токене установленного приложения.
result = client.bizproc.activity.add(
    code="create_smart_invoice",
    handler="https://your-domain.example/bp-handler",
    auth_user_id=1,
    name="Создать смарт-счет",
    description="Создает смарт-счет по данным лида или сделки",
    properties={
        "invoice_title": {
            "Name": "Название счета",
            "Type": "string",
            "Required": "Y",
            "Default": "Счет по документу CRM",
        },
        "mycompany_id": {
            "Name": "Идентификатор вашей компании",
            "Type": "int",
            "Required": "Y",
            "Default": "1",
        },
    },
    filter={
        "INCLUDE": [
            ["crm", "CCrmDocumentDeal"],
            ["crm", "CCrmDocumentLead"],
        ],
    },
).response.result

print(result)  # True

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

// $b24 построен на токене установленного приложения.
// Типизированный метод activity()->add принимает расширенные DTO,
// поэтому для короткого примера используем прямой вызов через ядро SDK.
$response = $b24->core->call('bizproc.activity.add', [
    'CODE' => 'create_smart_invoice',
    'HANDLER' => 'https://your-domain.example/bp-handler',
    'AUTH_USER_ID' => 1,
    'NAME' => 'Создать смарт-счет',
    'DESCRIPTION' => 'Создает смарт-счет по данным лида или сделки',
    'PROPERTIES' => [
        'invoice_title' => [
            'Name' => 'Название счета',
            'Type' => 'string',
            'Required' => 'Y',
            'Default' => 'Счет по документу CRM',
        ],
        'mycompany_id' => [
            'Name' => 'Идентификатор вашей компании',
            'Type' => 'int',
            'Required' => 'Y',
            'Default' => '1',
        ],
    ],
    'FILTER' => [
        'INCLUDE' => [
            ['crm', 'CCrmDocumentDeal'],
            ['crm', 'CCrmDocumentLead'],
        ],
    ],
]);

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

def parse_document_id(document_id: list[str]) -> dict:
    for value in document_id:
        if value.startswith("DEAL_"):
            return {"entityTypeId": 2, "ownerType": "D", "id": int(value[5:])}

        if value.startswith("LEAD_"):
            return {"entityTypeId": 1, "ownerType": "L", "id": int(value[5:])}

    raise ValueError("Действие запущено не из лида и не из сделки")

payload = request.json
source = parse_document_id(payload.get("document_id", []))
properties = payload.get("properties", {})

<?php
function parseDocumentId(array $documentId): array
{
    foreach ($documentId as $value) {
        if (str_starts_with((string)$value, 'DEAL_')) {
            return ['entityTypeId' => 2, 'ownerType' => 'D', 'id' => (int)substr((string)$value, 5)];
        }

        if (str_starts_with((string)$value, 'LEAD_')) {
            return ['entityTypeId' => 1, 'ownerType' => 'L', 'id' => (int)substr((string)$value, 5)];
        }
    }

    throw new RuntimeException('Действие запущено не из лида и не из сделки');
}

$source = parseDocumentId((array)($_REQUEST['document_id'] ?? []));
$properties = $_REQUEST['properties'] ?? [];

source_item = token.call_method("crm.item.get", {
    "entityTypeId": source["entityTypeId"],
    "id": source["id"],
})["result"]["item"]

source_rows = token.call_method("crm.item.productrow.list", {
    "filter": {
        "=ownerType": source["ownerType"],
        "=ownerId": source["id"],
    },
})["result"]["productRows"]

<?php
$sourceItem = $b24->core
    ->call('crm.item.get', [
        'entityTypeId' => $source['entityTypeId'],
        'id' => $source['id'],
    ])
    ->getResponseData()
    ->getResult()['item'];

$sourceRows = $b24->core
    ->call('crm.item.productrow.list', [
        'filter' => [
            '=ownerType' => $source['ownerType'],
            '=ownerId' => $source['id'],
        ],
    ])
    ->getResponseData()
    ->getResult()['productRows'];

def prepare_product_rows(rows: list[dict]) -> list[dict]:
    return [
        {
            "productId": row.get("productId"),
            "productName": row.get("productName"),
            "price": row.get("price"),
            "quantity": row.get("quantity", 1),
            "discountTypeId": row.get("discountTypeId"),
            "discountRate": row.get("discountRate"),
            "discountSum": row.get("discountSum"),
            "taxRate": row.get("taxRate"),
            "taxIncluded": row.get("taxIncluded"),
            "measureCode": row.get("measureCode"),
            "sort": row.get("sort", (index + 1) * 10),
        }
        for index, row in enumerate(rows)
    ]

fields = {
    "title": properties.get("invoice_title", "Счет по документу CRM"),
    "companyId": int(source_item.get("companyId") or 0),
    "contactId": int(source_item.get("contactId") or 0),
    "contactIds": source_item.get("contactIds") or [],
    "mycompanyId": int(properties.get("mycompany_id") or 0),
}

if source["entityTypeId"] == 2:
    fields["parentId2"] = source["id"]

invoice = token.call_method("crm.item.add", {
    "entityTypeId": 31,
    "fields": fields,
})["result"]["item"]

if source_rows:
    token.call_method("crm.item.productrow.set", {
        "ownerType": "SI",
        "ownerId": invoice["id"],
        "productRows": prepare_product_rows(source_rows),
    })

print(f"Создан смарт-счет {invoice['id']}")

<?php
function prepareProductRows(array $rows): array
{
    $preparedRows = [];

    foreach (array_values($rows) as $index => $row) {
        $preparedRows[] = [
            'productId' => $row['productId'] ?? null,
            'productName' => $row['productName'] ?? null,
            'price' => $row['price'] ?? null,
            'quantity' => $row['quantity'] ?? 1,
            'discountTypeId' => $row['discountTypeId'] ?? null,
            'discountRate' => $row['discountRate'] ?? null,
            'discountSum' => $row['discountSum'] ?? null,
            'taxRate' => $row['taxRate'] ?? null,
            'taxIncluded' => $row['taxIncluded'] ?? null,
            'measureCode' => $row['measureCode'] ?? null,
            'sort' => $row['sort'] ?? (($index + 1) * 10),
        ];
    }

    return $preparedRows;
}

$fields = [
    'title' => $properties['invoice_title'] ?? 'Счет по документу CRM',
    'companyId' => (int)($sourceItem['companyId'] ?? 0),
    'contactId' => (int)($sourceItem['contactId'] ?? 0),
    'contactIds' => $sourceItem['contactIds'] ?? [],
    'mycompanyId' => (int)($properties['mycompany_id'] ?? 0),
];

if ($source['entityTypeId'] === 2) {
    $fields['parentId2'] = $source['id'];
}

$invoice = $b24->core
    ->call('crm.item.add', [
        'entityTypeId' => 31,
        'fields' => $fields,
    ])
    ->getResponseData()
    ->getResult()['item'];

if ($sourceRows !== []) {
    $b24->core->call('crm.item.productrow.set', [
        'ownerType' => 'SI',
        'ownerId' => $invoice['id'],
        'productRows' => prepareProductRows($sourceRows),
    ]);
}

echo 'Создан смарт-счет ' . $invoice['id'];