yumoqing/pricing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2026-05-16 16:13:18 +08:00
parent 0efc1be770
commit 19f03c82c3
2 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pricing/init.py
View File

@ -1,3 +1,4 @@
from sqlor.dbpools import DBPools
from pricing.pricing import ( from pricing.pricing import (
PricingProgram, PricingProgram,
test_pricing, test_pricing,
@ -15,3 +16,7 @@ def load_pricing():
env.load_pricing_data = PricingProgram.load_pricing_data env.load_pricing_data = PricingProgram.load_pricing_data
env.get_pricing_program = PricingProgram.get_pricing_program env.get_pricing_program = PricingProgram.get_pricing_program
env.test_pricing = test_pricing 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)

9
pricing/pricing.py
View File

@ -304,6 +304,15 @@ class PricingProgram:
exception(e) exception(e)
raise 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 @staticmethod
async def get_ppid_pricing(ppid): async def get_ppid_pricing(ppid):
dat = curDateString() dat = curDateString()