luffy-(13)
2024-06-21 01:55:00
内容概览
- 支付宝支付介绍
- 支付宝支付二次封装
- 订单相关表设计
- 生成订单接口
- 支付前端
- 支付宝回调接口
支付宝支付介绍
"""
项目中有需要在线支付功能,可以使用支付宝支付(沙箱环境)微信支付(需要有备案过的域名)云闪付我们的项目以支付宝支付为例支付流程使用官方或第三方的API/sdk第三方sdk:基于API封装(我们使用这个)官方sdk:https://opendocs.alipay.com/open/02no41支付宝支付介绍申请条件很严苛沙箱环境：Sandbox：程序的虚拟执行环境，不需要申请各种认证，直接写程序，后期只需要换成只是的秘钥即可
"""
使用支付宝支付
1. 使用沙箱环境:https://open.alipay.com/develop/sandbox/app
2. 第三方的sdk:https://github.com/fzlee/alipay-基于支付宝的API接口封装的，开源软件，-pip install python-alipay-sdk3. 生成公钥私钥:使用支付宝提供的工具-https://opendocs.alipay.com/common/02kipk-生成公钥私钥，在本地(私钥好好保管)4. 把公钥填在支付宝网站上(沙箱环境/正式环境)-把我们的公钥填进网站，会生成一个支付宝公钥，以后项目中我们使用支付宝公钥来做
基本使用
新建两个文件保存应用私钥与支付宝公钥
app_private_key.pem，应用私钥
-----BEGIN RSA PRIVATE KEY-----
base64 encoded content
-----END RSA PRIVATE KEY-----
alipay_public_key.pem，支付宝公钥
-----BEGIN PUBLIC KEY-----
base64 encoded content
-----END PUBLIC KEY-----
from alipay import AliPay
from alipay.utils import AliPayConfig# 初始化得到对象，传入一堆参数
alipay = AliPay(appid="2016092000554611", # app的id号app_notify_url=None, # 默认回调 urlapp_private_key_string=open('./app_private_key.pem').read(), # 应用私钥alipay_public_key_string=open('./alipay_public_key.pem').read(), # 支付宝的公钥，验证支付宝回传消息使用，不是你自己的公钥,sign_type="RSA2", # RSA 或者 RSA2debug=False, # 默认 Falseverbose=False, # 输出调试数据config=AliPayConfig(timeout=15) # 可选，请求超时时间
)# 生成支付链接
order_string = alipay.api_alipay_trade_page_pay(out_trade_no="订单号(uuid)",total_amount=99999, # 支付金额subject='精品内衣', # 订单标题return_url="https://example.com", # get回调地址(前端)notify_url="https://example.com/notify" # post回调地址(后端)
)
# print('https://openapi.alipay.com/gateway.do?'+order_string) # 真实的地址
print('https://openapi.alipaydev.com/gateway.do?'+order_string) # 测试的地址
支付宝支付二次封装
"""
目录结构
alipay_common # 包名pem # 放公钥私钥alipay_public_key.pemapp_private_key.pem__init__.py pay.py # 核心文件settings.py #配置文件
"""# 如果保证公钥私钥的安全：1. 不在项目中直接写,写在环境变量中2. 专门写一个公钥私钥管理的服务,发送请求获取,接口携带很多认证
pay.py
from alipay import AliPay
from alipay.utils import AliPayConfig
from . import settings# 初始化得到对象，传入一堆参数
alipay = AliPay(appid=settings.APPID, # app的id号app_notify_url=None, # 默认回调 urlapp_private_key_string=settings.APP_PRIVATE_KEY_STRING,# 支付宝的公钥，验证支付宝回传消息使用，不是你自己的公钥,alipay_public_key_string=settings.ALIPAY_PUBLIC_KEY_STRING,sign_type=settings.SIGN, # RSA 或者 RSA2debug=settings.DEBUG, # 默认 Falseverbose=False, # 输出调试数据config=AliPayConfig(timeout=15) # 可选，请求超时时间
)
settings.py
import os# 应用ID
APPID = '2021000121695894'
# 应用私钥
APP_PRIVATE_KEY_STRING = open(os.path.join(os.path.dirname(os.path.abspath(__file__)), 'pem', 'app_private_key.pem')).read()
# 支付宝公钥
ALIPAY_PUBLIC_KEY_STRING = open(os.path.join(os.path.dirname(os.path.abspath(__file__)), 'pem', 'alipay_public_key.pem')).read()
# 加密方式
SIGN = 'RSA2'# 是否是支付宝测试环境(沙箱环境)，如果采用真是支付宝环境，配置False
DEBUG = True# 支付网关
GATEWAY = 'https://openapi.alipaydev.com/gateway.do?' if DEBUG else 'https://openapi.alipay.com/gateway.do?'init
from .pay import alipay
from .settings import GATEWAY
订单相关表设计
1. 创建订单app
...\apps> python ../../manage.py startapp order
# 注册app 2. 设计表-订单表-订单详情表 ：订单表和订单详情是一对多的关系
from django.db import models
from user.models import UserInfo
from course.models import Course# Create your models here.
# 订单表
class Order(models.Model):"""订单模型"""status_choices = ((0, '未支付'),(1, '已支付'),(2, '已取消'),(3, '超时取消'),)pay_choices = ((1, '支付宝'),(2, '微信支付'),)subject = models.CharField(max_length=150, verbose_name="订单标题")total_amount = models.DecimalField(max_digits=10, decimal_places=2, verbose_name="订单总价", default=0)# 唯一的，咱们生成的， uuidout_trade_no = models.CharField(max_length=64, verbose_name="订单号", unique=True)# 支付宝 成功后，会有个流水号trade_no = models.CharField(max_length=64, null=True, verbose_name="流水号")# 订单状态order_status = models.SmallIntegerField(choices=status_choices, default=0, verbose_name="订单状态")pay_type = models.SmallIntegerField(choices=pay_choices, default=1, verbose_name="支付方式")# 支付时间：支付宝支付完成返回的数据中有这个字段pay_time = models.DateTimeField(null=True, verbose_name="支付时间")# 订单创建时间，不一定支付created_time = models.DateTimeField(auto_now_add=True, verbose_name='创建时间')user = models.ForeignKey(UserInfo, related_name='order_user', on_delete=models.DO_NOTHING, db_constraint=False,verbose_name="下单用户")class Meta:db_table = "luffy_order"verbose_name = "订单记录"verbose_name_plural = "订单记录"def __str__(self):return "%s - ￥%s" % (self.subject, self.total_amount)@propertydef courses(self):data_list = []for item in self.order_courses.all():data_list.append({"id": item.id,"course_name": item.course.name,"real_price": item.real_price,})return data_list# 订单详情表
class OrderDetail(models.Model):"""订单详情"""order = models.ForeignKey(Order, related_name='order_courses', on_delete=models.CASCADE, db_constraint=False,verbose_name="订单")course = models.ForeignKey(Course, related_name='course_orders', on_delete=models.CASCADE, db_constraint=False,verbose_name="课程")price = models.DecimalField(max_digits=6, decimal_places=2, verbose_name="课程原价")real_price = models.DecimalField(max_digits=6, decimal_places=2, verbose_name="课程实价")class Meta:db_table = "luffy_order_detail"verbose_name = "订单详情"verbose_name_plural = "订单详情"def __str__(self):try:return "%s的订单：%s" % (self.course.name, self.order.out_trade_no)except:return super().__str__()生成订单接口
# 前端：点击购买按钮---->向后端发送请求【需要登录认证】，携带数据{courses:[1,2,3],total_amount:999,subject:订单名,pay_type:1}# 后端：-两个重要的事:生成支付链接,在订单表中插入数据-视图类:create;序列化类:数据校验,生成支付链接
视图类
from django.shortcuts import render
from .models import Order
from .serializers import OrderSerializer
from utils.response import APIResponse
from rest_framework.viewsets import GenericViewSet
from rest_framework_jwt.authentication import JSONWebTokenAuthentication
from rest_framework.permissions import IsAuthenticated# Create your views here.class OrderView(GenericViewSet):queryset = Order.objects.all()serializer_class = OrderSerializer# 登录后才能够访问authentication_classes = [JSONWebTokenAuthentication]permission_classes = [IsAuthenticated]# 这个新增接口,既要新增,又要返回支付链接;重写create方法def create(self, request, *args, **kwargs):serializer = self.get_serializer(data=request.data, context={'request': request})serializer.is_valid(raise_exception=True)serializer.save()pay_url = serializer.context.get('pay_url')return APIResponse(pay_url=pay_url)序列化类
import uuidfrom rest_framework import serializers
from .models import Order, OrderDetail
from rest_framework.exceptions import APIException
from libs.alipay_common import GATEWAY, alipay
from django.conf import settings
from course.models import Courseclass OrderSerializer(serializers.ModelSerializer):# courses不是order表的字段，一定要重写# 前端传入的是 courses:[1,3,4]----->转换成课程对象[课程对象1，课程对象3，课程对象4]courses = serializers.PrimaryKeyRelatedField(queryset=Course.objects.all(), write_only=True, many=True)class Meta:model = Orderfields = ['courses', 'total_amount', 'subject', 'pay_type'] # 只用来做数据校验和反序列化def _check_price(self, attrs):total_amount = attrs.get('total_amount')# 循环所有课程，取出价格累加得到总价格real_total = 0for course in attrs.get('courses'):real_total += course.priceif not total_amount == real_total: # 不正常，抛异常raise APIException('价格不一致')else:return real_totaldef _get_trade_no(self):return str(uuid.uuid4())def _get_user(self):# 当前登录用户，request.userrequest = self.context.get('request')return request.user # 必须通过了登录认证，才有当前登录用户def _get_pay_url(self, total_amount, subject, trade_no):pay_str = alipay.api_alipay_trade_page_pay(out_trade_no=trade_no,total_amount=float(total_amount),subject=subject,return_url=settings.RETURN_URL, # get回调地址notify_url=settings.NOTIFY_URL # post回调地址)return GATEWAY + pay_strdef _before_create(self, pay_url, attrs, user, trade_no):self.context['pay_url'] = pay_urlattrs['user'] = userattrs['out_trade_no'] = trade_nodef validate(self, attrs):# 1 校验价格：计算一下总价格和后端算出来的总价格是否一致total_amount = self._check_price(attrs)# 2）生成订单号：唯一的，trade_no = self._get_trade_no()# 3）支付用户：request.useruser = self._get_user()# 4）支付链接生成，放入到self.context中pay_url = self._get_pay_url(total_amount, attrs.get('subject'), trade_no)# 5）入库(两个表)的信息准备：重写create方法self._before_create(pay_url, attrs, user, trade_no)return attrsdef create(self, validated_data):# {courses:[对象1，对象2]，total_amount：11，subject：xx,pay_type:1,user:user,out_trade_no:3333}courses = validated_data.pop('courses')order = Order.objects.create(**validated_data)# 存订单详情表for course in courses:OrderDetail.objects.create(order=order, course=course, price=course.price, real_price=course.price)return order路由
from rest_framework.routers import SimpleRouter
from . import viewsrouter = SimpleRouter()
router.register('alipay', views.OrderView, 'alipay')
urlpatterns = []
urlpatterns += router.urls配置文件
# 上线后必须换成公网地址
# 后台基URL
HOST_URL = 'http://127.0.0.1:8000'
# 前台基URL
LUFFY_URL = 'http://127.0.0.1:8080'
# 支付宝同步异步回调接口配置
# 后台异步回调接口 ：支付宝post回调地址：后端地址，后端配合一个接口
NOTIFY_URL = HOST_URL + "/order/success/"
# 前台同步回调接口，没有 / 结尾 支付宝get回调地址：前端地址，前端配合一个支付成功的页面组件
RETURN_URL = LUFFY_URL + "/pay/success"## jwt配置
import datetime
JWT_AUTH = {'JWT_EXPIRATION_DELTA': datetime.timedelta(days=7),
}
支付前端
// 在点击支付按钮添加点击事件go_buy(price, subject) {let token = this.$cookies.get('token')if (token) {// 发送ajax请求this.$axios.post(this.$settings.BASE_URL + 'order/alipay/', {courses: [this.course_id],total_amount: price,subject: subject,pay_type: 1}, {headers: {'Authorization': 'jwt ' + token}}).then(res => {if (res.data.code == 100) {// 打开支付链接open(res.data.pay_url, '_self')} else {this.$message({message: res.data.msg,type: 'error'});}})} else {this.$message({message: '您没有登录，请先登录',type: 'error'});}
}
支付成功页面PaySuccess.vue
<template><div class="pay-success"><!--如果是单独的页面，就没必要展示导航栏(带有登录的用户)--><Header/><div class="main"><div class="title"><div class="success-tips"><p class="tips">您已成功购买 1 门课程！</p></div></div><div class="order-info"><p class="info"><b>订单号：</b><span>{{ result.out_trade_no }}</span></p><p class="info"><b>交易号：</b><span>{{ result.trade_no }}</span></p><p class="info"><b>付款时间：</b><span><span>{{ result.timestamp }}</span></span></p></div><div class="study"><span>立即学习</span></div></div></div>
</template><script>import Header from "@/components/Header"export default {name: "Success",data() {return {result: {},};},created() {// url后拼接的参数：?及后面的所有参数 => ?a=1&b=2// console.log(location.search);// 解析支付宝回调的url参数// location.search 路径中 ？ 后的数据let params = location.search.substring(1); // 去除? ------- a=1&b=2let items = params.length ? params.split('&') : []; // ['a=1', 'b=2']//逐个将每一项添加到args对象中for (let i = 0; i < items.length; i++) { // 第一次循环a=1，第二次b=2let k_v = items[i].split('='); // ['a', '1']//解码操作，因为查询字符串经过编码的if (k_v.length >= 2) {// url编码反解 https://www.baidu.com/s?ie=utf-8&f=8&rsv_bp=1&rsv_idx=1&tn=baidu&wd=%E7%BE%8E%E5%A5%B3let k = decodeURIComponent(k_v[0]);this.result[k] = decodeURIComponent(k_v[1]);// 没有url编码反解// this.result[k_v[0]] = k_v[1];}}// 解析后的结果console.log(this.result);// 把地址栏上面的支付结果，再get请求转发给后端this.$axios.get(this.$settings.BASE_URL + 'order/success/' + location.search,).then(response => {if (response.data.code == 100) {alert('支付成功')} else {alert('暂未收到您的付款，请稍后刷新在试')}}).catch(() => {console.log('支付结果同步失败');})},components: {Header,}
}
</script><style scoped>
.main {padding: 60px 0;margin: 0 auto;width: 1200px;background: #fff;
}.main .title {display: flex;-ms-flex-align: center;align-items: center;padding: 25px 40px;border-bottom: 1px solid #f2f2f2;
}.main .title .success-tips {box-sizing: border-box;
}.title img {vertical-align: middle;width: 60px;height: 60px;margin-right: 40px;
}.title .success-tips {box-sizing: border-box;
}.title .tips {font-size: 26px;color: #000;
}.info span {color: #ec6730;
}.order-info {padding: 25px 48px;padding-bottom: 15px;border-bottom: 1px solid #f2f2f2;
}.order-info p {display: -ms-flexbox;display: flex;margin-bottom: 10px;font-size: 16px;
}.order-info p b {font-weight: 400;color: #9d9d9d;white-space: nowrap;
}.study {padding: 25px 40px;
}.study span {display: block;width: 140px;height: 42px;text-align: center;line-height: 42px;cursor: pointer;background: #ffc210;border-radius: 6px;font-size: 16px;color: #fff;
}
</style>
支付宝回调接口
"""
支付成功,支付号会有两个回调-get 回调,回调给前端-为了保证准确性，支付宝回调会前端后，我们自己向后端发送一个请求，查询一下这个订单是否支付成功-post 回调,回调给后端接口-后端接口,接收支付宝的回调,修改订单状态-支付宝在24小时内,会有8次回掉,防止没有收到后端需要写两个接口:-post回调,给支付宝用-get回调,给前端做二次校验使用
"""
from rest_framework.exceptions import APIException
from utils.common_logger import logger
from utils.response import APIResponse
from rest_framework.response import Responseclass PaySuccessView(ViewSet):def list(self, request):try:out_trade_no = request.query_params.get('out_trade_no')Order.objects.get(out_trade_no=out_trade_no, order_status=1)return APIResponse()except Exception as e:raise APIException('该订单还没支付成功')def create(self, request): # 给支付宝用的，写完后无法测试-----》外网无法直接访问到内网try:# from django.http.request import QueryDict# print(type(request.data))result_data = request.data.dict() # 回调回来编码格式是urlencoded，QueryDic对象---》.dict--->转成真正的字典对象out_trade_no = result_data.get('out_trade_no')signature = result_data.pop('sign') # 如果是QueryDic对象不允许popfrom libs import alipay_common# 验证签名，result_data和signature验证签名，sdk帮咱们写好了，一定要验证签名result = alipay_common.alipay.verify(result_data, signature)if result and result_data["trade_status"] in ("TRADE_SUCCESS", "TRADE_FINISHED"):# 完成订单修改：订单状态、流水号、支付时间Order.objects.filter(out_trade_no=out_trade_no).update(order_status=1,pay_time=result_data.get('timestamp'),trade_no=result_data.get('trade_no'))# 完成日志记录logger.warning('%s订单支付成功' % out_trade_no)return Response('success') # 支付宝要求的格式else:logger.error('%s订单支付失败' % out_trade_no)return Response('failed')except:return Response('failed')luffy-(13)相关推荐
- mahout安装测试
Mahout 是 Apache Software Foundation(ASF) 旗下的一个开源项目,提供一些可扩展的机器学习领域经典算法的实现,旨在帮助开发人员更加方便快捷地创建智能应用程序.Apa ...
- 路飞学城之 luffy(1)
目录 路飞学城之 luffy(1) 一.内容 二.内容大纲 小结 三.内容大纲 小结 四.内容大纲 自定义模态框 componses/Login.vue componses/Header.vue vu ...
- ImportError: DLL load failed: 找不到指定的模块。 TensorFlow 1.13
版权声明:本文为博主原创文章,未经博主允许不得转载. https://blog.csdn.net/zhenlingcn/article/details/88647288 问题描述 问题环境 Tenso ...
- iPhone 14 与iPhone 13
iPhone 14 与iPhone 13 iPhone14Pro配置曝光:感叹号+4800w像素 | 小米12Ultra 最新套壳图 距离下一代iPhone发布还有半年之久,关于iPhone14系列的 ...
- PyTorch 笔记（13）— autograd（0.4 之前和之后版本差异）、Tensor（张量）、Gradient（梯度）
1. 背景简述 torch.autograd 是 PyTorch 中方便用户使用,专门开发的一套自动求导引擎,它能够根据输入和前向传播过程自动构建计算图,并执行反向传播. 计算图是现代深度学习框架 P ...
- 机器学习入门（13）— Affine 仿射层、Softmax 归一化指数函数层实现
1. 一维 Affine 仿射层 我们回顾下之前为了计算加权信号的总和,使用了矩阵的乘积运算 NumPy 中是 np.dot() , 参照代码如下: In [7]: X = np.random.ran ...
- 读书笔记2013第13本：《怎样解题》
<怎样解题>这本书是在看<编程大师访谈录>(中文版第12页)这本书时无意发现的,一个编程大师推荐这本书来指导编程设计,google到这本书后粗略地翻看了一遍,发现是一本教学生如 ...
- [14] 薪酬迅速翻倍的13条跳槽原则
首先,真正的高级人才是不用找工作的,因为只有被工作找的份. 但是,难免有些高级人才厌倦了旧的工作环境,或者遇到天花板,没有了发展空间,或者遇到新老板上任后排除异己来提拔自己的亲信等等,如果您真打算自己 ...
- centos6.5 php5.2,Linux中PHP安装与配置(CentOS-6.5：php-5.2.13)
1 PHP简介 PHP(PHP: Hypertext Preprocessor的缩写,中文名:"超文本预处理器")是一种通用开源脚本语言.语法吸收了C语言.Java和Per ...
- 乐高无限无法进入服务器,乐高无限6.13更新 无法进入游戏问题修复
乐高无限于13日例常更新,那么这次更新了什么内容呢,修复了哪些东西呢,下面就跟随小编一起去了解一下详细内容吧. 生存模式: 1.解决了在玩法模式中使用假日烟花异常的问题; 2.解决了昵称中包含部分特殊 ...
最新文章
- 项目协作和团队管理难的问题，智办事都帮你解决
- Android 环境配置
- pageadmin CMS网站建设教程：站点添加自定义字段
- directx和opengl 电子白板
- 304. 二维区域和检索 - 矩阵不可变
- 每日算法系列【LeetCode 1031】两个非重叠子数组的最大和
- 2.mysql高级查询
- 视频截取图片帧工具（可免费使用）
- 2022年下半年（软考高级）信息系统项目管理师报名条件
- 自动化缺陷检测系统---项目总览
- S32K144（12）FTM
- 李宏毅老师《机器学习》入门第一课
- 廊坊金彩教育：拼多多运营方案
- 手机屏幕驱动板HDMI调光触摸旋转说明Fondar
- torch.randn用法
- 翻译《文件系统取证分析》第13章
- 用winrar压缩工具切分文件和合并文件
- Vue知识点总结(16)——具名插槽（超级详细）
- 怎样查找某个外文期刊的文献？
- Shiro认证源码解析和工作原理