yumoqing/supplychain
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: check product_org_auth exists before insert in save_agreement_discount

Browse Source
This commit is contained in:
yumoqing 2026-07-12 23:19:42 +08:00
parent 41ccfcb301
commit 5a00a42f05
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
wwwroot/api/save_agreement_discount.dspy
View File

@ -34,7 +34,7 @@ async with DBPools().sqlorContext(dbname) as sor:
'productid': productid, 'prodtypeid': prodtypeid,
'discount': new_discount, 'created_at': now,
})
# Sync product_org_auth
# Sync product_org_auth (upsert — skip if exists)
async with DBPools().sqlorContext(dbname) as s2:
ag = await s2.sqlExe(
"SELECT sub_reseller_id FROM distribution_agreements WHERE id = ${aid}$",
@ -42,10 +42,15 @@ async with DBPools().sqlorContext(dbname) as sor:
)
if ag:
async with DBPools().sqlorContext('sage') as s3:
await s3.C('product_org_auth', {
'id': getID(), 'product_id': productid,
'org_id': ag[0].sub_reseller_id,
'auth_source': 'distribution_agreement', 'auth_source_id': new_id,
})
existing = await s3.sqlExe(
"SELECT id FROM product_org_auth WHERE product_id = ${pid}$ AND org_id = ${oid}$",
{'pid': productid, 'oid': ag[0].sub_reseller_id}
)
if not existing:
await s3.C('product_org_auth', {
'id': getID(), 'product_id': productid,
'org_id': ag[0].sub_reseller_id,
'auth_source': 'distribution_agreement', 'auth_source_id': new_id,
})
return {'status': 'ok'}