【Django+Vue3 线上教育平台项目实战】购物车与订单模块的精简实现与数据安全策略

在这里插入图片描述

文章目录

前言
一、购物车模块
- 1.后端核心逻辑
- 2.前端页面代码
- 3.操作流程及演示
二、订单模块
- 1.订单模块模型类设计
- 1.展示订单信息
- - a.页面展示
  - b.前端核心代码
  - c.后端核心逻辑
- 2.订单是否使用优惠券与积分
- - a.页面展示
  - b.前端核心代码
- 3.订单支付方式
- - a.页面展示
  - b.前端核心代码
- 4.提交订单（幂等性、事务性）⭐
- 5.支付宝支付订单 ⭐
- - a.准备工作
  - b.前端获取支付链接地址
  - c.支付宝支付接口
  - d.操作流程及展示
- 6.取消订单⭐

前言

在构建线上教育平台的征途中，购物车与订单模块 是不可或缺的核心。本次，我们将聚焦于这两个模块的精简实现，包括购物车的添加、展示、修改功能，以及订单列表的展示、优惠券与积分的应用、支付宝支付的流程，特别是提交订单时，我们将深入探讨如何运用幂等性和事务性技术，确保订单数据的一致性和系统的稳定性，避免因网络延迟、重复点击等问题导致的订单异常。

一、购物车模块

点击购买，加入购物车，判断购物车是否存在此课程，如果存在则特使不能重复添加，不存在加入购物车。

1.后端核心逻辑

购物车表

字段：id、user(外键)、course(外键)、is_checked（是否选中）

添加购物车、获取购物车列表信息、修改购物车选中状态：

# 0.购物车获取、添加、修改选中状态
class CartView(APIView):
    # 获取购物车列表,传参 userid
    def get(self, request):
        # 获取参数
        userid = request.GET.get('userid')

        carts = CartsModel.objects.filter(user_id=userid)
        cartsSer = CartsSerializer(carts, many=True)
        carts_list = cartsSer.data

        return Response({"code":"200","carts":carts_list,"total":len(carts_list),"others":"待添加..."})

    # post-加入购物车
    def post(self, request):
        # 获取参数
        userid = request.data.get('userid')
        courseid = request.data.get('courseid')
        # 查询购物车表，是否已存在对应数据
        cart = CartsModel.objects.filter(user_id=userid, course_id=courseid).first()
        if cart is None:
            # 查询用户表课程是否存在
            ucourse = UserCourseModel.objects.filter(user_id=userid, course_id=courseid).first()
            if ucourse:
            	# 用户表已有此课程，不能重复购买
                return Response({"code":10010,"message":"该课程已经购买，不可重复购买！"})

            # 不存在，添加购物车数据
            # cartInfo = {"user": userid, "course": courseid}
            cartSer = CartsSerializer(data=request.data)
            if cartSer.is_valid():
                cartSer.save()
                return Response({"message":"添加购物车成功！","code":"200"})
            else:
                print(cartSer.errors)
                return Response({"message":cartSer.errors,"code":"1001"})
        else:
            # 购物车已存在此信息，不能重复添加购物车
            return Response({"message":"购物车已存在此信息，切勿重复添加！","code":"1001"})

    # 修改购物车状态
    def patch(self, request):
        # 获取参数-购物车id，购物车选中状态
        cartid = request.data.get('course_id')
        selected = request.data.get('selected')
        print(cartid,selected)
        CartsModel.objects.filter(id=cartid).update(is_checked=selected)

        return Response({"message":"patch方法修改状态成功！","code":"200"})

2.前端页面代码

购物车页面 src\views\Cart.vue：

<template>
  <div class="cart">
    <Header/>
    <div class="cart-main">
	  <!-- 购物车头部：我的购物车 -->
      <div class="cart-header">
        <div class="cart-header-warp">
          <div class="cart-title left">
            <h1 class="left">我的购物车</h1>
            <div class="left">
              共<span>{{cart.course_list.length}}</span>门，已选择<span>{{cart.selected_course_total}}</span>门
            </div>
          </div>
          <div class="right">
            <div class="">
              <span class="left"><router-link class="myorder-history" to="/myorder">我的订单列表</router-link></span>
            </div>
          </div>
        </div>
      </div>
	  <!-- 购物车体 -->
      <div class="cart-body" id="cartBody">
		<!-- 购物车体-标题栏 -->
        <div class="cart-body-title">
          <div class="item-1 l"><el-checkbox v-model="cart.checked">全选</el-checkbox></div>
          <div class="item-2 l"><span class="course">课程</span></div>
          <div class="item-3 l"><span>金额</span></div>
          <div class="item-4 l"><span>操作</span></div>
        </div>
		<!-- 购物车 表格 -->
        <div class="cart-body-table">
          <div class="item" v-for="(course_info, key) in cart.course_list">
              <div class="item-1">
                  <el-checkbox @change="change_select_course(course_info)" v-model="course_info.selected"></el-checkbox>
              </div>
              <div class="item-2">
                  <router-link :to="`/project/${course_info.course.id}`" class="img-box l">
                    <img :src="course_info.course.picurl">
                  </router-link>
                  <dl class="l has-package"> 
                    <dt>【{{course_info.course.name}}】 {{course_info.course.describe}}</dt>
                  </dl>
              </div>

              <div class="item-3">
                  <div class="price" v-if="course_info.course.price !== undefined">
                      <span class="discount-price"><em>￥</em><span>{{course_info.course.price.toFixed(2)}}</span></span><br>
                  </div>
                  <div class="price" v-else>
                      <div class="discount-price"><em>￥</em><span>{{course_info.course.price.toFixed(2)}}</span></div>
                  </div>
              </div>
              <div class="item-4"><el-icon @click="delete_course(key)" :size="26" class="close"><Close /></el-icon></div>
		  </div>

		  <!-- 结算 -->
          <div class="cart-body-bot fixed">
            <div class=" cart-body-bot-box">
              <div class="right">
                <div class="add-coupon-box">
                  <div class="li-left">
                    <div class="li-2">
                      <span class="topdiv w70">总计金额：</span>
                      <span class="price price-red w100">
                        <em>￥</em>
                        <span>{{cart.total_price.toFixed(2)}}</span>
                      </span>
                    </div>
                  </div>
                  <div class="li-3"><router-link to="/order" class="btn">去结算</router-link></div>
                </div>
              </div>
            </div>
          </div>

        </div>
      </div>
    </div>
    <Footer/>
  </div>
</template>

import cart from "../api/cart";

let token = sessionStorage.access_token || localStorage.access_token;
cart.list(token)

src\api\cart.js

import { reactive } from "vue";
import http from "../http";
import store from "../store";
import router from "../router";

const cart = reactive({
  course_list: [],  // 购物车中的商品列表
  total_price: 0,  // 购物车中的商品总价格
  selected_course_total: 0, // 购物车中被勾选商品的数量
  checked: false,  // 购物车中是否全选商品了

  add(course_id, token) {
    // 添加商品到购物车
    return http.post("/carts/cart/", {
      course_id: course_id
    }, {
      // 因为当前课程端添加课程商品到购物车必须登录，所以接口操作时必须发送jwt
      headers: {
        Authorization: "Bearer " + token,
      }
    })
  },
  list(token) {
    // 购物车商品列表
    
    // 本地浏览器获取userid
    const userid = localStorage.getItem('userid')
    return http.get("/carts/cart/?userid="+userid, {
      headers: {
        Authorization: "Bearer " + token,
      }
    }).then(response => {
      if (response.data.carts) {
        this.course_list = response.data.carts;
        this.calc();
      } else {
        ElMessage.error("当前购物车没有任何商品，请购物后再继续操作！");
        router.push("/");
      }
      return response
    })
  },
  calc() {
    // 计算当前购物车中的商品总价格和勾选商品的总数
    let total_price = 0;  // 临时设置一个变量用于累计总价格
    let select_total = 0; // 临时设置一个变量用于累计勾选商品的数量
    this.course_list.forEach(course => {

      // 累计当前购物车中有多少商品课程被勾选了
      if (course.is_checked) {
        console.log("累计当前购物车中有多少商品课程被勾选了********");
        // 统计当前课程的总价格
        total_price += parseFloat(course.course.price);
        select_total += 1;
      }
    })
    this.total_price = total_price;
    this.selected_course_total = select_total;
    this.checked = this.selected_course_total === this.course_list.length;
  },
  select(course_id, selected, token) {
    // 切换商品课程的勾选状态
    return http.patch("/carts/cart/", {
      course_id: course_id,
      selected: selected,
    }, {
      // 因为当前课程端添加课程商品到购物车必须登录，所以接口操作时必须发送jwt
      headers: {
        Authorization: "Bearer " + token,
      }
    }).then(response => {
      // 重新计算被勾选的商品数量
      this.calc();
    })

  },
  select_all(selected, token) {
    // 切换购物车对应商品课程的全选状态
    return http.put("/cart/", {
      selected,
    }, {
      headers: {
        Authorization: "Bearer " + token,
      }
    }).then(response => {
      this.calc();
    })
  },
  delete_course(key, token) {
    // 从购物车中删除商品课程
    let course_id = this.course_list[key].id;
    return http.delete("/cart/", {
      params: {
        course_id,  // course_id: course_id,的简写
      },
      headers: {
        Authorization: "Bearer " + token,
      }
    }).then(response => {
      this.course_list.splice(key, 1);
      // 通知vuex更新购物车中商品总数
      store.commit("set_cart_total", this.course_list.length);
      this.calc();
    })
  },
})

export default cart;

3.操作流程及演示

1. 加入购物车：

2.购物车页面：

3.点击去结算，跳转到订单页面

二、订单模块

确认订单页面

1.订单模块模型类设计

订单模块：订单表、订单详情表、优惠券表、用户优惠券表、积分记录表

# 1.订单表
class OrdersModel(models.Model):
    orderno = models.CharField(max_length=255,default="",primary_key=True)
    user = models.ForeignKey(UsersModel, on_delete=models.CASCADE, verbose_name='用户id')  # 注意：这里通常使用外键关联User模型
    pay_status = models.IntegerField(choices=((1, '生成'), (2, '已支付'), (3, '支付失败')), verbose_name='支付状态')
    pay_type = models.IntegerField(choices=((1, '支付宝'), (2, '微信'), (3, '网银')), verbose_name='支付类型')
    orders_status = models.IntegerField(
        choices=((1, '生成'), (2, '已支付'), (3, '支付失败'), (4, '退款'), (5, '评价'), (6, '已经完成'), (7, '取消')),
        verbose_name='订单状态')
    transaction = models.CharField(max_length=50, verbose_name='流水号')
    score = models.IntegerField(default=0,verbose_name="积分")
    coupon_id = models.IntegerField(default=0,verbose_name="优惠券id")
    coupon_money = models.IntegerField(default=0,verbose_name="优惠金额")
    total_money = models.IntegerField(default=0,verbose_name="总金额")
    pay_money = models.IntegerField(default=0,verbose_name="实际支付金额")
    def __str__(self):
        return f'订单ID: {self.id}'
    class Meta:
        verbose_name = '订单表'
        verbose_name_plural = '订单表'
        db_table = 'orders'

# 2.订单详情表
class OrdersDetailModel(models.Model):
    user = models.ForeignKey(UsersModel, on_delete=models.CASCADE)
    orders = models.ForeignKey(OrdersModel, on_delete=models.CASCADE)
    course = models.ForeignKey(CourseModel, on_delete=models.CASCADE)
    name = models.CharField(max_length=255)  # course被修改时，下订单时的属性不改变
    picurl = models.CharField(max_length=100, default='')# course被修改时，下订单时的属性不改变
    price = models.FloatField()# course被修改时，下订单时的属性不改变
    comment_status = models.IntegerField(default=0,verbose_name="评价状态")

    def __str__(self):
        return f'订单详情ID: {self.id}'

    class Meta:
        verbose_name = '订单详情表'
        verbose_name_plural = '订单详情表'
        db_table = "order_detail"

# 3.优惠券表：id、name、man满、jian减、开始时间、结束时间、总张数、已发
class CouponModel(models.Model):
    name = models.CharField(max_length=255,default="优惠券默认名")
    coupon_full = models.IntegerField(verbose_name="价格满-",default=0)
    coupon_reduce = models.IntegerField(verbose_name="价格减少-",default=0)
    start_time = models.DateTimeField(verbose_name="开始时间")
    end_time = models.DateTimeField(verbose_name="结束时间")
    count = models.IntegerField(verbose_name="优惠券总量",default=100)
    count_issued = models.IntegerField(verbose_name="已发出的优惠券数量",default=0)
    def __str__(self):
        return self.name
    class Meta:
        verbose_name = "优惠券表"
        verbose_name_plural = "优惠券表"
        db_table = "coupon"

# 4.用户优惠券表：user、优惠券、name、man满、jian减、开始时间、结束时间、使用状态
class UserCouponModel(models.Model):
    user = models.ForeignKey(UsersModel, on_delete=models.CASCADE)
    coupon = models.ForeignKey(CouponModel, on_delete=models.CASCADE)
    name = models.CharField(max_length=255,default="用户优惠券的默认名")
    coupon_full = models.IntegerField(verbose_name="价格满-",default=0)
    coupon_reduce = models.IntegerField(verbose_name="价格减少-",default=0)
    start_time = models.DateTimeField(verbose_name="开始时间")
    end_time = models.DateTimeField(verbose_name="结束时间")
    status = models.CharField(max_length=100,default="未使用")
    def __str__(self):
        return self.name
    class Meta:
        verbose_name = "用户优惠券表"
        verbose_name_plural = "用户优惠券表"
        db_table = "usercoupon"

# 5.积分记录表
class ScoreRecordModel(models.Model):
    user = models.ForeignKey(UsersModel, on_delete=models.CASCADE)
    types = models.IntegerField(default=1) #1+积分 2-积分
    score = models.IntegerField(default=0)
    descp = models.CharField(max_length=255, default='')
    def __str__(self):
        return self.descp
    class Meta:
        verbose_name = "积分记录表"
        verbose_name_plural = "积分记录表"
        db_table = "score_record"

1.展示订单信息

a.页面展示

购物车页面点击去结算后，进入订单页面

b.前端核心代码

订单页面 — 展示订单信息 src\views\Order.vue

<!-- 订单中展示课程信息 -->
<div class="item" v-for="course_info in order.selected_course_list">
	<!-- {{course_info}} -->
   <div class="item-2">
       <router-link :to="`/project/${course_info.id}`" class="img-box l"><img :src="course_info.course.picurl"></router-link>
       <dl class="l has-package">
         <dt>【{{course_info.course.name}}】{{course_info.course.describe}} </dt>
       </dl>
   </div>
   <div class="item-3">
       <div class="price">
           <p class="discount-price"><em>￥</em><span>{{course_info.course.price.toFixed(2)}}</span></p>
       </div>
   </div>
</div>

src\api\order.js

  // 1.获取购物车中的勾选商品列表
  get_selected(token) {
    return http.get("/carts/preorder/?userid=1", {
      headers: {
        Authorization: "Bearer " + token,
      }
    }).then(response => {
      console.log("response.data-----------获取购物车中的勾选商品列表---------------")
      console.log(response.data)
      if (response.data.cart) {
        this.selected_course_list = response.data.cart;
        this.calc_cart();
        // this.get_coupon_list(token);
        // 此用户拥有的优惠券
        this.coupon_list = response.data.coupon
        // 总积分
        this.has_credit = response.data.score;
        // 把用户拥有的积分与本次下单的最大对换积分进行比较，判断用户可以使用的最大数量积分
        if (this.has_credit < this.max_use_credit) {
          this.max_use_credit = this.has_credit
        }

      } else {
        ElMessage.error("当前购物车没有任何商品，请购物后再继续操作！");
        router.push("/");
      }
      return response
    })
  },

c.后端核心逻辑

cart/views.py

# 1.订单前，信息
class PreOrderView(APIView):
    def get(self, request):
        # 获取userid
        userid = request.GET.get('userid')
        # 查询购物车中已经选中的记录
        cart = CartsModel.objects.filter(user_id=userid,is_checked=True).all()
        cartSer = CartsSerializer(cart, many=True)
        # 查询用户的总积分
        user = UsersModel.objects.filter(id=userid).first()
        score = user.points
        # 查询优惠券
        coupons = UserCouponModel.objects.filter(user_id=userid)
        couponsSer = UserCouponSerializer(coupons, many=True)
        coupons_list = couponsSer.data
        return Response({"code":"200","cart":cartSer.data,"score":score,"coupon":coupons_list})

2.订单是否使用优惠券与积分

a.页面展示

在这里插入图片描述

b.前端核心代码

src\views\Order.vue

<!-- 优惠券/积分 -->
<div class="coupons-box">
  <div class="coupon-title-box">
    <p class="coupon-title">
      使用优惠券/积分
        <span v-if="order.use_coupon" @click="order.use_coupon=!order.use_coupon"><svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 1024 1024" data-v-394d1fd8=""><path fill="currentColor" d="M831.872 340.864 512 652.672 192.128 340.864a30.592 30.592 0 0 0-42.752 0 29.12 29.12 0 0 0 0 41.6L489.664 714.24a32 32 0 0 0 44.672 0l340.288-331.712a29.12 29.12 0 0 0 0-41.728 30.592 30.592 0 0 0-42.752 0z"></path></svg></span>
        <span v-else @click="order.use_coupon=!order.use_coupon"><svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 1024 1024" data-v-394d1fd8=""><path fill="currentColor" d="m488.832 344.32-339.84 356.672a32 32 0 0 0 0 44.16l.384.384a29.44 29.44 0 0 0 42.688 0l320-335.872 319.872 335.872a29.44 29.44 0 0 0 42.688 0l.384-.384a32 32 0 0 0 0-44.16L535.168 344.32a32 32 0 0 0-46.336 0z"></path></svg></span>
    </p>
  </div>
  <!-- 优惠券、积分选项卡 -->
  <transition name="el-zoom-in-top">
  <div class="coupon-del-box" v-if="order.use_coupon">
    <div class="coupon-switch-box">
      <div class="switch-btn ticket" :class="{'checked': order.discount_type===0}" @click="order.discount_type=0">优惠券 ({{order.coupon_list.length}})<em><i class="imv2-check"></i></em></div>
      <div class="switch-btn code" :class="{'checked': order.discount_type===1}" @click="order.discount_type=1">积分 ({{order.has_credit}})<em><i class="imv2-check"></i></em></div>
    </div>
	<!-- 优惠券渲染 -->
    <div class="coupon-content ticket" v-if="order.discount_type===0">
      <p class="no-coupons" v-if="order.coupon_list.length<1">暂无可用优惠券</p>
      <div class="coupons-box" v-else>
       <div class="content-box">
        <ul class="nouse-box">
         <li class="l" :class="{select: order.select === key}" @click="order.select = (order.select === key?-1:key)" v-for="(coupon,key) in order.coupon_list" :key="key">
          <div class="detail-box more-del-box">
           <div class="price-box">
            <p class="coupon-price l" v-if="coupon.discount === '1'"> ￥{{Math.abs(coupon.sale)}} </p>
            <p class="coupon-price l" v-if="coupon.discount === '2'"> {{coupon.sale.replace("*0.","")}}折 </p>
            <p class="use-inst l" v-if="coupon.condition>0">满{{coupon.coupon_full}}元可用</p>
            <p class="use-inst l" v-else>任意使用</p>
           </div>
           <div class="use-detail-box">
            <div class="use-ajust-box">适用于：{{coupon.name}}</div>
            <div class="use-ajust-box">有效期：{{coupon.start_time.split("T")[0].replaceAll("-",".")}}-{{coupon.end_time.split("T")[0].replaceAll("-",".")}}</div>
           </div>
          </div>
         </li>
        </ul>
       </div>
      </div>
    </div>
	<!-- 积分渲染 -->
    <div class="coupon-content code" v-else>
        <div class="input-box">
          <el-input-number v-model="order.credit" :step="1" :min="0" :max="order.max_use_credit"></el-input-number>
          <a class="convert-btn" @click="conver_credit">兑换</a>
          <a class="convert-btn" @click="max_conver_credit">最大积分兑换</a>
        </div>
        <div class="converted-box">
          <p>使用积分:<span class="code-num">200</span></p>
          <div v-for="course_info in order.selected_course_list">
            <p class="course-title" v-if="course_info.credit>0">
              课程:<span class="c_name">{{course_info.course.name}}</span>
              <span class="discount-cash">{{course_info.credit}}积分抵扣:<em>{{parseInt(course_info.credit / order.credit_to_money)}}</em>元</span>
            </p>
          </div>

        </div>
        <p class="error-msg">本次订单最多可以使用{{order.max_use_credit}}积分，您当前拥有{{order.has_credit}}积分。({{order.credit_to_money}}积分=1元)</p>
        <p class="tip">说明：每笔订单只能使用一次积分，并只有在部分允许使用积分兑换的课程中才能使用。</p>
      </div>
  </div>
  </transition>
</div>

  // 1.获取购物车中的勾选商品列表
  get_selected(token) {
    return http.get("/carts/preorder/?userid=1", {
      headers: {
        Authorization: "Bearer " + token,
      }
    }).then(response => {
      console.log("response.data-----------获取购物车中的勾选商品列表---------------")
      console.log(response.data)
      if (response.data.cart) {
        console.log(111111);
        this.selected_course_list = response.data.cart;
        this.calc_cart();
        // 此用户拥有的优惠券
        this.coupon_list = response.data.coupon
        // 总积分
        this.has_credit = response.data.score;
        // 把用户拥有的积分与本次下单的最大对换积分进行比较，判断用户可以使用的最大数量积分
        if (this.has_credit < this.max_use_credit) {
          this.max_use_credit = this.has_credit
        }

      } else {
        ElMessage.error("当前购物车没有任何商品，请购物后再继续操作！");
        router.push("/");
      }
      return response
    })
  },
  // 计算购物车内商品价格
  calc_cart() {
    // 计算本次下单的所有商品的相关价格
    let original_total_price = 0;  // 所有的课程的原价总价格
    let real_total_price = 0;      // 所有的课程的实付总价格
    // let max_use_credit = 0;        // 所有的课程的累计可以最大兑换积分
    this.selected_course_list.forEach(course => {
      original_total_price += course.course.price;
      real_total_price += course.course.price;
    })
    this.total_price = original_total_price;
    this.real_price = real_total_price;
    this.max_use_credit = this.real_price;
  },

3.订单支付方式

a.页面展示

在这里插入图片描述

b.前端核心代码

<!-- 选择支付方式 -->
<div class="pay-type">
  <p class="title">选择支付方式</p>
  <div class="list">
    <img :src="order.pay_type==0?'/src/assets/alipay2.png':'/src/assets/alipay1.png'" @click="order.pay_type=1" alt="支付宝">
    <img :src="order.pay_type==1?'/src/assets/wechat2.png':'/src/assets/wechat1.png'" @click="order.pay_type=2" alt="微信">
    <img :src="order.pay_type==2?'/src/assets/yue2.png':'/src/assets/yue1.png'"  @click="order.pay_type=3" alt="余额">
  </div>
</div>

4.提交订单（幂等性、事务性）⭐

在提交订单时，可能会遇到如下问题：

1.解决网络慢导致的频繁点击生成无效订单问题

问题描述： 由于网络延迟，用户可能在短时间内频繁点击生成订单按钮，导致生成多个无效订单。
解决方案： 通过 接口幂等性操作 来避免重复订单的生成。
实现流程：
1.前端准备： 在确认订单页面的onMounted生命周期钩子中，调用后端接口请求一个唯一的标识符（UUID）。
2.后端生成UUID： 后端接口接收到请求后，使用uuid.uuid4().hex()生成一个唯一的UUID，并将其存储在Redis中（可以设置一个合理的过期时间，如几分钟），然后将这个UUID返回给前端。
3.前端携带UUID生成订单： 用户点击生成订单按钮时，将之前获取的UUID作为参数一同发送到后端。
4.后端验证UUID： 后端接收到订单生成请求时，首先检查Redis中是否存在该UUID。
如果存在，说明是重复请求，直接返回“订单已生成，请勿重复操作”的提示，并从Redis中删除该UUID（可选，视业务逻辑而定）。
如果不存在，则认为是有效请求，继续订单生成流程，并在订单生成成功后，确保不将UUID存入Redis（因为是单次有效）。

2.解决订单与订单详情写入不一致问题

问题描述： 在生成订单的过程中，订单表已成功写入数据，但在写入订单详情表时发生错误，导致订单详情缺失，用户支付成功后可能无法获得相应的课程。
解决方案： 使用数据库事务来保证订单和订单详情的一致性。
实现流程：
1.引入事务支持： 确保你的数据库框架或ORM支持事务处理。例如，在Django中可以使用transaction模块，在SQLAlchemy中也有相应的事务管理。
2.开启事务： 在生成订单的接口逻辑中，首先开启一个数据库事务。这通常在数据库操作开始前进行。
3.执行订单和订单详情写入： 在事务的上下文中，先执行订单表的写入操作，然后执行订单详情表的写入操作。
4.异常处理与事务回滚： 如果在写入订单详情表时发生异常，立即捕获该异常，并执行事务回滚操作，以确保订单表中的数据也被撤销。这样可以保证数据库的一致性和完整性。
5.提交事务： 如果所有操作都成功完成，没有发生异常，则提交事务，使所有更改永久生效。

# 2.订单uid
class OrderKeysView(APIView):
    def get(self, request):
        userid = request.GET.get('userid')
        uid = uuid.uuid1().hex
        key = str(uid) + str(userid)
        r.set_str(key,'111')
        return Response({"code":"200","orderuid":key})

import datetime
from django.db import transaction
# 3.提交订单
class OrderView(APIView):
    @transaction.atomic()
    def post(self, request):
        # 获取参数：用户id、支付方式...
        userid = request.data.get('userid')
        pay_type = request.data.get('pay_type')
        credit = request.data.get('credit') #// 当前用户选择抵扣的积分
        user_coupon_id = request.data.get('user_coupon_id')
        orderuid = request.data.get('orderuid')
        print("验证接口幂等性1")
        # ***验证接口幂等性***
        value = r.get_str(orderuid)
        if value:
            #删除
            r.delete_str(orderuid)
            # 生成订单号
            print("验证接口幂等性2")
            orderno = datetime.datetime.strftime(datetime.datetime.now(), '%Y%m%d%H%M%S')+str(userid)+str(random.randint(10000,99999))
            print("orderno" + str(orderno))
            # 开启事务
            # 创建保存点
            save_id = transaction.savepoint()
            try:

                # 判断优惠券id，若存在查询用户优惠券表
                couponmoney = 0
                if int(user_coupon_id)>0:
                    user_coupon = UserCouponModel.objects.filter(id=user_coupon_id).first()
                    user_coupon.status = "已使用"
                    couponmoney = user_coupon.coupon_reduce #价格减少coupon_reduce
                    user_coupon.save()

                # 添加订单表
                orders = OrdersModel.objects.create(user_id=userid,pay_type=pay_type,score=credit,coupon_id=user_coupon_id,coupon_money=0,transaction=orderno,pay_status=2,orders_status=1)
                # 根据用户查询选中购物车
                total_money = 0
                pay_money = 0
                # 遍历购物车，写入订单表，计算出总价格，删除购物车中商品
                carts = CartsModel.objects.filter(user_id=userid,is_checked=True).all()
                for cart in carts:
                    total_money += float(cart.course.price)
                    # 添加订单详情表
                    OrdersDetailModel.objects.create(user_id=userid,orders_id=orders.id,course_id=cart.course.id,name=cart.course.name,picurl = cart.course.picurl,price = cart.course.price)
                    # 删除购物车表
                    # CartsModel.objects.filter(id=cart.id).delete()

                # 更新订单总价格---
                orders.total_money = total_money
                coupon = int(couponmoney) + int(credit) #总优惠金额
                if total_money > coupon:
                    orders.pay_money = total_money - coupon
                else:
                    orders.pay_money = 0

                orders.save()

                #如果使用积分，更新积分记录表，更新用户表中的总积分
                if int(credit) > 0:
                    user = UsersModel.objects.filter(id=userid).first()
                    user.points -= int(credit) #更新用户表总积分
                    user.save()
                    ScoreRecordModel.objects.create(user_id=userid,types=2,score=int(credit),descp="购买订单"+orderno+"时所用积分")

                # 提交事务

                # zset --- 把订单号 + score 加入队列
                times = int(time.time())+1800
                r.zset_zadd("orderno",times,orderno)

                transaction.savepoint_commit(save_id)
                return Response({"code":"200"})
            except:
                # 失败回滚
                transaction.savepoint_rollback(save_id)
                return Response({"code": "1001", "message": "订单生成失败！"})

5.支付宝支付订单 ⭐

支付宝开放平台：https://open.alipay.com/

操作流程：
1.支付宝开放平台注册账号，注册应用
2.在应用中配置回调地址，生成公钥私钥，在支付宝上配置
3.获取支付链接
4.点击链接跳转到支付宝平台，用测试账号登录，输入支付密码。
5.支付成功后支付宝会根据配置的回调地址回调接口
6.在接口中进行业务的处理

获取参数
验证签名
更新订单表中订单状态、支付状态、流水号

a.准备工作

1.登录后，注册沙箱应用

2.配置回调地址以及应用公钥

3.通过本地公钥，获得支付宝应用公钥

4.在项目中配置

5.支付宝支付工具类

tools/pay.py
tools/common.py - - - get_alipay()

# tools/pay.py
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 urllib.parse import urlparse, parse_qs
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 query_pay(self, out_trade_no,return_url=None, **kwargs):
        biz_content = {
            "out_trade_no": out_trade_no,
           
            # "product_code": "FAST_INSTANT_TRADE_PAY",
            # "qr_pay_mode":4
        }

        biz_content.update(kwargs)
        data = self.build_body("alipay.trade.query", biz_content, self.return_url)
        return self.sign_data(data)
    
    #转账接口
    def deposit(self,out_biz_no,trans_amount,title,payee_info,return_url=None,**kwargs):

          biz_content = {

              "out_biz_no":out_biz_no,
              "trans_amount":trans_amount,
              "biz_scene":"DIRECT_TRANSFER",
              "product_code":"TRANS_ACCOUNT_NO_PWD",
              "order_title":title,
              "payee_info":payee_info
          }

          biz_content.update(kwargs)
          data = self.build_body("alipay.fund.trans.uni.transfer", biz_content, self.return_url)
          return self.sign_data(data)

    #转账接口
    def refund(self,trade_no,refund_amount,return_url=None,**kwargs):

          biz_content = {
              "trade_no":trade_no,
              "refund_amount":refund_amount,
          }

          biz_content.update(kwargs)
          data = self.build_body("alipay.trade.refund", 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)

        # 将字典类型的数据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):
        # 开始计算签名
        key = self.app_private_key
        signer = PKCS1_v1_5.new(key)
        signature = signer.sign(SHA256.new(unsigned_string))
        # base64 编码，转换为unicode表示并移除回车
        sign = encodebytes(signature).decode("utf8").replace("\n", "")
        return sign

    def _verify(self, raw_content, signature):
        # 开始计算签名
        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)

# tools/common.py
from .pay import AliPay
def get_alipay():
    # 初始化支付实例

    # 公共参数
    # 沙箱环境地址：https://openhome.alipay.com/platform/appDaily.htm?tab=info
    app_id = "1111111111111"  # APPID （沙箱应用）

    # 支付完成后，支付偷偷向这里地址发送一个post请求，识别公网IP,如果是 192.168.20.13局域网IP ,支付宝找不到，def page2() 接收不到这个请求
    notify_url = "http://127.0.0.1:8000/carts/pay/"

    # 支付完成后，跳转的地址。
    return_url = "http://127.0.0.1:8000/carts/pay/"

    merchant_private_key_path = "tools/keys/private.txt"  # 应用私钥
    alipay_public_key_path = "tools/keys/public.txt"  # 支付宝公钥

    alipay = AliPay(
        appid=app_id,
        app_notify_url=notify_url,
        return_url=return_url,
        app_private_key_path=merchant_private_key_path,
        alipay_public_key_path=alipay_public_key_path,  # 支付宝的公钥，验证支付宝回传消息使用，不是你自己的公钥
        debug=True,  # 默认False,
    )
    return alipay

b.前端获取支付链接地址

  get_pay_link(order_id) {
    // 获取支付宝支付链接地址
    return http.post("/carts/pay/", {
	    order:this.order,
	    pay_money:this.pay_money
    }).then(response => {
      window.open(response.data, "_blank");
    })
  },

c.支付宝支付接口

# 4.支付宝接口 支付
class PayView(APIView):
    def post(self, request):
        # 获取订单号
        orderno = 10
        pay_money = 100
        pay = get_alipay()
        query_params = pay.direct_pay(
            subject="订单支付",  # 商品简单描述
            out_trade_no=str(orderno),  # 用户购买的商品订单号（每次不一样） 20180301073422891
            total_amount=float(pay_money),  # 交易金额(单位: 元 保留俩位小数)
        )
        payUrl = "https://openapi-sandbox.dl.alipaydev.com/gateway.do?{0}".format(query_params)
        return Response({"url":payUrl})
        
    def get(self, request):
        # 获取参数
        data = request.GET
        print("data----------" + str(data))
        rdata = {k:v for k,v in data.items()}
        print("rdata++++++++++++" + str(rdata))
        # 验证签名
        sign = rdata.pop('sign')

        pay = get_alipay()
        flag = pay.verify(rdata,sign)

        print(flag)
        # 业务逻辑
        if flag:
            # 更新订单表
            orderno = data['out_trade_no']
            # 支付宝流水号
            transaction_no = data['trade_no']
            # 调用支付宝查询接口查询
            flag = True
            if flag == True:
                # 通过订单号查询订单表
                orders = OrdersModel.objects.filter(orderno=orderno).first()
                orders.status=2 #状态
                orders.orders_status = 2 #支付状态
                orders.transaction_no = transaction_no
                orders.save()
                # 把成功的加入到成功队列中
                r.list_push("ordersuccess",orderno)
                return HttpResponseRedirect("http://127.0.0.1:3000/")
            else:
                orders = OrdersModel.objects.filter(orderno=orderno).first()
                orders.status=3
                orders.orders_status = 3
                orders.transaction_no = transaction_no
                orders.save()
                # 把成功的加入到成功队列中
                r.list_push("orderfail",orderno)
                return HttpResponseRedirect("http://127.0.0.1:3000/error")