From 229dc605172af7073abcbfc54b88004c5ceb720d Mon Sep 17 00:00:00 2001 From: Mikhail Chechnev Date: Tue, 20 Nov 2018 21:57:19 +0300 Subject: [PATCH] =?UTF-8?q?=D0=9C=D0=B5=D1=82=D0=BE=D0=B4=20=D1=83=D1=81?= =?UTF-8?q?=D1=82=D0=B0=D0=BD=D0=BE=D0=B2=D0=BA=D0=B8=20=D1=81=D0=BE=D1=81?= =?UTF-8?q?=D1=82=D0=BE=D1=8F=D0=BD=D0=B8=D1=8F=20=D0=BF=D0=BE=D0=B7=D0=B8?= =?UTF-8?q?=D1=86=D0=B8=D0=B8=20=D0=BE=D1=87=D0=B5=D1=80=D0=B5=D0=B4=D0=B8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- core/db_connector.js | 33 ++++++++++++++++++++++++++++++--- 1 file changed, 30 insertions(+), 3 deletions(-) diff --git a/core/db_connector.js b/core/db_connector.js index ffb5d3e..475016b 100644 --- a/core/db_connector.js +++ b/core/db_connector.js @@ -67,7 +67,7 @@ class DBConnector extends EventEmitter { "log", "getQueueOutgoing", "putQueueIncoming", - "setQueueValue" + "setQueueState" ] }) ) { @@ -149,7 +149,7 @@ class DBConnector extends EventEmitter { //Запись в журнал работы async putLog(prms) { if (this.bConnected) { - //Проверяем структуру переданного объекта для подключения + //Проверяем структуру переданного объекта с параметрами для записи в журнал let sCheckResult = checkObject(prms, { fields: [ { sName: "nLogState", bRequired: true }, @@ -221,7 +221,7 @@ class DBConnector extends EventEmitter { //Считать очередную порцию исходящих сообщений async getOutgoing(prms) { if (this.bConnected) { - //Проверяем структуру переданного объекта для подключения + //Проверяем структуру переданного объекта с параметрами считывания очереди let sCheckResult = checkObject(prms, { fields: [{ sName: "nPortionSize", bRequired: true }] }); @@ -246,6 +246,33 @@ class DBConnector extends EventEmitter { throw new ServerError(SERR_DB_EXECUTE, "Нет подключения к БД"); } } + //Установить состояние позиции очереди + async setQueueState(prms) { + if (this.bConnected) { + //Проверяем структуру переданного объекта для подключения + //let sCheckResult = checkObject(prms, { + // fields: [{ sName: "nPortionSize", bRequired: true }] + //}); + //Если структура объекта в норме + //if (!sCheckResult) { + let setStateData = { connection: this.connection }; + _.extend(setStateData, prms); + try { + let res = await this.connector.setQueueState(setStateData); + return res; + } catch (e) { + throw new ServerError(SERR_DB_EXECUTE, e.message); + } + //} else { + // throw new ServerError( + // glConst.SERR_OBJECT_BAD_INTERFACE, + // "Объект имеет недопустимый интерфейс: " + sCheckResult + // ); + //} + } else { + throw new ServerError(SERR_DB_EXECUTE, "Нет подключения к БД"); + } + } } //-----------------