Интеграция 1С с Битрикс CRM через REST API

Существуют стандартные интеграции Битрикс и 1С, но они умеют плюс/минус ничего, зато с использованием rest api Битрикса можно получать и передавать практически все что угодно, двигать сделки по этапам, назначать ответственных и т.п.

В рассматриваемом примере подключение к Битриксу происходит через Вебхуки (приложение в Битриксе).  В обработке данные берутся с формы, естественно, ничего не мешает заменить их на нужные источники – справочники, документы, бизнес-процессы и т.д.

Для изучения и тестирования методов настоятельно рекомендуется битриксовское же приложение «Документация по REST API». СРМу там посвящен свой раздел.

Обработка тестировалась на следующих версиях ПО:

1С-Битрикс: Корпоративный портал 18.1.8

1С:Предприятие 8.3 (8.3.14.1779)

Бухгалтерия предприятия КОРП, редакция 3.0 (3.0.70.39) (хотя конфигурация значения не имеет, в обработке используются только механизмы платформы)

Теория

Основная логика реализована в функции, которая действует по следующему алгоритму:

На входе получает структуру, где указан тип сущности, ее ORIGIN_ID (в боевых условиях для этих целей используются ГУИДы 1с) и структура всех полей  — типа названия, стоимости и т.д.

Ищет сущность в СРМ по ORIGIN_ID  

Если не находит – создает

Находит одну сущность – обновляет ее

Находит больше одной сущности – выдает ошибку

В случае успеха возвращает результат ок и Битрикс ИД созданной/обновленной сущности

В случае ошибки error и текст ошибки

&НаСервере
// Ищет и обновляет/создает сущность в СРМ Битрикс
// На входе - структура:
// СущностьСРМ - тип сущности, строка: contact, company, lead, deal, productsection, product
// ORIGIN_ID - ГУИД объекта 1С
// fields - структура полей для обновления
// Возвращает:
// Результат - ок/error
// Значение - если ок - битрикс ИД созданного/обновленного элемента, если error - текст ошибки
Функция СоздатьОбновитьСущностьБитрикс(СтруктураСущности)
//Готовим структуру для возврата
СтруктураСозданияОбновленияСущности = Новый Структура("Результат, Значение");

//Получаем настройки
ЛогинПортала = ЛогинПортала;
ПарольПортала = ПарольПортала;
АдресПортала = АдресПортала;
RestВебхук = RestВебхук;

//Создаем соединение
Соединение = Новый HTTPСоединение(АдресПортала, , ЛогинПортала, ПарольПортала,,, Новый ЗащищенноеСоединениеOpenSSL);

//Получаем название сущности СРМ
СущностьСРМ = СтруктураСущности.СущностьСРМ;

//Формируем запрос
HTTPЗапрос = Новый HTTPЗапрос(RestВебхук + "crm." + СущностьСРМ + ".list.json/");

//Запрос для поиска
СтрокаЗапроса = "";
Если СтруктураСущности.СущностьСРМ = "productsection" ИЛИ СтруктураСущности.СущностьСРМ = "product" Тогда
СтрокаЗапроса = СтрокаЗапроса + "filter[XML_ID]=" + КодироватьСтроку(СтруктураСущности.ORIGIN_ID, СпособКодированияСтроки.КодировкаURL);
Иначе
СтрокаЗапроса = СтрокаЗапроса + "filter[ORIGIN_ID]=" + КодироватьСтроку(СтруктураСущности.ORIGIN_ID, СпособКодированияСтроки.КодировкаURL);
КонецЕсли;

HTTPЗапрос.УстановитьТелоИзСтроки(СтрокаЗапроса, КодировкаТекста.UTF8);
HTTPОтвет = Соединение.ОтправитьДляОбработки(HTTPЗапрос);
СтруктураОтвета = HTTPОтвет.ПолучитьТелоКакСтроку();

//Разбираем ответ
ЧтениеJSON = Новый ЧтениеJSON;
ЧтениеJSON.УстановитьСтроку(СтруктураОтвета);
Попытка
СтруктураОтвета = ПрочитатьJSON(ЧтениеJSON);
Исключение
СтруктураСозданияОбновленияСущности.Результат = "error";
СтруктураСозданияОбновленияСущности.Значение = ОписаниеОшибки() + " | " + СтруктураОтвета;
Возврат СтруктураСозданияОбновленияСущности;
КонецПопытки;


//////////////
Если СтруктураОтвета.Свойство("total") И СтруктураОтвета.total = 1 Тогда
//Найдена одна сущность, обновляем
Соединение = Новый HTTPСоединение(АдресПортала, , ЛогинПортала, ПарольПортала,,, Новый ЗащищенноеСоединениеOpenSSL);
ИДНайденнойСущности = СтруктураОтвета.result[0].ID;
HTTPЗапрос = Новый HTTPЗапрос(RestВебхук + "crm." + СущностьСРМ + ".update.json?id=" + ИДНайденнойСущности);

СтрокаЗапроса = "";
Для Каждого Поле Из СтруктураСущности.fields Цикл
Если ТипЗнч(Поле.Значение) = Тип("Массив") И (Поле.Ключ = "CONTACT_IDS") Тогда
//Это для связанных объектов
Для Индекс = 0 По Поле.Значение.Количество()-1 Цикл
СтрокаЗапроса = СтрокаЗапроса + "&fields[" + Поле.Ключ + "][" + Индекс + "]=" + КодироватьСтроку(Поле.Значение[Индекс], СпособКодированияСтроки.КодировкаURL);
КонецЦикла;
ИначеЕсли ТипЗнч(Поле.Значение) = Тип("Массив") Тогда
//Сие для телефонов и почты
Для Индекс = 0 По Поле.Значение.Количество()-1 Цикл
СтрокаЗапроса = СтрокаЗапроса + "&fields[" + Поле.Ключ + "][" + Индекс + "][VALUE]=" + КодироватьСтроку(Поле.Значение[Индекс], СпособКодированияСтроки.КодировкаURL);
КонецЦикла;
Иначе
СтрокаЗапроса = СтрокаЗапроса + "&fields[" + Поле.Ключ + "]=" + КодироватьСтроку(Поле.Значение, СпособКодированияСтроки.КодировкаURL);
КонецЕсли
КонецЦикла;

HTTPЗапрос.УстановитьТелоИзСтроки(СтрокаЗапроса, КодировкаТекста.UTF8);
HTTPОтвет = Соединение.ОтправитьДляОбработки(HTTPЗапрос);
СтруктураОтвета = HTTPОтвет.ПолучитьТелоКакСтроку();

//Разбираем ответ
ЧтениеJSON = Новый ЧтениеJSON;
ЧтениеJSON.УстановитьСтроку(СтруктураОтвета);
СтруктураОтвета = ПрочитатьJSON(ЧтениеJSON);

Если СтруктураОтвета.Свойство("result") И СтруктураОтвета.result Тогда
//Все ок
СтруктураСозданияОбновленияСущности.Результат = "ок";
СтруктураСозданияОбновленияСущности.Значение = ИДНайденнойСущности;
Возврат СтруктураСозданияОбновленияСущности;
ИначеЕсли СтруктураОтвета.Свойство("error") Тогда
//Сервис вернул ошибку
ТекстОшибки = "Ошибка при обновлении " + СущностьСРМ + ": " + СтруктураОтвета.error;
Если СтруктураОтвета.Свойство("error_description") И СтруктураОтвета.error_description <> "" Тогда
ТекстОшибки = ТекстОшибки + ", error_description: " + СтруктураОтвета.error_description;
КонецЕсли;
СтруктураСозданияОбновленияСущности.Результат = "error";
СтруктураСозданияОбновленияСущности.Значение = ТекстОшибки;
Возврат СтруктураСозданияОбновленияСущности;
Иначе
//Прочая неизвестная хрень
СтруктураСозданияОбновленияСущности.Результат = "error";
СтруктураСозданияОбновленияСущности.Значение = "Неизвестная ошибка при обновлении " + СущностьСРМ + " с id=" + ИДНайденнойСущности;
Возврат СтруктураСозданияОбновленияСущности;
КонецЕсли;

ИначеЕсли СтруктураОтвета.Свойство("total") И СтруктураОтвета.total = 0 Тогда
//Не найдено, создаем
Соединение = Новый HTTPСоединение(АдресПортала, , ЛогинПортала, ПарольПортала,,, Новый ЗащищенноеСоединениеOpenSSL);
HTTPЗапрос = Новый HTTPЗапрос(RestВебхук + "crm." + СущностьСРМ + ".add.json/");

СтрокаЗапроса = "";

Если СтруктураСущности.СущностьСРМ = "productsection" ИЛИ СтруктураСущности.СущностьСРМ = "product" Тогда
СтрокаЗапроса = СтрокаЗапроса + "fields[XML_ID]=" + КодироватьСтроку(СтруктураСущности.ORIGIN_ID, СпособКодированияСтроки.КодировкаURL);
Иначе
СтрокаЗапроса = СтрокаЗапроса + "fields[ORIGIN_ID]=" + КодироватьСтроку(СтруктураСущности.ORIGIN_ID, СпособКодированияСтроки.КодировкаURL);
КонецЕсли;

Для Каждого Поле Из СтруктураСущности.fields Цикл
Если ТипЗнч(Поле.Значение) = Тип("Массив") И (Поле.Ключ = "CONTACT_IDS") Тогда
//Это для связанных объектов
Для Индекс = 0 По Поле.Значение.Количество()-1 Цикл
СтрокаЗапроса = СтрокаЗапроса + "&fields[" + Поле.Ключ + "][" + Индекс + "]=" + КодироватьСтроку(Поле.Значение[Индекс], СпособКодированияСтроки.КодировкаURL);
КонецЦикла;
ИначеЕсли ТипЗнч(Поле.Значение) = Тип("Массив") Тогда
//Сие для телефонов и почты
Для Индекс = 0 По Поле.Значение.Количество()-1 Цикл
СтрокаЗапроса = СтрокаЗапроса + "&fields[" + Поле.Ключ + "][" + Индекс + "][VALUE]=" + КодироватьСтроку(Поле.Значение[Индекс], СпособКодированияСтроки.КодировкаURL);
КонецЦикла;
Иначе
СтрокаЗапроса = СтрокаЗапроса + "&fields[" + Поле.Ключ + "]=" + КодироватьСтроку(Поле.Значение, СпособКодированияСтроки.КодировкаURL);
КонецЕсли
КонецЦикла;

HTTPЗапрос.УстановитьТелоИзСтроки(СтрокаЗапроса, КодировкаТекста.UTF8);
HTTPОтвет = Соединение.ОтправитьДляОбработки(HTTPЗапрос);
СтруктураОтвета = HTTPОтвет.ПолучитьТелоКакСтроку();

//Разбираем ответ
ЧтениеJSON = Новый ЧтениеJSON;
ЧтениеJSON.УстановитьСтроку(СтруктураОтвета);
СтруктураОтвета = ПрочитатьJSON(ЧтениеJSON);

//////////////
Если СтруктураОтвета.Свойство("result") И СтруктураОтвета.result <> "" Тогда
СтруктураСозданияОбновленияСущности.Результат = "ок";
СтруктураСозданияОбновленияСущности.Значение = Формат(СтруктураОтвета.result, "Л=ru_RU; ЧГ=0");
Возврат СтруктураСозданияОбновленияСущности;
ИначеЕсли СтруктураОтвета.Свойство("error") Тогда
//Сервис вернул ошибку
ТекстОшибки = "Ошибка при создании " + СущностьСРМ + ": " + СтруктураОтвета.error;
Если СтруктураОтвета.Свойство("error_description") И СтруктураОтвета.error_description <> "" Тогда
ТекстОшибки = ТекстОшибки + ", error_description: " + СтруктураОтвета.error_description;
КонецЕсли;
СтруктураСозданияОбновленияСущности.Результат = "error";
СтруктураСозданияОбновленияСущности.Значение = ТекстОшибки;
Возврат СтруктураСозданияОбновленияСущности;
Иначе
//Прочая неизвестная хрень
СтруктураСозданияОбновленияСущности.Результат = "error";
СтруктураСозданияОбновленияСущности.Значение = "Неизвестная ошибка при создании " + СущностьСРМ;
Возврат СтруктураСозданияОбновленияСущности;
КонецЕсли;
ИначеЕсли СтруктураОтвета.Свойство("total") И СтруктураОтвета.total > 1 Тогда
//Найдено больше одной компании, обтекаем
СтруктураСозданияОбновленияСущности.Результат = "error";
СтруктураСозданияОбновленияСущности.Значение = "Нарушена целостность данных. Найдено больше одной " + СущностьСРМ + " с одинаковым ORIGIN_ID";
Возврат СтруктураСозданияОбновленияСущности;
ИначеЕсли СтруктураОтвета.Свойство("error") Тогда
//Сервис вернул ошибку
ТекстОшибки = "Ошибка при поиске " + СущностьСРМ + ": " + СтруктураОтвета.error;
Если СтруктураОтвета.Свойство("error_description") И СтруктураОтвета.error_description <> "" Тогда
ТекстОшибки = ТекстОшибки + ", error_description: " + СтруктураОтвета.error_description;
КонецЕсли;
СтруктураСозданияОбновленияСущности.Результат = "error";
СтруктураСозданияОбновленияСущности.Значение = ТекстОшибки;
Возврат СтруктураСозданияОбновленияСущности;
Иначе
//Прочая неизвестная хрень
СтруктураСозданияОбновленияСущности.Результат = "error";
СтруктураСозданияОбновленияСущности.Значение = "Неизвестная ошибка при поиске " + СущностьСРМ;
Возврат СтруктураСозданияОбновленияСущности;
КонецЕсли;
КонецФункции

Использование обработки для тестирования

Указываем настройки

Адрес  портала в виде «portal.mysite.com»  ( без https:// )

Логин и пароль портала если используется http авторизация

Вебхук в виде «rest/1234/abc7skjbv1vyqxb2/» — т.е. точка доступа и собственно вебхук в одной строке

Отправка

Контакты и товары можно создавать независимо. Для создания сделки с контактом и товаром, а также для движения сделки по стадиям нужно заполнить все поля, так как каждый раз создаются/обновляются все сущности.

Результат на портале