@PostMapping("/add")
public R<ShoppingCart> add(@RequestBody ShoppingCart shoppingCart){
log.info("购物车数据:{}",shoppingCart);
//设置用户id,指定当前是哪个用户的购物车数据
Long currentId = BaseContext.getCurrentId();
shoppingCart.setUserId(currentId);
Long dishId = shoppingCart.getDishId();
LambdaQueryWrapper<ShoppingCart> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(ShoppingCart::getUserId,currentId);
if(dishId != null){
//添加到购物车的是菜品
queryWrapper.eq(ShoppingCart::getDishId,dishId);
}else{
//添加到购物车的是套餐
queryWrapper.eq(ShoppingCart::getSetmealId,shoppingCart.getSetmealId());
}
//查询当前菜品或者套餐是否在购物车中
//SQL:select * from shopping_cart where user_id = ? and dish_id/setmeal_id = ?
ShoppingCart cartServiceOne = shoppingCartService.getOne(queryWrapper);
if(cartServiceOne != null){
//如果已经存在,就在原来数量基础上加一
Integer number = cartServiceOne.getNumber();
cartServiceOne.setNumber(number + 1);
shoppingCartService.updateById(cartServiceOne);
}else{
//如果不存在,则添加到购物车,数量默认就是一
shoppingCart.setNumber(1);
shoppingCart.setCreateTime(LocalDateTime.now());
shoppingCartService.save(shoppingCart);
cartServiceOne = shoppingCart;
}
return R.success(cartServiceOne);
}
这是一段来自瑞吉外卖的添加购物车方法
相关代码解析如下:
1.
? ? public R<ShoppingCart> add(@RequestBody ShoppingCart shoppingCart){
这段代码定义了一个名为 add 的方法,它接收一个 ShoppingCart 的对象,返回值是 R<ShoppingCart> 类型。
2.
? ? ? ? log.info("购物车数据:{}",shoppingCart);
使用日志记录购物车数据
3.
? ?
? ? ? ? Long currentId = BaseContext.getCurrentId();
获取当前用户的id
BaseContext?
package com.nit.reggie.common;
/**
* 基于ThreadLocal封装工具类,用户保存和获取当前登录用户id
*/
public class BaseContext {
private static ThreadLocal<Long> threadLocal = new ThreadLocal<>();
/**
* 设置值
* @param id
*/
public static void setCurrentId(Long id){
threadLocal.set(id);
}
/**
* 获取值
* @return
*/
public static Long getCurrentId(){
return threadLocal.get();
}
}
4.
? ? ? ? shoppingCart.setUserId(currentId);
指定当前是哪个用户的购物车数据
5.
?Long dishId = shoppingCart.getDishId();
获取购物车中要添加的商品(菜品)的ID
6.
? ? ?LambdaQueryWrapper<ShoppingCart> queryWrapper = new LambdaQueryWrapper<>();
创建一个查询包装器,用于构建查询条件
7.
? ? ? ? queryWrapper.eq(ShoppingCart::getUserId,currentId);
设置查询条件,查找属于当前用户的购物车记录
8.
? ? ? ? if(dishId != null){
如果菜品不为空,表示添加的是菜品。
9.
? ? ? ? ? ? queryWrapper.eq(ShoppingCart::getDishId,dishId);
设置查询条件,查找与菜单ID 匹配的购物车记录
11.
? ? ?}else{
如果菜品 ID 为空,则表示添加的是套餐
12.?
? ? ? ? ? ? queryWrapper.eq(ShoppingCart::getSetmealId,shoppingCart.getSetmealId());
? ? ? ? }
设置查询条件,查找与套餐 ID 匹配的购物车记录
13.? ??
? ? ? ? ShoppingCart cartServiceOne = shoppingCartService.getOne(queryWrapper);
根据查询条件从数据库中获取一个购物车记录
14.
? ? ?if(cartServiceOne != null){
如果购物车记录已经存在
15.
? ? ? ? ? ? Integer number = cartServiceOne.getNumber();
? ? ? ? ? ? cartServiceOne.setNumber(number + 1);
在原来的数量基础上加1
16.
? ? ? ? ? ? shoppingCartService.updateById(cartServiceOne);
更新购物车记录
17.
? ? ? ? }else{
如果购物车记录不存在
18.
? ? ? ? ? ? shoppingCart.setNumber(1);
则添加到购物车,数量默认就是一
19.
? ? ? ? ? ? shoppingCart.setCreateTime(LocalDateTime.now());
设置创建时间为当前时间
20.
? ? ? ? ? ? shoppingCartService.save(shoppingCart);
保存购物车记录
21.
? ? ? ? ? ? cartServiceOne = shoppingCart;
? ? ? ? }
将新保存的购物车对象赋值给 cartServiceOne
22.
? ? ? ? return R.success(cartServiceOne);
? ? }
?
返回成功的响应,包含更新后的购物车对象。