From 640ff18d2d7f4be02ddb7f8f75e899f05545eb98 Mon Sep 17 00:00:00 2001 From: puzhibing <393733352@qq.com> Date: 星期一, 05 二月 2024 11:56:52 +0800 Subject: [PATCH] 更新bug修改 --- cloud-server-competition/src/main/java/com/dsh/competition/controller/CompetitionController.java | 97 +++++++++++++++++++++++++++++++++--------------- 1 files changed, 67 insertions(+), 30 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 74a0dd4..01fbc2a 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 @@ -12,7 +12,9 @@ import com.dsh.competition.entity.UserCompetition; import com.dsh.competition.feignclient.account.AppUserClient; import com.dsh.competition.feignclient.account.StudentClient; +import com.dsh.competition.feignclient.account.StudentHonorClient; import com.dsh.competition.feignclient.account.model.AppUser; +import com.dsh.competition.feignclient.account.model.StudentHonor; import com.dsh.competition.feignclient.account.model.TStudent; import com.dsh.competition.feignclient.course.CoursePackagePaymentClient; import com.dsh.competition.feignclient.course.model.PaymentDeductionClassHour; @@ -81,6 +83,12 @@ @Autowired private AppUserClient appUserClient; + + @Resource + private StudentHonorClient studentHonorClient; + + + /** * 根据门店ids 获取对应的赛事 根据赛事支付记录获取用户ids @@ -352,13 +360,10 @@ @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public synchronized ResultUtil paymentCompetition(PaymentCompetitionVo paymentCompetitionVo) { try { Competition byId = competitionService.getById(paymentCompetitionVo.getId()); Date date = byId.getEndTime(); - // Assuming you have a Date object - // Check if the date is past the current time boolean isPast = date.after(new Date()); if (!isPast) { return new ResultUtil(0, "已超过截至报名时间"); @@ -695,9 +700,27 @@ } else { competition.setStatus(3); } + + if(competition.getStatus() == 2){ + //添加勋章数据 + List<PaymentCompetition> list = paymentCompetitionService.list(new QueryWrapper<PaymentCompetition>() + .eq("competitionId", competition.getId()).eq("payStatus", 2).eq("state", 1)); + Set<Integer> collect = list.stream().map(PaymentCompetition::getAppUserId).collect(Collectors.toSet()); + for (Integer integer : collect) { + int count = paymentCompetitionService.count(new QueryWrapper<PaymentCompetition>() + .eq("appUserId", integer).eq("payStatus", 2).eq("state", 1)); + StudentHonor studentHonor = new StudentHonor(); + studentHonor.setAppUserId(integer); + studentHonor.setHonorType(2); + studentHonor.setNumber(count); + studentHonorClient.saveStudentHonor(studentHonor); + } + } } competition.setInsertTime(new Date()); cttService.save(competition); + + } catch (Exception e) { e.printStackTrace(); } @@ -715,8 +738,26 @@ } else { competition.setStatus(3); } + + if(competition.getStatus() == 2){ + //添加勋章数据 + List<PaymentCompetition> list = paymentCompetitionService.list(new QueryWrapper<PaymentCompetition>() + .eq("competitionId", competition.getId()).eq("payStatus", 2).eq("state", 1)); + Set<Integer> collect = list.stream().map(PaymentCompetition::getAppUserId).collect(Collectors.toSet()); + for (Integer integer : collect) { + int count = paymentCompetitionService.count(new QueryWrapper<PaymentCompetition>() + .eq("appUserId", integer).eq("payStatus", 2).eq("state", 1)); + StudentHonor studentHonor = new StudentHonor(); + studentHonor.setAppUserId(integer); + studentHonor.setHonorType(2); + studentHonor.setNumber(count); + studentHonorClient.saveStudentHonor(studentHonor); + } + } } cttService.updateById(competition); + + } catch (Exception e) { e.printStackTrace(); } @@ -755,9 +796,7 @@ String refund_id = map.get("refund_id"); paymentCompetition.setRefundOrderNo(refund_id); paymentCompetitionService.updateById(paymentCompetition); - storeClient.addBackRecord(paymentCompetition.getAmount() + "_" + paymentCompetition.getAppUserId()); - } if (paymentCompetition.getPayType() == 2) {//支付宝支付 @@ -837,30 +876,9 @@ @Resource private StudentClient studentClient; @PostMapping("/base/competition/getPeopleFromId1") - public List<CompetitionUser> getPeopleFromId1(@RequestBody GetPeopleQuery getPeopleQuery) { + public Page<CompetitionUser> getPeopleFromId1(@RequestBody GetPeopleQuery getPeopleQuery) { try { - Page<UserCompetition> participantPage = new Page<>(getPeopleQuery.getOffset(), getPeopleQuery.getLimit()); - List<CompetitionUser> page = participantService.getPeopleFromId1(participantPage, getPeopleQuery.getId(), getPeopleQuery.getState()); - - List<CompetitionUser> users = new ArrayList<>(); - List<UserCompetition> coms = userCompetitionService.list(new QueryWrapper<UserCompetition>().eq("competitionId", getPeopleQuery.getId())); - for (UserCompetition com : coms) { - int number = com.getParticipantId(); - String numberString = Integer.toString(number); - int digitCount = numberString.length(); - if (digitCount!=9){ - TStudent tStudent = studentClient.queryById(number); - CompetitionUser competitionUser = new CompetitionUser(); - competitionUser.setName(tStudent.getName()); - competitionUser.setPhone(tStudent.getPhone()); - competitionUser.setSex(tStudent.getSex()); - competitionUser.setIdCard(tStudent.getIdCard()); - competitionUser.setState(tStudent.getState()); - users.add(competitionUser); - } - } - page.addAll(users); - + Page<CompetitionUser> page = participantService.getPeopleFromId1(getPeopleQuery.getOffset(), getPeopleQuery.getLimit(), getPeopleQuery.getId(), getPeopleQuery.getState()); return page; } catch (Exception e) { e.printStackTrace(); @@ -884,14 +902,21 @@ List<Integer> ids = queryDataFee.getIds(); if (ids.size() == 0) { ids.add(-1); + }else{ + List<Competition> list1 = competitionService.list(new QueryWrapper<Competition>().in("storeId", ids).eq("auditStatus", 2).eq("state", 1).ne("status", 4)); + ids = list1.stream().map(Competition::getId).collect(Collectors.toList()); + if (ids.size() == 0) { + ids.add(-1); + } } + LambdaQueryWrapper<PaymentCompetition> vipPaymentLambdaQueryWrapper = new LambdaQueryWrapper<>(); if (ToolUtil.isNotEmpty(data)) { String stime = data.split(" - ")[0] + " 00:00:00"; String etime = data.split(" - ")[1] + " 23:59:59"; vipPaymentLambdaQueryWrapper.between(PaymentCompetition::getInsertTime, stime, etime); } - vipPaymentLambdaQueryWrapper.in(PaymentCompetition::getAppUserId, ids); + vipPaymentLambdaQueryWrapper.in(PaymentCompetition::getCompetitionId, ids); vipPaymentLambdaQueryWrapper.eq(PaymentCompetition::getPayStatus, 2); ArrayList<Integer> objects = new ArrayList<>(); objects.add(1); @@ -995,7 +1020,7 @@ m = "0" + i; } String s = year + "-" + m; - int count = cttService.count(new LambdaQueryWrapper<Competition>().like(Competition::getInsertTime, s).ne(Competition::getOperatorId, operatorId)); + 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)); months.add(count); monthsUser.add(count1); @@ -1006,5 +1031,17 @@ return map; } + + @ResponseBody + @PostMapping("/base/competition/queryAppUserId") + public List<Integer> queryAppUserId(@RequestBody List<Integer> storeIds){ + List<Competition> list = competitionService.list(new QueryWrapper<Competition>().in("storeId", storeIds).eq("auditStatus", 2).eq("state", 1)); + List<Integer> collect = list.stream().map(Competition::getId).collect(Collectors.toList()); + if(collect.size() == 0){ + return new ArrayList<>(); + } + List<PaymentCompetition> list1 = paymentCompetitionService.list(new QueryWrapper<PaymentCompetition>().eq("payStatus", 2).eq("state", 1).in("competitionId", collect)); + return list1.stream().map(PaymentCompetition::getAppUserId).collect(Collectors.toList()); + } } -- Gitblit v1.7.1