diff --git a/pricing/pricing.py b/pricing/pricing.py
index 7a42fbb..68a5228 100644
--- a/pricing/pricing.py
+++ b/pricing/pricing.py
@@ -306,12 +306,20 @@ class PricingProgram:
 
 	@staticmethod
 	async def reload_pp_data(ppt):
+		env = ServerEnv()
+		ppid = None
+		async with get_sqlor_context(env, 'pricing') as sor:
+			recs = await sor.R('pricing_program', {'id': ppt['id']})
+			if len(recs) == 0:
+				exception(f'{ppt["id"]} not found in pricing_program')
+				return
+			ppid = recs[0].ppid
 		debug(f'--EventHandle {ppt}')
 		dat = curDateString()
-		k = f'{ppt.ppid}.{dat}'
+		k = f'{ppid}.{dat}'
 		if PricingProgram.pricing_data.get(k):
 			del PricingProgram.pricing_data[k]
-		await PricingProgram.get_ppid_pricing(ppt.ppid)
+		await PricingProgram.get_ppid_pricing(ppid)
 
 	@staticmethod
 	async def get_ppid_pricing(ppid):