| | |
|---|
| | | 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.TOrderSaleDTO; |
|---|
| | | import com.ruoyi.system.mapper.TOrderSaleMapper; |
|---|
| | | import com.ruoyi.system.query.TDataGeneratorSaleQuery; |
|---|
| | | import com.ruoyi.system.query.TDataStatisticsQuery; |
|---|
| | | import com.ruoyi.system.query.TOrderMealQuery; |
|---|
| | | import com.ruoyi.system.query.TOrderSaleQuery; |
|---|
| | | 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> |
|---|
| | |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private TOrderSaleGoodsService orderSaleGoodsService; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private TGoodsTypeService goodsTypeService; |
|---|
| | | @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); |
|---|
| | | BigDecimal sum1 = orderSaleGoods.stream().map(TOrderSaleGoods::getThisSalePrice).reduce(BigDecimal::add).get(); |
|---|
| | | dto.setPayMoney(sum1); |
|---|
| | | 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 = LocalDateTime.MIN; |
|---|
| | | endTime = LocalDateTime.MAX; |
|---|
| | | break; |
|---|
| | | case 2: |
|---|
| | | // 昨日 |
|---|
| | | startTime = LocalDateTime.now().minusDays(1); |
|---|
| | | endTime = LocalDateTime.now().minusDays(1); |
|---|
| | | break; |
|---|
| | | case 3: |
|---|
| | | // 近7天 |
|---|
| | | startTime = LocalDateTime.now().minusDays(7); |
|---|
| | | endTime = LocalDateTime.now(); |
|---|
| | | break; |
|---|
| | | case 4: |
|---|
| | | // 近30天 |
|---|
| | | startTime = LocalDateTime.now().minusDays(30); |
|---|
| | | endTime = LocalDateTime.now(); |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | query.setStartTime(startTime); |
|---|
| | | query.setEndTime(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 = LocalDateTime.MIN; |
|---|
| | | endTime = LocalDateTime.MAX; |
|---|
| | | break; |
|---|
| | | case 2: |
|---|
| | | // 昨日 |
|---|
| | | startTime = LocalDateTime.now().minusDays(1); |
|---|
| | | endTime = LocalDateTime.now().minusDays(1); |
|---|
| | | break; |
|---|
| | | case 3: |
|---|
| | | // 近7天 |
|---|
| | | startTime = LocalDateTime.now().minusDays(7); |
|---|
| | | endTime = LocalDateTime.now(); |
|---|
| | | break; |
|---|
| | | case 4: |
|---|
| | | // 近30天 |
|---|
| | | startTime = LocalDateTime.now().minusDays(30); |
|---|
| | | endTime = LocalDateTime.now(); |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | query.setStartTime(startTime); |
|---|
| | | query.setEndTime(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, BigDecimal> getDataGeneratorMealDetail(TDataGeneratorSaleQuery query) { |
|---|
| | | return this.baseMapper.getDataGeneratorMealDetail(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 = LocalDateTime.MIN; |
|---|
| | | endTime = LocalDateTime.MAX; |
|---|
| | | break; |
|---|
| | | case 2: |
|---|
| | | // 昨日 |
|---|
| | | startTime = LocalDateTime.now().minusDays(1); |
|---|
| | | endTime = LocalDateTime.now().minusDays(1); |
|---|
| | | break; |
|---|
| | | case 3: |
|---|
| | | // 近7天 |
|---|
| | | startTime = LocalDateTime.now().minusDays(7); |
|---|
| | | endTime = LocalDateTime.now(); |
|---|
| | | break; |
|---|
| | | case 4: |
|---|
| | | // 近30天 |
|---|
| | | startTime = LocalDateTime.now().minusDays(30); |
|---|
| | | endTime = LocalDateTime.now(); |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | query.setStartTime(startTime); |
|---|
| | | query.setEndTime(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; |
|---|
| | | } |
|---|
| | | } |
|---|
