module.exports = Self => { Self.remoteMethod('upsertFixedPrice', { description: 'Inserts or updates a fixed price for an item', accessType: 'WRITE', accepts: [ { arg: 'ctx', type: 'object', http: {source: 'context'} }, { arg: 'id', type: 'number', description: 'The fixed price id' }, { arg: 'itemFk', type: 'number' }, { arg: 'warehouseFk', type: 'number' }, { arg: 'started', type: 'date' }, { arg: 'ended', type: 'date' }, { arg: 'rate2', type: 'number' }, { arg: 'rate3', type: 'number' }, { arg: 'minPrice', type: 'number' }, { arg: 'hasMinPrice', type: 'any' } ], returns: { type: 'object', root: true }, http: { path: `/upsertFixedPrice`, verb: 'PATCH' } }); Self.upsertFixedPrice = async(ctx, options) => { const models = Self.app.models; const args = ctx.args; let tx; const myOptions = {}; if (typeof options == 'object') Object.assign(myOptions, options); if (!myOptions.transaction) { tx = await Self.beginTransaction({}); myOptions.transaction = tx; } try { delete args.ctx; // removed unwanted data const fixedPrice = await models.FixedPrice.upsert(args, myOptions); const targetItem = await models.Item.findById(args.itemFk, null, myOptions); await targetItem.updateAttributes({ minPrice: args.minPrice, hasMinPrice: args.minPrice ? true : false }, myOptions); const itemFields = [ 'minPrice', 'hasMinPrice', 'name', 'subName', 'tag5', 'value5', 'tag6', 'value6', 'tag7', 'value7', 'tag8', 'value8', 'tag9', 'value9', 'tag10', 'value10' ]; const fieldsCopy = [].concat(itemFields); const filter = { include: { relation: 'item', scope: { fields: fieldsCopy } } }; const result = await models.FixedPrice.findById(fixedPrice.id, filter, myOptions); const item = result.item(); for (let key of itemFields) result[key] = item[key]; if (tx) await tx.commit(); return result; } catch (e) { if (tx) await tx.rollback(); throw e; } }; };