module.exports = Self => { Self.remoteMethodCtx('updateQuantity', { description: 'Changes the quantity of a sale', accessType: 'WRITE', accepts: [{ arg: 'id', type: 'number', required: true, description: 'sale ID', http: {source: 'path'} }, { arg: 'quantity', type: 'number', required: true, description: 'newQuantity' }], returns: { type: 'string', root: true }, http: { path: `/:id/updateQuantity`, verb: 'post' } }); Self.updateQuantity = async(ctx, id, newQuantity, options) => { const models = Self.app.models; const $t = ctx.req.__; // $translate const myOptions = {}; let tx; if (typeof options == 'object') Object.assign(myOptions, options); if (!myOptions.transaction) { tx = await Self.beginTransaction({}); myOptions.transaction = tx; } try { await models.Sale.canEdit(ctx, [id], myOptions); const filter = { include: { relation: 'ticket', scope: { include: { relation: 'client', scope: { include: { relation: 'salesPersonUser', scope: { fields: ['id', 'name'] } } } } } } }; const sale = await models.Sale.findById(id, filter, myOptions); const oldQuantity = sale.quantity; const result = await sale.updateAttributes({ quantity: newQuantity, originalQuantity: newQuantity }, myOptions); const salesPerson = sale.ticket().client().salesPersonUser(); if (salesPerson) { const url = await Self.app.models.Url.getUrl(); const change = $t('Changes in sales', { itemId: sale.itemFk, concept: sale.concept, oldQuantity: oldQuantity, newQuantity: newQuantity, itemUrl: `${url}item/${sale.itemFk}/summary` }); const message = $t('Changed sale quantity', { ticketId: sale.ticket().id, changes: change, ticketUrl: `${url}ticket/${sale.ticket().id}/sale`, }); await models.Chat.sendCheckingPresence(ctx, salesPerson.id, message, myOptions); } if (tx) await tx.commit(); return result; } catch (error) { if (tx) await tx.rollback(); throw error; } }; };