Как создать новую воронку со стадиями в смарт-процессе

from b24pysdk import BitrixWebhook, Client

client = Client(
    BitrixWebhook(
        domain="your-domain.bitrix24.com",
        webhook_token="user_id/webhook_key",
    )
)

types = client.crm.type.list(
    filter={"title": "Закупка оборудования"},  # Название смарт-процесса
).response.result["types"]

entity_type_id = int(types[0]["entityTypeId"]) if types else None

// 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('https://your-domain.bitrix24.ru/rest/USER_ID/TOKEN/');

$types = $sb->getCRMScope()->type()->list(
    order: [],
    filter: ['title' => 'Закупка оборудования'] // Название смарт-процесса
)->getTypes();

$entityTypeId = $types[0]->entityTypeId ?? null;

category = client.crm.category.add(
    entity_type_id=entity_type_id,  # Идентификатор типа из шага 1
    fields={
        "name": "Новая воронка",  # Название воронки
        "sort": 100,  # Индекс сортировки
    },
).response.result["category"]

category_id = int(category["id"])

// у crm.category.add нет обертки в SDK — вызываем метод напрямую
$result = $sb->core->call(
    'crm.category.add',
    [
        'entityTypeId' => $entityTypeId, // Идентификатор типа из шага 1
        'fields' => [
            'name' => 'Новая воронка', // Название воронки
            'sort' => 100 // Индекс сортировки
        ]
    ]
);

$categoryId = $result->getResponseData()->getResult()['category']['id'];

entity_id = f"DYNAMIC_{entity_type_id}_STAGE_{category_id}"

stages = client.crm.status.list(
    filter={"ENTITY_ID": entity_id},  # Справочник стадий этой воронки
    order={"SORT": "ASC"},  # Стадии по возрастанию индекса сортировки
).response.result

first_stage_id = int(stages[0]["ID"])  # Первая стадия группы «В работе»

$entityId = "DYNAMIC_{$entityTypeId}_STAGE_{$categoryId}";

$stages = $sb->getCRMScope()->status()->list(
    order: ['SORT' => 'ASC'], // Стадии по возрастанию индекса сортировки
    filter: ['ENTITY_ID' => $entityId] // Справочник стадий этой воронки
)->getStatuses();

$firstStageId = $stages[0]->ID; // Первая стадия группы «В работе»

client.crm.status.update(
    first_stage_id,  # Идентификатор стадии из шага 3
    fields={
        "NAME": "Первая стадия",  # Новое название стадии
    },
).response

$result = $sb->getCRMScope()->status()->update(
    $firstStageId, // Идентификатор стадии из шага 3
    [
        'NAME' => 'Первая стадия' // Новое название стадии
    ]
);

new_stage_id = client.crm.status.add(
    fields={
        "ENTITY_ID": entity_id,  # Справочник стадий из шага 3
        "STATUS_ID": f"DT{entity_type_id}_{category_id}:MY_STAGE",  # Код стадии
        "NAME": "Моя стадия",  # Название стадии
        "SORT": 60,  # Индекс сортировки
        "SEMANTICS": "F",  # Группа «Провал»
    },
).response.result

$result = $sb->getCRMScope()->status()->add(
    [
        'ENTITY_ID' => $entityId, // Справочник стадий из шага 3
        'STATUS_ID' => 'DT' . $entityTypeId . '_' . $categoryId . ':MY_STAGE', // Код стадии
        'NAME' => 'Моя стадия', // Название стадии
        'SORT' => 60, // Индекс сортировки
        'SEMANTICS' => 'F' // Группа «Провал»
    ]
);

$newStageId = $result->getId();

check_result = client.crm.status.list(
    filter={"ENTITY_ID": entity_id},
    order={"SORT": "ASC"},
).response.result

for stage in check_result:
    print(stage["NAME"], stage["SORT"], stage["SEMANTICS"])

$checkResult = $sb->getCRMScope()->status()->list(
    order: ['SORT' => 'ASC'],
    filter: ['ENTITY_ID' => $entityId]
)->getStatuses();

foreach ($checkResult as $stage) {
    echo $stage->NAME . ' | ' . $stage->SORT . ' | ' . $stage->SEMANTICS . PHP_EOL;
}

from b24pysdk import BitrixWebhook, Client
from b24pysdk.errors import BitrixAPIError

client = Client(
    BitrixWebhook(
        domain="your-domain.bitrix24.com",
        webhook_token="user_id/webhook_key",
    )
)

process_title = "Закупка оборудования"  # Название вашего смарт-процесса


def print_stages_table(stages):
    columns = {"В работе": [], "Успех": [], "Провал": []}

    for stage in stages:
        if stage["SEMANTICS"] == "S":
            columns["Успех"].append(stage["NAME"])
        elif stage["SEMANTICS"] == "F":
            columns["Провал"].append(stage["NAME"])
        else:
            columns["В работе"].append(stage["NAME"])

    max_rows = max(len(column) for column in columns.values())

    print("Таблица стадий:")
    for index in range(max_rows):
        row = [
            columns[group][index] if index < len(columns[group]) else ""
            for group in ("В работе", "Успех", "Провал")
        ]
        print(f"В работе: {row[0]} | Успех: {row[1]} | Провал: {row[2]}")


try:
    # 1. Получаем entityTypeId по названию смарт-процесса
    types = client.crm.type.list(
        filter={"title": process_title},
    ).response.result["types"]
    if not types:
        raise SystemExit(f"Смарт-процесс «{process_title}» не найден")
    entity_type_id = int(types[0]["entityTypeId"])

    # 2. Создаем воронку
    category_id = int(
        client.crm.category.add(
            entity_type_id=entity_type_id,
            fields={"name": "Новая воронка", "sort": 100},
        ).response.result["category"]["id"]
    )
    entity_id = f"DYNAMIC_{entity_type_id}_STAGE_{category_id}"

    # 3. Получаем предустановленные стадии
    stages = client.crm.status.list(
        filter={"ENTITY_ID": entity_id},
        order={"SORT": "ASC"},
    ).response.result

    if not stages:
        raise SystemExit(f"Стадии не найдены: проверьте справочник {entity_id}")

    # 4. Переименовываем первую стадию
    client.crm.status.update(
        int(stages[0]["ID"]),
        fields={"NAME": "Первая стадия"},
    ).response

    # 5. Добавляем свою стадию в группу «Провал»
    client.crm.status.add(
        fields={
            "ENTITY_ID": entity_id,
            "STATUS_ID": f"DT{entity_type_id}_{category_id}:MY_STAGE",
            "NAME": "Моя стадия",
            "SORT": 60,
            "SEMANTICS": "F",
        },
    ).response

    # Проверяем результат
    final_stages = client.crm.status.list(
        filter={"ENTITY_ID": entity_id},
        order={"SORT": "ASC"},
    ).response.result
except BitrixAPIError as error:
    print(f"Ошибка: {error}")
else:
    print_stages_table(final_stages)

<?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('https://your-domain.bitrix24.ru/rest/USER_ID/TOKEN/');

$crm = $sb->getCRMScope();
$processTitle = 'Закупка оборудования'; // Название вашего смарт-процесса

try {
    // 1. Получаем entityTypeId по названию смарт-процесса
    $types = $crm->type()->list(
        order: [],
        filter: ['title' => $processTitle]
    )->getTypes();
    if (empty($types)) {
        throw new \RuntimeException('Смарт-процесс не найден: ' . $processTitle);
    }
    $entityTypeId = $types[0]->entityTypeId;

    // 2. Создаем воронку
    $result = $sb->core->call(
        'crm.category.add',
        [
            'entityTypeId' => $entityTypeId,
            'fields' => ['name' => 'Новая воронка', 'sort' => 100]
        ]
    );
    $categoryId = $result->getResponseData()->getResult()['category']['id'];
    $entityId = 'DYNAMIC_' . $entityTypeId . '_STAGE_' . $categoryId;

    // 3. Получаем предустановленные стадии
    $stages = $crm->status()->list(
        order: ['SORT' => 'ASC'],
        filter: ['ENTITY_ID' => $entityId]
    )->getStatuses();

    if (empty($stages)) {
        throw new \RuntimeException('Стадии не найдены: проверьте справочник ' . $entityId);
    }

    // 4. Переименовываем первую стадию
    $crm->status()->update($stages[0]->ID, ['NAME' => 'Первая стадия']);

    // 5. Добавляем свою стадию в группу «Провал»
    $crm->status()->add([
        'ENTITY_ID' => $entityId,
        'STATUS_ID' => 'DT' . $entityTypeId . '_' . $categoryId . ':MY_STAGE',
        'NAME' => 'Моя стадия',
        'SORT' => 60,
        'SEMANTICS' => 'F',
    ]);

    // Проверяем результат
    $finalStages = $crm->status()->list(
        order: ['SORT' => 'ASC'],
        filter: ['ENTITY_ID' => $entityId]
    )->getStatuses();
} catch (\Throwable $e) {
    echo 'Ошибка: ' . $e->getMessage();
    exit;
}

$columns = ['В работе' => [], 'Успех' => [], 'Провал' => []];

foreach ($finalStages as $stage) {
    if ($stage->SEMANTICS === 'S') {
        $columns['Успех'][] = $stage->NAME;
    } elseif ($stage->SEMANTICS === 'F') {
        $columns['Провал'][] = $stage->NAME;
    } else {
        $columns['В работе'][] = $stage->NAME;
    }
}

$maxRows = max(
    count($columns['В работе']),
    count($columns['Успех']),
    count($columns['Провал'])
);

echo "Таблица стадий:\n";
for ($i = 0; $i < $maxRows; $i++) {
    echo 'В работе: ' . ($columns['В работе'][$i] ?? '')
        . ' | Успех: ' . ($columns['Успех'][$i] ?? '')
        . ' | Провал: ' . ($columns['Провал'][$i] ?? '') . "\n";
}