From db43d5aca31cf9ff1ad1702f7f8d7f566e73ab11 Mon Sep 17 00:00:00 2001 From: yumoqing Date: Tue, 14 Jul 2026 15:00:37 +0800 Subject: [PATCH] bugfix --- bin/backend_accounting.py | 25 ++++--------------------- 1 file changed, 4 insertions(+), 21 deletions(-) diff --git a/bin/backend_accounting.py b/bin/backend_accounting.py index 261243f3..21aa6fa3 100644 --- a/bin/backend_accounting.py +++ b/bin/backend_accounting.py @@ -26,31 +26,14 @@ from discount.init import load_discount from dapi.init import load_dapi from product_management import get_manager -# 初始化配置 -p = ProgramPath() -config = getConfig(NS={'workdir': os.getcwd(), 'ProgramPath': p}) -db = DBPools(config.databases) -# 生产环境 get_business_date 内直接 db=DBPools() 创建空实例 → sqlorFactory(None) -# 替换为使用已初始化的 db -import appbase.businessdate as _bd -_orig_gbd = _bd.get_business_date -async def _patched_get_business_date(sor=None): - async def _f(sor): - sql = "select * from params where params_name = 'business_date'" - recs = await sor.sqlExe(sql, {}) - if len(recs) > 0: - return recs[0]['params_value'] - raise Exception('BusinessDateParamsError') - if sor: - return await _f(sor) - async with db.sqlorContext(get_module_dbname('appbase')) as sor: - return await _f(sor) -_bd.get_business_date = _patched_get_business_date - def get_module_dbname(m): return 'sage' def main(): + # 初始化配置 + p = ProgramPath() + config = getConfig(NS={'workdir': os.getcwd(), 'ProgramPath': p}) + db = DBPools(config.databases) logger = MyLogger('backend_accounting', levelname='info', logfile=os.path.join(os.getcwd(), 'logs', 'backend_accounting.log')) info(f'Backend accounting process started (PID: {os.getpid()})')