diff --git a/core/db_connector.js b/core/db_connector.js index 789c38c..f13c18d 100644 --- a/core/db_connector.js +++ b/core/db_connector.js @@ -521,6 +521,7 @@ class DBConnector extends EventEmitter { let putQueueData = _.cloneDeep(prms); putQueueData.blMsg = prms.blMsg ? prms.blMsg : Buffer.from(""); putQueueData.connection = this.connection; + putQueueData.nExsSrv = this.nExsSrv; //Исполняем действие в БД try { let res = await this.connector.putQueue(putQueueData); diff --git a/modules/parus_oracle_db.js b/modules/parus_oracle_db.js index c425ebb..430ec7c 100644 --- a/modules/parus_oracle_db.js +++ b/modules/parus_oracle_db.js @@ -373,6 +373,7 @@ const putQueue = async prms => { inPrms: { NEXSSERVICEFN: prms.nServiceFnId, BMSG: prms.blMsg, + NEXSSRV: prms.nExsSrv, NEXSQUEUE: prms.nQueueId, NLNK_COMPANY: prms.nLnkCompanyId, NLNK_DOCUMENT: prms.nLnkDocumentId, diff --git a/modules/parus_pg_db.js b/modules/parus_pg_db.js index cdab6a7..b780036 100644 --- a/modules/parus_pg_db.js +++ b/modules/parus_pg_db.js @@ -361,6 +361,7 @@ const putQueue = async prms => { inPrms: { NEXSSERVICEFN: prms.nServiceFnId, BMSG: prms.blMsg, + NEXSSRV: prms.nExsSrv, NEXSQUEUE: prms.nQueueId, NLNK_COMPANY: prms.nLnkCompanyId, NLNK_DOCUMENT: prms.nLnkDocumentId,