diff --git a/config.js b/config.js index 49faa60..4b571ce 100644 --- a/config.js +++ b/config.js @@ -14,7 +14,7 @@ let dbConnect = { //Пароль пользователя БД sPassword: "parus", //Строка подключения к БД - sConnectString: "DEMOP_CITKSERV", + sConnectString: "DEMOP_CITKSERV_WAN", //Наименование модуля (для сессии БД) sSessionModuleName: "PARUS$ExchangeServer", //Подключаемый модуль обслуживания БД (низкоуровневые функции работы с СУБД) diff --git a/test.js b/test.js index 1eb551e..8a19f8d 100644 --- a/test.js +++ b/test.js @@ -8,6 +8,8 @@ const srvsModel = require("./models/obj_services"); //Модель данных const srvModel = require("./models/obj_service"); //Модель данных сервиса const srvFnModel = require("./models/obj_service_function"); //Модель данных функции сервиса const srvFnSModel = require("./models/obj_service_functions"); //Модель данных функции сервиса +const queueModel = require("./models/obj_queue"); //Модель данных позиции очереди обмена +const queuesModel = require("./models/obj_queues"); //Модель данных списка позиций очереди обмена const dbConnectorModel = require("./models/prms_db_connector"); //Описатели параметров функций модуля подключения к БД const dbConnectorInterfaceModel = require("./models/intf_db_connector_module"); //Интерфейс модуля взаимодействия с БД const utl = require("./core/utils"); //Вспомогательные функции @@ -34,19 +36,25 @@ const pDB = require("./modules/parus_oracle_db"); const getServices = async () => { let d = new db.DBConnector(cfg.dbConnect); await d.connect(); - r = await d.getServices(); + let r = await d.getServices(); + let q = await d.getOutgoing({ nPortionSize: 1 }); await d.disconnect(); - console.log(r); + console.log(q[0].bMsg instanceof Buffer); let errs = utl.validateObject(r[1], srvModel.Service, "Сервис"); let errs2 = utl.validateObject({ functions: r[1].functions }, srvFnSModel.ServiceFunctions, "Функция сервиса"); let errs3 = utl.validateObject({ services: r }, srvsModel.Services, "Список сервисов"); - console.log(r[1].functions[0]); + let errs4 = utl.validateObject(q[0], queueModel.Queue, "Позиция очереди обмена"); + let errs5 = utl.validateObject({ queues: q }, queuesModel.Queues, "Очередь сообщений обмена"); if (errs2) console.log(errs2); else console.log("Нет ошибок в функции сервиса"); if (errs) console.log(errs); else console.log("Нет ошибок в сервисе"); if (errs3) console.log(errs3); else console.log("Нет ошибок в списке сервисов"); + if (errs4) console.log(errs4); + else console.log("Нет ошибок в сообщении обмена"); + if (errs5) console.log(errs5); + else console.log("Нет ошибок в очереди сообщений обмена"); }; getServices();