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

Compare commits

base: Dollerok:62786dcc5a66087a3972117ec6987c47a59eedd1
Branches Tags
Dollerok:master
Dollerok:dependabot/npm_and_yarn/express-4.19.2
CITKParus:master
CITKParus:upgrade-node
CITKParus:dependabot/npm_and_yarn/express-4.19.2
..
compare: Dollerok:061b7f2fad8fe15e26f5e65d7cd4f9755e0d5304
Branches Tags
Dollerok:master
Dollerok:dependabot/npm_and_yarn/express-4.19.2
CITKParus:master
CITKParus:upgrade-node
CITKParus:dependabot/npm_and_yarn/express-4.19.2

No commits in common. "62786dcc5a66087a3972117ec6987c47a59eedd1" and "061b7f2fad8fe15e26f5e65d7cd4f9755e0d5304" have entirely different histories.
62786dcc5a ... 061b7f2fad

6 changed files with 38 additions and 60 deletions
Show Stats Expand all files Collapse all files

2
config.js
View File

@ -14,7 +14,7 @@ let common = {
//Версия сервера приложений
sVersion: "8.5.6.1",
//Релиз сервера приложений
sRelease: "2025.11.06",
sRelease: "2025.07.01",
//Таймаут останова сервера (мс)
nTerminateTimeout: 60000,
//Контролировать версию Системы

48
core/in_queue.js
View File

@ -152,8 +152,6 @@ class InQueue extends EventEmitter {
sOptions: buildOptionsXML({ options }),
blMsg
});
//Запомним идентификатор записи очереди в запросе
prms.req.nQId = q.nId;
//Скажем что пришло новое входящее сообщение
await this.logger.info(
`Новое входящее сообщение от ${prms.req.connection.address().address} для функции ${prms.function.sCode} (${buildURL({
@ -331,19 +329,13 @@ class InQueue extends EventEmitter {
}
}
}
//Всё успешно - отдаём результат клиенту, если ещё не отдали
if (bStopPropagation === false && !prms.res.writableFinished) {
if (optionsResp.headers) prms.res.set(optionsResp.headers);
prms.res.status(optionsResp.statusCode || 200).send(blResp);
}
//Если отправка ответа была прервана по таймауту
if (prms.req.bIsTimedOut === true) {
//Вернем ошибку обработчика с информацией об этом
throw new ServerError(
SERR_WEB_SERVER,
"Истекло время ожидания обработки входящего запроса. Канал закрыт. Клиенту был отправлен ответ с ошибкой истечения таймаута (504)."
);
} else {
//Если мы еще не отдали ответ от сервера
if (!prms.res.writableFinished) {
//Всё успешно - отдаём результат клиенту
if (bStopPropagation === false) {
if (optionsResp.headers) prms.res.set(optionsResp.headers);
prms.res.status(optionsResp.statusCode || 200).send(blResp);
}
//Фиксируем успех обработки - в протоколе работы сервиса
await this.logger.info(`Входящее сообщение ${q.nId} успешно отработано`, { nQueueId: q.nId });
//Фиксируем успех обработки - в статусе сообщения
@ -352,6 +344,12 @@ class InQueue extends EventEmitter {
nIncExecCnt: NINC_EXEC_CNT_YES,
nExecState: objQueueSchema.NQUEUE_EXEC_STATE_OK
});
} else {
//Или расскажем об ошибке
throw new ServerError(
SERR_WEB_SERVER,
"Истекло время ожидания обработки входящего запроса. Канал закрыт. Клиенту был отправлен ответ."
);
}
} catch (e) {
//Тема и текст уведомления об ошибке
@ -557,24 +555,21 @@ class InQueue extends EventEmitter {
if (req.headers["content-type"] === "false") req.headers["content-type"] = "application/octet-stream";
next();
});
//Конфигурируем сервер - устанавливаем таймаут обработки сообщений
this.webApp.use((req, res, next) => {
//Поднимем флаг истечения таймаута обработки
req.bIsTimedOut = false;
//Если требуется установить таймаут на обработку сообщений
if (this.inComing.nTimeout !== 0)
//Если требуется установить таймаут на обработку сообщений
if (this.inComing.nTimeout !== 0) {
//Конфигурируем сервер - устанавливаем таймаут обработки сообщений
this.webApp.use((req, res, next) => {
//Устанавливаем таймаут на ответ от сервера
res.setTimeout(this.inComing.nTimeout, () => {
//Поднимем флаг исчетечение таймаута обработки
req.bIsTimedOut = true;
//Формируем ошибку
let err = new Error("Истекло время ожидания формирования ответа для завершения текущего запроса.");
err.status = 504;
//Отправляем ошибку
next(err);
});
next();
});
next();
});
}
//Конфигурируем сервер - обработка тела сообщения
this.webApp.use(bodyParser.raw({ limit: `${this.inComing.nMsgMaxSize}mb`, type: "*/*" }));
//Конфигурируем сервер - обходим все сервисы, работающие на приём сообщений
@ -629,8 +624,7 @@ class InQueue extends EventEmitter {
//Протоколируем в журнал работы сервера
await this.logger.error(makeErrorText(new ServerError(SERR_WEB_SERVER, err.message)), {
nServiceId: srvs.nId,
nServiceFnId: fn.nId,
nQueueId: req.nQId || null
nServiceFnId: fn.nId
});
//Отправим ошибку клиенту
res.status(err.status || 500).send(makeErrorText(new ServerError(SERR_WEB_SERVER, err.message)));

4
core/kafka_connector.js
View File

@ -90,7 +90,7 @@ const subscribeKafka = async ({ settings, service, processMessage, logger }) =>
})
});
} catch (e) {
await logger.error(`Ошибка обработки входящего сообщения Kafka: ${makeErrorText(e)}`);
await logger.error(`Ошибка обработки исходящего сообщения Kafka: ${makeErrorText(e)}`);
}
}
});
@ -107,7 +107,7 @@ const subscribeKafka = async ({ settings, service, processMessage, logger }) =>
//Возвращаем соединение
return consumer;
} catch (e) {
await logger.error(`Ошибка запуска обработчика очереди входящих сообщений Kafka: ${makeErrorText(e)}`);
await logger.error(`Ошибка запуска обработчика очереди исходящих сообщений Kafka: ${makeErrorText(e)}`);
}
};

4
core/utils.js
View File

@ -404,7 +404,7 @@ const getURLProtocol = sURL => {
};
//Обёртывание промиса в таймаут исполнения
const wrapPromiseTimeout = (timeout, promise, promiseCancellable = true) => {
const wrapPromiseTimeout = (timeout, promise) => {
if (!timeout) return promise;
let timeoutPid;
const timeoutPromise = new Promise((resolve, reject) => {
@ -414,7 +414,7 @@ const wrapPromiseTimeout = (timeout, promise, promiseCancellable = true) => {
timeoutPid = setTimeout(() => reject(e), timeout);
});
return Promise.race([promise, timeoutPromise]).finally(() => {
if (promiseCancellable && promise.promise().isPending()) promise.cancel();
if (promise.promise().isPending()) promise.cancel();
if (timeoutPid) clearTimeout(timeoutPid);
});
};

34
modules/diadoc.js
View File

@ -27,8 +27,7 @@ const tag = [
"Resolutions",
"XmlSignatureRejections",
"RecipientTitles",
"Requests",
"UniversalMessages"
"Requests"
];
//------------
@ -145,11 +144,6 @@ const getOrganizations = organizations => {
//Найдем активную организацию не в роуминге
organization.Organizations[0] = organizations.Organizations.find(org => (org.IsRoaming === isRoaming) && (org.IsActive === isActive));
//Если не удалось получить организацию не в роуминге
if (!organization.Organizations[0]) {
//Найдем активную организацию
organization.Organizations[0] = organizations.Organizations.find(org => (org.IsActive === isActive));
};
//Если не удалось получить активную организацию
if (!organization.Organizations[0]) {
//Если нет организации не в роуминге и найдено более одной организации
if (organizations.Organizations.length > 1) {
@ -296,8 +290,6 @@ const beforeMessagePost = async prms => {
}
//Если не достали из контекста токен доступа - значит нет аутентификации на сервере
if (!sToken) return { bUnAuth: true };
//Получим параметры запроса
const optionsData = await toJSON(prms.queue.sOptions);
//Конвертируем XML из "Парус 8" в JSON
let obj = await toJSON(prms.queue.blMsg.toString());
//Формируем запрос для получения FromBoxId
@ -315,7 +307,7 @@ const beforeMessagePost = async prms => {
//Получим идентификатор организации по ИНН/КПП поставщика документа
for (let i in serverResp.Organizations) {
//Если найдена подходящая организация - запомним идентификатор и выходим из цикла
if (serverResp.Organizations[i].Inn == optionsData.inn_pr && serverResp.Organizations[i].Kpp == optionsData.kpp_pr) {
if (serverResp.Organizations[i].Inn == prms.options.inn_pr && serverResp.Organizations[i].Kpp == prms.options.kpp_pr) {
//Сохраняем полученный ответ
obj.FromBoxId = serverResp.Organizations[i].Boxes[0].BoxId;
break;
@ -323,13 +315,13 @@ const beforeMessagePost = async prms => {
}
//Не удалось получить ящик отправителя
if (!obj.FromBoxId) {
throw new Error(`Не удалось получить ящик текущей организации с ИНН: ${optionsData.inn_pr} и КПП: ${optionsData.kpp_pr}`);
throw new Error(`Не удалось получить ящик текущей организации с ИНН: ${prms.options.inn_pr} и КПП: ${prms.options.kpp_pr}`);
}
} catch (e) {
throw Error(`Ошибка при получении ящика текущей организации: ${e.message}`);
}
//Получим ящик получателя
organization = await getOrganizationBoxId(prms.service.sSrvRoot, buildHeaders(sAPIClientId, sToken), optionsData.inn_cs, optionsData.kpp_cs);
organization = await getOrganizationBoxId(prms.service.sSrvRoot, buildHeaders(sAPIClientId, sToken), prms.options.inn_cs, prms.options.kpp_cs);
obj.ToBoxId = organization.BoxId;
//Если не заполнен идентификатор подразделения и при получении ящика удалось его подобрать
if ((!obj.ToDepartmentId) && (organization.DepartmentId)) {
@ -456,8 +448,6 @@ const beforeEvent = async prms => {
}
//Если не достали из контекста токен доступа - значит нет аутентификации на сервере
if (!sToken) return { bUnAuth: true };
//Получим параметры запроса
const optionsData = await toJSON(prms.queue.sOptions);
//Формируем запрос для получения BoxId
let rqpOptions = {
uri: buildMyOrganizationURL(prms.service.sSrvRoot),
@ -470,7 +460,7 @@ const beforeEvent = async prms => {
//Получим идентификатор организации по ИНН/КПП контрагента организации
for (let i in serverResp.Organizations) {
//Если найдена подходящая организация - запомним идентификатор и выходим из цикла
if (serverResp.Organizations[i].Inn == optionsData.inn && serverResp.Organizations[i].Kpp == optionsData.kpp) {
if (serverResp.Organizations[i].Inn == prms.options.inn && serverResp.Organizations[i].Kpp == prms.options.kpp) {
//Сохраняем полученный ответ
sBoxId = serverResp.Organizations[i].Boxes[0].BoxId;
//Если задано подразделение
@ -497,7 +487,7 @@ const beforeEvent = async prms => {
}
//Не удалось получить ящик текущей организации
if (!sBoxId) {
throw new Error(`Не удалось получить ящик текущей организации с ИНН: ${optionsData.inn} и КПП: ${optionsData.kpp}`);
throw new Error(`Не удалось получить ящик текущей организации с ИНН: ${prms.options.inn} и КПП: ${prms.options.kpp}`);
}
} catch (e) {
throw Error(`Ошибка при получении ящика текущей организации: ${e.message}`);
@ -693,16 +683,12 @@ const beforeDocLoad = async prms => {
entId = "documentId=";
msgId = "letterId=";
break;
//Загрузка Универсального сообщения
case 6:
entId = "attachmentId=";
break;
default:
}
surl = `${surl}?${msgId}${prms.options.smsgid}&${entId}${prms.options.sentid}`;
let obj;
let rblMsg;
if (prms.queue.blMsg && (prms.options.type != 5) && (prms.options.type != 6)) {
if (prms.queue.blMsg && prms.options.type != 5) {
//Конвертируем XML из "Парус 8" в понятный "ДИАДОК" JSON
obj = await toJSON(prms.queue.blMsg.toString());
rblMsg = Buffer.from(JSON.stringify(obj));
@ -837,8 +823,6 @@ const beforeDepartmentIdGet = async prms => {
const afterDepartmentIdGet = async prms => {
let resu = null;
let organization = {};
//Получим параметры запроса
const optionsData = await toJSON(prms.queue.sOptions);
//Действие выполнено успешно
if (prms.optionsResp.statusCode == 200) {
try {
@ -846,7 +830,7 @@ const afterDepartmentIdGet = async prms => {
//Получим организацию не в роуминге (или единственную организацию в роуминге)
organization = getOrganizations(JSON.parse(prms.queue.blResp.toString()));
if (!organization) {
throw Error(`Не удалось получить ящик для контрагента с ИНН: ${optionsData.nINN} и КПП: ${optionsData.nKPP}`);
throw Error(`Не удалось получить ящик для контрагента с ИНН: ${prms.options.nINN} и КПП: ${prms.options.nKPP}`);
}
} catch (e) {
//Получим ключ разработчика
@ -854,7 +838,7 @@ const afterDepartmentIdGet = async prms => {
//Считаем токен доступа из контекста сервиса
let sToken = prms.service.sCtx;
//Получим головную организацию по ИНН/КПП
organization = await getOrganization(prms.service.sSrvRoot, buildHeaders(sAPIClientId, sToken), optionsData.nINN, optionsData.nKPP);
organization = await getOrganization(prms.service.sSrvRoot, buildHeaders(sAPIClientId, sToken), prms.options.nINN, prms.options.nKPP);
};
//Преобразуем JSON ответ сервиса "ДИАДОК" в XML, понятный "Парус 8"
resu = toXML({ root: organization });

6
package.json
View File

@ -9,14 +9,14 @@
},
"repository": {
"type": "git",
"url": "git+https://git.citpb.ru/CITKParus/P8-ExchangeService.git"
"url": "git+https://github.com/CITKParus/ExchangeService.git"
},
"author": "CITK Parus",
"license": "ISC",
"bugs": {
"url": "https://git.citpb.ru/CITKParus/P8-ExchangeService/issues"
"url": "https://github.com/CITKParus/ExchangeService/issues"
},
"homepage": "https://git.citpb.ru/CITKParus/P8-ExchangeService/",
"homepage": "https://github.com/CITKParus/ExchangeService#readme",
"dependencies": {
"body-parser": "^1.19.0",
"cors": "^2.8.5",