苍穹外卖 day7|yumoni的小窝

课程内容

缓存菜品
缓存套餐
添加购物车
查看购物车
清空购物车

缓存菜品

实现思路

将商品缓存至redis中
减少数据库查询操作
提高访问速度
缓存逻辑分析
- 查询菜品时线检查缓存是否存在
- 不存在则查询数据库同时载入缓存
- 存在则直接读取缓存
- 每个分类的菜品保存一份缓存数据
- 数据库汇总菜品数据有变更时清理缓存数据

代码开发

修改用户端接口DishController的list方法载入缓存处理逻辑

@GetMapping("/list")  
@ApiOperation("根据分类id查询菜品")  
public Result<List<DishVO>> list(Long categoryId) {  
    //构造redis中的key dish_分类id  
    String key = "dish_" + categoryId;  
      
    //查询redis中是否存在菜品  
    List<DishVO>list = (List<DishVO>) redisTemplate.opsForValue().get(key);  
    if (list != null) {  
        //存在则直接返回，无需查询数据库  
        return Result.success(list);  
    }  
      
    //不存在先从数据库中获取，然后存入redis  
    Dish dish = new Dish();  
    dish.setCategoryId(categoryId);  
    dish.setStatus(StatusConstant.ENABLE);//查询起售中的菜品  
    redisTemplate.opsForValue().set(key, list);  
      
    return Result.success(list);  
}

为了保证数据库和Redis中的数据保持一致
修改管理端接口DishController的相关方法
加入清理缓存逻辑

抽取清理缓存的方法

需要改造的方法:
- 新增菜品
- 修改菜品
- 批量删除菜品
- 起售停售菜品
在管理端DishController中添加

@Autowired
    private RedisTemplate redisTemplate;
	/**
     * 清理缓存数据
     * @param pattern
     */
    private void cleanCache(String pattern){
        Set keys = redisTemplate.keys(pattern);
        redisTemplate.delete(keys);
    }

优化新增菜品方法

@PostMapping  
@ApiOperation("新增菜品")  
public Result save(@RequestBody DishDTO dishDTO) {  
    log.info("新增菜品：{}", dishDTO);  
    dishService.saveWithFlavor(dishDTO);  
    //清理缓存数据  
    //只清理收影响的缓存数据  
    String key = "dish_" + dishDTO.getCategoryId();  
    cleanCache(key);  
  
    return Result.success();  
}

优化删除菜品方法

@DeleteMapping  
@ApiOperation("菜品批量删除")  
public Result delete(@RequestParam List<Long> ids) {  
    log.info("菜品批量删除：{}", ids);  
    dishService.deleteBatch(ids);//后绪步骤实现  
    //批量删除菜品可能同时删除多个不同分类的菜品  
    //直接清理所有菜品缓存数据  
    cleanCache("dish_*");  
  
    return Result.success();  
}

优化删除菜品方法

@PutMapping  
@ApiOperation("修改菜品")  
public Result update(@RequestBody DishDTO dishDTO) {  
    log.info("修改菜品：{}", dishDTO);  
    dishService.updateWithFlavor(dishDTO);  
    //修改操作较为繁琐  
    //可能会修改分类  
    //此时会影响两个分类的缓存数据  
    //直接清理所有菜品缓存数据  
    cleanCache("dish_*");  
  
    return Result.success();  
}

缓存套餐

使用Spring Cache框架简化操作

Spring Cache

实现类基于注解的缓存功能
只需要简单的加一个注解就能实现缓存功能
提供了一层抽象底层可以切换不同的缓存实现
- EHCache
- Caffeine
- Redis
需要提供对应的依赖

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

常用注解

注解	说明
@EnableCaching	开启缓存注解功能，通常加在启动类上
@Cacheable	在方法执行前先查询缓存中是否有数据，如果有数据，则直接返回缓存数据；如果没有缓存数据，调用方法并将方法返回值放到缓存中
@CachePut	将方法的返回值放到缓存中
@CacheEvict	将一条或多条数据从缓存中删除

@CachePut注解

作用 : 将方法返回值放入缓存
value : 缓存的名称每个缓存名称下面可以有很多key
key : 缓存的key 支持spring的表达式语言SPEL语法
key的写法如下
- #user.id user指的是方法形参的名称 id指的是user的Id属性
- #result.id result代表方法返回值该表达式以返回对象的id属性作为key
- #p0.id 指的是方法中的第一个参数返回第一个参数的id属性作为key
- root.agrs[0].id 指的是方法中的第一个参数然后同上

@Cacheable注解

作用 : 在方法执行前,spring先查看缓存中是否有数据如果有数据则直接返回
- 若没有数据调用方法将返回值放到缓存中
value : 缓存的名称每个缓存名称下面可以有多个key
key : 缓存的key 同样支持SPEL语法

@CacheEvict注解

作用 : 清理指定缓存
value : 缓存的名称每个缓存下面可以有多个key
key : 缓存的key 支持SPEL

代码开发

配置环境

在pom文件中加入maven坐标

<dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

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

在启动类上加入@EnableCaching注解开启缓存注解功能

@SpringBootApplication  
@EnableTransactionManagement //开启注解方式的事务管理  
@Slf4j  
@EnableCaching//开启缓存注解  
public class SkyApplication {  
    public static void main(String[] args) {  
        SpringApplication.run(SkyApplication.class, args);  
        log.info("server started");  
    }  
}

Service层

在用户端接口SetmealServiceImpl的list方法上加入@Cacheable注解

@Cacheable(cacheNames = "setmealCache", key = "#setmeal.categoryId")  
public List<Setmeal> list(Setmeal setmeal) {  
    List<Setmeal> list = setmealMapper.list(setmeal);  
    return list;  
}```

#### Controller层
- 在管理端接口SetmealService的方法上都加入@CacheEvict注解
```java
//新增套餐  
@PostMapping  
@ApiOperation("新增套餐")  
@CacheEvict(cacheNames = "setmealCache",key = "#setmealDTO.categoryId")//key: setmealCache::100  
public Result save(@RequestBody SetmealDTO setmealDTO) {  
    setmealService.saveWithDish(setmealDTO);  
    return Result.success();  
}  
  
@GetMapping("/page")  
@ApiOperation("套餐分页查询")  
public Result<PageResult> page(SetmealPageQueryDTO setmealPageQueryDTO) {  
    PageResult pageResult = setmealService.pageQuery(setmealPageQueryDTO);  
    return Result.success(pageResult);  
}  
  
@DeleteMapping  
@ApiOperation("批量删除套餐")  
@CacheEvict(cacheNames = "setmealCache",allEntries = true)  
public Result delete(@RequestParam List<Long> ids) {  
    setmealService.deleteBatch(ids);  
    return Result.success();  
}  
  
@GetMapping("/{id}")  
@ApiOperation("根据id查询套餐")  
public Result<SetmealVO> getById(@PathVariable Long id){  
    SetmealVO setmealVO = setmealService.getByIdWithDish(id);  
    return Result.success(setmealVO);  
}  
  
@PutMapping  
@ApiOperation("修改套餐")  
@CacheEvict(cacheNames = "setmealCache",allEntries = true)  
public Result update(@RequestBody SetmealDTO setmealDTO){  
    setmealService.updateWithDish(setmealDTO);  
    return Result.success();  
}  
  
@PostMapping("/status/{status}")  
@ApiOperation("套餐起售停售")  
@CacheEvict(cacheNames = "setmealCache",allEntries = true)  
public Result startOfstop(@PathVariable Integer status , long id){  
    setmealService.startOfstop(status,id);  
    return Result.success();  
}

添加购物车

用户可以将菜品或者套餐添加到购物车
如果设置了口味信息需要选择规格才能加入
套餐可以直接加入
在购物车内可以修改菜品和套餐的数量

表设计

暂时存放商品的地方
存放商品种类数量
不同用户购物车需要区分开

字段名	数据类型	说明	备注
id	bigint	主键	自增
name	varchar(32)	商品名称	冗余字段
image	varchar(255)	商品图片路径	冗余字段
user_id	bigint	用户id	逻辑外键
dish_id	bigint	菜品id	逻辑外键
setmeal_id	bigint	套餐id	逻辑外键
dish_flavor	varchar(50)	菜品口味
number	int	商品数量
amount	decimal(10,2)	商品单价	冗余字段
create_time	datetime	创建时间

代码开发

DTO设计

在sky-pojo模块 ShopingCarDto.java已定义

package com.sky.dto;

import lombok.Data;
import java.io.Serializable;

@Data
public class ShoppingCartDTO implements Serializable {

    private Long dishId;
    private Long setmealId;
    private String dishFlavor;

}

Controller层

根据添加购物车接口创建ShoppingCartController

@RestController  
@Slf4j  
@Api(tags = "c端 购物车相关接口")  
@RequestMapping("/user/shoppingCart")  
public class ShoppingCartController {  
  
    @Autowired  
    private ShoppingCartService shoppingCartService;  
  
    @PostMapping("/add")  
    @ApiOperation("添加购物车")  
    public Result<String> add(@RequestBody ShoppingCartDTO shoppingCartDTO) {  
        log.info("购物车数据:{}", shoppingCartDTO);  
        shoppingCartService.addShoppingCart(shoppingCartDTO);  
        return Result.success();  
  
    }  
}

Service层

创建ShoppingCartService接口

public interface ShoppingCartService {  
  
    //添加购物车  
    void addShoppingCart(ShoppingCartDTO shoppingCartDTO);  
}

在实现类实现add方法

@Service  
public class ShoppingCartServiceImpl implements ShoppingCartService {  
  
    @Autowired  
    private ShoppingCartMapper shoppingCartMapper;  
  
    @Autowired  
    private DishMapper dishMapper;  
  
    @Autowired  
    private SetmealMapper setmealMapper;  
  
    @Override  
    public void addShoppingCart(ShoppingCartDTO shoppingCartDTO) {  
        //判断当前加入购物车的商品是否存在  
        ShoppingCart shoppingCart = new ShoppingCart();  
        BeanUtils.copyProperties(shoppingCartDTO, shoppingCart);  
        Long userId = BaseContext.getCurrentId();  
        shoppingCart.setUserId(userId);  
  
        List<ShoppingCart> list = shoppingCartMapper.list(shoppingCart);  
  
        //如果存在直接加一即可  
        if (list != null && list.size() > 0) {  
            ShoppingCart cart = list.get(0);  
            cart.setNumber(cart.getNumber() + 1);//update  
            shoppingCartMapper.updateNumById(cart);  
        }else{  
            //不存在则重新加入  
            //先判断添加的是菜品还是套餐  
            Long dishId = shoppingCartDTO.getDishId();  
            if (dishId != null) {  
                //添加的是菜品  
                Dish dish = dishMapper.getById(dishId);  
                shoppingCart.setName(dish.getName());  
                shoppingCart.setImage(dish.getImage());  
                shoppingCart.setAmount(dish.getPrice());  
            } else {  
                //添加的是套餐  
                Long setmealId = shoppingCartDTO.getSetmealId();  
                Setmeal setmeal = setmealMapper.getById(setmealId);  
                shoppingCart.setName(setmeal.getName());  
                shoppingCart.setImage(setmeal.getImage());  
                shoppingCart.setAmount(setmeal.getPrice());  
  
  
            }  
            //统一插入数据  
            shoppingCart.setNumber(1);  
            shoppingCart.setCreateTime(LocalDateTime.now());  
  
            shoppingCartMapper.insert(shoppingCart);  
        }  
  
    }

Mapper层

创建ShoppingCartMapper接口

@Mapper  
public interface ShoppingCartMapper {  
    //动态查询  
    List<ShoppingCart> list(ShoppingCart shoppingCart);  
  
    //根据id修改商品  
    @Update("update shopping_cart set number = #{number} where id = #{id}")  
    void updateNumById(ShoppingCart shoppingCart);  
  
    @Insert("insert into shopping_cart(user_id, dish_id, setmeal_id, name, image, amount, number, create_time) " +  
            "values(#{userId}, #{dishId}, #{setmealId}, #{name}, #{image}, #{amount}, #{number}, #{createTime})")  
    void insert(ShoppingCart shoppingCart);  
}

创建对应的xml文件

<?xml version="1.0" encoding="UTF-8" ?>  
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"  
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >  
<mapper namespace="com.sky.mapper.ShoppingCartMapper">  
    <select id="list" parameterType="ShoppingCart" resultType="ShoppingCart">  
        select * from shopping_cart  
        <where>  
            <if test="userId != null">  
                and user_id = #{userId}  
            </if>  
            <if test="dishId != null">  
                and dish_id = #{dishId}  
            </if>  
            <if test="setmealId != null">  
                and setmeal_id = #{setmealId}  
            </if>  
            <if test="dishFlavor != null">  
                and dish_flavor = #{dishFlavor}  
            </if>  
        </where>  
        order by create_time desc  
    </select>  
</mapper>

查看购物车

代码开发

Controller层

在ShoppingCartController中创建查看购物车的方法

@GetMapping("/list")
    @ApiOperation("查看购物车")
    public Result<List<ShoppingCart>> list(){
        return Result.success(shoppingCartService.showShoppingCart());
    }

Service层

在ShoppingCartService接口中声明查看购物车的方法

//查看购物车
 List<ShoppingCart> showShoppingCart();

在实现类中实现

@Override  
public List<ShoppingCart> showShoppingCart() {  
    return shoppingCartMapper.list(ShoppingCart.  
            builder().  
            userId(BaseContext.getCurrentId()).  
            build());  
}

只需要获得id即可查看

清空购物车

代码开发

Controller层

在ShoppingCartController中创建清空购物车的方法

@DeleteMapping("/clean")
    @ApiOperation("清空购物车商品")
    public Result<String> clean(){
        shoppingCartService.cleanShoppingCart();
        return Result.success();
    }

Service层

在ShoppingCartService接口中声明清空购物车的方法：

//清空购物车方法
void cleanShoppingCart();

在实现类中实现

public void cleanShoppingCart() {
        shoppingCartMapper.deleteByUserId(BaseContext.getCurrentId());
    }

Mapper层

在ShoppingCartMapper接口中创建删除购物车数据的方法：
简单语句直接基于注解实现

@Delete("delete from shopping_cart where user_id = #{userId}")
    void deleteByUserId(Long userId);

删除购物车(作业)

代码开发

Controller层

@PostMapping("/sub")  
@ApiOperation("删除购物车中一个商品")  
public Result sub(@RequestBody ShoppingCartDTO shoppingCartDTO){  
    log.info("删除购物车中一个商品，商品：{}", shoppingCartDTO);  
    shoppingCartService.subShoppingCart(shoppingCartDTO);  
    return Result.success();  
}

Service层

//删除购物车中一个商品  
void subShoppingCart(ShoppingCartDTO shoppingCartDTO);

在实现类中实现

@Override  
public void subShoppingCart(ShoppingCartDTO shoppingCartDTO) {  
    ShoppingCart shoppingCart = new ShoppingCart();  
    BeanUtils.copyProperties(shoppingCartDTO,shoppingCart);  
    //设置查询条件，查询当前登录用户的购物车数据  
    shoppingCart.setUserId(BaseContext.getCurrentId());  
  
    List<ShoppingCart> list = shoppingCartMapper.list(shoppingCart);  
  
    if(list != null && list.size() > 0){  
        shoppingCart = list.get(0);  
  
        Integer number = shoppingCart.getNumber();  
        if(number == 1){  
            //当前商品在购物车中的份数为1，直接删除当前记录  
            shoppingCartMapper.deleteById(shoppingCart.getId());  
        }else {  
            //当前商品在购物车中的份数不为1，修改份数即可  
            shoppingCart.setNumber(shoppingCart.getNumber() - 1);  
            shoppingCartMapper.updateNumberById(shoppingCart);  
        }  
    }  
}

Mapper层

//根据id删除购物车中一个商品  
@Delete("delete from shopping_cart where id = #{id}")  
void deleteById(Long id);

课程内容

缓存菜品

实现思路

代码开发

抽取清理缓存的方法

缓存套餐

Spring Cache

@CachePut注解

@Cacheable注解

@CacheEvict注解

代码开发

配置环境

Service层

添加购物车

表设计

代码开发

DTO设计

Controller层

Service层

Mapper层

查看购物车

代码开发

Controller层

Service层

清空购物车

代码开发

Controller层

Service层

Mapper层

删除购物车(作业)

代码开发

Controller层

Service层

Mapper层

苍穹外卖 day8

苍穹外卖 day6

yumoni