luffy-16/订单表设计,立即付款接口/前端,支付成功get回调用户展示,支付成功post回调修改订单状态

一.昨日回顾

1 支付宝支付:
	-商户号:营业执照(登录的沙箱环境的商家)
	-客户:我们客户
2 生成公钥和私钥：公钥配置到支付宝网站上----》支付宝公钥
	-担心私钥不安全（不要把公钥私钥直接放在代码中，而是放在服务器上）
 	-支付宝支付（官方没有sdk，只提供了api），我们用了第三方，担心有问题
3 支付流程
	-用户在前端提交支付--->后端要生成订单(未支付)--->生成支付宝付款链接--->返回前端--->get请求支付链接--->支付宝付款页面(扫描付款)--->支付宝收到钱--->get回调到我们网站(展示用户付款成功)--->post回调(验签)修改订单状态
	-用户刚打开支付链接,你服务挂了,用户付款成功了
		-get回调也回不来了
		-支付宝的post回调,你也收不到(24小时以后,支付宝会推送8次)
			-25小时以内完成8次通知(通知的间隔频率一般是:4m,10m,10m,1h,2h,6h,15h)

二.今日内容

1.订单表设计

1 两张表
	-一个订单可能包含多门课程
	-订单表：订单号，订单生成时间，订单总价格。。。(订单跟订单详情是一对多的关系)
    -订单详情表：order,course，该课程的价格。。。

from django.db import models

from user.models import User
from course.models import Course
# 不同app之间的表，可以建立关联关系，导入使用
#user = models.ForeignKey(User)  # 不能用引号引起来

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)
    # 咱们生成的订单号（唯一：分布式id生成方案：雪花算法，snowflake）
    out_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="支付方式")
    # 支付时间（付款成功的时候，等支付宝post回调，回掉回来以后，返回数据中有支付时间）
    pay_time = models.DateTimeField(null=True, verbose_name="支付时间")
    user = models.ForeignKey(User, related_name='order_user', on_delete=models.DO_NOTHING, db_constraint=False, verbose_name="下单用户")
    # 订单创建时间
    created_time = models.DateTimeField(auto_now_add=True, verbose_name='创建时间')

    class Meta:
        db_table = "luffy_order"
        verbose_name = "订单记录"
        verbose_name_plural = "订单记录"

    def __str__(self):
        return "%s - ￥%s" % (self.subject, self.total_amount)

    @property
    def 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__()  # 相当于没写

2.立即付款接口(一堆校验,登录后)

1 付款接口需要登录后才能使用
	-自己写jwt的认证类
    -djangorestframwork-jwt 内置有个认证类，+ djangorestframwork的权限类也可以完成认证
    	（目前使用这种）

2 记得更改lib/al_pay/pay.py
这个网址后面记得加'?'
# 支付网关
GATEWAY = 'https://openapi.alipaydev.com/gateway.do?' if DEBUG else 'https://openapi.alipay.com/gateway.do?'

2.1视图类

from rest_framework_jwt.authentication import JSONWebTokenAuthentication
from rest_framework.permissions import IsAuthenticated
from rest_framework.viewsets import GenericViewSet
from rest_framework.mixins import CreateModelMixin
from .models import Order
from .serializer import PayOrderSerializer
from utils.response import APIResponse
class PayView(GenericViewSet,CreateModelMixin):
    queryset = Order.objects.all()
    serializer_class = PayOrderSerializer
    # 认证类，需要搭配权限类--->保证必须登录才能用
    # 只使用下面一个：（JSONWebTokenAuthentication）
    # 用户可以登录，也可以不登录，
    # 如果登录了后续能之间获取request.user
    # 如果没有登录，就获取不到
    authentication_classes = [JSONWebTokenAuthentication,]
    permission_classes = [IsAuthenticated,]

    # 重写create，控制返回的数据
    def create(self, request, *args, **kwargs):
        ser=self.get_serializer(data=request.data,context={'request':request})
        ser.is_valid(raise_exception=True)
        #保存
        self.perform_create(ser)
        # ser.save()  跟跟上面一样

        pay_url=ser.context.get('pay_url')

        return APIResponse(msg='订单创建成功',pay_url=pay_url)

2.2序列化类

from rest_framework import serializers
from course.models import Course
from rest_framework.exceptions import ValidationError
from utils.exception import MyException
from .models import Order,OrderDetail
import uuid
from django.conf import settings
from lib.al_pay import alipay,gateway
class PayOrderSerializer(serializers.ModelSerializer):
    # 用户传入的是courses:[1,2,3]==转成课程对象==》[obj1,obj2,obj3]
    # courses:[1,2,3]---->PrimaryKeyRelatedField--->指定queryset，会去queryset中过滤，主键为[1,2,3]的课程
    courses = serializers.PrimaryKeyRelatedField(queryset=Course.objects.all(), many=True, write_only=True)

    # user=serializers.PrimaryKeyRelatedField(queryset=User.objects.all(),many=False)
    class Meta:
        model = Order
        # 从前端传过来(订单号后端生成)
        '''
          {'subject':'python从入门到精通',
            total_amount:100,
            pay_type：1 (支付类型，目前只有支付宝)，
            courses:[1,2,3] 课程id号
         }
        '''
        fields = ['subject', 'total_amount', 'pay_type', 'courses']
        extra_kwargs = {
            'total_amount': {'required': True, }
        }

    def _check_price(self, attrs):
        courses = attrs.get('courses')
        total = 0
        for course in courses:
            total += course.price
        if not total == attrs.get('total_amount'):
            raise MyException('钱数不合法')

    def _get_order_no(self):
        order_no=str(uuid.uuid4())
        return order_no.replace('-','')

    def _get_user(self):
        user=self.context.get('request').user
        return user

    def _gen_pay_url(self,attrs,order_no):

        order_string = alipay.api_alipay_trade_page_pay(
            out_trade_no=order_no,
            total_amount=float(attrs.get('total_amount')), # 转成浮点型
            subject=attrs.get('subject'),
            # 写在配置文件中
            return_url=settings.RETURN_URL,
            notify_url=settings.NOTIFY_URL
        )
        return gateway+order_string

    def _pre_create(self,attrs,user,order_no):
        # 把用户，订单状态，订单号，写入attrs
        attrs['order_status']=0
        attrs['user']=user
        attrs['out_trade_no']=order_no



    def validate(self, attrs):
        # 1）订单总价校验
        self._check_price(attrs)
        # 2）生成订单号
        order_no=self._get_order_no()
        # 3）支付用户：request.user
        user=self._get_user()
        # 4）支付链接生成
        pay_url=self._gen_pay_url(attrs,order_no)
        self.context['pay_url']=pay_url
        # 5）入库(两个表)的信息准备（重写create方法）
        self._pre_create(attrs,user,order_no)
        return attrs

    def create(self, validated_data):
        # 存两个表
        # course需要存detail表
        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

2.3自定义异常类

'''=========>utils/exception.py'''
# 自定义异常类
from rest_framework.exceptions import  APIException

class MyException(APIException):
    status_code = 405
    default_detail = '校验出错了'
    default_code = '错误'

    def __init__(self, detail=None, code=None):
        super().__init__(detail=None, code=None)

2.4配置文件

'''========>settings/dev.py'''
# 支付宝回调地址

RETURN_URL = "http://127.0.0.1:8080/course/paysucess"
NOTIFY_URL = "http://127.0.0.1:8000/"  # 必须要用公网

2.5路由

# 使用相对导入
from . import views
# 自动生成路径
from rest_framework.routers import SimpleRouter
from .views import PayView
router = SimpleRouter()
# 127.0.0.1:8000/order/pay/
router.register('pay',PayView,'PayView')

from .views import PayView
urlpatterns = [
    # path('pay', PayView.as_view()),
]
urlpatterns+=router.urls  # 方式二

3.立即付款前端

views/ActualCourse.vue

buy_now(course) {
    //没有登录，提示请先登录
    let token = this.$cookies.get('token')
    if (token) {
        //发送请求获取支付链接
        this.$axios({
                method: 'post',
                url: this.$settings.base_url + '/order/pay/',
                data: {
                    subject: course.name,
                    total_amount: course.price,
                    pay_type: 1,
                    courses: [course.id,]
                },
                headers: {
                    authorization: 'jwt ' + token
                }
            }
        ).then(item => {
            console.log(item.data)
            if (item.data.status == 0) {
                open(item.data.pay_url, '_self')
            } else {
                this.$message({
                    message: item.data.msg
                })
            }
        })

    } else {
        this.$message({
            message: "请先登录"
        })
    }
}

4.支付成功get回调用户展示

4.1luffycity/ src / views / PaySucess.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参数
            let params = location.search.substring(1);  // 去除? => a=1&b=2
            let items = params.length ? params.split('&') : [];  // ['a=1', 'b=2']
            //逐个将每一项添加到args对象中
            for (let i = 0; i < items.length; i++) {  // 第一次循环a=1，第二次b=2
                let k_v = items[i].split('=');  // ['a', '1']
                //解码操作，因为查询字符串经过编码的
                if (k_v.length >= 2) {
                    // url编码反解
                    let 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({
                url: this.$settings.base_url + '/order/success/' + location.search,
                method: 'get',
            }).then(response => {
                console.log(response.data);
                if(!response.data.status==0){
                    console.log('暂未收到您的付款，请3s钟后再刷新该页面')
                }
            }).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>

4.2luffycity/ src / router / index.js

{
        path: '/course/paysucess',
        name: 'PaySucess',
        component: PaySucess,
    }

4.3get回调参数

# get回调，携带一些参数过来，展示课程购买成功
charset=utf-8&
out_trade_no=fe2baf0893d1403a89773e1e0151b4b3&
method=alipay.trade.page.pay.return&total_amount=99.00&
sign=C%2BtM1IqF9QBB7N86m6sEkJDoe8nvGKEymOPst%2FhrOTqZvZdyRTbr37a%2BAkhjV6Co6ot64mwJDVvlraJqevYltjXvWNovcViYAXL3JNZ%2FUoOo91PIsgFMJsTgXSy2R%2FyQ7NAhRhIhxGhNs5JNzTLt2JINKcZ%2FiUxzM%2Bkz3Z1EbjgB0JaDoNgRs9Wpwqb1VT%2FwZnyOAuoxOBwhij2SeP2ZC5qZfjQ8gzglSiUzbrQplbT3ZCGu5NHE1h42Zs8r3PkyxhghoK2T8UC7suI2u7l94713L8vP5hnegxkB79fNd4DQEZ4hnTV5nWDXjXw5RP9ob%2FQthMCTGssPS9%2Flme0%2F7w%3D%3D&
trade_no=2021011522001453300501032429&
auth_app_id=2016092000554611&version=1.0&
app_id=2016092000554611&
sign_type=RSA2&seller_id=2088102176466324&
timestamp=2021-01-15%2012%3A23%3A44

4.4后端接口

'''=====>order/urls.py'''
from .views import PaySuccess
path('success', PaySuccess.as_view()),
'''=====>order/views.py'''
class PaySuccess(APIView):
    def get(self,request,*args,**kwargs): # 咱们前端回调的
        out_trade_no=request.GET.get('out_trade_no')
        # 去数据库查询该订单是否已经支付完成
        order=Order.objects.filter(out_trade_no=out_trade_no,order_status=1).first()
        if order: # post回调回调完了，订单状态改了
            return APIResponse(msg='支付成功')
        else:
            return APIResponse(status=1,msg='暂未支付成功')

5.支付成功post回调修改订单状态

# lib/al_pay/init.py
from .pay import alipay,gateway

# order/views.py
from rest_framework.views import APIView
from utils.logging import get_logger
logger=get_logger('pay')

class PaySuccess(APIView):

    def post(self,request,*args,**kwargs): # 支付宝回调
        # 验签，通过，修改订单状态，返回给支付宝success
        try:
            result_data = request.data.dict()  # 一定不能忘
            out_trade_no = result_data.get('out_trade_no')
            signature = result_data.pop('sign') # 签名，必须验证签名
            from lib import al_pay
            result = al_pay.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)
                # 完成日志记录
                logger.warning('%s订单支付成功' % out_trade_no)
                return Response('success')  # 必须返回给支付宝，否则支付宝会一直回调
            else:
                logger.error('%s订单支付失败' % out_trade_no)
        except:
            pass
        return Response('failed')