CITKParus/P8-ExchangeService
7
0
Fork 1
Code Issues Pull Requests Projects Releases Wiki Activity

Compare commits

base: CITKParus:6366a7a0339285482d4743b2011dd5a33fb7524d
Branches Tags
CITKParus:master
CITKParus:dependabot/npm_and_yarn/express-4.19.2
..
compare: CITKParus:19b17d6052f691d6f34ca6ef7cf31102406bb8d8
Branches Tags
CITKParus:master
CITKParus:dependabot/npm_and_yarn/express-4.19.2

No commits in common. "6366a7a0339285482d4743b2011dd5a33fb7524d" and "19b17d6052f691d6f34ca6ef7cf31102406bb8d8" have entirely different histories.
6366a7a033 ... 19b17d6052

7 changed files with 106 additions and 200 deletions
Show Stats Expand all files Collapse all files

2
config.js
View File

@ -9,8 +9,6 @@
//Общие параметры
let common = {
//Наименование сервера приложений
sServerName: "",
//Версия сервера приложений
sVersion: "8.5.6.1",
//Релиз сервера приложений

9
core/app.js
View File

@ -201,20 +201,13 @@ class ParusAppServer {
this.dbConn = new db.DBConnector({
connectSettings: {
...prms.config.dbConnect,
exsSrv: {
sServerName: prms.config.common.sServerName,
sServerIP: `${prms.config.inComing.nPort};${
prms.config.inComing.sHost === "0.0.0.0" ? getIPs().join(";") : prms.config.inComing.sHost
}`
},
sRelease: prms.config.common.sRelease,
bControlSystemVersion: prms.config.common.bControlSystemVersion,
nPoolMin: prms.config.inComing.nPoolMin,
nPoolMax: prms.config.inComing.nPoolMax,
nPoolIncrement: prms.config.inComing.nPoolIncrement,
nMaxWorkers: prms.config.outGoing.nMaxWorkers
},
bServer: true
}
});
//Создаём модуль рассылки уведомлений
this.notifier = new ntf.Notifier({ logger: this.logger, mail: prms.config.mail });

33
core/db_connector.js
View File

@ -73,8 +73,6 @@ class DBConnector extends EventEmitter {
//Инициализируем остальные свойства
this.connection = null;
this.bConnected = false;
this.nExsSrv = null;
this.bServer = prms.bServer === true ? true : false;
} else {
throw new ServerError(SERR_MODULES_NO_MODULE_SPECIFIED, "Не указано имя подключаемого модуля-коннектора!");
}
@ -102,28 +100,6 @@ class DBConnector extends EventEmitter {
try {
//Подключаемся
this.connection = await this.connector.connect(this.connectSettings);
//Если это запуск сервиса интеграции
if (this.bServer) {
//Проверяем общие условия запуска
await this.connector.checkAppStart({
bControlSystemVersion: this.connectSettings.bControlSystemVersion,
sRelease: this.connectSettings.sRelease,
nWorkers: this.connectSettings.nMaxWorkers,
sServerName: this.connectSettings.exsSrv.sServerName,
sSessionAppName: this.connectSettings.sSessionAppName,
connection: this.connection
});
//Если сервис интеграции разделяется на сервера
if (this.connectSettings.exsSrv.sServerName) {
//Инициализируем информацию о сервере интеграции
this.nExsSrv = await this.connector.initServer({
sServerName: this.connectSettings.exsSrv.sServerName,
sServerIP: this.connectSettings.exsSrv.sServerIP,
nMaxWorkers: this.connectSettings.nMaxWorkers,
connection: this.connection
});
}
}
//Выставим внутренний флаг подключения
this.bConnected = true;
//Расскажем всем, что подключились
@ -140,11 +116,6 @@ class DBConnector extends EventEmitter {
//Смысл отключаться есть только когда мы подключены, в противном случае - зачем тратить время
if (this.bConnected) {
try {
//Если указана информация о сервере и это закрытие сервиса интеграции
if (this.nExsSrv && this.bServer) {
//Очищаем информацию о сервере
await this.connector.clearServer({ nExsSrv: this.nExsSrv, connection: this.connection });
}
//Отключаемся
await this.connector.disconnect({ connection: this.connection });
//Забываем подключение и удаляем флаги подключенности
@ -165,7 +136,7 @@ class DBConnector extends EventEmitter {
if (this.bConnected) {
try {
//Забираем список сервисов и декорируем его заготовками под список функций
let srvs = await this.connector.getServices({ connection: this.connection, nExsSrv: this.nExsSrv });
let srvs = await this.connector.getServices({ connection: this.connection });
srvs.forEach(s => {
s.functions = [];
});
@ -415,7 +386,6 @@ class DBConnector extends EventEmitter {
//Подготовим параметры для передачи в БД
let logData = _.cloneDeep(prms);
logData.connection = this.connection;
logData.nExsSrv = this.nExsSrv;
//И выполним запись в журнал
let res = await this.connector.log(logData);
//Валидируем полученный ответ
@ -551,7 +521,6 @@ class DBConnector extends EventEmitter {
//Подготовим параметры для передачи в БД
let getQueueOutgoingData = _.cloneDeep(prms);
getQueueOutgoingData.connection = this.connection;
getQueueOutgoingData.nExsSrv = this.nExsSrv;
//Выполняем считывание из БД
let res = await this.connector.getQueueOutgoing(getQueueOutgoingData);
//Валидируем полученный ответ

13
models/obj_config.js
View File

@ -13,9 +13,6 @@ const Schema = require("validate"); //Схемы валидации
// Тело модуля
//-------------
//Функция проверки длины значения наименование сервера приложений
const validateServerName = val => val.length <= 40;
//Функция проверки значения таймаута останова сервера
const validateTerminateTimeout = val => val >= 1000 && val <= 120000 && Number.isInteger(val);
@ -51,16 +48,6 @@ const validatePoolIncrementInComing = val => val >= 0 && val <= 1000;
//Схема валидации общих параметров сервера приложений
const common = new Schema({
//Наименование сервера приложений
sServerName: {
type: String,
required: false,
use: { validateServerName },
message: {
type: path => `Наименование сервера приложений (${path}) имеет некорректный тип данных (ожидалось - String)`,
validateServerName: path => `Длина наименования сервера приложений (${path}) не может превышать 40 символов`
}
},
//Версия сервера приложений
sVersion: {
type: String,

60
models/prms_db_connector.js
View File

@ -174,7 +174,8 @@ exports.putServiceAuthInQueue = new Schema({
required: false,
enum: [NFORCE_YES, NFORCE_NO],
message: {
type: path => `Признак принудительного завершения сессии (${path}) имеет некорректный тип данных (ожидалось - Number)`,
type: path =>
`Признак принудительного завершения сессии (${path}) имеет некорректный тип данных (ожидалось - Number)`,
enum: path => `Значение признака принудительного завершения сессии (${path}) не поддерживается`,
required: path => `Не указан признак принудительного завершения сессии (${path})`
}
@ -202,7 +203,8 @@ exports.putLog = new Schema({
enum: [NLOG_STATE_INF, NLOG_STATE_WRN, NLOG_STATE_ERR],
required: true,
message: {
type: path => `Тип сообщения журнала работы сервиса (${path}) имеет некорректный тип данных (ожидалось - Number)`,
type: path =>
`Тип сообщения журнала работы сервиса (${path}) имеет некорректный тип данных (ожидалось - Number)`,
enum: path => `Значение типа сообщения журнала работы сервиса (${path}) не поддерживается`,
required: path => `Не указан тип сообщения журнала работы сервиса (${path})`
}
@ -212,7 +214,8 @@ exports.putLog = new Schema({
type: String,
required: false,
message: {
type: path => `Сообщение журнала работы сервиса (${path}) имеет некорректный тип данных (ожидалось - String)`,
type: path =>
`Сообщение журнала работы сервиса (${path}) имеет некорректный тип данных (ожидалось - String)`,
required: path => `Не указано сообщение журнала работы сервиса (${path})`
}
},
@ -233,7 +236,8 @@ exports.putLog = new Schema({
message: {
type: path =>
`Идентификатор связанной функции-обработчика сообщения журнала работы сервиса (${path}) имеет некорректный тип данных (ожидалось - Number)`,
required: path => `Не указан идентификатор связанной функции-обработчика сообщения журнала работы сервиса (${path})`
required: path =>
`Не указан идентификатор связанной функции-обработчика сообщения журнала работы сервиса (${path})`
}
},
//Идентификатор связанной позиции очереди обмена
@ -243,7 +247,8 @@ exports.putLog = new Schema({
message: {
type: path =>
`Идентификатор связанной позиции очереди обмена сообщения журнала работы сервиса (${path}) имеет некорректный тип данных (ожидалось - Number)`,
required: path => `Не указан идентификатор связанной позиции очереди обмена сообщения журнала работы сервиса (${path})`
required: path =>
`Не указан идентификатор связанной позиции очереди обмена сообщения журнала работы сервиса (${path})`
}
}
});
@ -255,7 +260,8 @@ exports.getQueue = new Schema({
type: Number,
required: true,
message: {
type: path => `Идентификатор позиции очереди обмена (${path}) имеет некорректный тип данных (ожидалось - Number)`,
type: path =>
`Идентификатор позиции очереди обмена (${path}) имеет некорректный тип данных (ожидалось - Number)`,
required: path => `Не указан идентификатор позиции очереди обмена (${path})`
}
}
@ -268,7 +274,8 @@ exports.putQueue = new Schema({
type: Number,
required: true,
message: {
type: path => `Идентификатор функции сервиса обработчика позиции очереди (${path}) имеет некорректный тип данных (ожидалось - Number)`,
type: path =>
`Идентификатор функции сервиса обработчика позиции очереди (${path}) имеет некорректный тип данных (ожидалось - Number)`,
required: path => `Не указан идентификатор функции сервиса обработчика позиции очереди (${path})`
}
},
@ -277,7 +284,8 @@ exports.putQueue = new Schema({
use: { validateBuffer },
required: false,
message: {
validateBuffer: path => `Данные сообщения очереди обмена (${path}) имеют некорректный тип данных (ожидалось - null или Buffer)`,
validateBuffer: path =>
`Данные сообщения очереди обмена (${path}) имеют некорректный тип данных (ожидалось - null или Buffer)`,
required: path => `Не указаны данные сообщения очереди обмена (${path})`
}
},
@ -286,7 +294,8 @@ exports.putQueue = new Schema({
type: Number,
required: false,
message: {
type: path => `Идентификатор связанной позиции очереди обмена (${path}) имеет некорректный тип данных (ожидалось - Number)`,
type: path =>
`Идентификатор связанной позиции очереди обмена (${path}) имеет некорректный тип данных (ожидалось - Number)`,
required: path => `Не указан идентификатор связанной позиции очереди обмена (${path})`
}
},
@ -295,7 +304,8 @@ exports.putQueue = new Schema({
type: Number,
required: false,
message: {
type: path => `Идентификатор связанной организации (${path}) имеет некорректный тип данных (ожидалось - Number)`,
type: path =>
`Идентификатор связанной организации (${path}) имеет некорректный тип данных (ожидалось - Number)`,
required: path => `Не указан идентификатор связанной организации (${path})`
}
},
@ -304,7 +314,8 @@ exports.putQueue = new Schema({
type: Number,
required: false,
message: {
type: path => `Идентификатор связанного документа (${path}) имеет некорректный тип данных (ожидалось - Number)`,
type: path =>
`Идентификатор связанного документа (${path}) имеет некорректный тип данных (ожидалось - Number)`,
required: path => `Не указан идентификатор связанного документа (${path})`
}
},
@ -335,7 +346,8 @@ exports.getOutgoing = new Schema({
type: Number,
required: true,
message: {
type: path => `Количество считываемых сообщений очереди (${path}) имеет некорректный тип данных (ожидалось - Number)`,
type: path =>
`Количество считываемых сообщений очереди (${path}) имеет некорректный тип данных (ожидалось - Number)`,
required: path => `Не указано количество считываемых сообщений очереди (${path})`
}
}
@ -388,7 +400,8 @@ exports.setQueueState = new Schema({
enum: [NINC_EXEC_CNT_NO, NINC_EXEC_CNT_YES],
required: false,
message: {
type: path => `Флаг инкремента количества исполнений (${path}) имеет некорректный тип данных (ожидалось - Number)`,
type: path =>
`Флаг инкремента количества исполнений (${path}) имеет некорректный тип данных (ожидалось - Number)`,
enum: path => `Значение флага инкремента количества исполнений (${path}) не поддерживается`,
required: path => `Не указан флаг икремента количества исполнений (${path})`
}
@ -435,7 +448,8 @@ exports.setQueueMsg = new Schema({
use: { validateBuffer },
required: true,
message: {
validateBuffer: path => `Данные сообщения очереди обмена (${path}) имеют некорректный тип данных (ожидалось - null или Buffer)`,
validateBuffer: path =>
`Данные сообщения очереди обмена (${path}) имеют некорректный тип данных (ожидалось - null или Buffer)`,
required: path => `Не указаны данные сообщения очереди обмена (${path})`
}
}
@ -457,7 +471,8 @@ exports.setQueueOptions = new Schema({
type: String,
required: true,
message: {
validateBuffer: path => `Парамметры сообщения очереди обмена (${path}) имеют некорректный тип данных (ожидалось - String)`,
validateBuffer: path =>
`Парамметры сообщения очереди обмена (${path}) имеют некорректный тип данных (ожидалось - String)`,
required: path => `Не указаны параметры сообщения очереди обмена (${path})`
}
}
@ -492,7 +507,8 @@ exports.setQueueResp = new Schema({
use: { validateBuffer },
required: true,
message: {
validateBuffer: path => `Данные ответа сообщения очереди обмена (${path}) имеют некорректный тип данных (ожидалось - null или Buffer)`,
validateBuffer: path =>
`Данные ответа сообщения очереди обмена (${path}) имеют некорректный тип данных (ожидалось - null или Buffer)`,
required: path => `Не указаны данные ответа сообщения очереди обмена (${path})`
}
},
@ -502,7 +518,8 @@ exports.setQueueResp = new Schema({
enum: [NIS_ORIGINAL_NO, NIS_ORIGINAL_YES],
required: true,
message: {
type: path => `Признак передачи оригинала ответа (${path}) имеет некорректный тип данных (ожидалось - Number)`,
type: path =>
`Признак передачи оригинала ответа (${path}) имеет некорректный тип данных (ожидалось - Number)`,
enum: path => `Значение признака передачи оригинала ответа (${path}) не поддерживается`,
required: path => `Не указан признак передачи оригинала ответа (${path})`
}
@ -525,7 +542,8 @@ exports.setQueueOptionsResp = new Schema({
type: String,
required: true,
message: {
validateBuffer: path => `Парамметры ответа на сообщение очереди обмена (${path}) имеют некорректный тип данных (ожидалось - String)`,
validateBuffer: path =>
`Парамметры ответа на сообщение очереди обмена (${path}) имеют некорректный тип данных (ожидалось - String)`,
required: path => `Не указаны параметры ответа на сообщение очереди обмена (${path})`
}
}
@ -547,7 +565,8 @@ exports.setQueueAppSrvResult = new Schema({
use: { validateBuffer },
required: true,
message: {
validateBuffer: path => `Данные сообщения очереди обмена (${path}) имеют некорректный тип данных (ожидалось - null или Buffer)`,
validateBuffer: path =>
`Данные сообщения очереди обмена (${path}) имеют некорректный тип данных (ожидалось - null или Buffer)`,
required: path => `Не указаны данные сообщения очереди обмена (${path})`
}
},
@ -556,7 +575,8 @@ exports.setQueueAppSrvResult = new Schema({
use: { validateBuffer },
required: true,
message: {
validateBuffer: path => `Данные ответа сообщения очереди обмена (${path}) имеют некорректный тип данных (ожидалось - null или Buffer)`,
validateBuffer: path =>
`Данные ответа сообщения очереди обмена (${path}) имеют некорректный тип данных (ожидалось - null или Buffer)`,
required: path => `Не указаны данные ответа сообщения очереди обмена (${path})`
}
}

107
modules/parus_oracle_db.js
View File

@ -20,7 +20,6 @@ const DT_DATE = oracledb.DB_TYPE_DATE; //Тип данных "Дата" БД
const DT_CLOB = oracledb.DB_TYPE_CLOB; //Тип данных "Текстовые данные" БД
const DT_BLOB = oracledb.DB_TYPE_BLOB; //Тип данных "Двоичные данные" БД
const DT_CURSOR = oracledb.CURSOR; //Тип данных "Курсор" БД
const DT_VARCHAR_LENGTH = 32767; //Длина типа "Строка"
//------------
// Тело модуля
@ -45,8 +44,7 @@ const makeStoredPrms = (inPrms, outPrms) => {
for (i in outPrms) {
prms[i] = {
type: outPrms[i],
dir: oracledb.BIND_OUT,
...(outPrms[i] === DT_VARCHAR ? { maxSize: DT_VARCHAR_LENGTH } : {})
dir: oracledb.BIND_OUT
};
break;
}
@ -124,68 +122,46 @@ const executeStored = async prms => {
if (outResult) return outResult;
};
//Проверка условий при запуске сервиса интеграции
const checkAppStart = async prms => {
let res = await executeStored({
//Проверка допустимого количества воркеров
const checkWorkers = async prms => {
let workersData = await executeStored({
connection: prms.connection,
sName: "PKG_EXS.UTL_APPSRV_START_CHECK",
inPrms: {
NCONTROL_VERSION: prms.bControlSystemVersion ? 1 : 0,
SEXS_RELEASE_DATE: prms.sRelease,
NWORKERS: prms.nWorkers,
SEXSSRV: prms.sServerName,
SSESSION_APP_NAME: prms.sSessionAppName
},
sName: "PKG_EXS.UTL_LIC_CLNT_COUNT_GET",
outPrms: {
SERR_TEXT: DT_VARCHAR
LIC_CNT: DT_NUMBER
},
isFunction: false
isFunction: true
});
//Если есть ошибки запуска
if (res.SERR_TEXT) {
throw new Error(res.SERR_TEXT);
if (workersData.LIC_CNT === 0) {
throw new Error(`Не определено количество лицензий для приложения "ExchangeServer".`);
}
if (prms.nMaxWorkers > workersData.LIC_CNT - 1) {
throw new Error(
`Недопустимое значение параметра "Количество одновременно обрабатываемых исходящих сообщений" ("outGoing.nMaxWorkers") файла конфигурации сервиса приложений ("config.js"). Максимальное количество одновременно обрабатываемых исходящих сообщений - ${
workersData.LIC_CNT - 1
}.`
);
}
};
//Инициализация сервера интеграции
const initServer = async prms => {
let res = await executeStored({
//Проверка соответствия релизов сервера приложений и системы
const checkRelease = async prms => {
let releaseData = await executeStored({
connection: prms.connection,
sName: "PKG_EXS.EXSSRV_INIT",
inPrms: {
SEXSSRV: prms.sServerName,
SIP: prms.sServerIP,
NWORKERS: prms.nMaxWorkers
},
sName: "PKG_EXS.UTL_PRODUCT_RELEASE_GET",
outPrms: {
NEXSSRV: DT_NUMBER
DB_RELEASE: DT_VARCHAR
},
isFunction: false
isFunction: true
});
//Если рег. номер сервера интеграции не определен
if (!res.NEXSSRV) {
throw new Error(`Ошибка считывания сервера интеграции с мнемокодом "${prms.sServerName}".`);
if (releaseData.DB_RELEASE !== prms.sRelease) {
throw new Error(`Версия сервера приложений (${prms.sRelease}) не соответствует версии системы (${releaseData.DB_RELEASE}).`);
}
//Возвращаем рег. номер сервера интеграции
return res.NEXSSRV;
};
//Очистка информации о сервере при закрытии сервиса
const clearServer = async prms => {
await executeStored({
connection: prms.connection,
sName: "PKG_EXS.EXSSRV_CLEAR",
inPrms: {
NEXSSRV: prms.nExsSrv
},
isFunction: false
});
};
//Подключение к БД
const connect = async prms => {
try {
//Создаем пул подключения
let pool = await oracledb.createPool({
user: prms.sUser,
password: prms.sPassword,
@ -195,21 +171,21 @@ const connect = async prms => {
poolMax: prms.nPoolMax ? prms.nPoolMax : 4,
poolIncrement: prms.nPoolIncrement ? prms.nPoolIncrement : 0,
sessionCallback: (connection, requestedTag, callback) => {
//Устанавливаем схему
connection
.execute(`ALTER SESSION SET CURRENT_SCHEMA=${prms.sSchema}`)
.then(r => {
//Устанавливаем модуль сессии
connection.execute(`begin PKG_EXS.UTL_MODULE_SET(SEXSSRV => '${prms.exsSrv.sServerName}'); end;`);
})
.then(r => {
if (prms.sSessionAppName) connection.module = prms.sSessionAppName;
connection.execute(`ALTER SESSION SET CURRENT_SCHEMA=${prms.sSchema}`).then(
r => {
callback(null, connection);
})
.catch(e => {
},
e => {
callback(e, null);
});
}
);
}
});
if (prms.bControlSystemVersion) {
await checkRelease({ sRelease: prms.sRelease, connection: pool });
}
await checkWorkers({ nMaxWorkers: prms.nMaxWorkers, connection: pool });
return pool;
} catch (e) {
throw new Error(e.message);
@ -219,7 +195,6 @@ const connect = async prms => {
//Отключение от БД
const disconnect = async prms => {
try {
//Отключаем от базы данных
await prms.connection.close(NPOOL_DRAIN_TIME);
return;
} catch (e) {
@ -232,9 +207,6 @@ const getServices = async prms => {
let servicesData = await executeStored({
connection: prms.connection,
sName: "PKG_EXS.SERVICES_GET",
inPrms: {
NEXSSRV: prms.nExsSrv
},
outPrms: {
RCSERVICES: DT_CURSOR
}
@ -343,8 +315,7 @@ const log = async prms => {
SMSG: prms.sMsg,
NEXSSERVICE: prms.nServiceId,
NEXSSERVICEFN: prms.nServiceFnId,
NEXSQUEUE: prms.nQueueId,
NEXSSRV: prms.nExsSrv
NEXSQUEUE: prms.nQueueId
},
outPrms: { RCLOG: DT_CURSOR }
});
@ -390,8 +361,7 @@ const getQueueOutgoing = async prms => {
connection: prms.connection,
sName: "PKG_EXS.QUEUE_SRV_TYPE_SEND_GET",
inPrms: {
NPORTION_SIZE: prms.nPortionSize,
NEXSSRV: prms.nExsSrv
NPORTION_SIZE: prms.nPortionSize
},
outPrms: { RCQUEUES: DT_CURSOR }
});
@ -522,9 +492,6 @@ exports.DT_CLOB = DT_CLOB;
exports.DT_BLOB = DT_BLOB;
exports.DT_CURSOR = DT_CURSOR;
exports.executeStored = executeStored;
exports.checkAppStart = checkAppStart;
exports.initServer = initServer;
exports.clearServer = clearServer;
exports.connect = connect;
exports.disconnect = disconnect;
exports.getServices = getServices;

82
modules/parus_pg_db.js
View File

@ -130,65 +130,44 @@ const executeStored = async prms => {
if (outResult) return outResult;
};
//Проверка условий при запуске сервиса интеграции
const checkAppStart = async prms => {
let res = await executeStored({
//Проверка допустимого количества воркеров
const checkWorkers = async prms => {
let workersData = await executeStored({
connection: prms.connection,
sName: "PKG_EXS$UTL_APPSRV_START_CHECK",
inPrms: {
NCONTROL_VERSION: prms.bControlSystemVersion ? 1 : 0,
SEXS_RELEASE_DATE: prms.sRelease,
NWORKERS: prms.nWorkers,
SEXSSRV: prms.sServerName !== "" ? prms.sServerName : null,
SSESSION_APP_NAME: prms.sSessionAppName
},
sName: "PKG_EXS$UTL_LIC_CLNT_COUNT_GET",
outPrms: {
SERR_TEXT: DT_VARCHAR
LIC_CNT: DT_NUMBER
}
});
//Если есть ошибки запуска
if (res.SERR_TEXT) {
throw new Error(res.SERR_TEXT);
if (workersData.LIC_CNT === 0) {
throw new Error(`Не определено количество лицензий для приложения "ExchangeServer".`);
}
if (prms.nMaxWorkers > workersData.LIC_CNT - 1) {
throw new Error(
`Недопустимое значение параметра "Количество одновременно обрабатываемых исходящих сообщений" ("outGoing.nMaxWorkers") файла конфигурации сервиса приложений ("config.js"). Максимальное количество одновременно обрабатываемых исходящих сообщений - ${
workersData.LIC_CNT - 1
}.`
);
}
};
//Инициализация сервера интеграции
const initServer = async prms => {
let res = await executeStored({
//Проверка соответствия релизов сервера приложений и системы
const checkRelease = async prms => {
let releaseData = await executeStored({
connection: prms.connection,
sName: "PKG_EXS$EXSSRV_INIT",
inPrms: {
SEXSSRV: prms.sServerName,
SIP: prms.sServerIP,
NWORKERS: prms.nMaxWorkers
},
sName: "PKG_EXS$UTL_PRODUCT_RELEASE_GET",
outPrms: {
NEXSSRV: DT_NUMBER
DB_RELEASE: DT_VARCHAR
}
});
//Если рег. номер сервера интеграции потерялся
if (!res.NEXSSRV) {
throw new Error(`Ошибка считывания сервера интеграции с мнемокодом "${prms.sServerName}".`);
if (releaseData.DB_RELEASE !== prms.sRelease) {
throw new Error(`Версия сервера приложений (${prms.sRelease}) не соответствует версии системы (${releaseData.DB_RELEASE}).`);
}
//Возвращаем рег. номер сервера интеграции
return res.NEXSSRV;
};
//Очистка информации о сервере при закрытии сервиса
const clearServer = async prms => {
await executeStored({
connection: prms.connection,
sName: "PKG_EXS$EXSSRV_CLEAR",
inPrms: {
NEXSSRV: prms.nExsSrv
}
});
};
//Подключение к БД
const connect = async prms => {
try {
//Создаем пул подключения
let pool = new pg.Pool({
connectionString: `postgres://${prms.sUser}:${prms.sPassword}@${prms.sConnectString}`,
connectionTimeoutMillis: 600000,
@ -196,11 +175,12 @@ const connect = async prms => {
max: prms.nPoolMax ? prms.nPoolMax : 4
});
pool.on("acquire", async client => {
//Устанавливаем схему
await client.query(`select ALTER_SESSION_SET_SCHEMA($1);`, [prms.sSchema]);
//Устанавливаем модуль сессии
await client.query(`select PKG_EXS$UTL_MODULE_SET($1);`, [prms.exsSrv.sServerName]);
});
if (prms.bControlSystemVersion) {
await checkRelease({ sRelease: prms.sRelease, connection: pool });
}
await checkWorkers({ nMaxWorkers: prms.nMaxWorkers, connection: pool });
return pool;
} catch (e) {
throw new Error(e.message);
@ -221,9 +201,6 @@ const getServices = async prms => {
let servicesData = await executeStored({
connection: prms.connection,
sName: "PKG_EXS$SERVICES_GET",
inPrms: {
NEXSSRV: prms.nExsSrv
},
outPrms: {
RCSERVICES: DT_CURSOR
}
@ -331,8 +308,7 @@ const log = async prms => {
SMSG: prms.sMsg,
NEXSSERVICE: prms.nServiceId,
NEXSSERVICEFN: prms.nServiceFnId,
NEXSQUEUE: prms.nQueueId,
NEXSSRV: prms.nExsSrv
NEXSQUEUE: prms.nQueueId
},
outPrms: { RCLOG: DT_CURSOR }
});
@ -378,8 +354,7 @@ const getQueueOutgoing = async prms => {
connection: prms.connection,
sName: "PKG_EXS$QUEUE_SRV_TYPE_SEND_GET",
inPrms: {
NPORTION_SIZE: prms.nPortionSize,
NEXSSRV: prms.nExsSrv
NPORTION_SIZE: prms.nPortionSize
},
outPrms: { RCQUEUES: DT_CURSOR }
});
@ -510,9 +485,6 @@ exports.DT_CLOB = DT_CLOB;
exports.DT_BLOB = DT_BLOB;
exports.DT_CURSOR = DT_CURSOR;
exports.executeStored = executeStored;
exports.checkAppStart = checkAppStart;
exports.initServer = initServer;
exports.clearServer = clearServer;
exports.connect = connect;
exports.disconnect = disconnect;
exports.getServices = getServices;