diff --git a/app/pipeline_accounting_worker.py b/app/pipeline_accounting_worker.py index c98c893..3414200 100644 --- a/app/pipeline_accounting_worker.py +++ b/app/pipeline_accounting_worker.py @@ -39,7 +39,8 @@ def init_worker(): return 'pipeline' env.get_module_dbname = get_module_dbname - # 记账链路必需模块(顺序同主应用:pricing 先于资源/产品模块) + # 记账链路必需模块(顺序同主应用:appbase/pricing 先于资源/产品模块) + from appbase.init import load_appbase from pricing.init import load_pricing from accounting.init import load_accounting from discount.init import load_discount @@ -47,6 +48,8 @@ def init_worker(): from product_management import load_product_management from pipeline_llm.init import load_llm + load_appbase() # get_business_date(product_accounting_generic 依赖; + # 2026-09-05 实测缺失致出账 'NoneType' not callable) load_pricing() # buffered_charging(定价引擎) load_accounting() # consume_accounting / 余额 / 业务日期 load_discount() # get_min_product_discount(客户折扣→售价)