苍穹外卖学习条记(八)

套餐管理

• Controller
  
• Service
  
• Impl
  套餐管理
  
• Controller
  package com.sky.controller.admin;
  

import com.sky.dto.SetmealDTO;
import com.sky.dto.SetmealPageQueryDTO;
import com.sky.result.PageResult;
import com.sky.result.Result;
import com.sky.service.SetmealService;
import com.sky.vo.SetmealVO;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;
@RestController
@RequestMapping(“/admin/setmeal”)
@Api(tags = “套餐管理”)
@Slf4j
public class SetmealController {

1. @Autowired
2. private SetmealService setmealService;
4. /**
5. * 新增套餐
6. */
7. @PostMapping
8. @ApiOperation("新增套餐")
9. public Result save(@RequestBody SetmealDTO setmealDTO) {
10.     log.info("新增套餐");
11.     setmealService.saveWithDishes(setmealDTO);
12.     return Result.success();
13. }
15. /**
16. * 分页查询套餐
17. */
18. @GetMapping("/page")
19. @ApiOperation("分页查询套餐")
20. public Result<PageResult> page(SetmealPageQueryDTO setmealPageQueryDTO) {
21.     log.info("分页查询套餐:{}", setmealPageQueryDTO);
22.     PageResult pageResult = setmealService.pageQuery(setmealPageQueryDTO);
23.     return Result.success(pageResult);
24. }
26. /**
27. * 删除套餐
28. */
29. @DeleteMapping
30. @ApiOperation("删除套餐")
31. public Result delete(@RequestParam List<Long> ids) {
32.     log.info("删除套餐:{}", ids);
33.     setmealService.deleteBatch(ids);
34.     return Result.success();
35. }
37. /**
38. * 根据id查询套餐
39. */
40. @GetMapping("/{id}")
41. @ApiOperation("根据id查询套餐")
42. public Result<SetmealVO> getById(@PathVariable Long id) {
43.     log.info("根据id查询套餐:{}", id);
44.     SetmealVO setmealVO = setmealService.getByIdWithDish(id);
45.     return Result.success(setmealVO);
46. }
48. /**
49. * 修改套餐
50. */
51. @PutMapping
52. @ApiOperation("修改套餐")
53. public Result update(@RequestBody SetmealDTO setmealDTO) {
54.     log.info("修改套餐:{}", setmealDTO);
55.     setmealService.updateWithDishes(setmealDTO);
56.     return Result.success();
57. }
59. /**
60. * 修改套餐状态
61. */
62. @PostMapping("/status/{status}")
63. @ApiOperation("修改套餐状态")
64. public Result updateStatus(@PathVariable Integer status, Long id) {
65.     log.info("修改套餐状态:{}", id);
66.     setmealService.updateStatus(status, id);
67.     return Result.success();
68. }

复制代码

}
2. Service
package com.sky.service;
import com.sky.dto.SetmealDTO;
import com.sky.dto.SetmealPageQueryDTO;
import com.sky.result.PageResult;
import com.sky.vo.SetmealVO;
import java.util.List;
public interface SetmealService {

1. /**
2. * 新增套餐
3. */
4. void saveWithDishes(SetmealDTO setmealDTO);
6. /**
7. * 分页查询套餐
8. */
9. PageResult pageQuery(SetmealPageQueryDTO setmealPageQueryDTO);
11. /**
12. * 删除套餐
13. */
14. void deleteBatch(List<Long> ids);
16. /**
17. * 根据id查询套餐
18. */
19. SetmealVO getByIdWithDish(Long id);
21. /**
22. * 更新套餐
23. */
24. void updateWithDishes(SetmealDTO setmealDTO);
26. /**
27. * 更新套餐状态
28. */
29. void updateStatus(Integer status, Long id);

复制代码

}
3. Impl
package com.sky.service.impl;
import com.baomidou.mybatisplus.core.batch.MybatisBatch;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.sky.constant.MessageConstant;
import com.sky.dto.SetmealDTO;
import com.sky.dto.SetmealPageQueryDTO;
import com.sky.entity.Setmeal;
import com.sky.entity.SetmealDish;
import com.sky.mapper.SetmealDishMapper;
import com.sky.mapper.SetmealMapper;
import com.sky.result.PageResult;
import com.sky.service.SetmealService;
import com.sky.vo.SetmealVO;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.ibatis.session.SqlSessionFactory;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
@Service
@Slf4j
public class SetmealServiceImpl implements SetmealService {

1. @Autowired
2. private SetmealMapper setmealMapper;
4. @Autowired
5. private SetmealDishMapper setmealDishMapper;
7. @Autowired
8. private SqlSessionFactory sqlSessionFactory;
10. /**
11. * 新增套餐
12. */
13. @Override
14. @Transactional
15. public void saveWithDishes(SetmealDTO setmealDTO) {
16.     // 向套餐表插入一条数据
17.     Setmeal setmeal = new Setmeal();
18.     BeanUtils.copyProperties(setmealDTO, setmeal);
19.     setmealMapper.insert(setmeal);
20.     setmealMapper.selectById(setmeal.getId());// 获取插入后的主键值
21.     Long setmealId = setmeal.getId();// 获取套餐id
22.     // 获取套餐菜品
23.     List<SetmealDish> setmealDishes = setmealDTO.getSetmealDishes();
24.     if (setmealDishes != null && !setmealDishes.isEmpty()) {
25.         setmealDishes.forEach(setmealDish -> {
26.             setmealDish.setSetmealId(setmealId);// 设置套餐id
27.         });
28.         //批量插入套餐菜品
29.         MybatisBatch<SetmealDish> mybatisBatch = new MybatisBatch<>(sqlSessionFactory, setmealDishes);
30.         MybatisBatch.Method<SetmealDish> method = new MybatisBatch.Method<>(SetmealDishMapper.class);
31.         mybatisBatch.execute(method.insert());
32.     }
33. }
35. /**
36. * 分页查询套餐
37. */
38. @Override
39. @Transactional
40. public PageResult pageQuery(SetmealPageQueryDTO setmealPageQueryDTO) {
41.     Page<SetmealVO> page = new Page<>(setmealPageQueryDTO.getPage(), setmealPageQueryDTO.getPageSize());
42.     QueryWrapper<Setmeal> queryWrapper = new QueryWrapper<>();
43.     queryWrapper.isNotNull("s.name");
44.     // 如果提供了名称，则添加模糊查询条件
45.     if (StringUtils.isNotBlank(setmealPageQueryDTO.getName())) {
46.         queryWrapper.like("s.name", setmealPageQueryDTO.getName());
47.     }
48.     // 如果提供了分类id，则添加等值查询条件
49.     if (setmealPageQueryDTO.getCategoryId() != null) {
50.         queryWrapper.eq("s.category_id", setmealPageQueryDTO.getCategoryId());
51.     }
52.     // 如果提供了状态，则添加等值查询条件
53.     if (setmealPageQueryDTO.getStatus() != null) {
54.         queryWrapper.eq("s.status", setmealPageQueryDTO.getStatus());
55.     }
56.     // 按创建时间降序排序
57.     queryWrapper.orderByDesc("s.create_time");
58.     // 执行查询
59.     System.out.println(queryWrapper.getCustomSqlSegment());
61.     Page<SetmealVO> setmealVOPage = setmealMapper.selectPage(page, queryWrapper);
62.     long total = setmealVOPage.getTotal();
63.     List<SetmealVO> setmealVOList = setmealVOPage.getRecords();
64.     return new PageResult(total, setmealVOList);
65. }
67. /**
68. * 删除套餐
69. */
70. @Override
71. @Transactional
72. public void deleteBatch(List<Long> ids) {
73.     //判断是否存在起售中的套餐
74.     List<Setmeal> setmeals = setmealMapper.selectBatchIds(ids);
75.     for (Setmeal setmeal : setmeals) {
76.         if (setmeal.getStatus() == 1) {
77.             throw new RuntimeException(MessageConstant.SETMEAL_ON_SALE);
78.         }
79.     }
80.     //删除套餐
81.     setmealMapper.deleteBatchIds(ids);
82.     //删除套餐菜品
83.     LambdaQueryWrapper<SetmealDish> lambdaQueryWrapper = new LambdaQueryWrapper<>();
84.     lambdaQueryWrapper.in(SetmealDish::getSetmealId, ids);
85.     setmealDishMapper.delete(lambdaQueryWrapper);
86. }
88. /**
89. * 根据id查询套餐
90. */
91. @Override
92. @Transactional
93. public SetmealVO getByIdWithDish(Long id) {
94.     // 查询套餐
95.     Setmeal setmeal = setmealMapper.selectById(id);
96.     // 查询套餐菜品
97.     LambdaQueryWrapper<SetmealDish> lambdaQueryWrapper = new LambdaQueryWrapper<>();
98.     lambdaQueryWrapper.eq(SetmealDish::getSetmealId, id);
99.     List<SetmealDish> setmealDishes = setmealDishMapper.selectList(lambdaQueryWrapper);
100.     // 封装数据
101.     SetmealVO setmealVO = new SetmealVO();
102.     BeanUtils.copyProperties(setmeal, setmealVO);
103.     setmealVO.setSetmealDishes(setmealDishes);
104.     return setmealVO;
105. }
107. /**
108. * 更新套餐
109. */
110. @Override
111. @Transactional
112. public void updateWithDishes(SetmealDTO setmealDTO) {
113.     Setmeal setmeal = new Setmeal();
114.     BeanUtils.copyProperties(setmealDTO, setmeal);
115.     setmealMapper.updateById(setmeal);
116.     //删除原有套餐菜品
117.     LambdaQueryWrapper<SetmealDish> lambdaQueryWrapper = new LambdaQueryWrapper<>();
118.     lambdaQueryWrapper.eq(SetmealDish::getSetmealId, setmeal.getId());
119.     setmealDishMapper.delete(lambdaQueryWrapper);
120.     //插入新的套餐菜品
121.     List<SetmealDish> setmealDishes = setmealDTO.getSetmealDishes();
122.     if (setmealDishes != null && !setmealDishes.isEmpty()) {
123.         setmealDishes.forEach(setmealDish -> {
124.             setmealDish.setSetmealId(setmeal.getId());
125.         });
126.         //批量插入套餐菜品
127.         MybatisBatch<SetmealDish> mybatisBatch = new MybatisBatch<>(sqlSessionFactory, setmealDishes);
128.         MybatisBatch.Method<SetmealDish> method = new MybatisBatch.Method<>(SetmealDishMapper.class);
129.         mybatisBatch.execute(method.insert());
130.     }
131. }
133. /**
134. * 更新套餐状态
135. */
136. @Override
137. @Transactional
138. public void updateStatus(Integer status, Long id) {
139.     //判断是否存在未启售的菜品
140.     if (status == 1) {
141.         LambdaQueryWrapper<SetmealDish> lambdaQueryWrapper = new LambdaQueryWrapper<>();
142.         lambdaQueryWrapper.eq(SetmealDish::getSetmealId, id);
143.         List<SetmealDish> setmealDishes = setmealDishMapper.selectList(lambdaQueryWrapper);
144.         if (setmealDishes.isEmpty()) {
145.             throw new RuntimeException(MessageConstant.SETMEAL_ENABLE_FAILED);
146.         }
147.     }
148.     //更新套餐状态
149.     Setmeal setmeal = setmealMapper.selectById(id);
150.     if (setmeal == null) {
151.         throw new RuntimeException(MessageConstant.SETMEAL_NOT_FOUND);
152.     }
153.     setmeal.setStatus(status);
154.     setmealMapper.updateById(setmeal);
157. }

复制代码

}

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！qidao123.com:ToB企服之家，中国第一个企服评测及软件市场,开放入驻,技术点评得现金