From a4497ecba195a1ac4a81fbbd2a541a7f109609de Mon Sep 17 00:00:00 2001
From: liujie <liujie>
Date: 星期五, 04 八月 2023 17:03:34 +0800
Subject: [PATCH] 后台代码 --赛事模块

---
 cloud-server-competition/src/main/java/com/dsh/competition/controller/CompetitionController.java |   83 +++++++++++++++++++++++++----------------
 1 files changed, 50 insertions(+), 33 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 67a007a..4e90260 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
@@ -8,6 +8,8 @@
 import com.dsh.competition.entity.Participant;
 import com.dsh.competition.entity.PaymentCompetition;
 import com.dsh.competition.entity.UserCompetition;
+import com.dsh.competition.feignclient.account.AppUserClient;
+import com.dsh.competition.feignclient.account.model.AppUser;
 import com.dsh.competition.feignclient.model.*;
 import com.dsh.competition.model.CompetitionInfo;
 import com.dsh.competition.model.CompetitionListVo;
@@ -69,6 +71,9 @@
     @Autowired
     private IParticipantService participantService;
 
+    @Autowired
+    private AppUserClient appUserClient;
+
 
     @PostMapping("/base/competition/getPayedCompetitions")
     public List<PaymentCompetition> getAllCompetitionPayRecord(@RequestBody BillingDataRequestVo requestVo){
@@ -98,8 +103,11 @@
 
     @PostMapping("/base/competition/getPlayPaiFGoldPayRecord")
     public List<PaymentCompetition> getPlayPaiFGoldPayRecord(@RequestBody Integer appUserId){
+        ArrayList<Integer> integers = new ArrayList<>();
+        integers.add(1);
+        integers.add(2);
         return paymentCompetitionService.list(new QueryWrapper<PaymentCompetition>()
-                .eq("payType",3)
+                .in("payType",integers)
                 .eq("appUserId",appUserId)
                 .eq("payStatus",3));
     }
@@ -111,24 +119,31 @@
 
         List<PurchaseRecordVo> recordVos = new ArrayList<>();
 
-        List<Competition> list = cttService.list(new QueryWrapper<Competition>()
-                .eq("payType",3 )
-                .eq("auditStatus",2));
-        List<Integer> comIds = list.stream().map(Competition::getId).collect(Collectors.toList());
-        List<UserCompetition> userCompetitions = ucttService.list(new QueryWrapper<UserCompetition>()
-                .between("insertTime", sourseList.getStartTime(),sourseList.getEndTime() )
-                .eq("userId", sourseList.getAppUserId())
-                .in("competitionId",comIds ));
-        if (userCompetitions.size() > 0){
-            userCompetitions.forEach(coms ->{
-                PurchaseRecordVo recordVo = new PurchaseRecordVo();
-                recordVo.setPurchaseType("报名赛事");
-                recordVo.setPurchaseTime(dateFormat.format(coms.getInsertTime()));
-                PaymentCompetition paymentCompetition = paymentCompetitionService.getById(coms.getPaymentCompetitionId());
-                recordVo.setPurchaseAmount("-"+paymentCompetition.getAmount());
-                recordVos.add(recordVo);
-            });
+        ArrayList<Integer> integers = new ArrayList<>();
+        integers.add(1);
+        integers.add(2);
+        List<PaymentCompetition> list = paymentCompetitionService.list(new QueryWrapper<PaymentCompetition>()
+                .in("payType",integers )
+                .eq("appUserId", sourseList.getAppUserId())
+                .eq("state",1));
+        if (list.size() > 0){
+            List<Long> comIds = list.stream().map(PaymentCompetition::getId).collect(Collectors.toList());
+            List<UserCompetition> userCompetitions = ucttService.list(new QueryWrapper<UserCompetition>()
+                    .between("insertTime", sourseList.getStartTime(),sourseList.getEndTime() )
+                    .eq("appUserId", sourseList.getAppUserId())
+                    .in("paymentCompetitionId",comIds ));
+            if (userCompetitions.size() > 0){
+                userCompetitions.forEach(coms ->{
+                    PurchaseRecordVo recordVo = new PurchaseRecordVo();
+                    recordVo.setPurchaseType("报名赛事");
+                    recordVo.setPurchaseTime(dateFormat.format(coms.getInsertTime()));
+                    PaymentCompetition paymentCompetition = paymentCompetitionService.getById(coms.getPaymentCompetitionId());
+                    recordVo.setPurchaseAmount("-"+paymentCompetition.getAmount());
+                    recordVos.add(recordVo);
+                });
+            }
         }
+
         return recordVos;
     }
 
@@ -381,7 +396,7 @@
 
 
     @PostMapping("/base/competition/queryById")
-    public  Competition queryById(Integer id){
+    public  Competition queryById(@RequestBody Integer id){
         try {
             return cttService.getById(id);
         }catch (Exception e){
@@ -410,12 +425,15 @@
                 wrapper.lt(Competition::getEndTime,listQuery.getTime().split(" - ")[1]+" 23:59:59");
             }
             if(ToolUtil.isNotEmpty(listQuery.getState())){
-                wrapper.eq(Competition::getState,listQuery.getState());
+                wrapper.eq(Competition::getStatus,listQuery.getState());
             }
             if(ToolUtil.isNotEmpty(listQuery.getRegisterCondition())){
                 wrapper.eq(Competition::getRegisterCondition,listQuery.getRegisterCondition());
             }
             wrapper.in(Competition::getStoreId,listQuery.getIds());
+            wrapper.eq(Competition::getAuditStatus,2);
+            wrapper.orderByDesc(Competition::getInsertTime);
+
             Page<Competition> page = cttService.page(competitionPage, wrapper);
             return page;
         }catch (Exception e){
@@ -428,6 +446,7 @@
     @PostMapping("/base/competition/add")
     public void add(@RequestBody Competition competition){
         try {
+            competition.setInsertTime(new Date());
             cttService.save(competition);
         }catch (Exception e){
             e.printStackTrace();
@@ -455,19 +474,17 @@
     }
 
 
-//    @PostMapping("/base/competition/getPeopleFromId")
-//    public  Page<Participant> getPeopleFromId(@RequestBody GetPeopleQuery getPeopleQuery){
-//        try {
-//            Page<Participant> participantPage = new Page<>();
-//            LambdaQueryWrapper<Participant> participantLambdaQueryWrapper = new LambdaQueryWrapper<>();
-//            if(getPeopleQuery.getState()!=null){
-//                participantLambdaQueryWrapper.eq(Participant::getState)
-//            }
-//            participantService.page()
-//        }catch (Exception e){
-//            return null;
-//        }
-//    }
+    @PostMapping("/base/competition/getPeopleFromId")
+    public  Page<CompetitionUser> getPeopleFromId(@RequestBody GetPeopleQuery getPeopleQuery){
+        try {
+            Page<UserCompetition> participantPage = new Page<>(getPeopleQuery.getOffset(),getPeopleQuery.getLimit());
+            Page<CompetitionUser> page = participantService.getPeopleFromId(participantPage,getPeopleQuery.getId(),getPeopleQuery.getState());
+            return page;
+        }catch (Exception e){
+            e.printStackTrace();
+            return null;
+        }
+    }
 
 }
 

--
Gitblit v1.7.1