diff --git a/pricing/init.py b/pricing/init.py index 65f277d..4f475c2 100644 --- a/pricing/init.py +++ b/pricing/init.py @@ -1,3 +1,4 @@ +from sqlor.dbpools import DBPools from pricing.pricing import ( PricingProgram, test_pricing, @@ -15,3 +16,7 @@ def load_pricing(): env.load_pricing_data = PricingProgram.load_pricing_data env.get_pricing_program = PricingProgram.get_pricing_program env.test_pricing = test_pricing + dbpools = DBPools() + dbname = env.get_module_dbname('pricing') + ename = f'{dbname}.pricing_program_timing.u.after' + dbpools.bind(ename, PricingProgram.reload_pp_data) diff --git a/pricing/pricing.py b/pricing/pricing.py index 825090f..de2081c 100644 --- a/pricing/pricing.py +++ b/pricing/pricing.py @@ -304,6 +304,15 @@ class PricingProgram: exception(e) raise Exception(e) + @staticmethod + async def reload_pp_data(ppt): + debug(f'--EventHandle {ppt}') + dat = curDateString() + k = f'{ppt.ppid}.{dat}' + if PricingProgram.pricing_data.get(k): + del PricingProgram.pricing_data[k] + await PricingProgram.get_ppid_pricing(ppt.ppid) + @staticmethod async def get_ppid_pricing(ppid): dat = curDateString()