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


@@ -1,18 +1,33 @@


package com.ruoyi.system.service.impl;




import com.baomidou.mybatisplus.core.toolkit.Wrappers;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.ruoyi.common.basic.PageInfo;


import com.ruoyi.common.constant.OrderNumConstants;


import com.ruoyi.common.utils.CodeGenerateUtils;


import com.ruoyi.system.domain.TOrderSale;


import com.ruoyi.system.domain.TOrderSaleGoods;


import com.ruoyi.common.utils.DateUtils;


import com.ruoyi.system.domain.*;


import com.ruoyi.system.dto.CheckoutDTO;


import com.ruoyi.system.dto.TOrderSaleDTO;


import com.ruoyi.system.mapper.TOrderSaleMapper;


import com.ruoyi.system.query.*;


import com.ruoyi.system.service.TGoodsService;


import com.ruoyi.system.service.TGoodsTypeService;


import com.ruoyi.system.service.TOrderSaleGoodsService;


import com.ruoyi.system.service.TOrderSaleService;


import com.ruoyi.system.vo.*;


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


import org.springframework.stereotype.Service;


import org.springframework.util.CollectionUtils;




import java.math.BigDecimal;


import java.time.LocalDate;


import java.time.LocalDateTime;


import java.util.ArrayList;


import java.util.List;


import java.util.Map;


import java.util.Objects;


import java.util.stream.Collectors;




/**


 * <p>


@@ -27,18 +42,256 @@




    @Autowired


    private TOrderSaleGoodsService orderSaleGoodsService;




    @Autowired


    private TGoodsTypeService goodsTypeService;


    @Autowired


    private TGoodsService goodsService;


    @Override


    public void add(TOrderSaleDTO dto) {


        // 查询菜品分类


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


        // 销售单号


        dto.setOrderNum("XS" + CodeGenerateUtils.generateOrderSn());


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


        List<TOrderSaleGoods> orderSaleGoods = dto.getOrderSaleGoods();


        BigDecimal sum = orderSaleGoods.stream().map(TOrderSaleGoods::getGoodsSalePrice).reduce(BigDecimal::add).get();


        dto.setOrderMoney(sum);


        dto.setPayMoney(sum);


        this.save(dto);


        // 添加商品


        orderSaleGoods.forEach(orderSaleGoods1 -> orderSaleGoods1.setOrderId(dto.getId()));


        orderSaleGoods.forEach(orderSaleGoods1 -> {


            orderSaleGoods1.setOrderId(dto.getId());


            orderSaleGoods1.setId(null);


        });


        orderSaleGoodsService.saveBatch(orderSaleGoods);


    }




    @Override


    public PageInfo<TOrderSaleVO> pageList(TOrderSaleQuery query) {


        if(Objects.nonNull(query.getTimeType())){


            LocalDateTime startTime = null;


            LocalDateTime endTime = null;


            switch (query.getTimeType()){


                case 1:


                    // 今日


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


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


                    break;


                case 2:


                    // 昨日


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


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


                    break;


                case 3:


                    // 近7天


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


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


                    break;


                case 4:


                    // 近30天


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


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


                    break;


            }


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


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


        }


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


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


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


        if(!CollectionUtils.isEmpty(ids)){


            List<TOrderSaleGoods> list1 = orderSaleGoodsService.list(Wrappers.lambdaQuery(TOrderSaleGoods.class)


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


            list.forEach(e->{


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


                if(!CollectionUtils.isEmpty(collect)){


                    e.setGoodsAmount(collect.stream().map(TOrderSaleGoods::getGoodsSalePrice).reduce(BigDecimal::add).get());


                    e.setOrderSaleGoods(collect);


                }


            });


        }


        pageInfo.setRecords(list);


        return pageInfo;


    }




    @Override


    public AmountSumVO amountSum(TOrderMealQuery query) {


        return this.baseMapper.amountSum(query);


    }




    @Override


    public SalesVolumeVO salesVolume(TDataStatisticsQuery query) {


        SalesVolumeVO salesVolumeVO = this.baseMapper.salesVolume(query);


        salesVolumeVO.setSalesVolumeTotal(salesVolumeVO.getWeiXinPay().add(salesVolumeVO.getOtherPay()).add(salesVolumeVO.getCardPay())


                .add(salesVolumeVO.getMoneyPay()).add(salesVolumeVO.getAliPay()));


        // 查询成本


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


                .eq(TOrderSale::getShopId, query.getShopId()));


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


        if(!CollectionUtils.isEmpty(ids)){


            BigDecimal costTotal = orderSaleGoodsService.costTotal(ids);


            salesVolumeVO.setCostTotal(costTotal);


            salesVolumeVO.setProfitTotal(salesVolumeVO.getSalesVolumeTotal().subtract(costTotal));


        }


        return salesVolumeVO;


    }




    @Override


    public List<SalesRankingVO> salesRanking(TDataStatisticsQuery query) {


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


                .eq(TOrderSale::getShopId, query.getShopId())


                .between(TOrderSale::getOrderTime, query.getStartTime(), query.getEndTime()));


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


        List<SalesRankingVO> salesRankingVOS = new ArrayList<>();


        if(!CollectionUtils.isEmpty(ids)){


            List<TOrderSaleGoods> list1 = orderSaleGoodsService.list(Wrappers.lambdaQuery(TOrderSaleGoods.class)


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


            Map<Long, List<TOrderSaleGoods>> listMap = list1.stream().collect(Collectors.groupingBy(TOrderSaleGoods::getTypeId));


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


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


                SalesRankingVO salesRankingVO = new SalesRankingVO();


                salesRankingVO.setTypeName(list2.stream().filter(e->e.getId().equals(k)).findFirst().get().getTypeName());


                salesRankingVO.setSalesVolume(v.stream().map(item->item.getGoodsSalePrice().multiply(new BigDecimal(item.getGoodsCount()))).reduce(BigDecimal.ZERO, BigDecimal::add));


                salesRankingVOS.add(salesRankingVO);


            });


        }


        return salesRankingVOS;


    }




    @Override


    public List<TOrderSaleVO> exportOrderSale(TOrderMealQuery query) {


        if(Objects.nonNull(query.getTimeType())){


            LocalDateTime startTime = null;


            LocalDateTime endTime = null;


            switch (query.getTimeType()){


                case 1:


                    // 今日


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


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


                    break;


                case 2:


                    // 昨日


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


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


                    break;


                case 3:


                    // 近7天


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


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


                    break;


                case 4:


                    // 近30天


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


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


                    break;


            }


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


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


        }


        List<TOrderSaleVO> list = this.baseMapper.exportOrderSale(query);


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


        List<TOrderSaleGoods> list1 = orderSaleGoodsService.list(Wrappers.lambdaQuery(TOrderSaleGoods.class)


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


        // 查询商品信息


        for (TOrderSaleVO orderSaleVO : list) {


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


            orderSaleVO.setOrderSaleGoods(collect);


        }


        return list;


    }




    @Override


    public List<OrderTrendsVO> orderingTrends(TDataStatisticsQuery query) {


        return this.baseMapper.orderingTrends(query);


    }




    @Override


    public Map<String, Double> getDataGeneratorSaleDetail(TDataGeneratorSaleQuery query) {


        return this.baseMapper.getDataGeneratorSaleDetail(query);


    }




    @Override


    public List<TOrderSaleVO> saleGeneratorExport(TDataGeneratorSaleQuery query) {


        if(Objects.nonNull(query.getTimeType())){


            LocalDateTime startTime = null;


            LocalDateTime endTime = null;


            switch (query.getTimeType()){


                case 1:


                    // 今日


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


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


                    break;


                case 2:


                    // 昨日


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


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


                    break;


                case 3:


                    // 近7天


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


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


                    break;


                case 4:


                    // 近30天


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


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


                    break;


            }


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


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


        }


        List<TOrderSaleVO> list = this.baseMapper.saleGeneratorExport(query);


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


        List<TOrderSaleGoods> list1 = orderSaleGoodsService.list(Wrappers.lambdaQuery(TOrderSaleGoods.class)


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


        // 查询商品信息


        for (TOrderSaleVO orderSaleVO : list) {


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


            orderSaleVO.setOrderSaleGoods(collect);


        }


        return list;


    }




    @Override


    public void checkout(CheckoutDTO dto) {


        TOrderSale orderSale = this.getById(dto.getOrderId());


        orderSale.setPayType(dto.getPayType());


        orderSale.setPayMoney(dto.getPayMoney());


        orderSale.setStatus(2);


        this.updateById(orderSale);


    }




    @Override


    public void edit(TOrderSaleDTO dto) {


        // 销售单号


        List<TOrderSaleGoods> orderSaleGoods = dto.getOrderSaleGoods();


        BigDecimal sum = orderSaleGoods.stream().map(TOrderSaleGoods::getGoodsSalePrice).reduce(BigDecimal::add).get();


        dto.setOrderMoney(sum);


        this.updateById(dto);


        // 删除商品


        orderSaleGoodsService.remove(Wrappers.lambdaQuery(TOrderSaleGoods.class)


                .eq(TOrderSaleGoods::getOrderId,dto.getId()));


        // 添加商品


        orderSaleGoods.forEach(orderSaleGoods1 -> {


            orderSaleGoods1.setOrderId(dto.getId());


            orderSaleGoods1.setId(null);


        });


        orderSaleGoodsService.saveBatch(orderSaleGoods);


    }




    @Override


    public List<TDataGeneratorVO> saleGeneratorListExport(TDataGeneratorQuery query) {


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


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


        if(CollectionUtils.isEmpty(ids)){


            return new ArrayList<>();


        }


        List<TOrderSale> orderSales = this.list(Wrappers.lambdaQuery(TOrderSale.class)


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


        for (TDataGeneratorVO tDataGeneratorVO : list) {


            if(!CollectionUtils.isEmpty(orderSales)){


                BigDecimal money = orderSales.stream().map(TOrderSale::getPayMoney).reduce(BigDecimal::add).get();


                tDataGeneratorVO.setTotalRevenue(money);


            }


        }


        return list;


    }


}