From cad9305c4cbffe978370f4c39bfde63b248619c7 Mon Sep 17 00:00:00 2001
From: nickchange <126672920+nickchange@users.noreply.github.com>
Date: 星期六, 25 十一月 2023 10:05:28 +0800
Subject: [PATCH] 11.25
---
cloud-server-competition/src/main/java/com/dsh/competition/controller/CompetitionController.java | 126 +++++++++++++++++++++++++++++++++++++++++
1 files changed, 125 insertions(+), 1 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 0dcb55c..71b3fc3 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
@@ -13,7 +13,9 @@
import com.dsh.competition.feignclient.account.AppUserClient;
import com.dsh.competition.feignclient.account.model.AppUser;
import com.dsh.competition.feignclient.course.CoursePackagePaymentClient;
+import com.dsh.competition.feignclient.course.model.PaymentDeductionClassHour;
import com.dsh.competition.feignclient.model.*;
+import com.dsh.competition.feignclient.other.StoreClient;
import com.dsh.competition.model.*;
import com.dsh.competition.service.CompetitionService;
import com.dsh.competition.service.IParticipantService;
@@ -186,10 +188,14 @@
// integers.add(2);
integers.add(3);
+ ArrayList<Integer> pays = new ArrayList<>();
+ pays.add(2);
+ pays.add(3);
+
return paymentCompetitionService.list(new QueryWrapper<PaymentCompetition>()
.in("payType",integers)
.eq("appUserId",appUserId)
- .eq("payStatus",2));
+ .in("payStatus",pays));
}
@@ -627,6 +633,16 @@
wrapper.orderByDesc(Competition::getInsertTime);
Page<Competition> page = cttService.page(competitionPage, wrapper);
+ for (Competition record : page.getRecords()) {
+
+ // 查询当前赛事有多少人报名了
+ List<UserCompetition> competitionId = ucttService.list(new QueryWrapper<UserCompetition>()
+ .eq("competitionId", record.getId()));
+ // 报名数量
+ int temp = competitionId.size();
+ String value = String.valueOf(temp);
+ record.setCount(record.getApplicantsNumber()+"-"+value);
+ }
return page;
}catch (Exception e){
e.printStackTrace();
@@ -672,6 +688,16 @@
@PostMapping("/base/competition/add")
public void add(@RequestBody Competition competition){
try {
+ if (competition.getStartTime().after(new Date())){
+ competition.setStatus(1);
+ }
+ if (competition.getStartTime().before(new Date())){
+ if (competition.getEndTime().after(new Date())){
+ competition.setStatus(2);
+ }else{
+ competition.setStatus(3);
+ }
+ }
competition.setInsertTime(new Date());
cttService.save(competition);
}catch (Exception e){
@@ -682,11 +708,28 @@
@PostMapping("/base/competition/update")
public void update(@RequestBody Competition competition){
try {
+ if (competition.getStartTime().after(new Date())){
+ competition.setStatus(1);
+ }
+ if (competition.getStartTime().before(new Date())){
+ if (competition.getEndTime().after(new Date())){
+ competition.setStatus(2);
+ }else{
+ competition.setStatus(3);
+ }
+ }
cttService.updateById(competition);
}catch (Exception e){
e.printStackTrace();
}
}
+
+ @Resource
+ private StoreClient storeClient;
+
+ @Autowired
+ private UserCompetitionService userCompetitionService;
+
@PostMapping("/base/competition/cancel")
public void cancel(@RequestBody Integer id){
@@ -694,6 +737,87 @@
Competition byId = cttService.getById(id);
byId.setStatus(4);
cttService.updateById(byId);
+ List<PaymentCompetition> list = paymentCompetitionService.list(new QueryWrapper<PaymentCompetition>().eq("competitionId", byId.getId()).eq("payStatus", 2));
+ for (PaymentCompetition pay : list) {
+ PaymentCompetition paymentCompetition = pay;
+
+ String code = paymentCompetition.getCode();
+ Double amount = paymentCompetition.getAmount();
+ Competition competition = competitionService.getById(paymentCompetition.getCompetitionId());
+
+
+ String payOrderNo = paymentCompetition.getPayOrderNo();
+ if(paymentCompetition.getPayType() == 1){//微信支付
+ 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"));
+ continue;
+ }
+ String refund_id = map.get("refund_id");
+ paymentCompetition.setRefundOrderNo(refund_id);
+ paymentCompetitionService.updateById(paymentCompetition);
+
+ storeClient.addBackRecord(paymentCompetition.getAmount()+"_"+paymentCompetition.getAppUserId());
+
+
+ }
+ if(paymentCompetition.getPayType() == 2){//支付宝支付
+ Map<String, String> map = payMoneyUtil.aliRefund(payOrderNo, amount.toString());
+ String return_code = map.get("code");
+ if(!"10000".equals(return_code)){
+// return ResultUtil.error(map.get("msg"));
+ continue;
+ }
+ String refund_id = map.get("trade_no");
+ paymentCompetition.setRefundOrderNo(refund_id);
+ paymentCompetition.setRefundTime(new Date());
+ paymentCompetition.setPayStatus(3);
+ paymentCompetition.setAppUserId(null);
+ paymentCompetitionService.updateById(paymentCompetition);
+
+// competition.setApplicantsNumber(competition.getApplicantsNumber() - 1);
+ competitionService.updateById(competition);
+ }
+ if(paymentCompetition.getPayType() == 3){//玩湃币支付
+ AppUser appUser = appUserClient.queryAppUser(paymentCompetition.getAppUserId());
+ appUser.setPlayPaiCoins(appUser.getPlayPaiCoins() + amount.intValue());
+ appUserClient.updateAppUser(appUser);
+
+ paymentCompetition.setRefundOrderNo("");
+ paymentCompetition.setRefundTime(new Date());
+ paymentCompetition.setPayStatus(3);
+ paymentCompetition.setAppUserId(null);
+ paymentCompetitionService.updateById(paymentCompetition);
+
+// competition.setApplicantsNumber(competition.getApplicantsNumber() - 1);
+ competitionService.updateById(competition);
+ }
+ if(paymentCompetition.getPayType() == 4){//课程支付
+ List<UserCompetition> list1 = userCompetitionService.list(new QueryWrapper<UserCompetition>().eq("paymentCompetitionId", paymentCompetition.getId()));
+ for (UserCompetition userCompetition : list1) {
+// Participant participant = participantService.getById(userCompetition.getId());
+// Student student = studentClient.queryStudentByPhone(participant.getPhone());
+ PaymentDeductionClassHour paymentDeductionClassHour = new PaymentDeductionClassHour();
+ paymentDeductionClassHour.setId(userCompetition.getParticipantId());
+ paymentDeductionClassHour.setClassHour(competition.getClassPrice());
+ paymentDeductionClassHour.setCode(code);
+ coursePackagePaymentClient.rollbackPaymentDeductionClassHour(paymentDeductionClassHour);
+ }
+
+ paymentCompetition.setRefundOrderNo("");
+ paymentCompetition.setRefundTime(new Date());
+ paymentCompetition.setPayStatus(3);
+ paymentCompetition.setAppUserId(null);
+ paymentCompetitionService.updateById(paymentCompetition);
+
+// competition.setApplicantsNumber(competition.getApplicantsNumber() - 1);
+ competitionService.updateById(competition);
+ }
+
+
+ }
+
}catch (Exception e){
e.printStackTrace();
}
--
Gitblit v1.7.1