forked from CITKParus/P8-ExchangeService
Перенос модулей сервера приложений в репозиторий "P8-ExchangeServiceExt" из данного
This commit is contained in:
Mikhail Chechnev
parent
b135bbbab5
commit
f7f68feda5
@ -1,819 +0,0 @@
|
|||||||
/*
|
|
||||||
Сервис интеграции ПП Парус 8 с WEB API
|
|
||||||
Дополнительный модуль: Взаимодействие с "АТОЛ-Онлайн" (v4) в формате ФФД 1.05
|
|
||||||
|
|
||||||
Полный формат формируемой посылки для чека:
|
|
||||||
reqBody = {
|
|
||||||
timestamp: "",
|
|
||||||
external_id: 0,
|
|
||||||
service: {
|
|
||||||
callback_url: ""
|
|
||||||
},
|
|
||||||
receipt: {
|
|
||||||
client: {
|
|
||||||
email: "",
|
|
||||||
phone: ""
|
|
||||||
},
|
|
||||||
company: {
|
|
||||||
email: "",
|
|
||||||
sno: "",
|
|
||||||
inn: "",
|
|
||||||
payment_address: ""
|
|
||||||
},
|
|
||||||
agent_info: {
|
|
||||||
type: "",
|
|
||||||
paying_agent: {
|
|
||||||
operation: "",
|
|
||||||
phones: [""]
|
|
||||||
},
|
|
||||||
receive_payments_operator: {
|
|
||||||
phones: [""]
|
|
||||||
},
|
|
||||||
money_transfer_operator: {
|
|
||||||
phones: [""],
|
|
||||||
name: "",
|
|
||||||
address: "",
|
|
||||||
inn: ""
|
|
||||||
}
|
|
||||||
},
|
|
||||||
supplier_info: {
|
|
||||||
phones: [""]
|
|
||||||
},
|
|
||||||
items: [
|
|
||||||
{
|
|
||||||
name: "",
|
|
||||||
price: 0,
|
|
||||||
quantity: 0,
|
|
||||||
sum: 0,
|
|
||||||
measurement_unit: "",
|
|
||||||
payment_method: "",
|
|
||||||
payment_object: "",
|
|
||||||
vat: {
|
|
||||||
type: "",
|
|
||||||
sum: 0
|
|
||||||
},
|
|
||||||
agent_info: {
|
|
||||||
type: "",
|
|
||||||
paying_agent: {
|
|
||||||
operation: "",
|
|
||||||
phones: [""]
|
|
||||||
},
|
|
||||||
receive_payments_operator: {
|
|
||||||
phones: [""]
|
|
||||||
},
|
|
||||||
money_transfer_operator: {
|
|
||||||
phones: [""],
|
|
||||||
name: "",
|
|
||||||
address: "",
|
|
||||||
inn: ""
|
|
||||||
}
|
|
||||||
},
|
|
||||||
supplier_info: {
|
|
||||||
phones: [""],
|
|
||||||
name: "",
|
|
||||||
address: "",
|
|
||||||
inn: ""
|
|
||||||
},
|
|
||||||
user_data: ""
|
|
||||||
}
|
|
||||||
],
|
|
||||||
payments: [
|
|
||||||
{
|
|
||||||
type: 0,
|
|
||||||
sum: 0
|
|
||||||
}
|
|
||||||
],
|
|
||||||
vats: [
|
|
||||||
{
|
|
||||||
type: "",
|
|
||||||
sum: 0
|
|
||||||
}
|
|
||||||
],
|
|
||||||
total: 0,
|
|
||||||
additional_check_props: "",
|
|
||||||
cashier: "",
|
|
||||||
additional_user_props: {
|
|
||||||
name: "",
|
|
||||||
value: ""
|
|
||||||
}
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
Полный формат формируемой посылки для чека коррекции:
|
|
||||||
reqBody = {
|
|
||||||
timestamp: "",
|
|
||||||
external_id: 0,
|
|
||||||
correction: {
|
|
||||||
company: {
|
|
||||||
sno: "",
|
|
||||||
inn: "",
|
|
||||||
payment_address: ""
|
|
||||||
},
|
|
||||||
correction_info: {
|
|
||||||
type: "",
|
|
||||||
base_date: "",
|
|
||||||
base_number: "",
|
|
||||||
base_name: ""
|
|
||||||
},
|
|
||||||
payments: [
|
|
||||||
{
|
|
||||||
type: "",
|
|
||||||
sum: 0
|
|
||||||
}
|
|
||||||
],
|
|
||||||
vats: [
|
|
||||||
{
|
|
||||||
type: "",
|
|
||||||
sum: 0
|
|
||||||
}
|
|
||||||
],
|
|
||||||
cashier: ""
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
*/
|
|
||||||
|
|
||||||
//----------------------
|
|
||||||
// Подключение библиотек
|
|
||||||
//----------------------
|
|
||||||
|
|
||||||
const parseString = require("xml2js").parseString; //Конвертация XML в JSON
|
|
||||||
const js2xmlparser = require("js2xmlparser"); //Конвертация JSON в XML
|
|
||||||
const _ = require("lodash"); //Работа с массивами и коллекциями
|
|
||||||
const { buildURL } = require("@core/utils"); //Вспомогательные функции
|
|
||||||
|
|
||||||
//---------------------
|
|
||||||
// Глобальные константы
|
|
||||||
//---------------------
|
|
||||||
|
|
||||||
//Код круппы ККТ (тестовой, для боевой - прописать его в настройках сервиса)
|
|
||||||
const SGROUP_CODE = "v4-online-atol-ru_4179";
|
|
||||||
|
|
||||||
//Типы документов по значению "Наименование документа" (тэг 1000)
|
|
||||||
const SDOCTYPE_TAG100_CHECK = "3"; //Чек
|
|
||||||
const SDOCTYPE_TAG100_CHECK_CORR = "31"; //Чек коррекции
|
|
||||||
|
|
||||||
//Статусы документов АТОЛ-онлайн
|
|
||||||
const SSTATUS_DONE = "done"; //Готово
|
|
||||||
const SSTATUS_FAIL = "fail"; //Ошибка
|
|
||||||
const SSTATUS_WAIT = "wait"; //Ожидание
|
|
||||||
|
|
||||||
//Словарь - Признак способа расчёта
|
|
||||||
const paymentMethod = {
|
|
||||||
sName: "Признак способа расчёта",
|
|
||||||
vals: {
|
|
||||||
"1": "full_prepayment",
|
|
||||||
"2": "prepayment",
|
|
||||||
"3": "advance",
|
|
||||||
"4": "full_payment",
|
|
||||||
"5": "partial_payment",
|
|
||||||
"6": "credit",
|
|
||||||
"7": "credit_payment"
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
//Словарь - Признак предмета расчёта
|
|
||||||
const paymentObject = {
|
|
||||||
sName: "Признак предмета расчёта",
|
|
||||||
vals: {
|
|
||||||
"1": "commodity",
|
|
||||||
"2": "excise",
|
|
||||||
"3": "job",
|
|
||||||
"4": "service",
|
|
||||||
"5": "gambling_bet",
|
|
||||||
"6": "gambling_prize",
|
|
||||||
"7": "lottery",
|
|
||||||
"8": "lottery_prize",
|
|
||||||
"9": "intellectual_activity",
|
|
||||||
"10": "payment",
|
|
||||||
"11": "agent_commission",
|
|
||||||
"12": "composite",
|
|
||||||
"13": "another",
|
|
||||||
"14": "property_right",
|
|
||||||
"15": "non-operating_gain",
|
|
||||||
"16": "insurance_premium",
|
|
||||||
"17": "sales_tax",
|
|
||||||
"18": "resort_fee"
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
//Словарь - Тип операции
|
|
||||||
const paymensOperation = {
|
|
||||||
sName: "Тип операции",
|
|
||||||
vals: {
|
|
||||||
"3_1": "sell", //Тэг 1000 = 3 (чек), тэг 1054 = 1 (приход)
|
|
||||||
"3_2": "sell_refund", //Тэг 1000 = 3 (чек), тэг 1054 = 2 (возврат прихода)
|
|
||||||
"3_3": "buy", //Тэг 1000 = 3 (чек), тэг 1054 = 3 (расход)
|
|
||||||
"3_4": "buy_refund", //Тэг 1000 = 3 (чек), тэг 1054 = 4 (возврат расхода)
|
|
||||||
"31_1": "sell_correction", //Тэг 1000 = 31 (коррекция), тэг 1054 = 1 (приход)
|
|
||||||
"31_2": "sell_refund", //Тэг 1000 = 31 (коррекция), тэг 1054 = 2 (возврат прихода)
|
|
||||||
"31_3": "buy_correction", //Тэг 1000 = 31 (коррекция), тэг 1054 = 3 (расход)
|
|
||||||
"31_4": "buy_refund" //Тэг 1000 = 31 (коррекция), тэг 1054 = 4 (возврат расхода)
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
//Словарь - Ставка НДС позиции чека
|
|
||||||
const receiptItemVat = {
|
|
||||||
sName: "Ставка НДС позиции чека",
|
|
||||||
vals: {
|
|
||||||
"1": "vat20",
|
|
||||||
"2": "vat10",
|
|
||||||
"3": "vat120",
|
|
||||||
"4": "vat110",
|
|
||||||
"5": "vat0",
|
|
||||||
"6": "none"
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
//Словарь - Тип коррекции
|
|
||||||
const correctionInfoType = {
|
|
||||||
sName: "Тип коррекции",
|
|
||||||
vals: {
|
|
||||||
"0": "self",
|
|
||||||
"1": "instruction"
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
//------------
|
|
||||||
// Тело модуля
|
|
||||||
//------------
|
|
||||||
|
|
||||||
//Разбор XML
|
|
||||||
const parseXML = xmlDoc => {
|
|
||||||
return new Promise((resolve, reject) => {
|
|
||||||
parseString(xmlDoc, { explicitArray: false, mergeAttrs: true }, function(err, result) {
|
|
||||||
if (err) reject(err);
|
|
||||||
else resolve(result);
|
|
||||||
});
|
|
||||||
});
|
|
||||||
};
|
|
||||||
|
|
||||||
//Конвертация значений в ожидаемые систеой АТОЛ-онлайн
|
|
||||||
const mapDictionary = (dict, sValue) => {
|
|
||||||
if (!dict) throw Error(`Словарь не определен`);
|
|
||||||
if (!dict.sName || !dict.vals || !(dict.vals instanceof Object)) throw Error(`Словарь имеет некорректный формат`);
|
|
||||||
if (typeof sValue === "undefined" || sValue === null || sValue === "")
|
|
||||||
throw Error(`Не указано значение для привязки к словарю "${dict.sName}"`);
|
|
||||||
const res = dict.vals[sValue];
|
|
||||||
if (typeof res === "undefined") throw Error(`Значение "${sValue}" отсутствует в словаре "${dict.sName}"`);
|
|
||||||
return res;
|
|
||||||
};
|
|
||||||
|
|
||||||
//Поиск значения в составе свойств фискального документа по коду свойства
|
|
||||||
const getPropValueByCode = (props, sCode, sValType = "STR", sValField = "VALUE") => {
|
|
||||||
if (!["STR", "NUM", "DATE"].includes(sValType)) throw Error(`Тип данных "${sValType}" не поддерживается`);
|
|
||||||
let res = null;
|
|
||||||
let prop = _.find(props, { SCODE: sCode });
|
|
||||||
if (typeof prop !== "undefined") {
|
|
||||||
res = prop[sValField];
|
|
||||||
if (typeof res === "undefined") res = null;
|
|
||||||
else if (res === "") res = null;
|
|
||||||
if (res !== null) {
|
|
||||||
switch (sValType) {
|
|
||||||
case "STR": {
|
|
||||||
try {
|
|
||||||
res = res.toString();
|
|
||||||
} catch (e) {
|
|
||||||
throw Error(`Ошибка конвертации значения "${res}" в строку: ${e.message}`);
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
case "NUM": {
|
|
||||||
res = res.replace(",", ".");
|
|
||||||
if (isNaN(res)) throw Error(`Значение "${res}" не является числом`);
|
|
||||||
try {
|
|
||||||
res = Number(res);
|
|
||||||
} catch (e) {
|
|
||||||
throw Error(`Ошибка конвертации значения "${res}" в число: ${e.message}`);
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
case "DATE": {
|
|
||||||
const resTmp = res;
|
|
||||||
try {
|
|
||||||
res = new Date(res);
|
|
||||||
} catch (e) {
|
|
||||||
throw Error(`Ошибка конвертации значения "${resTmp}" в дату: ${e.message}`);
|
|
||||||
}
|
|
||||||
if (res instanceof Date && isNaN(res))
|
|
||||||
throw Error(`Значение "${resTmp}" не является корректной датой`);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
default:
|
|
||||||
throw Error(`Тип данных "${sValType}" не поддерживается`);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return res;
|
|
||||||
};
|
|
||||||
|
|
||||||
//Добавление определённого количетсва часов к дате
|
|
||||||
const addHours = (dDate, nHours) => {
|
|
||||||
dDate.setTime(dDate.getTime() + nHours * 60 * 60 * 1000);
|
|
||||||
return new Date(dDate);
|
|
||||||
};
|
|
||||||
|
|
||||||
//Конвертация строки в формате ДД.ММ.ГГГГ ЧЧ:МИ:СС в JS Date
|
|
||||||
const strDDMMYYYYHHMISStoDate = sDate => {
|
|
||||||
let res = null;
|
|
||||||
if (sDate) {
|
|
||||||
try {
|
|
||||||
const [date, time] = sDate.split(" ");
|
|
||||||
const [day, month, year] = date.split(".");
|
|
||||||
const [hh, min, ss] = time.split(":");
|
|
||||||
res = new Date(year, month - 1, day, hh, min, ss);
|
|
||||||
if (isNaN(res.getTime())) {
|
|
||||||
res = null;
|
|
||||||
}
|
|
||||||
} catch (e) {
|
|
||||||
res = null;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return res;
|
|
||||||
};
|
|
||||||
|
|
||||||
//Разбор строки с контактными данными покупателя
|
|
||||||
let parseClientContacts = (sContacts, sDelim) => {
|
|
||||||
//Считывание E-Mail (выбор одного из двух значений)
|
|
||||||
const getMail = (sVal1, sVal2) => {
|
|
||||||
//E-Mail там, где есть @
|
|
||||||
if (sVal1 && sVal1.indexOf("@") != -1) return sVal1.trim();
|
|
||||||
if (sVal2 && sVal2.indexOf("@") != -1) return sVal2.trim();
|
|
||||||
//Нет вообще ничего нужного
|
|
||||||
return "";
|
|
||||||
};
|
|
||||||
//Считывание телефона (выбор одного из двух значений)
|
|
||||||
const getPhone = (sVal1, sVal2) => {
|
|
||||||
//Телефон там, где нет @
|
|
||||||
if (sVal1 && sVal1.indexOf("@") == -1) return sVal1.trim();
|
|
||||||
if (sVal2 && sVal2.indexOf("@") == -1) return sVal2.trim();
|
|
||||||
//Нет вообще ничего нужного
|
|
||||||
return "";
|
|
||||||
};
|
|
||||||
//Результат работы
|
|
||||||
let res = {
|
|
||||||
sMail: "",
|
|
||||||
sPhone: ""
|
|
||||||
};
|
|
||||||
//Прбуем разобрать
|
|
||||||
try {
|
|
||||||
//Разбиваем строку с учётом разделителя
|
|
||||||
const tmp = sContacts.split(sDelim, 2);
|
|
||||||
//Забираем нужные данные
|
|
||||||
res.sMail = getMail(tmp[0], tmp[1]);
|
|
||||||
res.sPhone = getPhone(tmp[0], tmp[1]);
|
|
||||||
} catch (e) {}
|
|
||||||
//Возвращаем результат
|
|
||||||
return res;
|
|
||||||
};
|
|
||||||
|
|
||||||
//Получение списка оплат по чеку
|
|
||||||
const getPayments = props => {
|
|
||||||
//Список платежей
|
|
||||||
let payments = [];
|
|
||||||
//Сумма по чеку электронными
|
|
||||||
if (getPropValueByCode(props, "1081", "NUM") !== null) {
|
|
||||||
payments.push({
|
|
||||||
type: 1,
|
|
||||||
sum: getPropValueByCode(props, "1081", "NUM")
|
|
||||||
});
|
|
||||||
}
|
|
||||||
//Сумма по чеку предоплатой (зачет аванса и (или) предыдущих платежей)
|
|
||||||
if (getPropValueByCode(props, "1215", "NUM") !== null) {
|
|
||||||
payments.push({
|
|
||||||
type: 2,
|
|
||||||
sum: getPropValueByCode(props, "1215", "NUM")
|
|
||||||
});
|
|
||||||
}
|
|
||||||
//Сумма по чеку постоплатой (кредит)
|
|
||||||
if (getPropValueByCode(props, "1216", "NUM") !== null) {
|
|
||||||
payments.push({
|
|
||||||
type: 3,
|
|
||||||
sum: getPropValueByCode(props, "1216", "NUM")
|
|
||||||
});
|
|
||||||
}
|
|
||||||
//Сумма по чеку встречным представлением
|
|
||||||
if (getPropValueByCode(props, "1217", "NUM") !== null) {
|
|
||||||
payments.push({
|
|
||||||
type: 4,
|
|
||||||
sum: getPropValueByCode(props, "1217", "NUM")
|
|
||||||
});
|
|
||||||
}
|
|
||||||
//Возвращаем результат
|
|
||||||
return payments;
|
|
||||||
};
|
|
||||||
|
|
||||||
//Получение списка налогов по чеку
|
|
||||||
const getVats = props => {
|
|
||||||
//Список налогов
|
|
||||||
let vats = [];
|
|
||||||
//Сумма расчета по чеку без НДС;
|
|
||||||
if (getPropValueByCode(props, "1105", "NUM") !== null) {
|
|
||||||
vats.push({
|
|
||||||
type: "none",
|
|
||||||
sum: null
|
|
||||||
});
|
|
||||||
}
|
|
||||||
//Сумма расчета по чеку с НДС по ставке 0%;
|
|
||||||
if (getPropValueByCode(props, "1104", "NUM") !== null) {
|
|
||||||
vats.push({
|
|
||||||
type: "vat0",
|
|
||||||
sum: 0
|
|
||||||
});
|
|
||||||
}
|
|
||||||
//Сумма НДС чека по ставке 10%;
|
|
||||||
if (getPropValueByCode(props, "1103", "NUM") !== null) {
|
|
||||||
vats.push({
|
|
||||||
type: "vat10",
|
|
||||||
sum: getPropValueByCode(props, "1103", "NUM")
|
|
||||||
});
|
|
||||||
}
|
|
||||||
//Сумма НДС чека по ставке 20%;
|
|
||||||
if (getPropValueByCode(props, "1102", "NUM") !== null) {
|
|
||||||
vats.push({
|
|
||||||
type: "vat20",
|
|
||||||
sum: getPropValueByCode(props, "1102", "NUM")
|
|
||||||
});
|
|
||||||
}
|
|
||||||
//Сумма НДС чека по расч. ставке 10/110;
|
|
||||||
if (getPropValueByCode(props, "1107", "NUM") !== null) {
|
|
||||||
vats.push({
|
|
||||||
type: "vat110",
|
|
||||||
sum: getPropValueByCode(props, "1107", "NUM")
|
|
||||||
});
|
|
||||||
}
|
|
||||||
//Сумма НДС чека по расч. ставке 20/120
|
|
||||||
if (getPropValueByCode(props, "1106", "NUM") !== null) {
|
|
||||||
vats.push({
|
|
||||||
type: "vat120",
|
|
||||||
sum: getPropValueByCode(props, "1106", "NUM")
|
|
||||||
});
|
|
||||||
}
|
|
||||||
//Возвращаем результат
|
|
||||||
return vats;
|
|
||||||
};
|
|
||||||
|
|
||||||
//Обработчик "До" подключения к сервису
|
|
||||||
const beforeConnect = async prms => {
|
|
||||||
return {
|
|
||||||
options: {
|
|
||||||
headers: {
|
|
||||||
"Content-type": "application/json; charset=utf-8"
|
|
||||||
},
|
|
||||||
body: JSON.stringify({ login: prms.service.sSrvUser, pass: prms.service.sSrvPass }),
|
|
||||||
simple: false
|
|
||||||
}
|
|
||||||
};
|
|
||||||
};
|
|
||||||
|
|
||||||
//Обработчик "После" подключения к сервису
|
|
||||||
const afterConnect = async prms => {
|
|
||||||
let resp = null;
|
|
||||||
if (prms.queue.blResp) {
|
|
||||||
try {
|
|
||||||
resp = JSON.parse(prms.queue.blResp.toString());
|
|
||||||
} catch (e) {
|
|
||||||
throw new Error(`Неожиданный ответ сервера АТОЛ-Онлайн. Ошибка интерпретации: ${e.message}`);
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
throw new Error(`Сервер АТОЛ-Онлайн не вернул ответ`);
|
|
||||||
}
|
|
||||||
if (resp.error === null) {
|
|
||||||
return {
|
|
||||||
blResp: new Buffer(resp.token),
|
|
||||||
sCtx: resp.token,
|
|
||||||
dCtxExp: addHours(new Date(), 23)
|
|
||||||
};
|
|
||||||
} else {
|
|
||||||
throw new Error(`Сервер АТОЛ-Онлайн вернул ошибку: ${resp.error.text}`);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
//Обработчик "До" отправки запроса на регистрацию чека (приход, расход, возврат) серверу "АТОЛ-Онлайн"
|
|
||||||
const beforeRegBillSIR = async prms => {
|
|
||||||
try {
|
|
||||||
//Токен доступа
|
|
||||||
let sToken = null;
|
|
||||||
if (prms.service.sCtx) {
|
|
||||||
sToken = prms.service.sCtx;
|
|
||||||
}
|
|
||||||
//Если не достали из контекста токен доступа - значит нет аутентификации на сервере
|
|
||||||
if (!sToken) return { bUnAuth: true };
|
|
||||||
//Разберем XML-данные фискального документа
|
|
||||||
let parseRes = null;
|
|
||||||
if (prms.queue.blMsg) {
|
|
||||||
try {
|
|
||||||
parseRes = await parseXML(prms.queue.blMsg.toString());
|
|
||||||
} catch (e) {
|
|
||||||
throw new Error("Ошибка рабора XML");
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
throw new Error("В теле сообщения отсутствуют данные фискального документа");
|
|
||||||
}
|
|
||||||
//Сохраним короткие ссылки на документ и его свойства
|
|
||||||
const doc = parseRes.FISCDOC;
|
|
||||||
const docProps = parseRes.FISCDOC.FISCDOC_PROPS.FISCDOC_PROP;
|
|
||||||
//Определим тип операции по значению "Наименование документа" (тэг 1000) и "Признак расчета" (тэг 1054)
|
|
||||||
if (!getPropValueByCode(docProps, "1000"))
|
|
||||||
throw new Error("В фискальном документе не указано значение 'Наименование документа' (тэг 1000)");
|
|
||||||
if (!getPropValueByCode(docProps, "1054"))
|
|
||||||
throw new Error("В фискальном документе не указано значение 'Признак расчёта' (тэг 1054)");
|
|
||||||
const sOperation = mapDictionary(
|
|
||||||
paymensOperation,
|
|
||||||
`${getPropValueByCode(docProps, "1000")}_${getPropValueByCode(docProps, "1054")}`
|
|
||||||
);
|
|
||||||
//Собираем тело запроса в JSON из XML-данных документа
|
|
||||||
let reqBody = {};
|
|
||||||
if (getPropValueByCode(docProps, "1000") === SDOCTYPE_TAG100_CHECK) {
|
|
||||||
//Собираем чек
|
|
||||||
reqBody = {
|
|
||||||
timestamp: doc.SDDOC_DATE,
|
|
||||||
external_id: doc.NRN,
|
|
||||||
receipt: {
|
|
||||||
client: {
|
|
||||||
email: parseClientContacts(getPropValueByCode(docProps, "1008")).sMail,
|
|
||||||
phone: parseClientContacts(getPropValueByCode(docProps, "1008")).sPhone
|
|
||||||
},
|
|
||||||
company: {
|
|
||||||
email: getPropValueByCode(docProps, "1117"),
|
|
||||||
sno: getPropValueByCode(docProps, "1055"),
|
|
||||||
inn: getPropValueByCode(docProps, "1018"),
|
|
||||||
payment_address: getPropValueByCode(docProps, "1187")
|
|
||||||
},
|
|
||||||
items: [
|
|
||||||
{
|
|
||||||
name: getPropValueByCode(docProps, "1030"),
|
|
||||||
price: getPropValueByCode(docProps, "1079", "NUM"),
|
|
||||||
quantity: getPropValueByCode(docProps, "1023", "NUM"),
|
|
||||||
sum: getPropValueByCode(docProps, "1043", "NUM"),
|
|
||||||
measurement_unit: getPropValueByCode(docProps, "1197"),
|
|
||||||
payment_method: mapDictionary(paymentMethod, getPropValueByCode(docProps, "1214")),
|
|
||||||
payment_object: mapDictionary(paymentObject, getPropValueByCode(docProps, "1212")),
|
|
||||||
vat: {
|
|
||||||
type: mapDictionary(receiptItemVat, getPropValueByCode(docProps, "1199", "NUM")),
|
|
||||||
sum: getPropValueByCode(docProps, "1200", "NUM")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
],
|
|
||||||
total: getPropValueByCode(docProps, "1020", "NUM")
|
|
||||||
}
|
|
||||||
};
|
|
||||||
//Добавим общие платежи
|
|
||||||
let payments = getPayments(docProps);
|
|
||||||
if (payments.length > 0) reqBody.receipt.payments = payments;
|
|
||||||
//Добавим общие налоги
|
|
||||||
let vats = getVats(docProps);
|
|
||||||
if (vats.length > 0) reqBody.receipt.vats = vats;
|
|
||||||
} else {
|
|
||||||
//Собираем чек коррекции
|
|
||||||
reqBody = {
|
|
||||||
timestamp: doc.SDDOC_DATE,
|
|
||||||
external_id: doc.NRN,
|
|
||||||
correction: {
|
|
||||||
company: {
|
|
||||||
sno: getPropValueByCode(docProps, "1055"),
|
|
||||||
inn: getPropValueByCode(docProps, "1018"),
|
|
||||||
payment_address: getPropValueByCode(docProps, "1187")
|
|
||||||
},
|
|
||||||
correction_info: {
|
|
||||||
type: mapDictionary(correctionInfoType, getPropValueByCode(docProps, "1173")),
|
|
||||||
base_date: getPropValueByCode(docProps, "1178"),
|
|
||||||
base_number: getPropValueByCode(docProps, "1179"),
|
|
||||||
base_name: getPropValueByCode(docProps, "1177")
|
|
||||||
},
|
|
||||||
payments: getPayments(docProps),
|
|
||||||
vats: getVats(docProps)
|
|
||||||
}
|
|
||||||
};
|
|
||||||
}
|
|
||||||
//Собираем общий результат работы
|
|
||||||
let res = {
|
|
||||||
options: {
|
|
||||||
url: buildURL({ sSrvRoot: prms.service.sSrvRoot, sFnURL: prms.function.sFnURL })
|
|
||||||
.replace("<group_code>", SGROUP_CODE)
|
|
||||||
.replace("<operation>", sOperation),
|
|
||||||
headers: {
|
|
||||||
"Content-type": "application/json; charset=utf-8",
|
|
||||||
Token: sToken
|
|
||||||
},
|
|
||||||
simple: false
|
|
||||||
},
|
|
||||||
blMsg: new Buffer(JSON.stringify(reqBody))
|
|
||||||
};
|
|
||||||
//Возврат резульатата
|
|
||||||
return res;
|
|
||||||
} catch (e) {
|
|
||||||
throw Error(e);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
//Обработчик "После" отправки запроса на регистрацию чека (приход, расход, возврат) серверу "АТОЛ-Онлайн"
|
|
||||||
const afterRegBillSIR = async prms => {
|
|
||||||
//Буфер для данных ответа сервера
|
|
||||||
let resp = null;
|
|
||||||
//Если есть данные от сервера АТОЛ
|
|
||||||
if (prms.queue.blResp) {
|
|
||||||
//Пытаемся их разбирать
|
|
||||||
try {
|
|
||||||
resp = JSON.parse(prms.queue.blResp.toString());
|
|
||||||
} catch (e) {
|
|
||||||
//Пришел не JSON
|
|
||||||
throw new Error(`Неожиданный ответ сервера АТОЛ-Онлайн. Ошибка интерпретации: ${e.message}`);
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
//Данных от сервера нет
|
|
||||||
throw new Error(`Сервер АТОЛ-Онлайн не вернул ответ`);
|
|
||||||
}
|
|
||||||
//Данные есть и нам удалось их разобрать, проверяем на наличие ошибок
|
|
||||||
if (resp.error === null) {
|
|
||||||
//Ошибок нет - забираем идентификатор документа в системе АТОЛ и кладём в тело ответа - он это то что нам нужно
|
|
||||||
return {
|
|
||||||
blResp: new Buffer(resp.uuid)
|
|
||||||
};
|
|
||||||
} else {
|
|
||||||
//Есть ошибки, посмотрим что это, может быть аутентификация (кончился токен)
|
|
||||||
if (resp.error.code === 10 || resp.error.code === 11) {
|
|
||||||
//да, это была она - сигнализируем серверу приложений - надо переподключаться
|
|
||||||
return { bUnAuth: true };
|
|
||||||
} else {
|
|
||||||
//прочие ошибки - фиксируем в журнале
|
|
||||||
throw new Error(`Сервер АТОЛ-Онлайн вернул ошибку: ${resp.error.text}`);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
//Обработчик "До" отправки запроса на получение информации о чеке серверу "АТОЛ-Онлайн"
|
|
||||||
const beforeGetBillInfo = async prms => {
|
|
||||||
//Токен доступа
|
|
||||||
let sToken = null;
|
|
||||||
if (prms.service.sCtx) {
|
|
||||||
sToken = prms.service.sCtx;
|
|
||||||
}
|
|
||||||
//Если не достали из контекста токен доступа - значит нет аутентификации на сервере
|
|
||||||
if (!sToken) return { bUnAuth: true };
|
|
||||||
//Забираем идентификатор документа из тела сообщения
|
|
||||||
let sUUID = null;
|
|
||||||
if (prms.queue.blMsg) sUUID = prms.queue.blMsg.toString();
|
|
||||||
if (!sUUID) throw new Error("В теле сообщения не указан идентификатор документа в АТОЛ-Онлайн");
|
|
||||||
//Собираем общий результат работы
|
|
||||||
let res = {
|
|
||||||
options: {
|
|
||||||
url: buildURL({ sSrvRoot: prms.service.sSrvRoot, sFnURL: prms.function.sFnURL })
|
|
||||||
.replace("<group_code>", SGROUP_CODE)
|
|
||||||
.replace("<uuid>", sUUID),
|
|
||||||
headers: {
|
|
||||||
"Content-type": "application/json; charset=utf-8",
|
|
||||||
Token: sToken
|
|
||||||
},
|
|
||||||
simple: false
|
|
||||||
}
|
|
||||||
};
|
|
||||||
//Возврат резульатата
|
|
||||||
return res;
|
|
||||||
};
|
|
||||||
|
|
||||||
//Обработчик "После" отправки запроса на получение информации о чеке серверу "АТОЛ-Онлайн"
|
|
||||||
const afterGetBillInfo = async prms => {
|
|
||||||
//Буфер для результата работы обработчика
|
|
||||||
let res = null;
|
|
||||||
//Буфер для данных ответа сервера
|
|
||||||
let resp = null;
|
|
||||||
//Если есть данные от сервера АТОЛ
|
|
||||||
if (prms.queue.blResp) {
|
|
||||||
//Пытаемся их разбирать
|
|
||||||
try {
|
|
||||||
resp = JSON.parse(prms.queue.blResp.toString());
|
|
||||||
} catch (e) {
|
|
||||||
//Пришел не JSON
|
|
||||||
throw new Error(`Неожиданный ответ сервера АТОЛ-Онлайн. Ошибка интерпретации: ${e.message}`);
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
//Данных от сервера нет
|
|
||||||
throw new Error(`Сервер АТОЛ-Онлайн не вернул ответ`);
|
|
||||||
}
|
|
||||||
//Данные есть и нам удалось их разобрать - проверим, что нет ошибок аутентификации
|
|
||||||
//Есть ошибки, посмотрим что это, может быть аутентификация (кончился токен)
|
|
||||||
if (resp.error !== null && (resp.error.code === 10 || resp.error.code === 11)) {
|
|
||||||
//да, это была она - сигнализируем серверу приложений - надо переподключаться и дальше не работаем
|
|
||||||
return { bUnAuth: true };
|
|
||||||
}
|
|
||||||
//Ошибок атуентификации нет - проверяем состояние документа
|
|
||||||
if (resp.status) {
|
|
||||||
//Проверям, может быть документ зарегистрирован
|
|
||||||
if (resp.status === SSTATUS_DONE) {
|
|
||||||
//Документ обработан, проверим наличие данных фискализации
|
|
||||||
if (resp.payload) {
|
|
||||||
//Ошибок нет - забираем данные фискализации и кладём в тело ответа - это то что нам нужно
|
|
||||||
res = {
|
|
||||||
//Статус обработки документа
|
|
||||||
STATUS: resp.status,
|
|
||||||
//Дата и время документа внешней системы
|
|
||||||
TIMESTAMP: resp.timestamp,
|
|
||||||
//Дата и время документа из ФН
|
|
||||||
TAG1012: resp.payload.receipt_datetime,
|
|
||||||
//Номер смены
|
|
||||||
TAG1038: resp.payload.shift_number,
|
|
||||||
//Фискальный номер документа
|
|
||||||
TAG1040: resp.payload.fiscal_document_number,
|
|
||||||
//Номер ФН
|
|
||||||
TAG1041: resp.payload.fn_number,
|
|
||||||
//Номер чека в смене
|
|
||||||
TAG1042: resp.payload.fiscal_receipt_number,
|
|
||||||
//Фискальный признак документа
|
|
||||||
TAG1077: resp.payload.fiscal_document_attribute
|
|
||||||
};
|
|
||||||
} else {
|
|
||||||
//В ответе сервера нет ни данных фискализации, при этом документ отработан - это неожиданный ответ
|
|
||||||
throw new Error(
|
|
||||||
`Неожиданный ответ сервера АТОЛ-Онлайн. Ошибка интерпретации: документ в статусе "Готов" но в ответе сервера нет данных фискализации`
|
|
||||||
);
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
//Документ не зарегистрирован, может быть ещё обрабатывается
|
|
||||||
if (resp.status === SSTATUS_WAIT) {
|
|
||||||
//Скажем и об этом
|
|
||||||
res = {
|
|
||||||
//Статус обработки документа
|
|
||||||
STATUS: resp.status
|
|
||||||
};
|
|
||||||
} else {
|
|
||||||
//Документ не готов и не обрабатывается - очевидно ошибка при регистрации
|
|
||||||
if (resp.status === SSTATUS_FAIL) {
|
|
||||||
if (resp.error) {
|
|
||||||
res = {
|
|
||||||
//Статус обработки документа
|
|
||||||
STATUS: resp.status,
|
|
||||||
//Ошибка
|
|
||||||
ERROR: {
|
|
||||||
//Код ошибки
|
|
||||||
CODE: resp.error.code,
|
|
||||||
//Текст ошибки
|
|
||||||
TEXT: resp.error.text
|
|
||||||
}
|
|
||||||
};
|
|
||||||
} else {
|
|
||||||
//Статус - ошибка, но ошибки нет, это неожиданный ответ
|
|
||||||
throw new Error(
|
|
||||||
`Неожиданный ответ сервера АТОЛ-Онлайн. Ошибка интерпретации: документ в статусе "Ошибка" но в ответе сервера нет об ошибке`
|
|
||||||
);
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
//Других статусов быть не должно - это неожиданный ответ
|
|
||||||
throw new Error(
|
|
||||||
`Неожиданный ответ сервера АТОЛ-Онлайн. Ошибка интерпретации: неизвестный статус документа - ${
|
|
||||||
resp.status
|
|
||||||
}`
|
|
||||||
);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
//Нет данных о статусе документа - это неожиданный ответ
|
|
||||||
throw new Error(
|
|
||||||
`Неожиданный ответ сервера АТОЛ-Онлайн. Ошибка интерпретации: статус документа в ответе не определён`
|
|
||||||
);
|
|
||||||
}
|
|
||||||
//Вернём сформированный ответ
|
|
||||||
return {
|
|
||||||
blResp: new Buffer(js2xmlparser.parse("RESP", res))
|
|
||||||
};
|
|
||||||
};
|
|
||||||
|
|
||||||
//Обработчик "До" отправки запроса на получение чека серверу "ОФД"
|
|
||||||
const beforeGetOFDBillDoc = async prms => {
|
|
||||||
//Разберем данные для получения чека
|
|
||||||
let sDocPath = null;
|
|
||||||
if (prms.queue.blMsg) {
|
|
||||||
sDocPath = prms.queue.blMsg.toString();
|
|
||||||
} else {
|
|
||||||
throw new Error("В теле сообщения отсутствуют данные для получения чека фискального документа");
|
|
||||||
}
|
|
||||||
//Собираем общий результат работы
|
|
||||||
let res = {
|
|
||||||
options: {
|
|
||||||
url: buildURL({ sSrvRoot: prms.service.sSrvRoot, sFnURL: prms.function.sFnURL }).replace(
|
|
||||||
"<doc_path>",
|
|
||||||
sDocPath
|
|
||||||
),
|
|
||||||
simple: true
|
|
||||||
}
|
|
||||||
};
|
|
||||||
//Возврат резульатата
|
|
||||||
return res;
|
|
||||||
};
|
|
||||||
|
|
||||||
//Обработчик "После" отправки запроса на получение чека серверу "ОФД"
|
|
||||||
const afterGetOFDBillDoc = async prms => {};
|
|
||||||
|
|
||||||
//-----------------
|
|
||||||
// Интерфейс модуля
|
|
||||||
//-----------------
|
|
||||||
|
|
||||||
exports.beforeConnect = beforeConnect;
|
|
||||||
exports.afterConnect = afterConnect;
|
|
||||||
exports.beforeRegBillSIR = beforeRegBillSIR;
|
|
||||||
exports.afterRegBillSIR = afterRegBillSIR;
|
|
||||||
exports.beforeGetBillInfo = beforeGetBillInfo;
|
|
||||||
exports.afterGetBillInfo = afterGetBillInfo;
|
|
||||||
exports.beforeGetOFDBillDoc = beforeGetOFDBillDoc;
|
|
||||||
exports.afterGetOFDBillDoc = afterGetOFDBillDoc;
|
|
||||||
@ -1,46 +0,0 @@
|
|||||||
/*
|
|
||||||
Сервис интеграции ПП Парус 8 с WEB API
|
|
||||||
Дополнительный модуль: тестовый модуль для ПМИ
|
|
||||||
*/
|
|
||||||
|
|
||||||
//------------------------------
|
|
||||||
// Подключение внешних библиотек
|
|
||||||
//------------------------------
|
|
||||||
|
|
||||||
const js2xmlparser = require("js2xmlparser"); //Конвертация JSON в XML
|
|
||||||
|
|
||||||
//------------
|
|
||||||
// Тело модуля
|
|
||||||
//------------
|
|
||||||
|
|
||||||
//Формирование запроса к тестовому стенду на получение сведений о контрагенте
|
|
||||||
const beforeAgentInfo = async prms => {
|
|
||||||
//Считаем параметры запроса из тела сообщения
|
|
||||||
let sPayLoad = prms.queue.blMsg.toString();
|
|
||||||
//Вернем конвертированное в XML-сообщение (потребуется для использования при разборе ответа) и параметры для соединения
|
|
||||||
return {
|
|
||||||
options: {
|
|
||||||
url: `${prms.service.sSrvRoot}/${prms.function.sFnURL}?CPRMS=${sPayLoad}`
|
|
||||||
},
|
|
||||||
blMsg: new Buffer(js2xmlparser.parse("MSG", JSON.parse(sPayLoad)))
|
|
||||||
};
|
|
||||||
};
|
|
||||||
|
|
||||||
//Обработка ответа тестового стенда на запрос сведений о контрагенте
|
|
||||||
const afterAgentInfo = async prms => {
|
|
||||||
let r = JSON.parse(prms.queue.blResp.toString());
|
|
||||||
if (r.STATE === 0) {
|
|
||||||
throw Error(r.MSG);
|
|
||||||
} else {
|
|
||||||
return {
|
|
||||||
blResp: new Buffer(js2xmlparser.parse("AGENT", r))
|
|
||||||
};
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
//-----------------
|
|
||||||
// Интерфейс модуля
|
|
||||||
//-----------------
|
|
||||||
|
|
||||||
exports.beforeAgentInfo = beforeAgentInfo;
|
|
||||||
exports.afterAgentInfo = afterAgentInfo;
|
|
||||||
Loading…
x
Reference in New Issue
Block a user