python調(diào)用支付寶支付接口流程

ALIPAY_PUBLIC = os.path.join(BASE_DIR,'alipay_use','alipay','alipay_keys','alipay_public.txt')
APP_PUBLIC = os.path.join(BASE_DIR,'alipay_use','alipay','alipay_keys','app_public.txt')
APP_PRIVATE = os.path.join(BASE_DIR,'alipay_use','alipay','alipay_keys','app_private.txt')

# _*_ coding=utf-8 _*_
from datetime import datetime
from Crypto.PublicKey import RSA
from Crypto.Signature import PKCS1_v1_5
from Crypto.Hash import SHA256
from urllib.parse import quote_plus
from base64 import decodebytes, encodebytes
import json
class AliPay(object):
  """
  支付寶支付接口(PC端支付接口)
  """
  def __init__(self, appid, app_notify_url, app_private_key_path,
         alipay_public_key_path, return_url, debug=False):
    self.appid = appid
    self.app_notify_url = app_notify_url
    self.app_private_key_path = app_private_key_path
    self.app_private_key = None
    self.return_url = return_url
    with open(self.app_private_key_path) as fp:
      self.app_private_key = RSA.importKey(fp.read())
    self.alipay_public_key_path = alipay_public_key_path
    with open(self.alipay_public_key_path) as fp:
      self.alipay_public_key = RSA.importKey(fp.read())
    if debug is True:
      self.__gateway = "https://openapi.alipaydev.com/gateway.do"
    else:
      self.__gateway = "https://openapi.alipay.com/gateway.do"
  def direct_pay(self, subject, out_trade_no, total_amount, return_url=None, **kwargs):
    biz_content = {
      "subject": subject,
      "out_trade_no": out_trade_no,
      "total_amount": total_amount,
      "product_code": "FAST_INSTANT_TRADE_PAY",
      # "qr_pay_mode":4
    }
    biz_content.update(kwargs)
    data = self.build_body("alipay.trade.page.pay", biz_content, self.return_url)
    return self.sign_data(data)
  def build_body(self, method, biz_content, return_url=None):
    data = {
      "app_id": self.appid,
      "method": method,
      "charset": "utf-8",
      "sign_type": "RSA2",
      "timestamp": datetime.now().strftime("%Y-%m-%d %H:%M:%S"),
      "version": "1.0",
      "biz_content": biz_content
    }
    if return_url is not None:
      data["notify_url"] = self.app_notify_url
      data["return_url"] = self.return_url
    return data
  def sign_data(self, data):
    data.pop("sign", None)
    # 排序后的字符串
    unsigned_items = self.ordered_data(data)
    unsigned_string = "&".join("{0}={1}".format(k, v) for k, v in unsigned_items)
    sign = self.sign(unsigned_string.encode("utf-8"))
    # ordered_items = self.ordered_data(data)
    quoted_string = "&".join("{0}={1}".format(k, quote_plus(v)) for k, v in unsigned_items)
    # 獲得最終的訂單信息字符串
    signed_string = quoted_string + "&sign=" + quote_plus(sign)
    return signed_string
  def ordered_data(self, data):
    complex_keys = []
    for key, value in data.items():
      if isinstance(value, dict):
        complex_keys.append(key)
    # 將字典類型的數(shù)據(jù)dump出來
    for key in complex_keys:
      data[key] = json.dumps(data[key], separators=(',', ':'))
    return sorted([(k, v) for k, v in data.items()])
  def sign(self, unsigned_string):
    # 開始計(jì)算簽名
    key = self.app_private_key
    signer = PKCS1_v1_5.new(key)
    signature = signer.sign(SHA256.new(unsigned_string))
    # base64 編碼，轉(zhuǎn)換為unicode表示并移除回車
    sign = encodebytes(signature).decode("utf8").replace("\n", "")
    return sign
  def _verify(self, raw_content, signature):
    # 開始計(jì)算簽名
    key = self.alipay_public_key
    signer = PKCS1_v1_5.new(key)
    digest = SHA256.new()
    digest.update(raw_content.encode("utf8"))
    if signer.verify(digest, decodebytes(signature.encode("utf8"))):
      return True
    return False
  def verify(self, data, signature):
    if "sign_type" in data:
      sign_type = data.pop("sign_type")
    # 排序后的字符串
    unsigned_items = self.ordered_data(data)
    message = "&".join(u"{}={}".format(k, v) for k, v in unsigned_items)
    return self._verify(message, signature)

from django.contrib import admin
from django.conf.urls import url
from app01 import views
urlpatterns = [
  url('admin/', admin.site.urls),
  url('index/', views.index),
  url('result/', views.pay_result), # 支付寶處理完成后回調(diào)的get請(qǐng)求路由
  url('update_order/', views.update_order), # 支付寶處理完成后回調(diào)的post請(qǐng)求路由
]

import time
from urllib.parse import parse_qs
from django.conf import settings
from django.shortcuts import render, redirect, HttpResponse
from django.views.decorators.csrf import csrf_exempt
from alipay_use.alipay.alipay import AliPay
def aliPay():
  obj = AliPay(
    appid="2016100100642208",               # 支付寶沙箱里面的APPID，需要改成你自己的
    app_notify_url="http://129.211.29.98/update_order/", # 如果支付成功，支付寶會(huì)向這個(gè)地址發(fā)送POST請(qǐng)求（校驗(yàn)是否支付已經(jīng)完成），此地址要能夠在公網(wǎng)進(jìn)行訪問，需要改成你自己的服務(wù)器地址
    return_url="http://129.211.29.98/result/",      # 如果支付成功，重定向回到你的網(wǎng)站的地址。需要你自己改，這里是我的服務(wù)器地址
    alipay_public_key_path=settings.ALIPAY_PUBLIC, # 支付寶公鑰
    app_private_key_path=settings.APP_PRIVATE,   # 應(yīng)用私鑰
    debug=True, # 默認(rèn)False,True表示使用沙箱環(huán)境測(cè)試
  )
  # 優(yōu)化:在settings里面的設(shè)置后使用
  # obj = AliPay(
  #   appid=settings.APPID,
  #   app_notify_url=settings.NOTIFY_URL,
  #   return_url=settings.RETURN_URL,
  #   alipay_public_key_path=settings.PUB_KEY_PATH,
  #   app_private_key_path=settings.PRI_KEY_PATH,
  #   debug=True,
  # )
  return obj
@csrf_exempt
def index(request):
  if request.method == "GET":
    return render(request, 'index.html')
  # 實(shí)例化SDK里面的類AliPay
  alipay = aliPay()
  # 對(duì)購買的數(shù)據(jù)進(jìn)行加密
  money = float(request.POST.get('price')) # 保留倆位小數(shù) 前端傳回的數(shù)據(jù)
  out_trade_no = "x2" + str(time.time()) # 商戶訂單號(hào)  # 訂單號(hào)可以有多中生成方式，可以百度一下
  # 1. 在數(shù)據(jù)庫創(chuàng)建一條數(shù)據(jù)：狀態(tài)（待支付）
  query_params = alipay.direct_pay(
    subject="充氣式Saber", # 商品簡(jiǎn)單描述 這里一般是從前端傳過來的數(shù)據(jù)
    out_trade_no=out_trade_no, # 商戶訂單號(hào) 這里一般是從前端傳過來的數(shù)據(jù)
    total_amount=money, # 交易金額(單位: 元 保留倆位小數(shù))  這里一般是從前端傳過來的數(shù)據(jù)
  )
  # 拼接url，轉(zhuǎn)到支付寶支付頁面
  pay_url = "https://openapi.alipaydev.com/gateway.do?{}".format(query_params)
  return redirect(pay_url)
@csrf_exempt
def update_order(request):
  """
  支付成功后，支付寶向該地址發(fā)送的POST請(qǐng)求（用于修改訂單狀態(tài)）
  :param request:
  :return:
  """
  if request.method == 'POST':
    body_str = request.body.decode('utf-8')
    post_data = parse_qs(body_str)
    post_dict = {}
    for k, v in post_data.items():
      post_dict[k] = v[0]
    alipay = aliPay()
    sign = post_dict.pop('sign', None)
    status = alipay.verify(post_dict, sign)
    if status:
      # 1.修改訂單狀態(tài)
      out_trade_no = post_dict.get('out_trade_no')
      print(out_trade_no)
　　　　　　
      # 2. 根據(jù)訂單號(hào)將數(shù)據(jù)庫中的數(shù)據(jù)進(jìn)行更新
      return HttpResponse('支付成功')
    else:
      return HttpResponse('支付失敗')
  return HttpResponse('')
@csrf_exempt
def pay_result(request):
  """
  支付完成后，跳轉(zhuǎn)回的地址
  :param request:
  :return:
  """
  params = request.GET.dict()
  sign = params.pop('sign', None)
  alipay = aliPay()
  status = alipay.verify(params, sign)
  if status:
    return HttpResponse('支付成功')
  return HttpResponse('支付失敗')

<!DOCTYPE html>
<html lang="en">
<head>
  <meta charset="UTF-8">
  <title>Title</title>
</head>
<body>
<form action="" method="post">
  <input type="text" name="price">
  <input type="submit">
</form>
</body>
</html>