From f7e51fc7c91e474e5c0bcc79c47f074c0a59b5c3 Mon Sep 17 00:00:00 2001
From: 44323 <443237572@qq.com>
Date: 星期三, 11 十月 2023 20:03:35 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 cloud-server-management/src/main/java/com/dsh/guns/modular/system/controller/code/DataStatisticsController.java |   60 ++++++++++++++++++++++++++++++++++++++----------------------
 1 files changed, 38 insertions(+), 22 deletions(-)

diff --git a/cloud-server-management/src/main/java/com/dsh/guns/modular/system/controller/code/DataStatisticsController.java b/cloud-server-management/src/main/java/com/dsh/guns/modular/system/controller/code/DataStatisticsController.java
index b6122b6..7b8c8e3 100644
--- a/cloud-server-management/src/main/java/com/dsh/guns/modular/system/controller/code/DataStatisticsController.java
+++ b/cloud-server-management/src/main/java/com/dsh/guns/modular/system/controller/code/DataStatisticsController.java
@@ -115,28 +115,40 @@
     public Object getIncomeData(Integer operatorId,Integer storeId) {
         // 报名课程查询query
         RegisterOrderQuery query = new RegisterOrderQuery();
-
-        // 根据运营商ID 查询运营商下的所有门店
-        if (operatorId!=null){
-            List<TStore> stores = storeService.list(new QueryWrapper<TStore>().eq("operatorId", operatorId));
-            // 拿到该运营商下的门店id集合
-            List<Integer> storeIds = stores.stream().map(TStore::getId).collect(Collectors.toList());
-            query.setStoresIds(storeIds);
-        }
-
-        // 充值记录查询query
+    // 充值记录查询query
         RechargeRecordsQuery rechargeRecordsQuery = new RechargeRecordsQuery();
         // 赛事活动查询query
         CompetitionQuery competitionQuery = new CompetitionQuery();
+
         // 会员支付查询query
         IncomeQuery incomeQuery = new IncomeQuery();
         // 场地预约记录查询query
         SiteBookingQuery siteBookingQuery = new SiteBookingQuery();
+        // 筛选运营商的是时候使用
+        List<Integer> storeIds = new ArrayList<>();
+        // 根据运营商ID 查询运营商下的所有门店
+        if (storeId==null){
+            if (operatorId!=null){
+                List<TStore> stores = storeService.list(new QueryWrapper<TStore>().eq("operatorId", operatorId));
+                // 拿到该运营商下的门店id集合
+                storeIds = stores.stream().map(TStore::getId).collect(Collectors.toList());
+                query.setStoresIds(storeIds);
+                siteBookingQuery.setStoreIds(storeIds);
+                competitionQuery.setOperatorId(operatorId);
+            }
+        }else {
+            List<Integer> list = new ArrayList<>();
+            list.add(storeId);
+            query.setStoresIds(list);
+            siteBookingQuery.setStoreIds(list);
+            competitionQuery.setStoreId(storeId);
+        }
+
+
         Integer roleType = UserExt.getUser().getObjectType();
         rechargeRecordsQuery.setInsertType(roleType);
                        query.setInsertType(roleType);
             competitionQuery.setInsertType(roleType);
-                 incomeQuery.setInsertType(roleType);
                  incomeQuery.setInsertType(roleType);
         List<IncomeVO> incomeVOS = new ArrayList<>();
         // 会员支付记录
@@ -193,22 +205,26 @@
             if (competition.getAmount() != null) {
                 temp.setAmount(new BigDecimal(competition.getAmount().toString()));
             }
-
             incomeVOS.add(temp);
         }
         // 预约场地
-        List<SiteBooking> siteBookings = siteClient.listAll(siteBookingQuery);
-        for (SiteBooking siteBooking : siteBookings) {
-            IncomeVO temp = new IncomeVO();
-            if(siteBooking.getStatus()!=3){
-                continue;
+        // 说明当前运营商下没有门店
+        if (operatorId!=null && storeIds.size()==0){
+        }else{
+            List<SiteBooking> siteBookings = siteClient.listAll(siteBookingQuery);
+            for (SiteBooking siteBooking : siteBookings) {
+                IncomeVO temp = new IncomeVO();
+                if(siteBooking.getStatus()!=3){
+                    continue;
+                }
+                temp.setInsertTime(siteBooking.getPayTime());
+                if (siteBooking.getPayMoney() != null) {
+                    temp.setAmount(new BigDecimal(siteBooking.getPayMoney().toString()));
+                }
+                incomeVOS.add(temp);
             }
-            temp.setInsertTime(siteBooking.getPayTime());
-            if (siteBooking.getPayMoney() != null) {
-                temp.setAmount(new BigDecimal(siteBooking.getPayMoney().toString()));
-            }
-            incomeVOS.add(temp);
         }
+
         // 积分商品
         List<PointMerchandiseIncomeVo> amount = pointMercharsClient.getAmount();
         for (PointMerchandiseIncomeVo pointMerchandiseIncomeVo : amount) {

--
Gitblit v1.7.1