• 支付宝支付---流程详解

    👏👏👏

    哈喽！大家好，我是【太阳打伞】，一位热爱分享各种技术的博主！😍😍😍

    ⭐【太阳打伞】的创作宗旨：每一条命令都亲自执行过，每一行代码都实际运行过，每一种方法都真实实践过，每一篇文章都良心制作过。✊✊✊

    ⭐【太阳打伞】的博客中所有涉及命令、代码的地方，除了提供图片供大家参考，另外会在图片下方提供一份纯文本格式的命令或者代码方便大家粘贴复制直接执行命令或者运行代码。🤝🤝🤝

    ⭐如果你对技术有着浓厚的兴趣，欢迎关注【太阳打伞】，欢迎大家和我一起交流。😘😘😘

    ❤️❤️❤️感谢各位朋友接下来的阅读❤️❤️❤️
     

    流程图：

     ！！！：效果内容在最下方，一定要看呀。

    第一步：

    登录支付宝，打开控制台，进入研发服务

     

     第二步：

    进入沙箱，生成自己的私钥，支付宝公钥

    将支付宝公钥和自己私钥存放到.txt文件中

     第三步：

    拿到自己的支付宝沙箱应用id，和   买家账号：xxxxxxxxxxxx
                                                            登录密码111111
                                                            支付密码111111，

    买家账号等到支付时使用！

    第四步：

    后端代码实现：

    创建alipay.py文件

    我采用的是Tornado框架实现的！！！

    1.  
    2. from datetime import datetime
    3. from Crypto.PublicKey import RSA
    4. from Crypto.Signature import PKCS1_v1_5
    5. from Crypto.Hash import SHA256
    6. from urllib.parse import quote_plus
    7. from urllib.parse import urlparse, parse_qs
    8. from base64 import decodebytes, encodebytes
    9. import json
    10. from tornado import httpclient
    11.  
    12.  
    13. class AliPay:
    14.     """
    15.     支付宝支付接口(PC端支付接口)
    16.     """
    17.  
    18.  
    19.     def __init__(self, appid, app_notify_url, app_private_key_path,
    20.                  alipay_public_key_path, return_url, debug=True):
    21.         self.appid = appid
    22.         self.app_notify_url = app_notify_url
    23.         self.app_private_key_path = app_private_key_path
    24.         self.app_private_key = None
    25.         self.return_url = return_url
    26.         with open(self.app_private_key_path) as fp:
    27.             self.app_private_key = RSA.importKey(fp.read())
    28.         self.alipay_public_key_path = alipay_public_key_path
    29.         with open(self.alipay_public_key_path) as fp:
    30.             self.alipay_public_key = RSA.importKey(fp.read())
    31.  
    32.         if debug is True:
    33.             self.__gateway = "https://openapi.alipaydev.com/gateway.do"
    34.         else:
    35.             self.__gateway = "https://openapi.alipay.com/gateway.do"
    36.  
    37.     # 商户订单号out_trade_no
    38.     def direct_pay(self, subject, out_trade_no, total_amount, return_url=None, **kwargs):
    39.         biz_content = {
    40.             "subject": subject,
    41.             "out_trade_no": out_trade_no,
    42.             "total_amount": total_amount,
    43.             "product_code": "FAST_INSTANT_TRADE_PAY",
    44.             # "qr_pay_mode":4
    45.         }
    46.  
    47.         biz_content.update(kwargs)
    48.         data = self.build_body("alipay.trade.page.pay", biz_content, self.return_url)
    49.         return self.sign_data(data)
    50.  
    51.  
    52.     # 查询订单状态方法
    53.     async def api_alipay_trade_query(self,out_trade_no=None,**kwargs):
    54.             biz_content = {
    55.                 "out_trade_no": out_trade_no
    56.             }
    57.             biz_content.update(**kwargs)
    58.  
    59.             data = self.build_body("alipay.trade.query", biz_content)
    60.             url = self.__gateway + "?" + self.sign_data(data)
    61.             res = await httpclient.AsyncHTTPClient().fetch(url,method='GET',validate_cert=False,connect_timeout=30.0, request_timeout=30.0)
    62.             res = json.loads(res.body.decode())
    63.             return res
    64.  
    65.     #请求支付宝退款接口
    66.     async def api_alipay_trade_refund(self, refund_amount, out_trade_no=None, trade_no=None, **kwargs):
    67.             biz_content = {
    68.                 "refund_amount": refund_amount
    69.             }
    70.             biz_content.update(**kwargs)
    71.             if out_trade_no:
    72.                 biz_content["out_trade_no"] = out_trade_no
    73.             if trade_no:
    74.                 biz_content["trade_no"] = trade_no
    75.             data = self.build_body("alipay.trade.refund", biz_content)
    76.             url = self.__gateway + "?" + self.sign_data(data)
    77.             res = await httpclient.AsyncHTTPClient().fetch(url,method='GET',validate_cert=False,connect_timeout=30.0, request_timeout=30.0)
    78.             res = json.loads(res.body.decode())
    79.             return res
    80.  
    81.     def build_body(self, method, biz_content, return_url=None):
    82.         data = {
    83.             "app_id": self.appid,
    84.             "method": method,
    85.             "charset": "utf-8",
    86.             "sign_type": "RSA2",
    87.             "timestamp": datetime.now().strftime("%Y-%m-%d %H:%M:%S"),
    88.             "version": "1.0",
    89.             "biz_content": biz_content
    90.         }
    91.  
    92.         if return_url is not None:
    93.             data["notify_url"] = self.app_notify_url
    94.             data["return_url"] = self.return_url
    95.  
    96.         return data
    97.  
    98.     def sign_data(self, data):
    99.         data.pop("sign", None)
    100.         # 排序后的字符串
    101.         unsigned_items = self.ordered_data(data)
    102.         unsigned_string = "&".join("{0}={1}".format(k, v) for k, v in unsigned_items)
    103.         sign = self.sign(unsigned_string.encode("utf-8"))
    104.         # ordered_items = self.ordered_data(data)
    105.         quoted_string = "&".join("{0}={1}".format(k, quote_plus(v)) for k, v in unsigned_items)
    106.  
    107.         # 获得最终的订单信息字符串
    108.         signed_string = quoted_string + "&sign=" + quote_plus(sign)
    109.         return signed_string
    110.  
    111.     def ordered_data(self, data):
    112.         complex_keys = []
    113.         for key, value in data.items():
    114.             if isinstance(value, dict):
    115.                 complex_keys.append(key)
    116.  
    117.         # 将字典类型的数据dump出来
    118.         for key in complex_keys:
    119.             data[key] = json.dumps(data[key], separators=(',', ':'))
    120.  
    121.         return sorted([(k, v) for k, v in data.items()])
    122.  
    123.     def sign(self, unsigned_string):
    124.         # 开始计算签名
    125.         key = self.app_private_key
    126.         signer = PKCS1_v1_5.new(key)
    127.         signature = signer.sign(SHA256.new(unsigned_string))
    128.         # base64 编码，转换为unicode表示并移除回车
    129.         sign = encodebytes(signature).decode("utf8").replace("\n", "")
    130.         return sign
    131.  
    132.     def _verify(self, raw_content, signature):
    133.         # 开始计算签名
    134.         key = self.alipay_public_key
    135.         signer = PKCS1_v1_5.new(key)
    136.         digest = SHA256.new()
    137.         digest.update(raw_content.encode("utf8"))
    138.         if signer.verify(digest, decodebytes(signature.encode("utf8"))):
    139.             return True
    140.         return False
    141.  
    142.     def verify(self, data, signature):
    143.         if "sign_type" in data:
    144.             sign_type = data.pop("sign_type")
    145.         # 排序后的字符串
    146.         unsigned_items = self.ordered_data(data)
    147.         message = "&".join(u"{}={}".format(k, v) for k, v in unsigned_items)
    148.         return self._verify(message, signature)
    149.  
    150.  
    151.

    第五步：

    写pay.py主文件：

    1. import datetime
    2. import logging
    3. import decimal
    4. from base import BaseHandler
    5. from tornado.web import url
    6.  
    7. from db import UserModel,OrderModel
    8. from user import BaseMange
    9. # 充值
    10. from alipay import AliPay
    11. from utils import jwt_auth
    12.  
    13. # 钱包
    14. class WalletHandler(BaseMange):
    15.     """创建订单"""
    16.  
    17.     @jwt_auth
    18.     async def post(self):
    19.         _where = "model.uid == {}".format(self._cuser.id)
    20.         orders = await self.get_all_where(OrderModel,_where)
    21.         return self.finish({"errcode":0,"data":orders})
    22.  
    23.     @jwt_auth
    24.     async def get(self):
    25.         # 查询用户余额
    26.         user = await self.get_one_obj(UserModel, self._cuser.id)
    27.  
    28.         return self.finish({'errcode': 0, 'data': user.wallet})
    29.  
    30.  
    31.  
    32. class PayHandler(BaseMange):
    33.     # 转跳地址
    34.     @jwt_auth
    35.     async def get(self):
    36.  
    37.         alipay = AliPay(
    38.             appid='xxxxxxxxxx',  # 你的支付宝沙箱应用的id
    39.             app_private_key_path='./keys/app_private_2048.txt',  # 你的私钥
    40.             alipay_public_key_path='./keys/alipay_public_2048.txt',  # 支付宝公钥,
    41.             app_notify_url="http://127.0.0.1:8080/wallet",  # 回调地址
    42.             return_url='http://127.0.0.1:8080/pay',
    43.             debug=True  # 请求来到支付宝沙箱)
    44.         )
    45.         # 3.创建订单
    46.         order_id = datetime.datetime.now().strftime("%Y%m%d%H%M%S") + "_%s" % self._cuser.id
    47.         subject = self.get_argument("subject",None)
    48.         # 订单编号
    49.         total_amount= self.get_argument("total_amount",None)
    50.         # res = alipay.direct_pay(subject,order_id,total_amount)
    51.         # print(res)
    52.         # pay_url = "https://openapi.alipaydev.com/gateway.do?"+res  # 支付宝网关地址（沙箱应用）
    53.         # return self.finish({'errcode': 0, 'data': pay_url})
    54.  
    55.         """创建订单"""
    56.         try:
    57.             # 创建订单信息
    58.             order = {"order_id": order_id, "uid_id": self._cuser.id, "total_amount": float(total_amount)}
    59.  
    60.             order = await self.create(OrderModel, order)
    61.             res = alipay.direct_pay(subject, order_id, total_amount)
    62.             print(res)
    63.             pay_url = "https://openapi.alipaydev.com/gateway.do?" + res  # 支付宝网关地址（沙箱应用）
    64.             # print(pay_url)
    65.             return self.finish({'errcode': 0, 'data': pay_url})
    66.         except Exception as e:
    67.             logging.error("create order error, reason is %s" % e)
    68.             return self.finish({'errcode': 1, 'msg': "交易出错！"})
    69.  
    70.     @jwt_auth
    71.     async def post(self):
    72.  
    73.         order_id = self.get_argument("out_trade_no", None)  # 订单编号
    74.  
    75.         _where = "(model.order_id=='{}')".format(order_id)
    76.  
    77.         alipay = AliPay(
    78.             appid='xxxxxxxxxx',  # 你的支付宝沙箱应用的id
    79.             app_private_key_path='./keys/app_private_2048.txt',  # 你的私钥
    80.             alipay_public_key_path='./keys/alipay_public_2048.txt',  # 支付宝公钥,
    81.             app_notify_url="http://127.0.0.1:8080/wallet",  # 回调地址
    82.             return_url='http://127.0.0.1:8080/pay',
    83.             debug=True  # 请求来到支付宝沙箱)
    84.         )
    85.  
    86.         res = await alipay.api_alipay_trade_query(out_trade_no=order_id)
    87.         print(res)
    88.         res = res['alipay_trade_query_response']
    89.  
    90.         if res['code'] == '10000':
    91.             try:
    92.                 order = await self.get_one_where(OrderModel, _where)
    93.  
    94.                 # 修改订单的状态
    95.                 order.trade_no = res['trade_no']
    96.                 order.total_amount = res['total_amount']
    97.                 order.status = 1
    98.                 order.record = res["send_pay_date"]
    99.                 await self.application.objects.update(order)
    100.                 user = await self.get_one_obj(UserModel, self._cuser.id)
    101.                 user.wallet = user.wallet + decimal.Decimal(res['total_amount'])
    102.  
    103.                 await self.application.objects.update(user)
    104.                 return self.finish({'errcode': 0, 'msg': "充值成功"})
    105.             except Exception as e:
    106.                 print(e)
    107.  
    108.                 return self.finish({'errcode': 1, 'msg': "未找到订单交易！"})
    109.  
    110.         else:
    111.             return self.finish({'errcode': 2, 'msg': "支付失败！"})
    112.  
    113.  
    114. urlpatterns = [
    115.     url('/pay/', PayHandler),
    116.     url('/wallet/', WalletHandler),
    117.  
    118.  
    119. ]
    120.

    第六步：

    前端代码实现

    我使用的是Vue.3

    文件名是：wallet.vue

    1.  
    2. <template>
    3.   <div class="container">
    4.     <a-layout>
    5.       <a-layout-sider>
    6.         <mymenu>mymenu>
    7.       a-layout-sider>
    8.       <a-layout>
    9.  
    10.             <h2>充值页面h2>
    11.  
    12.             <h3>我的钱包h3>
    13.  
    14.             <p>
    15.                         <a-col :span="22">
    16.                             <a-statistic title="钱包余额" :precision="2" :value= wallet />
    17.                         a-col>
    18.                     p>
    19.  
    20.                     <div class="components-input-demo-presuffix">
    21.                         <h2>钱包充值h2>
    22.  
    23.                         <p>请输入充值金额：
    24.                             <a-input v-model:value="value" prefix="￥" suffix="RMB" placeholder="请输入充值金额" />
    25.                         p>
    26.                         <p>
    27.                             <a-button type="primary" @click="get_pay()">支付宝充值a-button> 
    28.                             <a-button type="">微信充值a-button>
    29.                         p>
    30.                     div>
    31.                     <p>用户订单表p>
    32.                     <p><table>
    33.                         <tr>
    34.                             <th>订单编号th>
    35.                             <th>创建时间th>
    36.                             <th>支付方式th>
    37.                             <th>备注th>
    38.                             <th>支付状态th>
    39.                         tr>
    40.                         <tr  v-for="(j,i) in orderlist" :key="i">
    41.                         <td>{{j.order_id}}td>
    42.                         <td>{{j.create_time}}td>
    43.                         <td>{{j.pay_method}}td>
    44.                         <td>{{j.record}}td>
    45.                         <td v-if="j.status==0">待支付td>
    46.                         <td v-if="j.status==1">已支付td>
    47.                         <td v-if="j.status==3">已取消td>
    48.                         tr>
    49.                     table>p>
    50.  
    51.  
    52.  
    53.                 
    54.             
    55.     
    56.          
    57.       a-layout>
    58.     a-layout>
    59.   div>
    60. template>
    61.  
    62. <script>
    63. // 导入子组件
    64. import mymenu from "./mymenu.vue";
    65. import { message } from "ant-design-vue";
    66.  
    67. export default {
    68.   data() {
    69.     return {
    70.       
    71.       collapsed: false,
    72.       selectedKeys: ["1"],
    73.       visible:false,
    74.       money:'',
    75.       id:'',
    76.       wallet:0,
    77.       value:50,
    78.       orderlist:[]
    79.  
    80.       
    81.       
    82.       
    83.       
    84.     };
    85.   },
    86.  
    87.   //声明组件
    88.   components: {
    89.     mymenu,
    90.   },
    91.   methods: {
    92.  
    93.             pay(id){
    94.             this.visible = true
    95.             // this.id = id
    96.     },
    97.  
    98.  
    99.             // 充值请求
    100.  
    101.             get_pay() {
    102.             this.myaxios(this.baseurl + "pay/", "get",{"subject":"钱包充值","total_amount":this.value}).then(data => {
    103.  
    104.                 console.log(data);
    105.                 if (data.errcode === 0) {
    106.                     window.location.href=data.data
    107.                 }
    108.  
    109.             });
    110.         },
    111.  
    112.             get_wallet() {
    113.             this.myaxios(this.baseurl + "wallet/", "get").then(data => {
    114.  
    115.                 console.log(data);
    116.                 if (data.errcode === 0) {
    117.                     this.wallet = data.data
    118.                 }
    119.  
    120.             });
    121.         },
    122.  
    123.  
    124.  
    125.  
    126.         get_orderlist(){
    127.             this.myaxios(this.baseurl + "wallet/", "post").then(data => {
    128.  
    129.                 console.log(data);
    130.                 if (data.errcode === 0) {
    131.                     this.orderlist = data.data
    132.                 }
    133.  
    134.             });
    135.         }
    136.             
    137.  
    138.  
    139.  
    140.  
    141.         
    142.       
    143.  
    144.  
    145.  
    146.  
    147.  
    148.           
    149.     
    150. },
    151.   created() {
    152.     this.get_wallet()
    153.     this.get_orderlist()
    154.  
    155.     
    156.  
    157.   },
    158.   mounted() {},
    159. };
    160. script>
    161.  
    162.  
    163. <style scoped>
    164. @import url("../assets/style.css");
    165. style>

    充值请求：

    文件名是：pay.vue

    1.  
    2. <template>
    3.   <div class="container">
    4.     <a-layout>
    5.       <a-layout-sider>
    6.         <mymenu>mymenu>
    7.       a-layout-sider>
    8.       <a-layout>
    9.  
    10.             <h2>充值页面h2>
    11.          
    12.       a-layout>
    13.     a-layout>
    14.   div>
    15. template>
    16.  
    17. <script>
    18. // 导入子组件
    19. import mymenu from "./mymenu.vue";
    20. import { message } from "ant-design-vue";
    21.  
    22. import { createFromIconfontCN } from '@ant-design/icons-vue';
    23.  
    24. const IconFont = createFromIconfontCN({
    25.     scriptUrl: '//at.alicdn.com/t/font_8d5l8fzk5b87iudi.js',
    26. });
    27.  
    28. export default {
    29.   data() {
    30.     return {
    31.       
    32.       collapsed: false,
    33.       selectedKeys: ["1"],
    34.       
    35.       
    36.       
    37.     };
    38.   },
    39.  
    40.   //声明组件
    41.   components: {
    42.     mymenu,
    43.   },
    44.   methods: {
    45.  
    46.             
    47.  
    48.  
    49.             // 充值请求
    50.  
    51.             check_order(){
    52.             this.myaxios(this.baseurl + "pay/", "post",{"out_trade_no":this.$route.query.out_trade_no,"trade_no":this.$route.query.trade_no,"total_amount":this.$route.query.total_amount,"timestamp":this.$route.query.timestamp}).then(data => {
    53.  
    54.                 console.log(data);
    55.                 if (data.errcode === 0) {
    56.                     this.$message.success(data.msg)
    57.                     window.location.href="/wallet"
    58.                 }else{
    59.                     this.$message.error(data.msg)
    60.                     window.location.href="/wallet"
    61.                 }
    62.  
    63.             });
    64.         }
    65.  
    66.           
    67.     
    68. },
    69.   created() {
    70.  
    71.     this.check_order()
    72.  
    73.   },
    74.   mounted() {},
    75. };
    76. script>
    77.  
    78.  
    79. <style scoped>
    80. @import url("../assets/style.css");
    81. style>

    第七步：

    数据库内容，字段名

    订单表：

     用户表：记得写钱包字段哦

     效果内容（show）：

     点击支付宝充值：

     输入从沙箱获得的支付宝账号和密码。

    点击确认付款！

    后面还让输入支付密码！！！

    钱包到账啦：

     

     这个就是支付宝支付，代码有效，修改即用！！！

     

  • 相关阅读:
    二维矩阵内的BFS搜索
    递归关系的渐进时间复杂度推导
    笔记（二）图的基本表示【斯坦福CS224W图机器学习】
    在java中使用Reactor 项目中的一个类Mono，用于表示异步单值操作
    如何提升网站运营效率
    haproxy，nginx，keepalived综合运用
    springboot采用协同过滤算法的家政服务平台的设计与实现毕业设计源码260839
    SCI英语论文长难句攻略
    图论——并查集
    Java基础练习（矩阵的加减乘除运算）
  • 原文地址：https://blog.csdn.net/justzcy/article/details/126469524