b.santos/cloud-cap-samples
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

use msg as transaction box

Browse Source
This commit is contained in:
D065023
2019-12-12 09:53:46 +01:00
parent 17d6dc8cf8
commit 5a659774b5
1 changed files with 3 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
packages/bookshop/srv/admin-service.js
View File

@@ -38,24 +38,20 @@ bupaSrv.on('sap/messaging/ccf/BO/BusinessPartner/Changed', async msg => {
console.log('>> Message:', msg.data) console.log('>> Message:', msg.data)
const BusinessPartner = msg.data.KEY[0].BUSINESSPARTNER const BusinessPartner = msg.data.KEY[0].BUSINESSPARTNER
const tx = cds.transaction() const tx = cds.transaction(msg)
const selectQl = SELECT.from(ShippingAddresses).where({ BusinessPartner }) const selectQl = SELECT.from(ShippingAddresses).where({ BusinessPartner })
const ownAddresses = await tx.run(selectQl) const ownAddresses = await tx.run(selectQl)
// await tx.commit()
console.log('own:', ownAddresses)
if (ownAddresses && ownAddresses.length > 0) { if (ownAddresses && ownAddresses.length > 0) {
console.log('found') console.log('found')
const txExt = bupaSrv.transaction() const txExt = bupaSrv.transaction(msg)
try { try {
const remoteAddresses = await txExt.run(selectQl) const remoteAddresses = await txExt.run(selectQl)
const qlsToUpdateDifferences = _qlsToUpdateDifferences(ownAddresses, remoteAddresses) const qlsToUpdateDifferences = _qlsToUpdateDifferences(ownAddresses, remoteAddresses)
if (qlsToUpdateDifferences.length) { if (qlsToUpdateDifferences.length) {
const tx2 = cds.transaction()
await Promise.all(qlsToUpdateDifferences.map(ql => await Promise.all(qlsToUpdateDifferences.map(ql =>
tx2.run(ql) tx.run(ql)
)) ))
tx2.commit()
} }
} catch (e) { } catch (e) {
console.error(e) console.error(e)