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

Compare commits

base: Dollerok:ac7870e8841fcbbf2a23aff5600f3024a7efcfe6
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:1dc5b5d10850566ef25d02fb14c88ff3e3c3fc41
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. "ac7870e8841fcbbf2a23aff5600f3024a7efcfe6" and "1dc5b5d10850566ef25d02fb14c88ff3e3c3fc41" have entirely different histories.
ac7870e884 ... 1dc5b5d108

3 changed files with 12 additions and 20 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.12.24",
sRelease: "2025.11.06",
//Таймаут останова сервера (мс)
nTerminateTimeout: 60000,
//Контролировать версию Системы

2
core/mqtt_connector.js
View File

@ -37,7 +37,7 @@ const publishMQTT = async ({ settings, url, auth, topic, message, logger }) => {
//Прослушиваем ошибки
client.on("error", e => {
//Если требуется выдавать ошибку
if ([SLOG_ERROR, SLOG_INFO].includes(settings.sLogLevel)) {
if (settings.sLogLevel === SLOG_ERROR) {
//Выводим ошибку
logger.error(`${SERR_MQTT}: ${makeErrorText(e)}`);
}

28
modules/diadoc.js
View File

@ -136,23 +136,15 @@ const buildHeaders = (sAPIClientId, sToken = null) => ({
});
//Отбор организций
const getOrganizations = (organizations, sNumEdo = null) => {
const getOrganizations = organizations => {
//Параметры отбора
let isRoaming = false;
let isActive = true;
//Итоговая выборка
let organization = { Organizations: [] };
//Задан код участника ЭДО
if (sNumEdo) {
//Найдем активную организацию не в роуминге
organization.Organizations[0] = organizations.Organizations.find(org => (org.FnsParticipantId === sNumEdo));
};
//Не удалось получить организацию по коду участника ЭДО
if (!organization.Organizations[0]) {
//Найдем активную организацию не в роуминге
organization.Organizations[0] = organizations.Organizations.find(org => (org.IsRoaming === isRoaming) && (org.IsActive === isActive));
};
//Не удалось получить организацию не в роуминге
//Найдем активную организацию не в роуминге
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));
@ -193,7 +185,7 @@ const getOrganization = async (sSrvRoot, headers, nInn, nKpp) => {
};
//Получение ящика организации по ИНН/КПП контрагента
const getOrganizationBoxId = async (sSrvRoot, headers, nInn, nKpp, sNumEdo) => {
const getOrganizationBoxId = async (sSrvRoot, headers, nInn, nKpp) => {
//Параметры запроса
let rqpOptions;
let serverResp;
@ -213,9 +205,9 @@ const getOrganizationBoxId = async (sSrvRoot, headers, nInn, nKpp, sNumEdo) => {
serverResp = await rqp(rqpOptions);
try {
//Получим организацию не в роуминге (или единственную организацию в роуминге)
serverResp = getOrganizations(serverResp, sNumEdo);
serverResp = getOrganizations(serverResp);
if (!serverResp?.Organizations[0]) {
throw Error(`Не удалось получить ящик получателя для контрагента с ${sNumEdo ? `кодом участника ЭДО: ${sNumEdo}, ` : ""}ИНН: ${nInn} и КПП: ${nKpp}`);
throw Error(`Не удалось получить ящик получателя для контрагента с ИНН: ${nInn} и КПП: ${nKpp}`);
}
} catch (e) {
//Получим головную организацию по ИНН/КПП
@ -337,7 +329,7 @@ const beforeMessagePost = async prms => {
throw Error(`Ошибка при получении ящика текущей организации: ${e.message}`);
}
//Получим ящик получателя
organization = await getOrganizationBoxId(prms.service.sSrvRoot, buildHeaders(sAPIClientId, sToken), optionsData.inn_cs, optionsData.kpp_cs, optionsData.num_cs);
organization = await getOrganizationBoxId(prms.service.sSrvRoot, buildHeaders(sAPIClientId, sToken), optionsData.inn_cs, optionsData.kpp_cs);
obj.ToBoxId = organization.BoxId;
//Если не заполнен идентификатор подразделения и при получении ящика удалось его подобрать
if ((!obj.ToDepartmentId) && (organization.DepartmentId)) {
@ -852,9 +844,9 @@ const afterDepartmentIdGet = async prms => {
try {
try {
//Получим организацию не в роуминге (или единственную организацию в роуминге)
organization = getOrganizations(JSON.parse(prms.queue.blResp.toString()), optionsData.sNumEdo);
organization = getOrganizations(JSON.parse(prms.queue.blResp.toString()));
if (!organization) {
throw Error(`Не удалось получить ящик для контрагента с ${optionsData.sNumEdo ? `кодом участника ЭДО: ${optionsData.sNumEdo}, ` : ""}ИНН: ${optionsData.nINN} и КПП: ${optionsData.nKPP}`);
throw Error(`Не удалось получить ящик для контрагента с ИНН: ${optionsData.nINN} и КПП: ${optionsData.nKPP}`);
}
} catch (e) {
//Получим ключ разработчика