java/PlayPai.git

			@@ -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;
			@@ -82,6 +84,12 @@
			@Autowired
			private AppUserClient appUserClient;

			@Resource
			private StudentHonorClient studentHonorClient;




			/**
			* 根据门店ids 获取对应的赛事根据赛事支付记录获取用户ids
			*/
			@@ -102,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;
			}
			@@ -125,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<>();
			@@ -352,13 +375,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, "已超过截至报名时间");
			@@ -565,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);
			@@ -576,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();
			@@ -695,9 +717,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 +755,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();
			}
			@@ -746,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"));
			@@ -754,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());