package com.dsh.communityWorldCup.service.impl;
|
|
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.WorldCupPayment;
|
import com.dsh.communityWorldCup.entity.WorldCupPaymentParticipant;
|
import com.dsh.communityWorldCup.entity.WorldCupStore;
|
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.TStudent;
|
import com.dsh.communityWorldCup.feignclient.competition.ParticipantClient;
|
import com.dsh.communityWorldCup.feignclient.competition.model.Participant;
|
import com.dsh.communityWorldCup.feignclient.other.StoreClient;
|
import com.dsh.communityWorldCup.feignclient.other.model.Store;
|
import com.dsh.communityWorldCup.mapper.WorldCupCompetitorMapper;
|
import com.dsh.communityWorldCup.mapper.WorldCupPaymentParticipantMapper;
|
import com.dsh.communityWorldCup.model.MyWorldCupInfo;
|
import com.dsh.communityWorldCup.model.MyWorldCupList;
|
import com.dsh.communityWorldCup.model.WorldCupListVo;
|
import com.dsh.communityWorldCup.model.*;
|
import com.dsh.communityWorldCup.service.IWorldCupPaymentParticipantService;
|
import com.dsh.communityWorldCup.service.IWorldCupPaymentService;
|
import com.dsh.communityWorldCup.service.IWorldCupService;
|
import com.dsh.communityWorldCup.service.IWorldCupStoreService;
|
import com.dsh.communityWorldCup.util.GeodesyUtil;
|
import com.dsh.communityWorldCup.util.ToolUtil;
|
import org.springframework.beans.BeanUtils;
|
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.text.SimpleDateFormat;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* @author zhibing.pu
|
* @Date 2024/2/19 11:07
|
*/
|
@Service
|
public class WorldCupPaymentParticipantServiceImpl extends ServiceImpl<WorldCupPaymentParticipantMapper, WorldCupPaymentParticipant> implements IWorldCupPaymentParticipantService {
|
|
@Autowired
|
private IWorldCupPaymentService worldCupPaymentService;
|
|
@Resource
|
private StudentClient studentClient;
|
|
@Resource
|
private ParticipantClient participantClient;
|
|
@Autowired
|
private IWorldCupService worldCupService;
|
|
@Autowired
|
private IWorldCupPaymentParticipantService worldCupPaymentParticipantService;
|
|
@Autowired
|
private IWorldCupStoreService worldCupStoreService;
|
|
@Resource
|
private StoreClient storeClient;
|
|
@Resource
|
private AppUserClient appUserClient;
|
|
@Resource
|
private WorldCupCompetitorMapper worldCupCompetitorMapper;
|
|
|
|
|
/**
|
* 获取报名数据
|
* @param worldCupId
|
* @param participantType
|
* @param participantId
|
* @return
|
*/
|
@Override
|
public WorldCupPaymentParticipant getWorldCupPaymentParticipant(Integer worldCupId, Integer participantType, Long participantId) {
|
return this.baseMapper.getWorldCupPaymentParticipant(worldCupId, participantType, participantId);
|
}
|
|
|
/**
|
* 获取社区世界杯我的报名列表
|
* @param myWorldCupList
|
* @return
|
*/
|
@Override
|
public List<WorldCupListVo> getMyWorldCupList(MyWorldCupList myWorldCupList) {
|
int pageNo = (myWorldCupList.getPageNo() - 1) * myWorldCupList.getPageSize();
|
myWorldCupList.setPageNo(pageNo);
|
myWorldCupList.setIsStudent(myWorldCupList.getIsStudent() == 0 ? 2 : 1);
|
List<WorldCupListVo> myWorldCupList1 = this.baseMapper.getMyWorldCupList(myWorldCupList);
|
for (WorldCupListVo worldCupListVo : myWorldCupList1) {
|
Integer worldCupId = worldCupListVo.getWorldCupId();
|
List<WorldCupPayment> list = worldCupPaymentService.list(new QueryWrapper<WorldCupPayment>().eq("worldCupId", worldCupId).eq("payStatus", 2).eq("state", 1));
|
List<Long> collect = list.stream().map(WorldCupPayment::getId).collect(Collectors.toList());
|
Integer heat = worldCupListVo.getHeat();
|
if(collect.size() > 0){
|
int count = worldCupPaymentParticipantService.count(new QueryWrapper<WorldCupPaymentParticipant>().in("worldCupPaymentId", collect));
|
heat += count;
|
}
|
worldCupListVo.setHeat(heat);
|
}
|
return myWorldCupList1;
|
}
|
|
|
/**
|
* 获取已报名的世界杯详情
|
* @param id 社区世界杯支付对应的参与者记录id
|
* @return
|
*/
|
@Override
|
public MyWorldCupInfo getMyWorldCupInfo(Long id, String lon, String lat) {
|
WorldCupPaymentParticipant worldCupPaymentParticipant = this.getById(id);
|
Integer worldCupId = worldCupPaymentParticipant.getWorldCupId();
|
WorldCupPayment worldCupPayment = worldCupPaymentService.getById(worldCupPaymentParticipant.getWorldCupPaymentId());
|
WorldCupInfo worldCupInfo = worldCupService.getWorldCupInfo(worldCupId, null, null);
|
WorldCup worldCup = worldCupService.getById(worldCupId);
|
MyWorldCupInfo myWorldCupInfo = new MyWorldCupInfo();
|
BeanUtils.copyProperties(worldCupInfo, myWorldCupInfo);
|
myWorldCupInfo.setId(worldCupPaymentParticipant.getId());
|
myWorldCupInfo.setUnitPrice(worldCupPayment.getUnitPrice().doubleValue());
|
myWorldCupInfo.setExpense(worldCupPayment.getAmount().doubleValue());
|
myWorldCupInfo.setStatus(worldCup.getStatus());
|
myWorldCupInfo.setRevocable(1);
|
myWorldCupInfo.setProvince(worldCup.getProvince());
|
myWorldCupInfo.setCity(worldCup.getCity());
|
myWorldCupInfo.setPayType(worldCupPayment.getPayType());
|
//开始前一天不能取消
|
if(worldCup.getStartTime().getTime() < System.currentTimeMillis() + 86400000L){
|
myWorldCupInfo.setRevocable(0);
|
}
|
List<ParticipantVo> datas = new ArrayList<>();
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy");
|
List<WorldCupPaymentParticipant> list1 = this.list(new QueryWrapper<WorldCupPaymentParticipant>().eq("worldCupPaymentId", worldCupPaymentParticipant.getWorldCupPaymentId()));
|
for (WorldCupPaymentParticipant wcpp : list1) {
|
Integer participantType = wcpp.getParticipantType();
|
Long participantId = wcpp.getParticipantId();
|
ParticipantVo participantVo = new ParticipantVo();
|
//学员
|
if(1 == participantType){
|
TStudent tStudent = studentClient.queryById(participantId.intValue());
|
participantVo.setId(tStudent.getId());
|
participantVo.setName(tStudent.getName());
|
int age = Integer.valueOf(sdf.format(new Date())) - Integer.valueOf(sdf.format(tStudent.getBirthday()));
|
participantVo.setAge(age);
|
participantVo.setIdcard(tStudent.getIdCard());
|
participantVo.setPhone(tStudent.getPhone());
|
participantVo.setIsStudent(1);
|
datas.add(participantVo);
|
}
|
//参赛人员
|
if(2 == participantType){
|
Participant participant = participantClient.getParticipant(participantId);
|
participantVo.setId(participant.getId());
|
participantVo.setName(participant.getName());
|
int age = Integer.valueOf(sdf.format(new Date())) - Integer.valueOf(sdf.format(participant.getBirthday()));
|
participantVo.setAge(age);
|
participantVo.setIdcard(participant.getIdcard());
|
participantVo.setPhone(participant.getPhone());
|
participantVo.setIsStudent(0);
|
datas.add(participantVo);
|
}
|
}
|
|
myWorldCupInfo.setParticipants(datas);
|
List<WorldCupStore> worldCupStores = worldCupStoreService.list(new QueryWrapper<WorldCupStore>().eq("worldCupId", id));
|
ArrayList<Map<String, Object>> objects = new ArrayList<>();
|
for (WorldCupStore worldCupStore : worldCupStores) {
|
HashMap<String, Object> map = new HashMap<>();
|
Store store = storeClient.queryStoreById(worldCupStore.getStoreId());
|
map.put("name", store.getName());
|
|
|
String str = store.getAddress();
|
str = str.substring(str.indexOf("省") + 1);
|
|
// 去掉第一个“市”及之前的字符串
|
str = str.substring(str.indexOf("市") + 1);
|
|
// 去掉第一个“区”及之前的字符串
|
str = str.substring(str.indexOf("区") + 1);
|
|
map.put("address", str);
|
map.put("storeLon", store.getLon());
|
map.put("storeLat", store.getLat());
|
map.put("storeCoverDrawing", store.getCoverDrawing());
|
if (ToolUtil.isNotEmpty(lon) && ToolUtil.isNotEmpty(lat)) {
|
Map<String, Double> distance = GeodesyUtil.getDistance(lon + "," + lat, store.getLon() + "," + store.getLat());
|
double wgs84 = new BigDecimal(distance.get("WGS84")).divide(new BigDecimal(1000)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
|
map.put("distance", wgs84);
|
}
|
objects.add(map);
|
}
|
worldCupInfo.setStoreInfos(objects);
|
String address = worldCupInfo.getAddress();
|
String province = worldCupInfo.getProvince();
|
String city = worldCupInfo.getCity();
|
int index = address.indexOf("市");
|
if(index != -1){
|
address = address.substring(index + 1);
|
worldCupInfo.setAddress(address);
|
}
|
index = province.indexOf("省");
|
if(index != -1){
|
province = province.substring(0, index - 1);
|
worldCupInfo.setProvince(province);
|
}
|
index = city.indexOf("市");
|
if(index != -1){
|
city = city.substring(0, index - 1);
|
worldCupInfo.setCity(city);
|
}
|
return myWorldCupInfo;
|
}
|
|
|
/**
|
* 获取已报过名的参赛人员
|
* @param uid 当前用户
|
* @return
|
*/
|
@Override
|
public List<ParticipantVo> getParticipant(Integer uid) {
|
List<WorldCupPayment> list = worldCupPaymentService.list(new QueryWrapper<WorldCupPayment>().eq("appUserId", uid)
|
.eq("payStatus", 2).eq("state", 1));
|
List<Long> collect = list.stream().map(WorldCupPayment::getId).collect(Collectors.toList());
|
List<ParticipantVo> datas = new ArrayList<>();
|
Set<Long> csry = new HashSet<>();
|
Set<Long> xy = new HashSet<>();
|
if(collect.size() > 0){
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy");
|
List<WorldCupPaymentParticipant> list1 = this.list(new QueryWrapper<WorldCupPaymentParticipant>().in("worldCupPaymentId", collect));
|
for (WorldCupPaymentParticipant worldCupPaymentParticipant : list1) {
|
Integer participantType = worldCupPaymentParticipant.getParticipantType();
|
Long participantId = worldCupPaymentParticipant.getParticipantId();
|
ParticipantVo participantVo = new ParticipantVo();
|
AppUser appUser = appUserClient.getAppUser(worldCupPaymentParticipant.getAppUserId());
|
//学员
|
if(1 == participantType && !xy.contains(participantId)){
|
TStudent tStudent = studentClient.queryById(participantId.intValue());
|
participantVo.setId(tStudent.getId());
|
participantVo.setName(tStudent.getName());
|
participantVo.setAvatar(tStudent.getHeadImg());
|
int age = Integer.valueOf(sdf.format(new Date())) - Integer.valueOf(sdf.format(tStudent.getBirthday()));
|
participantVo.setAge(age);
|
participantVo.setIdcard(tStudent.getIdCard());
|
participantVo.setPhone(tStudent.getPhone());
|
participantVo.setIsStudent(1);
|
datas.add(participantVo);
|
xy.add(participantId);
|
}
|
//参赛人员
|
if(2 == participantType && !csry.contains(participantId)){
|
Participant participant = participantClient.getParticipant(participantId);
|
participantVo.setId(participant.getId());
|
participantVo.setName(participant.getName());
|
participantVo.setAvatar(participant.getHeadImg());
|
int age = Integer.valueOf(sdf.format(new Date())) - Integer.valueOf(sdf.format(participant.getBirthday()));
|
participantVo.setAge(age);
|
participantVo.setIdcard(participant.getIdcard());
|
participantVo.setPhone(participant.getPhone());
|
participantVo.setIsStudent(0);
|
datas.add(participantVo);
|
csry.add(participantId);
|
}
|
}
|
}
|
return datas;
|
}
|
|
|
/**
|
* 获取 已报名人员列表
|
* @param registeredPersonnel
|
* @return
|
*/
|
@Override
|
public Map<String, Object> getRegisteredPersonnel(RegisteredPersonnel registeredPersonnel) {
|
Integer id = registeredPersonnel.getId();
|
String idcode = registeredPersonnel.getIdcode();
|
String name = registeredPersonnel.getName();
|
String phone = registeredPersonnel.getPhone();
|
Integer status = registeredPersonnel.getStatus();
|
Integer offset = registeredPersonnel.getOffset();
|
Integer limit = registeredPersonnel.getLimit();
|
QueryWrapper<WorldCupPayment> queryWrapper = new QueryWrapper<WorldCupPayment>()
|
.eq("worldCupId", id).eq("state", 1);
|
if(null == status){
|
queryWrapper.in("payStatus", Arrays.asList(2, 3));
|
}else if(status == 1){
|
queryWrapper.eq("payStatus", 2);
|
}else{
|
queryWrapper.eq("payStatus", 3);
|
}
|
List<WorldCupPayment> list = worldCupPaymentService.list(queryWrapper);
|
List<Long> collect = list.stream().map(WorldCupPayment::getId).collect(Collectors.toList());
|
Map<String, Object> map = new HashMap<>();
|
if(collect.size() == 0){
|
map.put("rows", new ArrayList<>());
|
map.put("total", 0);
|
return map;
|
}
|
List<WorldCupPaymentParticipant> list1 = this.list(new QueryWrapper<WorldCupPaymentParticipant>().in("worldCupPaymentId", collect).orderByDesc("createTime"));
|
List<Map<String, Object>> list2 = new ArrayList<>();
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy");
|
SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
for (WorldCupPaymentParticipant on : list1) {
|
WorldCupPayment worldCupPayment = worldCupPaymentService.getById(on.getWorldCupPaymentId());
|
Map<String, Object> map1 = new HashMap<>();
|
AppUser appUser = appUserClient.getAppUser(on.getAppUserId());
|
if(on.getParticipantType() == 1){
|
TStudent tStudent = studentClient.queryById(on.getParticipantId().intValue());
|
if(ToolUtil.isNotEmpty(name) && tStudent.getName().indexOf(name) == -1){
|
continue;
|
}
|
if(ToolUtil.isNotEmpty(phone) && (ToolUtil.isEmpty(tStudent.getPhone()) ? appUser.getPhone() : tStudent.getPhone()).indexOf(phone) == -1){
|
continue;
|
}
|
if(ToolUtil.isNotEmpty(idcode) && tStudent.getIdCard().indexOf(idcode) == -1){
|
continue;
|
}
|
map1.put("id", tStudent.getId());
|
map1.put("isStudent", 1);
|
map1.put("name", tStudent.getName());
|
map1.put("gender", tStudent.getSex() == 1 ? "男" : "女");
|
map1.put("age", Integer.valueOf(sdf.format(new Date())) - Integer.valueOf(sdf.format(tStudent.getBirthday())));
|
map1.put("phone", ToolUtil.isEmpty(tStudent.getPhone()) ? appUser.getPhone() : tStudent.getPhone());
|
map1.put("idcard", tStudent.getIdCard());
|
map1.put("state", worldCupPayment.getPayStatus() - 1);
|
map1.put("insertTime", sdf1.format(worldCupPayment.getPayTime()));
|
}else{
|
Participant participant = participantClient.getParticipant(on.getParticipantId());
|
if(ToolUtil.isNotEmpty(name) && participant.getName().indexOf(name) == -1){
|
continue;
|
}
|
if(ToolUtil.isNotEmpty(phone) && (ToolUtil.isNotEmpty(participant.getPhone()) ? participant.getPhone() : appUser.getPhone()).indexOf(phone) == -1){
|
continue;
|
}
|
if(ToolUtil.isNotEmpty(idcode) && participant.getIdcard().indexOf(idcode) == -1){
|
continue;
|
}
|
map1.put("id", participant.getId());
|
map1.put("isStudent", 0);
|
map1.put("name", participant.getName());
|
map1.put("gender", participant.getGender() == 1 ? "男" : "女");
|
map1.put("age", Integer.valueOf(sdf.format(new Date())) - Integer.valueOf(sdf.format(participant.getBirthday())));
|
map1.put("phone", ToolUtil.isNotEmpty(participant.getPhone()) ? participant.getPhone() : appUser.getPhone());
|
map1.put("idcard", participant.getIdcard());
|
map1.put("state", worldCupPayment.getPayStatus() - 1);
|
map1.put("insertTime", sdf1.format(worldCupPayment.getPayTime()));
|
}
|
list2.add(map1);
|
}
|
|
limit += offset;
|
map.put("rows", list2.subList(offset, list2.size() >= limit ? limit : list2.size()));
|
map.put("total", list2.size());
|
return map;
|
}
|
|
@Override
|
public int getCount(Integer worldCupId, List<Long> worldCupPaymentId) {
|
return this.baseMapper.getCount(worldCupId, worldCupPaymentId);
|
}
|
|
|
/**
|
* 获取用户列表
|
* @param worldCupGameStatisticsInfoList
|
* @return
|
*/
|
@Override
|
public Map<String, Object> getUserGameRecordList(WorldCupGameStatisticsInfoList worldCupGameStatisticsInfoList) {
|
Map<String, Object> map1 = new HashMap<>();
|
String name = worldCupGameStatisticsInfoList.getName();
|
String phone = worldCupGameStatisticsInfoList.getPhone();
|
String idcard = worldCupGameStatisticsInfoList.getIdcard();
|
List<Map<String, Object>> mapList = this.baseMapper.getUserGameRecordList();
|
List<Map<String, Object>> list = new ArrayList<>();
|
for (int i = 0; i < mapList.size(); i++) {
|
Map<String, Object> map = mapList.get(i);
|
Integer participantType = Integer.valueOf(map.get("participantType").toString());
|
Long participantId = Long.valueOf(map.get("participantId").toString());
|
Integer appUserId = Integer.valueOf(map.get("appUserId").toString());
|
Map<String, Object> userGameRecordList = worldCupCompetitorMapper.getUserGameRecordList(participantType, participantId);
|
Map<String, Object> userGameRecordList1 = worldCupCompetitorMapper.getUserGameRecordList1(participantType, participantId);
|
Integer totalSession = 0;
|
Integer win = 0;
|
if(null != userGameRecordList){
|
totalSession = Integer.valueOf(null != userGameRecordList && null != userGameRecordList.get("num") ? userGameRecordList.get("num").toString() : "0");
|
win = Integer.valueOf(null != userGameRecordList1 && null != userGameRecordList1.get("num") ? userGameRecordList1.get("num").toString() : "0");
|
}else{
|
userGameRecordList = new HashMap<>();
|
}
|
userGameRecordList.put("totalSession", totalSession);
|
userGameRecordList.put("win", win);
|
Integer lose = totalSession - win;
|
userGameRecordList.put("lose", lose);
|
userGameRecordList.put("winRate", totalSession == 0 ? 0 : new BigDecimal(win).divide(new BigDecimal(totalSession), new MathContext(4, RoundingMode.HALF_EVEN)).multiply(new BigDecimal(100)).doubleValue());
|
userGameRecordList.put("participantType", participantType);
|
userGameRecordList.put("participantId", participantId);
|
AppUser appUser = appUserClient.getAppUser(appUserId);
|
userGameRecordList.put("province", appUser.getProvince() + appUser.getCity());
|
if(1 == participantType){
|
TStudent tStudent = studentClient.queryById(participantId.intValue());
|
if(ToolUtil.isNotEmpty(name) && tStudent.getName().indexOf(name) == -1){
|
continue;
|
}
|
if(ToolUtil.isNotEmpty(phone) && (ToolUtil.isEmpty(tStudent.getPhone()) ? appUser.getPhone() : tStudent.getPhone()).indexOf(phone) == -1){
|
continue;
|
}
|
if(ToolUtil.isNotEmpty(idcard) && tStudent.getIdCard().indexOf(idcard) == -1){
|
continue;
|
}
|
|
userGameRecordList.put("name", tStudent.getName());
|
userGameRecordList.put("phone", ToolUtil.isEmpty(tStudent.getPhone()) ? appUser.getPhone() : tStudent.getPhone());
|
userGameRecordList.put("idcard", tStudent.getIdCard());
|
}else{
|
Participant participant = participantClient.getParticipant(participantId);
|
if(ToolUtil.isNotEmpty(name) && participant.getName().indexOf(name) == -1){
|
continue;
|
}
|
if(ToolUtil.isNotEmpty(phone) && (ToolUtil.isNotEmpty(participant.getPhone()) ? participant.getPhone() : appUser.getPhone()).indexOf(phone) == -1){
|
continue;
|
}
|
if(ToolUtil.isNotEmpty(idcard) && participant.getIdcard().indexOf(idcard) == -1){
|
continue;
|
}
|
|
userGameRecordList.put("name", participant.getName());
|
userGameRecordList.put("phone", ToolUtil.isNotEmpty(participant.getPhone()) ? participant.getPhone() : appUser.getPhone());
|
userGameRecordList.put("idcard", participant.getIdcard());
|
}
|
list.add(userGameRecordList);
|
}
|
map1.put("total", list.size());
|
Integer offset = worldCupGameStatisticsInfoList.getOffset();
|
Integer limit = worldCupGameStatisticsInfoList.getLimit();
|
limit += offset;
|
map1.put("rows", list.subList(offset, list.size() >= limit ? limit : list.size()));
|
return map1;
|
}
|
}
|
