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保存

效果如下:

 

 

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

import os
from alipay import AliPay
from rest_framework import status
from rest_framework.permissions import IsAuthenticated
from rest_framework.response import Response
from rest_framework.views import APIViewfrom MyApps.orders.models import OrderInfo
from MyApps.payment.models import Payment
from django.conf import settingsclass PaymentView(APIView):"""支付"""permission_classes = (IsAuthenticated,)def get(self, request, order_id):"""获取支付链接"""# 判断订单信息是否正确try:order = OrderInfo.objects.get(order_id=order_id, user=request.user,pay_method=OrderInfo.PAY_METHODS_ENUM["ALIPAY"],status=OrderInfo.ORDER_STATUS_ENUM["UNPAID"])except OrderInfo.DoesNotExist:return Response({'message': '订单信息有误'}, status=status.HTTP_400_BAD_REQUEST)# 构造支付宝支付链接地址alipay = AliPay(appid=settings.ALIPAY_APPID,app_notify_url=None,  # 默认回调urlapp_private_key_string=open(os.path.join(os.path.dirname(os.path.abspath(__file__)), "keys","app_private_key.pem")).read(),# app_private_key_string=settings.app_private_key_string,alipay_public_key_string=open(os.path.join(os.path.dirname(os.path.abspath(__file__)), 'keys','alipay_public_key.pem')).read(),# alipay_public_key_string=settings.alipay_public_key_string,  # 支付宝的公钥,验证支付宝回传消息使用,不是你自己的公钥,sign_type="RSA2",  # RSA 或者 RSA2debug=settings.ALIPAY_DEBUG  # 默认False)order_string = alipay.api_alipay_trade_page_pay(out_trade_no=order_id,total_amount=str(order.total_amount),subject="联想商城%s" % order_id,return_url="http://localhost:63342/BMyStore/front_end_pc/pay_success.html",)# 需要跳转到https://openapi.alipay.com/gateway.do? + order_string# 拼接链接返回前端alipay_url = settings.ALIPAY_URL + "?" + order_stringreturn Response({'alipay_url': alipay_url})# 支付宝回调函数接口 put /payment/status/?支付宝参数
class PaymentStatusView(APIView):def put(self, request):# 接收参数,效验参数# 构造支付宝支付链接地址alipay_req_data = request.query_paramsif not alipay_req_data:return Response({"message": "缺少参数"}, status=status.HTTP_400_BAD_REQUEST)alipay_req_dict = alipay_req_data.dict()sign = alipay_req_dict.pop("sign")alipay = AliPay(appid=settings.ALIPAY_APPID,app_notify_url=None,  # 默认回调urlapp_private_key_string=open(os.path.join(os.path.dirname(os.path.abspath(__file__)),"keys/app_private_key.pem")).read(),alipay_public_key_string=open(os.path.join(os.path.dirname(os.path.abspath(__file__)),"keys/alipay_public_key.pem")).read(),# 支付宝的公钥,验证支付宝回传消息使用,不是你自己的公钥,sign_type="RSA2",  # RSA 或者 RSA2debug=settings.ALIPAY_DEBUG  # 默认False)result = alipay.verify(alipay_req_dict, sign)# 保存数据,保存支付结果数据if result:order_id = alipay_req_dict.get("out_trade_no")trade_id = alipay_req_dict.get("trade_no")# 修改订单状态Payment.objects.create(order_id=order_id,trade_id=trade_id)OrderInfo.objects.filter(order_id=order_id).update(status=OrderInfo.ORDER_STATUS_ENUM["UNCOMMENT"])print('支付成功!')return Response({"trade_id": trade_id})return Response({"message": "参数有误"}, status=status.HTTP_400_BAD_REQUEST)
from django_filters.rest_framework import DjangoFilterBackend
from drf_haystack.viewsets import HaystackViewSet
from rest_framework.filters import OrderingFilter
from rest_framework.generics import ListAPIView, CreateAPIView, DestroyAPIView, RetrieveAPIView
from rest_framework.pagination import PageNumberPagination
from rest_framework.views import APIView
from rest_framework.response import Response
from rest_framework.viewsets import GenericViewSet
from MyApps.goods import models
from MyApps.goods.models import SKU, GoodsCategory, Collect, Comment1, SKUImage
from MyApps.goods.serializers import SKUSerializer, SKUIndexSerializer, CollectSerializer, Comment1Serializer
from rest_framework.permissions import IsAuthenticated
from django_redis import get_redis_connection
from rest_framework.filters import BaseFilterBackend
from django_filters import FilterSet, filtersclass SKUListView(ListAPIView):"""sku列表数据"""serializer_class = SKUSerializer# 分页与排序filter_backends = (OrderingFilter,)ordering_fields = ("create_time", "price", "sales")def get_queryset(self):category_id = self.kwargs["category_id"]return SKU.objects.filter(category_id=category_id, is_launched=True)class SKUSearchViewSet(HaystackViewSet):"""SKU搜索"""index_models = [SKU]serializer_class = SKUIndexSerializer# 分页与排序# filter_backends = (OrderingFilter,)def list(self, request, *args, **kwargs):queryset = self.filter_queryset(self.get_queryset())ordering_fields = ("create_time", "price", "sales")od = request.query_params.get("ordering", None)if od in ordering_fields:queryset = queryset.order_by(od)page = self.paginate_queryset(queryset)if page is not None:serializer = self.get_serializer(page, many=True)return self.get_paginated_response(serializer.data)serializer = self.get_serializer(queryset, many=True)return Response(serializer.data)class CategoriesView(APIView):"""获取当前分类信息"""def get(self, request, pk):"""1.获取前端数据2. 查询当前三级分类信息3.通过三级分类信息获取一二集分类4. 返回:param request::return:"""cat3 = GoodsCategory.objects.get(id=pk)  # 获取三级cat2 = cat3.parent  # 自关联获取二级,cat1 = cat2.parent  # 自关联获取一级# 返回数据return Response({"cat1": cat1.name,"cat2": cat2.name,"cat3": cat3.name})class GetGoodsView(APIView):"""获取当前分类信息"""def get(self, request, pk):SKU1 = models.SKU.objects.filter(pk=pk).first()comment_count = SKU1.goods.comment_countcollect_count = SKU1.goods.collect_countgoods_id = SKU1.goods_id# 返回数据return Response({"goods_id": goods_id, 'comment_count': comment_count, 'collect_count': collect_count})class IsCollectedView(APIView):def post(self, request):print(request.data)sku_id = int(request.data.get("sku_id", -5))user_id = request.data.get("user_id", 1)if sku_id == -5:return Response({"res_data": 0})collecs = models.Collect.objects.filter(user_id=user_id)sku_id_list = [i.sku_id for i in collecs]print(sku_id in sku_id_list)res = 0if sku_id in sku_id_list:res = 1return Response({"res_data": res})##################################
class MyPageNumberPagination(PageNumberPagination):page_size_query_param = 'size'page_size = 10max_page_size = 100class CommentFilterSet(FilterSet):goods = filters.NumberFilter(field_name='goods', required=True)class Meta:model = models.Comment1fields = ['goods']class Comment1View(ListAPIView, GenericViewSet):filter_backends = [DjangoFilterBackend]filterset_class = CommentFilterSetqueryset = models.Comment1.objectsserializer_class = Comment1Serializer################################################
class SelfFilterBackend(BaseFilterBackend):def filter_queryset(self, request, queryset, view):return queryset.filter(user=request.user)class CollectViewSet(ListAPIView, CreateAPIView, GenericViewSet):permission_classes = [IsAuthenticated]filter_backends = [SelfFilterBackend, DjangoFilterBackend]pagination_class = MyPageNumberPagination# 当前登录用户的所有收藏记录queryset = models.Collect.objectsserializer_class = CollectSerializerdef perform_create(self, serializer):user = self.request.userinstance = Collect.objects.filter(user=user, **serializer.validated_data).first()if not instance:instance = serializer.save(user=user)instance.sku.goods.collect_count += 1instance.sku.goods.save()return Response({"message": 'ok', 'data': {'active': True}})else:instance.delete()instance.sku.goods.collect_count -= 1instance.sku.goods.save()return Response({"message": 'ok', 'data': {'active': False}})class HotSkus(ListAPIView):serializer_class = SKUSerializer# 分页与排序filter_backends = (OrderingFilter,)ordering_fields = ("sales", "create_time", "price")def get_queryset(self):category_id = self.kwargs["category_id"]return SKU.objects.filter(category_id=category_id, is_launched=True).order_by('-sales')[:2]class ImgListView(APIView):def get(self, request):s_id = request.query_params.get("sku_id")img_list = SKUImage.objects.filter(sku_id=s_id)img_list = [i.image.path.split("BMyStore\\")[1] for i in img_list]return Response({"img_list": img_list})

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


本文来自互联网用户投稿,文章观点仅代表作者本人,不代表本站立场,不承担相关法律责任。如若转载,请注明出处。 如若内容造成侵权/违法违规/事实不符,请点击【内容举报】进行投诉反馈!

相关文章

立即
投稿

微信公众账号

微信扫一扫加关注

返回
顶部