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

Доработан контроль "определенности" результата обработчиков сервера приложений

Browse Source
This commit is contained in:
Mikhail Chechnev 2018-12-24 16:01:33 +03:00
parent ca445a4083
commit 8f4541208c
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
core/in_queue.js
View File

@ -145,14 +145,14 @@ class InQueue extends EventEmitter {
nExecState: objQueueSchema.NQUEUE_EXEC_STATE_APP_OK nExecState: objQueueSchema.NQUEUE_EXEC_STATE_APP_OK
}); });
//Фиксируем успех исполнения //Фиксируем успех исполнения
if (resBefore.blMsg) { if (!_.isUndefined(resBefore.blMsg)) {
blMsg = resBefore.blMsg; blMsg = resBefore.blMsg;
q = await this.dbConn.setQueueMsg({ q = await this.dbConn.setQueueMsg({
nQueueId: q.nId, nQueueId: q.nId,
blMsg blMsg
}); });
} }
if (resBefore.blResp) { if (!_.isUndefined(resBefore.blResp)) {
blResp = resBefore.blResp; blResp = resBefore.blResp;
q = await this.dbConn.setQueueResp({ q = await this.dbConn.setQueueResp({
nQueueId: q.nId, nQueueId: q.nId,
@ -217,7 +217,7 @@ class InQueue extends EventEmitter {
nExecState: objQueueSchema.NQUEUE_EXEC_STATE_APP_OK nExecState: objQueueSchema.NQUEUE_EXEC_STATE_APP_OK
}); });
//Фиксируем успех исполнения //Фиксируем успех исполнения
if (resAfter.blResp) { if (!_.isUndefined(resAfter.blResp)) {
blResp = resAfter.blResp; blResp = resAfter.blResp;
q = await this.dbConn.setQueueResp({ q = await this.dbConn.setQueueResp({
nQueueId: q.nId, nQueueId: q.nId,

2
models/obj_in_queue.js
View File

@ -41,7 +41,7 @@ exports.InQueueProcessorFnAfter = new Schema({
//Обработанный ответ системы //Обработанный ответ системы
blResp: { blResp: {
type: Buffer, type: Buffer,
required: true, required: false,
message: { message: {
type: path => `Обработанный ответ системы (${path}) имеет некорректный тип данных (ожидалось - Buffer)`, type: path => `Обработанный ответ системы (${path}) имеет некорректный тип данных (ожидалось - Buffer)`,
required: path => `Не указан обработанный ответ системы (${path})` required: path => `Не указан обработанный ответ системы (${path})`