From 7e247f308e0dad27aad689e7e0d0b89d573a10ec Mon Sep 17 00:00:00 2001 From: yumoqing Date: Sat, 12 Apr 2025 19:48:51 +0800 Subject: [PATCH] bugfix --- platformbiz/getdbname.py | 8 ++++++++ platformbiz/pb_acc.py | 4 ++-- platformbiz/recharge.py | 3 ++- 3 files changed, 12 insertions(+), 3 deletions(-) create mode 100644 platformbiz/getdbname.py diff --git a/platformbiz/getdbname.py b/platformbiz/getdbname.py new file mode 100644 index 0000000..bde7030 --- /dev/null +++ b/platformbiz/getdbname.py @@ -0,0 +1,8 @@ +ifrom ahserver.serverenv import get_serverenv + +def get_dbname(): + f = get_serverenv('get_module_dbname') + if f is None: + raise Exception('get_module_dbname() not found') + return f('platformbiz') + diff --git a/platformbiz/pb_acc.py b/platformbiz/pb_acc.py index 0928dc9..32e6653 100644 --- a/platformbiz/pb_acc.py +++ b/platformbiz/pb_acc.py @@ -6,15 +6,15 @@ from sqlor.dbpools import DBPools from ahserver.serverenv import get_serverenv from accounting.accounting_config import Accounting from accounting.bizaccount import BizAccounting - from accounting.bill import write_bill +from getdbname import get_dbname async def get_owner_orgid(sor, orgid): return '0' async def get_balance(orgid): db = DBPools() - dbname = await rfexe('get_module_dbname', 'platformbiz') + dbname = get_dbname() async with db.sqlorContext(dbname) as sor: f = get_serverenv('getCustomerBalance') if f: diff --git a/platformbiz/recharge.py b/platformbiz/recharge.py index 989bc65..b0ece74 100644 --- a/platformbiz/recharge.py +++ b/platformbiz/recharge.py @@ -3,6 +3,7 @@ from appPublic.registerfunction import rfexe from appPublic.log import exception, debug from sqlor.dbpools import DBPools from pf_pay.ali_pay import Zhifubao_Pay +from getdbname import get_dbname from platformbiz.biz_order import add_recharge_log, add_recharge_order class Recharge: @@ -23,7 +24,7 @@ class Recharge: async def start_recharge_action(self, action): db = DBPools() - dbname = await rfexe('get_module_dbname', 'platformbiz') + dbname = get_dbname() async with db.sqlorContext(dbname) as sor: order = await add_recharge_order(sor, self.customerid, self.userid,