diff --git a/unipay/init.py b/unipay/init.py index 2330a8a..d10f142 100644 --- a/unipay/init.py +++ b/unipay/init.py @@ -161,14 +161,16 @@ async def alipay_notify(request): e = Exception(f'{provider} cannot pay') exception(f'{e}') return + data = None try: data = await PROVIDERS[provider].handle_notify(request) except Exception as e: e = Exception(f'{provider} cannot pay') exception(f'{e}') return + debug(f'{data=}') try: - await unipay_accounting(request, data) + await unipay_accounting(request, data.data) except Exception as e: exception(f'{e}') return {"code":"SUCCESS", "message":"OK"} diff --git a/unipay/paylog.py b/unipay/paylog.py index c10089e..1a2119c 100644 --- a/unipay/paylog.py +++ b/unipay/paylog.py @@ -73,8 +73,8 @@ class PaymentLog: return None async def unipay_accounting(request, data): - logid = data.params.out_trade_no - trade_id = data.params.trade_no + logid = data.out_trade_no + trade_id = data.trade_no env = request._run_ns db = DBPools() dbname = env.get_module_dbname('unipay') diff --git a/unipay/providers/wechat.py b/unipay/providers/wechat.py index b218a65..a3f6dd0 100644 --- a/unipay/providers/wechat.py +++ b/unipay/providers/wechat.py @@ -255,7 +255,7 @@ class WechatGateway(Gateway): # 返回标准结构 ret = { "provider": "wechat", - "params": decrypted + "data": decrypted } return DictObject(**ret)