Интеграция информационных систем через 1С:Шина: от теории к реализации

Схема обмена данными через 1С:Шину

На рисунке показана общая схема интеграции трёх информационных баз с использованием 1С:Шина: маршрутизатор, через который сортируются полученные данные, каналы источника и приемника, группа «Офис» и группа «Магазин».

В состав группы «Магазин» входят две розничные базы с уникальным кодом идентификации, по которому система определяет отправителя или получателя данных. В состав группы «Офис» входит основная база в центральном офисе.

Процесс передачи данных из «Офис» идет напрямую в «Магазин». Так как в нашем примере основная база в единственно экземпляре, то нет необходимости возвращать данные из офиса в офис, а передает данные из «Магазин» и направляется к блоку «Маршрутизатор», чтобы определить в каком направлении отправить сообщение или «ВОфис», или «ВМагазин».

У каждой розничной базы есть свой остаток товара, именно его и передадим офису, а в конце примера убедимся, что остатки верны.

Для примера передачи данных используем внешняя обработку, через которую отправим сообщение в информационную базу «Магазин», чтобы обратно принять информацию об остатках товаров для «Офиса».

Выбираем идентификатор магазина «shop». Обязательно должен совпадать с идентификатор в 1C:Шина и нажимаем «Отправить запрос».

В панели управлении 1С:Шина можем заметить, что служебные фоновые задания, настроенные в информационных базах, запускаются и статусы баз меняются на зеленый цвет. Это означает, что они готовы принимать сообщения.

Также можно проследить, что сообщение находится в одном из каналов при передаче данных. В нашем примере сообщение находится в канале «ВМагазин» для идентификатора «shop» и ждёт дальнейших указаний. Статус становится красным, так как служебные фоновые задания завершаются через 2 минуты с момента последнего его вызова.

После доставки сообщение исчезает из канала ожидания, а система помечает его как доставленное.

Во вкладке «Метрики» мы можем проследить по каким узлам перемещалось сообщение и при необходимости быстро определить, на каком этапе остановилось сообщение, если произошла ошибка.

После получения данных отчет об остатках будет в головном офисе во входящих письмах.

Можем убедиться, что остатки совпадают с остатками отправителя. Во входящем письме отображаются запрошенные данные, а также отправитель, тема сообщения и дата получения.

Подобные проекты специалисты ИнфоСофт регулярно реализуют при внедрении и модернизации корпоративных информационных систем на платформе 1С. Далее разберем практическую настройку 1С:Шина на реальном примере.

Техническая реализация: настройка и код

Для настройки и запуска обмена нужна система управления базами данных и желательно актуальная версия 1С:Шины со средой разработки. В этой статье используется 1С:Шина версия 9.1.10, а в качестве СУБД - PostgreSQL 17.

Для дальнейшей работы нужно добавить СУБД в инфраструктуру 1С:Шины.

После добавления СУБД создадим новое приложение. Обратите внимание на поле «Режим разработки», в котором нужно проставить галочку и «Тип СУБД» - выбрать ранее добавленную СУБД.

Может потребоваться некоторое время перед тем, как статус приложения сменится на «Работает» и появится возможность перейти к разработке. Спустя некоторое время, нажмите на ссылку в строке приложения «Разработать».

Откроется новая вкладка со средой разработки, в которой нужно добавить новый элемент «Процесс интеграции» в ветку «Основное».

Для построения схемы используем «Палитру узлов». Здесь находятся все основные объекты, которые будут использоваться дальше.

Перейдём к созданию схемы обмена. Главными элементами на схеме выступают «Офис» и «Магазин». Переместите два элемента «ГруппаУчастников» и задайте им наименования.

Для передачи данных нужны связующие каналы. Добавим из раздела «Источники» два канала «Канал1СИсточник».

Также на схеме нужны каналы для получения данных. Добавим из раздела «Приемники» два канала «Канал1СНазначение».

После добавим главный элемент маршрутизации «МаршрутизаторПоСодержимому» из раздела «Маршрутизаторы».

Далее соединим блоки. Входящие и исходящие связи из «Офис» и «Магазин», отмеченные синими стрелками, соединим узлом «Связь». Для соединения остальных блоков, отмеченных красными стрелками, используется узел «Маршрут».

Для настройки маршрутизации нужно задать событие в свойствах маршрутизации.

В данном окне пропишите свой код маршрутизации по содержимому. В примере используем параметр «ТипСообщения», который определяет, в какой узел отправить данные.

Чтобы обновить проект на сервере, нужно «Опубликовать проект» или нажмите F9.

За ходом обновления проекта вы можете наблюдать в левом нижнем углу строки состояния среды разработки. Статус «updating» изменится на статус «running».

Это означает, что приложение успешно обновилось. Для отладки приложения, нужно «Начать отладку приложения» или нажмите F5 и откроется новая вкладка c процессом.

Ваши информационные базы нужно добавить в «Инфосистемы». Укажите код базы и наименование. После обязательно нажмите на кнопку «Выдать ключ API» и запишите для каждой базы идентификатор ключа и секрет клиента.

Перейдите к процессу. Добавленные базы нужно внести в состав группы «Офис» и «Магазин».

Отметьте соответствующие базы для состава групп и нажмите кнопку «Добавить в группу».

Настройка приложения закончена. Осталось запустить процесс и перейти к настройки информационных баз. Если ваш процесс не в статусе «Запущен», то нажмите на иконку запуска.

На этом этапе нужно добавить в каждую из информационных баз объект конфигурации вида Сервис интеграции. В поле «Адрес внешнего сервиса интеграции» установите адрес приложения «1С:Шины».

На вкладке «Основные» нажмите «Действия», чтобы загрузить каналы.

В открывшейся форме укажите идентификатор ключа и секрет клиента, полученные на этапе создания информационных систем в приложении 1С:Шина. Затем нажмите кнопку «Получить каналы сервиса». В списке снимите флажки с каналов, которые не имеют отношения к вашей информационной базе, то есть для офиса необходимо оставьте «ВОфис», «ИзОфиса» и нажмите «Загрузить».

Создадим для примера внешнюю обработку с тремя реквизитами и одной командой, чтобы передавать данные/сообщения. Первый реквизит «ВсеМагазины» тип булево нужен для передачи информации всем магазинам. Второй реквизит «ВыбранныйМагазин» тип подразделения нужен для выбора конкретного магазина. Третий реквизит «Магазин» тип булево нужен для передачи информации из магазина в другой магазин. Создадим команду «ОтправитьЗапрос» и разместим ее на форме.

1С:Шина поддерживает передачу сообщений с телом и без тела. Полезная нагрузка может передаваться как в теле сообщения, так и в его параметрах. В качестве примера, иллюстрирующего оба варианта работы, разберем следующий сценарий:

• Офис передает в магазин сообщение без тела, выполняющее запрос информации по остаткам товаров.
• В ответ магазин передает файл в двоичном виде, содержащий запрошенный отчет об остатках.

Перейдём к коду команды из примера обработки. Есть два условия для передачи сообщения: либо информация передаётся из магазина в офис, либо из магазина в другой магазин. Разберем первый случай.

С помощью метода «СоздатьСообщение» создается экземпляр сообщения. В свойстве «КодПолучателя» указывается код информационной системы, именно этому участнику обмена 1С:Шина будет доставляться сообщение. Важно, что в примере коды записей справочника Подразделения должны совпадать с кодами добавленных баз в 1С:Шина. Если свойство «КодПолучателя» не задано, то сообщение считается широковещательным и доставляется всем доступным получателям в соответствии со схемой процесса интеграции.

Затем создается параметр сообщения с именем «ТипСообщения» и в качестве значения ему устанавливается строка «ЗапросОстатков». Это нужно для того, чтобы определить получателя в маршрутизации и для дальнейшей обработки в каналах информационных баз. Далее с помощью метода «ОтправитьСообщение» сообщение передается для отправки.

Откройте конфигуратор информационной базы «Магазин» и перейдите в модуль сервиса интеграции. В момент загрузки канала «ВМагазин» был создан пустой обработчик. Напишем код, который будет проверять тип полученного сообщения и, если пришел запрос остатков, формировать соответствующий отчет и отправлять его обратно.

Код формирует отчёт «Остатки товаров на складах», сохраняет его в файл с двоичным содержимым, задавая размер файла. Это нужно, чтобы эффективно реализовать код обработки полученного сообщения. Далее методом «ПолучитьТелоКакПоток» вы получаете двоичный поток, в который записываете файл с результатом отчета. Задаём «ТипСообщения» для дальнейшей маршрутизации и с помощью метода «ОтправитьСообщение» отправляем дальше по узлу схемы 1С:Шина.

Откройте конфигуратор информационной базы «Офис» и перейдите в модуль сервиса интеграции. В канал «ВОфис» запишем код получения сообщения.

Получаем размер файла/сообщения из параметров входящего сообщения. Если размер известен, то используем его для буфера. Если нет, то берём буфер по 1 КБ. Это нужно для эффективного чтения данных. Для доступа к телу сообщения используется метод «ПолучитьТелоКакПоток», который возвращает двоичный поток. Далее содержимое потока считывается в буфер и преобразуется в строку, содержащую исходный текст HTML-страницы с отчетом.

Используя метод «ПолучитьСтрокуИзБуфераДвоичныхДанных», получаем текст отчета. Далее создаём «ВходящиеПисьма» и задаём параметры отправителя, даты, наименования и т.д. Создаём набор записей регистра «СостояниеВходящихПисем» и устанавливаем отбор по новому письму. Добавляем запись в регистр, указывая, что письмо ещё не прочитано. Сохраняем сам объект письма в базу.

Разберем второй случай. Для передачи сообщения из магазина в другой магазин нам понадобиться немного измененный код от передачи данных в офис. Откройте внешнюю обработку и вставьте код, формирующий отчёт «Остатки товаров на складах» и сохраняющий его в файл с двоичным содержимым, но измените параметры «ТипСообщения», чтобы в маршрутизации перенаправлять в канал «ВМагазин», «КодПолучателя» и удалите «ИдентификаторСообщенияЗапроса».

Откройте конфигуратор второй информационной базы «Магазин» и перейдите в модуль сервиса интеграции. В канал «ВМагазин» скопируйте код для получения сообщения из канала «ВОфис» без изменений. Таким образом мы сможем получить отчет об остатках товара в нашем втором магазине.

Метод «ОтправитьСообщение» создает запись в служебной таблице информационной базы. Служебное фоновое задание в 1С:Шина отправляет сообщения позже, служебным фоновым заданием. Для запуска служебных фоновых заданий вам нужно вызвать метод «СервисыИнтеграцииМенеджер.ВыполнитьОбработку». Они запускаются в момент первого вызова этого метода и завершаются через 2 минуты с момента последнего его вызова. Поэтому, чтобы служебные фоновые задания работали непрерывно, этот метод нужно вызывать периодически. Рекомендуемая периодичность - 1 раз в минуту. Чтобы реализовать периодический вызов этого метода, создайте регламентное задание.

После успешной настройки конфигураций запустите информационную базу «Магазин» от имени пользователя с административными правами и откройте «Функции для технического специалиста». Нужно открыть «Управление сервисами интеграции».

В списке доступных сервисов интеграции вы увидите единственную запись. Нажмите «Редактировать» и в открывшемся окне в полях «Имя пользователя» и «Пароль пользователя» укажите идентификатор ключа и секрет клиента соответственно. Нажмите «ОК» для сохранения настроек. Чтобы запустить обмен сообщениями, нажмите «Установить активность». Сделайте аналогичные настройки в информационной базе «Офис» и во второй базе «Магазин».

Рекомендации по дальнейшему развитию

Начинайте с простых сценариев - например, с обмена справочниками и остатками. Когда процесс отладится, постепенно добавляйте более сложную логику: обработку заказов, перемещений, ценообразования. Не забывайте активно пользоваться встроенным мониторингом 1С:Шина - это ваш главный помощник при поиске и разборе проблем.

Польза для бизнеса

1С:Шина удобный инструмент интеграции, который особенно эффективен при работе с тремя и более информационными базами.

Вместо создания множества прямых соединений между системами, что значительно усложняет дальнейшую поддержку, 1С:Шина объединяет все обмены в одной точке, централизованный мониторинг и высокую гибкость настройки маршрутизации и трансформации данных.

В рассмотренном кейсе с одной базой офиса и двумя базами магазинов применение 1С:Шина позволило сделать обмен данными прозрачным, надёжным и существенно более простым в сопровождении.

Если необходимо интегрировать несколько информационных баз, рекомендуем использовать 1С:Шина как основное решение.

Хотите так же связать свои информационные системы через 1С:Шину?