绵阳收银系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
xuhy
2024-09-11 9ca97fd558700e7054c5f54192a9db7a1e6b8230 
 ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TOrderMealServiceImpl.java


@@ -6,12 +6,12 @@


import com.ruoyi.common.constant.OrderNumConstants;


import com.ruoyi.common.enums.BoardEnum;


import com.ruoyi.common.utils.CodeGenerateUtils;


import com.ruoyi.common.utils.DateUtils;


import com.ruoyi.system.domain.*;


import com.ruoyi.system.dto.*;


import com.ruoyi.system.mapper.TOrderMealGoodsMapper;


import com.ruoyi.system.mapper.TOrderMealMapper;


import com.ruoyi.system.query.TDataStatisticsQuery;


import com.ruoyi.system.query.TOrderMealQuery;


import com.ruoyi.system.query.*;


import com.ruoyi.system.service.*;


import com.ruoyi.system.vo.*;


import org.springframework.beans.factory.annotation.Autowired;


@@ -19,6 +19,7 @@


import org.springframework.util.CollectionUtils;




import java.math.BigDecimal;


import java.time.LocalDate;


import java.time.LocalDateTime;


import java.util.*;


import java.util.stream.Collectors;


@@ -50,19 +51,22 @@


        if(Objects.isNull(dto.getBoardId())){


            throw new RuntimeException("餐桌不能为空");


        }


        TOrderMeal orderMeal = this.getById(dto.getId());


        orderMeal.setRemark(orderMeal.getRemark()+dto.getRemark());


        orderMeal.setMealType(dto.getMealType());


        orderMeal.setMealPerson(dto.getMealPerson());


        orderMeal.setMealTime(dto.getMealTime());


        orderMeal.setOrderMoney(dto.getOrderMoney());




        // 查询菜品分类


        List<TGoodsType> list1 = goodsTypeService.list();


        // 查询餐桌


        TBoard board = boardService.getById(dto.getBoardId());


        // 如果菜品为空


        if(CollectionUtils.isEmpty(dto.getMealOrderGoodsDTOS())){


            // 开台


            board.setStatus(BoardEnum.WAITING_ORDER.getCode());


            this.save(dto);


        }else {


        if(!CollectionUtils.isEmpty(dto.getMealOrderGoodsDTOS())){


            board.setStatus(BoardEnum.DURING_MEAL.getCode());


            boardService.updateById(board);


            // 订单金额，订单编号


            String orderNum = OrderNumConstants.MEAL+CodeGenerateUtils.generateOrderSn();


            String orderNum = OrderNumConstants.MEAL+CodeGenerateUtils.generateVolumeSn();


            dto.setOrderNum(orderNum);


            List<TOrderMealGoods> orderMealGoods = new ArrayList<>();


            // 查询商品


@@ -77,25 +81,29 @@


                    orderMealGood.setGoodsPicture(item1.getGoodsPicture());


                    orderMealGood.setGoodsCount(item.getGoodsCount());


                    orderMealGood.setGoodsSalePrice(item1.getSalePrice().multiply(new BigDecimal(item.getGoodsCount())));


//                    orderMealGood.setTypeId(item1.getTypeId());


                    orderMealGood.setCostPrice(item1.getCostPrice().multiply(new BigDecimal(item.getGoodsCount())));


                    orderMealGood.setTypeId(item1.getTypeId());


                    orderMealGood.setGoodsId(item1.getId());


                    orderMealGood.setTypeName(list1.stream().filter(item2 -> item2.getId().equals(item1.getTypeId())).findFirst().get().getTypeName());


                    orderMealGoods.add(orderMealGood);


                });


            });


            this.saveOrUpdate(dto);


            BigDecimal orderMoney = BigDecimal.ZERO;


            // 添加菜品


            orderMealGoods.forEach(item -> {


                item.setOrderId(dto.getId());


            });


            for (TOrderMealGoods orderMealGood : orderMealGoods) {


                orderMealGood.setOrderId(dto.getId());


                orderMoney = orderMoney.add(orderMealGood.getGoodsSalePrice());


            }


            orderMealGoodsService.saveBatch(orderMealGoods);


            orderMeal.setOrderMoney(orderMoney);


            this.updateById(orderMeal);


            // 添加备注


            TOrderRemark tOrderRemark = new TOrderRemark();


            tOrderRemark.setOrderId(dto.getId());


            tOrderRemark.setRemark(dto.getRemark());


            tOrderRemark.setCreateTime(LocalDateTime.now());


            orderRemarkService.save(tOrderRemark);


//            TOrderRemark tOrderRemark = new TOrderRemark();


//            tOrderRemark.setOrderId(dto.getId());


//            tOrderRemark.setRemark(dto.getRemark());


//            tOrderRemark.setCreateTime(LocalDateTime.now());


//            orderRemarkService.save(tOrderRemark);


        }


        boardService.updateById(board);


    }




    @Override


@@ -115,7 +123,8 @@


                orderMealGood.setGoodsPicture(item1.getGoodsPicture());


                orderMealGood.setGoodsCount(item.getGoodsCount());


                orderMealGood.setGoodsSalePrice(item1.getGoodsSalePrice().multiply(new BigDecimal(item.getGoodsCount())));


//                orderMealGood.setTypeId(item1.getTypeId());


                orderMealGood.setTypeId(item1.getTypeId());


                orderMealGood.setGoodsId(item1.getId());


                orderMealGood.setTypeName(list1.stream().filter(item2 -> item2.getId().equals(item1.getTypeId())).findFirst().get().getTypeName());


                orderMealGoods.add(orderMealGood);


            });


@@ -126,11 +135,11 @@


        });


        orderMealGoodsService.saveBatch(orderMealGoods);


        // 添加备注


        TOrderRemark tOrderRemark = new TOrderRemark();


        tOrderRemark.setOrderId(dto.getOrderId());


        tOrderRemark.setRemark(dto.getRemark());


        tOrderRemark.setCreateTime(LocalDateTime.now());


        orderRemarkService.save(tOrderRemark);


//        TOrderRemark tOrderRemark = new TOrderRemark();


//        tOrderRemark.setOrderId(dto.getOrderId());


//        tOrderRemark.setRemark(dto.getRemark());


//        tOrderRemark.setCreateTime(LocalDateTime.now());


//        orderRemarkService.save(tOrderRemark);


    }




    @Override


@@ -153,27 +162,27 @@


            switch (query.getTimeType()){


                case 1:


                    // 今日


                    startTime = LocalDateTime.MIN;


                    endTime = LocalDateTime.MAX;


                    startTime = DateUtils.getDayStart(LocalDateTime.now());


                    endTime = DateUtils.getDayEnd(LocalDateTime.now());


                    break;


                case 2:


                    // 昨日


                    startTime = LocalDateTime.now().minusDays(1);


                    endTime = LocalDateTime.now().minusDays(1);


                    startTime = DateUtils.getDayStart(LocalDateTime.now().minusDays(1));


                    endTime = DateUtils.getDayEnd(LocalDateTime.now().minusDays(1));


                    break;


                case 3:


                    // 近7天


                    startTime = LocalDateTime.now().minusDays(7);


                    endTime = LocalDateTime.now();


                    startTime = DateUtils.getDayStart(LocalDateTime.now().minusDays(7));


                    endTime = DateUtils.getDayEnd(LocalDateTime.now());


                    break;


                case 4:


                    // 近30天


                    startTime = LocalDateTime.now().minusDays(30);


                    endTime = LocalDateTime.now();


                    startTime = DateUtils.getDayStart(LocalDateTime.now().minusDays(30));


                    endTime = DateUtils.getDayEnd(LocalDateTime.now());


                    break;


            }


            query.setStartTime(startTime);


            query.setEndTime(endTime);


            query.setStartTime(DateUtils.localDateTimeToDate(startTime));


            query.setEndTime(DateUtils.localDateTimeToDate(endTime));


        }


        PageInfo<TOrderMealVO> pageInfo = new PageInfo<>(query.getPageNum(),query.getPageSize());


        List<TOrderMealVO> list = this.baseMapper.pageList(query,pageInfo);


@@ -182,12 +191,14 @@


            List<TOrderMealGoods> list1 = orderMealGoodsService.list(Wrappers.lambdaQuery(TOrderMealGoods.class)


                    .eq(TOrderMealGoods::getOrderId, tOrderMealVO.getId()));


            tOrderMealVO.setOrderMealGoods(list1);


            Map<String, List<TOrderMealGoods>> map = list1.stream().collect(Collectors.groupingBy(TOrderMealGoods::getTypeName));


            List<String> goodsList = new ArrayList<>();


            map.forEach((k,v)->{


                goodsList.add(k+":"+v.stream().map(item->item.getGoodsName()+" "+(item.getGoodsSalePrice().multiply(new BigDecimal(item.getGoodsCount())))).collect(Collectors.joining(",")));


            });


            tOrderMealVO.setGoodsList(goodsList);


            if(!CollectionUtils.isEmpty(list1)){


                Map<String, List<TOrderMealGoods>> map = list1.stream().collect(Collectors.groupingBy(TOrderMealGoods::getTypeName));


                List<String> goodsList = new ArrayList<>();


                map.forEach((k,v)->{


                    goodsList.add(k+":"+v.stream().map(item->item.getGoodsName()+" "+(item.getGoodsSalePrice().multiply(new BigDecimal(item.getGoodsCount())))).collect(Collectors.joining(",")));


                });


                tOrderMealVO.setGoodsList(goodsList);


            }


        }


        pageInfo.setRecords(list);


        return pageInfo;


@@ -245,27 +256,27 @@


            switch (query.getTimeType()){


                case 1:


                    // 今日


                    startTime = LocalDateTime.MIN;


                    endTime = LocalDateTime.MAX;


                    startTime = DateUtils.getDayStart(LocalDateTime.now());


                    endTime = DateUtils.getDayEnd(LocalDateTime.now());


                    break;


                case 2:


                    // 昨日


                    startTime = LocalDateTime.now().minusDays(1);


                    endTime = LocalDateTime.now().minusDays(1);


                    startTime = DateUtils.getDayStart(LocalDateTime.now().minusDays(1));


                    endTime = DateUtils.getDayEnd(LocalDateTime.now().minusDays(1));


                    break;


                case 3:


                    // 近7天


                    startTime = LocalDateTime.now().minusDays(7);


                    endTime = LocalDateTime.now();


                    startTime = DateUtils.getDayStart(LocalDateTime.now().minusDays(7));


                    endTime = DateUtils.getDayEnd(LocalDateTime.now());


                    break;


                case 4:


                    // 近30天


                    startTime = LocalDateTime.now().minusDays(30);


                    endTime = LocalDateTime.now();


                    startTime = DateUtils.getDayStart(LocalDateTime.now().minusDays(30));


                    endTime = DateUtils.getDayEnd(LocalDateTime.now());


                    break;


            }


            query.setStartTime(startTime);


            query.setEndTime(endTime);


            query.setStartTime(DateUtils.localDateTimeToDate(startTime));


            query.setEndTime(DateUtils.localDateTimeToDate(endTime));


        }


        List<TOrderMealVO> list = this.baseMapper.exportOrderMeal(query);


        List<Long> ids = list.stream().map(TOrderMealVO::getId).collect(Collectors.toList());


@@ -295,4 +306,107 @@


        return this.baseMapper.personnelStatistics(query);


    }




    @Override


    public PageInfo<TOrderMealVO> pageListGenerator(TDataGeneratorMealQuery query) {


        PageInfo<TOrderMealVO> pageInfo = new PageInfo<>(query.getPageNum(),query.getPageSize());


        List<TOrderMealVO> list = this.baseMapper.pageListGenerator(query,pageInfo);


        // 查询商品信息


        for (TOrderMealVO tOrderMealVO : list) {


            List<TOrderMealGoods> list1 = orderMealGoodsService.list(Wrappers.lambdaQuery(TOrderMealGoods.class)


                    .eq(TOrderMealGoods::getOrderId, tOrderMealVO.getId()));


            tOrderMealVO.setOrderMealGoods(list1);


            Map<String, List<TOrderMealGoods>> map = list1.stream().collect(Collectors.groupingBy(TOrderMealGoods::getTypeName));


            List<String> goodsList = new ArrayList<>();


            map.forEach((k,v)->{


                goodsList.add(k+":"+v.stream().map(item->item.getGoodsName()+" "+(item.getGoodsSalePrice().multiply(new BigDecimal(item.getGoodsCount())))).collect(Collectors.joining(",")));


            });


            tOrderMealVO.setGoodsList(goodsList);


        }


        pageInfo.setRecords(list);


        return pageInfo;


    }




    @Override


    public Map<String, Double> getDataGeneratorMealDetail(TDataGeneratorMealQuery query) {


        return this.baseMapper.getDataGeneratorMealDetail(query);


    }




    @Override


    public List<TOrderMealVO> mealGeneratorExport(TDataGeneratorMealQuery query) {


        List<TOrderMealVO> list = this.baseMapper.mealGeneratorExport(query);


        List<Long> ids = list.stream().map(TOrderMealVO::getId).collect(Collectors.toList());


        List<TOrderMealGoods> list1 = orderMealGoodsService.list(Wrappers.lambdaQuery(TOrderMealGoods.class)


                .in(TOrderMealGoods::getOrderId,ids));


        // 查询商品信息


        for (TOrderMealVO tOrderMealVO : list) {


            List<TOrderMealGoods> collect = list1.stream().filter(e -> e.getOrderId().equals(tOrderMealVO.getId())).collect(Collectors.toList());


            tOrderMealVO.setOrderMealGoods(collect);


            Map<String, List<TOrderMealGoods>> map = collect.stream().collect(Collectors.groupingBy(TOrderMealGoods::getTypeName));


            List<String> goodsList = new ArrayList<>();


            map.forEach((k,v)->{


                goodsList.add(k+":"+v.stream().map(item->item.getGoodsName()+" "+(item.getGoodsSalePrice().multiply(new BigDecimal(item.getGoodsCount())))).collect(Collectors.joining(",")));


            });


            tOrderMealVO.setGoodsList(goodsList);


        }


        return list;


    }




    @Override


    public void startMeal(TOrderMeal dto) {


        // 查询餐桌


        TBoard board = boardService.getById(dto.getBoardId());


        // 开台


        board.setStatus(BoardEnum.WAITING_ORDER.getCode());


        boardService.updateById(board);


        dto.setMealTime(LocalDate.now());


        dto.setOrderNum(OrderNumConstants.MEAL + CodeGenerateUtils.generateVolumeSn());


        this.save(dto);


    }




    @Override


    public List<TDataGeneratorVO> mealGeneratorListExport(TDataGeneratorQuery query) {


        List<TDataGeneratorVO> list = this.baseMapper.mealGeneratorListExport(query);


        List<Long> ids = list.stream().map(TDataGeneratorVO::getId).collect(Collectors.toList());


        if(CollectionUtils.isEmpty(ids)){


            return new ArrayList<>();


        }


        List<TOrderMeal> orderMeals = this.list(Wrappers.lambdaQuery(TOrderMeal.class)


                .in(TOrderMeal::getGeneratorId, ids));


        List<Long> mealIds = orderMeals.stream().map(TOrderMeal::getId).collect(Collectors.toList());


        if(!CollectionUtils.isEmpty(mealIds)){


            List<TOrderMealGoods> mealGoods = orderMealGoodsService.list(Wrappers.lambdaQuery(TOrderMealGoods.class)


                    .in(TOrderMealGoods::getOrderId, mealIds));


            for (TDataGeneratorVO tDataGeneratorVO : list) {


                List<Long> collect = orderMeals.stream().filter(e -> e.getGeneratorId().equals(tDataGeneratorVO.getId())).map(TOrderMeal::getId).collect(Collectors.toList());


                BigDecimal money = mealGoods.stream().filter(e -> collect.contains(e.getOrderId()))


                        .reduce(BigDecimal.ZERO, (x, y) -> x.add(y.getGoodsSalePrice().multiply(new BigDecimal(y.getGoodsCount()))), BigDecimal::add);


                tDataGeneratorVO.setTotalRevenue(money);


            }


        }


        return list;


    }




    @Override


    public ProfitDetailsVO profitDetails(ProfitDetailsQuery query) {




        ProfitDetailsVO profitDetailsVO = new ProfitDetailsVO();


        // 查询商品盈利明细


        PageInfo<GoodsProfitVO> pageInfo = new PageInfo<>(query.getPageNum(),query.getPageSize());


        List<GoodsProfitVO> list = this.baseMapper.profitDetails(query,pageInfo);


        pageInfo.setRecords(list);


        profitDetailsVO.setGoodsProfitVOS(pageInfo);




        // 统计商品金额


        Map<String,BigDecimal> map = this.baseMapper.profitDetailsStatistics(query);


        profitDetailsVO.setTotalProfits(new BigDecimal(map.get("totalProfits").toString()));


        profitDetailsVO.setTotalCosts(new BigDecimal(map.get("totalCosts").toString()));


        profitDetailsVO.setTotalSales(new BigDecimal(map.get("totalSales").toString()));


        return profitDetailsVO;


    }




    @Override


    public List<GoodsProfitVO> profitDetailsExport(ProfitDetailsQuery query) {


        return this.baseMapper.profitDetailsExport(query);


    }




}