0
0

Django+DRF+Vue+Mysql+Redis OUC软件工程作业

交作业啦

前端：html+css+js+Vue+Element-ui

后端：Django+DRF+celery+haystack+django_crontab

数据库：Mysql+Redis

一些技术和功能：

  • 为session、短信验证码、用户浏览记录、购物车、异步任务队列 创建缓存
  • whoosh搜索引擎
  • 异步任务队列 用于发送邮件、短信
  • 定时任务 定时更新静态页面、刷新日志等
  • 腾讯云短信服务
  • chatGPT客服(New)
  • 支付宝沙盒
  • 客服群聊
  • 数据库乐观锁
  • 页面静态化
  • JWT认证
  • 发货地址、不同的商品的详情、售后服务等都可以通过后台设置
  • 自选CPU、内存、显卡
  • "点击此处确认验证邮箱"
  • 对于未登录的用户，购物车数据使用浏览器cookie保存 登陆后合并购物车 对于已登录的用户，购物车数据在后端使用Redis保存

效果如下：

代码过多，这里只展示一部分，欢迎感兴趣的小伙伴一起讨论学习：

  1. import os
  2. from alipay import AliPay
  3. from rest_framework import status
  4. from rest_framework.permissions import IsAuthenticated
  5. from rest_framework.response import Response
  6. from rest_framework.views import APIView
  8. from MyApps.orders.models import OrderInfo
  9. from MyApps.payment.models import Payment
  10. from django.conf import settings
  12. class PaymentView(APIView):
  13.     """
  14.     支付
  15.     """
  16.     permission_classes = (IsAuthenticated,)
  18.     def get(self, request, order_id):
  19.         """
  20.         获取支付链接
  21.         """
  22.         # 判断订单信息是否正确
  23.         try:
  24.             order = OrderInfo.objects.get(order_id=order_id, user=request.user,
  25.                                           pay_method=OrderInfo.PAY_METHODS_ENUM["ALIPAY"],
  26.                                           status=OrderInfo.ORDER_STATUS_ENUM["UNPAID"])
  27.         except OrderInfo.DoesNotExist:
  28.             return Response({'message': '订单信息有误'}, status=status.HTTP_400_BAD_REQUEST)
  30.         # 构造支付宝支付链接地址
  31.         alipay = AliPay(
  32.             appid=settings.ALIPAY_APPID,
  33.             app_notify_url=None,  # 默认回调url
  34.             app_private_key_string=open(os.path.join(os.path.dirname(os.path.abspath(__file__)), "keys",
  35.                                                      "app_private_key.pem")).read(),
  36.             # app_private_key_string=settings.app_private_key_string,
  37.             alipay_public_key_string=open(os.path.join(os.path.dirname(os.path.abspath(__file__)), 'keys',
  38.                                                        'alipay_public_key.pem')).read(),
  39.             # alipay_public_key_string=settings.alipay_public_key_string,  # 支付宝的公钥，验证支付宝回传消息使用，不是你自己的公钥,
  40.             sign_type="RSA2",  # RSA 或者 RSA2
  41.             debug=settings.ALIPAY_DEBUG  # 默认False
  42.         )
  44.         order_string = alipay.api_alipay_trade_page_pay(
  45.             out_trade_no=order_id,
  46.             total_amount=str(order.total_amount),
  47.             subject="联想商城%s" % order_id,
  48.             return_url="http://localhost:63342/BMyStore/front_end_pc/pay_success.html",
  49.         )
  50.         # 需要跳转到https://openapi.alipay.com/gateway.do? + order_string
  51.         # 拼接链接返回前端
  52.         alipay_url = settings.ALIPAY_URL + "?" + order_string
  53.         return Response({'alipay_url': alipay_url})
  55. # 支付宝回调函数接口 put /payment/status/?支付宝参数
  56. class PaymentStatusView(APIView):
  57.     def put(self, request):
  58.         # 接收参数，效验参数
  59.         # 构造支付宝支付链接地址
  60.         alipay_req_data = request.query_params
  61.         if not alipay_req_data:
  62.             return Response({"message": "缺少参数"}, status=status.HTTP_400_BAD_REQUEST)
  63.         alipay_req_dict = alipay_req_data.dict()
  64.         sign = alipay_req_dict.pop("sign")
  66.         alipay = AliPay(
  67.             appid=settings.ALIPAY_APPID,
  68.             app_notify_url=None,  # 默认回调url
  69.             app_private_key_string=open(os.path.join(os.path.dirname(os.path.abspath(__file__)),
  70.                                                      "keys/app_private_key.pem")).read(),
  71.             alipay_public_key_string=open(os.path.join(os.path.dirname(os.path.abspath(__file__)),
  72.                                                        "keys/alipay_public_key.pem")).read(),
  73.             # 支付宝的公钥，验证支付宝回传消息使用，不是你自己的公钥,
  74.             sign_type="RSA2",  # RSA 或者 RSA2
  75.             debug=settings.ALIPAY_DEBUG  # 默认False
  76.         )
  78.         result = alipay.verify(alipay_req_dict, sign)
  79.         # 保存数据，保存支付结果数据
  80.         if result:
  81.             order_id = alipay_req_dict.get("out_trade_no")
  82.             trade_id = alipay_req_dict.get("trade_no")
  83.             # 修改订单状态
  84.             Payment.objects.create(
  85.                 order_id=order_id,
  86.                 trade_id=trade_id
  87.             )
  88.             OrderInfo.objects.filter(order_id=order_id).update(status=OrderInfo.ORDER_STATUS_ENUM["UNCOMMENT"])
  89.             print('支付成功！')
  90.             return Response({"trade_id": trade_id})
  92.         return Response({"message": "参数有误"}, status=status.HTTP_400_BAD_REQUEST)
  1. from django_filters.rest_framework import DjangoFilterBackend
  2. from drf_haystack.viewsets import HaystackViewSet
  3. from rest_framework.filters import OrderingFilter
  4. from rest_framework.generics import ListAPIView, CreateAPIView, DestroyAPIView, RetrieveAPIView
  5. from rest_framework.pagination import PageNumberPagination
  6. from rest_framework.views import APIView
  7. from rest_framework.response import Response
  8. from rest_framework.viewsets import GenericViewSet
  9. from MyApps.goods import models
  10. from MyApps.goods.models import SKU, GoodsCategory, Collect, Comment1, SKUImage
  11. from MyApps.goods.serializers import SKUSerializer, SKUIndexSerializer, CollectSerializer, Comment1Serializer
  12. from rest_framework.permissions import IsAuthenticated
  13. from django_redis import get_redis_connection
  14. from rest_framework.filters import BaseFilterBackend
  15. from django_filters import FilterSet, filters
  17. class SKUListView(ListAPIView):
  18.     """
  19.     sku列表数据
  20.     """
  21.     serializer_class = SKUSerializer
  22.     # 分页与排序
  23.     filter_backends = (OrderingFilter,)
  24.     ordering_fields = ("create_time", "price", "sales")
  26.     def get_queryset(self):
  27.         category_id = self.kwargs["category_id"]
  28.         return SKU.objects.filter(category_id=category_id, is_launched=True)
  30. class SKUSearchViewSet(HaystackViewSet):
  31.     """
  32.     SKU搜索
  33.     """
  34.     index_models = [SKU]
  35.     serializer_class = SKUIndexSerializer
  37.     # 分页与排序
  38.     # filter_backends = (OrderingFilter,)
  40.     def list(self, request, *args, **kwargs):
  41.         queryset = self.filter_queryset(self.get_queryset())
  43.         ordering_fields = ("create_time", "price", "sales")
  44.         od = request.query_params.get("ordering", None)
  45.         if od in ordering_fields:
  46.             queryset = queryset.order_by(od)
  48.         page = self.paginate_queryset(queryset)
  49.         if page is not None:
  50.             serializer = self.get_serializer(page, many=True)
  51.             return self.get_paginated_response(serializer.data)
  53.         serializer = self.get_serializer(queryset, many=True)
  54.         return Response(serializer.data)
  56. class CategoriesView(APIView):
  57.     """获取当前分类信息"""
  59.     def get(self, request, pk):
  60.         """
  61.         1.获取前端数据
  62.         2. 查询当前三级分类信息
  63.         3.通过三级分类信息获取一二集分类
  64.         4. 返回
  65.         :param request:
  66.         :return:
  67.         """
  68.         cat3 = GoodsCategory.objects.get(id=pk)  # 获取三级
  69.         cat2 = cat3.parent  # 自关联获取二级,
  70.         cat1 = cat2.parent  # 自关联获取一级
  72.         # 返回数据
  73.         return Response({
  74.             "cat1": cat1.name,
  75.             "cat2": cat2.name,
  76.             "cat3": cat3.name
  77.         })
  79. class GetGoodsView(APIView):
  80.     """获取当前分类信息"""
  82.     def get(self, request, pk):
  83.         SKU1 = models.SKU.objects.filter(pk=pk).first()
  84.         comment_count = SKU1.goods.comment_count
  85.         collect_count = SKU1.goods.collect_count
  86.         goods_id = SKU1.goods_id
  88.         # 返回数据
  89.         return Response({"goods_id": goods_id, 'comment_count': comment_count, 'collect_count': collect_count})
  91. class IsCollectedView(APIView):
  93.     def post(self, request):
  94.         print(request.data)
  95.         sku_id = int(request.data.get("sku_id", -5))
  96.         user_id = request.data.get("user_id", 1)
  98.         if sku_id == -5:
  99.             return Response({"res_data": 0})
  101.         collecs = models.Collect.objects.filter(user_id=user_id)
  102.         sku_id_list = [i.sku_id for i in collecs]
  103.         print(sku_id in sku_id_list)
  104.         res = 0
  105.         if sku_id in sku_id_list:
  106.             res = 1
  107.         return Response({"res_data": res})
  109. ##################################
  110. class MyPageNumberPagination(PageNumberPagination):
  111.     page_size_query_param = 'size'
  112.     page_size = 10
  113.     max_page_size = 100
  115. class CommentFilterSet(FilterSet):
  116.     goods = filters.NumberFilter(field_name='goods', required=True)
  118.     class Meta:
  119.         model = models.Comment1
  120.         fields = ['goods']
  122. class Comment1View(ListAPIView, GenericViewSet):
  123.     filter_backends = [DjangoFilterBackend]
  124.     filterset_class = CommentFilterSet
  126.     queryset = models.Comment1.objects
  127.     serializer_class = Comment1Serializer
  129. ################################################
  130. class SelfFilterBackend(BaseFilterBackend):
  131.     def filter_queryset(self, request, queryset, view):
  132.         return queryset.filter(user=request.user)
  134. class CollectViewSet(ListAPIView, CreateAPIView, GenericViewSet):
  135.     permission_classes = [IsAuthenticated]
  136.     filter_backends = [SelfFilterBackend, DjangoFilterBackend]
  137.     pagination_class = MyPageNumberPagination
  138.     # 当前登录用户的所有收藏记录
  139.     queryset = models.Collect.objects
  140.     serializer_class = CollectSerializer
  142.     def perform_create(self, serializer):
  143.         user = self.request.user
  144.         instance = Collect.objects.filter(user=user, **serializer.validated_data).first()
  145.         if not instance:
  146.             instance = serializer.save(user=user)
  147.             instance.sku.goods.collect_count += 1
  148.             instance.sku.goods.save()
  149.             return Response({"message": 'ok', 'data': {'active': True}})
  150.         else:
  151.             instance.delete()
  152.             instance.sku.goods.collect_count -= 1
  153.             instance.sku.goods.save()
  154.             return Response({"message": 'ok', 'data': {'active': False}})
  156. class HotSkus(ListAPIView):
  157.     serializer_class = SKUSerializer
  158.     # 分页与排序
  159.     filter_backends = (OrderingFilter,)
  160.     ordering_fields = ("sales", "create_time", "price")
  162.     def get_queryset(self):
  163.         category_id = self.kwargs["category_id"]
  164.         return SKU.objects.filter(category_id=category_id, is_launched=True).order_by('-sales')[:2]
  166. class ImgListView(APIView):
  168.     def get(self, request):
  169.         s_id = request.query_params.get("sku_id")
  170.         img_list = SKUImage.objects.filter(sku_id=s_id)
  171.         img_list = [i.image.path.split("BMyStore\\")[1] for i in img_list]
  172.         return Response({"img_list": img_list})

有些代码写的略显丑陋 不过能跑就不改了 哈哈

标签： django python 后端
本文转载自: https://blog.csdn.net/suic009/article/details/128412841
版权归原作者 老师我作业忘带了 所有， 如有侵权，请联系我们删除。
登录后发布评论

“Django+DRF+Vue+Mysql+Redis OUC软件工程作业”的评论:

还没有评论
关于作者
...
overfit同步小助手
文章同步
相关阅读

网络安全法-网络运行安全

使用selenium/drissionpage时如何阻止chrome自动跳转http到https

docker desktop 里部署的Open WebUI 管理员密码忘记了的处理方法

在ubuntu20.04中搭建onsite比赛运行环境

利用开源的低代码表单设计器FcDesigner高效管理和渲染复杂表单结构

Kafka学习笔记

【前端】浏览器输入url到页面呈现发生了什么？

文章导航
交作业啦