From 603fbdb1bd13acf72fc94b95d96d32403c0889c2 Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期三, 06 三月 2024 18:15:16 +0800
Subject: [PATCH] 添加方法
---
cloud-server-communityWorldCup/src/main/java/com/dsh/communityWorldCup/service/impl/WorldCupCompetitorServiceImpl.java | 103 ++++++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 100 insertions(+), 3 deletions(-)
diff --git a/cloud-server-communityWorldCup/src/main/java/com/dsh/communityWorldCup/service/impl/WorldCupCompetitorServiceImpl.java b/cloud-server-communityWorldCup/src/main/java/com/dsh/communityWorldCup/service/impl/WorldCupCompetitorServiceImpl.java
index bf244d5..11c1a73 100644
--- a/cloud-server-communityWorldCup/src/main/java/com/dsh/communityWorldCup/service/impl/WorldCupCompetitorServiceImpl.java
+++ b/cloud-server-communityWorldCup/src/main/java/com/dsh/communityWorldCup/service/impl/WorldCupCompetitorServiceImpl.java
@@ -1,11 +1,14 @@
package com.dsh.communityWorldCup.service.impl;
+import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.dsh.communityWorldCup.entity.WorldCup;
import com.dsh.communityWorldCup.entity.WorldCupCompetitor;
import com.dsh.communityWorldCup.feignclient.account.AppUserClient;
import com.dsh.communityWorldCup.feignclient.account.StudentClient;
import com.dsh.communityWorldCup.feignclient.account.model.AppUser;
+import com.dsh.communityWorldCup.feignclient.account.model.AppUserIdsByCityName;
import com.dsh.communityWorldCup.feignclient.account.model.TStudent;
import com.dsh.communityWorldCup.feignclient.competition.ParticipantClient;
import com.dsh.communityWorldCup.feignclient.competition.model.Participant;
@@ -13,15 +16,15 @@
import com.dsh.communityWorldCup.mapper.WorldCupCompetitorMapper;
import com.dsh.communityWorldCup.model.*;
import com.dsh.communityWorldCup.service.IWorldCupCompetitorService;
+import com.dsh.communityWorldCup.service.IWorldCupService;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.math.BigDecimal;
import java.math.MathContext;
import java.math.RoundingMode;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
/**
* @author zhibing.pu
@@ -38,6 +41,9 @@
@Resource
private AppUserClient appUserClient;
+
+ @Autowired
+ private IWorldCupService worldCupService;
@@ -245,4 +251,95 @@
}
return list;
}
+
+
+ /**
+ * 比赛结束后通知处理逻辑
+ * @param custom 开始比赛接口上传的自定义参数
+ * @param red_score 红方分数
+ * @param blue 蓝方分数
+ */
+ @Override
+ public void endWorldCupCallback(String custom, Integer red_score, Integer blue) {
+ List<Long> ids = JSON.parseArray(custom, Long.class);
+ List<WorldCupCompetitor> worldCupCompetitors = this.listByIds(ids);
+ WorldCupCompetitor worldCupCompetitor1 = worldCupCompetitors.get(0);
+ WorldCup worldCup = worldCupService.getById(worldCupCompetitor1.getWorldCupId());
+ for (WorldCupCompetitor worldCupCompetitor : worldCupCompetitors) {
+ //蓝方
+ if(worldCupCompetitor.getParticipant() == 1){
+ worldCupCompetitor.setMatchResult(blue.compareTo(red_score));
+ worldCupCompetitor.setOurScore(blue);
+ worldCupCompetitor.setOpponentScore(red_score);
+ worldCupCompetitor.setEndTime(new Date());
+ worldCupCompetitor.setWinIntegral(0);
+ if(null != worldCup.getWinIntegral() && 0 < worldCup.getWinIntegral() && blue.compareTo(red_score) >= 0){
+ worldCupCompetitor.setWinIntegral(worldCup.getWinIntegral());
+ AppUser appUser = appUserClient.getAppUser(worldCupCompetitor.getAppUserId());
+ appUser.setIntegral(appUser.getIntegral() + worldCup.getWinIntegral());
+ appUserClient.updateAppUser(appUser);
+ }
+ }
+ //红方
+ if(worldCupCompetitor.getParticipant() == 2){
+ worldCupCompetitor.setMatchResult(red_score.compareTo(blue));
+ worldCupCompetitor.setOurScore(red_score);
+ worldCupCompetitor.setOpponentScore(blue);
+ worldCupCompetitor.setEndTime(new Date());
+ worldCupCompetitor.setWinIntegral(0);
+ if(null != worldCup.getWinIntegral() && 0 < worldCup.getWinIntegral() && red_score.compareTo(blue) >= 0){
+ worldCupCompetitor.setWinIntegral(worldCup.getWinIntegral());
+ AppUser appUser = appUserClient.getAppUser(worldCupCompetitor.getAppUserId());
+ appUser.setIntegral(appUser.getIntegral() + worldCup.getWinIntegral());
+ appUserClient.updateAppUser(appUser);
+ }
+ }
+ }
+
+ this.updateBatchById(worldCupCompetitors);
+ }
+
+
+ /**
+ * 获取比赛排行榜列表数据
+ * @param worldCupRecords
+ * @return
+ */
+ @Override
+ public Map<String, Object> worldCupRecordsList(WorldCupRecords worldCupRecords) {
+ Map<String, Object> map1 = new HashMap<>();
+ AppUserIdsByCityName appUserIdsByCityName = new AppUserIdsByCityName();
+ appUserIdsByCityName.setProvince(worldCupRecords.getProvince());
+ appUserIdsByCityName.setCity(worldCupRecords.getCity());
+ List<Integer> appUserIds = appUserClient.getAppUserIdsByCityName(appUserIdsByCityName);
+ List<Map<String, Object>> mapList = this.baseMapper.worldCupRecordsList(worldCupRecords, appUserIds);
+ for (int i = 0; i < mapList.size(); i++) {
+ Map<String, Object> map = mapList.get(i);
+ Integer participantType = Integer.valueOf(map.get("participantType").toString());
+ Integer participantId = Integer.valueOf(map.get("participantId").toString());
+ Integer appUserId = Integer.valueOf(map.get("appUserId").toString());
+ Integer totalSession = Integer.valueOf(map.get("totalSession").toString());
+ Integer win = Integer.valueOf(map.get("win").toString());
+ Integer lose = totalSession - win;
+ map.put("lose", lose);
+ AppUser appUser = appUserClient.getAppUser(appUserId);
+ map.put("province", appUser.getProvince() + appUser.getCity());
+ if(1 == participantType){
+ TStudent tStudent = studentClient.queryById(participantId);
+ map.put("name", tStudent.getName());
+ map.put("phone", tStudent.getPhone());
+ }else{
+ Participant participant = participantClient.getParticipant(participantId);
+ map.put("name", participant.getName());
+ map.put("phone", participant.getPhone());
+ }
+ }
+ Integer offset = worldCupRecords.getOffset();
+ Integer limit = worldCupRecords.getLimit();
+ limit += offset;
+ map1.put("rows", mapList.subList(offset, mapList.size() >= limit ? limit : mapList.size()));
+ int count = this.baseMapper.worldCupRecordsListCount(appUserIds);
+ map1.put("total", count);
+ return map1;
+ }
}
--
Gitblit v1.7.1