This commit is contained in:
yumoqing 2025-12-17 12:06:59 +08:00
parent a13ef0ef05
commit caeba6f59f

View File

@ -37,7 +37,11 @@ class AlipayGateway(Gateway):
self._alipay_public_key = serialization.load_pem_public_key(
alipay_public_key_pem
)
self.session = None
def setup_session(self):
if self.session:
return
self.session = aiohttp.ClientSession(timeout=aiohttp.ClientTimeout(total=20))
# ==============================================================================
@ -85,6 +89,7 @@ class AlipayGateway(Gateway):
"""
返回一个可以在 H5 里直接重定向的支付宝支付 URL
"""
self.setup_session()
debug(f'{payload=}')
biz_content = {
"out_trade_no": payload["out_trade_no"],
@ -118,6 +123,7 @@ class AlipayGateway(Gateway):
# ==============================================================================
async def query(self, out_trade_no: str) -> Dict[str, Any]:
self.setup_session()
biz_content = {
"out_trade_no": out_trade_no,
}
@ -150,6 +156,7 @@ class AlipayGateway(Gateway):
out_request_no 必须全局唯一一个退款请求一个编号
"""
self.setup_session()
biz_content = {
"out_trade_no": out_trade_no,
"refund_amount": refund_amount,
@ -181,6 +188,7 @@ class AlipayGateway(Gateway):
"""
支付宝异步通知验签
"""
self.setup_session()
form = await request.post()
params = dict(form)