qhfl-7 結算中心

時間 2019-11-09

標籤 qhfl 結算中心简体版

原文原文鏈接

結算中心,即從購物車前往支付前的確認頁面，這裏要開始選擇優惠券了前端

"""
前端傳過來數據 course_list 課程列表

redis 中將要存放的結算數據 {
    settlement_userid_courseid: {
            id, 課程id，
            title,
            course_img,
            valid_period_display,
            price,
            course_coupon_dict: {  # 課程優惠券
                coupon_id: {優惠券信息}
                coupon_id2: {優惠券信息}
                coupon_id3: {優惠券信息}
            }
            # 默認不給你選  這個字段只有更新的時候才添加
            default_coupon_id: 1
    }

    global_coupon_userid: {                # 全局優惠券
        coupon_id: {優惠券信息}
        coupon_id2: {優惠券信息}
        coupon_id3: {優惠券信息},
        # 這個字段只有更新的時候才添加
        default_global_coupon_id: 1
    }
}
"""

加入結算中心接口

加入結算中心後，放到redis中，同時將redis中的購物車中課程清除。等待結算redis

class SettlementView(APIView):
    authentication_classes = [LoginAuth, ]

    def post(self, request):
        res = BaseResponse()
        # 1 獲取前端的數據以及user_id
        course_list = request.data.get("course_list", "")
        user_id = request.user.pk
        # 2 校驗數據的合法性
        for course_id in course_list:
            # 2.1 判斷course_id 是否在購物車中
            shopping_car_key = SHOPPINGCAR_KEY % (user_id, course_id)
            if not CONN.exists(shopping_car_key):
                res.code = 1050
                res.error = "課程ID不合法"
                return Response(res.dict)
            # 3 構建數據結構
            # 3.1 獲取用戶的全部合法優惠券
            user_all_coupons = CouponRecord.objects.filter(
                account_id=user_id,
                status=0,
                coupon__valid_begin_date__lte=now(),
                coupon__valid_end_date__gte=now(),
            ).all()
            print(user_all_coupons)
            # 3.2 構建優惠券dict
            course_coupon_dict = {}
            global_coupon_dict = {}
            for coupon_record in user_all_coupons:
                coupon = coupon_record.coupon
                if coupon.object_id == course_id:  # 一門課程只能存在一張優惠券
                    course_coupon_dict[coupon.id] = {
                        "id": coupon.id,
                        "name": coupon.name,
                        "coupon_type": coupon.get_coupon_type_display(),
                        "object_id": coupon.object_id,
                        "money_equivalent_value": coupon.money_equivalent_value,
                        "off_percent": coupon.off_percent,
                        "minimum_consume": coupon.minimum_consume
                    }
                elif coupon.object_id == "":
                    global_coupon_dict[coupon.id] = {
                        "id": coupon.id,
                        "name": coupon.name,
                        "coupon_type": coupon.get_coupon_type_display(),
                        "money_equivalent_value": coupon.money_equivalent_value,
                        "off_percent": coupon.off_percent,
                        "minimum_consume": coupon.minimum_consume
                    }
            # 3.3 構建寫入redis的數據結構
            course_info = CONN.hgetall(shopping_car_key)
            price_policy_dict = json.loads(course_info["price_policy_dict"])
            default_policy_id = course_info["default_price_policy_id"]
            valid_period = price_policy_dict[default_policy_id]["valid_period_display"]
            price = price_policy_dict[default_policy_id]["price"]

            settlement_info = {
                "id": course_info["id"],
                "title": course_info["title"],
                "course_img": course_info["course_img"],
                "valid_period": valid_period,
                "price": price,
                "course_coupon_dict": json.dumps(course_coupon_dict, ensure_ascii=False)
            }
            # 4 寫入redis
            settlement_key = SETTLEMENT_KEY % (user_id, course_id)
            global_coupon_key = GLOBAL_COUPON_KEY % user_id
            CONN.hmset(settlement_key, settlement_info)
            if global_coupon_dict:
                CONN.hmset(global_coupon_key, global_coupon_dict)  # 將全局優惠券也放到redis中
            # 5 刪除購物車中的數據
            CONN.delete(shopping_car_key)
        res.data = "加入結算中心成功"
        return Response(res.dict)

post加入結算中心

模擬測試接口django

查看結算中心

 def get(self, request):
        res = BaseResponse()
        # 1， 獲取user_id
        user_id = request.user.pk
        # 2,  拼接全部key
        # 3， 去redis取數據
        settlement_key = SETTLEMENT_KEY % (user_id, "*")
        global_coupon_key = GLOBAL_COUPON_KEY % user_id
        all_keys = CONN.scan_iter(settlement_key)
        ret = []
        for key in all_keys:
            ret.append(CONN.hgetall(key))
        global_coupon_info = CONN.hgetall(global_coupon_key)
        res.data = {
            "settlement_info": ret,
            "global_coupon_dict": global_coupon_info
        }
        return Response(res.dict)

獲取結算信息

更新結算中心接口

在結算時，若是有更改課程的優惠券，或全局優惠券時，需put請求更新結算中心的數據json

   def put(self, request):
        # course_id  course_coupon_id  global_coupon_id
        res = BaseResponse()
        # 1, 獲取前端傳過來數據
        course_id = request.data.get("course_id", "")
        course_coupon_id = request.data.get("course_coupon_id", "")
        global_coupon_id = request.data.get("global_coupon_id", "")
        user_id = request.user.pk
        # 2, 校驗數據合法性
        # 2.1 校驗course_id
        key = SETTLEMENT_KEY % (user_id, course_id)
        if course_id:
            if not CONN.exists(key):
                res.code = 1060
                res.error = "課程ID不合法"
                return Response(res.dict)
        # 2.2 校驗 course_coupon_id
        if course_coupon_id:
            course_coupon_dict = json.loads(CONN.hget(key, "course_coupon_dict"))
            if str(course_coupon_id) not in course_coupon_dict:
                res.code = 1061
                res.error = "課程優惠券ID不合法"
                return Response(res.dict)
        # 2.3 校驗global_coupon_id
        if global_coupon_id:
            global_coupon_key = GLOBAL_COUPON_KEY % user_id
            if not CONN.exists(global_coupon_key):
                res.code = 1062
                res.error = "全局優惠券ID不合法"
                return Response(res.dict)
            CONN.hset(global_coupon_key, "default_global_coupon_id", global_coupon_id)
        # 3，修改redis中數據
        CONN.hset(key, "default_coupon_id", course_coupon_id)
        res.data = "更新成功"
        return Response(res.dict)

更新結算信息

更新後查看結算的結果數據結構

import json
import redis
from rest_framework.views import APIView
from rest_framework.response import Response
from utils.base_response import BaseResponse
from utils.redis_pool import POOL
from django.utils.timezone import now
from utils.my_auth import LoginAuth

from .views import SHOPPINGCAR_KEY
from .models import CouponRecord

CONN = redis.Redis(connection_pool=POOL)
SETTLEMENT_KEY = "SETTLEMENT_%s_%s"
GLOBAL_COUPON_KEY = "GLOBAL_COUPON_%s"
"""
前端傳過來數據 course_list


redis 中存的數據 {
    settlement_userid_courseid: {
            id, 課程id，
            title,
            course_img,
            valid_period_display,
            price,
            course_coupon_dict: {
                coupon_id: {優惠券信息}
                coupon_id2: {優惠券信息}
                coupon_id3: {優惠券信息}
            }
            # 默認不給你選  這個字段只有更新的時候才添加
            default_coupon_id: 1
    }

    global_coupon_userid: {
        coupon_id: {優惠券信息}
        coupon_id2: {優惠券信息}
        coupon_id3: {優惠券信息},
        # 這個字段只有更新的時候才添加
        default_global_coupon_id: 1

    }

}
"""


class SettlementView(APIView):
    authentication_classes = [LoginAuth, ]

    def post(self, request):
        res = BaseResponse()
        # 1 獲取前端的數據以及user_id
        course_list = request.data.get("course_list", "")
        user_id = request.user.pk
        # 2 校驗數據的合法性
        for course_id in course_list:
            # 2.1 判斷course_id 是否在購物車中
            shopping_car_key = SHOPPINGCAR_KEY % (user_id, course_id)
            if not CONN.exists(shopping_car_key):
                res.code = 1050
                res.error = "課程ID不合法"
                return Response(res.dict)
            # 3 構建數據結構
            # 3.1 獲取用戶的全部合法優惠券
            user_all_coupons = CouponRecord.objects.filter(
                account_id=user_id,
                status=0,
                coupon__valid_begin_date__lte=now(),
                coupon__valid_end_date__gte=now(),
            ).all()
            print(user_all_coupons)
            # 3.2 構建優惠券dict
            course_coupon_dict = {}
            global_coupon_dict = {}
            for coupon_record in user_all_coupons:
                coupon = coupon_record.coupon
                if coupon.object_id == course_id:  # 一門課程只能存在一張優惠券
                    course_coupon_dict[coupon.id] = {
                        "id": coupon.id,
                        "name": coupon.name,
                        "coupon_type": coupon.get_coupon_type_display(),
                        "object_id": coupon.object_id,
                        "money_equivalent_value": coupon.money_equivalent_value,
                        "off_percent": coupon.off_percent,
                        "minimum_consume": coupon.minimum_consume
                    }
                elif coupon.object_id == "":
                    global_coupon_dict[coupon.id] = {
                        "id": coupon.id,
                        "name": coupon.name,
                        "coupon_type": coupon.get_coupon_type_display(),
                        "money_equivalent_value": coupon.money_equivalent_value,
                        "off_percent": coupon.off_percent,
                        "minimum_consume": coupon.minimum_consume
                    }
            # 3.3 構建寫入redis的數據結構
            course_info = CONN.hgetall(shopping_car_key)
            price_policy_dict = json.loads(course_info["price_policy_dict"])
            default_policy_id = course_info["default_price_policy_id"]
            valid_period = price_policy_dict[default_policy_id]["valid_period_display"]
            price = price_policy_dict[default_policy_id]["price"]

            settlement_info = {
                "id": course_info["id"],
                "title": course_info["title"],
                "course_img": course_info["course_img"],
                "valid_period": valid_period,
                "price": price,
                "course_coupon_dict": json.dumps(course_coupon_dict, ensure_ascii=False)
            }
            # 4 寫入redis
            settlement_key = SETTLEMENT_KEY % (user_id, course_id)
            global_coupon_key = GLOBAL_COUPON_KEY % user_id
            CONN.hmset(settlement_key, settlement_info)
            if global_coupon_dict:
                CONN.hmset(global_coupon_key, global_coupon_dict)  # 將全局優惠券也放到redis中
            # 5 刪除購物車中的數據
            CONN.delete(shopping_car_key)
        res.data = "加入結算中心成功"
        return Response(res.dict)

    def get(self, request):
        res = BaseResponse()
        # 1， 獲取user_id
        user_id = request.user.pk
        # 2,  拼接全部key
        # 3， 去redis取數據
        settlement_key = SETTLEMENT_KEY % (user_id, "*")
        global_coupon_key = GLOBAL_COUPON_KEY % user_id
        all_keys = CONN.scan_iter(settlement_key)
        ret = []
        for key in all_keys:
            ret.append(CONN.hgetall(key))
        global_coupon_info = CONN.hgetall(global_coupon_key)
        res.data = {
            "settlement_info": ret,
            "global_coupon_dict": global_coupon_info
        }
        return Response(res.dict)

    def put(self, request):
        # course_id  course_coupon_id  global_coupon_id
        res = BaseResponse()
        # 1, 獲取前端傳過來數據
        course_id = request.data.get("course_id", "")
        course_coupon_id = request.data.get("course_coupon_id", "")
        global_coupon_id = request.data.get("global_coupon_id", "")
        user_id = request.user.pk
        # 2, 校驗數據合法性
        # 2.1 校驗course_id
        key = SETTLEMENT_KEY % (user_id, course_id)
        if course_id:
            if not CONN.exists(key):
                res.code = 1060
                res.error = "課程ID不合法"
                return Response(res.dict)
        # 2.2 校驗 course_coupon_id
        if course_coupon_id:
            course_coupon_dict = json.loads(CONN.hget(key, "course_coupon_dict"))
            if str(course_coupon_id) not in course_coupon_dict:
                res.code = 1061
                res.error = "課程優惠券ID不合法"
                return Response(res.dict)
        # 2.3 校驗global_coupon_id
        if global_coupon_id:
            global_coupon_key = GLOBAL_COUPON_KEY % user_id
            if not CONN.exists(global_coupon_key):
                res.code = 1062
                res.error = "全局優惠券ID不合法"
                return Response(res.dict)
            CONN.hset(global_coupon_key, "default_global_coupon_id", global_coupon_id)
        # 3，修改redis中數據
        CONN.hset(key, "default_coupon_id", course_coupon_id)
        res.data = "更新成功"
        return Response(res.dict)