msb-public-java
/
RuoYi-Cloud
mirror of https://gitee.com/y_project/RuoYi-Cloud.git
1
0
Code Issues Projects Releases Wiki Activity

框架集成MyBatis-Plus使得编码更加方便1

Browse Source
pull/371/head
wuyibo 2 years ago
parent 6653d88b69
commit 74728a6194
2 changed files with 103 additions and 93 deletions
Show Stats Download Patch File Download Diff File

192
ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/CompetitionServiceImpl.java
Unescape View File

@ -1,13 +1,5 @@
package com.ruoyi.system.service.impl; package com.ruoyi.system.service.impl;
import java.io.File;
import java.math.BigDecimal;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.util.NumberUtil; import cn.hutool.core.util.NumberUtil;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
@ -41,17 +33,23 @@ import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.StringUtils; import org.springframework.util.StringUtils;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.io.File;
import java.math.BigDecimal;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
/** /**
* 比赛信息Service业务层处理 * 比赛信息Service业务层处理
* *
* @author ruoyi * @author ruoyi
* @date 2022-11-02 * @date 2022-11-02
*/ */
@Log4j2 @Log4j2
@Service @Service
public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Competition> implements ICompetitionService public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Competition> implements ICompetitionService {
{
@Resource @Resource
private CompetitionMapper competitionMapper; private CompetitionMapper competitionMapper;
@Resource @Resource
@ -87,85 +85,80 @@ public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Compe
private String winLocation; private String winLocation;
@Value("${image.domainName}") @Value("${image.domainName}")
private String domainName; private String domainName;
/** /**
* 查询比赛信息 * 查询比赛信息
* *
* @param id 比赛信息主键 * @param id 比赛信息主键
* @return 比赛信息 * @return 比赛信息
*/ */
@Override @Override
public Competition selectCompetitionById(Long id) public Competition selectCompetitionById(Long id) {
{
return competitionMapper.selectCompetitionById(id); return competitionMapper.selectCompetitionById(id);
} }
/** /**
* 查询比赛信息列表 * 查询比赛信息列表
* *
* @param competition 比赛信息 * @param competition 比赛信息
* @return 比赛信息 * @return 比赛信息
*/ */
@Override @Override
public List<Competition> selectCompetitionList(Competition competition) public List<Competition> selectCompetitionList(Competition competition) {
{
return competitionMapper.selectCompetitionList(competition); return competitionMapper.selectCompetitionList(competition);
} }
/** /**
* 新增比赛信息 * 新增比赛信息
* *
* @param competition 比赛信息 * @param competition 比赛信息
* @return 结果 * @return 结果
*/ */
@Override @Override
public int insertCompetition(Competition competition) public int insertCompetition(Competition competition) {
{
return competitionMapper.insertCompetition(competition); return competitionMapper.insertCompetition(competition);
} }
/** /**
* 修改比赛信息 * 修改比赛信息
* *
* @param competition 比赛信息 * @param competition 比赛信息
* @return 结果 * @return 结果
*/ */
@Override @Override
public int updateCompetition(Competition competition) public int updateCompetition(Competition competition) {
{
return competitionMapper.updateCompetition(competition); return competitionMapper.updateCompetition(competition);
} }
/** /**
* 批量删除比赛信息 * 批量删除比赛信息
* *
* @param ids 需要删除的比赛信息主键 * @param ids 需要删除的比赛信息主键
* @return 结果 * @return 结果
*/ */
@Override @Override
public int deleteCompetitionByIds(Long[] ids) public int deleteCompetitionByIds(Long[] ids) {
{
return competitionMapper.deleteCompetitionByIds(ids); return competitionMapper.deleteCompetitionByIds(ids);
} }
/** /**
* 删除比赛信息信息 * 删除比赛信息信息
* *
* @param id 比赛信息主键 * @param id 比赛信息主键
* @return 结果 * @return 结果
*/ */
@Override @Override
public int deleteCompetitionById(Long id) public int deleteCompetitionById(Long id) {
{
return competitionMapper.deleteCompetitionById(id); return competitionMapper.deleteCompetitionById(id);
} }
@Override @Override
public WxAppletsCodeVo genCompetitionCommonAqrSpread(WxAppletsCodeVo wxAppletsCodeVo) { public WxAppletsCodeVo genCompetitionCommonAqrSpread(WxAppletsCodeVo wxAppletsCodeVo) {
Object key = redisService.getCacheObject(CacheConstants.COMPETITION_SPREAD_AQR_CODE + wxAppletsCodeVo.getScene()); Object key = redisService.getCacheObject(CacheConstants.COMPETITION_SPREAD_AQR_CODE + wxAppletsCodeVo.getScene());
if(ObjectUtils.isEmpty(key)){ if (ObjectUtils.isEmpty(key)) {
wxAppletsCodeVo = wxApplesCodeService.genWxApplesAqrCode(wxAppletsCodeVo); wxAppletsCodeVo = wxApplesCodeService.genWxApplesAqrCode(wxAppletsCodeVo);
redisService.setCacheObject(CacheConstants.COMPETITION_SPREAD_AQR_CODE + wxAppletsCodeVo.getScene(),wxAppletsCodeVo.getCodeImgUrl(),30L, TimeUnit.DAYS); redisService.setCacheObject(CacheConstants.COMPETITION_SPREAD_AQR_CODE + wxAppletsCodeVo.getScene(), wxAppletsCodeVo.getCodeImgUrl(), 30L, TimeUnit.DAYS);
}else { } else {
wxAppletsCodeVo.setCodeImgUrl((String) key); wxAppletsCodeVo.setCodeImgUrl((String) key);
} }
return wxAppletsCodeVo; return wxAppletsCodeVo;
@ -173,22 +166,37 @@ public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Compe
@Override @Override
public List<Competition> getCompetitionByCondition(CompetitionVo competition) { public List<Competition> getCompetitionByCondition(CompetitionVo competition) {
return competitionMapper.getCompetitionByCondition(competition); List<Competition> competitionList = competitionMapper.getCompetitionByCondition(competition);
for (Competition comp : competitionList) {
if (comp.getCompetitionNature() == 0) {
WxBasketballTeam mainTeam = wxBasketballTeamMapper.selectWxBasketballTeamById(comp.getMainTeamId());
if (ObjectUtil.isNotEmpty(mainTeam)) {
comp.setMainTeamLogo(mainTeam.getTeamLogo());
}
if (comp.getGuestTeamId() != null) {
WxBasketballTeam guestTeam = wxBasketballTeamMapper.selectWxBasketballTeamById(comp.getGuestTeamId());
if (ObjectUtil.isNotEmpty(guestTeam)) {
comp.setGuestTeamLogo(guestTeam.getTeamLogo());
}
}
}
}
return competitionList;
} }
@Override @Override
public CompetitionExcleVo getTeamEnrollExcleImpData(Long competitionId, Long userId) { public CompetitionExcleVo getTeamEnrollExcleImpData(Long competitionId, Long userId) {
CompetitionExcleVo excleVo = new CompetitionExcleVo(); CompetitionExcleVo excleVo = new CompetitionExcleVo();
Competition competition = competitionMapper.selectCompetitionById(competitionId); Competition competition = competitionMapper.selectCompetitionById(competitionId);
if(ObjectUtil.isNull(competition)){ if (ObjectUtil.isNull(competition)) {
return excleVo; return excleVo;
} }
//todo 获取球队数据 //todo 获取球队数据
CompetitionOfTeam team = competitionOfTeamMapper.selectOneByUserId(competitionId,String.valueOf(userId)); CompetitionOfTeam team = competitionOfTeamMapper.selectOneByUserId(competitionId, String.valueOf(userId));
if(ObjectUtil.isNull(team)){ if (ObjectUtil.isNull(team)) {
return excleVo; return excleVo;
} }
BeanUtil.copyProperties(competition,excleVo); BeanUtil.copyProperties(competition, excleVo);
excleVo.setOfTeam(team); excleVo.setOfTeam(team);
//todo 查询球队队员数据 //todo 查询球队队员数据
CompetitionMembers condtion = new CompetitionMembers(); CompetitionMembers condtion = new CompetitionMembers();
@ -202,15 +210,15 @@ public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Compe
@Override @Override
public CompetitionResponse getCompetitionById(Long id) { public CompetitionResponse getCompetitionById(Long id) {
//查询比赛信息 //查询比赛信息
CompetitionResponse competitionResponse=new CompetitionResponse(); CompetitionResponse competitionResponse = new CompetitionResponse();
Competition competition = competitionMapper.selectCompetitionById(id); Competition competition = competitionMapper.selectCompetitionById(id);
if(UtilTool.isNull(competition)){ if (UtilTool.isNull(competition)) {
throw new ServiceException("根据id未查询到约战信息"); throw new ServiceException("根据id未查询到约战信息");
} }
BeanUtils.copyProperties(competition,competitionResponse); BeanUtils.copyProperties(competition, competitionResponse);
//查询比赛参与人员列表数据 //查询比赛参与人员列表数据
List<CompetitionMembersVo> membersList = competitionMembersMapper.getCompetitionMembersByCompetitionId(competition.getId()); List<CompetitionMembersVo> membersList = competitionMembersMapper.getCompetitionMembersByCompetitionId(competition.getId());
if(competition.getCompetitionNature().intValue()==0) { if (competition.getCompetitionNature().intValue() == 0) {
Map<Long, List<CompetitionMembersVo>> groupByTeamIdMap = membersList.stream().collect(Collectors.groupingBy(CompetitionMembers::getCompetitionTeamId)); //查询主队下的队员信息 Map<Long, List<CompetitionMembersVo>> groupByTeamIdMap = membersList.stream().collect(Collectors.groupingBy(CompetitionMembers::getCompetitionTeamId)); //查询主队下的队员信息
for (Map.Entry<Long, List<CompetitionMembersVo>> entry : groupByTeamIdMap.entrySet()) { for (Map.Entry<Long, List<CompetitionMembersVo>> entry : groupByTeamIdMap.entrySet()) {
if (!StringUtils.isEmpty(competition.getMainTeamId()) && entry.getKey().equals(competition.getMainTeamId())) { if (!StringUtils.isEmpty(competition.getMainTeamId()) && entry.getKey().equals(competition.getMainTeamId())) {
@ -221,14 +229,14 @@ public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Compe
} }
} }
//查询球队的合照 //查询球队的合照
List<Long> teamIds =new ArrayList<>(); List<Long> teamIds = new ArrayList<>();
if(!StringUtils.isEmpty(competition.getMainTeamId())) { if (!StringUtils.isEmpty(competition.getMainTeamId())) {
teamIds.add(competition.getMainTeamId()); teamIds.add(competition.getMainTeamId());
} }
if(!StringUtils.isEmpty(competition.getGuestTeamId())) { if (!StringUtils.isEmpty(competition.getGuestTeamId())) {
teamIds.add(competition.getGuestTeamId()); teamIds.add(competition.getGuestTeamId());
} }
if(teamIds.size()>0) { if (teamIds.size() > 0) {
List<WxBasketballTeam> basketballTeamList = wxBasketballTeamMapper.selectBatchIds(teamIds); List<WxBasketballTeam> basketballTeamList = wxBasketballTeamMapper.selectBatchIds(teamIds);
CompetitionTeamVsTeam competitionTeamVsTeam = new CompetitionTeamVsTeam(); CompetitionTeamVsTeam competitionTeamVsTeam = new CompetitionTeamVsTeam();
for (WxBasketballTeam team : basketballTeamList) { for (WxBasketballTeam team : basketballTeamList) {
@ -256,26 +264,26 @@ public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Compe
public Boolean establishCompetition(CompetitionVo entity) { public Boolean establishCompetition(CompetitionVo entity) {
//使用赛会名称加密缓存防止重复提交 //使用赛会名称加密缓存防止重复提交
Object key = redisService.getCacheObject(Constants.COMPETITION_CREATE_KEY + DigestUtil.md5(entity.getCompetitionName().trim())); Object key = redisService.getCacheObject(Constants.COMPETITION_CREATE_KEY + DigestUtil.md5(entity.getCompetitionName().trim()));
if(ObjectUtil.isNotNull(key)){ if (ObjectUtil.isNotNull(key)) {
throw new ServiceException("当前创建赛会数据已提交到系统，毋须重复提交！"); throw new ServiceException("当前创建赛会数据已提交到系统，毋须重复提交！");
} }
LoginUser user = SecurityUtils.getLoginUser(); LoginUser user = SecurityUtils.getLoginUser();
entity.setCreatedBy(String.valueOf(user.getUserid())); entity.setCreatedBy(String.valueOf(user.getUserid()));
entity.setCreatedTime(new Date()); entity.setCreatedTime(new Date());
DateFormat sdf = new SimpleDateFormat("yyyyMMdd"); DateFormat sdf = new SimpleDateFormat("yyyyMMdd");
entity.setCompetitionCode(sdf.format(new Date())+ RandomStringUtils.randomNumeric(6)); entity.setCompetitionCode(sdf.format(new Date()) + RandomStringUtils.randomNumeric(6));
//判断是否已经存在 //判断是否已经存在
List<Competition> existList = competitionMapper.selectCompetitionList( Competition.builder().competitionName(entity.getCompetitionName()).competitionNature(entity.getCompetitionNature()).build()); List<Competition> existList = competitionMapper.selectCompetitionList(Competition.builder().competitionName(entity.getCompetitionName()).competitionNature(entity.getCompetitionNature()).build());
if(existList.size()>0) { if (existList.size() > 0) {
throw new ServiceException("当前赛会已存在，毋须重复提交！"); throw new ServiceException("当前赛会已存在，毋须重复提交！");
} }
//小程序-推送赛会通知给系统管理员。管理员好及时去审核赛会 //小程序-推送赛会通知给系统管理员。管理员好及时去审核赛会
List<UserRole> userRoles = userRoleMapper.selectUserRoleList(UserRole.builder().roleCode(UserRoles.ADMIN.code()).build()); List<UserRole> userRoles = userRoleMapper.selectUserRoleList(UserRole.builder().roleCode(UserRoles.ADMIN.code()).build());
List<Long> userIds = userRoles.stream().map(UserRole::getUserId).collect(Collectors.toList()); List<Long> userIds = userRoles.stream().map(UserRole::getUserId).collect(Collectors.toList());
List<WxUser> managerUsers = wxUserMapper.listByIds(userIds); List<WxUser> managerUsers = wxUserMapper.listByIds(userIds);
if(!StringUtils.isEmpty(managerUsers)&&!StringUtils.isEmpty(managerUsers.size()>0)){ if (!StringUtils.isEmpty(managerUsers) && !StringUtils.isEmpty(managerUsers.size() > 0)) {
for (WxUser managerUser:managerUsers){ for (WxUser managerUser : managerUsers) {
if(!StringUtils.isEmpty(managerUser.getOpenid())) { if (!StringUtils.isEmpty(managerUser.getOpenid())) {
WxMssVo wxMssVo = new WxMssVo(); WxMssVo wxMssVo = new WxMssVo();
wxMssVo.setTemplate_id(WxAppletsTemplateIdsEnum.COMPETITION_SIGN_UP.getCode()); wxMssVo.setTemplate_id(WxAppletsTemplateIdsEnum.COMPETITION_SIGN_UP.getCode());
wxMssVo.setTouser(managerUser.getOpenid()); wxMssVo.setTouser(managerUser.getOpenid());
@ -289,8 +297,8 @@ public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Compe
} }
} }
} }
if(competitionMapper.insertCompetition(entity)>0){ if (competitionMapper.insertCompetition(entity) > 0) {
redisService.setCacheObject(Constants.COMPETITION_CREATE_KEY + DigestUtil.md5(entity.getCompetitionName().trim()),entity.getCompetitionName(),20L,TimeUnit.SECONDS); redisService.setCacheObject(Constants.COMPETITION_CREATE_KEY + DigestUtil.md5(entity.getCompetitionName().trim()), entity.getCompetitionName(), 20L, TimeUnit.SECONDS);
} }
return Boolean.TRUE; return Boolean.TRUE;
} }
@ -299,27 +307,27 @@ public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Compe
public Boolean challengeConfirm(Competition entity) { public Boolean challengeConfirm(Competition entity) {
//使用赛会名称加密缓存防止重复提交 //使用赛会名称加密缓存防止重复提交
Object key = redisService.getCacheObject(Constants.COMPETITION_CREATE_KEY + DigestUtil.md5(entity.getCompetitionName().trim())); Object key = redisService.getCacheObject(Constants.COMPETITION_CREATE_KEY + DigestUtil.md5(entity.getCompetitionName().trim()));
if(UtilTool.isNotNull(key)){ if (UtilTool.isNotNull(key)) {
throw new ServiceException("当前创建赛会数据已提交到系统，毋须重复提交！"); throw new ServiceException("当前创建赛会数据已提交到系统，毋须重复提交！");
} }
LoginUser user = SecurityUtils.getLoginUser(); LoginUser user = SecurityUtils.getLoginUser();
entity.setCreatedBy(String.valueOf(user.getUserid())); entity.setCreatedBy(String.valueOf(user.getUserid()));
entity.setCreatedTime(new Date()); entity.setCreatedTime(new Date());
DateFormat sdf = new SimpleDateFormat("yyyyMMdd"); DateFormat sdf = new SimpleDateFormat("yyyyMMdd");
entity.setCompetitionCode(sdf.format(new Date())+ RandomStringUtils.randomNumeric(6)); entity.setCompetitionCode(sdf.format(new Date()) + RandomStringUtils.randomNumeric(6));
//判断是否已经存在 //判断是否已经存在
List<Competition> dbList = competitionMapper.selectCompetitionList(Competition.builder().competitionNature(entity.getCompetitionNature()) List<Competition> dbList = competitionMapper.selectCompetitionList(Competition.builder().competitionNature(entity.getCompetitionNature())
.competitionName(entity.getCompetitionName()).build()); .competitionName(entity.getCompetitionName()).build());
if(dbList.size()>0) { if (dbList.size() > 0) {
throw new ServiceException("当前赛会已存在，毋须重复提交！"); throw new ServiceException("当前赛会已存在，毋须重复提交！");
} }
//小程序-推送赛会通知给系统管理员。管理员好及时去审核赛会 //小程序-推送赛会通知给系统管理员。管理员好及时去审核赛会
List<UserRole> userRoles = userRoleMapper.selectUserRoleList(UserRole.builder().roleCode(UserRoles.ADMIN.code()).build()); List<UserRole> userRoles = userRoleMapper.selectUserRoleList(UserRole.builder().roleCode(UserRoles.ADMIN.code()).build());
List<Long> userIds = userRoles.stream().map(UserRole::getUserId).collect(Collectors.toList()); List<Long> userIds = userRoles.stream().map(UserRole::getUserId).collect(Collectors.toList());
List<WxUser> managerUsers = wxUserMapper.listByIds(userIds); List<WxUser> managerUsers = wxUserMapper.listByIds(userIds);
if(!StringUtils.isEmpty(managerUsers)&&!StringUtils.isEmpty(managerUsers.size()>0)){ if (!StringUtils.isEmpty(managerUsers) && !StringUtils.isEmpty(managerUsers.size() > 0)) {
for (WxUser managerUser:managerUsers){ for (WxUser managerUser : managerUsers) {
if(!StringUtils.isEmpty(managerUser.getOpenid())) { if (!StringUtils.isEmpty(managerUser.getOpenid())) {
WxMssVo wxMssVo = new WxMssVo(); WxMssVo wxMssVo = new WxMssVo();
wxMssVo.setTemplate_id(WxAppletsTemplateIdsEnum.COMPETITION_SIGN_UP.getCode()); wxMssVo.setTemplate_id(WxAppletsTemplateIdsEnum.COMPETITION_SIGN_UP.getCode());
wxMssVo.setTouser(managerUser.getOpenid()); wxMssVo.setTouser(managerUser.getOpenid());
@ -333,11 +341,11 @@ public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Compe
} }
} }
} }
if(ObjectUtil.isNull(entity.getId())) { if (ObjectUtil.isNull(entity.getId())) {
if (competitionMapper.insertCompetition(entity) > 0) { if (competitionMapper.insertCompetition(entity) > 0) {
redisService.setCacheObject(Constants.COMPETITION_CREATE_KEY + DigestUtil.md5(entity.getCompetitionName().trim()), entity.getCompetitionName(), 20L, TimeUnit.SECONDS); redisService.setCacheObject(Constants.COMPETITION_CREATE_KEY + DigestUtil.md5(entity.getCompetitionName().trim()), entity.getCompetitionName(), 20L, TimeUnit.SECONDS);
} }
}else { } else {
competitionMapper.updateCompetition(entity); competitionMapper.updateCompetition(entity);
} }
return Boolean.TRUE; return Boolean.TRUE;
@ -345,16 +353,16 @@ public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Compe
@Override @Override
public List<Competition> getMyJoinCompetition(CompetitionVo competition) { public List<Competition> getMyJoinCompetition(CompetitionVo competition) {
List<Competition> list=competitionMapper.getMyJoinCompetition(competition); List<Competition> list = competitionMapper.getMyJoinCompetition(competition);
for (Competition comp:list){ for (Competition comp : list) {
if(competition.getCompetitionNature()==0){ if (competition.getCompetitionNature() == 0) {
WxBasketballTeam mainTeam = wxBasketballTeamMapper.selectWxBasketballTeamById(comp.getMainTeamId()); WxBasketballTeam mainTeam = wxBasketballTeamMapper.selectWxBasketballTeamById(comp.getMainTeamId());
if(!org.springframework.util.ObjectUtils.isEmpty(mainTeam)) { if (!org.springframework.util.ObjectUtils.isEmpty(mainTeam)) {
comp.setMainTeamLogo(mainTeam.getTeamLogo()); comp.setMainTeamLogo(mainTeam.getTeamLogo());
} }
if(comp.getGuestTeamId()!=null) { if (comp.getGuestTeamId() != null) {
WxBasketballTeam guestTeam = wxBasketballTeamMapper.selectWxBasketballTeamById(comp.getGuestTeamId()); WxBasketballTeam guestTeam = wxBasketballTeamMapper.selectWxBasketballTeamById(comp.getGuestTeamId());
if(!org.springframework.util.ObjectUtils.isEmpty(guestTeam)) { if (!org.springframework.util.ObjectUtils.isEmpty(guestTeam)) {
comp.setGuestTeamLogo(guestTeam.getTeamLogo()); comp.setGuestTeamLogo(guestTeam.getTeamLogo());
} }
} }
@ -362,11 +370,12 @@ public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Compe
} }
return list; return list;
} }
@Transactional @Transactional
@Override @Override
public Boolean add(Competition entity) { public Boolean add(Competition entity) {
entity.setCompetitionNature(0); entity.setCompetitionNature(0);
Long id=entity.getId(); Long id = entity.getId();
LoginUser user = SecurityUtils.getLoginUser(); LoginUser user = SecurityUtils.getLoginUser();
//判断是否存在 //判断是否存在
List<Competition> competitions = competitionMapper.selectCompetitionList(Competition.builder() List<Competition> competitions = competitionMapper.selectCompetitionList(Competition.builder()
@ -374,11 +383,11 @@ public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Compe
.mainTeamId(entity.getMainTeamId()) .mainTeamId(entity.getMainTeamId())
.buildingId(entity.getBuildingId()) .buildingId(entity.getBuildingId())
.cityCode(entity.getCityCode()).build()); .cityCode(entity.getCityCode()).build());
if(competitions.size()>0){ if (competitions.size() > 0) {
throw new ServiceException("当前约战数据已存在，毋须重复提交！"); throw new ServiceException("当前约战数据已存在，毋须重复提交！");
} }
//获取场馆数据 //获取场馆数据
if(!StringUtils.isEmpty(entity.getBuildingId())){ if (!StringUtils.isEmpty(entity.getBuildingId())) {
WxBuildingInfo buildingInfo = wxBuildingInfoService.selectWxBuildingInfoById(entity.getBuildingId()); WxBuildingInfo buildingInfo = wxBuildingInfoService.selectWxBuildingInfoById(entity.getBuildingId());
entity.setBuildingName(buildingInfo.getBuildingName()); entity.setBuildingName(buildingInfo.getBuildingName());
entity.setCityCode(buildingInfo.getCityCode()); entity.setCityCode(buildingInfo.getCityCode());
@ -391,12 +400,12 @@ public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Compe
entity.setCreatedTime(new Date()); entity.setCreatedTime(new Date());
entity.setFounder(user.getUserid()); entity.setFounder(user.getUserid());
entity.setStatus(CompetitionStatusEnum.TREATY_WAR.getValue()); entity.setStatus(CompetitionStatusEnum.TREATY_WAR.getValue());
if(ObjectUtil.isNull(entity.getId())){ if (ObjectUtil.isNull(entity.getId())) {
competitionMapper.insertCompetition(entity); competitionMapper.insertCompetition(entity);
}else { } else {
competitionMapper.updateCompetition(entity); competitionMapper.updateCompetition(entity);
} }
if(!StringUtils.isEmpty(entity.getGuestTeamId())) { if (!StringUtils.isEmpty(entity.getGuestTeamId())) {
TeamMembers teamMembers = teamMembersService.getOneByTeamIdAndRoleCode(entity.getGuestTeamId(), RoleEnum.TEAM_MANAGER.getCode()); TeamMembers teamMembers = teamMembersService.getOneByTeamIdAndRoleCode(entity.getGuestTeamId(), RoleEnum.TEAM_MANAGER.getCode());
//如果指定了约战的对象就需要给约战的球队的队长发一个消息 //如果指定了约战的对象就需要给约战的球队的队长发一个消息
Message message = new Message(); Message message = new Message();
@ -408,23 +417,23 @@ public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Compe
message.setSourceId(entity.getId()); message.setSourceId(entity.getId());
message.setFlowEntity(JSON.toJSONString(entity)); message.setFlowEntity(JSON.toJSONString(entity));
message.setCreatedTime(new Date()); message.setCreatedTime(new Date());
message.setMessageTitle("您收到一条【"+entity.getMainTeamName()+"】"+FowTypeEnum.MAKE_AN_APPOINTMENT.getDesc()+"，请及时处理"); message.setMessageTitle("您收到一条【" + entity.getMainTeamName() + "】" + FowTypeEnum.MAKE_AN_APPOINTMENT.getDesc() + "，请及时处理");
messageService.insertMessage(message); messageService.insertMessage(message);
//小程序-查询用户数据看看是否可以推送服务消息根据unionId是否存在 //小程序-查询用户数据看看是否可以推送服务消息根据unionId是否存在
WxUser guestUser = wxUserMapper.selectWxUserById(teamMembers.getUserId()); WxUser guestUser = wxUserMapper.selectWxUserById(teamMembers.getUserId());
if(!StringUtils.isEmpty(guestUser)&&!StringUtils.isEmpty(guestUser.getOpenid())){ if (!StringUtils.isEmpty(guestUser) && !StringUtils.isEmpty(guestUser.getOpenid())) {
WxMssVo wxMssVo=new WxMssVo(); WxMssVo wxMssVo = new WxMssVo();
wxMssVo.setTemplate_id(WxAppletsTemplateIdsEnum.TREATY_WAR.getCode()); wxMssVo.setTemplate_id(WxAppletsTemplateIdsEnum.TREATY_WAR.getCode());
wxMssVo.setTouser(guestUser.getOpenid()); wxMssVo.setTouser(guestUser.getOpenid());
Map<String, TemplateDataVo> map = new HashMap<>(); Map<String, TemplateDataVo> map = new HashMap<>();
map.put("thing1",new TemplateDataVo(entity.getMainTeamName())); map.put("thing1", new TemplateDataVo(entity.getMainTeamName()));
map.put("thing2",new TemplateDataVo(entity.getGuestTeamName())); map.put("thing2", new TemplateDataVo(entity.getGuestTeamName()));
map.put("thing3",new TemplateDataVo("您有新的约战信息，请在小程序中进行处理")); map.put("thing3", new TemplateDataVo("您有新的约战信息，请在小程序中进行处理"));
wxMssVo.setData(map); wxMssVo.setData(map);
wxAppletsService.pushOneUser(wxMssVo); wxAppletsService.pushOneUser(wxMssVo);
} }
} }
if(StringUtils.isEmpty(id)) { if (StringUtils.isEmpty(id)) {
//保存创建人到比赛参与人员表 //保存创建人到比赛参与人员表
CompetitionMembers competitionMembers = new CompetitionMembers(); CompetitionMembers competitionMembers = new CompetitionMembers();
competitionMembers.setCompetitionId(entity.getId()); competitionMembers.setCompetitionId(entity.getId());
@ -439,6 +448,7 @@ public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Compe
} }
return true; return true;
} }
@Override @Override
public Boolean edit(Competition entity) { public Boolean edit(Competition entity) {
LoginUser user = SecurityUtils.getLoginUser(); LoginUser user = SecurityUtils.getLoginUser();
@ -450,7 +460,7 @@ public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Compe
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
@Override @Override
public CompetitionExcleVo importExcleData(Long competitionId,Map<String, PictureData> maplist, Sheet sheet) { public CompetitionExcleVo importExcleData(Long competitionId, Map<String, PictureData> maplist, Sheet sheet) {
CompetitionExcleVo excleVo = new CompetitionExcleVo(); CompetitionExcleVo excleVo = new CompetitionExcleVo();
String time = new SimpleDateFormat("yyyy-MM-dd").format(new Date()); String time = new SimpleDateFormat("yyyy-MM-dd").format(new Date());
//System.out.println("获取到精确到日的时间格式为"+time); //System.out.println("获取到精确到日的时间格式为"+time);
@ -531,13 +541,13 @@ public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Compe
throw new CheckedException("球队人数不能为空"); throw new CheckedException("球队人数不能为空");
} }
//todo 校验是否是整数 //todo 校验是否是整数
if(!NumberUtil.isInteger(teamUserNum)){ if (!NumberUtil.isInteger(teamUserNum)) {
throw new CheckedException("球队人数必须是正整数"); throw new CheckedException("球队人数必须是正整数");
} }
//todo 获取到数据后，开始保存数据 //todo 获取到数据后，开始保存数据
LoginUser user = SecurityUtils.getLoginUser(); LoginUser user = SecurityUtils.getLoginUser();
String userId = null; String userId = null;
if(ObjectUtil.isNotNull(user)&&ObjectUtil.isNotNull(user.getUserid())){ if (ObjectUtil.isNotNull(user) && ObjectUtil.isNotNull(user.getUserid())) {
userId = String.valueOf(user.getUserid()); userId = String.valueOf(user.getUserid());
} }
CompetitionOfTeamVo team = new CompetitionOfTeamVo(); CompetitionOfTeamVo team = new CompetitionOfTeamVo();
@ -574,7 +584,7 @@ public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Compe
if (UtilTool.isNotNull(competitionOfTeam)) { if (UtilTool.isNotNull(competitionOfTeam)) {
team.setId(competitionOfTeam.getId()); team.setId(competitionOfTeam.getId());
competitionOfTeamMapper.updateCompetitionOfTeam(team); competitionOfTeamMapper.updateCompetitionOfTeam(team);
}else { } else {
competitionOfTeamMapper.insertCompetitionOfTeam(team); competitionOfTeamMapper.insertCompetitionOfTeam(team);
} }
excleVo.setOfTeam(team); excleVo.setOfTeam(team);
@ -618,8 +628,8 @@ public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Compe
if (cell != null) { if (cell != null) {
cell.setCellType(CellType.STRING); cell.setCellType(CellType.STRING);
//todo 校验是否是整数 //todo 校验是否是整数
if(!NumberUtil.isInteger(cell.getStringCellValue())){ if (!NumberUtil.isInteger(cell.getStringCellValue())) {
throw new CheckedException(membersVo.getRealName()+" 的身高必须是正整数"); throw new CheckedException(membersVo.getRealName() + " 的身高必须是正整数");
} }
membersVo.setHeight(new BigDecimal(cell.getStringCellValue())); membersVo.setHeight(new BigDecimal(cell.getStringCellValue()));
} }
@ -628,8 +638,8 @@ public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Compe
if (cell != null) { if (cell != null) {
cell.setCellType(CellType.STRING); cell.setCellType(CellType.STRING);
//todo 校验是否是整数 //todo 校验是否是整数
if(!NumberUtil.isInteger(cell.getStringCellValue())){ if (!NumberUtil.isInteger(cell.getStringCellValue())) {
throw new CheckedException(membersVo.getRealName()+" 的体重必须是正整数"); throw new CheckedException(membersVo.getRealName() + " 的体重必须是正整数");
} }
membersVo.setWeight(new BigDecimal(cell.getStringCellValue())); membersVo.setWeight(new BigDecimal(cell.getStringCellValue()));
} }
@ -653,9 +663,9 @@ public class CompetitionServiceImpl extends ServiceImpl<CompetitionMapper, Compe
//membersVo.setAvatar(domainName+datePath+newFileName); //membersVo.setAvatar(domainName+datePath+newFileName);
//保存图片 //保存图片
PictureData pictureData2 = maplist.get(i + "_0"); PictureData pictureData2 = maplist.get(i + "_0");
log.info(membersVo.getRealName()+" 开始导入，图片位置"+i + "_0"); log.info(membersVo.getRealName() + " 开始导入，图片位置" + i + "_0");
if (pictureData2 == null) { if (pictureData2 == null) {
throw new CheckedException(membersVo.getRealName()+" 的头像插入方式错误,请先选中单元格然后插入图片"); throw new CheckedException(membersVo.getRealName() + " 的头像插入方式错误,请先选中单元格然后插入图片");
} }
byte[] data2 = pictureData2.getData(); byte[] data2 = pictureData2.getData();
String newFileName2 = UUID.randomUUID() + "_0.jpg"; String newFileName2 = UUID.randomUUID() + "_0.jpg";

4
ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/CompetitionTeamVsTeamServiceImpl.java
Unescape View File

@ -320,8 +320,8 @@ public class CompetitionTeamVsTeamServiceImpl extends ServiceImpl<CompetitionTea
public Boolean deleteBatchByIds(Ids ids) { public Boolean deleteBatchByIds(Ids ids) {
Long[] idList = ids.getIdList().stream().toArray(Long[]::new); Long[] idList = ids.getIdList().stream().toArray(Long[]::new);
//删除赛程的时候同时删除比赛结果 //删除赛程的时候同时删除比赛结果
competitionResultService.lambdaUpdate().in(CompetitionResult::getCompetitionVsId,ids).remove(); competitionResultService.lambdaUpdate().in(CompetitionResult::getCompetitionVsId,idList).remove();
competitionMembersScoreService.lambdaUpdate().in(CompetitionMembersScore::getCompetitionVsId,ids).remove(); competitionMembersScoreService.lambdaUpdate().in(CompetitionMembersScore::getCompetitionVsId,idList).remove();
competitionTeamVsTeamMapper.deleteCompetitionTeamVsTeamByIds(idList); competitionTeamVsTeamMapper.deleteCompetitionTeamVsTeamByIds(idList);
return Boolean.TRUE; return Boolean.TRUE;
} }

Write Preview
Loading…
Cancel
Save