diff --git a/core/in_queue.js b/core/in_queue.js index 790a23d..d33d619 100644 --- a/core/in_queue.js +++ b/core/in_queue.js @@ -145,14 +145,14 @@ class InQueue extends EventEmitter { nExecState: objQueueSchema.NQUEUE_EXEC_STATE_APP_OK }); //Фиксируем успех исполнения - if (resBefore.blMsg) { + if (!_.isUndefined(resBefore.blMsg)) { blMsg = resBefore.blMsg; q = await this.dbConn.setQueueMsg({ nQueueId: q.nId, blMsg }); } - if (resBefore.blResp) { + if (!_.isUndefined(resBefore.blResp)) { blResp = resBefore.blResp; q = await this.dbConn.setQueueResp({ nQueueId: q.nId, @@ -217,7 +217,7 @@ class InQueue extends EventEmitter { nExecState: objQueueSchema.NQUEUE_EXEC_STATE_APP_OK }); //Фиксируем успех исполнения - if (resAfter.blResp) { + if (!_.isUndefined(resAfter.blResp)) { blResp = resAfter.blResp; q = await this.dbConn.setQueueResp({ nQueueId: q.nId, diff --git a/models/obj_in_queue.js b/models/obj_in_queue.js index 539ed13..300ea77 100644 --- a/models/obj_in_queue.js +++ b/models/obj_in_queue.js @@ -41,7 +41,7 @@ exports.InQueueProcessorFnAfter = new Schema({ //Обработанный ответ системы blResp: { type: Buffer, - required: true, + required: false, message: { type: path => `Обработанный ответ системы (${path}) имеет некорректный тип данных (ожидалось - Buffer)`, required: path => `Не указан обработанный ответ системы (${path})`