苍穹外卖项目笔记（8）— 缓存商品、购物车功能

前言

代码链接：

Echo0701/take-out⁤ (github.com)

1 缓存菜品

1.1 问题说明

【注】很多时候系统性能的瓶颈就在于数据库这端

1.2 实现思路

通过 Redis 来缓存数据，减少数据库查询操作

【注】Redis 基于内存来保存数据的，访问 Redis 数据本质上是对内存的操作，而查询数据库本质上是对磁盘IO的操作

缓存逻辑分析：

1.3 代码开发

1.3.1 缓存菜品数据

DishController.java

@RestController("userDishController")
@RequestMapping("/user/dish")
@Slf4j
@Api(tags = "C端-菜品浏览接口")
public class DishController {@Autowiredprivate DishService dishService;@Autowiredprivate RedisTemplate redisTemplate;/*** 根据分类id查询菜品** @param categoryId* @return*/@GetMapping("/list")@ApiOperation("根据分类id查询菜品")public Result<List<DishVO>> list(Long categoryId) {//构造 redis 中的 key，规则：dish_分类idString key = "dish_" + categoryId;//查询 redis 中是否存在菜品数据List<DishVO> list = (List<DishVO>) redisTemplate.opsForValue().get(key);if (list != null && list.size() > 0) {//如果存在，直接返回，无须查询数据库return Result.success(list);}Dish dish = new Dish();dish.setCategoryId(categoryId);dish.setStatus(StatusConstant.ENABLE);//查询起售中的菜品//如果不存在，查询数据库，将查询到的数据放入 redis 中list = dishService.listWithFlavor(dish);redisTemplate.opsForValue().set(key, list);return Result.success(list);}}

【注】如果出现异常：java.lang.reflect.InvocationTargetException，可能原因：

① 未进行注入，检查 @Autowired

② 未启动 Redis 服务器：打开 redis 的安装目录在地址栏输入cmd，输入
redis-server.exe redis.windows.conf

1.3.2 清理缓存数据

修改管理端接口 DishController 相关的方法，加入清理缓存的逻辑，需要改造的方法有：

新增菜品
批量删除菜品
修改菜品
起售停售

2 缓存套餐

2.1 Spring Cache

2.1.1 简介

Spring Cache 是一个框架，实现了基于注解的缓存功能，只需要简单的加一个注释，就能实现缓存功能。它提供了一层抽象，底层可以切换不同的缓存实现，例如：

EHCache
Caffeine
Redis（本项目实现）

maven 坐标：

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-cache</artifactId><version>2.7.3</version></dependency>

2.1.2 常用注解

2.2 实现思路

3 添加购物车

3.1 需求分析和设计

产品原型

接口设计

请求方式：POST
请求路径：/user/shoppingCart/add
请求参数：套餐id、菜品id、口味
返回结果：code、data、msg

数据库设计

购物车：暂时存放所选商品的地方
选的什么商品
每个商品买了几个
不同用户的购物车需要区分开

【注】冗余字段（比较稳定）的设计可以帮助我们提高查询速度，但冗余字段不可大量设计

3.2 代码开发

ShoppingCartController.java

@RestController
@RequestMapping("/user/shoppingCart")
@Slf4j
@Api(tags = "C端购物车相关接口")
public class ShoppingCartController {@Autowiredprivate ShoppingCartService shoppingCartService;/*** 添加购物车* @param shoppingCartDTO* @return*/@PostMapping("/add")@ApiOperation("添加购物车")public Result add(@RequestBody ShoppingCartDTO shoppingCartDTO) {log.info("添加购物车，商品信息为：{}",shoppingCartDTO);shoppingCartService.addShoppingCart(shoppingCartDTO);return Result.success();}/*** 查看购物车* @return*/@GetMapping("/list")@ApiOperation("查看购物车")public Result<List<ShoppingCart>> list() {List<ShoppingCart> list = shoppingCartService.showShoppingCart();return Result.success(list);}/*** 清空购物车* @return*/@DeleteMapping("/clean")@ApiOperation("清空购物车")public Result clean() {shoppingCartService.cleanShoppingCart();return Result.success();}/*** 减少购物车商品* @param shoppingCartDTO* @return*/@PostMapping("/sub")@ApiOperation("减少购物车商品数量")public Result sub(@RequestBody ShoppingCartDTO shoppingCartDTO) {log.info("减少购物车商品数量，商品信息为：{}", shoppingCartDTO);shoppingCartService.subShoppingCart(shoppingCartDTO);return Result.success();}
}

ShoppingCartServiceImpl.java

    /*** 添加购物车* @param shoppingCartDTO*/public void addShoppingCart(ShoppingCartDTO shoppingCartDTO) {// 判断当前添加的商品是否已经在购物车中存在了//select * from shopping_cart where user_id = ? and setmeal_id = xx//select * from shopping_cart where user_id = ? and dish_id = xx and dish_flavorShoppingCart shopingCart = new ShoppingCart();BeanUtils.copyProperties(shoppingCartDTO, shopingCart);Long userId = BaseContext.getCurrentId();shopingCart.setUserId(userId);List<ShoppingCart> list = shoppingCartMapper.list(shopingCart);// 若存在，只需要进行update方法更新商品数量，if(list != null && list.size() > 0) {//查到了，把这条购物车数据获取到，把 num + 1//由于user_id是唯一的，再加上上面的信息限制，所以查询的结果只可能有两种：1、查不到；2、查出来唯一的一条数据ShoppingCart cart = list.get(0);cart.setNumber(cart.getNumber() + 1); //加 1 操作以后，执行update语句：update shopping_cart set number = ? where id = ?shoppingCartMapper.updateNumberById(cart);} else{// 如果不存在才需要在购物车表里面插入一条新的数据//购物车对象仍然可以使用上面的shoppingcart，但是商品的名称、价格、图片仍然需要查询，如果是套餐到套餐表里面去查询，如果是菜品到菜品表里面去查询//判断本次添加到购物车的是菜品还是套餐,可以通过判断它们的id 是否为空来进行判断Long dishId = shoppingCartDTO.getDishId();if(dishId != null){//本次添加到购物车的是菜品Dish dish = dishMapper.getById(dishId);shopingCart.setName(dish.getName());shopingCart.setImage(dish.getImage());shopingCart.setAmount(dish.getPrice());} else {//本次添加到购物车的是套餐Long setmealId = shoppingCartDTO.getSetmealId();Setmeal setmeal = setmealMapper.getById(setmealId);shopingCart.setName(setmeal.getName());shopingCart.setImage(setmeal.getImage());shopingCart.setAmount(setmeal.getPrice());}shopingCart.setNumber(1);shopingCart.setCreateTime(LocalDateTime.now());shoppingCartMapper.insert(shopingCart);}}

ShoppingCartMapper.xml

    <insert id="insertBatch" parameterType="list">insert into shopping_cart (name, image, user_id, dish_id, setmeal_id, dish_flavor, number, amount, create_time)values<foreach collection="shoppingCartList" item="sc" separator=",">(#{sc.name},#{sc.image},#{sc.userId},#{sc.dishId},#{sc.setmealId},#{sc.dishFlavor},#{sc.number},#{sc.amount},#{sc.createTime})</foreach></insert>

4 查看购物车

4.1 需求分析和设计

产品原型

接口设计

4.2 代码开发

ShoppingCartServiceImpl.java

    /*** 查看购物车* @return*/public List<ShoppingCart> showShoppingCart() {//获取当前微信用户的idLong userId = BaseContext.getCurrentId();ShoppingCart shoppingCart = ShoppingCart.builder().userId(userId).build();List<ShoppingCart> list = shoppingCartMapper.list(shoppingCart);return list;}

ShoppingCartMapper.xml

    <select id = "list" resultType="com.sky.entity.ShoppingCart">select * from shopping_cart<where>
<!--            test里面写的属性名，然后是表字段名 = #{属性名}--><if test="userId != null">and user_id = #{userId}</if><if test="setmealId != null">and setmeal_id = #{setmealId}</if><if test="dishId != null">and dish_id = #{dishId}</if><if test="dishFlavor != null">and dish_flavor = #{dishFlavor}</if></where></select>

5 清空购物车

5.1 需求分析和设计

接口设计

5.2 代码开发

ShoppingCartServiceImpl.java

    /*** 清空购物车*/public void cleanShoppingCart() {//获取当前微信用户的idLong userId = BaseContext.getCurrentId();shoppingCartMapper.deleteByUserId(userId);}

ShoppingCartMapper.java

@Mapper
public interface ShoppingCartMapper {/*** 动态条件查询，查询条件（参数）为购物车对象* @param shoppingCart* @return*/List<ShoppingCart> list(ShoppingCart shoppingCart);/*** 根据id修改商品数量* @param shoppingCart*/@Update("update shopping_cart set number = #{number} where id = #{id}")void updateNumberById(ShoppingCart shoppingCart);/*** 插入购物车数据* @param shopingCart*/@Insert("insert into shopping_cart(name, user_id, dish_id, setmeal_id, dish_flavor, number, amount, image, create_time)" +"values (#{name}, #{userId}, #{dishId}, #{setmealId}, #{dishFlavor}, #{number}, #{amount}, #{image}, #{createTime})")void insert(ShoppingCart shopingCart);/*** 根据用户 id 清空购物车* @param userId*/@Delete("delete from shopping_cart where user_id = #{userId}")void deleteByUserId(Long userId);/*** 根据商品 id 删除购物车数据* @param id*/@Delete("delete from shopping_cart where id = #{id}")void deleteById(Long id);/*** 批量插入购物车*/void insertBatch(List<ShoppingCart> shoppingCartList);
}