How to Create a New Sales Funnel with Stages in a Smart Process

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": "Equipment procurement"},  # Smart process name
        ).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.com/rest/USER_ID/TOKEN/');
        
        $types = $sb->getCRMScope()->type()->list(
            order: [],
            filter: ['title' => 'Equipment procurement'] // Smart process name
        )->getTypes();
        
        $entityTypeId = $types[0]->entityTypeId ?? null;
        

category = client.crm.category.add(
            entity_type_id=entity_type_id,  # Type identifier from step 1
            fields={
                "name": "New funnel",  # Funnel name
                "sort": 100,  # Sorting index
            },
        ).response.result["category"]
        
        category_id = int(category["id"])
        

// crm.category.add has no wrapper in the SDK — calling the method directly
        $result = $sb->core->call(
            'crm.category.add',
            [
                'entityTypeId' => $entityTypeId, // Type identifier from step 1
                'fields' => [
                    'name' => 'New funnel', // Funnel name
                    'sort' => 100 // Sorting index
                ]
            ]
        );
        
        $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},  # Stage directory of this funnel
            order={"SORT": "ASC"},  # Stages in ascending order of the sorting index
        ).response.result
        
        first_stage_id = int(stages[0]["ID"])  # First stage of the "In Progress" group
        

$entityId = "DYNAMIC_{$entityTypeId}_STAGE_{$categoryId}";
        
        $stages = $sb->getCRMScope()->status()->list(
            order: ['SORT' => 'ASC'], // Stages in ascending order of the sorting index
            filter: ['ENTITY_ID' => $entityId] // Stage directory of this funnel
        )->getStatuses();
        
        $firstStageId = $stages[0]->ID; // First stage of the "In Progress" group
        

client.crm.status.update(
            first_stage_id,  # Stage identifier from step 3
            fields={
                "NAME": "First stage",  # New stage name
            },
        ).response
        

$result = $sb->getCRMScope()->status()->update(
            $firstStageId, // Stage identifier from step 3
            [
                'NAME' => 'First stage' // New stage name
            ]
        );
        

new_stage_id = client.crm.status.add(
            fields={
                "ENTITY_ID": entity_id,  # Stage directory from step 3
                "STATUS_ID": f"DT{entity_type_id}_{category_id}:MY_STAGE",  # Stage code
                "NAME": "My stage",  # Stage name
                "SORT": 60,  # Sorting index
                "SEMANTICS": "F",  # "Failure" group
            },
        ).response.result
        

$result = $sb->getCRMScope()->status()->add(
            [
                'ENTITY_ID' => $entityId, // Stage directory from step 3
                'STATUS_ID' => 'DT' . $entityTypeId . '_' . $categoryId . ':MY_STAGE', // Stage code
                'NAME' => 'My stage', // Stage name
                'SORT' => 60, // Sorting index
                'SEMANTICS' => 'F' // "Failure" group
            ]
        );
        
        $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 = "Equipment procurement"  # Name of your smart process
        
        
        def print_stages_table(stages):
            columns = {"In Progress": [], "Success": [], "Failure": []}
        
            for stage in stages:
                if stage["SEMANTICS"] == "S":
                    columns["Success"].append(stage["NAME"])
                elif stage["SEMANTICS"] == "F":
                    columns["Failure"].append(stage["NAME"])
                else:
                    columns["In Progress"].append(stage["NAME"])
        
            max_rows = max(len(column) for column in columns.values())
        
            print("Stage table:")
            for index in range(max_rows):
                row = [
                    columns[group][index] if index < len(columns[group]) else ""
                    for group in ("In Progress", "Success", "Failure")
                ]
                print(f"In Progress: {row[0]} | Success: {row[1]} | Failure: {row[2]}")
        
        
        try:
            # 1. Retrieve the entityTypeId by the smart process name
            types = client.crm.type.list(
                filter={"title": process_title},
            ).response.result["types"]
            if not types:
                raise SystemExit(f'Smart process "{process_title}" not found')
            entity_type_id = int(types[0]["entityTypeId"])
        
            # 2. Create the funnel
            category_id = int(
                client.crm.category.add(
                    entity_type_id=entity_type_id,
                    fields={"name": "New funnel", "sort": 100},
                ).response.result["category"]["id"]
            )
            entity_id = f"DYNAMIC_{entity_type_id}_STAGE_{category_id}"
        
            # 3. Retrieve the pre-installed stages
            stages = client.crm.status.list(
                filter={"ENTITY_ID": entity_id},
                order={"SORT": "ASC"},
            ).response.result
        
            if not stages:
                raise SystemExit(f"Stages not found: check the {entity_id} directory")
        
            # 4. Rename the first stage
            client.crm.status.update(
                int(stages[0]["ID"]),
                fields={"NAME": "First stage"},
            ).response
        
            # 5. Add your own stage to the "Failure" group
            client.crm.status.add(
                fields={
                    "ENTITY_ID": entity_id,
                    "STATUS_ID": f"DT{entity_type_id}_{category_id}:MY_STAGE",
                    "NAME": "My stage",
                    "SORT": 60,
                    "SEMANTICS": "F",
                },
            ).response
        
            # Verify the result
            final_stages = client.crm.status.list(
                filter={"ENTITY_ID": entity_id},
                order={"SORT": "ASC"},
            ).response.result
        except BitrixAPIError as error:
            print(f"Error: {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.com/rest/USER_ID/TOKEN/');
        
        $crm = $sb->getCRMScope();
        $processTitle = 'Equipment procurement'; // Name of your smart process
        
        try {
            // 1. Retrieve the entityTypeId by the smart process name
            $types = $crm->type()->list(
                order: [],
                filter: ['title' => $processTitle]
            )->getTypes();
            if (empty($types)) {
                throw new \RuntimeException('Smart process not found: ' . $processTitle);
            }
            $entityTypeId = $types[0]->entityTypeId;
        
            // 2. Create the funnel
            $result = $sb->core->call(
                'crm.category.add',
                [
                    'entityTypeId' => $entityTypeId,
                    'fields' => ['name' => 'New funnel', 'sort' => 100]
                ]
            );
            $categoryId = $result->getResponseData()->getResult()['category']['id'];
            $entityId = 'DYNAMIC_' . $entityTypeId . '_STAGE_' . $categoryId;
        
            // 3. Retrieve the pre-installed stages
            $stages = $crm->status()->list(
                order: ['SORT' => 'ASC'],
                filter: ['ENTITY_ID' => $entityId]
            )->getStatuses();
        
            if (empty($stages)) {
                throw new \RuntimeException('Stages not found: check the directory ' . $entityId);
            }
        
            // 4. Rename the first stage
            $crm->status()->update($stages[0]->ID, ['NAME' => 'First stage']);
        
            // 5. Add your own stage to the "Failure" group
            $crm->status()->add([
                'ENTITY_ID' => $entityId,
                'STATUS_ID' => 'DT' . $entityTypeId . '_' . $categoryId . ':MY_STAGE',
                'NAME' => 'My stage',
                'SORT' => 60,
                'SEMANTICS' => 'F',
            ]);
        
            // Verify the result
            $finalStages = $crm->status()->list(
                order: ['SORT' => 'ASC'],
                filter: ['ENTITY_ID' => $entityId]
            )->getStatuses();
        } catch (\Throwable $e) {
            echo 'Error: ' . $e->getMessage();
            exit;
        }
        
        $columns = ['In Progress' => [], 'Success' => [], 'Failure' => []];
        
        foreach ($finalStages as $stage) {
            if ($stage->SEMANTICS === 'S') {
                $columns['Success'][] = $stage->NAME;
            } elseif ($stage->SEMANTICS === 'F') {
                $columns['Failure'][] = $stage->NAME;
            } else {
                $columns['In Progress'][] = $stage->NAME;
            }
        }
        
        $maxRows = max(
            count($columns['In Progress']),
            count($columns['Success']),
            count($columns['Failure'])
        );
        
        echo "Stage table:\n";
        for ($i = 0; $i < $maxRows; $i++) {
            echo 'In Progress: ' . ($columns['In Progress'][$i] ?? '')
                . ' | Success: ' . ($columns['Success'][$i] ?? '')
                . ' | Failure: ' . ($columns['Failure'][$i] ?? '') . "\n";
        }