Как найти дубликаты в CRM по телефону и email

$phone = readline("Введите номер телефона: ");
        $email = readline("Введите email: ");
        
        $entityIDs = [
            'LEAD' => [],
            'CONTACT' => [],
            'COMPANY' => []
        ];
        $resultEntity = [
            'lead' => [],
            'contact' => [],
            'company' => []
        ];
        

phone = input("Введите номер телефона: ")
        email = input("Введите email: ")
        
        entity_ids = {
            "LEAD": [],
            "CONTACT": [],
            "COMPANY": [],
        }
        
        result_entity = {
            "lead": [],
            "contact": [],
            "company": [],
        }
        

// Телефон и почта, по которым ищем. Соседние вкладки спрашивают их у
        // пользователя; здесь они заданы константами, потому что пример сам создаёт
        // объекты с этими значениями.
        const (
        	phone = "+7 900 555-35-35"
        	email = "duplicate@example.com"
        )
        
        // Идентификаторы найденных объектов и подробные данные по ним. Ключи —
        // те же, что возвращает crm.duplicate.findbycomm.
        entityIDs := map[string][]b24.ID{"LEAD": nil, "CONTACT": nil, "COMPANY": nil}
        rows := make([]row, 0)
        

use Bitrix24\SDK\Services\CRM\Duplicates\Result\DuplicateResult;
        
        // Объединяет идентификаторы из ответа метода с массивом $entityIDs
        function mergeDuplicates(DuplicateResult $result, array &$entityIDs): void
        {
            $data = $result->getCoreResponse()->getResponseData()->getResult();
            foreach (['LEAD', 'CONTACT', 'COMPANY'] as $type) {
                if (!empty($data[$type]) && is_array($data[$type])) {
                    $entityIDs[$type] = array_merge($entityIDs[$type], $data[$type]);
                }
            }
        }
        
        if($phone)
        {
            mergeDuplicates($sb->getCRMScope()->duplicate()->findByPhone([$phone]), $entityIDs);
        }
        
        if($email)
        {
            mergeDuplicates($sb->getCRMScope()->duplicate()->findByEmail([$email]), $entityIDs);
        }
        

if phone:
            result = client.crm.duplicate.findbycomm(
                type="PHONE",
                values=[phone],
            ).result
            for key in entity_ids:
                if isinstance(result.get(key), list):
                    entity_ids[key].extend(result[key])
        
        if email:
            result = client.crm.duplicate.findbycomm(
                type="EMAIL",
                values=[email],
            ).result
            for key in entity_ids:
                if isinstance(result.get(key), list):
                    entity_ids[key].extend(result[key])
        

// Метод ищет по ОДНОМУ типу коммуникации за вызов, поэтому телефон и почту
        // опрашиваем отдельно, а идентификаторы копим в общей карте.
        for _, comm := range []struct{ typ, value string }{
        	{"PHONE", phone},
        	{"EMAIL", email},
        } {
        	if comm.value == "" {
        		continue
        	}
        	res, err := core.Call(ctx, "crm.duplicate.findbycomm", b24.Params{
        		"type":   comm.typ,
        		"values": []string{comm.value},
        	}, b24.WithIdempotent())
        	if err != nil {
        		return fmt.Errorf("crm.duplicate.findbycomm %s: %w", comm.typ, err)
        	}
        
        	// Ответ — объект с ключами LEAD, CONTACT, COMPANY. Ключа может не быть
        	// вовсе: если по этому типу ничего не нашлось, его просто не пришлют.
        	var found map[string][]b24.ID
        	if err := json.Unmarshal(res.Result, &found); err != nil {
        		return fmt.Errorf("разбор дубликатов: %w", err)
        	}
        	for key := range entityIDs {
        		entityIDs[key] = appendUnique(entityIDs[key], found[key])
        	}
        }
        

if(!empty($entityIDs['LEAD']))
        {
            $leads = $sb->getCRMScope()->lead()->list(
                [],
                ['ID' => $entityIDs['LEAD']],
                ['ID', 'NAME', 'LAST_NAME', 'PHONE', 'EMAIL', 'TITLE']
            )->getLeads();
            if(!empty($leads))
            {
                $resultEntity['lead'] = $leads;
            }
        }
        

if entity_ids["LEAD"]:
            result = client.crm.lead.list(
                filter={"ID": entity_ids["LEAD"]},
                select=["ID", "NAME", "LAST_NAME", "PHONE", "EMAIL", "TITLE"],
            ).result
        
            if result:
                result_entity["lead"] = result
        

res, err := core.Call(ctx, "crm.lead.list", b24.Params{
        	"filter": b24.Params{"ID": entityIDs["LEAD"]},
        	"select": []string{"ID", "NAME", "LAST_NAME", "PHONE", "EMAIL", "TITLE"},
        }, b24.WithIdempotent())
        if err != nil {
        	return fmt.Errorf("crm.lead.list: %w", err)
        }
        var leads []entity
        if err := json.Unmarshal(res.Result, &leads); err != nil {
        	return fmt.Errorf("разбор лидов: %w", err)
        }
        for _, e := range leads {
        	rows = append(rows, e.row("лид"))
        }
        

if(!empty($entityIDs['CONTACT']))
        {
            $contacts = $sb->getCRMScope()->contact()->list(
                [],
                ['ID' => $entityIDs['CONTACT']],
                ['ID', 'NAME', 'LAST_NAME', 'PHONE', 'EMAIL'],
                0
            )->getContacts();
            if(!empty($contacts))
            {
                $resultEntity['contact'] = $contacts;
            }
        }
        

if entity_ids["CONTACT"]:
            result = client.crm.contact.list(
                filter={"ID": entity_ids["CONTACT"]},
                select=["ID", "NAME", "LAST_NAME", "PHONE", "EMAIL"],
            ).result
        
            if result:
                result_entity["contact"] = result
        

res, err := core.Call(ctx, "crm.contact.list", b24.Params{
        	"filter": b24.Params{"ID": entityIDs["CONTACT"]},
        	"select": []string{"ID", "NAME", "LAST_NAME", "PHONE", "EMAIL"},
        }, b24.WithIdempotent())
        if err != nil {
        	return fmt.Errorf("crm.contact.list: %w", err)
        }
        var contacts []entity
        if err := json.Unmarshal(res.Result, &contacts); err != nil {
        	return fmt.Errorf("разбор контактов: %w", err)
        }
        for _, e := range contacts {
        	rows = append(rows, e.row("контакт"))
        }
        

if(!empty($entityIDs['COMPANY']))
        {
            $companies = $sb->getCRMScope()->company()->list(
                [],
                ['ID' => $entityIDs['COMPANY']],
                ['ID', 'PHONE', 'EMAIL', 'TITLE']
            )->getCompanies();
            if(!empty($companies))
            {
                $resultEntity['company'] = $companies;
            }
        }
        

if entity_ids["COMPANY"]:
            result = client.crm.company.list(
                filter={"ID": entity_ids["COMPANY"]},
                select=["ID", "PHONE", "EMAIL", "TITLE"],
            ).result
        
            if result:
                result_entity["company"] = result
        

// У компании нет имени и фамилии — её название лежит в TITLE.
        res, err := core.Call(ctx, "crm.company.list", b24.Params{
        	"filter": b24.Params{"ID": entityIDs["COMPANY"]},
        	"select": []string{"ID", "TITLE", "PHONE", "EMAIL"},
        }, b24.WithIdempotent())
        if err != nil {
        	return fmt.Errorf("crm.company.list: %w", err)
        }
        var companies []entity
        if err := json.Unmarshal(res.Result, &companies); err != nil {
        	return fmt.Errorf("разбор компаний: %w", err)
        }
        for _, e := range companies {
        	rows = append(rows, e.row("компания"))
        }
        

$table = [];
        $table[] = [
            "Идентификатор",
            "Тип объекта",
            "Название/Имя и фамилия",
            "Телефон",
            "Email"
        ];
        
        foreach ($resultEntity as $entityType => $entities) {
            foreach ($entities as $item) {
                $phones = '';
                if (!empty($item->PHONE)) {
                    $phones = implode(', ', array_map(fn($phone) => $phone->VALUE, $item->PHONE));
                }
                $emails = '';
                if (!empty($item->EMAIL)) {
                    $emails = implode(', ', array_map(fn($email) => $email->VALUE, $item->EMAIL));
                }
                $title = !empty($item->TITLE) ? $item->TITLE : '';
                if (!empty($item->NAME) || !empty($item->LAST_NAME)) {
                    $namePart = trim($item->NAME . ' ' . $item->LAST_NAME);
                    if ($title) {
                        $title .= ': ' . $namePart;
                    } else {
                        $title = $namePart;
                    }
                }
        
                $table[] = [
                    $item->ID,
                    $entityType,
                    $title ?: '—',
                    $phones ?: '—',
                    $emails ?: '—'
                ];
            }
        }
        
        foreach ($table as $row) {
            echo implode("\t", $row) . "\n";
        }
        

table = [[
            "Идентификатор",
            "Тип объекта",
            "Название/Имя и фамилия",
            "Телефон",
            "Email",
        ]]
        
        for entity_type, entities in result_entity.items():
            for item in entities:
                phones = ", ".join(phone["VALUE"] for phone in (item.get("PHONE") or []))
                emails = ", ".join(email["VALUE"] for email in (item.get("EMAIL") or []))
                title = item.get("TITLE") or ""
                name_part = " ".join(filter(None, [item.get("NAME"), item.get("LAST_NAME")]))
                if title and name_part:
                    title = f"{title}: {name_part}"
                elif name_part:
                    title = name_part
        
                table.append([
                    item["ID"],
                    entity_type,
                    title or "—",
                    phones or "—",
                    emails or "—",
                ])
        
        for row in table:
            print("\t".join(map(str, row)))
        

if len(rows) == 0 {
        	fmt.Println("Дубликаты не найдены")
        	return nil
        }
        fmt.Println("ID\tТип\tНазвание\tТелефон\tEmail")
        for _, r := range rows {
        	fmt.Printf("%d\t%s\t%s\t%s\t%s\n", r.ID, r.Kind, r.Title, r.Phone, r.Email)
        }
        

<?php
        // composer require bitrix24/b24phpsdk:"^3.0"
        require_once 'vendor/autoload.php';
        
        use Bitrix24\SDK\Services\ServiceBuilderFactory;
        use Bitrix24\SDK\Services\CRM\Duplicates\Result\DuplicateResult;
        use Symfony\Component\EventDispatcher\EventDispatcher;
        use Monolog\Logger;
        use Monolog\Handler\StreamHandler;
        
        $log = new Logger('b24');
        $log->pushHandler(new StreamHandler('php://stdout'));
        
        $sb = (new ServiceBuilderFactory(new EventDispatcher(), $log))
            ->initFromWebhook('https://your-domain.bitrix24.ru/rest/USER_ID/TOKEN/');
        
        // Запрос у пользователя телефона и email
        $phone = readline("Введите номер телефона: ");
        $email = readline("Введите email: ");
        
        // Инициализация переменных
        $entityIDs = [
            'LEAD' => [],
            'CONTACT' => [],
            'COMPANY' => []
        ];
        $resultEntity = [
            'lead' => [],
            'contact' => [],
            'company' => []
        ];
        
        // Объединяет идентификаторы из ответа метода с массивом $entityIDs
        function mergeDuplicates(DuplicateResult $result, array &$entityIDs): void
        {
            $data = $result->getCoreResponse()->getResponseData()->getResult();
            foreach (['LEAD', 'CONTACT', 'COMPANY'] as $type) {
                if (!empty($data[$type]) && is_array($data[$type])) {
                    $entityIDs[$type] = array_merge($entityIDs[$type], $data[$type]);
                }
            }
        }
        
        // Поиск дубликатов по телефону
        if($phone)
        {
            mergeDuplicates($sb->getCRMScope()->duplicate()->findByPhone([$phone]), $entityIDs);
        }
        
        // Поиск дубликатов по email
        if($email)
        {
            mergeDuplicates($sb->getCRMScope()->duplicate()->findByEmail([$email]), $entityIDs);
        }
        
        // Обрабатываем лиды
        if(!empty($entityIDs['LEAD']))
        {
            $leads = $sb->getCRMScope()->lead()->list(
                [],
                ['ID' => $entityIDs['LEAD']],
                ['ID', 'NAME', 'LAST_NAME', 'PHONE', 'EMAIL', 'TITLE']
            )->getLeads();
            if(!empty($leads))
            {
                $resultEntity['lead'] = $leads;
            }
        }
        
        // Обрабатываем контакты
        if(!empty($entityIDs['CONTACT']))
        {
            $contacts = $sb->getCRMScope()->contact()->list(
                [],
                ['ID' => $entityIDs['CONTACT']],
                ['ID', 'NAME', 'LAST_NAME', 'PHONE', 'EMAIL'],
                0
            )->getContacts();
            if(!empty($contacts))
            {
                $resultEntity['contact'] = $contacts;
            }
        }
        
        // Обрабатываем компании
        if(!empty($entityIDs['COMPANY']))
        {
            $companies = $sb->getCRMScope()->company()->list(
                [],
                ['ID' => $entityIDs['COMPANY']],
                ['ID', 'PHONE', 'EMAIL', 'TITLE']
            )->getCompanies();
            if(!empty($companies))
            {
                $resultEntity['company'] = $companies;
            }
        }
        
        // Формируем таблицу
        $table = [];
        
        // Заголовок таблицы
        $table[] = [
            "Идентификатор",
            "Тип объекта",
            "Название/Имя и фамилия",
            "Телефон",
            "Email"
        ];
        
        // Строки данных
        foreach ($resultEntity as $entityType => $entities) {
            foreach ($entities as $item) {
                $phones = '';
                if (!empty($item->PHONE)) {
                    $phones = implode(', ', array_map(fn($phone) => $phone->VALUE, $item->PHONE));
                }
                $emails = '';
                if (!empty($item->EMAIL)) {
                    $emails = implode(', ', array_map(fn($email) => $email->VALUE, $item->EMAIL));
                }
                $title = !empty($item->TITLE) ? $item->TITLE : '';
                if (!empty($item->NAME) || !empty($item->LAST_NAME)) {
                    $namePart = trim($item->NAME . ' ' . $item->LAST_NAME);
                    if ($title) {
                        $title .= ': ' . $namePart;
                    } else {
                        $title = $namePart;
                    }
                }
        
                $table[] = [
                    $item->ID,
                    $entityType,
                    $title ?: '—',
                    $phones ?: '—',
                    $emails ?: '—'
                ];
            }
        }
        
        // Выводим таблицу в консоль через табуляцию
        foreach ($table as $row) {
            echo implode("\t", $row) . "\n";
        }
        

from b24pysdk import BitrixWebhook, Client
        from b24pysdk.errors import BitrixAPIError
        
        client = Client(
            BitrixWebhook(
                domain="your-domain.bitrix24.com",
                webhook_token="user_id/webhook_key",
            )
        )
        
        phone = input("Введите номер телефона: ")
        email = input("Введите email: ")
        
        entity_ids = {"LEAD": [], "CONTACT": [], "COMPANY": []}
        result_entity = {"lead": [], "contact": [], "company": []}
        
        try:
            if phone:
                phone_result = client.crm.duplicate.findbycomm(
                    type="PHONE",
                    values=[phone],
                ).response.result
                for key in entity_ids:
                    entity_ids[key].extend(phone_result.get(key, []))
        
            if email:
                email_result = client.crm.duplicate.findbycomm(
                    type="EMAIL",
                    values=[email],
                ).response.result
                for key in entity_ids:
                    entity_ids[key].extend(email_result.get(key, []))
        
            if entity_ids["LEAD"]:
                result = client.crm.lead.list(
                    filter={"ID": entity_ids["LEAD"]},
                    select=["ID", "NAME", "LAST_NAME", "PHONE", "EMAIL", "TITLE"],
                ).response.result
                if result:
                    result_entity["lead"] = result
        
            if entity_ids["CONTACT"]:
                result = client.crm.contact.list(
                    filter={"ID": entity_ids["CONTACT"]},
                    select=["ID", "NAME", "LAST_NAME", "PHONE", "EMAIL"],
                ).response.result
                if result:
                    result_entity["contact"] = result
        
            if entity_ids["COMPANY"]:
                result = client.crm.company.list(
                    filter={"ID": entity_ids["COMPANY"]},
                    select=["ID", "PHONE", "EMAIL", "TITLE"],
                ).response.result
                if result:
                    result_entity["company"] = result
        except BitrixAPIError as error:
            print(error)
        
        table = [[
            "Идентификатор",
            "Тип объекта",
            "Название/Имя и фамилия",
            "Телефон",
            "Email",
        ]]
        
        for entity_type, entities in result_entity.items():
            for item in entities:
                phones = ""
                if item.get("PHONE"):
                    phones = ", ".join(phone["VALUE"] for phone in item["PHONE"])
        
                emails = ""
                if item.get("EMAIL"):
                    emails = ", ".join(email["VALUE"] for email in item["EMAIL"])
        
                title = item.get("TITLE") or ""
                if item.get("NAME") or item.get("LAST_NAME"):
                    name_part = " ".join(filter(None, [item.get("NAME"), item.get("LAST_NAME")]))
                    if title:
                        title = f"{title}: {name_part}"
                    else:
                        title = name_part
        
                table.append([
                    item["ID"],
                    entity_type,
                    title or "—",
                    phones or "—",
                    emails or "—",
                ])
        
        for row in table:
            print("\t".join(map(str, row)))
        

// Подготовка в пустом каталоге — 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"
        	"strings"
        
        	b24 "github.com/bitrix24/b24gosdk"
        )
        
        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()
        	// Телефон и почта, по которым ищем. Соседние вкладки спрашивают их у
        	// пользователя; здесь они заданы константами, потому что пример сам создаёт
        	// объекты с этими значениями.
        	const (
        		phone = "+7 900 555-35-35"
        		email = "duplicate@example.com"
        	)
        
        	// Идентификаторы найденных объектов и подробные данные по ним. Ключи —
        	// те же, что возвращает crm.duplicate.findbycomm.
        	entityIDs := map[string][]b24.ID{"LEAD": nil, "CONTACT": nil, "COMPANY": nil}
        	rows := make([]row, 0)
        	// --- подготовка: свои дубликаты
        
        	cleanup, err := createDuplicates(ctx, core, phone, email)
        	defer cleanup()
        	if err != nil {
        		return err
        	}
        
        	// --- шаг 1: ищем дубликаты по коммуникациям
        	// Метод ищет по ОДНОМУ типу коммуникации за вызов, поэтому телефон и почту
        	// опрашиваем отдельно, а идентификаторы копим в общей карте.
        	for _, comm := range []struct{ typ, value string }{
        		{"PHONE", phone},
        		{"EMAIL", email},
        	} {
        		if comm.value == "" {
        			continue
        		}
        		res, err := core.Call(ctx, "crm.duplicate.findbycomm", b24.Params{
        			"type":   comm.typ,
        			"values": []string{comm.value},
        		}, b24.WithIdempotent())
        		if err != nil {
        			return fmt.Errorf("crm.duplicate.findbycomm %s: %w", comm.typ, err)
        		}
        
        		// Ответ — объект с ключами LEAD, CONTACT, COMPANY. Ключа может не быть
        		// вовсе: если по этому типу ничего не нашлось, его просто не пришлют.
        		var found map[string][]b24.ID
        		if err := json.Unmarshal(res.Result, &found); err != nil {
        			return fmt.Errorf("разбор дубликатов: %w", err)
        		}
        		for key := range entityIDs {
        			entityIDs[key] = appendUnique(entityIDs[key], found[key])
        		}
        	}
        	fmt.Printf("найдено: лидов %d, контактов %d, компаний %d\n",
        		len(entityIDs["LEAD"]), len(entityIDs["CONTACT"]), len(entityIDs["COMPANY"]))
        
        	// --- шаг 2: данные лидов
        
        	if len(entityIDs["LEAD"]) > 0 {
        		res, err := core.Call(ctx, "crm.lead.list", b24.Params{
        			"filter": b24.Params{"ID": entityIDs["LEAD"]},
        			"select": []string{"ID", "NAME", "LAST_NAME", "PHONE", "EMAIL", "TITLE"},
        		}, b24.WithIdempotent())
        		if err != nil {
        			return fmt.Errorf("crm.lead.list: %w", err)
        		}
        		var leads []entity
        		if err := json.Unmarshal(res.Result, &leads); err != nil {
        			return fmt.Errorf("разбор лидов: %w", err)
        		}
        		for _, e := range leads {
        			rows = append(rows, e.row("лид"))
        		}
        	}
        
        	// --- шаг 3: данные контактов
        
        	if len(entityIDs["CONTACT"]) > 0 {
        		res, err := core.Call(ctx, "crm.contact.list", b24.Params{
        			"filter": b24.Params{"ID": entityIDs["CONTACT"]},
        			"select": []string{"ID", "NAME", "LAST_NAME", "PHONE", "EMAIL"},
        		}, b24.WithIdempotent())
        		if err != nil {
        			return fmt.Errorf("crm.contact.list: %w", err)
        		}
        		var contacts []entity
        		if err := json.Unmarshal(res.Result, &contacts); err != nil {
        			return fmt.Errorf("разбор контактов: %w", err)
        		}
        		for _, e := range contacts {
        			rows = append(rows, e.row("контакт"))
        		}
        	}
        
        	// --- шаг 4: данные компаний
        
        	if len(entityIDs["COMPANY"]) > 0 {
        		// У компании нет имени и фамилии — её название лежит в TITLE.
        		res, err := core.Call(ctx, "crm.company.list", b24.Params{
        			"filter": b24.Params{"ID": entityIDs["COMPANY"]},
        			"select": []string{"ID", "TITLE", "PHONE", "EMAIL"},
        		}, b24.WithIdempotent())
        		if err != nil {
        			return fmt.Errorf("crm.company.list: %w", err)
        		}
        		var companies []entity
        		if err := json.Unmarshal(res.Result, &companies); err != nil {
        			return fmt.Errorf("разбор компаний: %w", err)
        		}
        		for _, e := range companies {
        			rows = append(rows, e.row("компания"))
        		}
        	}
        
        	// --- выводим таблицу
        	if len(rows) == 0 {
        		fmt.Println("Дубликаты не найдены")
        		return nil
        	}
        	fmt.Println("ID\tТип\tНазвание\tТелефон\tEmail")
        	for _, r := range rows {
        		fmt.Printf("%d\t%s\t%s\t%s\t%s\n", r.ID, r.Kind, r.Title, r.Phone, r.Email)
        	}
        	return nil
        }
        
        // entity — общий вид строки списков лидов, контактов и компаний: набор полей у
        // них разный, но нужные нам совпадают.
        type entity struct {
        	ID       b24.ID       `json:"ID"`
        	Title    string       `json:"TITLE"`
        	Name     string       `json:"NAME"`
        	LastName string       `json:"LAST_NAME"`
        	Phone    []multifield `json:"PHONE"`
        	Email    []multifield `json:"EMAIL"`
        }
        
        // multifield — строка поля типа crm_multifield: телефон и почта хранятся
        // списком объектов, даже когда значение одно.
        type multifield struct {
        	Value string `json:"VALUE"`
        }
        
        type row struct {
        	ID                        b24.ID
        	Kind, Title, Phone, Email string
        }
        
        func (e entity) row(kind string) row {
        	title := strings.TrimSpace(e.Name + " " + e.LastName)
        	if title == "" {
        		title = e.Title
        	}
        	return row{ID: e.ID, Kind: kind, Title: title,
        		Phone: first(e.Phone), Email: first(e.Email)}
        }
        
        func first(values []multifield) string {
        	if len(values) == 0 {
        		return "—"
        	}
        	return values[0].Value
        }
        
        func appendUnique(dst, src []b24.ID) []b24.ID {
        	seen := make(map[b24.ID]bool, len(dst))
        	for _, id := range dst {
        		seen[id] = true
        	}
        	for _, id := range src {
        		if !seen[id] {
        			seen[id] = true
        			dst = append(dst, id)
        		}
        	}
        	return dst
        }
        
        // --- вспомогательное: подготовка данных и уборка
        
        // createDuplicates заводит лид, контакт и компанию с одинаковыми телефоном и
        // почтой — ровно ту ситуацию, которую ищет сценарий. Возвращает функцию
        // уборки: она вызывается и тогда, когда подготовка оборвалась на середине.
        func createDuplicates(ctx context.Context, core *b24.Core, phone, email string) (func(), error) {
        	comm := b24.Params{
        		"PHONE": []map[string]any{b24.MultifieldAdd(phone, "WORK")},
        		"EMAIL": []map[string]any{b24.MultifieldAdd(email, "WORK")},
        	}
        	created := map[string]b24.ID{}
        	cleanup := func() {
        		for method, id := range created {
        			del(ctx, core, method, b24.Params{"id": id})
        		}
        	}
        
        	for _, spec := range []struct {
        		add, delete string
        		fields      b24.Params
        	}{
        		{"crm.lead.add", "crm.lead.delete", b24.Params{"TITLE": "Заявка с сайта", "NAME": "Пётр", "LAST_NAME": "Иванов"}},
        		{"crm.contact.add", "crm.contact.delete", b24.Params{"NAME": "Пётр", "LAST_NAME": "Иванов"}},
        		{"crm.company.add", "crm.company.delete", b24.Params{"TITLE": "ООО Пётр Иванов"}},
        	} {
        		fields := b24.Params{}
        		for k, v := range spec.fields {
        			fields[k] = v
        		}
        		for k, v := range comm {
        			fields[k] = v
        		}
        		res, err := core.Call(ctx, spec.add, b24.Params{"fields": fields})
        		if err != nil {
        			return cleanup, fmt.Errorf("%s: %w", spec.add, err)
        		}
        		var id b24.ID
        		if err := json.Unmarshal(res.Result, &id); err != nil {
        			return cleanup, fmt.Errorf("разбор идентификатора из %s: %w", spec.add, err)
        		}
        		created[spec.delete] = id
        	}
        	return cleanup, 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)
        	}
        }