From b23b243473fc9ab20ca62eebf3668c143e2e7d23 Mon Sep 17 00:00:00 2001
From: 无关风月 <443237572@qq.com>
Date: 星期三, 24 七月 2024 15:30:53 +0800
Subject: [PATCH] Merge branch '2.0' of http://120.76.84.145:10101/gitblit/r/java/PlayPai into 2.0

---
 cloud-server-competition/src/main/java/com/dsh/competition/controller/CompetitionController.java |   37 ++++++++++++++++++++++++++++---------
 1 files changed, 28 insertions(+), 9 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 01fbc2a..82f7bde 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
@@ -110,11 +110,12 @@
         // 获取到赛事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;
         }
@@ -133,6 +134,20 @@
             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<>();
@@ -570,8 +585,9 @@
                 String code = map.get("out_refund_no");
                 String refund_id = map.get("refund_id");
                 String result = map.get("result");
-                PaymentCompetition paymentCompetition = paymentCompetitionService.getOne(new QueryWrapper<PaymentCompetition>().eq("code", code).eq("payType", 1));
-                if (paymentCompetition.getPayStatus() == 1) {
+                PaymentCompetition paymentCompetition = paymentCompetitionService.getOne(new QueryWrapper<PaymentCompetition>()
+                        .eq("code", code).eq("payType", 1));
+                if (paymentCompetition.getPayStatus() == 2) {
                     paymentCompetition.setPayStatus(3);
                     paymentCompetition.setRefundTime(new Date());
                     paymentCompetition.setRefundOrderNo(refund_id);
@@ -581,11 +597,12 @@
                     Competition competition = cttService.getById(paymentCompetition.getCompetitionId());
                     competition.setApplicantsNumber(competition.getApplicantsNumber() - 1);
                     cttService.updateById(competition);
+
+                    PrintWriter out = response.getWriter();
+                    out.write(result);
+                    out.flush();
+                    out.close();
                 }
-                PrintWriter out = response.getWriter();
-                out.write(result);
-                out.flush();
-                out.close();
             }
         } catch (Exception e) {
             e.printStackTrace();
@@ -787,7 +804,8 @@
 
                 String payOrderNo = paymentCompetition.getPayOrderNo();
                 if (paymentCompetition.getPayType() == 1) {//微信支付
-                    Map<String, String> map = payMoneyUtil.wxRefund(payOrderNo, code, amount.toString(), amount.toString(), "/base/competition/weChatCancelPaymentCompetitionCallback");
+                    Map<String, String> map = payMoneyUtil.wxRefund(payOrderNo, code, amount.toString(), amount.toString(),
+                            "/base/competition/weChatCancelPaymentCompetitionCallback");
                     String return_code = map.get("return_code");
                     if (!"SUCCESS".equals(return_code)) {
 //                        return ResultUtil.error(map.get("return_msg"));
@@ -795,6 +813,7 @@
                     }
                     String refund_id = map.get("refund_id");
                     paymentCompetition.setRefundOrderNo(refund_id);
+                    paymentCompetition.setAppUserId(null);
                     paymentCompetitionService.updateById(paymentCompetition);
                     storeClient.addBackRecord(paymentCompetition.getAmount() + "_" + paymentCompetition.getAppUserId());
 

--
Gitblit v1.7.1