123 lines
3.6 KiB
Java
123 lines
3.6 KiB
Java
package com.sky.service.impl;
|
|
|
|
import com.github.pagehelper.Page;
|
|
import com.github.pagehelper.PageHelper;
|
|
import com.sky.constant.MessageConstant;
|
|
import com.sky.constant.StatusConstant;
|
|
import com.sky.dto.SetmealDTO;
|
|
import com.sky.dto.SetmealPageQueryDTO;
|
|
import com.sky.entity.Dish;
|
|
import com.sky.entity.Setmeal;
|
|
import com.sky.entity.SetmealDish;
|
|
import com.sky.exception.SetmealEnableFailedException;
|
|
import com.sky.mapper.DishMapper;
|
|
import com.sky.mapper.SetMealDishMapper;
|
|
import com.sky.mapper.SetmealMapper;
|
|
import com.sky.result.PageResult;
|
|
import com.sky.service.SetmealService;
|
|
import com.sky.vo.DishItemVO;
|
|
import com.sky.vo.SetmealVO;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.springframework.beans.BeanUtils;
|
|
import org.springframework.stereotype.Service;
|
|
|
|
import javax.annotation.Resource;
|
|
import java.util.List;
|
|
|
|
/**
|
|
* 套餐业务实现
|
|
*/
|
|
@Service
|
|
@Slf4j
|
|
public class SetmealServiceImpl implements SetmealService {
|
|
|
|
@Resource
|
|
private SetmealMapper setmealMapper;
|
|
@Resource
|
|
private SetMealDishMapper setmealDishMapper;
|
|
@Resource
|
|
private DishMapper dishMapper;
|
|
|
|
/**
|
|
* 条件查询
|
|
*
|
|
* @param setmeal Setmeal
|
|
* @return List<Setmeal>
|
|
*/
|
|
public List<Setmeal> list(Setmeal setmeal) {
|
|
return setmealMapper.list(setmeal);
|
|
}
|
|
|
|
/**
|
|
* 根据id查询菜品选项
|
|
*
|
|
* @param id Long
|
|
* @return List<DishItemVO>
|
|
*/
|
|
public List<DishItemVO> getDishItemById(Long id) {
|
|
return setmealMapper.getDishItemBySetmealId(id);
|
|
}
|
|
|
|
/**
|
|
* 新增套餐，同时需要保存套餐和菜品的关联关系
|
|
*
|
|
* @param setmealDTO SetmealDTO
|
|
*/
|
|
@Override
|
|
public void saveWithDish(SetmealDTO setmealDTO) {
|
|
Setmeal setmeal = new Setmeal();
|
|
BeanUtils.copyProperties(setmealDTO, setmeal);
|
|
|
|
// 向套餐表插入数据
|
|
setmealMapper.insert(setmeal);
|
|
// 获取生成的套餐id
|
|
Long setmealId = setmeal.getId();
|
|
List<SetmealDish> setmealDishes = setmealDTO.getSetmealDishes();
|
|
setmealDishes.forEach(setmealDish -> {
|
|
setmealDish.setSetmealId(setmealId);
|
|
});
|
|
// 保存套餐和菜品的关联关系
|
|
setmealDishMapper.insertBatch(setmealDishes);
|
|
}
|
|
|
|
/**
|
|
* 分页查询
|
|
*
|
|
* @param setmealPageQueryDTO SetmealPageQueryDTO
|
|
* @return PageResult
|
|
*/
|
|
@Override
|
|
public PageResult pageQuery(SetmealPageQueryDTO setmealPageQueryDTO) {
|
|
int pageNum = setmealPageQueryDTO.getPage();
|
|
int pageSize = setmealPageQueryDTO.getPageSize();
|
|
|
|
PageHelper.startPage(pageNum, pageSize);
|
|
Page<SetmealVO> page = setmealDishMapper.pageQuery(setmealPageQueryDTO);
|
|
return new PageResult(page.getTotal(), page.getResult());
|
|
}
|
|
|
|
/**
|
|
* 套餐起售停售
|
|
*
|
|
* @param status Integer
|
|
* @param id Long
|
|
*/
|
|
@Override
|
|
public void startOrStop(Integer status, Long id) {
|
|
// 起售套餐时，判断套餐内是否有停售菜品，有停售菜品提示"套餐内包含未启售菜品，无法启售"
|
|
if (status.equals(StatusConstant.ENABLE)) {
|
|
List<Dish> dishList = dishMapper.getBySetmealId(id);
|
|
if (dishList != null && !dishList.isEmpty()) {
|
|
dishList.forEach(dish -> {
|
|
if (dish.getStatus().equals(StatusConstant.DISABLE)) {
|
|
throw new SetmealEnableFailedException(MessageConstant.SETMEAL_ENABLE_FAILED);
|
|
}
|
|
});
|
|
}
|
|
}
|
|
|
|
Setmeal setmeal = Setmeal.builder().id(id).status(status).build();
|
|
setmealMapper.update(setmeal);
|
|
}
|
|
}
|