The_Law

Untitled

Aug 21st, 2018
367
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 7.06 KB | None | 0 0
  1. Функция ЗапуститьЗапросыДляИнтервала(минимальныйИдентификатор_п, максимальныйИдентификатор_п, номерФоновогоЗадания_п) Экспорт
  2.  
  3. parameters_л = Новый Массив;
  4. значениеПараметра_л = Новый Соответствие;
  5. значениеПараметра_л.Вставить("parameterType", "maximumMileage");
  6. значениеПараметра_л.Вставить("value", 30000);
  7. parameters_л.Добавить(значениеПараметра_л);
  8.  
  9. значениеПараметра_л = Новый Соответствие;
  10. значениеПараметра_л.Вставить("parameterType", "modification");
  11. значениеПараметра_л.Вставить("value", 97809);
  12. ссылкаПоМодификации_л = значениеПараметра_л;
  13. parameters_л.Добавить(значениеПараметра_л);
  14.  
  15. значениеПараметра_л = Новый Соответствие;
  16. значениеПараметра_л.Вставить("parameterType", "termOfLeasing");
  17. значениеПараметра_л.Вставить("value", 36);
  18. parameters_л.Добавить(значениеПараметра_л);
  19.  
  20. значениеПараметра_л = Новый Соответствие;
  21. значениеПараметра_л.Вставить("parameterType", "vehicleSuperType");
  22. значениеПараметра_л.Вставить("value", 8);
  23. parameters_л.Добавить(значениеПараметра_л);
  24.  
  25. запросДоступностиПараметры_л = Новый Соответствие;
  26. запросДоступностиПараметры_л.Вставить("parameters", parameters_л);
  27.  
  28. настройкиПодключения_л = Справочники.AMQP_НастройкиСерверов.ПолучитьСтруктуруНастроекПодключения(Справочники.CS_СписокИнформационныхБаз.ПолучитьСерверAMQP());
  29. реквизитыПотока_л = ОбщегоНазначенияЕП.ПолучитьРеквизиты(Справочники.AMQP_НастройкиСерверов_Потоки.Лизинг1с_ПолучениеСущностей, "ИмяОбменника,КлючМаршрута,ТаймаутRPC,ЭтоRPCСообщение");
  30. реквизитыПотока_л.КлючМаршрута = "extendedServices.getAvailability.rpc";
  31.  
  32. Сообщить(Строка(номерФоновогоЗадания_п)+" Начали " + ТекущаяДата());
  33. Для счетчик_л = минимальныйИдентификатор_п По максимальныйИдентификатор_п цикл
  34.  
  35.  
  36.  
  37. идентификатор_л = 7777770000+счетчик_л;
  38.  
  39. //структураОтвет_л = ЗапроситьДанные(Справочники.AMQP_НастройкиСерверов_Потоки.ДоступностьВариантов, параметрыЗапросаДоступности_п);
  40. //текстОтвета_л = JSON.СериализацияJSON(структураОтвет_л);
  41.  
  42.  
  43. ссылкаПоМодификации_л.Вставить("value", идентификатор_л);
  44.  
  45.  
  46. структураОтправкиRPC_л = AMQP.СтруктураОтправкиRPCСоздать();
  47. структураОтправкиRPC_л.НастройкиПодключения = настройкиПодключения_л;
  48. структураОтправкиRPC_л.ИмяОбменника = реквизитыПотока_л.ИмяОбменника;
  49. структураОтправкиRPC_л.КлючМаршрута = реквизитыПотока_л.КлючМаршрута;
  50. структураОтправкиRPC_л.ТекстСообщения = JSON.СериализацияJSON(запросДоступностиПараметры_л);
  51. структураОтправкиRPC_л.Таймаут = реквизитыПотока_л.ТаймаутRPC;
  52. структураОтправкиRPC_л.ЗакрыватьСоединение = Истина;
  53.  
  54. началоОтправки_л = ТекущаяУниверсальнаяДатаВМиллисекундах();
  55. структураРезультат_л = AMQP.ОтправитьСообщениеВОчередьRPCСтруктура(структураОтправкиRPC_л);
  56. задержка_л = ТекущаяУниверсальнаяДатаВМиллисекундах()-началоОтправки_л;
  57.  
  58. текстОтвета_л = структураРезультат_л.СообщениеJSON;
  59.  
  60.  
  61. Сообщить(Строка(номерФоновогоЗадания_п)+" Ответ получен за " + задержка_л + "милисекунд, идентификатор модификации " + идентификатор_л);
  62. //Сообщить(текстОтвета_л);
  63.  
  64.  
  65. КонецЦикла;
  66. Сообщить(Строка(номерФоновогоЗадания_п)+" Закончили " + ТекущаяДата());
  67.  
  68.  
  69. КонецФункции // ()
Advertisement
Add Comment
Please, Sign In to add comment