| | |
| | | // 获取到赛事id集合 去重 |
| | | List<Integer> collect = comIds.stream().distinct().collect(Collectors.toList()); |
| | | // 根据赛事id 查询赛事支付记录 获取用户ids |
| | | if (collect.size() == 0) { |
| | | if (collect.isEmpty()) { |
| | | return new ArrayList<>(); |
| | | } else { |
| | | List<Integer> userIds = paymentCompetitionService.list(new QueryWrapper<PaymentCompetition>() |
| | | .in("competitionId", collect)).stream() |
| | | .in("competitionId", collect) |
| | | .eq("payStatus",2)).stream() |
| | | .map(PaymentCompetition::getAppUserId).collect(Collectors.toList()); |
| | | return userIds; |
| | | } |
| | |
| | | List<Integer> operatorId = cttService.list(new QueryWrapper<Competition>() |
| | | .eq("operatorId", operatorId1)).stream().map(Competition::getId).collect(Collectors.toList()); |
| | | query.setUserIds(operatorId); |
| | | } else if (query.getStoreId() != null) { |
| | | List<Competition> list = cttService.list(new QueryWrapper<Competition>()); |
| | | List<Integer> integers = new ArrayList<>(); |
| | | for (Competition competition : list) { |
| | | for (String s : competition.getStoreId().split(",")) { |
| | | if (s.equals(""+query.getStoreId())){ |
| | | integers.add(competition.getId()); |
| | | } |
| | | } |
| | | } |
| | | if (integers.isEmpty()){ |
| | | integers.add(-1); |
| | | } |
| | | query.setUserIds(integers); |
| | | } |
| | | List<PaymentCompetition> paymentCompetitions = paymentCompetitionService.listAll(query); |
| | | List<PaymentCompetition> result = new ArrayList<>(); |