diff --git a/pricing/pricing.py b/pricing/pricing.py index 8236f5b..03ef86b 100644 --- a/pricing/pricing.py +++ b/pricing/pricing.py @@ -50,6 +50,13 @@ where enabled_date >= ${biz_date}$ return recs[0] return None +async def sor_get_program_items(sor, ppid): + sql = """select b.* from pricing_program_timing a, pricing_item b +where b.pptid = a.id + and a.ppid = ${ppid}$""" + recs = await sor.sqlExe(sql, {'ppid': ppid}) + return recs + async def get_pricing_specs_by_pptid(pptid): env = ServerEnv() dbname = env.get_module_dbname('pricing')