From b36a6ceaa2aea3f88fcad80b38332b2140370faf Mon Sep 17 00:00:00 2001
From: Mikhail Chechnev <mim_@mail.ru>
Date: Mon, 26 Nov 2018 20:52:35 +0300
Subject: [PATCH] =?UTF-8?q?=D0=9D=D0=B5=D0=BC=D0=BD=D0=BE=D0=B3=D0=BE=20?=
 =?UTF-8?q?=D1=82=D0=B5=D1=81=D1=82=D0=BE=D0=B2=20=D0=B2=20=D0=BE=D1=84?=
 =?UTF-8?q?=D0=B8=D1=81=D0=BD=D0=BE=D0=BC=20=D0=BE=D0=BA=D1=80=D1=83=D0=B6?=
 =?UTF-8?q?=D0=B5=D0=BD=D0=B8=D0=B8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 config.js |  2 +-
 test.js   | 22 +++++++++++++++++-----
 2 files changed, 18 insertions(+), 6 deletions(-)

diff --git a/config.js b/config.js
index 17ed908..d863077 100644
--- a/config.js
+++ b/config.js
@@ -14,7 +14,7 @@ let dbConnect = {
     //Пароль пользователя БД
     sPassword: "parus",
     //Строка подключения к БД
-    sConnectString: "DEMOP_CITKSERV_WAN",
+    sConnectString: "DEMOP_CITKSERV",
     //Наименование сервера приложений в сессии БД
     sSessionAppName: "PARUS$ExchangeServer",
     //Подключаемый модуль обслуживания БД (низкоуровневые функции работы с СУБД)
diff --git a/test.js b/test.js
index 8a19f8d..206c722 100644
--- a/test.js
+++ b/test.js
@@ -35,11 +35,18 @@ const pDB = require("./modules/parus_oracle_db");
 
 const getServices = async () => {
     let d = new db.DBConnector(cfg.dbConnect);
-    await d.connect();
-    let r = await d.getServices();
-    let q = await d.getOutgoing({ nPortionSize: 1 });
-    await d.disconnect();
-    console.log(q[0].bMsg instanceof Buffer);
+    try {
+        await d.connect();
+        let r = await d.getServices();
+        let q = await d.getOutgoing({ nPortionSize: 1 });
+        console.log(q);
+        let qs = await d.setQueueState({ nQueueId: 94568140, nExecState: 0 });
+        console.log(qs);
+        let l = await d.putLog({ nLogState: 0, sMsg: "Тест", nServiceId: 94557937, nServiceFnId: 94557939 });
+        await d.disconnect();
+        /*
+    console.log(q[0]);
+    console.log(q[0].blMsg 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, "Список сервисов");
@@ -55,6 +62,11 @@ const getServices = async () => {
     else console.log("Нет ошибок в сообщении обмена");
     if (errs5) console.log(errs5);
     else console.log("Нет ошибок в очереди сообщений обмена");
+    */
+    } catch (e) {
+        await d.disconnect();
+        console.log(e.sCode + " " + e.sMessage);
+    }
 };
 
 getServices();