Использование REST API Bitrix24 — различия между версиями
(Новая страница: «Инструкция по интеграции с облачным сервисом Bitrix24 Общий порядок работы с OAuth при создан…») |
(нет различий)
|
Версия 06:54, 16 июня 2015
Инструкция по интеграции с облачным сервисом Bitrix24
Общий порядок работы с OAuth при создании приложений для Битрикс24 регистрируется своё приложение в Маркетплейсе Битрикс24; запрашиваются с удаленного сервера ключи; сервер перенаправляет браузер на зарегистрированный приложением URL; обрабатывается ответ; подписываются полученным ключом все запросы к Rest API.
Содержание
Регистрация приложения в Маркетплейс Битрикс24
C 25 мая 2015г. Для того чтобы добавлять свои приложения на портал больше не требуется становиться технологическим партнером.
Если у вас права администратора на вашем портале, зайдите в раздел Приложения - Добавить приложение. Выбрать для личного пользования (в этом случае, никто кроме вас и вашего портала не сможет использовать это приложение)
Откроется форма добавления приложения
В форме заполняем: 1)Название приложения — произвольное. 2)Приложение использует только API – обязательно 3)Права доступа — указываем к каким разделам будет доступ у данного приложения 4)Укажите ссылку — указываем произвольный ваш сайт (или любую произвольную страницу).
После этого нажимаем «Сохранить» После этого мы увидим «Список локальных приложений», в котором будет указан «Код приложения» и «Ключ приложения». Они будут необходимы в дальнейшем для авторизации и выполнении методов REST API.
OAuth-авторизация для desktop-приложения
Алгоритм: 1. При помощи client_id получаем параметр code, требуемый для получения авторизационного токена. 2. При помощи clent_id, client_secret и code приложение получает параметры access_code и refresh_token. 3. При помощи access_code приложение совершает запросы к REST-сервису до его истечения. 4. Через час access_code истекает, и приложение может использовать полученный refresh_token для получения нового. 5. Если refresh_token еще не истек (с момента его получения не прошел месяц), то приложение получает свежий access_code и свежий refresh_token, после чего, можно перейти к шагу 3. 6. Если refresh_token уже истек, то требуется повторная авторизация с участием пользователя.
По сути, физическая авторизация пользователя требуется только на шаге 1. В итоге получаем, что если приложение используется постоянно (шаг 4 используется чаще раза в месяц), то приложение имеет возможность продлевать авторизацию не трогая пользователя сколь угодно долго.
Рассмотрим данный алгоритм более подробно. Desktop приложение должно слушать какой-либо порт на localhost (Октелл как правило слушает порт 4055). 1)Для авторизации необходимо открыть браузер и перейти на адрес вида: https://мой_портал.bitrix24.ru/oauth/authorize/?client_id=код_приложения&response_type=code&redirect_uri=http%3A%2F%2Foktell.ru
, где мой_портал.bitrix24.ru — адрес портала, например oktell.bitrix24.ru client_id — код приложения, который был получен на после успешной регистрации приложения. response_type — тип ответа — код (константа) redirect_uri — адрес который был указан при создании приложения в Маркетплейс (необходимо указывать urlencode), например http%3A%2F%2Foktell.ru
2)Далее произойдет редирект на адрес вида:
http://redirect_uri/?code=код_получения_авторизации&domain=мой_портал.bitrix24.ru
, где code – код получения авторизации, необходим для выполнения дальнейших шагов. domain – адрес портала Битрикс24 (например oktell.bitrix24.ru)
После получения этих данных браузер больше не нужен. Данные которые были получены в результате создания приложения и полученный code необходимо внести в таблицу oktell.dbo.bitrix_oauth в соответствующие поля.
3)Приложение (Октелл) должно сделать http-запрос к адресу вида: https://мой_портал.bitrix24.ru/oauth/token/?client_id=код_приложения&grant_type=authorization_code&client_secret=секретный_ключ_приложения&redirect_uri=http%3A%2F%2Flocalhost%3A70005&code=код_получения_авторизации&scope=требуемый_набор_разрешений
, где мой_портал.bitrix24.ru — адрес портала, например oktell.bitrix24.ru client_id — код приложения, который был получен на после успешной регистрации приложения. client_secret – секретный ключ приложения, который был получен на после успешной регистрации приложения. redirect_uri — адрес на который должен произойти редирект, как правило запрос выполняется в браузере на сервере где установлен Октелл и поэтому указывается ссылка вида — http%3A%2F%2Flocalhost%3A4055 (urlencode от http://localhost:4055) code - код получения авторизации scope – требуемый набор разрешений (например: scope=task,crm)
В ответ сервер вернет json-структура со всеми необходимыми для совершения запросов к серверу данными.
{"access_token":"XXXXXXXXXXXXXXXX","expires_in":3600,"scope":"crm","user_id":41,"refresh_token":"XXXXXXXXXXXXXXXXXXXXXX","domain":"oktell.bitrix24.ru","member_id":"XXXXXXXXXXXXXXXXXXXXXXXXXXX"}
, где access_token – ключ для отправки запросов к REST-сервису expires_in – период действия данного at (access_token) scope – объекты к которым предоставлен доступ user_id – id пользователя от имени которого произошла авторизация refresh_token - маркер обновления, для получения нового access_token domain – домен к которому был получен доступ member_id - уникальный идентификатор портала
Все, приложение может совершать запросы к REST-сервису.
4)При достижении периода жизни at необходимо отправить запрос на получение нового at на следующего вида:
https:// мой_портал.bitrix24.ru /oauth/token/?client_id=xxxxx&grant_type=refresh_token&client_secret=xxxxx&redirect_uri= http%3A%2F%2Flocalhost%3A4055 &refresh_token=zzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzz , где мой_портал.bitrix24.ru — адрес портала, например oktell.bitrix24.ru client_id — код приложения, который был получен на после успешной регистрации приложения. grant_type – константа – refresh_token client_secret – секретный ключ приложения, который был получен на после успешной регистрации приложения. redirect_uri — адрес на который должен произойти редирект, как правило запрос выполняется в браузере на сервере где установлен Октелл и поэтому указывается ссылка вида — http%3A%2F%2Flocalhost%3A4055 (urlencode от http://localhost:4055) refresh_token - маркер обновления, для получения нового access_token
В результате выполнения данного запроса будет возвращена json-структура вида: {"access_token":"XXXXXXXXX","expires_in":3600,"scope":"task,crm","user_id":41,"refresh_token":"XXXXXXXXXXXXXXXX","domain":"oktell.bitrix24.ru","member_id":"XXXXXXXX"}
access_token, который хранится в БД обновляется каждый час, для того чтобы была возможность непрерывно выполнять любые запросы к Bitrix24.
Пример сценария, который отправляет запрос на получение access_token, после получения code и обновляет access_token по существующему refresh_token:
Пример использования REST API
Рассмотрим пример получения списка всех лидов. Для этого нам понадобятся 2 метода: crm.lead.list - Возвращает список лидов по фильтру, при этом фильтры использоваться не будут это означает, что будет получаться весь список лидов (в дальнейшем имеет смысл рассмотреть применение фильтра и получать только тех, кто был изменен после последней синхронизации). crm.lead.get - Возвращает лид по идентификатору, с помощью данного метода мы получим контактные данные по лиду – телефон, e-mail, web-сайт.
Сценарий «bitrix_crm_lead_list»
0) Выводим уведомление о Запуске сценария и Получаем текущую дату и время для того чтобы отобразить время выполнения сценария. Дату и время получаем из функции «Текущие дата и время». 1)В данном сценарии как и в любом другом удобно использовать существующий, автоматически обновляемый access_token, который мы получили в предыдущей главе. Получаем данные из таблицы oktell.dbo.bitrix_oauth для выполнения REST запроса. Текст выполняемого запроса - select @access_token=access_token,
@domain=domain
from oktell.dbo.bitrix_oauth where client_id='client_id'
2) Устанавливаем счетчик для получения списка лидов = 0 и счетчик последней итерации = 0 и счетчик итераций получения лидов=0
3) Получаем первые N лидов, во второй итерации след N лидов, количество N получаем после выполнения 1-го запроса и в каждом последующем, так же после первого запроса получим сколько всего лидов. В примере: 'https://'+[domain]+'/rest/crm.lead.list?start='+[counter_lead_start]+'&auth='+[access_token]
4) Получаем сколько всего лидов. Используется компонент Парсер с алгоритмом «Парсер JSON». В примере: поисковый запрос - total
Важно! Все компоненты парсер в данном сценарии используют алгоритм «Парсер JSON».
5) Записываем в счетчик получения лидов начальный номер для следующей итерации. В примере: поисковый запрос - next 5.1)Если парсер JSON выполнился с ошибкой, это означает что счетчик для следующей итерации отсутствует, что свидетельствует о последней итерации, тогда дополнительно определяем счетчик последней итерации и устанавливаем для последней итерации счетчик получения лидов = сколько всего лидов (total)
6) Устанавливаем счетчик для получения N-го лида парсером (как правило счетчик будет бегать от 0 до 49). 7) Получаем N-ый лид для дальнейшего парсинга (Парсер JSON). В примере: поисковый запрос- выражение - '"result"/'+[counter_lead_parse]
7.1)Далее идет серия JSON парсеров по тегам которые необходимы для сохранения (количество тегов можно менять в зависимости от условий, главное всегда получать как минимум тег “ID”, который соответствует № лида).
Важно! У компонентов парсер всегда должны быть назначены переходы по ветке «Ошибка», т.к. в случае если данных в этом поле не будет парсер отработает именно по этому переходу и если он не указан, то сценарий завершится.
8) Обновляем лид в таблице - [oktell].[dbo].[bitrix_leads] если он там есть и добавляем если нет, определение происходит по sql_ID (по № лида). Текст выполняемого запроса - if exists (select * from oktell.dbo.bitrix_leads where sql_ID=replace(@sql_ID,'"',))
UPDATE [oktell].[dbo].[bitrix_leads]
SET [sql_ADDRESS] = replace(@sql_ADDRESS,'"',)
,[sql_ADDRESS_2] = replace(@sql_ADDRESS_2,'"',)
,[sql_ADDRESS_CITY] = replace(@sql_ADDRESS_CITY,'"',)
,[sql_ADDRESS_COUNTRY] = replace(@sql_ADDRESS_COUNTRY,'"',)
,[sql_ADDRESS_COUNTRY_CODE] = replace(@sql_ADDRESS_COUNTRY_CODE,'"',)
,[sql_ADDRESS_POSTAL_CODE] = replace(@sql_ADDRESS_POSTAL_CODE,'"',)
,[sql_ADDRESS_PROVINCE] = replace(@sql_ADDRESS_PROVINCE,'"',)
,[sql_ADDRESS_REGION] = replace(@sql_ADDRESS_REGION,'"',)
,[sql_ASSIGNED_BY_ID] = replace(@sql_ASSIGNED_BY_ID,'"',)
,[sql_BIRTHDATE] = cast(replace(@sql_BIRTHDATE,'"',) as datetime2(0))
,[sql_COMMENTS] = replace(@sql_COMMENTS,'"',)
,[sql_COMPANY_ID] = replace(@sql_COMPANY_ID,'"',)
,[sql_COMPANY_TITLE] = replace(@sql_COMPANY_TITLE,'"',)
,[sql_CONTACT_ID] = replace(@sql_CONTACT_ID,'"',)
,[sql_CREATED_BY_ID] = replace(@sql_CREATED_BY_ID,'"',)
,[sql_CURRENCY_ID] = replace(@sql_CURRENCY_ID,'"',)
,[sql_DATE_CLOSED] = cast(replace(@sql_DATE_CLOSED,'"',) as datetime2(0))
,[sql_DATE_CREATE] = cast(replace(@sql_DATE_CREATE,'"',) as datetime2(0))
,[sql_DATE_MODIFY] = cast(replace(@sql_DATE_MODIFY,'"',) as datetime2(0))
,[sql_LAST_NAME] = replace(@sql_LAST_NAME,'"',)
,[sql_MODIFY_BY_ID] = replace(@sql_MODIFY_BY_ID,'"',)
,[sql_NAME] = replace(@sql_NAME,'"',)
,[sql_OPENED] = replace(@sql_OPENED,'"',)
,[sql_OPPORTUNITY] = replace(@sql_OPPORTUNITY,'"',)
,[sql_ORIGIN_ID] = replace(@sql_ORIGIN_ID,'"',)
,[sql_ORIGINATOR_ID] = replace(@sql_ORIGINATOR_ID,'"',)
,[sql_POST] = replace(@sql_POST,'"',)
,[sql_SECOND_NAME] = replace(@sql_SECOND_NAME,'"',)
,[sql_SOURCE_DESCRIPTION] = replace(@sql_SOURCE_DESCRIPTION,'"',)
,[sql_SOURCE_ID] = replace(@sql_SOURCE_ID,'"',)
,[sql_STATUS_DESCRIPTION] = replace(@sql_STATUS_DESCRIPTION,'"',)
,[sql_STATUS_ID] = replace(@sql_STATUS_ID,'"',)
,[sql_TITLE] = replace(replace(@sql_TITLE,'"',),'\',)
WHERE sql_ID=replace(@sql_ID,'"',)
else
INSERT INTO [oktell].[dbo].[bitrix_leads]
([sql_ADDRESS]
,[sql_ADDRESS_2]
,[sql_ADDRESS_CITY]
,[sql_ADDRESS_COUNTRY]
,[sql_ADDRESS_COUNTRY_CODE]
,[sql_ADDRESS_POSTAL_CODE]
,[sql_ADDRESS_PROVINCE]
,[sql_ADDRESS_REGION]
,[sql_ASSIGNED_BY_ID]
,[sql_BIRTHDATE]
,[sql_COMMENTS]
,[sql_COMPANY_ID]
,[sql_COMPANY_TITLE]
,[sql_CONTACT_ID]
,[sql_CREATED_BY_ID]
,[sql_CURRENCY_ID]
,[sql_DATE_CLOSED]
,[sql_DATE_CREATE]
,[sql_DATE_MODIFY]
,[sql_ID]
,[sql_LAST_NAME]
,[sql_MODIFY_BY_ID]
,[sql_NAME]
,[sql_OPENED]
,[sql_OPPORTUNITY]
,[sql_ORIGIN_ID]
,[sql_ORIGINATOR_ID]
,[sql_POST]
,[sql_SECOND_NAME]
,[sql_SOURCE_DESCRIPTION]
,[sql_SOURCE_ID]
,[sql_STATUS_DESCRIPTION]
,[sql_STATUS_ID]
,[sql_TITLE])
VALUES
(replace(@sql_ADDRESS,'"',)
,replace(@sql_ADDRESS_2,'"',)
,replace(@sql_ADDRESS_CITY,'"',)
,replace(@sql_ADDRESS_COUNTRY,'"',)
,replace(@sql_ADDRESS_COUNTRY_CODE,'"',)
,replace(@sql_ADDRESS_POSTAL_CODE,'"',)
,replace(@sql_ADDRESS_PROVINCE,'"',)
,replace(@sql_ADDRESS_REGION,'"',)
,replace(@sql_ASSIGNED_BY_ID,'"',)
,cast(replace(@sql_BIRTHDATE,'"',) as datetime2(0))
,replace(@sql_COMMENTS,'"',)
,replace(@sql_COMPANY_ID,'"',)
,replace(@sql_COMPANY_TITLE,'"',)
,replace(@sql_CONTACT_ID,'"',)
,replace(@sql_CREATED_BY_ID,'"',)
,replace(@sql_CURRENCY_ID,'"',)
,cast(replace(@sql_DATE_CLOSED,'"',) as datetime2(0))
,cast(replace(@sql_DATE_CREATE,'"',) as datetime2(0))
,cast(replace(@sql_DATE_MODIFY,'"',) as datetime2(0))
,replace(@sql_ID,'"',)
,replace(@sql_LAST_NAME,'"',)
,replace(@sql_MODIFY_BY_ID,'"',)
,replace(@sql_NAME,'"',)
,replace(@sql_OPENED,'"',)
,replace(@sql_OPPORTUNITY,'"',)
,replace(@sql_ORIGIN_ID,'"',)
,replace(@sql_ORIGINATOR_ID,'"',)
,replace(@sql_POST,'"',)
,replace(@sql_SECOND_NAME,'"',)
,replace(@sql_SOURCE_DESCRIPTION,'"',)
,replace(@sql_SOURCE_ID,'"',)
,replace(@sql_STATUS_DESCRIPTION,'"',)
,replace(@sql_STATUS_ID,'"',)
,replace(replace(@sql_TITLE,'"',),'\',))
8.1)Если sql запрос по добавлению\обновлению лида выполнился с ошибкой, то Записываем информацию об ошибке в таблицу [oktell].[dbo].[bitrix_import_lead_error]
Текст выполняемого запроса -
insert into oktell.dbo.bitrix_import_lead_error
([sql_ID]
,[sql_error]
,[sql_full_lead_info]
,[sql_date_error])
values
(@sql_id,
@sql_error, @sql_dull_lead_info, getdate())
9) Увеличиваем счетчик для получения N-го лида на 1 (+1)
10) После этого происходит проверка Счетчик получения N-го лида меньше чем Счетчик количества полученных лидов в веб-запросе? Текст выражения - [Счетчик итераций получения списка лидов]*50+num([counter_lead_parse]) В выражении используем коэффициент в виде счетчика итераций получения списка лидов, для того чтобы корректно проходить по всем лидам которые получили в результате web-запроса. Например при первой итерации пройдем по 0*50+[0..49] лидам, при второй по 1*50+[0..49], т.е. с 50 по 99 лид и т.д.
10.1)Если да, то переходим на шаг 7) 10.2)Если нет, то переходим на шаг 11) 11) Увеличиваем Счетчик итерации получения списка лидов +1
12)Проверяем Счетчик последней итерации=1?
12.1)Если да, то переходим на шаг 13) 12.2)Если нет, то переходим на шаг 3) 13)Отображаем уведомление о Завершении сценария со временем выполнения. Текст уведомления — выражение - 'Сценарий импорта лидов завершен! Последний стартовый ID: '+[counter_lead_start]+endline+ 'Всего лидов: '+[counter_total]+endline+ 'Время выполнения: ' + DateDiff( s,[Дата запуска сценария], NOW )+' секунд'
14) Обновляем данные по завершению сценария в таблице oktell.dbo.bitrix_lead_runtime Текст выполняемого запроса - if exists (select lead_list_dt from oktell.dbo.bitrix_lead_runtime where id=1) update oktell.dbo.bitrix_lead_runtime set lead_list_dt=getdate() where id=1
else
insert into oktell.dbo.bitrix_lead_runtime (lead_list_dt) values (getdate()) 15) Производим Запуск сценария bitrix_crm_lead_get_by_id, в котором мы обновим контакты лидов, при первом запуске будут получены все контакты, при дальнейших запусках только контакты у лидов которые были обновлены после выполнения данного сценария.
Сценарий «bitrix_crm_lead_get_by_id»
В данном сценарии будет последовательно обрабатываться каждый № лида, т.к. это могло бы занять достаточно много времени, проверять будем только те лиды, которые были изменены после предыдущего запуска данного сценария (если он запускается в первый раз, то получим данные по всем лидам). Дату запуска получаем из таблицы [oktell]. [dbo].[bitrix_lead_runtime]
0) Выводим уведомление о Запуске сценария и Получаем текущую дату и время для того чтобы отобразить время выполнения сценария. Дату и время получаем из функции «Текущие дата и время».
1) Получаем данные из таблицы oktell.dbo.bitrix_oauth для выполнения REST запроса
Текст запроса -
select @access_token=access_token,
@domain=domain
from oktell.dbo.bitrix_oauth where client_id='client_id' 2) Присваиваем счетчику для перебора лидов отрицательное значение, это необходимо для получение первого лида.
3) SQL-запрос. Получение N-го лида. Получаем № лида (ID)
Текст запроса -
declare @dt datetime
if exists(select coalesce(lead_get_by_id_dt,) from oktell.dbo.bitrix_lead_runtime where id=1) select @dt=coalesce(lead_get_by_id_dt,) from oktell.dbo.bitrix_lead_runtime where id=1 else select @dt=
select top 1 @sql_ID=sql_ID from [oktell].[dbo].[bitrix_leads] where sql_ID>@counter_id
and sql_date_modify>=@dt
set @res=@@rowcount
4) sql_result>0? – в результате выполнения запроса нашелся хотя бы один лид?
4.1)Если да, то идем на шаг 5) 4.2)Если нет, то Обновляем данные о времени выполнения в таблице [oktell].[dbo].[bitrix_lead_runtime] и выводим уведомление с временем завершения сценария. Текст запроса - if exists (select * from oktell.dbo.bitrix_lead_runtime where id=1) update oktell.dbo.bitrix_lead_runtime set lead_get_by_id_dt=getdate() where id=1
else
insert into oktell.dbo.bitrix_lead_runtime (lead_get_by_id_dt) values (getdate()) 5)Выполняем web-запрос и получаем информацию по N-му лиду передавая его ID
Текст запроса — выражение вида - 'https://'+[domain]+'/rest/crm.lead.get?id='+[sql_ID]+'&auth='+[access_token] 6)Получаем «Выбранное решение» лидом (опционально, можно убрать данный компонент) Текст запроса — выражение вида - '"result"/"UF_CRM_1387525788"/'+str([i])
7) Добавляем выбранное клиентом решение в таблицу - oktell.dbo.bitrix_lead_solution (опционально, можно убрать данный компонент) Текст запроса - if exists (select * from oktell.dbo.bitrix_lead_solution where sql_LEAD_ID=replace(@sql_ID,'"',)) update oktell.dbo.bitrix_lead_solution set sql_solution=replace(@solution,'"',) where sql_LEAD_ID=replace(@sql_ID,'"',)
else
insert into oktell.dbo.bitrix_lead_solution (sql_LEAD_ID, sql_solution) values (replace(@sql_ID,'"',), replace(@solution,'"',))
8)Устанавливаем Счетчик i =0, он необходим для того, чтобы из JSON структуры мы могли получить произвольное количество e-mail на следующей цепочке шагов. 9)Подсчитываем количество e-mail у лида. Компонент Парсер. Текст запроса — выражение вида - "result"/"EMAIL"
10)Получаем i-ый e-mail и выполняем серию компонентов Парсер JSON, для получения каждого из них. Получаем структуру вида: {"ID"="1111", "TYPE_ID"="EMAIL", "VALUE"="name@domen.ru", "VALUE_TYPE"="WORK"}
11)Каждый из них добавляем в таблицу oktell.dbo.bitrix_lead_contacts Текст запроса - if exists (select * from oktell.dbo.bitrix_lead_contacts where sql_LEAD_ID=replace(@sql_ID,'"',) and sql_CONTACT_ID=replace(@sql_CONTACT_ID,'"',)) begin /*begin if 1*/ if (coalesce(replace(@sql_CONTACT_ID,'"',),)+coalesce(replace(@sql_VALUE_TYPE,'"',),)+coalesce(replace(@sql_VALUE,'"',),)+coalesce(replace(@sql_TYPE_ID,'"',),))<> update oktell.dbo.bitrix_lead_contacts set [sql_VALUE_TYPE]=replace(@sql_VALUE_TYPE,'"',) ,[sql_VALUE]=replace(@sql_VALUE,'"',) ,[sql_TYPE_ID]=replace(@sql_TYPE_ID,'"',) where sql_LEAD_ID=replace(@sql_ID,'"',) and sql_CONTACT_ID=replace(@sql_CONTACT_ID,'"',) end /*end if 1 */
else
begin /*begin if 2*/
if (coalesce(replace(@sql_CONTACT_ID,'"',),)+coalesce(replace(@sql_VALUE_TYPE,'"',),)+coalesce(replace(@sql_VALUE,'"',),)+coalesce(replace(@sql_TYPE_ID,'"',),))<> insert into oktell.dbo.bitrix_lead_contacts ([sql_LEAD_ID] ,[sql_CONTACT_ID] ,[sql_VALUE_TYPE] ,[sql_VALUE] ,[sql_TYPE_ID]) values (replace(@sql_ID,'"',) ,replace(@sql_CONTACT_ID,'"',) ,replace(@sql_VALUE_TYPE,'"',) ,replace(@sql_VALUE,'"',) ,replace(@sql_TYPE_ID,'"',)) end /*end if 2 */
12)Увеличиваем счетчик i=i+1 13)Проверяем i<cnt_EMAIL? Т.е. еще остались e-mail которые необходимо добавить в БД? 13.1)Если да, то идем на шаг 10) 13.2)Если нет, то идем на шаг 14) 14)Устанавливаем Счетчик i=0 (для получения телефонов) и повторяем точно такой же цикл как и для e-mail, т.к. JSON структура ответа у них совпадает. 15)Подсчитываем количество телефонов у лида Текст запроса — выражение вида - "result"/"PHONE" 16)Получаем i-ый телефон и выполняем серию компонентов Парсер JSON, для получения каждого из них. Получаем структуру вида: {"ID"="1111", "TYPE_ID"="PHONE", "VALUE"="+7 (123) 345-67-89 (доб. 123)", "VALUE_TYPE"="WORK", "POST"="Начальник отдела IT"}
17)Каждый из них добавляем в таблицу oktell.dbo.bitrix_lead_contacts Текст запроса - if exists (select * from oktell.dbo.bitrix_lead_contacts where sql_LEAD_ID=replace(@sql_ID,'"',) and sql_CONTACT_ID=replace(@sql_CONTACT_ID,'"',)) begin /*begin if 1*/ if (coalesce(replace(@sql_CONTACT_ID,'"',),)+coalesce(replace(@sql_VALUE_TYPE,'"',),)+coalesce(replace(@sql_VALUE,'"',),)+coalesce(replace(@sql_TYPE_ID,'"',),))<> update oktell.dbo.bitrix_lead_contacts set [sql_VALUE_TYPE]=replace(@sql_VALUE_TYPE,'"',) ,[sql_VALUE]=replace(@sql_VALUE,'"',) ,[sql_TYPE_ID]=replace(@sql_TYPE_ID,'"',) where sql_LEAD_ID=replace(@sql_ID ,'"',) and sql_CONTACT_ID=replace(@sql_CONTACT_ID,'"',) end /*end if 1*/
else
begin /*begin if 2*/ if (coalesce(@sql_CONTACT_ID,)+coalesce(@sql_VALUE_TYPE,)+coalesce(@sql_VALUE,)+coalesce(@sql_TYPE_ID,))<> insert into oktell.dbo.bitrix_lead_contacts ([sql_LEAD_ID] ,[sql_CONTACT_ID] ,[sql_VALUE_TYPE] ,[sql_VALUE] ,[sql_TYPE_ID]) values (replace(@sql_ID,'"',) ,replace(@sql_CONTACT_ID,'"',) ,replace(@sql_VALUE_TYPE,'"',) ,replace(@sql_VALUE,'"',) ,replace(@sql_TYPE_ID,'"',)) end /*end if 2*/ 18)Увеличиваем счетчик i=i+1 19)Проверяем i<cnt_PHONE? Т.е. еще остались телефоны которые необходимо добавить в БД? 19.1)Если да, то идем на шаг 16) 19.2)Если нет, то идем на шаг 20) 20)Присваиваем счетчик перебора лидов = текущему ID лида, для поиска построчно и переходим на шаг 3) и так до тех пор пока не отработает условие 4.2)
Создание служебных задач
После того, как все сценарии были настроены можно создать служебные задачи для автоматизации процесса получения новых refresh_token, access_token, и информации из Bitrix24. Исходя из описания REST API следует что access_token необходимо получать каждые 3600с, в то время как refresh_token активен в течении 1 месяца. В данном примере была создана служебная задача с периодом запуска — раз в 50 минут. Что позволяет всегда хранить действующий access_token, следует учитывать что после выполнения запроса refresh_token так же обновляется. Таким образом были созданы 2 служебные задачи:
Итоги
В результате мы можем совершать запросы используя REST API и получать и записывать практически любую информацию из облачной версии Bitrix24. В данной статье был рассмотрен пример получения всех лидов и сохранения информации в БД. Эти данные мы можем использовать: 1)Для определения номера при входящем звонке и отображении web-формы в Call-центре сразу со страницей лида. 2)Для отображение названии компании в различных отчетах, например пропущенные вызовы, что упростит поиск и скорость принятия решения на отработку вызова. 3)Для использования данной базы в различных исходящих обзвонах, отправки почты на e-mail.
Приведены только несколько примеров. Применение может быть различным.
Исходный код
Скрипт создания таблиц в БД OKTELL
/*[bitrix_oauth] – Таблица с данными по Bitrix OAuth*/
USE [oktell] GO
/****** Object: Table [dbo].[bitrix_oauth] Script Date: 05/24/2015 00:50:09 ******/ SET ANSI_NULLS ON GO
SET QUOTED_IDENTIFIER ON GO
CREATE TABLE [dbo].[bitrix_oauth]( [Id] [int] IDENTITY(1,1) NOT NULL, [access_token] [nvarchar](2000) NULL, [expires_in] [nvarchar](2000) NULL, [scope] [nvarchar](2000) NULL, [user_id] [nvarchar](2000) NULL, [refresh_token] [nvarchar](2000) NULL, [domain] [nvarchar](2000) NULL, [member_id] [nvarchar](2000) NULL, [redirect_uri] [nvarchar](2000) NULL, [client_id] [nvarchar](2000) NULL, [client_secret] [nvarchar](2000) NULL, [dateexec] [datetime] NULL, [code] [nvarchar](2000) NULL, PRIMARY KEY CLUSTERED ( [Id] ASC )WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY] ) ON [PRIMARY]
GO
/*-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------*/
/*[bitrix_leads] – Таблица которая содержит всю информацию по лидам*/
USE [oktell] GO
/****** Object: Table [dbo].[bitrix_leads] Script Date: 05/24/2015 00:49:34 ******/ SET ANSI_NULLS ON GO
SET QUOTED_IDENTIFIER ON GO
CREATE TABLE [dbo].[bitrix_leads]( [Id] [int] IDENTITY(1,1) NOT NULL, [sql_ADDRESS] [nvarchar](3000) NULL, [sql_ADDRESS_2] [nvarchar](3000) NULL, [sql_ADDRESS_CITY] [nvarchar](3000) NULL, [sql_ADDRESS_COUNTRY] [nvarchar](3000) NULL, [sql_ADDRESS_COUNTRY_CODE] [nvarchar](3000) NULL, [sql_ADDRESS_POSTAL_CODE] [nvarchar](3000) NULL, [sql_ADDRESS_PROVINCE] [nvarchar](3000) NULL, [sql_ADDRESS_REGION] [nvarchar](3000) NULL, [sql_ASSIGNED_BY_ID] [nvarchar](3000) NULL, [sql_BIRTHDATE] [datetime] NULL, [sql_COMMENTS] [ntext] NULL, [sql_COMPANY_ID] [nvarchar](3000) NULL, [sql_COMPANY_TITLE] [nvarchar](4000) NULL, [sql_CONTACT_ID] [nvarchar](3000) NULL, [sql_CREATED_BY_ID] [nvarchar](3000) NULL, [sql_CURRENCY_ID] [nvarchar](3000) NULL, [sql_DATE_CLOSED] [datetime] NULL, [sql_DATE_CREATE] [datetime] NULL, [sql_DATE_MODIFY] [datetime] NULL, [sql_ID] [int] NOT NULL, [sql_LAST_NAME] [nvarchar](3000) NULL, [sql_MODIFY_BY_ID] [nvarchar](3000) NULL, [sql_NAME] [nvarchar](3000) NULL, [sql_OPENED] [nvarchar](3000) NULL, [sql_OPPORTUNITY] [nvarchar](3000) NULL, [sql_ORIGIN_ID] [nvarchar](3000) NULL, [sql_ORIGINATOR_ID] [nvarchar](3000) NULL, [sql_POST] [nvarchar](3000) NULL, [sql_SECOND_NAME] [nvarchar](3000) NULL, [sql_SOURCE_DESCRIPTION] [nvarchar](3000) NULL, [sql_SOURCE_ID] [nvarchar](3000) NULL, [sql_STATUS_DESCRIPTION] [nvarchar](3000) NULL, [sql_STATUS_ID] [nvarchar](3000) NULL, [sql_TITLE] [nvarchar](4000) NULL,
CONSTRAINT [PK__bitrix_l__3214EC075C4299A5] PRIMARY KEY CLUSTERED
( [Id] ASC )WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY] ) ON [PRIMARY] TEXTIMAGE_ON [PRIMARY]
GO
/*---------------------------------------------------------------------------------------------------------------------------------------------*/
/* [bitrix_lead_contacts] – Список контактов лидов*/
USE [oktell] GO
/****** Object: Table [dbo].[bitrix_lead_contacts] Script Date: 05/24/2015 00:47:54 ******/ SET ANSI_NULLS ON GO
SET QUOTED_IDENTIFIER ON GO
CREATE TABLE [dbo].[bitrix_lead_contacts]( [Id] [int] IDENTITY(1,1) NOT NULL, [sql_LEAD_ID] [int] NULL, [sql_CONTACT_ID] [nvarchar](2000) NULL, [sql_VALUE_TYPE] [nvarchar](2000) NULL, [sql_VALUE] [nvarchar](2000) NULL, [sql_TYPE_ID] [nvarchar](2000) NULL,
CONSTRAINT [PK__bitrix_l__3214EC07699C94C3] PRIMARY KEY CLUSTERED
( [Id] ASC )WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY] ) ON [PRIMARY]
GO /*---------------------------------------------------------------------------------------------------------------------------------------*/
/*[bitrix_import_lead_error] – таблица ошибок при выполнении sql запроса на добавление\обновление лида*/
USE [oktell] GO
Object Table [dbo].[bitrix_import_lead_error] Script Date 05242015 004716
SET ANSI_NULLS ON GO
SET QUOTED_IDENTIFIER ON GO
CREATE TABLE [dbo].[bitrix_import_lead_error]( [Id] [int] IDENTITY(1,1) NOT NULL, [sql_ID] [nvarchar](2000) NULL, [sql_error] [nvarchar](2000) NULL, [sql_full_lead_info] [ntext] NULL, [sql_date_error] [datetime] NULL, PRIMARY KEY CLUSTERED ( [Id] ASC )WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY] ) ON [PRIMARY] TEXTIMAGE_ON [PRIMARY]
GO
/*----------------------------------------------------------------------------------------------------------------------------------------------*/
/*[bitrix_lead_runtime] – Таблица с данными по дате запуска сценариев импорта лидов и импорта контактов лидов*/
USE [oktell] GO
/****** Object: Table [dbo].[bitrix_lead_runtime] Script Date: 05/24/2015 00:48:20 ******/ SET ANSI_NULLS ON GO
SET QUOTED_IDENTIFIER ON GO
CREATE TABLE [dbo].[bitrix_lead_runtime]( [Id] [int] IDENTITY(1,1) NOT NULL, [lead_get_by_id_dt] [datetime] NULL, [lead_list_dt] [datetime] NULL, PRIMARY KEY CLUSTERED ( [Id] ASC )WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY] ) ON [PRIMARY]
GO
/*-------------------------------------------------------------------------------------------------------------------------------------------------------------*/
/*[bitrix_lead_solution] – Таблица содержащая решение клиентов по проектам (распологается в самом низу карточки лида)*/
USE [oktell] GO
/****** Object: Table [dbo].[bitrix_lead_solution] Script Date: 05/24/2015 00:49:04 ******/ SET ANSI_NULLS ON GO
SET QUOTED_IDENTIFIER ON GO
CREATE TABLE [dbo].[bitrix_lead_solution]( [Id] [int] IDENTITY(1,1) NOT NULL, [sql_LEAD_ID] [int] NULL, [sql_solution] [nvarchar](2000) NULL,
CONSTRAINT [PK__bitrix_l__3214EC0765CC03DF] PRIMARY KEY CLUSTERED
( [Id] ASC )WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY] ) ON [PRIMARY]
GO
/*----------------------------------------------------------------------------------------------------------------------------------------------------------------------------*/
