diff --git a/wwwroot/oca.dspy b/wwwroot/oca.dspy index da3c071..9ccaca7 100644 --- a/wwwroot/oca.dspy +++ b/wwwroot/oca.dspy @@ -1,6 +1,10 @@ iorgid = params_kw.orgid db = DBPools() async with db.sqlorContext(dbname) as sor: + recs = await sor.R('organization', {'id': orgid}) + if len(recs) == 0: + return f"error: {orgid=} not found" + await openCustomerAccounts(sor, '0', orgid) return f'{orgid} customer accounts opened' return f'{db.e_except=}'