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

<?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
        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';
        
        // $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
        

# 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
        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'] ?? [];
        

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
        $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'];
        

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
        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'];
        

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']}")