create接口流程
需求：向购物车添加商品
流程：写shopping_cart路由--->写ShoppingCart视图函数--->使用Authuser校验用户是否登录--->首先写添加create--->
使用异常的格式，逻辑代码写在try里,报错涉及到用户认证错误，课程不存在错误、价格策略不存在错误、还有正常错误1004--->
1.获取用户id--->获取课程id、价格策略id--->3.1校验课程是否存在---->
3.2校验课程价格策略是否合法---->4.在redis中存储数据
1、登录校验
2、获取课程id和价格策略id，校验课程id和价格策略id是否合法
3、通过用户id、课程id将课程信息放入购物车
添加商品的数据结构
遇到的问题，存储的解构设计问题，刚开始字典套字典，存取都麻烦，后来设计的合理的解构： #方案一
'''
user_id:{
shopping_car:{
course_id:{
name:"",
img:"",
price_plicy:{},
default_price_policy_id:3
}
}
} '''
#方案二
#用户1买的课程2
'''
shopping_car_1_2:{
name:"",
img:"",
price_policy:{},
default_price_policy_id:3 }
shopping_car_1_3:{
name:"",
img:"",
price_policy:{},
default_price_policy_id:3 }
添加接口-create
class ShoppingCart(ViewSetMixin, APIView):
#对添加购物车之前对用户信息做校验
authentication_classes = [UserAuth] def list(self, request, *args, **kwargs):
pass def create(self, request, *args, **kwargs): #添加到购物车
"""
提交post请求，将提交课程存放redis中 状态码：
1000 : 成功
1001 ：认证失败
1002 : 课程不存在
1003 : 价格策略不存在 """ response=BaseResponse()
try: # 1 用户的ID
user_pk=request.user.pk # 2 获取课程ID和对应的价格策略ID
course_id=request.data.get("course_id")
price_policy_id=request.data.get("price_policy_id") # 3 校验数据合法性 # 3.1 校验课程是否存在
course_obj=Course.objects.get(pk=course_id) #如果遇见课程id不存在，
直接会执行ObjectDoesNotExist这个异常 # 3.2 校验课程价格策略id是否合法
#查找课程的价格策略
price_policy_list=course_obj.price_policy.all()
#判断这个课程价格策略是否在数据库中 price_policy_dict={} #构造个字典为了判断价格策略id是否在price_plicy_list里
for price_policy in price_policy_list:
price_policy_dict[price_policy.pk]={
"prcie":price_policy.price,
"valid_period":price_policy.valid_period,
"valid_period_text":price_policy.get_valid_period_display(),
}
'''
price_policy_dict: # price_policy_dict的数据格式
{
1:{"price":100,"valid_period":60},
2:{"price":200,"valid_period":120},
} '''
if price_policy_id not in price_policy_dict:
raise PriceDoesNotExist
# 4.向redis存储
#方案一
'''
user_id:{
shopping_car:{
course_id:{
name:"",
img:"",
price_plicy:{},
default_price_policy_id:3
}
}
} '''
#方案二
'''
shopping_car_1_2:{
name:"",
img:"",
price_policy:{},
default_price_policy_id:3 }
shopping_car_1_3:{
name:"",
img:"",
price_policy:{},
default_price_policy_id:3 }
shopping_car_2_1:{
name:"",
img:"",
price_policy:{},
default_price_policy_id:3 } '''
#redis接口1
# import redis
# pool=redis.ConnectionPool(host="127.0.0.1",port="6379")
# redis=redis.Redis(connection_pool=pool)
#redis接口2
from django_redis import get_redis_connection
redis=get_redis_connection("default") #使用redis中get_redis_connection函数，
在setting中配置default from django.conf import settings
import json
shopping_car_key=settings.SHOPPING_CAR_KEY%(user_pk,course_id)
#向SHOPPING_CAR_KEY="shopping_car_%s_%s" 字典传入参数 course_info={
"name":course_obj.name,
"course_img":course_obj.course_img,
"relate_price_policy":json.dumps(price_policy_dict),
"default_price_policy_id":price_policy_id } #向redis中存储购物车商品数据
redis.hmset(shopping_car_key,course_info) response.data="添加购物车成功！" except ObjectDoesNotExist as e:
response.code="",
response.errot="课程不存在" except PriceDoesNotExist as e:
response.code="",
response.errot=e.error except Exception as e:
response.code="",
response.error=str(e) # 返回购物车商品数据
return Response(response.dict)
遇见的问题：
在使用redis存储数据时，构造数据结构时出现了问题，原因是使用字典套字典的格式，user_id, shopping_car,
course_id\course_img\price_policy\default_price_policy 这样存储数据时一层套一层，想取到里边的值时很麻烦，
而且存储也不方便，于是使用了shopping_car_%s_%s这种格式，给传入user_id和course_id，
里边就是course_name,course_img，price_policy,default_price_policy方便存储。
create制作流程详细
a.校验买课的用户是否登录;
在AuthUser中获取到user.name,user.token进行校验
b.获取课程id和价格策略id;
从发来的请求中获取这俩值
c.校验数据合法性
d.向redis中存储
首先配置redis，在setting中配置，顺便启动redis服务端和客户端
# redis配置
CACHES = {
"default": {
"BACKEND": "django_redis.cache.RedisCache",
"LOCATION": "redis://127.0.0.1:6379",
"OPTIONS": {
"CLIENT_CLASS": "django_redis.client.DefaultClient",
"CONNECTION_POOL_KWARGS": {"max_connections": 100}
# "PASSWORD": "密码",
}
}
}
redis的接口可以是以下俩种，一般第二个方便
#redis接口1
import redis
pool=redis.ConnectionPool(host="127.0.0.1",port="")
redis=redis.Redis(connection_pool=pool) redis接口2
from django_redis import get_redis_connection
redis=get_redis_connection("default") #使用redis中get_redis_connection函数，在setting中配置default
接着构造字典的键和值shopping_car_key和course_info，进行redis存储
redis.hmset(shopping_car_key,course_info)
测试效果
使用postman发送
{
"course_id":1,
"price_policy_id":2
}
响应
{
"code": 1000,
"data": "添加购物车成功！",
"error": ""
}
使用redis进行查询
import redis
# redis = redis.Redis(host='127.0.0.1', port=6379)
pool = redis.ConnectionPool(host='127.0.0.1', port=6379)
redis = redis.Redis(connection_pool=pool)
print(redis.hgetall("shopping_car_1_1"))
效果：
{b'name': b'python\xe5\x85\xa8\xe6\xa0\x88', b'default_price_policy_id': b'',
b'course_img': b'python.png',
b'relate_price_policy': b'{"1": {"prcie": 100.0, "valid_period": 7, "valid_period_text": "1\\u5468"},
"2": {"prcie": 200.0, "valid_period": 14, "valid_period_text": "2\\u5468"},
"3": {"prcie": 300.0, "valid_period": 180, "valid_period_text": "6\\u4e2a\\u6708"}}'}
效果图-作出黑框里这些内容
