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

require_once 'vendor/autoload.php';
        
        use Bitrix24\SDK\Services\ServiceBuilderFactory;
        use Symfony\Component\EventDispatcher\EventDispatcher;
        use Monolog\Logger;
        use Monolog\Handler\StreamHandler;
        
        $logger = new Logger('b24');
        $logger->pushHandler(new StreamHandler('php://stdout'));
        
        $serviceBuilder = (new ServiceBuilderFactory(new EventDispatcher(), $logger))
            ->initFromWebhook('https://your-domain.bitrix24.com/rest/USER_ID/TOKEN/');
        
        $types = $serviceBuilder->getCRMScope()->type()
            ->list([], ['title' => 'Equipment procurement'])
            ->getTypes();
        $entityTypeId = $types[0]->entityTypeId;
        

from b24pysdk import BitrixWebhook, Client
        
        client = Client(
            BitrixWebhook(
                domain="your-domain.bitrix24.com",
                webhook_token="user_id/webhook_key",
            )
        )
        
        entity_type_id = int(
            client.crm.type.list(
                filter={"title": "Equipment procurement"},
            ).response.result["types"][0]["entityTypeId"]
        )
        

$result = $serviceBuilder->core->call(
            'crm.category.add',
            [
                'entityTypeId' => $entityTypeId,
                'fields' => [
                    'name' => 'New funnel',
                    'sort' => 100,
                ]
            ]
        );
        $categoryId = $result->getResponseData()->getResult()['category']['id'];
        

category_id = int(
            client.crm.category.add(
                entity_type_id=entity_type_id,
                fields={
                    "name": "New funnel",
                    "sort": 100,
                },
            ).response.result["category"]["id"]
        )
        

$entityId = "DYNAMIC_{$entityTypeId}_STAGE_{$categoryId}";
        $stages = $serviceBuilder->getCRMScope()->status()
            ->list([], ['ENTITY_ID' => $entityId])
            ->getStatuses();
        

entity_id = f"DYNAMIC_{entity_type_id}_STAGE_{category_id}"
        stages = client.crm.status.list(
            filter={"ENTITY_ID": entity_id},
        ).response.result
        

$result = $serviceBuilder->getCRMScope()->status()->update(
            $stageId,
            [
                'NAME' => 'New name',
            ]
        );
        

client.crm.status.update(
            stage_id,
            fields={
                "NAME": "New name",
            },
        ).response
        

$result = $serviceBuilder->getCRMScope()->status()->add(
            [
                'ENTITY_ID' => $entityId,
                'STATUS_ID' => 'DT' . $entityTypeId . '_' . $categoryId . ':MY_STAGE',
                'NAME' => 'My stage',
                'SORT' => 60,
                'SEMANTICS' => 'F',
            ]
        );
        $newStageId = $result->getId();
        

new_stage_id = 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.result
        

<?php
        require_once 'vendor/autoload.php';
        
        use Bitrix24\SDK\Services\ServiceBuilderFactory;
        use Symfony\Component\EventDispatcher\EventDispatcher;
        use Monolog\Logger;
        use Monolog\Handler\StreamHandler;
        
        $logger = new Logger('b24');
        $logger->pushHandler(new StreamHandler('php://stdout'));
        
        $serviceBuilder = (new ServiceBuilderFactory(new EventDispatcher(), $logger))
            ->initFromWebhook('https://your-domain.bitrix24.com/rest/USER_ID/TOKEN/');
        
        $crm = $serviceBuilder->getCRMScope();
        
        try {
            // 1. Get entityTypeId by smart process name
            $types = $crm->type()
                ->list([], ['title' => 'Equipment procurement'])
                ->getTypes();
            $entityTypeId = $types[0]->entityTypeId;
        
            // 2. Create a new funnel
            $result = $serviceBuilder->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. Get the list of stages
            $stages = $crm->status()
                ->list([], ['ENTITY_ID' => $entityId])
                ->getStatuses();
        
            // 4. Change the first stage
            if (!empty($stages)) {
                $firstStageId = $stages[0]->ID;
                $crm->status()->update($firstStageId, ['NAME' => 'First stage']);
            }
        
            // 5. Add a new stage
            $crm->status()->add([
                'ENTITY_ID' => $entityId,
                'STATUS_ID' => 'DT' . $entityTypeId . '_' . $categoryId . ':MY_STAGE',
                'NAME' => 'My stage',
                'SORT' => 60,
                'SEMANTICS' => 'F',
            ]);
        
            // 6. Get the final stages table
            $stages = $crm->status()
                ->list([], ['ENTITY_ID' => $entityId])
                ->getStatuses();
        } catch (\Throwable $e) {
            echo 'Error: ' . $e->getMessage();
            exit;
        }
        
        // Form the stages table
        $columns = [
            'In progress' => [],
            'Success' => [],
            'Failure' => []
        ];
        
        foreach ($stages as $stage) {
            $semantics = $stage->EXTRA['SEMANTICS'] ?? $stage->SEMANTICS;
            if ($semantics === 'S') {
                $columns['Success'][] = $stage->NAME;
            } elseif ($semantics === 'F') {
                $columns['Failure'][] = $stage->NAME;
            } else {
                $columns['In progress'][] = $stage->NAME;
            }
        }
        
        // Determine the maximum number of rows
        $maxRows = max(
            count($columns['In progress']),
            count($columns['Success']),
            count($columns['Failure'])
        );
        
        // Create an array of objects for output
        $tableData = [];
        
        for ($i = 0; $i < $maxRows; $i++) {
            $tableData[] = [
                'In progress' => $columns['In progress'][$i] ?? '',
                'Success' => $columns['Success'][$i] ?? '',
                'Failure' => $columns['Failure'][$i] ?? ''
            ];
        }
        
        // Display the table 
        echo "Stages table:\n";
        foreach ($tableData as $row) {
            echo "In progress: " . $row['In progress'] . " | Success: " . $row['Success'] . " | Failure: " . $row['Failure'] . "\n";
        }
        

from b24pysdk import BitrixWebhook, Client
        from b24pysdk.errors import BitrixAPIError
        
        def print_stages_table(stages):
            columns = {
                "In progress": [],
                "Success": [],
                "Failure": [],
            }
        
            for stage in stages:
                semantics = (stage.get("EXTRA") or {}).get("SEMANTICS") or stage.get("SEMANTICS")
                if semantics == "S":
                    columns["Success"].append(stage["NAME"])
                elif semantics == "F":
                    columns["Failure"].append(stage["NAME"])
                else:
                    columns["In progress"].append(stage["NAME"])
        
            max_rows = max(
                len(columns["In progress"]),
                len(columns["Success"]),
                len(columns["Failure"]),
            )
        
            table_data = []
            for index in range(max_rows):
                table_data.append(
                    {
                        "In progress": columns["In progress"][index] if index < len(columns["In progress"]) else "",
                        "Success": columns["Success"][index] if index < len(columns["Success"]) else "",
                        "Failure": columns["Failure"][index] if index < len(columns["Failure"]) else "",
                    }
                )
        
            for row in table_data:
                print(
                    "In progress: "
                    + row["In progress"]
                    + " | Success: "
                    + row["Success"]
                    + " | Failure: "
                    + row["Failure"]
                )
        
        client = Client(
            BitrixWebhook(
                domain="your-domain.bitrix24.com",
                webhook_token="user_id/webhook_key",
            )
        )
        
        try:
            entity_type_id = int(
                client.crm.type.list(
                    filter={"title": "Equipment procurement"},
                ).response.result["types"][0]["entityTypeId"]
            )
        
            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}"
        
            stages = client.crm.status.list(
                filter={"ENTITY_ID": entity_id},
            ).response.result
        
            if stages:
                first_stage_id = int(stages[0]["ID"])
                client.crm.status.update(
                    first_stage_id,
                    fields={
                        "NAME": "First stage",
                    },
                ).response
        
            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
        
            stages = client.crm.status.list(
                filter={"ENTITY_ID": entity_id},
            ).response.result
        except BitrixAPIError as error:
            print(f"Error: {error}")
        else:
            print("Stages table:")
            print_stages_table(stages)