Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- Функция ЗапуститьЗапросыДляИнтервала(минимальныйИдентификатор_п, максимальныйИдентификатор_п, номерФоновогоЗадания_п) Экспорт
- parameters_л = Новый Массив;
- значениеПараметра_л = Новый Соответствие;
- значениеПараметра_л.Вставить("parameterType", "maximumMileage");
- значениеПараметра_л.Вставить("value", 30000);
- parameters_л.Добавить(значениеПараметра_л);
- значениеПараметра_л = Новый Соответствие;
- значениеПараметра_л.Вставить("parameterType", "modification");
- значениеПараметра_л.Вставить("value", 97809);
- ссылкаПоМодификации_л = значениеПараметра_л;
- parameters_л.Добавить(значениеПараметра_л);
- значениеПараметра_л = Новый Соответствие;
- значениеПараметра_л.Вставить("parameterType", "termOfLeasing");
- значениеПараметра_л.Вставить("value", 36);
- parameters_л.Добавить(значениеПараметра_л);
- значениеПараметра_л = Новый Соответствие;
- значениеПараметра_л.Вставить("parameterType", "vehicleSuperType");
- значениеПараметра_л.Вставить("value", 8);
- parameters_л.Добавить(значениеПараметра_л);
- запросДоступностиПараметры_л = Новый Соответствие;
- запросДоступностиПараметры_л.Вставить("parameters", parameters_л);
- настройкиПодключения_л = Справочники.AMQP_НастройкиСерверов.ПолучитьСтруктуруНастроекПодключения(Справочники.CS_СписокИнформационныхБаз.ПолучитьСерверAMQP());
- реквизитыПотока_л = ОбщегоНазначенияЕП.ПолучитьРеквизиты(Справочники.AMQP_НастройкиСерверов_Потоки.Лизинг1с_ПолучениеСущностей, "ИмяОбменника,КлючМаршрута,ТаймаутRPC,ЭтоRPCСообщение");
- реквизитыПотока_л.КлючМаршрута = "extendedServices.getAvailability.rpc";
- Сообщить(Строка(номерФоновогоЗадания_п)+" Начали " + ТекущаяДата());
- Для счетчик_л = минимальныйИдентификатор_п По максимальныйИдентификатор_п цикл
- идентификатор_л = 7777770000+счетчик_л;
- //структураОтвет_л = ЗапроситьДанные(Справочники.AMQP_НастройкиСерверов_Потоки.ДоступностьВариантов, параметрыЗапросаДоступности_п);
- //текстОтвета_л = JSON.СериализацияJSON(структураОтвет_л);
- ссылкаПоМодификации_л.Вставить("value", идентификатор_л);
- структураОтправкиRPC_л = AMQP.СтруктураОтправкиRPCСоздать();
- структураОтправкиRPC_л.НастройкиПодключения = настройкиПодключения_л;
- структураОтправкиRPC_л.ИмяОбменника = реквизитыПотока_л.ИмяОбменника;
- структураОтправкиRPC_л.КлючМаршрута = реквизитыПотока_л.КлючМаршрута;
- структураОтправкиRPC_л.ТекстСообщения = JSON.СериализацияJSON(запросДоступностиПараметры_л);
- структураОтправкиRPC_л.Таймаут = реквизитыПотока_л.ТаймаутRPC;
- структураОтправкиRPC_л.ЗакрыватьСоединение = Истина;
- началоОтправки_л = ТекущаяУниверсальнаяДатаВМиллисекундах();
- структураРезультат_л = AMQP.ОтправитьСообщениеВОчередьRPCСтруктура(структураОтправкиRPC_л);
- задержка_л = ТекущаяУниверсальнаяДатаВМиллисекундах()-началоОтправки_л;
- текстОтвета_л = структураРезультат_л.СообщениеJSON;
- Сообщить(Строка(номерФоновогоЗадания_п)+" Ответ получен за " + задержка_л + "милисекунд, идентификатор модификации " + идентификатор_л);
- //Сообщить(текстОтвета_л);
- КонецЦикла;
- Сообщить(Строка(номерФоновогоЗадания_п)+" Закончили " + ТекущаяДата());
- КонецФункции // ()
Advertisement
Add Comment
Please, Sign In to add comment