我的瑞吉项目基于springboot-vue

package com.xxl.reggie.controller; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.xxl.reggie.common.R; import com.xxl.reggie.dto.DishDto; import com.xxl.reggie.entity.Category; import com.xxl.reggie.entity.Dish; import com.xxl.reggie.entity.DishFlavor; import com.xxl.reggie.service.CategoryService; import com.xxl.reggie.service.DishFlavorService; import com.xxl.reggie.service.DishService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.web.bind.annotation.*; import java.util.List; import java.util.Set; import java.util.concurrent.TimeUnit; import java.util.stream.Collectors; @RestController @RequestMapping("/dish") @Slf4j public class DishController { @Autowired private CategoryService categoryService; @Autowired private DishService dishService; @Autowired private DishFlavorService dishFlavorService; @Autowired private RedisTemplate redisTemplate; /** * 新增菜品 * @param dto * @return */ @PostMapping public R<String> save(@RequestBody DishDto dto){ // log.info("dto:{}",dto.toString()); dishService.saveWithFlavor(dto); // 清理某个分类下的菜品缓存数据 String key = "dish_"+dto.getCategoryId()+"_1"; redisTemplate.delete(key); return R.success("新增菜品成功"); } @GetMapping("/page") public R<Page> page(int page,int pageSize,String name){ // 构造分页构造器对象 Page<Dish> pageInfo = new Page<>(page,pageSize); Page<DishDto> dishDtoPage = new Page<>(); // 条件构造器 LambdaQueryWrapper<Dish> queryWrapper = new LambdaQueryWrapper<>(); // 添加过滤条件 queryWrapper.like(name!=null,Dish::getName,name); // 添加排序条件 queryWrapper.orderByDesc(Dish::getUpdateTime); // 执行分页查询 dishService.page(pageInfo,queryWrapper); // 对象拷贝 BeanUtils.copyProperties(pageInfo,dishDtoPage,"records"); List<Dish> records = pageInfo.getRecords(); List<DishDto> list = records.stream().map((item)->{ DishDto dto = new DishDto(); BeanUtils.copyProperties(item,dto); Long categoryId = item.getCategoryId(); // 根据id查询分类对象 Category category = categoryService.getById(categoryId); if (category!=null){ String categoryName = category.getName(); dto.setCategoryName(categoryName); } return dto; }).collect(Collectors.toList()); dishDtoPage.setRecords(list); return R.success(dishDtoPage); } /** * 根据id查询菜品信息和对应的口味信息 * @param id * @return */ @GetMapping("/{id}") public R<DishDto> get(@PathVariable Long id){ // DishDto dishDto= dishService.getByIdWithFlavor(id); return R.success(dishDto); } /** * 修改菜品 * @param dto * @return */ @PutMapping public R<String> update(@RequestBody DishDto dto){ // log.info(dto.toString()); dishService.updateWithFlavor(dto); // 清理所有菜品的缓存 // Set key = redisTemplate.keys("dish_*"); // redisTemplate.delete(key); // 清理某个分类下的菜品缓存数据 String key = "dish_"+dto.getCategoryId()+"_1"; redisTemplate.delete(key); return R.success("菜品修改成功"); } /** * 修改启停售状态 * @param ids * @return */ @PostMapping("/status/{status}") public R<String> updateStatusDish(@PathVariable Integer status,@RequestParam List<Long> ids){ // log.info(ids.toString()); LambdaQueryWrapper<Dish> queryWrapper = new LambdaQueryWrapper<Dish>(); queryWrapper.in(ids!=null,Dish::getId,ids); List<Dish> list = dishService.list(queryWrapper); for (Dish dish:list ) { if (dish!=null){ dish.setStatus(status); dishService.updateById(dish); } } return R.success("状态修改成功"); } /** * 删除菜品 * @param ids * @return */ @DeleteMapping public R<String> deleteDish(@RequestParam List<Long> ids){ dishService.deleteWithFlavor(ids); return R.success("删除成功"); } // 查询菜品 @GetMapping("/list") public R<List<DishDto>> getDishList(Dish dish){ List<DishDto> listDto =null; // 动态设置缓存的key String key = "dish_"+dish.getCategoryId()+"_"+dish.getStatus(); // 先从缓存中获取数据 listDto = (List<DishDto>) redisTemplate.opsForValue().get(key); // 如果存在，则直接返回，无需拆线呢数据库 if (listDto!=null){ return R.success(listDto); } // 构造查询条件 LambdaQueryWrapper<Dish> queryWrapper = new LambdaQueryWrapper<>(); queryWrapper.eq(dish.getCategoryId()!=null,Dish::getCategoryId,dish.getCategoryId()).or().like(dish.getName()!=null,Dish::getName,dish.getName()); // 添加条件，查询状态为1的在售的菜品 queryWrapper.eq(Dish::getStatus,1); // 添加排序条件 queryWrapper.orderByAsc(Dish::getSort).orderByDesc(Dish::getUpdateTime); List<Dish> list = dishService.list(queryWrapper); listDto = list.stream().map((item)->{ DishDto dto = new DishDto(); BeanUtils.copyProperties(item,dto); Long categoryId = item.getCategoryId(); // 根据id查询分类对象 Category category = categoryService.getById(categoryId); if (category!=null){ String categoryName = category.getName(); dto.setCategoryName(categoryName); } // 获取菜品id Long dishId = item.getId(); LambdaQueryWrapper<DishFlavor> lambdaQueryWrapper = new LambdaQueryWrapper<>(); lambdaQueryWrapper.eq(dishId!=null,DishFlavor::getDishId,dishId); // lambdaQueryWrapper.eq(DishFlavor::get,1); List<DishFlavor> dishFlavorList = dishFlavorService.list(lambdaQueryWrapper); dto.setFlavors(dishFlavorList); return dto; }).collect(Collectors.toList()); // 如果不存在，则需要查询数据库，将查询到的菜品数据添加到redis redisTemplate.opsForValue().set(key,listDto,60, TimeUnit.MINUTES); return R.success(listDto); } }