lf 前后端分离 (4) 价格策略

一.价格策略

价格策略就是通过前端发送要购买的课程以及价格策略来找出表关联的字段返回客户端

通过contenttype 属性 找到课程所有的价格策略

for prcie_policy in course_obj.price_policy.all():

进行判断获取的价格策略是否存在

if prcie_policy_id not in price_policy_dict:
    raise CommonException(1002, "价格策略有误")

在创建与前端匹配的数据结构

import redis
import json

from rest_framework.views import APIView
from rest_framework.response import Response

from app01.models import *
from app01.utils.auth import LoginAuth
from app01.utils.response import BaseResponse
from app01.utils.exception import CommonException

from django.conf import settings
from django.core.exceptions import ObjectDoesNotExist

cache = redis.Redis(decode_responses=True)

class ShoppingCartView(APIView):
    authentication_classes = [LoginAuth]

    def post(self, request):
        course_id = request.data.get("course_id")
        prcie_policy_id = request.data.get("price_policy_id")

        user_id = request.user.pk
        res = BaseResponse()

        try:
            course_obj = Course.objects.get(pk=course_id)
            price_policy_dict = {}
            price_policy_list = []
            for prcie_policy in course_obj.price_policy.all():
                price_policy_dict[prcie_policy.pk] = {
                    "id": prcie_policy.pk,
                    "valid_period": prcie_policy.valid_period,
                    "valid_period_text": prcie_policy.get_valid_period_display(),
                    "price": prcie_policy.price,
                    "default": prcie_policy_id == prcie_policy.pk
                }
            print("price_policy_dict", price_policy_dict)

            #这里需要进行价格策略判断
            if prcie_policy_id not in price_policy_dict:
                raise CommonException(1002, "价格策略有误")
            pp = PricePolicy.objects.get(pk=prcie_policy_id)
            for i in price_policy_dict:
                price_policy_list.append(price_policy_dict[i])

            shoppingcar_key = settings.SHOPPING_CAR_KEY % (user_id, course_id)
            shoppingcar_val = {
                "id":course_id,
                "name": course_obj.name,
                "course_img": course_obj.course_img,
                "relate_price_policy": price_policy_list,
                "default_price_period": prcie_policy_id,
                "default_price": pp.price,
                # "valid_period": pp.valid_period,
                # "valid_period_text": pp.get_valid_period_display(),
            }
            cache.set(shoppingcar_key, json.dumps(shoppingcar_val, ensure_ascii=False))
            print(cache.get(shoppingcar_key))

            res.data = "加入购物车成功"

        except CommonException as e:
            res.code = e.code
            res.msg = e.msg
        except ObjectDoesNotExist as e:
            res.code = 1001
            res.msg = "课程不存在"

        return Response(res.dict)

    def get(self, request):



        shopping_car_list = []

        for key in cache.keys(pattern="shoppingcar_1_*"):
            data = cache.get(key)
            print(data)
            shopping_car_list.append(json.loads(data))

        res = BaseResponse()
        res.data = {
            "total": len(shopping_car_list),
            "shopping_car_list": shopping_car_list
        }



        return Response(res.dict)

关于baseresponse

通过定义静态方法,@property无需调用添加()
实例化对象res .dict发送字典形式数据

class BaseResponse(object):
    def __init__(self):
        self.code = 1000
        self.data = None
        self.msg = ""

    @property
    def dict(self):

        return self.__dict__

if __name__ == '__main__':

    res = BaseResponse()
    res.data = 12312
    print(res.dict)