|
@@ -307,10 +307,12 @@ class InAppPurchaseView(View):
|
|
def app_store_server_notifications(request):
|
|
def app_store_server_notifications(request):
|
|
try:
|
|
try:
|
|
logger = logging.getLogger('apple_pay')
|
|
logger = logging.getLogger('apple_pay')
|
|
|
|
+ logger.info('App Store服务器通知请求类型:{}'.format(request.method))
|
|
logger.info('App Store服务器通知参数:{}'.format(request.POST))
|
|
logger.info('App Store服务器通知参数:{}'.format(request.POST))
|
|
|
|
+ logger.info('App Store服务器通知请求body:{}'.format(request.body))
|
|
if request.method == 'POST':
|
|
if request.method == 'POST':
|
|
payload = json.loads(request.body.decode('utf-8'))
|
|
payload = json.loads(request.body.decode('utf-8'))
|
|
- LOGGER.info('App Store服务器通知payload:{}'.format(payload))
|
|
|
|
|
|
+ logger.info('App Store服务器通知payload:{}'.format(payload))
|
|
# 获取 signedPayload
|
|
# 获取 signedPayload
|
|
signed_payload = payload.get('signedPayload')
|
|
signed_payload = payload.get('signedPayload')
|
|
if not signed_payload:
|
|
if not signed_payload:
|
|
@@ -336,7 +338,7 @@ class InAppPurchaseView(View):
|
|
root_certificates, enable_online_checks, environment, bundle_id, app_apple_id)
|
|
root_certificates, enable_online_checks, environment, bundle_id, app_apple_id)
|
|
decoded_payload = verifier.verify_and_decode_notification(signed_payload)
|
|
decoded_payload = verifier.verify_and_decode_notification(signed_payload)
|
|
|
|
|
|
- LOGGER.info(f"打印decoded_payload{decoded_payload}")
|
|
|
|
|
|
+ logger.info(f"App Store服务器通知解码后decoded_payload:{decoded_payload}")
|
|
|
|
|
|
if decoded_payload.notificationType == "DID_RENEW":
|
|
if decoded_payload.notificationType == "DID_RENEW":
|
|
# 处理订阅续费
|
|
# 处理订阅续费
|
|
@@ -345,6 +347,6 @@ class InAppPurchaseView(View):
|
|
return HttpResponse(status=200)
|
|
return HttpResponse(status=200)
|
|
|
|
|
|
except Exception as e:
|
|
except Exception as e:
|
|
- LOGGER.info('App Store服务器通知异常:{}'.
|
|
|
|
|
|
+ logger.info('App Store服务器通知异常:{}'.
|
|
format('error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e))))
|
|
format('error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e))))
|
|
return HttpResponse(status=500)
|
|
return HttpResponse(status=500)
|