From 055bb95f76e7e15cb1cbd5f9b7fe79b41eb30e5e Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期四, 02 七月 2026 19:04:32 +0800
Subject: [PATCH] update

---
 cloud-server-competition/src/main/java/com/dsh/competition/controller/CompetitionController.java |   58 +++++++++++++++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 51 insertions(+), 7 deletions(-)

diff --git a/cloud-server-competition/src/main/java/com/dsh/competition/controller/CompetitionController.java b/cloud-server-competition/src/main/java/com/dsh/competition/controller/CompetitionController.java
index 208c8bc..694add2 100644
--- a/cloud-server-competition/src/main/java/com/dsh/competition/controller/CompetitionController.java
+++ b/cloud-server-competition/src/main/java/com/dsh/competition/controller/CompetitionController.java
@@ -1142,13 +1142,11 @@
         // 年
         ArrayList<Integer> years = new ArrayList<>();
         ArrayList<Integer> yearsUser = new ArrayList<>();
-        Integer operatorId = vo.getOperatorId();
-        List<Integer> operatorId1 = cttService.list(new QueryWrapper<Competition>().eq("operatorId", operatorId))
-                .stream().map(Competition::getId).collect(Collectors.toList());
         for (Object o : collect) {
             String s = o.toString();
-            int count = cttService.count(new LambdaQueryWrapper<Competition>().like(Competition::getInsertTime, s).eq(Competition::getOperatorId, vo.getOperatorId()));
-            int count1 = ucttService.count(new LambdaQueryWrapper<UserCompetition>().in(UserCompetition::getAppUserId, vo.getIds()).like(UserCompetition::getInsertTime, s));
+            List<Integer> competitionIds = listCompetitionIds(vo, s);
+            int count = competitionIds.size();
+            int count1 = countUserCompetitions(vo, s, competitionIds);
             years.add(count);
             yearsUser.add(count1);
         }
@@ -1166,8 +1164,9 @@
                 m = "0" + i;
             }
             String s = year + "-" + m;
-            int count = cttService.count(new LambdaQueryWrapper<Competition>().like(Competition::getInsertTime, s).eq(Competition::getOperatorId, operatorId));
-            int count1 = ucttService.count(new LambdaQueryWrapper<UserCompetition>().in(UserCompetition::getAppUserId, vo.getIds()).like(UserCompetition::getInsertTime, s));
+            List<Integer> competitionIds = listCompetitionIds(vo, s);
+            int count = competitionIds.size();
+            int count1 = countUserCompetitions(vo, s, competitionIds);
             months.add(count);
             monthsUser.add(count1);
         }
@@ -1177,6 +1176,51 @@
         return map;
     }
 
+    private List<Integer> listCompetitionIds(CompetionVO vo, String dateText) {
+        return cttService.list(buildCompetitionCountWrapper(vo, dateText))
+                .stream()
+                .map(Competition::getId)
+                .collect(Collectors.toList());
+    }
+
+    private int countUserCompetitions(CompetionVO vo, String dateText, List<Integer> competitionIds) {
+        if (competitionIds.isEmpty()) {
+            return 0;
+        }
+        return ucttService.count(new LambdaQueryWrapper<UserCompetition>()
+                .in(UserCompetition::getAppUserId, vo.getIds())
+                .in(UserCompetition::getCompetitionId, competitionIds)
+                .like(UserCompetition::getInsertTime, dateText));
+    }
+
+    private LambdaQueryWrapper<Competition> buildCompetitionCountWrapper(CompetionVO vo, String dateText) {
+        LambdaQueryWrapper<Competition> wrapper = new LambdaQueryWrapper<Competition>()
+                .like(Competition::getInsertTime, dateText)
+                .eq(Competition::getOperatorId, vo.getOperatorId());
+        appendStoreIdFilter(wrapper, vo.getStoreIds());
+        return wrapper;
+    }
+
+    private void appendStoreIdFilter(LambdaQueryWrapper<Competition> wrapper, List<Integer> storeIds) {
+        if (storeIds == null || storeIds.isEmpty()) {
+            return;
+        }
+
+        List<Integer> validStoreIds = storeIds.stream()
+                .filter(Objects::nonNull)
+                .collect(Collectors.toList());
+        if (validStoreIds.isEmpty()) {
+            return;
+        }
+
+        wrapper.and(item -> {
+            item.apply("FIND_IN_SET({0}, storeId)", validStoreIds.get(0));
+            for (int i = 1; i < validStoreIds.size(); i++) {
+                item.or().apply("FIND_IN_SET({0}, storeId)", validStoreIds.get(i));
+            }
+        });
+    }
+
 
     @ResponseBody
     @PostMapping("/base/competition/queryAppUserId")

--
Gitblit v1.7.1