From 5a659774b5d70f74a76409f76b7c165a026a3114 Mon Sep 17 00:00:00 2001 From: D065023 Date: Thu, 12 Dec 2019 09:53:46 +0100 Subject: [PATCH] use msg as transaction box --- packages/bookshop/srv/admin-service.js | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) diff --git a/packages/bookshop/srv/admin-service.js b/packages/bookshop/srv/admin-service.js index b37f9911..c390a185 100644 --- a/packages/bookshop/srv/admin-service.js +++ b/packages/bookshop/srv/admin-service.js @@ -38,24 +38,20 @@ bupaSrv.on('sap/messaging/ccf/BO/BusinessPartner/Changed', async msg => { console.log('>> Message:', msg.data) const BusinessPartner = msg.data.KEY[0].BUSINESSPARTNER - const tx = cds.transaction() + const tx = cds.transaction(msg) const selectQl = SELECT.from(ShippingAddresses).where({ BusinessPartner }) const ownAddresses = await tx.run(selectQl) - // await tx.commit() - console.log('own:', ownAddresses) if (ownAddresses && ownAddresses.length > 0) { console.log('found') - const txExt = bupaSrv.transaction() + const txExt = bupaSrv.transaction(msg) try { const remoteAddresses = await txExt.run(selectQl) const qlsToUpdateDifferences = _qlsToUpdateDifferences(ownAddresses, remoteAddresses) if (qlsToUpdateDifferences.length) { - const tx2 = cds.transaction() await Promise.all(qlsToUpdateDifferences.map(ql => - tx2.run(ql) + tx.run(ql) )) - tx2.commit() } } catch (e) { console.error(e)