小白勇闯《苍穹外卖》Day3

碎碎念：开学马上大四了，但是前几年一直没有好好学习专业课，只是临近考试的时候突击复习一下，导致到现在还是小白T_T 7月放暑假在家陆陆续续看了黑马的Java基础和web相关课程，但是并没有完全看完，也没有深入理解...眼看时间已经来不及了，简历上还是一片空白，决定硬着头皮学项目了，干中学吧，加油！！！

叠个甲：只是发表一下学习记录，内容不一定正确，希望大家包容一下，欢迎大佬们多多指正！！！

菜品管理

前两天已经完成了环境搭建，员工管理，分类管理，今天开始菜品管理了

公共字段自动填充

技术点：枚举、注解、AOP、反射

——————————————这里恶补了一下知识点————————————————

枚举：适合做信息分类和标志。这里用来标识操作类型，insert/update

注解：自定义注解

public @i8nterface 注解名称{ public 属性类型 属性名() default 默认值 ; }

特殊属性value：在使用时如果只有一个value， value名称可省略不写

原理：本质上是一个接口继承了annotation类，里面定义的属性其实上是一个一个的抽象方法

使用举例：

@注解名(aaa="李四",bbb=true,ccc={"java","python"}) public void test(){ }

元注解：注解注解的注解

@Retention（RetentionPolicy.RUNTIME) @Target({ElementType.METHOD}) public @interface Test{ }

@Retention约束存活范围

@Target约束标记范围

解析注释：使用解析注解的方法

AOP：面向切面编程。通用公共功能从业务代码中剥离。

@Aspect+@Component定义切面类；@Pointcut定义切点表达式；编写通知@Before前置，@AfterReturning返回，@AfterThrowing 异常通知，@After 最终通知，@Around 环绕通知

反射：加载类，并且以编程的方式解剖类中各种成分（成员变量，方法，构造器等）

①加载类，获取类的字节码文件：Calss对象（三种方法）

②获取类的构造器：Constructor对象

③获取类的成员变量：Field对象

set()复制，get()取值

④获取类的成员方法：Method对象

invoke（）触发执行

反射作用：可以得到一个类的全部成分然后操作；可以破坏封装性；可以绕过泛型约束

需求

（1).在新增数据时, 将createTime、updateTime 设置为当前时间, createUser、updateUser设置为当前登录用户ID。

（2).在更新数据时, 将updateTime 设置为当前时间, updateUser设置为当前登录用户ID。

实现思路

代码开发

创建注解和切面的包和类

定义注解类

/** * 自动填充 */ @Target(ElementType.METHOD) @Retention(RetentionPolicy.RUNTIME) public @interface AutoFill { /** * 数据库操作类型 * @return */ OperationType value(); }

已定义好的枚举类

/** * 数据库操作类型 */ public enum OperationType { /** * 更新操作 */ UPDATE, /** * 插入操作 */ INSERT }

已定义好的AutoFillConstant常量类

/** * 公共字段自动填充相关常量 */ public class AutoFillConstant { /** * 实体类中的方法名称 */ public static final String SET_CREATE_TIME = "setCreateTime"; public static final String SET_UPDATE_TIME = "setUpdateTime"; public static final String SET_CREATE_USER = "setCreateUser"; public static final String SET_UPDATE_USER = "setUpdateUser"; }

切面类

（@Slf4j 是 lombok 提供注解，编译期自动生成 Logger 日志实例，简化日志对象创建，直接使用log.info/log.error输出日志。）

/** * 自定义切面类，统一为公共字段赋值 */ @Aspect @Component @Slf4j public class AutoFillAspect { /** * 切入点 */ @Pointcut("execution(* com.sky.mapper.*.*(..)) && @annotation(com.sky.annotation.AutoFill)")//不仅要在mapper里还要满足注解 public void autoFillPointCut() {} /** * 通知 自动填充公共字段 * @param joinPoint */ @Before("autoFillPointCut()") public void autoFill(JoinPoint joinPoint) { log.info("公共字段自动填充..."); //获得方法签名对象 MethodSignature signature = (MethodSignature) joinPoint.getSignature(); //获得方法上的注解 AutoFill autoFill = signature.getMethod().getAnnotation(AutoFill.class); //获得注解中的操作类型 OperationType operationType = autoFill.value(); //获取当前目标方法的参数 Object[] args = joinPoint.getArgs(); if (args == null || args.length == 0) { return; } //实体对象 Object entity = args[0]; //准备赋值的数据 LocalDateTime time = LocalDateTime.now(); Long empId = BaseContext.getCurrentId(); if (operationType == OperationType.INSERT) { //当前执行的是insert操作，为4个字段赋值 try { //获得set方法对象----Method Method setCreateTime = entity.getClass().getDeclaredMethod(AutoFillConstant.SET_CREATE_TIME, LocalDateTime.class); Method setUpdateTime = entity.getClass().getDeclaredMethod(AutoFillConstant.SET_UPDATE_TIME, LocalDateTime.class); Method setCreateUser = entity.getClass().getDeclaredMethod(AutoFillConstant.SET_CREATE_USER, Long.class); Method setUpdateUser = entity.getClass().getDeclaredMethod(AutoFillConstant.SET_UPDATE_USER, Long.class); //通过反射调用目标对象的方法 setCreateTime.invoke(entity, time); setUpdateTime.invoke(entity, time); setCreateUser.invoke(entity, empId); setUpdateUser.invoke(entity, empId); } catch (Exception ex) { log.error("公共字段自动填充失败：{}", ex.getMessage()); } }else if(operationType == OperationType.UPDATE){ //当前执行的是update操作，为2个字段赋值 try { //获得set方法对象----Method Method setUpdateTime = entity.getClass().getDeclaredMethod(AutoFillConstant.SET_UPDATE_TIME, LocalDateTime.class); Method setUpdateUser = entity.getClass().getDeclaredMethod(AutoFillConstant.SET_UPDATE_USER, Long.class); //通过反射调用目标对象的方法 setUpdateTime.invoke(entity, time); setUpdateUser.invoke(entity, empId); } catch (Exception ex) { log.error("公共字段自动填充失败：{}", ex.getMessage()); } } } }

这里我AOP掌握不熟练（下面是我问ai给我的解释）

public void autoFillPointCut () {}这个空方法 = 给切点表达式起别名，方便复用。

JoinPoint连接点，joinPoint相当于一个袋子装被拦截的 mapper 方法全部信息

这段代码的通俗理解：

先从袋子里拿出来[被拦截的那个方法]；再拿到写在 mapper 方法上面的注解；把注解里面的内容取出来，得到INSERT或者UPDATE；从袋子里，拿到调用 mapper 时传进去的参数;判断是否为空；若不为空，取第一个参数，这个就是我们要存数据库的实体；准备要填的数据，时间和id；若为INSERT，用反射在运行的时候，找到这 4 个 set 方法，拿到方法对象，.invoke(对象,值)调用这个 set 方法，把值设置进去；若为UPDATE,找到这 2 个 set 方法，拿到方法对象，.invoke(对象,值)调用这个 set 方法，把值设置进去;反射很容易报错，捕获异常，打印错误

在Mapper接口的方法上加入 AutoFill 注解

@AutoFill(OperationType.INSERT) @Insert("insert into category(type, name, sort, status, create_time, update_time, create_user, update_user)" + " VALUES" + " (#{type}, #{name}, #{sort}, #{status}, #{createTime}, #{updateTime}, #{createUser}, #{updateUser})") void insert(Category category); @AutoFill(OperationType.UPDATE) void update(Category category); @AutoFill(OperationType.UPDATE) void update(Employee employee);

注释掉原代码

测试

（测试的时候突然登录不上前端页面了，发现是没打开nginx，大家不要学我犯这么笨蛋的错误）

发现打了断点但是修改员工数据时断点不停，前端显示修改成功

排查了以下三点：

Employee 实体的@Data注解存在，字段updateTime、updateUser定义正确。

看控制台没有输出公共字段自动填充失败，定位反射哪里报错。

数据库里这条员工记录，update_time、update_user发生变化。

拦截的是 Mapper 接口，MyBatis 运行时会生成代理对象来执行方法，IDEA 调试器对动态代理生成的类，断点经常无法触发。后面我也尝试修改断点的 Suspend 模式，从 All 改成 Thread，断点换到set赋值那里，但是代理场景下依旧不稳定。

所以我直接手动输出日志了

功能测试成功！

所以实际开发中日志打印也是很重要的调试手段，不能完全依赖 IDEA 断点。

原来是因为没有debug运行。。。

新增菜品

需求分析和设计

接口设计：

根据类型查询分类（已完成）

文件上传

新增菜品

数据库设计

代码开发

文件上传

—————————————————这里去补了一下知识点————————————————

需要先注册阿里云--->充值--->开通OSS--->创建bucket--->获取并配置AccessKey

application-dev.yml

alioss: endpoint: 你自己的 access-key-id: 你自己的 access-key-secret: 你自己的 bucket-name: 你自己的

application.yml

alioss: endpoint: ${sky.alioss.endpoint} access-key-id: ${sky.alioss.access-key-id} access-key-secret: ${sky.alioss.access-key-secret} bucket-name: ${sky.alioss.bucket-name}

新建类OssConfiguration

@Configuration @Slf4j public class OssConfiguration { /** * 通过spring管理对象 * @param aliOssProperties * @return */ @Bean @ConditionalOnMissingBean public AliOssUtil aliOssUtil(AliOssProperties aliOssProperties) { log.info("开始创建阿里云OSS工具类..."); return new AliOssUtil(aliOssProperties.getEndpoint(), aliOssProperties.getAccessKeyId(), aliOssProperties.getAccessKeySecret(), aliOssProperties.getBucketName()); } }

新建类CommonController

@RestController @RequestMapping("/admin/common") @Slf4j @Api(tags = "通用接口") public class CommonController { @Autowired private AliOssUtil aliOssUtil; /** * 文件上传 * @param file * @return */ @PostMapping("/upload") @ApiOperation("文件上传") public Result<String> upload(MultipartFile file){ log.info(file.getName()); //原始文件名 String originalFilename = file.getOriginalFilename(); String extension = originalFilename.substring(originalFilename.lastIndexOf(".")); //将文件上传的阿里云 String fileName = UUID.randomUUID().toString() + extension; try { String filePath = aliOssUtil.upload(file.getBytes(), fileName); return Result.success(filePath); } catch (IOException e) { log.error("文件上传失败:{}", e.getMessage()); } return Result.error(MessageConstant.UPLOAD_FAILED); } }

测试一下，可以正常上传

新增菜品

DishController

@RestController @RequestMapping("/admin/dish") @Api(tags = "菜品相关接口") @Slf4j public class DishController { @Autowired private DishService dishService; /** * 新增菜品 * @param dishDTO * @return */ @PostMapping @ApiOperation("新增菜品") public Result<String> save(@RequestBody DishDTO dishDTO){ log.info("新增菜品：{}", dishDTO); dishService.saveWithFlavor(dishDTO); return Result.success(); } }

DishService

public interface DishService { /** * 新增菜品 * @param dishDTO */ void saveWithFlavor(DishDTO dishDTO); }

DishServiceImpl

@Service public class DishServiceImpl implements DishService { @Autowired private DishMapper dishMapper; @Autowired private DishFlavorMapper dishFlavorMapper; /** * 新增菜品 * @param dishDTO */ @Transactional public void saveWithFlavor(DishDTO dishDTO) { Dish dish = new Dish(); BeanUtils.copyProperties(dishDTO, dish); //向菜品表dish插入1条数据 dishMapper.insert(dish); //获取菜品的主键值 Long dishId = dish.getId(); List<DishFlavor> flavors = dishDTO.getFlavors(); if(flavors != null && flavors.size() > 0){ //向口味表dish_flavor插入n条 flavors.forEach(dishFlavor -> { dishFlavor.setDishId(dishId); }); //批量插入 dishFlavorMapper.insertBatch(flavors); } } }

DishMapper

/** * 插入菜品数据 * @param dish */ @AutoFill(OperationType.INSERT) void insert(Dish dish);

DishMapper.xml

<!-- useGeneratedKeys:true 表示获取主键值 keyProperty="id" 表示将主键值赋给id属性--> <insert id="insert" useGeneratedKeys="true" keyProperty="id"> insert into dish (status, name, category_id, price, image, description, create_time, update_time, create_user,update_user) values (#{status}, #{name}, #{categoryId}, #{price}, #{image}, #{description}, #{createTime}, #{updateTime},#{createUser}, #{updateUser}) </insert>

DishFlavorMapper

@Mapper public interface DishFlavorMapper { /** * 批量插入口味数据 * @param flavors */ void insertBatch(List<DishFlavor> flavors); }

DishFlavorMapper.xml

<insert id="insertBatch"> insert into dish_flavor(dish_id, name, value) values <foreach collection="flavors" item="dishFlavor" separator=","> (#{dishFlavor.dishId},#{dishFlavor.name},#{dishFlavor.value}) </foreach> </insert>

菜品分页查询

需求分析和设计

代码开发

DishController

/** * 菜品分页查询 * @param dishPageQueryDTO * @return */ @GetMapping("/page") @ApiOperation("菜品分页查询") public Result<PageResult> page(DishPageQueryDTO dishPageQueryDTO){ log.info("菜品分页查询：{}", dishPageQueryDTO); PageResult pageResult = dishService.pageQuery(dishPageQueryDTO); return Result.success(pageResult); }

DishService

/** * 菜品分页查询 * @param dishPageQueryDTO * @return */ PageResult pageQuery(DishPageQueryDTO dishPageQueryDTO);

DishServiceImpl

/** * 菜品分页查询 * @param dishPageQueryDTO * @return */ public PageResult pageQuery(DishPageQueryDTO dishPageQueryDTO) { PageHelper.startPage(dishPageQueryDTO.getPage(), dishPageQueryDTO.getPageSize()); Page<DishVO> page = dishMapper.pageQuery(dishPageQueryDTO); return new PageResult(page.getTotal(), page.getResult()); }

DishMapper

DTO：接收前端传给后端的数据（入参） VO：后端返回给前端的数据（出参）

/** * 菜品分页查询 * @param dishPageQueryDTO * @return */ Page<DishVO> pageQuery(DishPageQueryDTO dishPageQueryDTO);

DishMapper.xml

涉及多表查询，左连接

<select id="pageQuery" resultType="com.sky.vo.DishVO"> select d.*,c.name categoryName from dish d left join category c on d.category_id = c.id <where> <if test="name != null"> and d.name like concat('%',#{name},'%') </if> <if test="categoryId != null"> and d.category_id = #{categoryId} </if> <if test="status != null"> and d.status = #{status} </if> </where> order by d.create_time desc </select>

删除菜品

需求分析和设计

接口

数据库

代码开发

注意这里有批量删除，一旦选中的菜品绑定套餐，全部的都无法删除

DishController

/** * 品批量删除 * @param ids * @return */ @DeleteMapping @ApiOperation("菜品批量删除") public Result delete(@RequestParam List<Long> ids){ log.info("菜品批量删除：{}", ids); dishService.deleteBatch(ids); return Result.success(); }

DishService

void deleteBatch(List<Long> ids);

DishServiceImpl

@Transactional public void deleteBatch(List<Long> ids) { ids.forEach(id->{ Dish dish = dishMapper.getById(id); //判断当前要删除的菜品状态是否为起售中 if(dish.getStatus() == StatusConstant.ENABLE){ //如果是起售中，抛出业务异常 throw new DeletionNotAllowedException(MessageConstant.DISH_ON_SALE); } }); //判断当前要删除的菜品是否被套餐关联了 List<Long> setmealIds = setmealDishMapper.getSetmealIdsByDishIds(ids); if(setmealIds != null && setmealIds.size() > 0){ //如果关联了，抛出业务异常 throw new DeletionNotAllowedException(MessageConstant.DISH_BE_RELATED_BY_SETMEAL); } //删除菜品表中的数据 ids.forEach(id -> { dishMapper.deleteById(id); //删除口味表中的数据 dishFlavorMapper.deleteByDishId(id); });

DishMapper

/** * 根据主键查询菜品数据 * @param id * @return */ @Select("select * from dish where id = #{id}") Dish getById(Long id); /** * 根据主键删除菜品数 * @param id */ @Delete("delete from dish where id = #{id}") void deleteById(Long id);

SetmealDishMapper

@Mapper public interface SetmealDishMapper { /**根据菜品id查询关联的套餐id * @param ids * @return */ List<Long> getSetmealIdsByDishIds(List<Long> ids); }

SetmealDishMapper.xml

<select id="getSetmealIdsByDishIds" resultType="java.lang.Long"> select setmeal_id from setmeal_dish where dish_id in <foreach collection="ids" separator="," open="(" close=")" item="dishId"> #{dishId} </foreach> </select>

DishFlavorMapper

/** * 根据菜品id删除口味数据 * @param dishId */ @Delete("delete from dish_flavor where dish_id = #{dishId}") void deleteByDishId(Long dishId);

修改菜品

需求分析和设计

根据id查询菜品

修改菜品

代码开发

根据id查询菜品

DishController

/** * 根据id查询菜品和关联的口味数据 * @param id * @return */ @GetMapping("/{id}") @ApiOperation("根据id查询菜品和关联的口味数据") public Result<DishVO> getById(@PathVariable Long id){ return Result.success(dishService.getByIdWithFlavor(id)); }

DishService

/** * 根据id查询菜品和关联的口味数据 * @param id * @return */ DishVO getByIdWithFlavor(Long id);

DishServiceImpl

/** * 根据id查询菜品和关联的口味数据 * * @param id * @return */ public DishVO getByIdWithFlavor(Long id) { //查询菜品表 Dish dish = dishMapper.getById(id); //查询关联的口味 List<DishFlavor> dishFlavorList = dishFlavorMapper.getByDishId(id); //封装成VO DishVO dishVO = new DishVO(); BeanUtils.copyProperties(dish, dishVO); dishVO.setFlavors(dishFlavorList); return dishVO; }

DishFlavorMapper

/** * 根据菜品id查询对应的口味 * @param dishId * @return */ @Select("select * from dish_flavor where dish_id = #{dishId}") List<DishFlavor> getByDishId(Long dishId);

修改菜品

DishController

/** * 修改菜品 * @param dishDTO * @return */ @PutMapping @ApiOperation("修改菜品") public Result update(@RequestBody DishDTO dishDTO){ log.info("修改菜品：{}", dishDTO); dishService.updateWithFlavor(dishDTO); return Result.success(); }

DishService

/** * 根据id修改菜品和关联的口味 * @param dishDTO */ void updateWithFlavor(DishDTO dishDTO);

DishServiceImpl

/** * 根据id修改菜品和关联的口味 * * @param dishDTO */ @Transactional public void updateWithFlavor(DishDTO dishDTO) { Dish dish = new Dish(); BeanUtils.copyProperties(dishDTO, dish); //修改菜品表dish，执行update操作 dishMapper.update(dish); //删除当前菜品关联的口味数据，操作dish_flavor，执行delete操作 dishFlavorMapper.deleteByDishId(dishDTO.getId()); //插入最新的口味数据，操作dish_flavor，执行insert操作 List<DishFlavor> flavors = dishDTO.getFlavors(); if (flavors != null && flavors.size() > 0) { flavors.forEach(dishFlavor -> { dishFlavor.setDishId(dishDTO.getId()); }); dishFlavorMapper.insertBatch(flavors); } }

DishMapper

/** * 根据主键修改菜品信息 * @param dish */ @AutoFill(OperationType.UPDATE) void update(Dish dish);

DishMapper.xml

<update id="update"> update dish <set> <if test="name != null"> name = #{name}, </if> <if test="categoryId != null"> category_id = #{categoryId}, </if> <if test="price != null"> price = #{price}, </if> <if test="image != null"> image = #{image}, </if> <if test="description != null"> description = #{description}, </if> <if test="status != null"> status = #{status}, </if> <if test="updateTime != null"> update_time = #{updateTime}, </if> <if test="updateUser != null"> update_user = #{updateUser}, </if> </set> where id = #{id} </update>

菜品起售停售

需求分析和设计

代码开发

DishController

/** * 菜品起售停售 * @param status * @param id * @return */ @PostMapping("/status/{status}") @ApiOperation("菜品起售停售") public Result<String> startOrStop(@PathVariable Integer status, Long id){ dishService.startOrStop(status,id); return Result.success(); }

DishService

/** * 菜品起售停售 * @param status * @param id */ void startOrStop(Integer status, Long id);

DishServiceImpl

/** * 菜品起售停售 * * @param status * @param id */ @Transactional public void startOrStop(Integer status, Long id) { Dish dish = Dish.builder() .id(id) .status(status) .build(); dishMapper.update(dish); if (status == StatusConstant.DISABLE) { // 如果是停售操作，还需要将包含当前菜品的套餐也停售 List<Long> dishIds = new ArrayList<>(); dishIds.add(id); // select setmeal_id from setmeal_dish where dish_id in (?,?,?) List<Long> setmealIds = setmealDishMapper.getSetmealIdsByDishIds(dishIds); if (setmealIds != null && setmealIds.size() > 0) { for (Long setmealId : setmealIds) { Setmeal setmeal = Setmeal.builder() .id(setmealId) .status(StatusConstant.DISABLE) .build(); setmealMapper.update(setmeal); } } } }

SetmealMapper

/** * 根据id修改套餐 * * @param setmeal */ @AutoFill(OperationType.UPDATE) void update(Setmeal setmeal);

SetmealMapper.xml

<update id="update" parameterType="Setmeal"> update setmeal <set> <if test="name != null"> name = #{name}, </if> <if test="categoryId != null"> category_id = #{categoryId}, </if> <if test="price != null"> price = #{price}, </if> <if test="status != null"> status = #{status}, </if> <if test="description != null"> description = #{description}, </if> <if test="image != null"> image = #{image}, </if> <if test="updateTime != null"> update_time = #{updateTime}, </if> <if test="updateUser != null"> update_user = #{updateUser} </if> </set> where id = #{id} </update>