Как прикрепить задачу к смарт-процессу

import os

from b24pysdk import BitrixWebhook, Client

client = Client(
    BitrixWebhook(
        domain="your-domain.bitrix24.com",
        webhook_token=os.environ["B24_HOOK_TOKEN"],
    )
)
# B24_HOOK_TOKEN = 'user_id/webhook_key'

result = client.crm.enum.ownertype().response.result

require_once 'vendor/autoload.php';

use Bitrix24\SDK\Services\ServiceBuilderFactory;
use Symfony\Component\EventDispatcher\EventDispatcher;
use Psr\Log\NullLogger;

$serviceBuilder = (new ServiceBuilderFactory(new EventDispatcher(), new NullLogger()))
    ->initFromWebhook(getenv('B24_HOOK'));
// B24_HOOK = 'https://your-domain.bitrix24.com/rest/USER_ID/TOKEN/'

$result = $serviceBuilder->getCRMScope()->enum()->ownerType()->getItems();

// Метод вызывается без параметров и возвращает и предустановленные типы
// объектов CRM, и смарт-процессы.
res, err := core.Call(ctx, "crm.enum.ownertype", nil, b24.WithIdempotent())
if err != nil {
	return fmt.Errorf("crm.enum.ownertype: %w", err)
}

var ownerTypes []struct {
	ID              int    `json:"ID"`
	Name            string `json:"NAME"`
	SymbolCode      string `json:"SYMBOL_CODE"`
	SymbolCodeShort string `json:"SYMBOL_CODE_SHORT"`
}
if err := json.Unmarshal(res.Result, &ownerTypes); err != nil {
	return fmt.Errorf("разбор типов объектов: %w", err)
}

// Ищем свой смарт-процесс по названию и запоминаем ДВА значения: ID — это
// entityTypeId для поиска элемента, SYMBOL_CODE_SHORT — первая половина
// значения привязки.
var entityTypeIDFound int
var symbolCodeShort string
for _, t := range ownerTypes {
	if t.Name == spaTitle {
		entityTypeIDFound, symbolCodeShort = t.ID, t.SymbolCodeShort
		break
	}
}
if symbolCodeShort == "" {
	return fmt.Errorf("смарт-процесс %q не найден в crm.enum.ownertype", spaTitle)
}

result = client.crm.item.list(
    entity_type_id=177,
    select=["id", "title"],
    filter={
        "title": "Стиральная машина",
    },
).response.result

$result = $serviceBuilder->getCRMScope()->item()->list(
    177, // ID из результата crm.enum.ownertype
    [], // сортировка
    [
        'title' => 'Стиральная машина', // название элемента
    ],
    [
        'id', // выбираемые поля
        'title',
    ]
)->getItems();

res, err = core.Call(ctx, "crm.item.list", b24.Params{
	"entityTypeId": entityTypeIDFound,
	"select":       []string{"id", "title"},
	"filter":       b24.Params{"title": itemTitle},
}, b24.WithIdempotent())
if err != nil {
	return fmt.Errorf("crm.item.list: %w", err)
}

// Метод заворачивает ответ в объект с ключом items. Одинаковые названия
// никто не запрещает, поэтому ответ — список даже при точном фильтре.
var list struct {
	Items []struct {
		ID    int    `json:"id"`
		Title string `json:"title"`
	} `json:"items"`
}
if err := json.Unmarshal(res.Result, &list); err != nil {
	return fmt.Errorf("разбор элементов: %w", err)
}
if len(list.Items) == 0 {
	return fmt.Errorf("элемент %q не найден", itemTitle)
}

result = client.tasks.task.add(
    fields={
        "TITLE": "task for test",
        "RESPONSIBLE_ID": 1,
        "UF_CRM_TASK": [
            "Tb1_29",
        ],
    }
).response.result

$result = $serviceBuilder->core->call(
    'tasks.task.add',
    [
        'fields' => [
            'TITLE' => 'task for test', // название задачи
            'RESPONSIBLE_ID' => 1, // исполнитель
            'UF_CRM_TASK' => [ // массив элементов CRM
                'Tb1_29'
            ]
        ]
    ]
)->getResponseData()->getResult();

// Значение привязки собирается из ответов, а не из готовой строки: краткий
// код зависит от entityTypeId и на другом портале будет другим.
binding := symbolCodeShort + "_" + strconv.Itoa(list.Items[0].ID)

res, err = core.Call(ctx, "tasks.task.add", b24.Params{
	"fields": b24.Params{
		"TITLE":          "Проверить оборудование (b24gosdk)",
		"RESPONSIBLE_ID": userID,
		// UF_CRM_TASK — всегда массив, даже когда привязка одна.
		"UF_CRM_TASK": []string{binding},
	},
})
if err != nil {
	return fmt.Errorf("tasks.task.add: %w", err)
}

// tasks.* заворачивает ответ в объект с ключом task, и идентификатор задачи
// приходит СТРОКОЙ ("3731"): b24.ID разбирает и число, и строку с числом.
var added struct {
	Task struct {
		ID    b24.ID `json:"id"`
		Title string `json:"title"`
	} `json:"task"`
}
if err := json.Unmarshal(res.Result, &added); err != nil {
	return fmt.Errorf("разбор созданной задачи: %w", err)
}

import os

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

smart_process_name = "название_смарт_процесса"
item_name = "название_элемента"
responsible_id = 1
task_title = "название_задачи"


def create_task_with_smart_process(client, smart_process_name, item_name, responsible_id, task_title):
    try:
        result = client.crm.enum.ownertype().response.result
    except BitrixAPIError as error:
        print(f"Ошибка получения типов сущностей: {error}")
        return

    smart_process = None
    for process in result:
        if process["NAME"] == smart_process_name:
            smart_process = process
            break

    if smart_process is None:
        print("Смарт-процесс не найден")
        return

    symbol_code_short = smart_process["SYMBOL_CODE_SHORT"]

    try:
        item_result = client.crm.item.list(
            entity_type_id=int(smart_process["ID"]),
            select=["id", "title"],
            filter={"title": item_name},
        ).response.result
    except BitrixAPIError as error:
        print(f"Ошибка получения элементов смарт-процесса: {error}")
        return

    if len(item_result["items"]) == 0:
        print("Элемент смарт-процесса не найден")
        return

    item_id = item_result["items"][0]["id"]

    try:
        task_result = client.tasks.task.add(
            fields={
                "TITLE": task_title,
                "RESPONSIBLE_ID": responsible_id,
                "UF_CRM_TASK": [f"{symbol_code_short}_{item_id}"],
            }
        ).response.result
    except BitrixAPIError as error:
        print(f"Ошибка создания задачи: {error}")
    else:
        print("Задача успешно создана!")
        print(task_result)


client = Client(
    BitrixWebhook(
        domain="your-domain.bitrix24.com",
        webhook_token=os.environ["B24_HOOK_TOKEN"],
    )
)
# B24_HOOK_TOKEN = 'user_id/webhook_key'

create_task_with_smart_process(client, smart_process_name, item_name, responsible_id, task_title)

require_once 'vendor/autoload.php';

use Bitrix24\SDK\Services\ServiceBuilderFactory;
use Bitrix24\SDK\Core\Exceptions\BaseException;
use Symfony\Component\EventDispatcher\EventDispatcher;
use Psr\Log\NullLogger;

$serviceBuilder = (new ServiceBuilderFactory(new EventDispatcher(), new NullLogger()))
    ->initFromWebhook(getenv('B24_HOOK'));
// B24_HOOK = 'https://your-domain.bitrix24.com/rest/USER_ID/TOKEN/'

// Переменные для ввода данных пользователем
$smartProcessName = 'название_смарт_процесса'; // Название смарт-процесса
$itemName = 'название_элемента'; // Название элемента смарт-процесса
$responsibleId = 1; // ID ответственного за задачу, число
$taskTitle = 'название_задачи'; // Название задачи

// Функция для создания задачи с привязкой к элементу смарт-процесса
function createTaskWithSmartProcess($serviceBuilder, $smartProcessName, $itemName, $responsibleId, $taskTitle) {
    // Получение идентификаторов типов сущностей и смарт-процессов
    try {
        $ownerTypes = $serviceBuilder->getCRMScope()->enum()->ownerType()->getItems();
    } catch (BaseException $e) {
        echo 'Ошибка при получении типов сущностей: ' . $e->getMessage();
        return;
    }

    // Поиск нужного смарт-процесса
    $smartProcess = null;
    foreach ($ownerTypes as $process) {
        if ($process->NAME === $smartProcessName) {
            $smartProcess = $process;
            break;
        }
    }

    if (!$smartProcess) {
        echo 'Смарт-процесс не найден';
        return;
    }

    $symbolCodeShort = $smartProcess->SYMBOL_CODE_SHORT;

    // Поиск элемента смарт-процесса с использованием фильтра по названию
    try {
        $items = $serviceBuilder->getCRMScope()->item()->list(
            $smartProcess->ID,
            [],
            ['title' => $itemName],
            ['id', 'title']
        )->getItems();
    } catch (BaseException $e) {
        echo 'Ошибка при получении элементов смарт-процесса: ' . $e->getMessage();
        return;
    }

    if (count($items) === 0) {
        echo 'Элемент смарт-процесса не найден';
        return;
    }

    $itemId = $items[0]->id;

    // Создание задачи
    try {
        $taskResult = $serviceBuilder->core->call('tasks.task.add', [
            'fields' => [
                'TITLE' => $taskTitle, // Используем введенное название задачи
                'RESPONSIBLE_ID' => $responsibleId, // Добавляем ID ответственного
                'UF_CRM_TASK' => [$symbolCodeShort . '_' . $itemId]
            ]
        ])->getResponseData()->getResult();
    } catch (BaseException $e) {
        echo 'Ошибка при создании задачи: ' . $e->getMessage();
        return;
    }

    echo 'Задача успешно создана!';
    print_r($taskResult);
}

// Вызов функции для создания задачи
createTaskWithSmartProcess($serviceBuilder, $smartProcessName, $itemName, $responsibleId, $taskTitle);

// Подготовка в пустом каталоге — go get без go mod init не сработает:
//
//	go mod init example && go get github.com/bitrix24/b24gosdk
//
// Запуск:
//
//	export B24_WEBHOOK_URL='https://ваш-портал.bitrix24.ru/rest/1/токен/' && go run .
//
// Пример самодостаточный: он создаёт смарт-процесс, разрешённый для поля задач,
// добавляет в него элемент, собирает значение привязки, создаёт задачу,
// проверяет привязку и убирает за собой. Запускается на любом портале, ничего
// править не нужно.
package main

import (
	"context"
	"encoding/json"
	"errors"
	"fmt"
	"log"
	"os"
	"strconv"

	b24 "github.com/bitrix24/b24gosdk"
)

const (
	spaTitle  = "Закупка оборудования (пример b24gosdk)"
	itemTitle = "Стиральная машина"
)

func main() {
	if err := run(context.Background()); err != nil {
		log.Fatal(err)
	}
}

func run(ctx context.Context) error {
	// Путь вебхука — это секрет, поэтому он приходит из окружения, а не из кода.
	core := b24.NewClient(os.Getenv("B24_WEBHOOK_URL")).Core()

	// --- подготовка: смарт-процесс, который разрешено класть в поле задачи

	entityTypeID, typeID, err := addType(ctx, core, spaTitle)
	if err != nil {
		return err
	}
	defer del(ctx, core, "crm.type.delete", b24.Params{"id": typeID})

	itemID, err := addItem(ctx, core, entityTypeID, itemTitle)
	if err != nil {
		return err
	}
	defer del(ctx, core, "crm.item.delete", b24.Params{
		"entityTypeId": entityTypeID, "id": itemID,
	})

	userID, err := currentUser(ctx, core)
	if err != nil {
		return err
	}

	// --- шаг 1: идентификаторы смарт-процесса
	// Метод вызывается без параметров и возвращает и предустановленные типы
	// объектов CRM, и смарт-процессы.
	res, err := core.Call(ctx, "crm.enum.ownertype", nil, b24.WithIdempotent())
	if err != nil {
		return fmt.Errorf("crm.enum.ownertype: %w", err)
	}

	var ownerTypes []struct {
		ID              int    `json:"ID"`
		Name            string `json:"NAME"`
		SymbolCode      string `json:"SYMBOL_CODE"`
		SymbolCodeShort string `json:"SYMBOL_CODE_SHORT"`
	}
	if err := json.Unmarshal(res.Result, &ownerTypes); err != nil {
		return fmt.Errorf("разбор типов объектов: %w", err)
	}

	// Ищем свой смарт-процесс по названию и запоминаем ДВА значения: ID — это
	// entityTypeId для поиска элемента, SYMBOL_CODE_SHORT — первая половина
	// значения привязки.
	var entityTypeIDFound int
	var symbolCodeShort string
	for _, t := range ownerTypes {
		if t.Name == spaTitle {
			entityTypeIDFound, symbolCodeShort = t.ID, t.SymbolCodeShort
			break
		}
	}
	if symbolCodeShort == "" {
		return fmt.Errorf("смарт-процесс %q не найден в crm.enum.ownertype", spaTitle)
	}
	fmt.Printf("смарт-процесс %q: entityTypeId=%d, краткий код %q\n",
		spaTitle, entityTypeIDFound, symbolCodeShort)

	// --- шаг 2: идентификатор элемента
	res, err = core.Call(ctx, "crm.item.list", b24.Params{
		"entityTypeId": entityTypeIDFound,
		"select":       []string{"id", "title"},
		"filter":       b24.Params{"title": itemTitle},
	}, b24.WithIdempotent())
	if err != nil {
		return fmt.Errorf("crm.item.list: %w", err)
	}

	// Метод заворачивает ответ в объект с ключом items. Одинаковые названия
	// никто не запрещает, поэтому ответ — список даже при точном фильтре.
	var list struct {
		Items []struct {
			ID    int    `json:"id"`
			Title string `json:"title"`
		} `json:"items"`
	}
	if err := json.Unmarshal(res.Result, &list); err != nil {
		return fmt.Errorf("разбор элементов: %w", err)
	}
	if len(list.Items) == 0 {
		return fmt.Errorf("элемент %q не найден", itemTitle)
	}
	fmt.Printf("элемент %q: id=%d\n", list.Items[0].Title, list.Items[0].ID)

	// --- шаг 3: задача с привязкой
	// Значение привязки собирается из ответов, а не из готовой строки: краткий
	// код зависит от entityTypeId и на другом портале будет другим.
	binding := symbolCodeShort + "_" + strconv.Itoa(list.Items[0].ID)

	res, err = core.Call(ctx, "tasks.task.add", b24.Params{
		"fields": b24.Params{
			"TITLE":          "Проверить оборудование (b24gosdk)",
			"RESPONSIBLE_ID": userID,
			// UF_CRM_TASK — всегда массив, даже когда привязка одна.
			"UF_CRM_TASK": []string{binding},
		},
	})
	if err != nil {
		return fmt.Errorf("tasks.task.add: %w", err)
	}

	// tasks.* заворачивает ответ в объект с ключом task, и идентификатор задачи
	// приходит СТРОКОЙ ("3731"): b24.ID разбирает и число, и строку с числом.
	var added struct {
		Task struct {
			ID    b24.ID `json:"id"`
			Title string `json:"title"`
		} `json:"task"`
	}
	if err := json.Unmarshal(res.Result, &added); err != nil {
		return fmt.Errorf("разбор созданной задачи: %w", err)
	}
	defer del(ctx, core, "tasks.task.delete", b24.Params{"taskId": added.Task.ID})
	fmt.Printf("задача %d создана с привязкой %s\n", added.Task.ID, binding)

	// --- проверка: привязка действительно сохранилась
	// Без UF_CRM_TASK в select привязки в ответе не будет: это системное поле,
	// по умолчанию оно не возвращается.
	res, err = core.Call(ctx, "tasks.task.get", b24.Params{
		"taskId": added.Task.ID,
		"select": []string{"ID", "UF_CRM_TASK"},
	}, b24.WithIdempotent())
	if err != nil {
		return fmt.Errorf("tasks.task.get: %w", err)
	}

	// Просили UF_CRM_TASK, а в ответе поле называется ufCrmTask. UnwrapFold
	// сравнивает имена без учёта регистра и подчёркиваний, поэтому такое
	// переименование её не сбивает.
	raw, ok := b24.UnwrapFold(res.Result, "task", "UF_CRM_TASK")
	if !ok || b24.IsEmpty(raw) {
		return fmt.Errorf("привязка не сохранилась у задачи %d", added.Task.ID)
	}
	var bindings []string
	if err := json.Unmarshal(raw, &bindings); err != nil {
		return fmt.Errorf("разбор привязок: %w", err)
	}
	fmt.Printf("в задаче %d поле «Элементы CRM» = %v\n", added.Task.ID, bindings)
	return nil
}

// --- вспомогательное: подготовка данных и уборка

// addType создаёт смарт-процесс и возвращает его entityTypeId и id.
func addType(ctx context.Context, core *b24.Core, title string) (int, b24.ID, error) {
	// Двух настроек мало по отдельности: isUseInUserfieldEnabled разрешает
	// смарт-процесс в пользовательских полях вообще, а linkedUserFields кладёт
	// его именно в поле задачи UF_CRM_TASK. Без второй привязка не сохранится.
	//
	// isRecyclebinEnabled выключаем осознанно: элемент в корзине всё ещё
	// считается элементом, а crm.type.delete отказывается удалять тип, у
	// которого есть элементы.
	res, err := core.Call(ctx, "crm.type.add", b24.Params{
		"fields": b24.Params{
			"title":                   title,
			"isUseInUserfieldEnabled": "Y",
			"linkedUserFields":        b24.Params{"TASKS_TASK|UF_CRM_TASK": "true"},
			"isRecyclebinEnabled":     "N",
		},
	})
	if err != nil {
		// Код ошибки сравнивается через errors.Is, а не строкой: опечатка в
		// литерале скомпилируется и молча уведёт в другую ветку.
		if errors.Is(err, b24.Code("CREATE_DYNAMIC_TYPE_RESTRICTED")) {
			return 0, 0, fmt.Errorf("на этом портале нельзя создать смарт-процесс: %w", err)
		}
		return 0, 0, fmt.Errorf("crm.type.add: %w", err)
	}
	var out struct {
		Type struct {
			ID           b24.ID `json:"id"`
			EntityTypeID int    `json:"entityTypeId"`
		} `json:"type"`
	}
	if err := json.Unmarshal(res.Result, &out); err != nil {
		return 0, 0, fmt.Errorf("разбор смарт-процесса: %w", err)
	}
	return out.Type.EntityTypeID, out.Type.ID, nil
}

func addItem(ctx context.Context, core *b24.Core, entityTypeID int, title string) (b24.ID, error) {
	res, err := core.Call(ctx, "crm.item.add", b24.Params{
		"entityTypeId": entityTypeID,
		"fields":       b24.Params{"title": title},
	})
	if err != nil {
		return 0, fmt.Errorf("crm.item.add: %w", err)
	}
	raw, ok := b24.Unwrap(res.Result, "item", "id")
	if !ok {
		return 0, fmt.Errorf("нет item.id в %s", res.Result)
	}
	var id b24.ID
	return id, json.Unmarshal(raw, &id)
}

func currentUser(ctx context.Context, core *b24.Core) (b24.ID, error) {
	res, err := core.Call(ctx, "user.current", nil, b24.WithIdempotent())
	if err != nil {
		return 0, fmt.Errorf("user.current: %w", err)
	}
	var u struct {
		ID b24.ID `json:"ID"`
	}
	if err := json.Unmarshal(res.Result, &u); err != nil {
		return 0, err
	}
	return u.ID, nil
}

// del убирает созданное. Ошибку уборки печатаем, но не возвращаем: она не
// должна подменить собой настоящую ошибку сценария.
func del(ctx context.Context, core *b24.Core, method string, params b24.Params) {
	if _, err := core.Call(ctx, method, params); err != nil {
		fmt.Fprintf(os.Stderr, "уборка, %s: %v\n", method, err)
	}
}

result = client.tasks.task.get(
    bitrix_id=3731,
    select=["ID", "UF_CRM_TASK"],
).response.result

$result = $serviceBuilder->core->call(
    'tasks.task.get',
    [
        'taskId' => 3731, // ID задачи
        'select' => ['ID', 'UF_CRM_TASK'] // выбираемые поля
    ]
)->getResponseData()->getResult();

// Без UF_CRM_TASK в select привязки в ответе не будет: это системное поле,
// по умолчанию оно не возвращается.
res, err = core.Call(ctx, "tasks.task.get", b24.Params{
	"taskId": added.Task.ID,
	"select": []string{"ID", "UF_CRM_TASK"},
}, b24.WithIdempotent())
if err != nil {
	return fmt.Errorf("tasks.task.get: %w", err)
}

// Просили UF_CRM_TASK, а в ответе поле называется ufCrmTask. UnwrapFold
// сравнивает имена без учёта регистра и подчёркиваний, поэтому такое
// переименование её не сбивает.
raw, ok := b24.UnwrapFold(res.Result, "task", "UF_CRM_TASK")
if !ok || b24.IsEmpty(raw) {
	return fmt.Errorf("привязка не сохранилась у задачи %d", added.Task.ID)
}
var bindings []string
if err := json.Unmarshal(raw, &bindings); err != nil {
	return fmt.Errorf("разбор привязок: %w", err)
}