95 lines
3.7 KiB
JavaScript
95 lines
3.7 KiB
JavaScript
const UserError = require('vn-loopback/util/user-error');
|
|
|
|
module.exports = Self => {
|
|
Self.remoteMethod('createShipment', {
|
|
description: 'Create an expedition and return a base64Binary label from de MRW WebService',
|
|
accessType: 'WRITE',
|
|
accepts: [{
|
|
arg: 'expeditionFk',
|
|
type: 'number',
|
|
required: true
|
|
}],
|
|
returns: {
|
|
type: ['object'],
|
|
root: true
|
|
},
|
|
http: {
|
|
path: `/createShipment`,
|
|
verb: 'POST'
|
|
}
|
|
});
|
|
|
|
Self.createShipment = async expeditionFk => {
|
|
const models = Self.app.models;
|
|
const mrw = await Self.getConfig();
|
|
|
|
const today = Date.vnNew();
|
|
const [hours, minutes] = mrw?.expeditionDeadLine ? mrw.expeditionDeadLine.split(':').map(Number) : [0, 0];
|
|
|
|
const deadLine = Date.vnNew();
|
|
deadLine.setHours(hours, minutes, 0);
|
|
|
|
if (today > deadLine && (!mrw.notified || mrw.notified.setHours(0, 0, 0, 0) !== today.setHours(0, 0, 0, 0))) {
|
|
await models.NotificationQueue.create({notificationFk: 'mrw-deadline'});
|
|
await mrw.updateAttributes({notified: Date.vnNow()});
|
|
}
|
|
|
|
const query =
|
|
`SELECT
|
|
CASE co.code
|
|
WHEN 'ES' THEN a.postalCode
|
|
WHEN 'PT' THEN LEFT(a.postalCode, mc.portugalPostCodeTrim)
|
|
WHEN 'AD' THEN REPLACE(a.postalCode, 'AD', '00')
|
|
END postalCode,
|
|
a.city,
|
|
a.street,
|
|
co.code countryCode,
|
|
c.fi,
|
|
c.name clientName,
|
|
c.phone,
|
|
DATE_FORMAT(t.shipped, '%d/%m/%Y') created,
|
|
t.shipped,
|
|
CONCAT( e.ticketFk, LPAD(e.counter, mc.counterWidth, '0')) reference,
|
|
LPAD(IF(mw.serviceType IS NULL, ms.serviceType, mw.serviceType), mc.serviceTypeWidth,'0') serviceType,
|
|
IF(mw.weekdays, 'S', 'N') weekDays,
|
|
oa.description deliveryObservation
|
|
FROM expedition e
|
|
JOIN ticket t ON e.ticketFk = t.id
|
|
JOIN agencyMode am ON am.id = t.agencyModeFk
|
|
JOIN mrwService ms ON ms.agencyModeCodeFk = am.code
|
|
LEFT JOIN mrwServiceWeekday mw ON mw.agencyModeCodeFk = am.code
|
|
AND mw.weekDays & (1 << WEEKDAY(t.landed))
|
|
JOIN client c ON t.clientFk = c.id
|
|
JOIN address a ON t.addressFk = a.id
|
|
LEFT JOIN addressObservation oa ON oa.addressFk = a.id
|
|
LEFT JOIN observationType ot ON ot.id = oa.observationTypeFk
|
|
AND ot.code = 'delivery'
|
|
JOIN province p ON a.provinceFk = p.id
|
|
JOIN country co ON co.id = p.countryFk
|
|
JOIN mrwConfig mc
|
|
WHERE e.id = ?
|
|
LIMIT 1`;
|
|
|
|
const [expeditionData] = await Self.rawSql(query, [expeditionFk]);
|
|
|
|
if (!expeditionData)
|
|
throw new UserError(`This expedition is not a MRW shipment`);
|
|
|
|
if (expeditionData?.shipped.setHours(0, 0, 0, 0) < today.setHours(0, 0, 0, 0))
|
|
throw new UserError(`This ticket has a shipped date earlier than today`);
|
|
|
|
const shipmentResponse = await Self.sendXmlDoc(
|
|
__dirname + `/createShipment.ejs`,
|
|
{mrw, expeditionData},
|
|
'application/soap+xml'
|
|
);
|
|
const shipmentId = Self.getTextByTag(shipmentResponse, 'NumeroEnvio');
|
|
|
|
if (!shipmentId) throw new UserError(Self.getTextByTag(shipmentResponse, 'Mensaje'));
|
|
|
|
const file = await models.MrwConfig.getLabel(shipmentId);
|
|
|
|
return {shipmentId, file};
|
|
};
|
|
};
|