Добавить событие календаря для работы с клиентами

from b24pysdk import BitrixWebhook, Client


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

contact_id = 1
result_contact = client.crm.contact.get(
    bitrix_id=contact_id,
).response.result

// 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/');

$contactID = 1;
$resultContact = $sb->getCRMScope()->contact()->get($contactID)->contact();

// core, ctx и contactID объявлены в полном примере ниже
res, err := core.Call(ctx, "crm.contact.get",
	b24.Params{"id": contactID}, b24.WithIdempotent())
if err != nil {
	return fmt.Errorf("crm.contact.get: %w", err)
}

// Из ответа нужны телефон и ответственный. PHONE — мультиполе: список
// объектов, даже когда номер один, и приходит он только если у контакта
// вообще есть телефоны.
var contact struct {
	ID           b24.ID `json:"ID"`
	Name         string `json:"NAME"`
	LastName     string `json:"LAST_NAME"`
	AssignedByID b24.ID `json:"ASSIGNED_BY_ID"`
	Phone        []struct {
		ID        b24.ID `json:"ID"`
		Value     string `json:"VALUE"`
		ValueType string `json:"VALUE_TYPE"`
	} `json:"PHONE"`
}
if err := json.Unmarshal(res.Result, &contact); err != nil {
	return fmt.Errorf("разбор контакта: %w", err)
}
if len(contact.Phone) == 0 {
	return fmt.Errorf("у контакта %d нет телефона", contactID)
}

contact_phone = result_contact["PHONE"][0]

response = client.crm.activity.add(
    fields={
        "SUBJECT": "calendar title",
        "DESCRIPTION": "calendar body",
        "DESCRIPTION_TYPE": 3,
        "OWNER_ID": contact_id,
        "OWNER_TYPE_ID": 3,
        "TYPE_ID": 1,
        "COMMUNICATIONS": [
            {
                "VALUE": contact_phone["VALUE"],
                "ENTITY_ID": contact_id,
                "ENTITY_TYPE_ID": 3,
            }
        ],
        "START_TIME": "2025-05-20T14:00:00",
        "END_TIME": "2025-05-20T15:00:00",
        "RESPONSIBLE_ID": result_contact["ASSIGNED_BY_ID"],
    }
).response

$phones = $resultContact->PHONE;
$contactPhone = reset($phones);

$result = $sb->getCRMScope()->activity()->add(
    [
        "SUBJECT" => "calendar title",
        "DESCRIPTION" => "calendar body",
        "DESCRIPTION_TYPE" => 3,
        "OWNER_ID" => $contactID,
        "OWNER_TYPE_ID" => 3,
        "TYPE_ID" => 1,
        "COMMUNICATIONS" => [
            [
                'VALUE' => $contactPhone->VALUE,
                'ENTITY_ID' => $contactID,
                'ENTITY_TYPE_ID' => 3
            ]
        ],
        "START_TIME" => "2025-05-20T14:00:00",
        "END_TIME" => "2025-05-20T15:00:00",
        "RESPONSIBLE_ID" => $resultContact->ASSIGNED_BY_ID,
    ]
);

// core, ctx и contact объявлены в полном примере ниже.
// Время начала и окончания — в формате ISO 8601. Здесь встреча на час,
// завтра в это же время.
start := time.Now().Add(24 * time.Hour)

res, err = core.Call(ctx, "crm.activity.add", b24.Params{
	"fields": b24.Params{
		"SUBJECT":     "Встреча с клиентом",
		"DESCRIPTION": "Обсудить условия поставки",
		// 1 — обычный текст, 2 — HTML, 3 — BB-код.
		"DESCRIPTION_TYPE": 3,
		"OWNER_ID":         contact.ID,
		"OWNER_TYPE_ID":    entityTypeContact,
		// 1 — встреча; полный список типов дел отдаёт crm.enum.activitytype.
		"TYPE_ID": 1,
		// COMMUNICATIONS связывает событие с контактными данными клиента:
		// значение берётся из мультиполя PHONE, полученного на шаге 1.
		"COMMUNICATIONS": []b24.Params{{
			"VALUE":          contact.Phone[0].Value,
			"ENTITY_ID":      contact.ID,
			"ENTITY_TYPE_ID": entityTypeContact,
		}},
		"START_TIME":     start.Format(time.RFC3339),
		"END_TIME":       start.Add(time.Hour).Format(time.RFC3339),
		"RESPONSIBLE_ID": contact.AssignedByID,
	},
})
if err != nil {
	return fmt.Errorf("crm.activity.add: %w", err)
}

// Обёртки нет: result — сразу идентификатор созданного дела.
var activityID b24.ID
if err := json.Unmarshal(res.Result, &activityID); err != nil {
	return fmt.Errorf("разбор идентификатора события: %w", err)
}

activities = client.crm.activity.list(
    filter={
        "OWNER_TYPE_ID": 3,
        "OWNER_ID": contact_id,
    },
    select=["*", "COMMUNICATIONS"],
    order={"ID": "DESC"},
).response.result

// у crm.activity.list нет обертки в SDK — вызываем метод напрямую
$activities = $sb->core->call(
    'crm.activity.list',
    [
        'filter' => [
            'OWNER_TYPE_ID' => 3,
            'OWNER_ID' => $contactID,
        ],
        'select' => ['*', 'COMMUNICATIONS'],
        'order' => ['ID' => 'DESC'],
    ]
)->getResponseData()->getResult();

from datetime import datetime, timedelta

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

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

contact_id = 1
result_activity = None

try:
    contact = client.crm.contact.get(bitrix_id=contact_id).response.result

    if contact.get("ASSIGNED_BY_ID") and contact.get("PHONE"):
        contact_phone = contact["PHONE"][0]
        staff_id = contact["ASSIGNED_BY_ID"]
        now = datetime.now()
        result_activity = client.crm.activity.add(
            fields={
                "SUBJECT": "calendar title",
                "DESCRIPTION": "calendar body",
                "DESCRIPTION_TYPE": 3,
                "OWNER_ID": contact_id,
                "OWNER_TYPE_ID": 3,
                "TYPE_ID": 1,
                "COMMUNICATIONS": [
                    {
                        "VALUE": contact_phone["VALUE"],
                        "ENTITY_ID": contact_id,
                        "ENTITY_TYPE_ID": 3,
                    }
                ],
                "START_TIME": now.isoformat(timespec="seconds"),
                "END_TIME": (now + timedelta(hours=1)).isoformat(timespec="seconds"),
                "RESPONSIBLE_ID": staff_id,
            }
        ).response
except BitrixAPIError as error:
    print({"message": f"Activity not added: {error}"})
else:
    if result_activity and result_activity.result:
        print({"message": "Activity add"})
    else:
        print({"message": "Activity not added"})

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

$contactID = 1;
try {
    $resultContact = $sb->getCRMScope()->contact()->get($contactID)->contact();
    $resultActivity = null;
    if (!empty($resultContact->ASSIGNED_BY_ID) && !empty($resultContact->PHONE))
    {
        $phones = $resultContact->PHONE;
        $contactPhone = reset($phones);
        $staffID = $resultContact->ASSIGNED_BY_ID;
        $resultActivity = $sb->getCRMScope()->activity()->add(
            [
                "SUBJECT" => "calendar title",
                "DESCRIPTION" => "calendar body",
                "DESCRIPTION_TYPE" => 3,// тип текста (crm.enum.contenttype): обычный, HTML, BB-код
                "OWNER_ID" => $contactID,
                "OWNER_TYPE_ID" => 3, // crm.enum.ownertype
                "TYPE_ID" => 1, // crm.enum.activitytype
                "COMMUNICATIONS" => [
                    [
                        'VALUE' => $contactPhone->VALUE,
                        'ENTITY_ID' => $contactID,
                        'ENTITY_TYPE_ID' => 3// crm.enum.ownertype
                    ]
                ],
                "START_TIME" => date("Y-m-d H:i:s", time()),
                "END_TIME" => date("Y-m-d H:i:s", time() + 3600),
                "RESPONSIBLE_ID" => $staffID,
            ]
        )->getId();
    }
    if (!empty($resultActivity))
    {
        echo json_encode(['message' => 'Activity add']);
    }
    else
    {
        echo json_encode(['message' => 'Activity not added']);
    }
} catch (\Throwable $e) {
    echo json_encode(['message' => 'Activity not added: ' . $e->getMessage()]);
}

// Подготовка в пустом каталоге — 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"
	"fmt"
	"log"
	"os"
	"time"

	b24 "github.com/bitrix24/b24gosdk"
)

// entityTypeContact — идентификатор типа объекта «контакт» из crm.enum.ownertype.
const entityTypeContact = 3

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()

	// --- подготовка: свой контакт с телефоном

	contactID, err := addContact(ctx, core)
	if err != nil {
		return err
	}
	defer del(ctx, core, "crm.contact.delete", b24.Params{"id": contactID})

	// --- шаг 1: данные клиента
	res, err := core.Call(ctx, "crm.contact.get",
		b24.Params{"id": contactID}, b24.WithIdempotent())
	if err != nil {
		return fmt.Errorf("crm.contact.get: %w", err)
	}

	// Из ответа нужны телефон и ответственный. PHONE — мультиполе: список
	// объектов, даже когда номер один, и приходит он только если у контакта
	// вообще есть телефоны.
	var contact struct {
		ID           b24.ID `json:"ID"`
		Name         string `json:"NAME"`
		LastName     string `json:"LAST_NAME"`
		AssignedByID b24.ID `json:"ASSIGNED_BY_ID"`
		Phone        []struct {
			ID        b24.ID `json:"ID"`
			Value     string `json:"VALUE"`
			ValueType string `json:"VALUE_TYPE"`
		} `json:"PHONE"`
	}
	if err := json.Unmarshal(res.Result, &contact); err != nil {
		return fmt.Errorf("разбор контакта: %w", err)
	}
	if len(contact.Phone) == 0 {
		return fmt.Errorf("у контакта %d нет телефона", contactID)
	}
	fmt.Printf("контакт %d %s %s, телефон %s, ответственный %d\n",
		contact.ID, contact.Name, contact.LastName, contact.Phone[0].Value, contact.AssignedByID)

	// --- шаг 2: событие календаря
	// Время начала и окончания — в формате ISO 8601. Здесь встреча на час,
	// завтра в это же время.
	start := time.Now().Add(24 * time.Hour)

	res, err = core.Call(ctx, "crm.activity.add", b24.Params{
		"fields": b24.Params{
			"SUBJECT":     "Встреча с клиентом",
			"DESCRIPTION": "Обсудить условия поставки",
			// 1 — обычный текст, 2 — HTML, 3 — BB-код.
			"DESCRIPTION_TYPE": 3,
			"OWNER_ID":         contact.ID,
			"OWNER_TYPE_ID":    entityTypeContact,
			// 1 — встреча; полный список отдаёт crm.enum.activitytype.
			"TYPE_ID": 1,
			// COMMUNICATIONS связывает событие с контактными данными клиента:
			// значение берётся из мультиполя PHONE, полученного на шаге 1.
			"COMMUNICATIONS": []b24.Params{{
				"VALUE":          contact.Phone[0].Value,
				"ENTITY_ID":      contact.ID,
				"ENTITY_TYPE_ID": entityTypeContact,
			}},
			"START_TIME":     start.Format(time.RFC3339),
			"END_TIME":       start.Add(time.Hour).Format(time.RFC3339),
			"RESPONSIBLE_ID": contact.AssignedByID,
		},
	})
	if err != nil {
		return fmt.Errorf("crm.activity.add: %w", err)
	}

	// Обёртки нет: result — сразу идентификатор созданного события.
	var activityID b24.ID
	if err := json.Unmarshal(res.Result, &activityID); err != nil {
		return fmt.Errorf("разбор идентификатора события: %w", err)
	}
	defer del(ctx, core, "crm.activity.delete", b24.Params{"id": activityID})

	fmt.Printf("событие %d создано на %s\n", activityID, start.Format("02.01.2006 15:04"))
	return nil
}

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

// addContact создаёт контакт с телефоном: страница берёт готовый контакт с
// идентификатором 1, но на чужом портале это другой человек или никого.
func addContact(ctx context.Context, core *b24.Core) (b24.ID, error) {
	res, err := core.Call(ctx, "crm.contact.add", b24.Params{
		"fields": b24.Params{
			"NAME":      "Алексей",
			"LAST_NAME": "Вронский",
			// Мультиполе: строка без ID ДОБАВЛЯЕТ значение. MultifieldAdd
			// собирает её за вас, чтобы не путаться в ключах.
			"PHONE": []map[string]any{
				b24.MultifieldAdd("+7 800 100-10-20", "MOBILE"),
			},
		},
	})
	if err != nil {
		return 0, fmt.Errorf("crm.contact.add: %w", err)
	}
	var id b24.ID
	return id, json.Unmarshal(res.Result, &id)
}

// 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)
	}
}