Использование REST API Bitrix24
Содержание
Общий порядок работы с OAuth при создании приложений для Битрикс24
- Регистрируется своё приложение в Маркетплейсе Битрикс24
- Запрашиваются с удаленного сервера ключи
- Сервер перенаправляет браузер на зарегистрированный приложением URL
- Обрабатывается ответ
- Подписываются полученным ключом все запросы к Rest API.
Регистрация приложения в Маркетплейс Битрикс24
C 25 мая 2015г. для того чтобы добавлять свои приложения на портал больше не требуется становиться технологическим партнером.
Если у вас права администратора на вашем портале, зайдите в раздел Приложения - Добавить приложение. Выбрать для личного пользования (в этом случае, никто кроме вас и вашего портала не сможет использовать это приложение)
Откроется форма добавления приложения
В форме заполняем:
- Название приложения — произвольное.
- Приложение использует только API – обязательно
- Права доступа — указываем к каким разделам будет доступ у данного приложения
- Укажите ссылку — указываем произвольный ваш сайт (или любую произвольную страницу).
После этого нажимаем «Сохранить»
После этого мы увидим «Список локальных приложений», в котором будет указан «Код приложения» и «Ключ приложения». Они будут необходимы в дальнейшем для авторизации и выполнении методов REST API.
OAuth-авторизация для desktop-приложения
Алгоритм:
- При помощи client_id получаем параметр code, требуемый для получения авторизационного токена.
- При помощи clent_id, client_secret и code приложение получает параметры access_code и refresh_token.
- При помощи access_code приложение совершает запросы к REST-сервису до его истечения.
- Через час access_code истекает, и приложение может использовать полученный refresh_token для получения нового.
- Если refresh_token еще не истек (с момента его получения не прошел месяц), то приложение получает свежий access_code и свежий refresh_token, после чего, можно перейти к шагу 3.
- Если refresh_token уже истек, то требуется повторная авторизация с участием пользователя.
По сути, физическая авторизация пользователя требуется только на шаге 1. В итоге получаем, что если приложение используется постоянно (шаг 4 используется чаще раза в месяц), то приложение имеет возможность продлевать авторизацию не трогая пользователя сколь угодно долго.Рассмотрим данный алгоритм более подробно.
Desktop приложение должно слушать какой-либо порт на localhost (Oktell как правило слушает порт 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)Приложение (Oktell) должно сделать 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 — адрес на который должен произойти редирект, как правило запрос выполняется в браузере на сервере где установлен Oktell и поэтому указывается ссылка вида — 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 — адрес на который должен произойти редирект, как правило запрос выполняется в браузере на сервере где установлен Oktell и поэтому указывается ссылка вида — 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
