学习目标

1、完成区域管理开发

2、完成桌台管理开发

3、完成分类管理开发

4、完成菜品管理开发

第一章 商家平台-区域管理

  1.     在商家用户建立品牌、门店、员工后，就需要对当前的门店划分区域，每个门店都可以维护自己的餐厅区域,注意的桌台的数据归属我们采用多租户功能区实现这里不需要考虑【多租户】后面有专题去简介

1、功能区拆解

image.png

红色区域：此处为查询条件功能区，筛选列表信息

功能 说明
区域名称 输入区域名称，键盘按enter触发搜索列表
状态 下拉框，显示【启用、禁用】，change触发搜索列表

蓝色区域：区域维护功能

功能 说明
添加 新增区域信息
修改 修改区域信息
删除 删除区域信息==【真实删除】==，删除时，会有再次确认提示
禁用、启用 禁用启用区域

2、数据库结构

  1. CREATE TABLE `tab_table_area` (
  2.   `id` bigint(18) NOT NULL COMMENT '桌台区域id',
  3.   `area_name` varchar(64) COLLATE utf8_bin NOT NULL COMMENT '区域名称',
  4.   `created_time` datetime DEFAULT NULL COMMENT '创建时间',
  5.   `updated_time` datetime DEFAULT NULL COMMENT '创建时间',
  6.   `sharding_id` bigint(18) DEFAULT NULL COMMENT '分库id',
  7.   `store_id` bigint(18) NOT NULL COMMENT '门店主键id',
  8.   `enterprise_id` bigint(18) NOT NULL COMMENT '商户号',
  9.   `sort_no` int(11) DEFAULT NULL COMMENT '排序',
  10.   `enable_flag` varchar(10) CHARACTER SET utf8 NOT NULL COMMENT '是否有效',
  11.   PRIMARY KEY (`id`)
  12. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='桌台区域';

自动填充：

下列字段，无需手动填充，系统会自动填充下列字段

字段 注释 填充方式
id 主键 雪花算法
enterprise_id 商户号 mybatis-plus-多租户拦截
created_time 创建时间 mybatis-plus-自动填充组件
updated_time 修改时间 mybatis-plus-自动填充组件
sharding_id 分库id mybatis-plus-自动填充组件
store_id 门店id mybatis-plus-多租户拦截

3、功能开发

在开始业务开发之前，我们首先看一下区域管理的UML图

image.png

TableAreaController：对TableAreaFace接口进行dubbo的RPC调用，为dubbo服务的消费者

TableAreaFace：区域管理dubbo接口定义

TableAreaFaceImpl：区域管理dubbo接口定义实现，这里做VO和POJO的转换

ITableAreaService：区域管理的业务接口定义，为TableAreaFaceImpl提供核心业务逻辑的定义

TableAreaServiceImpl：区域管理的业务接口定义实现

3.1、TableAreaFace接口

TableAreaFace：区域管理dubbo接口定义

  1. package com.itheima.restkeeper;
  3. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  4. import com.itheima.restkeeper.exception.ProjectException;
  5. import com.itheima.restkeeper.req.TableAreaVo;
  7. import java.util.List;
  9. /**
  10.  * @ClassName TableAreaFace.java
  11.  * @Description 桌台区域dubbo服务
  12.  */
  13. public interface TableAreaFace {
  15.     /**
  16.      * @param tableAreaVo 查询条件
  17.      * @param pageNum     当前页
  18.      * @param pageSize    每页大小
  19.      * @return Page<TableAreaVo>
  20.      * @Description 区域列表
  21.      */
  22.     Page<TableAreaVo> findTableAreaVoPage(TableAreaVo tableAreaVo,
  23.                                           int pageNum,
  24.                                           int pageSize)throws ProjectException;
  26.     /**
  27.      * @param tableAreaVo 对象信息
  28.      * @return TableAreaVo
  29.      * @Description 创建区域
  30.      */
  31.     TableAreaVo createTableArea(TableAreaVo tableAreaVo)throws ProjectException;
  33.     /**
  34.      * @param tableAreaVo 对象信息
  35.      * @return Boolean
  36.      * @Description 修改区域
  37.      */
  38.     Boolean updateTableArea(TableAreaVo tableAreaVo)throws ProjectException;
  40.     /**
  41.      * @param checkedIds 选择对象信息Id
  42.      * @return Boolean
  43.      * @Description 删除区域
  44.      */
  45.     Boolean deleteTableArea(String[] checkedIds)throws ProjectException;
  48.     /**
  49.      * @param tableAreaId 选择对象信息Id
  50.      * @return TableAreaVo
  51.      * @Description 查找区域
  52.      */
  53.     TableAreaVo findTableAreaByTableAreaId(Long tableAreaId)throws ProjectException;
  55.     /***
  56.      * @description 查询区域下拉框
  57.      * @return: List<TableAreaVo>
  58.      */
  59.     List<TableAreaVo> findTableAreaVoList()throws ProjectException;
  60. }

3.2、TableAreaFaceImpl接口实现

TableAreaFaceImpl：区域管理dubbo接口定义实现，这里做VO和POJO的转换

  1. package com.itheima.restkeeper.face;
  3. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  4. import com.itheima.restkeeper.TableAreaFace;
  5. import com.itheima.restkeeper.enums.TableAreaEnum;
  6. import com.itheima.restkeeper.exception.ProjectException;
  7. import com.itheima.restkeeper.pojo.TableArea;
  8. import com.itheima.restkeeper.req.TableAreaVo;
  9. import com.itheima.restkeeper.service.ITableAreaService;
  10. import com.itheima.restkeeper.utils.BeanConv;
  11. import com.itheima.restkeeper.utils.EmptyUtil;
  12. import com.itheima.restkeeper.utils.ExceptionsUtil;
  13. import lombok.extern.slf4j.Slf4j;
  14. import org.apache.dubbo.config.annotation.DubboService;
  15. import org.apache.dubbo.config.annotation.Method;
  16. import org.springframework.beans.factory.annotation.Autowired;
  18. import java.util.List;
  20. /**
  21.  * @ClassName TableAreaFaceImpl.java
  22.  * @Description 桌台区域dubbo服务
  23.  */
  24. @Slf4j
  25. @DubboService(version = "${dubbo.application.version}",timeout = 5000,
  26.     methods ={
  27.         @Method(name = "findTableAreaVoPage",retries = 2),
  28.         @Method(name = "createTableArea",retries = 0),
  29.         @Method(name = "updateTableArea",retries = 0),
  30.         @Method(name = "deleteTableArea",retries = 0)
  31.     })
  32. public class TableAreaFaceImpl implements TableAreaFace {
  34.     @Autowired
  35.     ITableAreaService tableAreaService;
  37.     @Override
  38.     public Page<TableAreaVo> findTableAreaVoPage(TableAreaVo tableAreaVo,
  39.                                                  int pageNum,
  40.                                                  int pageSize)throws ProjectException {
  41.         try {
  42.             //查询区域分页
  43.             Page<TableArea> page = tableAreaService.findTableAreaVoPage(tableAreaVo, pageNum, pageSize);
  44.             Page<TableAreaVo> pageVo = new Page<>();
  45.             BeanConv.toBean(page,pageVo);
  46.             //结果集转换
  47.             List<TableArea> tableAreaList = page.getRecords();
  48.             List<TableAreaVo> tableAreaVoList = BeanConv.toBeanList(tableAreaList,TableAreaVo.class);
  49.             pageVo.setRecords(tableAreaVoList);
  50.             //返回结果
  51.             return pageVo;
  52.         } catch (Exception e) {
  53.             log.error("查询区域列表异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  54.             throw new ProjectException(TableAreaEnum.PAGE_FAIL);
  55.         }
  57.     }
  59.     @Override
  60.     public TableAreaVo createTableArea(TableAreaVo tableAreaVo) throws ProjectException{
  61.         try {
  62.             //创建区域
  63.             return BeanConv.toBean( tableAreaService.createTableArea(tableAreaVo), TableAreaVo.class);
  64.         } catch (Exception e) {
  65.             log.error("保存区域异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  66.             throw new ProjectException(TableAreaEnum.CREATE_FAIL);
  67.         }
  68.     }
  70.     @Override
  71.     public Boolean updateTableArea(TableAreaVo tableAreaVo) throws ProjectException{
  72.         try {
  73.             //修改区域
  74.             return tableAreaService.updateTableArea(tableAreaVo);
  75.         } catch (Exception e) {
  76.             log.error("保存区域异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  77.             throw new ProjectException(TableAreaEnum.UPDATE_FAIL);
  78.         }
  79.     }
  81.     @Override
  82.     public Boolean deleteTableArea(String[] checkedIds)throws ProjectException {
  83.         try {
  84.             //删除区域
  85.             return tableAreaService.deleteTableArea(checkedIds);
  86.         } catch (Exception e) {
  87.             log.error("删除区域异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  88.             throw new ProjectException(TableAreaEnum.DELETE_FAIL);
  89.         }
  90.     }
  92.     @Override
  93.     public TableAreaVo findTableAreaByTableAreaId(Long tableAreaId)throws ProjectException {
  94.         try {
  95.             //按id查询区域
  96.             TableArea tableArea = tableAreaService.getById(tableAreaId);
  97.             if (!EmptyUtil.isNullOrEmpty(tableArea)){
  98.                 return BeanConv.toBean(tableArea,TableAreaVo.class);
  99.             }
  100.             return null;
  101.         } catch (Exception e) {
  102.             log.error("查找区域所有区域异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  103.             throw new ProjectException(TableAreaEnum.SELECT_AREA_FAIL);
  104.         }
  105.     }
  107.     @Override
  108.     public List<TableAreaVo> findTableAreaVoList()throws ProjectException {
  109.         try {
  110.             //查询区域
  111.             return BeanConv.toBeanList(tableAreaService.findTableAreaVoList(),TableAreaVo.class);
  112.         } catch (Exception e) {
  113.             log.error("查找区域所有区域异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  114.             throw new ProjectException(TableAreaEnum.SELECT_AREA_LIST_FAIL);
  115.         }
  116.     }
  117. }

3.3、ITableAreaService业务接口

ITableAreaService：区域管理的业务接口定义，为TableAreaFaceImpl提供核心业务逻辑的定义

  1. package com.itheima.restkeeper.service;
  3. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  4. import com.itheima.restkeeper.pojo.TableArea;
  5. import com.itheima.restkeeper.pojo.TableArea;
  6. import com.baomidou.mybatisplus.extension.service.IService;
  7. import com.itheima.restkeeper.req.TableAreaVo;
  9. import java.util.List;
  11. /**
  12.  * @Description：桌台区域 服务类
  13.  */
  14. public interface ITableAreaService extends IService<TableArea> {
  16.     /**
  17.      * @Description 区域列表
  18.      * @param tableAreaVo 查询条件
  19.      * @param pageNum     当前页
  20.      * @param pageSize    每页大小
  21.      * @return Page<TableArea>
  22.      */
  23.     Page<TableArea> findTableAreaVoPage(TableAreaVo tableAreaVo, int pageNum, int pageSize);
  25.     /**
  26.      * @Description 创建区域
  27.      * @param tableAreaVo 对象信息
  28.      * @return TableArea
  29.      */
  30.     TableArea createTableArea(TableAreaVo tableAreaVo);
  32.     /**
  33.      * @Description 修改区域
  34.      * @param tableAreaVo 对象信息
  35.      * @return Boolean
  36.      */
  37.     Boolean updateTableArea(TableAreaVo tableAreaVo);
  39.     /**
  40.      * @Description 删除区域
  41.      * @param checkedIds 选择的区域ID
  42.      * @return Boolean
  43.      */
  44.     Boolean deleteTableArea(String[] checkedIds);
  46.     /***
  47.      * @description 查询区域下拉框
  48.      * @return:  List<TableArea>
  49.      */
  50.     List<TableArea> findTableAreaVoList();
  52. }

3.4、TableAreaServiceImpl接口实现

TableAreaServiceImpl：区域管理的业务接口定义实现

  1. package com.itheima.restkeeper.service.impl;
  3. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  4. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  5. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  6. import com.itheima.restkeeper.basic.BasicPojo;
  7. import com.itheima.restkeeper.constant.SuperConstant;
  8. import com.itheima.restkeeper.mapper.TableAreaMapper;
  9. import com.itheima.restkeeper.pojo.TableArea;
  10. import com.itheima.restkeeper.req.TableAreaVo;
  11. import com.itheima.restkeeper.service.ITableAreaService;
  12. import com.itheima.restkeeper.utils.BeanConv;
  13. import com.itheima.restkeeper.utils.EmptyUtil;
  14. import org.springframework.stereotype.Service;
  16. import java.util.ArrayList;
  17. import java.util.Arrays;
  18. import java.util.List;
  20. /**
  21.  * @Description：桌台区域 服务实现类
  22.  */
  23. @Service
  24. public class TableAreaServiceImpl extends ServiceImpl<TableAreaMapper, TableArea> implements ITableAreaService {
  26.     @Override
  27.     public Page<TableArea> findTableAreaVoPage(TableAreaVo tableAreaVo, int pageNum, int pageSize) {
  28.         //构建分页对象
  29.         Page<TableArea> page = new Page<>(pageNum,pageSize);
  30.         QueryWrapper<TableArea> queryWrapper = new QueryWrapper<>();
  31.         //按区域名称查询
  32.         if (!EmptyUtil.isNullOrEmpty(tableAreaVo.getAreaName())) {
  33.             queryWrapper.lambda().likeRight(TableArea::getAreaName,tableAreaVo.getAreaName());
  34.         }
  35.         //按是否有效查询
  36.         if (!EmptyUtil.isNullOrEmpty(tableAreaVo.getEnableFlag())) {
  37.             queryWrapper.lambda().eq(TableArea::getEnableFlag,tableAreaVo.getEnableFlag());
  38.         }
  39.         //按sortNo升序排列
  40.         queryWrapper.lambda().orderByAsc(TableArea::getSortNo);
  41.         //返回结果
  42.         return page(page, queryWrapper);
  43.     }
  45.     @Override
  46.     public TableArea createTableArea(TableAreaVo tableAreaVo) {
  47.         //转换TableAreaVo为TableArea
  48.         TableArea tableArea = BeanConv.toBean(tableAreaVo, TableArea.class);
  49.         //执行保存
  50.         boolean flag = save(tableArea);
  51.         if (flag){
  52.             return tableArea;
  53.         }
  54.         return null;
  55.     }
  57.     @Override
  58.     public Boolean updateTableArea(TableAreaVo tableAreaVo) {
  59.         //转换TableAreaVo为TableArea
  60.         TableArea tableArea = BeanConv.toBean(tableAreaVo, TableArea.class);
  61.         //按ID执行修改
  62.         return updateById(tableArea);
  63.     }
  65.     @Override
  66.     public Boolean deleteTableArea(String[] checkedIds) {
  67.         //构建选中的List<Sring>集合
  68.         List<String> ids = Arrays.asList(checkedIds);
  69.         List<Long> idsLong = new ArrayList<>();
  70.         ids.forEach(n->{
  71.             idsLong.add(Long.valueOf(n));
  72.         });
  73.         //批量删除
  74.         return removeByIds(idsLong);
  75.     }
  77.     @Override
  78.     public List<TableArea> findTableAreaVoList() {
  79.         //构建查询条件
  80.         QueryWrapper<TableArea> queryWrapper = new QueryWrapper<>();
  81.         queryWrapper.lambda().eq(BasicPojo::getEnableFlag, SuperConstant.YES);
  82.         //执行list查询
  83.         return list(queryWrapper);
  84.     }
  85. }

3.5、TableAreaController类

TableAreaController：对TableAreaFace接口进行dubbo的RPC调用，为dubbo服务的消费者

  1. package com.itheima.restkeeper.web;
  3. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  4. import com.itheima.restkeeper.TableAreaFace;
  5. import com.itheima.restkeeper.basic.ResponseWrap;
  6. import com.itheima.restkeeper.enums.TableAreaEnum;
  7. import com.itheima.restkeeper.exception.ProjectException;
  8. import com.itheima.restkeeper.req.TableAreaVo;
  9. import com.itheima.restkeeper.utils.EmptyUtil;
  10. import com.itheima.restkeeper.utils.ExceptionsUtil;
  11. import com.itheima.restkeeper.utils.ResponseWrapBuild;
  12. import io.swagger.annotations.Api;
  13. import io.swagger.annotations.ApiImplicitParam;
  14. import io.swagger.annotations.ApiImplicitParams;
  15. import io.swagger.annotations.ApiOperation;
  16. import lombok.extern.slf4j.Slf4j;
  17. import org.apache.dubbo.config.annotation.DubboReference;
  18. import org.springframework.validation.annotation.Validated;
  19. import org.springframework.web.bind.annotation.*;
  21. import java.util.List;
  23. /**
  24.  * @ClassName TableAreaController.java
  25.  * @Description 区域Controller
  26.  */
  27. @RestController
  28. @RequestMapping("table-area")
  29. @Slf4j
  30. @Api(tags = "区域controller")
  31. public class TableAreaController {
  33.     @DubboReference(version = "${dubbo.application.version}",check = false)
  34.     TableAreaFace tableAreaFace;
  36.     /**
  37.      * @Description 区域列表
  38.      * @param tableAreaVo 查询条件
  39.      * @return
  40.      */
  41.     @PostMapping("page/{pageNum}/{pageSize}")
  42.     @ApiOperation(value = "查询区域分页",notes = "查询区域分页")
  43.     @ApiImplicitParams({
  44.        @ApiImplicitParam(name = "tableAreaVo",value = "区域查询对象",dataType = "TableAreaVo"),
  45.        @ApiImplicitParam(paramType = "path",name = "pageNum",value = "页码",dataType = "Integer"),
  46.        @ApiImplicitParam(paramType = "path",name = "pageSize",value = "每页条数",dataType = "Integer")
  47.     })
  48.     public ResponseWrap<Page<TableAreaVo>> findTableAreaVoPage(
  49.         @RequestBody TableAreaVo tableAreaVo,
  50.         @PathVariable("pageNum") int pageNum,
  51.         @PathVariable("pageSize") int pageSize) {
  52.         Page<TableAreaVo> tableAreaVoPage = tableAreaFace.findTableAreaVoPage(tableAreaVo, pageNum, pageSize);
  53.         return ResponseWrapBuild.build(TableAreaEnum.SUCCEED,tableAreaVoPage);
  54.     }
  56.     /**
  57.      * @Description 添加区域
  58.      * @param tableAreaVo 对象信息
  59.      * @return
  60.      */
  61.     @PostMapping
  62.     @ApiOperation(value = "添加区域",notes = "添加区域")
  63.     @ApiImplicitParam(name = "tableAreaVo",value = "区域对象",required = true,dataType = "TableAreaVo")
  64.     ResponseWrap<TableAreaVo> createTableArea(@RequestBody TableAreaVo tableAreaVo) {
  65.         TableAreaVo tableAreaVoResult = tableAreaFace.createTableArea(tableAreaVo);
  66.         return ResponseWrapBuild.build(TableAreaEnum.SUCCEED,tableAreaVoResult);
  67.     }
  69.     /**
  70.      * @Description 修改区域
  71.      * @param tableAreaVo 对象信息
  72.      * @return
  73.      */
  74.     @PatchMapping
  75.     @ApiOperation(value = "修改区域",notes = "修改区域")
  76.     @ApiImplicitParam(name = "tableAreaVo",value = "区域对象",required = true,dataType = "TableAreaVo")
  77.     ResponseWrap<Boolean> updateTableArea(@RequestBody TableAreaVo tableAreaVo) {
  78.         Boolean flag = tableAreaFace.updateTableArea(tableAreaVo);
  79.         return ResponseWrapBuild.build(TableAreaEnum.SUCCEED,flag);
  80.     }
  82.     /**
  83.      * @Description 删除区域
  84.      * @param tableAreaVo 查询对象
  85.      * @return
  86.      */
  87.     @DeleteMapping
  88.     @ApiOperation(value = "删除区域",notes = "删除区域")
  89.     @ApiImplicitParam(name = "tableAreaVo",value = "区域查询对象",required = true,dataType = "TableAreaVo")
  90.     ResponseWrap<Boolean> deleteTableArea(@RequestBody TableAreaVo tableAreaVo ) {
  91.         //获得所有选择的区域IDS
  92.         String[] checkedIds = tableAreaVo.getCheckedIds();
  93.         Boolean flag = tableAreaFace.deleteTableArea(checkedIds);
  94.         return ResponseWrapBuild.build(TableAreaEnum.SUCCEED,flag);
  95.     }
  97.     /**
  98.      * @Description 查找区域
  99.      * @param tableAreaId 区域id
  100.      * @return
  101.      */
  102.     @GetMapping("{tableAreaId}")
  103.     @ApiOperation(value = "查找区域",notes = "查找区域")
  104.     @ApiImplicitParam(paramType = "path",name = "tableAreaId",value = "区域Id",example = "1",dataType = "Long")
  105.     ResponseWrap<TableAreaVo> findTableAreaByTableAreaId(@PathVariable("tableAreaId") Long tableAreaId) {
  106.         TableAreaVo tableAreaVo = tableAreaFace.findTableAreaByTableAreaId(tableAreaId);
  107.         return ResponseWrapBuild.build(TableAreaEnum.SUCCEED, tableAreaVo);
  108.     }
  110.     /**
  111.      * @Description 查找区域
  112.      * @return
  113.      */
  114.     @GetMapping("list")
  115.     @ApiOperation(value = "查找区域列表",notes = "查找区域列表")
  116.     ResponseWrap<List<TableAreaVo>> findTableAreaVoList() {
  117.         List<TableAreaVo> list = tableAreaFace.findTableAreaVoList();
  118.         return ResponseWrapBuild.build(TableAreaEnum.SUCCEED,list);
  119.     }
  121.     @PostMapping("update-tableArea-enableFlag")
  122.     @ApiOperation(value = "修改区域状态",notes = "修改区域状态")
  123.     ResponseWrap<Boolean> updateTableAreaEnableFlag(@RequestBody TableAreaVo tableAreaVo) {
  124.         Boolean flag = tableAreaFace.updateTableArea(tableAreaVo);
  125.         return ResponseWrapBuild.build(TableAreaEnum.SUCCEED,flag);
  126.     }
  127. }

第二章 商家平台-桌台管理

  1.     商家建立区域后，需要为区域指定对于的桌台，桌台的就餐人数，以及各种状态【空闲、开桌、锁桌】等切换，注意的桌台的数据归属我们采用多租户功能区实现这里不需要考虑【多租户】后面有专题去简介

image.png

1、功能区拆解

image.png

红色区域：此处为查询条件功能区，筛选列表信息

功能 说明
桌台名称 输入桌台名称，键盘按enter触发搜索列表
就餐人数 输入就餐人数，键盘按enter触发搜索列
桌台状体 下拉框，显示【空闲、开台、锁桌】，change触发搜索列表
状态 下拉框，显示【启用、禁用】，change触发搜索列表

蓝色区域：桌台维护功能

功能 说明
添加 新增桌台信息
修改 修改桌台信息
删除 删除桌台信息==【真实删除】==，删除时，会有再次确认提示
禁用、启用 禁用启用桌台
空闲、锁台 切换桌台状态

2、数据库结构

  1. CREATE TABLE `tab_table` (
  2.   `id` bigint(18) NOT NULL COMMENT '桌台id',
  3.   `area_id` bigint(18) DEFAULT NULL COMMENT '区域ID',
  4.   `table_name` varchar(64) COLLATE utf8_bin NOT NULL COMMENT '桌台名称',
  5.   `table_seat_number` int(11) NOT NULL COMMENT '桌台座位数目',
  6.   `table_status` varchar(32) COLLATE utf8_bin NOT NULL COMMENT 'FREE:空闲 USER:开桌  lOCK 锁桌',
  7.   `created_time` datetime DEFAULT NULL COMMENT '创建时间',
  8.   `updated_time` datetime DEFAULT NULL COMMENT '创建时间',
  9.   `sharding_id` bigint(18) DEFAULT NULL COMMENT '分库id',
  10.   `store_id` bigint(18) NOT NULL COMMENT '门店主键id',
  11.   `enterprise_id` bigint(18) NOT NULL COMMENT '商户号',
  12.   `sort_no` int(11) DEFAULT NULL COMMENT '排序',
  13.   `enable_flag` varchar(10) CHARACTER SET utf8 NOT NULL COMMENT '是否有效',
  14.   PRIMARY KEY (`id`)
  15. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='桌台';

自动填充：

下列字段，无需手动填充，系统会自动填充下列字段

字段 注释 填充方式
id 主键 雪花算法
enterprise_id 商户号 mybatis-plus-多租户拦截
created_time 创建时间 mybatis-plus-自动填充组件
updated_time 修改时间 mybatis-plus-自动填充组件
sharding_id 分库id mybatis-plus-自动填充组件
store_id 门店id mybatis-plus-多租户拦截

3、功能开发

image.png

TableController：对TableFace接口进行dubbo的RPC调用，为dubbo服务的消费者

TableFace：桌台管理dubbo接口定义

TableFaceImpl：桌台管理dubbo接口定义实现，这里做VO和POJO的转换

ITableService：桌台管理的业务接口定义，为TableFaceImpl提供核心业务逻辑的定义

TableServiceImpl：桌台管理的业务接口定义实现

3.1、TableFace接口

桌台管理dubbo接口定义

  1. package com.itheima.restkeeper;
  3. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  4. import com.itheima.restkeeper.exception.ProjectException;
  5. import com.itheima.restkeeper.req.TableVo;
  7. import java.util.List;
  9. /**
  10.  * @Description 桌台dubbo接口服务
  11.  */
  12. public interface TableFace {
  14.     /**
  15.      * @param tableVo  查询条件
  16.      * @param pageNum  当前页
  17.      * @param pageSize 每页大小
  18.      * @return
  19.      * @Description 桌台列表
  20.      */
  21.     Page<TableVo> findTableVoPage(TableVo tableVo,
  22.                                   int pageNum,
  23.                                   int pageSize)throws ProjectException;
  25.     /**
  26.      * @param tableVo 对象信息
  27.      * @return TableVo
  28.      * @Description 创建桌台
  29.      */
  30.     TableVo createTable(TableVo tableVo)throws ProjectException;
  32.     /**
  33.      * @param tableVo 对象信息
  34.      * @return Boolean
  35.      * @Description 修改桌台
  36.      */
  37.     Boolean updateTable(TableVo tableVo)throws ProjectException;
  39.     /**
  40.      * @param checkedIds 选择对象信息Id
  41.      * @return Boolean
  42.      * @Description 删除桌台
  43.      */
  44.     Boolean deleteTable(String[] checkedIds)throws ProjectException;
  47.     /**
  48.      * @param tableId 选择对象信息Id
  49.      * @return TableVo
  50.      * @Description 查找桌台
  51.      */
  52.     TableVo findTableByTableId(Long tableId)throws ProjectException;
  54.     /***
  55.      * @description 查询桌台下拉框
  56.      * @return: List<TableVo>
  57.      */
  58.     List<TableVo> findTableVoList()throws ProjectException;
  59. }

3.2、TableFaceImpl接口实现

桌台管理dubbo接口定义实现，这里做VO和POJO的转换

  1. package com.itheima.restkeeper.face;
  3. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  4. import com.itheima.restkeeper.TableFace;
  5. import com.itheima.restkeeper.enums.TableEnum;
  6. import com.itheima.restkeeper.exception.ProjectException;
  7. import com.itheima.restkeeper.pojo.Table;
  8. import com.itheima.restkeeper.req.TableVo;
  9. import com.itheima.restkeeper.service.ITableService;
  10. import com.itheima.restkeeper.utils.BeanConv;
  11. import com.itheima.restkeeper.utils.EmptyUtil;
  12. import com.itheima.restkeeper.utils.ExceptionsUtil;
  13. import com.itheima.restkeeper.utils.ResponseWrapBuild;
  14. import io.seata.spring.annotation.GlobalTransactional;
  15. import lombok.extern.slf4j.Slf4j;
  16. import org.apache.dubbo.config.annotation.DubboService;
  17. import org.apache.dubbo.config.annotation.Method;
  18. import org.springframework.beans.factory.annotation.Autowired;
  20. import java.util.List;
  22. /**
  23.  * @Description 桌台dubbo接口实现
  24.  */
  25. @Slf4j
  26. @DubboService(version = "${dubbo.application.version}",timeout = 5000,
  27.     methods ={
  28.         @Method(name = "findTableVoPage",retries = 2),
  29.         @Method(name = "createTable",retries = 0),
  30.         @Method(name = "updateTable",retries = 0),
  31.         @Method(name = "deleteTable",retries = 0)
  32.     })
  33. public class TableFaceImpl implements TableFace {
  35.     @Autowired
  36.     ITableService tableService;
  38.     @Override
  39.     public Page<TableVo> findTableVoPage(TableVo tableVo,
  40.                                          int pageNum,
  41.                                          int pageSize) throws ProjectException{
  42.         try {
  43.             //查询所有桌台
  44.             Page<Table> page = tableService.findTableVoPage(tableVo, pageNum, pageSize);
  45.             Page<TableVo> pageVo = new Page<>();
  46.             BeanConv.toBean(page,pageVo);
  47.             //结果集转换
  48.             List<Table> tableList = page.getRecords();
  49.             List<TableVo> tableVoList = BeanConv.toBeanList(tableList,TableVo.class);
  50.             pageVo.setRecords(tableVoList);
  51.             return pageVo;
  52.         } catch (Exception e) {
  53.             log.error("查询桌台列表异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  54.             throw new ProjectException(TableEnum.SELECT_TABLE_LIST_FAIL);
  55.         }
  56.     }
  58.     @Override
  59.     public TableVo createTable(TableVo tableVo) throws ProjectException{
  60.         try {
  61.             //添加桌台
  62.             return BeanConv.toBean( tableService.createTable(tableVo), TableVo.class);
  63.         } catch (Exception e) {
  64.             log.error("保存桌台异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  65.             throw new ProjectException(TableEnum.CREATE_FAIL);
  66.         }
  67.     }
  69.     @Override
  70.     @GlobalTransactional
  71.     public Boolean updateTable(TableVo tableVo) throws ProjectException{
  72.         try {
  73.             //修改桌台
  74.             return tableService.updateTable(tableVo);
  75.         } catch (Exception e) {
  76.             log.error("保存桌台异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  77.             throw new ProjectException(TableEnum.UPDATE_FAIL);
  78.         }
  79.     }
  81.     @Override
  82.     public Boolean deleteTable(String[] checkedIds) throws ProjectException{
  83.         try {
  84.             //删除桌台
  85.             return tableService.deleteTable(checkedIds);
  86.         } catch (Exception e) {
  87.             log.error("删除桌台异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  88.             throw new ProjectException(TableEnum.DELETE_FAIL);
  89.         }
  90.     }
  92.     @Override
  93.     public TableVo findTableByTableId(Long tableId)throws ProjectException {
  94.         try {
  95.             //按ID查询桌台
  96.             Table table = tableService.getById(tableId);
  97.             if (!EmptyUtil.isNullOrEmpty(table)){
  98.                 return BeanConv.toBean(table,TableVo.class);
  99.             }
  100.             return null;
  101.         } catch (Exception e) {
  102.             log.error("查找桌台所有桌台异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  103.             throw new ProjectException(TableEnum.SELECT_TABLE_FAIL);
  104.         }
  105.     }
  107.     @Override
  108.     public List<TableVo> findTableVoList()throws ProjectException {
  109.         try {
  110.             //查询桌台列表，用在哪里？是否要注意状态
  111.             return BeanConv.toBeanList(tableService.findTableVoList(),TableVo.class);
  112.         } catch (Exception e) {
  113.             log.error("查找桌台所有桌台异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  114.             throw new ProjectException(TableEnum.SELECT_TABLE_LIST_FAIL);
  115.         }
  116.     }
  117. }

3.3、ITableService业务接口

桌台管理的业务接口定义，为TableFaceImpl提供核心业务逻辑的定义

  1. package com.itheima.restkeeper.service;
  3. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  4. import com.baomidou.mybatisplus.extension.service.IService;
  5. import com.itheima.restkeeper.pojo.Table;
  6. import com.itheima.restkeeper.req.TableVo;
  8. import java.util.List;
  10. /**
  11.  * @Description：桌台服务类
  12.  */
  13. public interface ITableService extends IService<Table> {
  15.     /**
  16.      * @param tableVo  查询条件
  17.      * @param pageNum  当前页
  18.      * @param pageSize 每页大小
  19.      * @return Page<Table>
  20.      * @Description 门店列表
  21.      */
  22.     Page<Table> findTableVoPage(TableVo tableVo, int pageNum, int pageSize);
  24.     /**
  25.      * @param tableVo 对象信息
  26.      * @return Table
  27.      * @Description 创建门店
  28.      */
  29.     Table createTable(TableVo tableVo);
  31.     /**
  32.      * @param tableVo 对象信息
  33.      * @return Boolean
  34.      * @Description 修改门店
  35.      */
  36.     Boolean updateTable(TableVo tableVo);
  38.     /**
  39.      * @param checkedIds 选择的门店ID
  40.      * @return Boolean
  41.      * @Description 删除门店
  42.      */
  43.     Boolean deleteTable(String[] checkedIds);
  45.     /***
  46.      * @description 查询门店下拉框
  47.      * @return: List<Table>
  48.      */
  49.     List<Table> findTableVoList();
  51.     /***
  52.      * @description 当桌台处于空闲状态，进行开桌
  53.      * @param tableVo
  54.      * @return
  55.      */
  56.     Boolean openTable(TableVo tableVo);
  57. }

3.4、TableServiceImpl业务接口实现

桌台管理的业务接口定义实现

  1. package com.itheima.restkeeper.service.impl;
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  5. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  6. import com.itheima.restkeeper.basic.BasicPojo;
  7. import com.itheima.restkeeper.constant.SuperConstant;
  8. import com.itheima.restkeeper.pojo.Table;
  9. import com.itheima.restkeeper.mapper.TableMapper;
  10. import com.itheima.restkeeper.req.TableVo;
  11. import com.itheima.restkeeper.service.ITableService;
  12. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  13. import com.itheima.restkeeper.utils.BeanConv;
  14. import com.itheima.restkeeper.utils.EmptyUtil;
  15. import org.springframework.stereotype.Service;
  17. import java.util.ArrayList;
  18. import java.util.Arrays;
  19. import java.util.List;
  21. /**
  22.  * @Description：桌台 服务实现类
  23.  */
  24. @Service
  25. public class TableServiceImpl extends ServiceImpl<TableMapper, Table> implements ITableService {
  27.     @Override
  28.     public Page<Table> findTableVoPage(TableVo tableVo,int pageNum,int pageSize) {
  29.         //构建分页对象
  30.         Page<Table> page = new Page<>(pageNum,pageSize);
  31.         QueryWrapper<Table> queryWrapper = new QueryWrapper<>();
  32.         //按桌台名称查询
  33.         if (!EmptyUtil.isNullOrEmpty(tableVo.getTableName())) {
  34.             queryWrapper.lambda().likeRight(Table::getTableName,tableVo.getTableName());
  35.         }
  36.         //按就餐人数查询
  37.         if (!EmptyUtil.isNullOrEmpty(tableVo.getTableSeatNumber())) {
  38.             queryWrapper.lambda().eq(Table::getTableSeatNumber,tableVo.getTableSeatNumber());
  39.         }
  40.         //按桌台使用状态查询
  41.         if (!EmptyUtil.isNullOrEmpty(tableVo.getTableStatus())) {
  42.             queryWrapper.lambda().eq(Table::getTableStatus,tableVo.getTableStatus());
  43.         }
  44.         //按桌台有效性查询
  45.         if (!EmptyUtil.isNullOrEmpty(tableVo.getEnableFlag())) {
  46.             queryWrapper.lambda().eq(Table::getEnableFlag,tableVo.getEnableFlag());
  47.         }
  48.         //按sortNo升序排列
  49.         queryWrapper.lambda().orderByAsc(Table::getSortNo);
  50.         //返回分页结果
  51.         return page(page,queryWrapper);
  52.     }
  54.     @Override
  55.     public Table createTable(TableVo tableVo) {
  56.         //转换TableVo为Table
  57.         Table table = BeanConv.toBean(tableVo, Table.class);
  58.         //执行保存
  59.         boolean flag = save(table);
  60.         if (flag){
  61.             return table;
  62.         }
  63.         return null;
  64.     }
  66.     @Override
  67.     public Boolean updateTable(TableVo tableVo) {
  68.         //转换TableVo为Table
  69.         Table table = BeanConv.toBean(tableVo, Table.class);
  70.         //执行按ID进行修改
  71.         return updateById(table);
  72.     }
  74.     @Override
  75.     public Boolean deleteTable(String[] checkedIds) {
  76.         //构建选择ids的List<String>集合
  77.         List<String> ids = Arrays.asList(checkedIds);
  78.         List<Long> idsLong = new ArrayList<>();
  79.         ids.forEach(n->{
  80.             idsLong.add(Long.valueOf(n));
  81.         });
  82.         //执行批量移除
  83.         return removeByIds(idsLong);
  84.     }
  86.     @Override
  87.     public List<Table> findTableVoList() {
  88.         //构建查询条件：有效状态
  89.         QueryWrapper<Table> queryWrapper = new QueryWrapper<>();
  90.         queryWrapper.lambda().eq(BasicPojo::getEnableFlag, SuperConstant.YES);
  91.         //执行list查询
  92.         return list(queryWrapper);
  93.     }
  95.     @Override
  96.     public Boolean openTable(TableVo tableVo) {
  97.         //构建条件：SuperConstant.FREE
  98.         LambdaQueryWrapper<Table> lambdaQueryWrapper = new LambdaQueryWrapper();
  99.         lambdaQueryWrapper
  100.             .eq(Table::getTableStatus,SuperConstant.FREE).eq(Table::getId,tableVo.getId());
  101.         //执行update条件查询
  102.         return update(BeanConv.toBean(tableVo,Table.class),lambdaQueryWrapper);
  103.     }
  104. }

3.5、TableController类

对TableFace接口进行dubbo的RPC调用，为dubbo服务的消费者

  1. package com.itheima.restkeeper.web;
  3. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  4. import com.itheima.restkeeper.TableFace;
  5. import com.itheima.restkeeper.basic.ResponseWrap;
  6. import com.itheima.restkeeper.enums.TableEnum;
  7. import com.itheima.restkeeper.exception.ProjectException;
  8. import com.itheima.restkeeper.req.TableVo;
  9. import com.itheima.restkeeper.utils.EmptyUtil;
  10. import com.itheima.restkeeper.utils.ExceptionsUtil;
  11. import com.itheima.restkeeper.utils.ResponseWrapBuild;
  12. import io.swagger.annotations.Api;
  13. import io.swagger.annotations.ApiImplicitParam;
  14. import io.swagger.annotations.ApiImplicitParams;
  15. import io.swagger.annotations.ApiOperation;
  16. import lombok.extern.slf4j.Slf4j;
  17. import org.apache.dubbo.config.annotation.DubboReference;
  18. import org.springframework.web.bind.annotation.*;
  20. import java.util.List;
  22. /**
  23.  * @ClassName TableController.java
  24.  * @Description 桌台Controller
  25.  */
  26. @RestController
  27. @RequestMapping("table")
  28. @Slf4j
  29. @Api(tags = "桌台controller")
  30. public class TableController {
  32.     @DubboReference(version = "${dubbo.application.version}",check = false)
  33.     TableFace tableFace;
  35.     /**
  36.      * @Description 桌台列表
  37.      * @param tableVo 查询条件
  38.      * @return
  39.      */
  40.     @PostMapping("page/{pageNum}/{pageSize}")
  41.     @ApiOperation(value = "查询桌台list",notes = "查询桌台list")
  42.     @ApiImplicitParams({
  43.         @ApiImplicitParam(name = "tableVo",value = "桌台查询对象",dataType = "TableVo"),
  44.         @ApiImplicitParam(paramType = "path",name = "pageNum",value = "页码",dataType = "Integer"),
  45.         @ApiImplicitParam(paramType = "path",name = "pageSize",value = "每页条数",dataType = "Integer")
  46.     })
  47.     public ResponseWrap<Page<TableVo>> findTableVoPage(
  48.         @RequestBody TableVo tableVo,
  49.         @PathVariable("pageNum") int pageNum,
  50.         @PathVariable("pageSize") int pageSize) {
  51.         Page<TableVo> tableVoList = tableFace.findTableVoPage(tableVo,pageNum,pageSize);
  52.         return ResponseWrapBuild.build(TableEnum.SUCCEED,tableVoList);
  53.     }
  55.     /**
  56.      * @Description 添加桌台
  57.      * @param tableVo 对象信息
  58.      * @return
  59.      */
  60.     @PostMapping
  61.     @ApiOperation(value = "添加桌台",notes = "添加桌台")
  62.     @ApiImplicitParam(name = "tableVo",value = "桌台对象",required = true,dataType = "TableVo")
  63.     ResponseWrap<TableVo> createTable(@RequestBody TableVo tableVo) {
  64.         TableVo tableVoResult = tableFace.createTable(tableVo);
  65.         return ResponseWrapBuild.build(TableEnum.SUCCEED,tableVoResult);
  66.     }
  68.     /**
  69.      * @Description 修改桌台
  70.      * @param tableVo 对象信息
  71.      * @return
  72.      */
  73.     @PatchMapping
  74.     @ApiOperation(value = "修改桌台",notes = "修改桌台")
  75.     @ApiImplicitParam(name = "tableVo",value = "桌台对象",required = true,dataType = "TableVo")
  76.     ResponseWrap<Boolean> updateTable(@RequestBody TableVo tableVo) {
  77.         Boolean flag = tableFace.updateTable(tableVo);
  78.         return ResponseWrapBuild.build(TableEnum.SUCCEED,flag);
  79.     }
  81.     /**
  82.      * @Description 查找桌台
  83.      * @param tableId 桌台id
  84.      * @return
  85.      */
  86.     @GetMapping("{tableId}")
  87.     @ApiOperation(value = "查找桌台",notes = "查找桌台")
  88.     @ApiImplicitParam(paramType = "path",name = "tableId",value = "桌台Id",dataType = "Long")
  89.     ResponseWrap<TableVo> findTableByTableId(@PathVariable("tableId") Long tableId) {
  90.         TableVo tableVo = tableFace.findTableByTableId(tableId);
  91.         return ResponseWrapBuild.build(TableEnum.SUCCEED,tableVo);
  92.     }
  94.     /**
  95.      * @Description 删除桌台
  96.      * @param tableVo 查询对象
  97.      * @return
  98.      */
  99.     @DeleteMapping
  100.     @ApiOperation(value = "删除桌台",notes = "删除桌台")
  101.     @ApiImplicitParam(name = "tableVo",value = "桌台查询对象",required = true,dataType = "TableVo")
  102.     ResponseWrap<Boolean> deleteTable(@RequestBody TableVo tableVo ) {
  103.         //拿到选中桌台的IDS
  104.         String[] checkedIds = tableVo.getCheckedIds();
  105.         Boolean flag = tableFace.deleteTable(checkedIds);
  106.         return ResponseWrapBuild.build(TableEnum.SUCCEED,flag);
  107.     }
  109.     /**
  110.      * @Description 查找桌台
  111.      * @return
  112.      */
  113.     @GetMapping("list")
  114.     @ApiOperation(value = "查找桌台列表",notes = "查找桌台列表")
  115.     ResponseWrap<List<TableVo>> findTableVoList() {
  116.         List<TableVo> list = tableFace.findTableVoList();
  117.         return ResponseWrapBuild.build(TableEnum.SUCCEED,list);
  118.     }
  120.     @PostMapping("update-table-enableFlag")
  121.     @ApiOperation(value = "修改桌台有效状态",notes = "修改桌台有效状态")
  122.     ResponseWrap<Boolean> updateTableEnableFlag(@RequestBody TableVo tableVo) {
  123.         Boolean flag = tableFace.updateTable(tableVo);
  124.         return ResponseWrapBuild.build(TableEnum.SUCCEED,flag);
  125.     }
  127.     @PostMapping("update-table-tableStatus")
  128.     @ApiOperation(value = "修改桌台状态",notes = "修改桌台状态")
  129.     ResponseWrap<Boolean> updateTableStatus(@RequestBody TableVo tableVo) {
  130.         Boolean flag = tableFace.updateTable(tableVo);
  131.         return ResponseWrapBuild.build(TableEnum.SUCCEED,flag);
  132.     }
  133. }

第三章 商家平台-分类管理

  1.     菜品的分类主要是为菜品进行分类，在点餐的app端用户可以根据菜品分类去筛选菜品，帮助用户快速找到锁需要的菜品注意的分类的数据归属我们采用多租户功能区实现这里不需要考虑【多租户】后面有专题去简介

image.png

1、功能区拆解

image.png

红色区域：此处为查询条件功能区，筛选列表信息

功能 说明
分类名称 输入分类名称，键盘按enter触发搜索列表
状态 下拉框，显示【启用、禁用】，change触发搜索列表

蓝色区域：菜品分类维护功能

功能 说明
添加 新增分类信息
修改 修改分类信息
删除 删除分类信息==【真实删除】==，删除时，会有再次确认提示
禁用、启用 禁用启用分类

image.png

在添加或修改菜品分类时候，我们会从数字字典中获得分类类型【菜品、套餐】，用于区分是单个菜品还是套餐

2、数据库结构

  1. CREATE TABLE `tab_category` (
  2.   `id` bigint(18) NOT NULL COMMENT '分类id',
  3.   `category_type` varchar(11) COLLATE utf8_bin DEFAULT NULL COMMENT '类型 菜品：DISH  套餐：MEAL',
  4.   `category_name` varchar(64) COLLATE utf8_bin NOT NULL COMMENT '分类名称',
  5.   `enable_flag` varchar(18) CHARACTER SET utf8 DEFAULT NULL COMMENT '是否有效',
  6.   `created_time` datetime DEFAULT NULL COMMENT '创建时间',
  7.   `updated_time` datetime DEFAULT NULL COMMENT '创建时间',
  8.   `sharding_id` bigint(18) DEFAULT NULL COMMENT '分库id',
  9.   `store_id` bigint(18) NOT NULL COMMENT '门店主键id',
  10.   `enterprise_id` bigint(18) NOT NULL COMMENT '商户号',
  11.   `sort_no` int(11) DEFAULT NULL COMMENT '排序',
  12.   PRIMARY KEY (`id`)
  13. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='菜品及套餐分类';

自动填充：

下列字段，无需手动填充，系统会自动填充下列字段

字段 注释 填充方式
id 主键 雪花算法
enterprise_id 商户号 mybatis-plus-多租户拦截
created_time 创建时间 mybatis-plus-自动填充组件
updated_time 修改时间 mybatis-plus-自动填充组件
sharding_id 分库id mybatis-plus-自动填充组件
store_id 门店id mybatis-plus-多租户拦截

3、功能开发

image.png

CategoryController：对CategoryFace接口进行dubbo的RPC调用，为dubbo服务的消费者

CategoryFace：菜品分类管理dubbo接口定义

CategoryFaceImpl：菜品分类管理dubbo接口定义实现，这里做VO和POJO的转换

ICategoryService：菜品分类管理的业务接口定义，为CategoryFaceImpl提供核心业务逻辑的定义

CategoryServiceImpl：菜品分类管理的业务接口定义实现

3.1、CategoryFace接口

品分类管理dubbo接口定义

  1. package com.itheima.restkeeper;
  3. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  4. import com.itheima.restkeeper.exception.ProjectException;
  5. import com.itheima.restkeeper.req.CategoryVo;
  7. import java.util.List;
  9. /**
  10.  * @ClassName CategoryFace.java
  11.  * @Description 菜品分类dubbo服务接口
  12.  */
  13. public interface CategoryFace {
  15.     /**
  16.      * @Description 分类列表
  17.      * @param categoryVo 查询条件
  18.      * @param pageNum 当前页
  19.      * @param pageSize 每页条数
  20.      * @return Page<CategoryVo>
  21.      */
  22.     Page<CategoryVo> findCategoryVoPage(CategoryVo categoryVo,
  23.                                         int pageNum,
  24.                                         int pageSize)throws ProjectException;
  26.     /**
  27.      * @Description 创建分类
  28.      * @param categoryVo 对象信息
  29.      * @return CategoryVo
  30.      */
  31.     CategoryVo createCategory(CategoryVo categoryVo)throws ProjectException;
  33.     /**
  34.      * @Description 修改分类
  35.      * @param categoryVo 对象信息
  36.      * @return Boolean
  37.      */
  38.     Boolean updateCategory(CategoryVo categoryVo)throws ProjectException;
  40.     /**
  41.      * @Description 删除分类
  42.      * @param checkedIds 选择对象信息Id
  43.      * @return Boolean
  44.      */
  45.     Boolean deleteCategory(String[] checkedIds)throws ProjectException;
  48.     /**
  49.      * @Description 查找分类
  50.      * @param categoryId 选择对象信息Id
  51.      * @return CategoryVo
  52.      */
  53.     CategoryVo findCategoryByCategoryId(Long categoryId)throws ProjectException;
  55.     /***
  56.      * @description 查询分类下拉框
  57.      * @return: List<CategoryVo>
  58.      */
  59.     List<CategoryVo> findCategoryVoList()throws ProjectException;
  60. }

3.2、CategoryFaceImpl接口实现

菜品分类管理dubbo接口定义实现，这里做VO和POJO的转换

  1. package com.itheima.restkeeper.face;
  3. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  4. import com.itheima.restkeeper.CategoryFace;
  5. import com.itheima.restkeeper.enums.CategoryEnum;
  6. import com.itheima.restkeeper.exception.ProjectException;
  7. import com.itheima.restkeeper.pojo.Category;
  8. import com.itheima.restkeeper.req.CategoryVo;
  9. import com.itheima.restkeeper.service.ICategoryService;
  10. import com.itheima.restkeeper.utils.BeanConv;
  11. import com.itheima.restkeeper.utils.EmptyUtil;
  12. import com.itheima.restkeeper.utils.ExceptionsUtil;
  13. import lombok.extern.slf4j.Slf4j;
  14. import org.apache.dubbo.config.annotation.DubboService;
  15. import org.apache.dubbo.config.annotation.Method;
  16. import org.springframework.beans.factory.annotation.Autowired;
  18. import java.util.List;
  20. /**
  21.  * @ClassName CategoryFaceImpl.java
  22.  * @Description 菜品分类dubbo服务接口实现
  23.  */
  24. @Slf4j
  25. @DubboService(version = "${dubbo.application.version}",timeout = 5000,
  26.     methods ={
  27.         @Method(name = "findCategoryVoPage",retries = 2),
  28.         @Method(name = "createCategory",retries = 0),
  29.         @Method(name = "updateCategory",retries = 0),
  30.         @Method(name = "deleteCategory",retries = 0)
  31.     })
  32. public class CategoryFaceImpl implements CategoryFace {
  34.     @Autowired
  35.     ICategoryService categoryService;
  38.     @Override
  39.     public Page<CategoryVo> findCategoryVoPage(CategoryVo categoryVo,
  40.                                                int pageNum,
  41.                                                int pageSize)throws ProjectException {
  42.         try {
  43.             //查询分类分页
  44.             Page<Category> page = categoryService.findCategoryVoPage(categoryVo, pageNum, pageSize);
  45.             Page<CategoryVo> pageVo = new Page<>();
  46.             BeanConv.toBean(page,pageVo);
  47.             //结果集转换
  48.             List<Category> categoryList = page.getRecords();
  49.             List<CategoryVo> categoryVoList = BeanConv.toBeanList(categoryList,CategoryVo.class);
  50.             pageVo.setRecords(categoryVoList);
  51.             //返回结果
  52.             return pageVo;
  53.         } catch (Exception e) {
  54.             log.error("查询分类列表异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  55.             throw new ProjectException(CategoryEnum.PAGE_FAIL);
  56.         }
  58.     }
  60.     @Override
  61.     public CategoryVo createCategory(CategoryVo categoryVo)throws ProjectException {
  62.         try {
  63.             //创建分类
  64.             return BeanConv.toBean( categoryService.createCategory(categoryVo), CategoryVo.class);
  65.         } catch (Exception e) {
  66.             log.error("保存分类异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  67.             throw new ProjectException(CategoryEnum.CREATE_FAIL);
  68.         }
  69.     }
  71.     @Override
  72.     public Boolean updateCategory(CategoryVo categoryVo) throws ProjectException{
  73.         try {
  74.             //修改分类
  75.             return categoryService.updateCategory(categoryVo);
  76.         } catch (Exception e) {
  77.             log.error("保存分类异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  78.             throw new ProjectException(CategoryEnum.UPDATE_FAIL);
  79.         }
  80.     }
  82.     @Override
  83.     public Boolean deleteCategory(String[] checkedIds) {
  84.         try {
  85.             //删除分类
  86.             return categoryService.deleteCategory(checkedIds);
  87.         } catch (Exception e) {
  88.             log.error("删除分类异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  89.             throw new ProjectException(CategoryEnum.DELETE_FAIL);
  90.         }
  91.     }
  93.     @Override
  94.     public CategoryVo findCategoryByCategoryId(Long categoryId)throws ProjectException {
  95.         try {
  96.             //按分类id查询分类
  97.             Category category = categoryService.getById(categoryId);
  98.             if (!EmptyUtil.isNullOrEmpty(category)){
  99.                 return BeanConv.toBean(category,CategoryVo.class);
  100.             }
  101.             return null;
  102.         } catch (Exception e) {
  103.             log.error("查找分类所有分类异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  104.             throw new ProjectException(CategoryEnum.SELECT_CATEGORY_FAIL);
  105.         }
  106.     }
  108.     @Override
  109.     public List<CategoryVo> findCategoryVoList()throws ProjectException {
  110.         try {
  111.             //查询分类下拉框
  112.             return BeanConv.toBeanList(categoryService.findCategoryVoList(),CategoryVo.class);
  113.         } catch (Exception e) {
  114.             log.error("查找分类所有分类异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  115.             throw new ProjectException(CategoryEnum.SELECT_CATEGORY_LIST_FAIL);
  116.         }
  117.     }
  118. }

3.3、ICategoryService业务接口

菜品分类管理的业务接口定义，为CategoryFaceImpl提供核心业务逻辑的定义

  1. package com.itheima.restkeeper.service;
  3. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  4. import com.baomidou.mybatisplus.extension.service.IService;
  5. import com.itheima.restkeeper.pojo.Category;
  6. import com.itheima.restkeeper.req.CategoryVo;
  8. import java.util.List;
  10. /**
  11.  * @Description：菜品及套餐分类 服务类
  12.  */
  13. public interface ICategoryService extends IService<Category> {
  15.     /**
  16.      * @Description 分类列表
  17.      * @param categoryVo 查询条件
  18.      * @param pageNum 当前页
  19.      * @param pageSize 当前页
  20.      * @return Page<Category>
  21.      */
  22.     Page<Category> findCategoryVoPage(CategoryVo categoryVo, int pageNum, int pageSize);
  24.     /**
  25.      * @Description 创建分类
  26.      * @param categoryVo 对象信息
  27.      * @return Category
  28.      */
  29.     Category createCategory(CategoryVo categoryVo);
  31.     /**
  32.      * @Description 修改分类
  33.      * @param categoryVo 对象信息
  34.      * @return Boolean
  35.      */
  36.     Boolean updateCategory(CategoryVo categoryVo);
  38.     /**
  39.      * @Description 删除分类
  40.      * @param checkedIds 选择的分类ID
  41.      * @return Boolean
  42.      */
  43.     Boolean deleteCategory(String[] checkedIds);
  45.     /***
  46.      * @description 查询分类下拉框
  47.      * @return: List<Category>
  48.      */
  49.     List<Category> findCategoryVoList();
  51.     /***
  52.      * @description 查询当前门店的分类
  53.      * @param storeId
  54.      * @return List<Category>
  55.      */
  56.     List<Category> findCategoryVoByStoreId(Long storeId);
  57. }

3.4、CategoryServiceImpl业务接口实现

菜品分类管理的业务接口定义实现

  1. package com.itheima.restkeeper.service.impl;
  3. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  4. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  5. import com.itheima.restkeeper.basic.BasicPojo;
  6. import com.itheima.restkeeper.constant.SuperConstant;
  7. import com.itheima.restkeeper.pojo.Category;
  8. import com.itheima.restkeeper.mapper.CategoryMapper;
  9. import com.itheima.restkeeper.req.CategoryVo;
  10. import com.itheima.restkeeper.service.ICategoryService;
  11. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  12. import com.itheima.restkeeper.utils.BeanConv;
  13. import com.itheima.restkeeper.utils.EmptyUtil;
  14. import org.springframework.stereotype.Service;
  16. import java.util.ArrayList;
  17. import java.util.Arrays;
  18. import java.util.List;
  20. /**
  21.  * @Description：菜品分类业务服务实现类
  22.  */
  23. @Service
  24. public class CategoryServiceImpl extends ServiceImpl<CategoryMapper, Category> implements ICategoryService {
  26.     @Override
  27.     public Page<Category> findCategoryVoPage(CategoryVo categoryVo, int pageNum, int pageSize) {
  28.         //构建Page<Category>分页对象
  29.         Page<Category> page = new Page<>(pageNum,pageSize);
  30.         QueryWrapper<Category> queryWrapper = new QueryWrapper<>();
  31.         //按分类类型查询
  32.         if (!EmptyUtil.isNullOrEmpty(categoryVo.getCategoryType())) {
  33.             queryWrapper.lambda().eq(Category::getCategoryType,categoryVo.getCategoryType());
  34.         }
  35.         //按分类名称查询
  36.         if (!EmptyUtil.isNullOrEmpty(categoryVo.getCategoryName())) {
  37.             queryWrapper.lambda().likeRight(Category::getCategoryName,categoryVo.getCategoryName());
  38.         }
  39.         //按分类有效性查询
  40.         if (!EmptyUtil.isNullOrEmpty(categoryVo.getEnableFlag())) {
  41.             queryWrapper.lambda().eq(Category::getEnableFlag,categoryVo.getEnableFlag());
  42.         }
  43.         //按sortNo升序排列
  44.         queryWrapper.lambda().orderByAsc(Category::getSortNo);
  45.         //执行page查询返回结果
  46.         return page(page, queryWrapper);
  47.     }
  49.     @Override
  50.     public Category createCategory(CategoryVo categoryVo) {
  51.         //转换CategoryVo为Category
  52.         Category category = BeanConv.toBean(categoryVo, Category.class);
  53.         //执行保存
  54.         boolean flag = save(category);
  55.         if (flag){
  56.             return category;
  57.         }
  58.         return null;
  59.     }
  61.     @Override
  62.     public Boolean updateCategory(CategoryVo categoryVo) {
  63.         //转换CategoryVo为Category
  64.         Category category = BeanConv.toBean(categoryVo, Category.class);
  65.         //执行updateById修改
  66.         return updateById(category);
  67.     }
  69.     @Override
  70.     public Boolean deleteCategory(String[] checkedIds) {
  71.         //构建选中ids的List<String>
  72.         List<String> ids = Arrays.asList(checkedIds);
  73.         List<Long> idsLong = new ArrayList<>();
  74.         ids.forEach(n->{
  75.             idsLong.add(Long.valueOf(n));
  76.         });
  77.         //执行removeByIds批量移除
  78.         return removeByIds(idsLong);
  79.     }
  81.     @Override
  82.     public List<Category> findCategoryVoList() {
  83.         //构建查询条件：SuperConstant.YES
  84.         QueryWrapper<Category> queryWrapper = new QueryWrapper<>();
  85.         queryWrapper.lambda().eq(BasicPojo::getEnableFlag, SuperConstant.YES);
  86.         //执行list查询
  87.         return list(queryWrapper);
  88.     }
  90.     @Override
  91.     public List<Category> findCategoryVoByStoreId(Long storeId) {
  92.         //构建查询条件：SuperConstant.YES
  93.         QueryWrapper<Category> queryWrapper = new QueryWrapper<>();
  94.         queryWrapper.lambda().eq(Category::getStoreId,storeId)
  95.                 .eq(BasicPojo::getEnableFlag, SuperConstant.YES);
  96.         //执行list查询
  97.         return list(queryWrapper);
  98.     }
  100. }

3.5、CategoryController类

对TableFace接口进行dubbo的RPC调用，为dubbo服务的消费者

  1. package com.itheima.restkeeper.web;
  3. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  4. import com.itheima.restkeeper.CategoryFace;
  5. import com.itheima.restkeeper.basic.ResponseWrap;
  6. import com.itheima.restkeeper.enums.CategoryEnum;
  7. import com.itheima.restkeeper.exception.ProjectException;
  8. import com.itheima.restkeeper.req.CategoryVo;
  9. import com.itheima.restkeeper.utils.ResponseWrapBuild;
  10. import io.swagger.annotations.Api;
  11. import io.swagger.annotations.ApiImplicitParam;
  12. import io.swagger.annotations.ApiImplicitParams;
  13. import io.swagger.annotations.ApiOperation;
  14. import lombok.extern.slf4j.Slf4j;
  15. import org.apache.dubbo.config.annotation.DubboReference;
  16. import org.springframework.web.bind.annotation.*;
  18. import java.util.List;
  20. /**
  21.  * @ClassName CategoryController.java
  22.  * @Description 分类Controller
  23.  */
  24. @RestController
  25. @RequestMapping("category")
  26. @Slf4j
  27. @Api(tags = "分类controller")
  28. public class CategoryController {
  30.     @DubboReference(version = "${dubbo.application.version}",check = false)
  31.     CategoryFace categoryFace;
  33.     /**
  34.      * @Description 分类列表
  35.      * @param categoryVo 查询条件
  36.      * @return
  37.      */
  38.     @PostMapping("page/{pageNum}/{pageSize}")
  39.     @ApiOperation(value = "查询分类分页",notes = "查询分类分页")
  40.     @ApiImplicitParams({
  41.         @ApiImplicitParam(name = "categoryVo",value = "分类查询对象",required = false,dataType = "CategoryVo"),
  42.         @ApiImplicitParam(paramType = "path",name = "pageNum",value = "页码",dataType = "Integer"),
  43.         @ApiImplicitParam(paramType = "path",name = "pageSize",value = "每页条数",dataType = "Integer")
  44.     })
  45.     public ResponseWrap<Page<CategoryVo>> findCategoryVoPage(
  46.         @RequestBody CategoryVo categoryVo,
  47.         @PathVariable("pageNum") int pageNum,
  48.         @PathVariable("pageSize") int pageSize) {
  49.         Page<CategoryVo> categoryVoPage = categoryFace.findCategoryVoPage(categoryVo, pageNum, pageSize);
  50.         return ResponseWrapBuild.build(CategoryEnum.SUCCEED,categoryVoPage);
  51.     }
  53.     /**
  54.      * @Description 添加分类
  55.      * @param categoryVo 对象信息
  56.      * @return
  57.      */
  58.     @PostMapping
  59.     @ApiOperation(value = "添加分类",notes = "添加分类")
  60.     @ApiImplicitParam(name = "categoryVo",value = "分类对象",required = true,dataType = "CategoryVo")
  61.     ResponseWrap<CategoryVo> createCategory(@RequestBody CategoryVo categoryVo) {
  62.         CategoryVo categoryVoResult = categoryFace.createCategory(categoryVo);
  63.         return ResponseWrapBuild.build(CategoryEnum.SUCCEED,categoryVoResult);
  64.     }
  66.     /**
  67.      * @Description 修改分类
  68.      * @param categoryVo 对象信息
  69.      * @return
  70.      */
  71.     @PatchMapping
  72.     @ApiOperation(value = "修改分类",notes = "修改分类")
  73.     @ApiImplicitParam(name = "categoryVo",value = "分类对象",required = true,dataType = "CategoryVo")
  74.     ResponseWrap<Boolean> updateCategory(@RequestBody CategoryVo categoryVo) {
  75.         Boolean flag = categoryFace.updateCategory(categoryVo);
  76.         return ResponseWrapBuild.build(CategoryEnum.SUCCEED,flag);
  77.     }
  79.     /**
  80.      * @Description 删除分类
  81.      * @param categoryVo 查询对象
  82.      * @return
  83.      */
  84.     @DeleteMapping
  85.     @ApiOperation(value = "删除分类",notes = "删除分类")
  86.     @ApiImplicitParam(name = "categoryVo",value = "分类查询对象",required = true,dataType = "CategoryVo")
  87.     ResponseWrap<Boolean> deleteCategory(@RequestBody CategoryVo categoryVo ) {
  88.         //获得所有选择分类IDS
  89.         String[] checkedIds = categoryVo.getCheckedIds();
  90.         Boolean flag = categoryFace.deleteCategory(checkedIds);
  91.         return ResponseWrapBuild.build(CategoryEnum.SUCCEED,flag);
  92.     }
  94.     /**
  95.      * @Description 查找分类
  96.      * @param categoryId 分类id
  97.      * @return
  98.      */
  99.     @GetMapping("{categoryId}")
  100.     @ApiOperation(value = "查找分类",notes = "查找分类")
  101.     @ApiImplicitParam(paramType = "path",name = "categoryId",value = "分类Id",dataType = "Long")
  102.     ResponseWrap<CategoryVo> findCategoryByCategoryId(@PathVariable("categoryId") Long categoryId) {
  103.         CategoryVo categoryVo = categoryFace.findCategoryByCategoryId(categoryId);
  104.         return ResponseWrapBuild.build(CategoryEnum.SUCCEED,categoryVo);
  105.     }
  107.     /**
  108.      * @Description 查找分类
  109.      * @return
  110.      */
  111.     @GetMapping("list")
  112.     @ApiOperation(value = "查找分类列表",notes = "查找分类列表")
  113.     ResponseWrap<List<CategoryVo>> findCategoryVoList() {
  114.         List<CategoryVo> list = categoryFace.findCategoryVoList();
  115.         return ResponseWrapBuild.build(CategoryEnum.SUCCEED,list);
  116.     }
  119.     @PostMapping("update-category-enableFlag")
  120.     @ApiOperation(value = "修改分类状态",notes = "修改分类状态")
  121.     ResponseWrap<Boolean> updateCategoryEnableFlag(@RequestBody CategoryVo categoryVo) {
  122.         Boolean flag = categoryFace.updateCategory(categoryVo);
  123.         return ResponseWrapBuild.build(CategoryEnum.SUCCEED,flag);
  124.     }
  125. }

第四章 商家平台-菜品管理

  1.     门店管理进行菜品管理的功能，包括对菜品的添加、修改、删除、禁用、启用、起售、停售、查看详情等功能，注意的菜品的数据归属我们采用多租户功能区实现这里不需要考虑【多租户】后面有专题去简介

image.png

1、功能区拆解

image.png

红色区域：此处为查询条件功能区，筛选列表信息

功能 说明
编码 输入菜品编码【简码】，键盘按enter触发搜索列表
菜品名称 输入菜品名称，键盘按enter触发搜索列表
分类 下拉框，显示菜品分类【数字字典】，change触发搜索列表
状态 下拉框，显示【启用、禁用】，change触发搜索列表

蓝色区域：菜品维护功能

功能 说明
添加 新增菜品信息
修改 修改菜品信息
删除 删除菜品信息==【真实删除】==，删除时，会有再次确认提示
详情 右侧弹出菜品详细信息
禁用、启用 禁用启用菜品
起售、停售 起售、停售菜品

image.png

2、数据库结构

  1. CREATE TABLE `tab_dish` (
  2.   `id` bigint(18) NOT NULL COMMENT '菜品Id',
  3.   `dish_name` varchar(64) COLLATE utf8_bin NOT NULL COMMENT '菜品名称',
  4.   `dish_number` int(9) DEFAULT NULL COMMENT '菜品数量',
  5.   `category_id` varchar(64) COLLATE utf8_bin NOT NULL COMMENT '菜品分类id',
  6.   `price` decimal(12,4) NOT NULL COMMENT '菜品价格',
  7.   `reduce_price` decimal(12,4) NOT NULL COMMENT '菜品优惠价格',
  8.   `code` varchar(64) COLLATE utf8_bin NOT NULL COMMENT '商品码',
  9.   `description` varchar(400) COLLATE utf8_bin DEFAULT NULL COMMENT '描述信息',
  10.   `dish_status` varchar(11) COLLATE utf8_bin NOT NULL COMMENT 'YES 停售 NO 起售',
  11.   `created_time` datetime DEFAULT NULL COMMENT '创建时间',
  12.   `updated_time` datetime DEFAULT NULL COMMENT '创建时间',
  13.   `sharding_id` bigint(18) DEFAULT NULL COMMENT '分库id',
  14.   `store_id` bigint(18) NOT NULL COMMENT '门店主键id',
  15.   `enterprise_id` bigint(18) NOT NULL COMMENT '商户号',
  16.   `sort_no` int(11) DEFAULT NULL COMMENT '排序',
  17.   `enable_flag` varchar(10) CHARACTER SET utf8 NOT NULL COMMENT '是否有效',
  18.   PRIMARY KEY (`id`)
  19. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='菜品管理';
  1. CREATE TABLE `tab_dish_flavor` (
  2.   `id` bigint(18) NOT NULL COMMENT '主键Id',
  3.   `dish_id` bigint(18) DEFAULT NULL COMMENT '菜品id',
  4.   `data_key` varchar(255) CHARACTER SET utf8 NOT NULL COMMENT '数据字典KEY【数字字典统一管理】',
  5.   `created_time` datetime DEFAULT NULL COMMENT '创建时间',
  6.   `updated_time` datetime DEFAULT NULL COMMENT '创建时间',
  7.   `sharding_id` bigint(18) DEFAULT NULL COMMENT '分库id',
  8.   `enable_flag` varchar(10) CHARACTER SET utf8 NOT NULL COMMENT '是否有效',
  9.   PRIMARY KEY (`id`)
  10. ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4COMMENT='菜品口味';

自动填充：

下列字段，无需手动填充，系统会自动填充下列字段

字段 注释 填充方式
id 主键 雪花算法
enterprise_id 商户号 mybatis-plus-多租户拦截
created_time 创建时间 mybatis-plus-自动填充组件
updated_time 修改时间 mybatis-plus-自动填充组件
sharding_id 分库id mybatis-plus-自动填充组件
store_id 门店id mybatis-plus-多租户拦截

3、功能开发

image.png

DishController：对DishFace接口进行dubbo的RPC调用，为dubbo服务的消费者

DishFace：菜品管理dubbo接口定义,对AffixFace图片接口调用

DishFaceImpl：菜品管理dubbo接口定义实现，这里做VO和POJO的转换

IDishService：菜品管理的业务接口定义，为DishFaceImpl提供核心业务逻辑的定义

DishServiceImpl：菜品管理的业务接口定义实现

3.1、DishFace接口

菜品管理dubbo接口定义

  1. package com.itheima.restkeeper;
  3. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  4. import com.itheima.restkeeper.exception.ProjectException;
  5. import com.itheima.restkeeper.req.DishVo;
  7. /**
  8.  * @ClassName DishFace.java
  9.  * @Description 菜品接口
  10.  */
  11. public interface DishFace {
  13.     /**
  14.      * @Description 菜品列表
  15.      * @param dishVo 查询条件
  16.      * @param pageNum 当前页
  17.      * @param pageSize 每页条数
  18.      * @return Page<DishVo>
  19.      */
  20.     Page<DishVo> findDishVoPage(DishVo dishVo,
  21.                                 int pageNum,
  22.                                 int pageSize)throws ProjectException;
  24.     /**
  25.      * @Description 创建菜品
  26.      * @param dishVo 对象信息
  27.      * @return DishVo
  28.      */
  29.     DishVo createDish(DishVo dishVo)throws ProjectException;
  31.     /**
  32.      * @Description 修改菜品
  33.      * @param dishVo 对象信息
  34.      * @return Boolean
  35.      */
  36.     Boolean updateDish(DishVo dishVo) throws ProjectException;
  38.     /**
  39.      * @Description 删除菜品
  40.      * @param checkedIds 选择对象信息Id
  41.      * @return Boolean
  42.      */
  43.     Boolean deleteDish(String[] checkedIds)throws ProjectException;
  46.     /**
  47.      * @Description 查找菜品
  48.      * @param dishId 选择对象信息Id
  49.      * @return DishVo
  50.      */
  51.     DishVo findDishByDishId(Long dishId)throws ProjectException;
  53. }

3.2、DishFaceImpl接口实现

菜品管理dubbo接口定义实现，这里做VO和POJO的转换

  1. package com.itheima.restkeeper.face;
  3. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  4. import com.itheima.restkeeper.AffixFace;
  5. import com.itheima.restkeeper.DishFace;
  6. import com.itheima.restkeeper.constant.AppletCacheConstant;
  7. import com.itheima.restkeeper.enums.DishEnum;
  8. import com.itheima.restkeeper.exception.ProjectException;
  9. import com.itheima.restkeeper.pojo.Dish;
  10. import com.itheima.restkeeper.pojo.DishFlavor;
  11. import com.itheima.restkeeper.req.AffixVo;
  12. import com.itheima.restkeeper.req.DishVo;
  13. import com.itheima.restkeeper.service.IDishFlavorService;
  14. import com.itheima.restkeeper.service.IDishService;
  15. import com.itheima.restkeeper.utils.BeanConv;
  16. import com.itheima.restkeeper.utils.EmptyUtil;
  17. import com.itheima.restkeeper.utils.ExceptionsUtil;
  18. import lombok.extern.slf4j.Slf4j;
  19. import org.apache.dubbo.config.annotation.DubboReference;
  20. import org.apache.dubbo.config.annotation.DubboService;
  21. import org.apache.dubbo.config.annotation.Method;
  22. import org.redisson.api.RAtomicLong;
  23. import org.redisson.api.RLock;
  24. import org.redisson.api.RedissonClient;
  25. import org.springframework.beans.factory.annotation.Autowired;
  26. import org.springframework.transaction.annotation.Transactional;
  28. import java.util.ArrayList;
  29. import java.util.List;
  30. import java.util.concurrent.TimeUnit;
  31. import java.util.stream.Collectors;
  33. /**
  34.  * @ClassName DishFaceImpl.java
  35.  * @Description 菜品接口实现
  36.  */
  37. @Slf4j
  38. @DubboService(version = "${dubbo.application.version}",timeout = 5000,
  39.         methods ={
  40.                 @Method(name = "findDishVoPage",retries = 2),
  41.                 @Method(name = "createDish",retries = 0),
  42.                 @Method(name = "updateDish",retries = 0),
  43.                 @Method(name = "deleteDish",retries = 0)
  44.         })
  45. public class DishFaceImpl implements DishFace {
  47.     @Autowired
  48.     IDishService dishService;
  50.     @Autowired
  51.     IDishFlavorService dishFlavorService;
  53.     @Autowired
  54.     RedissonClient redissonClient;
  56.     @DubboReference(version = "${dubbo.application.version}",check = false)
  57.     AffixFace affixFace;
  59.     @Override
  60.     public Page<DishVo> findDishVoPage(DishVo dishVo,
  61.                                        int pageNum,
  62.                                        int pageSize)throws ProjectException {
  63.         try {
  64.             //查询菜品分页
  65.             Page<Dish> page = dishService.findDishVoPage(dishVo, pageNum, pageSize);
  66.             Page<DishVo> pageVo = new Page<>();
  67.             BeanConv.toBean(page,pageVo);
  68.             //结果集转换
  69.             List<Dish> dishList = page.getRecords();
  70.             List<DishVo> dishVoList = BeanConv.toBeanList(dishList,DishVo.class);
  71.             if (!EmptyUtil.isNullOrEmpty(dishVoList)){
  72.                 dishVoList.forEach(n->{
  73.                     //处理附件
  74.                     List<AffixVo> affixVoList = affixFace.findAffixVoByBusinessId(n.getId());
  75.                     if (!EmptyUtil.isNullOrEmpty(affixVoList)){
  76.                         n.setAffixVo(affixVoList.get(0));
  77.                     }
  78.                     //处理口味1
  79.                     List<DishFlavor> dishFlavors = dishFlavorService.findDishFlavorByDishId(n.getId());
  80.                     List<String> dishFavorList = new ArrayList<>();
  81.                     for (DishFlavor dishFlavor : dishFlavors) {
  82.                         dishFavorList.add(String.valueOf(dishFlavor.getDataKey()));
  83.                     }
  84.                     String[] dishFlavorDataKey = new String[dishFavorList.size()];
  85.                     dishFavorList.toArray(dishFlavorDataKey);
  86.                     n.setHasDishFlavor(dishFlavorDataKey);
  87.                 });
  88.             }
  89.             pageVo.setRecords(dishVoList);
  90.             //返回结果
  91.             return pageVo;
  92.         } catch (Exception e) {
  93.             log.error("查询菜品列表异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  94.             throw new ProjectException(DishEnum.PAGE_FAIL);
  95.         }
  96.     }
  98.     @Override
  99.     @Transactional
  100.     public DishVo createDish(DishVo dishVo) throws ProjectException{
  101.         try {
  102.             //创建菜品
  103.             DishVo dishVoResult = BeanConv.toBean(dishService.createDish(dishVo), DishVo.class);
  104.             dishVoResult.setHasDishFlavor(dishVo.getHasDishFlavor());
  105.             //绑定附件
  106.             if (!EmptyUtil.isNullOrEmpty(dishVoResult)){
  107.                 affixFace.bindBusinessId(AffixVo.builder()
  108.                         .businessId(dishVoResult.getId())
  109.                         .id(dishVo.getAffixVo().getId())
  110.                         .build());
  111.             }
  112.             dishVoResult.setAffixVo(AffixVo.builder()
  113.                     .pathUrl(dishVo.getAffixVo().getPathUrl())
  114.                     .businessId(dishVoResult.getId())
  115.                     .id(dishVo.getAffixVo().getId()).build());
  116.             //构建初始化库存
  117.             String key = AppletCacheConstant.REPERTORY_DISH+dishVoResult.getId();
  118.             RAtomicLong atomicLong = redissonClient.getAtomicLong(key);
  119.             atomicLong.set(dishVoResult.getDishNumber());
  120.             return  dishVoResult;
  121.         } catch (Exception e) {
  122.             log.error("保存菜品异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  123.             throw new ProjectException(DishEnum.CREATE_FAIL);
  124.         }
  125.     }
  127.     @Override
  128.     @Transactional
  129.     public Boolean updateDish(DishVo dishVo) throws ProjectException {
  130.         Boolean flag = false;
  131.         //修改菜品
  132.         flag = dishService.updateDish(dishVo);
  133.         //处理菜品图片
  134.         if (flag){
  135.             List<AffixVo> affixVoList = affixFace.findAffixVoByBusinessId(dishVo.getId());
  136.             List<Long> affixIds = affixVoList.stream()
  137.                     .map(AffixVo::getId)
  138.                     .collect(Collectors.toList());
  139.             if (!affixIds.contains(dishVo.getAffixVo().getId())){
  140.                 //删除图片
  141.                 flag = affixFace.deleteAffixVoByBusinessId(dishVo.getId());
  142.                 //绑定新图片
  143.                 affixFace.bindBusinessId(AffixVo.builder()
  144.                         .businessId(dishVo.getId())
  145.                         .id(dishVo.getAffixVo().getId())
  146.                         .build());
  147.             }
  148.         }
  149.         //构建redis库存
  150.         String key = AppletCacheConstant.REPERTORY_DISH+dishVo.getId();
  151.         RAtomicLong atomicLong = redissonClient.getAtomicLong(key);
  152.         atomicLong.set(dishVo.getDishNumber());
  153.         return flag;
  155.     }
  157.     @Override
  158.     @Transactional
  159.     public Boolean deleteDish(String[] checkedIds)throws ProjectException {
  160.         try {
  161.             Boolean flag = dishService.deleteDish(checkedIds);
  162.             for (String checkedId : checkedIds) {
  163.                 //删除图片
  164.                 affixFace.deleteAffixVoByBusinessId(Long.valueOf(checkedId));
  165.                 //删除菜品库存
  166.                 String key = AppletCacheConstant.REPERTORY_DISH+checkedId;
  167.                 RAtomicLong atomicLong = redissonClient.getAtomicLong(key);
  168.                 atomicLong.delete();
  170.             }
  171.             return flag;
  172.         } catch (Exception e) {
  173.             log.error("删除菜品异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  174.             throw new ProjectException(DishEnum.DELETE_FAIL);
  175.         }
  176.     }
  178.     @Override
  179.     public DishVo findDishByDishId(Long dishId)throws ProjectException {
  180.         try {
  181.             //按菜品ID查找菜品
  182.             Dish dish = dishService.getById(dishId);
  183.             if (!EmptyUtil.isNullOrEmpty(dish)){
  184.                 return BeanConv.toBean(dish,DishVo.class);
  185.             }
  186.             return null;
  187.         } catch (Exception e) {
  188.             log.error("查找菜品所有菜品异常：{}", ExceptionsUtil.getStackTraceAsString(e));
  189.             throw new ProjectException(DishEnum.SELECT_DISH_FAIL);
  190.         }
  191.     }
  193. }

3.3、IDishService业务接口

菜品管理的业务接口定义，为DishFaceImpl提供核心业务逻辑的定义

  1. package com.itheima.restkeeper.service;
  3. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  4. import com.itheima.restkeeper.pojo.Dish;
  5. import com.itheima.restkeeper.pojo.Dish;
  6. import com.baomidou.mybatisplus.extension.service.IService;
  7. import com.itheima.restkeeper.req.DishVo;
  9. import java.util.List;
  11. /**
  12.  * @Description：菜品管理 服务类
  13.  */
  14. public interface IDishService extends IService<Dish> {
  16.     /**
  17.      * @Description 菜品列表
  18.      * @param dishVo 查询条件
  19.      * @param pageNum 当前页
  20.      * @param pageSize 每页条数
  21.      * @return Page<Dish>
  22.      */
  23.     Page<Dish> findDishVoPage(DishVo dishVo, int pageNum, int pageSize);
  25.     /**
  26.      * @Description 创建菜品
  27.      * @param dishVo 对象信息
  28.      * @return Dish
  29.      */
  30.     Dish createDish(DishVo dishVo);
  32.     /**
  33.      * @Description 修改菜品
  34.      * @param dishVo 对象信息
  35.      * @return Boolean
  36.      */
  37.     Boolean updateDish(DishVo dishVo);
  39.     /**
  40.      * @Description 删除菜品
  41.      * @param checkedIds 选择的菜品ID
  42.      * @return Boolean
  43.      */
  44.     Boolean deleteDish(String[] checkedIds);
  47.     /***
  48.      * @description 查询分类下所有菜品
  49.      * @param categoryId
  50.      * @return List<Dish>
  51.      */
  52.     List<Dish> findDishVoByCategoryId(Long categoryId);
  54.     /***
  55.      * @description 查询店铺下所有起售且有效菜品
  56.      * @param storeId
  57.      * @return List<Dish>
  58.      */
  59.     List<Dish> findDishVoByStoreId(Long storeId);
  62.     /***
  63.      * @description 增减菜品库存数量
  64.      * @param step 增减步长
  65.      * @return Boolean
  66.      */
  67.     Boolean updateDishNumber(Long step, Long dishId);
  69.     /***
  70.      * @description 查询所有有效的菜品信息
  71.      * @return
  72.      */
  73.     List<Dish> findDishVos();
  74. }

3.4、DishServiceImpl业务接口实现

菜品管理的业务接口定义实现

  1. package com.itheima.restkeeper.service.impl;
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  5. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  6. import com.google.common.collect.Lists;
  7. import com.itheima.restkeeper.constant.SuperConstant;
  8. import com.itheima.restkeeper.pojo.Dish;
  9. import com.itheima.restkeeper.mapper.DishMapper;
  10. import com.itheima.restkeeper.pojo.DishFlavor;
  11. import com.itheima.restkeeper.req.DishVo;
  12. import com.itheima.restkeeper.service.IDishFlavorService;
  13. import com.itheima.restkeeper.service.IDishService;
  14. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  15. import com.itheima.restkeeper.utils.BeanConv;
  16. import com.itheima.restkeeper.utils.EmptyUtil;
  17. import org.springframework.beans.factory.annotation.Autowired;
  18. import org.springframework.stereotype.Service;
  19. import org.springframework.transaction.annotation.Transactional;
  21. import java.util.ArrayList;
  22. import java.util.Arrays;
  23. import java.util.List;
  25. /**
  26.  * @Description：菜品管理 服务实现类
  27.  */
  28. @Service
  29. public class DishServiceImpl extends ServiceImpl<DishMapper, Dish> implements IDishService {
  31.     @Autowired
  32.     IDishFlavorService dishFlavorService;
  34.     @Autowired
  35.     DishMapper dishMapper;
  37.     @Override
  38.     public Page<Dish> findDishVoPage(DishVo dishVo, int pageNum, int pageSize) {
  39.         //构建Page<Dish>分页对象
  40.         Page<Dish> page = new Page<>(pageNum,pageSize);
  41.         QueryWrapper<Dish> queryWrapper = new QueryWrapper<>();
  42.         //按分类查询
  43.         if (!EmptyUtil.isNullOrEmpty(dishVo.getCategoryId())) {
  44.             queryWrapper.lambda().eq(Dish::getCategoryId,dishVo.getCategoryId());
  45.         }
  46.         //按菜品名称查询
  47.         if (!EmptyUtil.isNullOrEmpty(dishVo.getDishName())) {
  48.             queryWrapper.lambda().likeRight(Dish::getDishName,dishVo.getDishName());
  49.         }
  50.         //按简码查询
  51.         if (!EmptyUtil.isNullOrEmpty(dishVo.getCode())) {
  52.             queryWrapper.lambda().likeRight(Dish::getCode,dishVo.getCode());
  53.         }
  54.         //按有效性查询
  55.         if (!EmptyUtil.isNullOrEmpty(dishVo.getEnableFlag())) {
  56.             queryWrapper.lambda().eq(Dish::getEnableFlag,dishVo.getEnableFlag());
  57.         }
  58.         //按sortNo升序
  59.         queryWrapper.lambda().orderByAsc(Dish::getSortNo);
  60.         //执行page返回结果
  61.         return page(page, queryWrapper);
  62.     }
  64.     @Override
  65.     @Transactional
  66.     public Dish createDish(DishVo dishVo) {
  67.         //转换DishVo为Dish
  68.         Dish dish = BeanConv.toBean(dishVo, Dish.class);
  69.         //执行保存
  70.         boolean flag = save(dish);
  71.         //保存菜品和口味中间表信息
  72.         if (flag){
  73.             List<DishFlavor> list = Lists.newArrayList();
  74.             List<String> dataKeys = Arrays.asList(dishVo.getHasDishFlavor());
  75.             dataKeys.forEach(n->{
  76.                 DishFlavor dishFlavor = DishFlavor.builder()
  77.                         .dishId(dish.getId())
  78.                         .dataKey(n)
  79.                         .build();
  80.                 list.add(dishFlavor);
  81.             });
  82.             flag = dishFlavorService.saveBatch(list);
  83.         }
  84.         if (flag){
  85.             return dish;
  86.         }
  87.         return null;
  88.     }
  90.     /**
  91.      * @Description 菜品拥有的口味
  92.      */
  93.     private List<String> dishHasDishFlavor(Long dishId){
  94.         QueryWrapper<DishFlavor> queryWrapper = new QueryWrapper<>();
  95.         queryWrapper.lambda().eq(DishFlavor::getDishId,dishId);
  96.         List<DishFlavor> list = dishFlavorService.list(queryWrapper);
  97.         ArrayList<String> listDataKeys = Lists.newArrayList();
  98.         if (!EmptyUtil.isNullOrEmpty(list)){
  99.             list.forEach(n->{
  100.                 listDataKeys.add(String.valueOf(n.getDataKey()));
  101.             });
  102.         }
  103.         return listDataKeys;
  104.     }
  106.     @Override
  107.     public Boolean updateDish(DishVo dishVo) {
  108.         Dish dish = BeanConv.toBean(dishVo, Dish.class);
  109.         boolean flag = updateById(dish);
  110.         if (flag){
  111.             //删除以往有的口味
  112.             QueryWrapper<DishFlavor> queryWrapper = new QueryWrapper<>();
  113.             queryWrapper.lambda().eq(DishFlavor::getDishId,dish.getId());
  114.             dishFlavorService.remove(queryWrapper);
  115.         }
  116.         //添加新口味
  117.         List<DishFlavor> list = Lists.newArrayList();
  118.         List<String> newDishHasDishFlavors = Arrays.asList(dishVo.getHasDishFlavor());
  119.         newDishHasDishFlavors.forEach(n->{
  120.             DishFlavor dishFlavors = DishFlavor.builder()
  121.                     .dishId(dish.getId())
  122.                     .dataKey(n)
  123.                     .build();
  124.             list.add(dishFlavors);
  125.         });
  126.         flag = dishFlavorService.saveBatch(list);
  127.         return flag;
  128.     }
  130.     @Override
  131.     public Boolean deleteDish(String[] checkedIds) {
  132.         //构建选择ids的List<String>
  133.         List<String> ids = Arrays.asList(checkedIds);
  134.         List<Long> idsLong = new ArrayList<>();
  135.         ids.forEach(n->{
  136.             idsLong.add(Long.valueOf(n));
  137.         });
  138.         //批量移除菜品
  139.         boolean flag = removeByIds(idsLong);
  140.         //批量移除菜品口味
  141.         if (flag){
  142.             QueryWrapper<DishFlavor> queryWrapper = new QueryWrapper<>();
  143.             queryWrapper.lambda().in(DishFlavor::getDishId,idsLong);
  144.             flag = dishFlavorService.remove(queryWrapper);
  145.         }
  146.         return flag;
  147.     }
  149.     @Override
  150.     public List<Dish> findDishVoByCategoryId(Long categoryId) {
  151.         //构建查询条件：菜品起售，菜品有效
  152.         LambdaQueryWrapper<Dish> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  153.         lambdaQueryWrapper.eq(Dish::getCategoryId,categoryId)
  154.                 .eq(Dish::getEnableFlag,SuperConstant.YES)
  155.                 .eq(Dish::getDishStatus,SuperConstant.YES);
  156.         //执行list查询
  157.         return list(lambdaQueryWrapper);
  158.     }
  160.     @Override
  161.     public List<Dish> findDishVoByStoreId(Long storeId) {
  162.         //构建查询条件：店铺ID，菜品起售，菜品有效
  163.         LambdaQueryWrapper<Dish> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  164.         lambdaQueryWrapper.eq(Dish::getStoreId,storeId)
  165.                 .eq(Dish::getEnableFlag,SuperConstant.YES)
  166.                 .eq(Dish::getDishStatus,SuperConstant.YES);
  167.         //执行list查询
  168.         return list(lambdaQueryWrapper);
  169.     }
  171.     @Override
  172.     public Boolean updateDishNumber(Long step,Long dishId) {
  173.         //修改菜品数量
  174.         Integer row = dishMapper.updateDishNumber(step,dishId);
  175.         return row==1 ? true:false;
  176.     }
  178.     @Override
  179.     public List<Dish> findDishVos() {
  180.         QueryWrapper<Dish> queryWrapper = new QueryWrapper<>();
  181.         queryWrapper.lambda().eq(Dish::getEnableFlag,SuperConstant.YES)
  182.                 .eq(Dish::getDishStatus,SuperConstant.YES);
  183.         return list(queryWrapper);
  184.     }
  187. }

3.5、DishController类

对DishFace接口进行dubbo的RPC调用，为dubbo服务的消费者

  1. package com.itheima.restkeeper.web;
  3. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  4. import com.itheima.restkeeper.DishFace;
  5. import com.itheima.restkeeper.basic.ResponseWrap;
  6. import com.itheima.restkeeper.enums.DishEnum;
  7. import com.itheima.restkeeper.req.DishVo;
  8. import com.itheima.restkeeper.utils.ResponseWrapBuild;
  9. import io.swagger.annotations.Api;
  10. import io.swagger.annotations.ApiImplicitParam;
  11. import io.swagger.annotations.ApiImplicitParams;
  12. import io.swagger.annotations.ApiOperation;
  13. import lombok.extern.slf4j.Slf4j;
  14. import org.apache.dubbo.config.annotation.DubboReference;
  15. import org.springframework.web.bind.annotation.*;
  17. /**
  18.  * @ClassName DishController.java
  19.  * @Description 菜品Controller
  20.  */
  21. @RestController
  22. @RequestMapping("dish")
  23. @Slf4j
  24. @Api(tags = "菜品controller")
  25. public class DishController {
  27.     @DubboReference(version = "${dubbo.application.version}",check = false)
  28.     DishFace dishFace;
  30.     /**
  31.      * @Description 菜品列表
  32.      * @param dishVo 查询条件
  33.      * @return
  34.      */
  35.     @PostMapping("page/{pageNum}/{pageSize}")
  36.     @ApiOperation(value = "查询菜品分页",notes = "查询菜品分页")
  37.     @ApiImplicitParams({
  38.         @ApiImplicitParam(name = "dishVo",value = "菜品查询对象",dataType = "DishVo"),
  39.         @ApiImplicitParam(paramType = "path",name = "pageNum",value = "页码",dataType = "Integer"),
  40.         @ApiImplicitParam(paramType = "path",name = "pageSize",value = "每页条数",dataType = "Integer")
  41.     })
  42.     public ResponseWrap<Page<DishVo>> findDishVoPage(
  43.         @RequestBody DishVo dishVo,
  44.         @PathVariable("pageNum") int pageNum,
  45.         @PathVariable("pageSize") int pageSize) {
  46.         Page<DishVo> dishVoPage = dishFace.findDishVoPage(dishVo, pageNum, pageSize);
  47.         return ResponseWrapBuild.build(DishEnum.SUCCEED,dishVoPage);
  48.     }
  50.     /**
  51.      * @Description 添加菜品
  52.      * @param dishVo 对象信息
  53.      * @return
  54.      */
  55.     @PostMapping
  56.     @ApiOperation(value = "添加菜品",notes = "添加菜品")
  57.     @ApiImplicitParam(name = "dishVo",value = "菜品对象",required = true,dataType = "DishVo")
  58.     ResponseWrap<DishVo> createDish(@RequestBody DishVo dishVo) {
  59.         DishVo dishVoResult = dishFace.createDish(dishVo);
  60.         return ResponseWrapBuild.build(DishEnum.SUCCEED,dishVoResult);
  61.     }
  63.     /**
  64.      * @Description 修改菜品
  65.      * @param dishVo 对象信息
  66.      * @return
  67.      */
  68.     @PatchMapping
  69.     @ApiOperation(value = "修改菜品",notes = "修改菜品")
  70.     @ApiImplicitParam(name = "dishVo",value = "菜品对象",required = true,dataType = "DishVo")
  71.     ResponseWrap<Boolean> updateDish(@RequestBody DishVo dishVo) {
  72.         Boolean flag = dishFace.updateDish(dishVo);
  73.         return ResponseWrapBuild.build(DishEnum.SUCCEED,flag);
  74.     }
  76.     /**
  77.      * @Description 删除菜品
  78.      * @param dishVo 查询对象
  79.      * @return
  80.      */
  81.     @DeleteMapping
  82.     @ApiOperation(value = "删除菜品",notes = "删除菜品")
  83.     @ApiImplicitParam(name = "dishVo",value = "菜品查询对象",required = true,dataType = "DishVo")
  84.     ResponseWrap<Boolean> deleteDish(@RequestBody DishVo dishVo ) {
  85.         //获得所有选中的菜品IDS
  86.         String[] checkedIds = dishVo.getCheckedIds();
  87.         Boolean flag = dishFace.deleteDish(checkedIds);
  88.         return ResponseWrapBuild.build(DishEnum.SUCCEED,flag);
  89.     }
  91.     /**
  92.      * @Description 查找菜品
  93.      * @param dishId 菜品id
  94.      * @return
  95.      */
  96.     @GetMapping("{dishId}")
  97.     @ApiOperation(value = "查找菜品",notes = "查找菜品")
  98.     @ApiImplicitParam(paramType = "path",name = "dishId",value = "菜品Id",dataType = "Long")
  99.     ResponseWrap<DishVo> findDishByDishId(@PathVariable("dishId") Long dishId) {
  100.         DishVo dishVo = dishFace.findDishByDishId(dishId);
  101.         return ResponseWrapBuild.build(DishEnum.SUCCEED,dishVo);
  102.     }
  104.     @PostMapping("update-dish-enableFlag")
  105.     @ApiOperation(value = "修改菜品有效状态",notes = "修改菜品有效状态")
  106.     ResponseWrap<Boolean> updateDishEnableFlag(@RequestBody DishVo dishVo) {
  107.         Boolean flag = dishFace.updateDish(dishVo);
  108.         return ResponseWrapBuild.build(DishEnum.SUCCEED,flag);
  109.     }
  111.     @PostMapping("update-dish-dishStatus")
  112.     @ApiOperation(value = "修改菜品状态",notes = "修改菜品状态")
  113.     ResponseWrap<Boolean> updateDishDishStatus(@RequestBody DishVo dishVo) {
  114.         Boolean flag = dishFace.updateDish(dishVo);
  115.         return ResponseWrapBuild.build(DishEnum.SUCCEED,flag);
  116.     }
  118. }

课堂讨论

1、概述区域、桌台、分类、菜品表之间的关系，及关键字段。

2、项目中区域、桌台、分类、菜品是否有企业归属及门店归属的概念？在设计数据库的时候需要注意什么?

3、菜品的库存的控制你是这么理解的？菜品库存与那些操作有关？

4、设计一下==《汽车维修4S美容中心》==中的表结构

课后任务

1、完成区域、桌台、分类、菜品管理开发，同步到git【☆☆☆☆☆】

2、完成当天课堂讨论，同步到git【☆☆☆☆☆】

3、完成2-5道sql练习【☆☆☆☆】

4、梳理项目一业务，同步到git【☆☆☆】