CITKParus/P8-ExchangeService
9
0
Fork 2
Code Issues Pull Requests Projects Releases 5 Wiki Activity

П8-64251 - ошибка освобождения обработчика при сбросе флага "Сохранять успешное исполнение в очереди"

Browse Source
This commit is contained in:
Mim 2026-06-29 17:30:23 +03:00
parent a25060b2f4
commit 2251a12c91
4 changed files with 14 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
core/logger.js
View File

@ -82,6 +82,10 @@ class Logger {
}
} catch (e) {
console.log(SCONSOLE_LOG_COLOR_PATTERN_ERR, `${sNow} ОШИБКА ПРОТОКОЛИРОВАНИЯ: `, e.sMessage);
try {
if (this.dbConnector && this.dbConnector.bConnected)
await this.dbConnector.putLog({ nLogState: NLOG_STATE_ERR, sMsg: `ОШИБКА ПРОТОКОЛИРОВАНИЯ: ${e.sMessage}` });
} catch {}
}
}
} else {

12
core/out_queue.js
View File

@ -204,10 +204,14 @@ class OutQueue extends EventEmitter {
else await this.logger.info(message, logData);
}
//Сбрасываем признак "В работе" позиции очереди
await this.dbConn.setInProgress({
nQueueId: prms.nQueueId,
nInProgress: objQueueSchema.NQUEUE_IN_PROGRESS_NO
});
try {
await this.dbConn.setInProgress({
nQueueId: prms.nQueueId,
nInProgress: objQueueSchema.NQUEUE_IN_PROGRESS_NO
});
} catch (e) {
this.logger.error(`При сбросе признака "В работе" для исходящего сообщения ${prms.nQueueId}: ${makeErrorText(e)}`);
}
//Увеличиваем количество доступных обработчиков
this.nWorkersLeft++;
} else {

1
modules/parus_oracle_db.js
View File

@ -418,6 +418,7 @@ const setInProgress = async prms => {
connection: prms.connection,
sName: "PKG_EXS.QUEUE_IN_PROGRESS_SET",
inPrms: {
NFLAG_SMART: 1,
NEXSQUEUE: prms.nQueueId,
NIN_PROGRESS: prms.nInProgress
}

1
modules/parus_pg_db.js
View File

@ -379,6 +379,7 @@ const setInProgress = async prms => {
connection: prms.connection,
sName: "PKG_EXS$QUEUE_IN_PROGRESS_SET",
inPrms: {
NFLAG_SMART: 1,
NEXSQUEUE: prms.nQueueId,
NIN_PROGRESS: prms.nInProgress
}