Skill v1.0.1

Automated scan100/100

steelmorgan/1c-agent-based-dev-framework/data-exchange

+1 new

──Details

PublishedJune 21, 2026 at 10:51 AM

Content Hashsha256:90509009a0458065...

Git SHAf0ac1fdfcab1

Bump Typepatch

Compare with v1.0.0

──Files

Files (1 file, 28.1 KB)

SKILL.md28.1 KBactive

SKILL.md · 475 lines · 28.1 KB

version: "1.0.1" name: data-exchange description: "Use for реализации и диагностики обмена данными 1С (РИБ, КД 2.0/3.0, EnterpriseData, БСП). Helps выбрать модель обмена, обеспечить идемпотентность пакетов и явное разрешение конфликтов."

Обмен данными 1С

Ключевой принцип: Обмен данными — это распределённая система. Каждый пакет должен быть идемпотентным (повторная загрузка не портит данные), каждый конфликт — явно разрешённым, каждая ошибка — залогированной с привязкой к узлу и номеру сообщения.

Правило 1: Архитектура планов обмена — выбор модели

Перед реализацией необходимо определить модель обмена. Выбор влияет на весь дальнейший код.

Модель	Когда использовать	Механизм
РИБ (распределённая ИБ)	Полная копия конфигурации на узлах, переносятся все данные	`ПланыОбмена`, XML-сериализация, `ОбменДаннымиXML`
Избирательный обмен (БСП)	Обмен по правилам, фильтрация объектов, разные конфигурации	Подсистема «Обмен данными» БСП, формат EnterpriseData
КД 2.0	Сложные правила конвертации между разными конфигурациями	Обработка «Конвертация данных», XML-правила
КД 3.0 / EDT	Современные проекты, правила на BSL, поддержка EnterpriseData	Конфигурация «Конвертация данных 3»

Структура плана обмена

bsl

// Главный узел — это текущая ИБ
// Подчинённые узлы — внешние базы данных
УзелГлавный = ПланыОбмена.МойОбмен.ГлавныйУзел();
Если УзелГлавный = Неопределено Тогда
    // Это главный узел (центральная база)
КонецЕсли;
 
// Создание нового узла обмена
НовыйУзел = ПланыОбмена.МойОбмен.СоздатьУзел();
НовыйУзел.Код = "ФИЛИАЛ_001";
НовыйУзел.Наименование = "Филиал Москва";
НовыйУзел.Записать();

Правило 2: Регистрация изменений — ЗарегистрироватьИзменения

Регистрация изменений — основной механизм отслеживания того, что нужно передать узлу. Неправильная регистрация — главный источник ошибок: либо данные не уходят, либо уходят лишние.

Явная регистрация

bsl

// Зарегистрировать конкретный объект для конкретного узла
ПланыОбмена.ЗарегистрироватьИзменения(УзелОбмена, ОбъектСсылка);
 
// Зарегистрировать набор объектов (например, при первичной синхронизации)
МассивОбъектов = Новый Массив;
МассивОбъектов.Добавить(НоменклатураСсылка1);
МассивОбъектов.Добавить(НоменклатураСсылка2);
ПланыОбмена.ЗарегистрироватьИзменения(УзелОбмена, МассивОбъектов);

Подписки на события для автоматической регистрации

bsl

// В обработчике подписки ПриЗаписи — регистрировать изменения явно
Процедура НоменклатураПриЗаписи(Источник, Отказ, РежимЗаписи, РежимПроведения)
 
    Если Источник.ОбменДанными.Загрузка Тогда
        Возврат; // Не регистрировать изменения при загрузке из обмена
    КонецЕсли;
 
    Для Каждого УзелОбмена Из ПланыОбмена.МойОбмен.Выбрать() Цикл
        Если УзелОбмена.Ссылка <> ПланыОбмена.МойОбмен.ЭтотУзел() Тогда
            ПланыОбмена.ЗарегистрироватьИзменения(УзелОбмена.Ссылка, Источник.Ссылка);
        КонецЕсли;
    КонецЦикла;
 
КонецПроцедуры

Критическое правило: проверка флага Загрузка

bsl

// ОБЯЗАТЕЛЬНО в начале каждого обработчика объекта
Если Источник.ОбменДанными.Загрузка Тогда
    Возврат; // Пропустить все проверки и дополнительную логику при загрузке
КонецЕсли;

Без этой проверки: при загрузке данных из внешней базы сработают бизнес-правила текущей базы → данные испортятся или загрузка завершится с ошибкой.

Правило 3: Выгрузка данных — формирование пакета сообщения

Канонический паттерн выгрузки (РИБ)

bsl

Функция СформироватьСообщениеОбмена(УзелОбмена) Экспорт
 
    СообщениеОбмена = ПланыОбмена.СоздатьСообщениеОбмена();
    СообщениеОбмена.Отправитель = ПланыОбмена.МойОбмен.ЭтотУзел();
    СообщениеОбмена.Получатель = УзелОбмена;
 
    ЗаписьXML = Новый ЗаписьXML;
    ЗаписьXML.УстановитьСтроку();
 
    Попытка
        ОбменДаннымиXML.НачатьЗаписьСообщения(ЗаписьXML, СообщениеОбмена);
 
        // Выгрузка изменений
        ВыборкаИзменений = ПланыОбмена.Выбрать(УзелОбмена, ТипПланаОбмена.ТолькоИзменения);
        Пока ВыборкаИзменений.Следующий() Цикл
            ОбменДаннымиXML.ЗаписатьИзменения(ЗаписьXML, ВыборкаИзменений.ПолучитьОбъект());
        КонецЦикла;
 
        ОбменДаннымиXML.ЗакончитьЗаписьСообщения(ЗаписьXML);
 
    Исключение
        ЗаписьЖурналаРегистрации(
            НСтр("ru = 'ОбменДанными.Выгрузка'"),
            УровеньЖурналаРегистрации.Ошибка,
            Метаданные.ПланыОбмена.МойОбмен,
            УзелОбмена,
            ПодробноеПредставлениеОшибки(ИнформацияОбОшибке()));
        ВызватьИсключение;
    КонецПопытки;
 
    Возврат ЗаписьXML.Закрыть();
 
КонецФункции

Номер сообщения и подтверждение

bsl

// ВАЖНО: номер сообщения фиксируется только после успешной доставки
// Не вызывать УстановитьНомерОтправленного до подтверждения получения
 
// На стороне отправителя — после подтверждения доставки:
ПланыОбмена.УстановитьНомерОтправленного(УзелОбмена, НомерСообщения);
 
// На стороне получателя — после успешной загрузки:
ПланыОбмена.УстановитьНомерПринятого(УзелОбмена, НомерСообщения);

Правило 4: Загрузка данных — идемпотентность и защита от дублей

Идемпотентность пакета означает: повторная загрузка одного и того же сообщения не изменяет результат. Это критично при сетевых сбоях и ручных повторных запусках.

Канонический паттерн загрузки (РИБ)

bsl

Процедура ЗагрузитьСообщениеОбмена(ТекстСообщения) Экспорт
 
    ЧтениеXML = Новый ЧтениеXML;
    ЧтениеXML.УстановитьСтроку(ТекстСообщения);
 
    СообщениеОбмена = ПланыОбмена.СоздатьСообщениеОбмена();
 
    НачатьТранзакцию();
    Попытка
 
        ОбменДаннымиXML.НачатьЧтениеСообщения(ЧтениеXML, СообщениеОбмена);
 
        // Проверка: не загружать уже принятое сообщение (идемпотентность)
        Если СообщениеОбмена.НомерСообщения <= ПланыОбмена.МойОбмен
                .НайтиПоКоду(СообщениеОбмена.Отправитель.Код).НомерПринятого Тогда
            ЗаписьЖурналаРегистрации(
                НСтр("ru = 'ОбменДанными.Загрузка'"),
                УровеньЖурналаРегистрации.Предупреждение,,,
                СтрШаблон(НСтр("ru = 'Сообщение №%1 от узла %2 уже было принято. Пропускаем.'"),
                    СообщениеОбмена.НомерСообщения, СообщениеОбмена.Отправитель));
            ОтменитьТранзакцию();
            Возврат;
        КонецЕсли;
 
        // Загрузка объектов
        Пока ОбменДаннымиXML.ЧитатьИзменения(ЧтениеXML) Цикл
            Данные = ОбменДаннымиXML.ПрочитатьИзменения(ЧтениеXML);
            Данные.ОбменДанными.Загрузка = Истина;
            Данные.Записать();
        КонецЦикла;
 
        ОбменДаннымиXML.ЗакончитьЧтениеСообщения(ЧтениеXML);
 
        // Фиксируем номер принятого сообщения
        ПланыОбмена.УстановитьНомерПринятого(
            СообщениеОбмена.Отправитель, СообщениеОбмена.НомерСообщения);
 
        ЗафиксироватьТранзакцию();
 
    Исключение
        ОтменитьТранзакцию();
        ЗаписьЖурналаРегистрации(
            НСтр("ru = 'ОбменДанными.Загрузка'"),
            УровеньЖурналаРегистрации.Ошибка,
            Метаданные.ПланыОбмена.МойОбмен,
            СообщениеОбмена.Отправитель,
            СтрШаблон(НСтр("ru = 'Ошибка загрузки сообщения №%1.
            |%2'"), СообщениеОбмена.НомерСообщения,
                ПодробноеПредставлениеОшибки(ИнформацияОбОшибке())));
        ВызватьИсключение;
    КонецПопытки;
 
КонецПроцедуры

Обеспечение идемпотентности при загрузке справочников

bsl

// При загрузке справочников — искать по внешнему идентификатору, не создавать дубли
Функция НайтиИлиСоздатьНоменклатуру(ВнешнийКод, Наименование)
 
    // Поиск по внешнему коду (синхронизационному ключу)
    СуществующийЭлемент = Справочники.Номенклатура.НайтиПоКоду(ВнешнийКод);
    Если СуществующийЭлемент <> Справочники.Номенклатура.ПустаяСсылка() Тогда
        Возврат СуществующийЭлемент;
    КонецЕсли;
 
    // Создать новый только если не нашли
    НовыйЭлемент = Справочники.Номенклатура.СоздатьЭлемент();
    НовыйЭлемент.Код = ВнешнийКод;
    НовыйЭлемент.Наименование = Наименование;
    НовыйЭлемент.ОбменДанными.Загрузка = Истина;
    НовыйЭлемент.Записать();
    Возврат НовыйЭлемент.Ссылка;
 
КонецФункции

Правило 5: Разрешение конфликтов

Конфликт возникает когда один и тот же объект изменён в двух узлах одновременно. Стратегия разрешения должна быть задокументирована и реализована явно — «молчаливая» победа последнего изменения недопустима в большинстве бизнес-задач.

Стратегии разрешения

Стратегия	Когда применять	Реализация
Победа главного узла	Главная база — источник правды	Отклонять изменения из подчинённых при конфликте
Победа последнего изменения	Некритичные данные (настройки, описания)	`МоментВремени()` — кто новее, тот побеждает
Победа по бизнес-правилу	Статусная машина, приоритеты	Явная функция разрешения
Ручное разрешение	Критичные данные, не поддаются автоматике	Фиксировать в реестре конфликтов

Паттерн: разрешение по приоритету узла

bsl

// В обработчике ОбменДанными.ОбработкаКонфликта (БСП)
// или в ручной логике загрузки:
 
Функция РазрешитьКонфликт(ДанныеПриемника, ДанныеИсточника, УзелОбмена) Экспорт
 
    // Если это главный узел — наши данные побеждают всегда
    Если ПланыОбмена.МойОбмен.ГлавныйУзел() = Неопределено Тогда
        // Мы главный узел
        ЗаписьЖурналаРегистрации(
            НСтр("ru = 'ОбменДанными.Конфликт'"),
            УровеньЖурналаРегистрации.Предупреждение,
            ДанныеПриемника.Метаданные(),
            ДанныеПриемника.Ссылка,
            СтрШаблон(НСтр("ru = 'Конфликт с узлом %1. Победа главного узла.'"), УзелОбмена));
        Возврат Ложь; // Не загружать данные источника
    КонецЕсли;
 
    // Разрешение по дате последнего изменения
    Если ДанныеИсточника.МоментВремени() > ДанныеПриемника.МоментВремени() Тогда
        Возврат Истина; // Загрузить — источник новее
    Иначе
        ЗаписьЖурналаРегистрации(
            НСтр("ru = 'ОбменДанными.Конфликт'"),
            УровеньЖурналаРегистрации.Предупреждение,
            ДанныеПриемника.Метаданные(),
            ДанныеПриемника.Ссылка,
            НСтр("ru = 'Конфликт. Победа приёмника — локальная версия новее.'"));
        Возврат Ложь; // Не загружать — наши данные новее
    КонецЕсли;
 
КонецФункции

Правило 6: Обмен через подсистему БСП «Обмен данными»

БСП предоставляет готовую инфраструктуру: настройки узлов, правила обмена, транспорт (файл, FTP, e-mail, WS), очередь сообщений, реестр конфликтов.

Ключевые объекты подсистемы

bsl

// Основной модуль подсистемы
// ОбменДаннымиСервер — серверный модуль
// ОбменДаннымиКлиент — клиентский модуль
// ОбменДанными — общий модуль (клиент-сервер)
 
// Регистрация объекта для обмена через БСП
ОбменДаннымиСервер.ЗарегистрироватьОбъектДляОбмена(УзелОбмена, ОбъектСсылка);
 
// Запуск синхронизации через БСП
НастройкиОбмена = ОбменДаннымиСервер.НастройкиОбменаДляУзла(УзелОбмена);
ОбменДаннымиСервер.СинхронизироватьДанные(НастройкиОбмена);

Формат EnterpriseData

EnterpriseData — стандартизированный XML-формат для обмена между конфигурациями 1С. Используется в современных планах обмена БСП.

bsl

// Структура пакета EnterpriseData
// <Файл>
//   <ТипФайла>ОбменДанными</ТипФайла>
//   <ФорматВерсии>1.0</ФорматВерсии>
//   <Отправитель>
//     <Наименование>УТ 11.5</Наименование>
//     <Идентификатор>GUID_узла</Идентификатор>
//   </Отправитель>
//   <Данные>
//     <Объект ТипОбъекта="Справочник.Номенклатура">
//       ...поля объекта...
//     </Объект>
//   </Данные>
// </Файл>
 
// Чтение пакета EnterpriseData
ЧтениеXML = Новый ЧтениеXML;
ЧтениеXML.ОткрытьФайл(ПутьКФайлу);
 
Десериализатор = Новый СериализаторXDTO(ФабрикаXDTO);
Пока ЧтениеXML.Прочитать() Цикл
    Если ЧтениеXML.ТипУзла = ТипУзлаXML.НачалоЭлемента
            И ЧтениеXML.ЛокальноеИмя = "Объект" Тогда
        ОбъектXDTO = Десериализатор.ПрочитатьXML(ЧтениеXML);
        ОбработатьОбъектXDTO(ОбъектXDTO);
    КонецЕсли;
КонецЦикла;

Правило 7: КД 2.0 — правила конвертации

КД 2.0 используется для обмена между разными конфигурациями с помощью файла правил конвертации (XML).

Паттерн загрузки через КД 2.0

bsl

// Загрузка данных с использованием обработки «Конвертация данных»
Процедура ЗагрузитьДанныеПоПравилам(ПутьКФайлу, ПутьКПравилам) Экспорт
 
    ОбработкаЗагрузки = ВнешниеОбработки.Создать(ПутьКПравилам);
 
    ОбработкаЗагрузки.ИмяФайлаОбмена = ПутьКФайлу;
    ОбработкаЗагрузки.ПутьКПравиламОбмена = ПутьКПравилам;
    ОбработкаЗагрузки.ЗагрузитьПравилаОбмена();
 
    Попытка
        ОбработкаЗагрузки.ВыполнитьЗагрузку();
    Исключение
        ЗаписьЖурналаРегистрации(
            НСтр("ru = 'ОбменДанными.КД2.Загрузка'"),
            УровеньЖурналаРегистрации.Ошибка,,,
            ПодробноеПредставлениеОшибки(ИнформацияОбОшибке()));
        ВызватьИсключение;
    КонецПопытки;
 
КонецПроцедуры

Отличия КД 2.0 от КД 3.0

Аспект	КД 2.0	КД 3.0
Правила	XML-файл	BSL-модули в конфигурации КД 3
Поддержка EDT	Нет	Да
Формат	Proprietary XML	EnterpriseData (опционально)
Обработчики	В правилах (строки кода)	Полноценный BSL, отладка
Рекомендация	Существующие проекты	Новые проекты

Правило 8: Диагностика и мониторинг обмена

Таблица событий журнала регистрации

При диагностике обмена искать события:

Событие ЖР	Что означает
`ОбменДанными`	Общие события подсистемы БСП
`ОбменДанными.Выгрузка`	Формирование пакета
`ОбменДанными.Загрузка`	Приём и обработка пакета
`ОбменДанными.Конфликт`	Зафиксированные конфликты
`ОбменДанными.Транспорт`	Ошибки доставки

Проверка состояния узлов обмена

bsl

// Диагностический запрос — состояние узлов и счётчиков сообщений
Запрос = Новый Запрос;
Запрос.Текст =
"ВЫБРАТЬ
|   Узлы.Ссылка КАК Узел,
|   Узлы.Код,
|   Узлы.НомерОтправленного,
|   Узлы.НомерПринятого,
|   КОЛИЧЕСТВО(Изменения.Узел) КАК КоличествоИзменений
|ИЗ
|   ПланОбмена.МойОбмен КАК Узлы
|       ЛЕВОЕ СОЕДИНЕНИЕ РегистрСведений.ИзменениеПоПланамОбмена КАК Изменения
|       ПО Изменения.Узел = Узлы.Ссылка
|ГДЕ
|   Узлы.Ссылка <> Узлы.ЭтотУзел
|СГРУППИРОВАТЬ ПО
|   Узлы.Ссылка, Узлы.Код, Узлы.НомерОтправленного, Узлы.НомерПринятого";
 
РезультатЗапроса = Запрос.Выполнить();

Ручная перерегистрация при сбоях

bsl

// Сброс счётчика и перерегистрация всех данных для узла
// ВНИМАНИЕ: использовать только при полной ресинхронизации
Процедура ПеререгистрироватьВсеДанные(УзелОбмена) Экспорт
 
    // Сбросить счётчики
    УзелОбменаОбъект = УзелОбмена.ПолучитьОбъект();
    УзелОбменаОбъект.НомерОтправленного = 0;
    УзелОбменаОбъект.НомерПринятого = 0;
    УзелОбменаОбъект.Записать();
 
    // Удалить накопленные изменения
    ПланыОбмена.УдалитьРегистрациюИзменений(УзелОбмена, 0);
 
    // Зарегистрировать заново
    // (зависит от состава плана обмена — перебрать все типы объектов)
 
    ЗаписьЖурналаРегистрации(
        НСтр("ru = 'ОбменДанными.Перерегистрация'"),
        УровеньЖурналаРегистрации.Предупреждение,
        Метаданные.ПланыОбмена.МойОбмен,
        УзелОбмена,
        НСтр("ru = 'Выполнена полная перерегистрация данных для узла.'"));
 
КонецПроцедуры

Типичные ошибки

Ошибка	Последствие	Как избежать
Нет проверки `ОбменДанными.Загрузка`	Бизнес-логика срабатывает при загрузке, данные портятся или зацикливается обмен	В каждом обработчике ПриЗаписи в первых строках
Фиксация `НомерОтправленного` до подтверждения доставки	Изменения помечены как отправленные, но до узла не дошли; при следующем сеансе не выгрузятся	Фиксировать номер только после подтверждения получателя
Загрузка без проверки идемпотентности	Дублирование документов, двойные движения регистров	Проверять `НомерСообщения <= НомерПринятого` перед загрузкой
Конфликт без логирования	Данные тихо перезаписаны, потеряны правки пользователя	Всегда писать в ЖР при конфликте с уровнем Предупреждение
Регистрировать изменения внутри обработчика загрузки	Бесконечный обмен: А→Б→А→Б	Флаг `Загрузка = Истина` отключает регистрацию
Длинная транзакция при загрузке большого пакета	Блокировки, таймауты, откат всего пакета	Загружать пообъектно с отдельными транзакциями или батчами
Не удалять записи регистра изменений после выгрузки	Накопление миллионов записей, деградация производительности	`ПланыОбмена.УдалитьРегистрациюИзменений` после подтверждения

Связанные ресурсы

error-handling — канонический паттерн транзакций, обязательный при загрузке/выгрузке
background-jobs — обмен данными часто выполняется в фоновых заданиях

depends_on:

bsl-practices/error-handling
bsl-practices/background-jobs

← v1.0.0 All versions v1.0.2 →