From 9ca97fd558700e7054c5f54192a9db7a1e6b8230 Mon Sep 17 00:00:00 2001
From: xuhy <3313886187@qq.com>
Date: 星期三, 11 九月 2024 16:31:47 +0800
Subject: [PATCH] 完善导出等接口

---
 ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TOrderSaleServiceImpl.java |  264 +++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 258 insertions(+), 6 deletions(-)

diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TOrderSaleServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TOrderSaleServiceImpl.java
index ce3a1b9..62f8b4b 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TOrderSaleServiceImpl.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TOrderSaleServiceImpl.java
@@ -1,19 +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>
@@ -28,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(OrderNumConstants.SALE + 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;
+    }
 }

--
Gitblit v1.7.1