From 74728a61945bc8bc5bc1685cc013bd2a6777e3fc Mon Sep 17 00:00:00 2001 From: wuyibo <771227828@qq.com> Date: Wed, 30 Aug 2023 16:51:21 +0800 Subject: [PATCH] =?UTF-8?q?=E6=A1=86=E6=9E=B6=E9=9B=86=E6=88=90MyBatis-Plu?= =?UTF-8?q?s=E4=BD=BF=E5=BE=97=E7=BC=96=E7=A0=81=E6=9B=B4=E5=8A=A0?= =?UTF-8?q?=E6=96=B9=E4=BE=BF1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/CompetitionServiceImpl.java | 192 +++++++++--------- .../CompetitionTeamVsTeamServiceImpl.java | 4 +- 2 files changed, 103 insertions(+), 93 deletions(-) diff --git a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/CompetitionServiceImpl.java b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/CompetitionServiceImpl.java index 9c8edf80..7602e575 100644 --- a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/CompetitionServiceImpl.java +++ b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/CompetitionServiceImpl.java @@ -1,13 +1,5 @@ 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.util.NumberUtil; import cn.hutool.core.util.ObjectUtil; @@ -41,17 +33,23 @@ import org.springframework.transaction.annotation.Transactional; import org.springframework.util.StringUtils; 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业务层处理 - * + * * @author ruoyi * @date 2022-11-02 */ @Log4j2 @Service -public class CompetitionServiceImpl extends ServiceImpl implements ICompetitionService -{ +public class CompetitionServiceImpl extends ServiceImpl implements ICompetitionService { @Resource private CompetitionMapper competitionMapper; @Resource @@ -87,85 +85,80 @@ public class CompetitionServiceImpl extends ServiceImpl selectCompetitionList(Competition competition) - { + public List selectCompetitionList(Competition competition) { return competitionMapper.selectCompetitionList(competition); } /** * 新增比赛信息 - * + * * @param competition 比赛信息 * @return 结果 */ @Override - public int insertCompetition(Competition competition) - { + public int insertCompetition(Competition competition) { return competitionMapper.insertCompetition(competition); } /** * 修改比赛信息 - * + * * @param competition 比赛信息 * @return 结果 */ @Override - public int updateCompetition(Competition competition) - { + public int updateCompetition(Competition competition) { return competitionMapper.updateCompetition(competition); } /** * 批量删除比赛信息 - * + * * @param ids 需要删除的比赛信息主键 * @return 结果 */ @Override - public int deleteCompetitionByIds(Long[] ids) - { + public int deleteCompetitionByIds(Long[] ids) { return competitionMapper.deleteCompetitionByIds(ids); } /** * 删除比赛信息信息 - * + * * @param id 比赛信息主键 * @return 结果 */ @Override - public int deleteCompetitionById(Long id) - { + public int deleteCompetitionById(Long id) { return competitionMapper.deleteCompetitionById(id); } @Override public WxAppletsCodeVo genCompetitionCommonAqrSpread(WxAppletsCodeVo wxAppletsCodeVo) { Object key = redisService.getCacheObject(CacheConstants.COMPETITION_SPREAD_AQR_CODE + wxAppletsCodeVo.getScene()); - if(ObjectUtils.isEmpty(key)){ + if (ObjectUtils.isEmpty(key)) { wxAppletsCodeVo = wxApplesCodeService.genWxApplesAqrCode(wxAppletsCodeVo); - redisService.setCacheObject(CacheConstants.COMPETITION_SPREAD_AQR_CODE + wxAppletsCodeVo.getScene(),wxAppletsCodeVo.getCodeImgUrl(),30L, TimeUnit.DAYS); - }else { + redisService.setCacheObject(CacheConstants.COMPETITION_SPREAD_AQR_CODE + wxAppletsCodeVo.getScene(), wxAppletsCodeVo.getCodeImgUrl(), 30L, TimeUnit.DAYS); + } else { wxAppletsCodeVo.setCodeImgUrl((String) key); } return wxAppletsCodeVo; @@ -173,22 +166,37 @@ public class CompetitionServiceImpl extends ServiceImpl getCompetitionByCondition(CompetitionVo competition) { - return competitionMapper.getCompetitionByCondition(competition); + List 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 public CompetitionExcleVo getTeamEnrollExcleImpData(Long competitionId, Long userId) { CompetitionExcleVo excleVo = new CompetitionExcleVo(); Competition competition = competitionMapper.selectCompetitionById(competitionId); - if(ObjectUtil.isNull(competition)){ + if (ObjectUtil.isNull(competition)) { return excleVo; } //todo 获取球队数据 - CompetitionOfTeam team = competitionOfTeamMapper.selectOneByUserId(competitionId,String.valueOf(userId)); - if(ObjectUtil.isNull(team)){ + CompetitionOfTeam team = competitionOfTeamMapper.selectOneByUserId(competitionId, String.valueOf(userId)); + if (ObjectUtil.isNull(team)) { return excleVo; } - BeanUtil.copyProperties(competition,excleVo); + BeanUtil.copyProperties(competition, excleVo); excleVo.setOfTeam(team); //todo 查询球队队员数据 CompetitionMembers condtion = new CompetitionMembers(); @@ -202,15 +210,15 @@ public class CompetitionServiceImpl extends ServiceImpl membersList = competitionMembersMapper.getCompetitionMembersByCompetitionId(competition.getId()); - if(competition.getCompetitionNature().intValue()==0) { + if (competition.getCompetitionNature().intValue() == 0) { Map> groupByTeamIdMap = membersList.stream().collect(Collectors.groupingBy(CompetitionMembers::getCompetitionTeamId)); //查询主队下的队员信息 for (Map.Entry> entry : groupByTeamIdMap.entrySet()) { if (!StringUtils.isEmpty(competition.getMainTeamId()) && entry.getKey().equals(competition.getMainTeamId())) { @@ -221,14 +229,14 @@ public class CompetitionServiceImpl extends ServiceImpl teamIds =new ArrayList<>(); - if(!StringUtils.isEmpty(competition.getMainTeamId())) { + List teamIds = new ArrayList<>(); + if (!StringUtils.isEmpty(competition.getMainTeamId())) { teamIds.add(competition.getMainTeamId()); } - if(!StringUtils.isEmpty(competition.getGuestTeamId())) { + if (!StringUtils.isEmpty(competition.getGuestTeamId())) { teamIds.add(competition.getGuestTeamId()); } - if(teamIds.size()>0) { + if (teamIds.size() > 0) { List basketballTeamList = wxBasketballTeamMapper.selectBatchIds(teamIds); CompetitionTeamVsTeam competitionTeamVsTeam = new CompetitionTeamVsTeam(); for (WxBasketballTeam team : basketballTeamList) { @@ -256,26 +264,26 @@ public class CompetitionServiceImpl extends ServiceImpl existList = competitionMapper.selectCompetitionList( Competition.builder().competitionName(entity.getCompetitionName()).competitionNature(entity.getCompetitionNature()).build()); - if(existList.size()>0) { + List existList = competitionMapper.selectCompetitionList(Competition.builder().competitionName(entity.getCompetitionName()).competitionNature(entity.getCompetitionNature()).build()); + if (existList.size() > 0) { throw new ServiceException("当前赛会已存在,毋须重复提交!"); } //小程序-推送赛会通知给系统管理员。管理员好及时去审核赛会 List userRoles = userRoleMapper.selectUserRoleList(UserRole.builder().roleCode(UserRoles.ADMIN.code()).build()); List userIds = userRoles.stream().map(UserRole::getUserId).collect(Collectors.toList()); List managerUsers = wxUserMapper.listByIds(userIds); - if(!StringUtils.isEmpty(managerUsers)&&!StringUtils.isEmpty(managerUsers.size()>0)){ - for (WxUser managerUser:managerUsers){ - if(!StringUtils.isEmpty(managerUser.getOpenid())) { + if (!StringUtils.isEmpty(managerUsers) && !StringUtils.isEmpty(managerUsers.size() > 0)) { + for (WxUser managerUser : managerUsers) { + if (!StringUtils.isEmpty(managerUser.getOpenid())) { WxMssVo wxMssVo = new WxMssVo(); wxMssVo.setTemplate_id(WxAppletsTemplateIdsEnum.COMPETITION_SIGN_UP.getCode()); wxMssVo.setTouser(managerUser.getOpenid()); @@ -289,8 +297,8 @@ public class CompetitionServiceImpl extends ServiceImpl0){ - redisService.setCacheObject(Constants.COMPETITION_CREATE_KEY + DigestUtil.md5(entity.getCompetitionName().trim()),entity.getCompetitionName(),20L,TimeUnit.SECONDS); + if (competitionMapper.insertCompetition(entity) > 0) { + redisService.setCacheObject(Constants.COMPETITION_CREATE_KEY + DigestUtil.md5(entity.getCompetitionName().trim()), entity.getCompetitionName(), 20L, TimeUnit.SECONDS); } return Boolean.TRUE; } @@ -299,27 +307,27 @@ public class CompetitionServiceImpl extends ServiceImpl dbList = competitionMapper.selectCompetitionList(Competition.builder().competitionNature(entity.getCompetitionNature()) .competitionName(entity.getCompetitionName()).build()); - if(dbList.size()>0) { + if (dbList.size() > 0) { throw new ServiceException("当前赛会已存在,毋须重复提交!"); } //小程序-推送赛会通知给系统管理员。管理员好及时去审核赛会 List userRoles = userRoleMapper.selectUserRoleList(UserRole.builder().roleCode(UserRoles.ADMIN.code()).build()); List userIds = userRoles.stream().map(UserRole::getUserId).collect(Collectors.toList()); List managerUsers = wxUserMapper.listByIds(userIds); - if(!StringUtils.isEmpty(managerUsers)&&!StringUtils.isEmpty(managerUsers.size()>0)){ - for (WxUser managerUser:managerUsers){ - if(!StringUtils.isEmpty(managerUser.getOpenid())) { + if (!StringUtils.isEmpty(managerUsers) && !StringUtils.isEmpty(managerUsers.size() > 0)) { + for (WxUser managerUser : managerUsers) { + if (!StringUtils.isEmpty(managerUser.getOpenid())) { WxMssVo wxMssVo = new WxMssVo(); wxMssVo.setTemplate_id(WxAppletsTemplateIdsEnum.COMPETITION_SIGN_UP.getCode()); wxMssVo.setTouser(managerUser.getOpenid()); @@ -333,11 +341,11 @@ public class CompetitionServiceImpl extends ServiceImpl 0) { redisService.setCacheObject(Constants.COMPETITION_CREATE_KEY + DigestUtil.md5(entity.getCompetitionName().trim()), entity.getCompetitionName(), 20L, TimeUnit.SECONDS); } - }else { + } else { competitionMapper.updateCompetition(entity); } return Boolean.TRUE; @@ -345,16 +353,16 @@ public class CompetitionServiceImpl extends ServiceImpl getMyJoinCompetition(CompetitionVo competition) { - List list=competitionMapper.getMyJoinCompetition(competition); - for (Competition comp:list){ - if(competition.getCompetitionNature()==0){ + List list = competitionMapper.getMyJoinCompetition(competition); + for (Competition comp : list) { + if (competition.getCompetitionNature() == 0) { WxBasketballTeam mainTeam = wxBasketballTeamMapper.selectWxBasketballTeamById(comp.getMainTeamId()); - if(!org.springframework.util.ObjectUtils.isEmpty(mainTeam)) { + if (!org.springframework.util.ObjectUtils.isEmpty(mainTeam)) { comp.setMainTeamLogo(mainTeam.getTeamLogo()); } - if(comp.getGuestTeamId()!=null) { + if (comp.getGuestTeamId() != null) { WxBasketballTeam guestTeam = wxBasketballTeamMapper.selectWxBasketballTeamById(comp.getGuestTeamId()); - if(!org.springframework.util.ObjectUtils.isEmpty(guestTeam)) { + if (!org.springframework.util.ObjectUtils.isEmpty(guestTeam)) { comp.setGuestTeamLogo(guestTeam.getTeamLogo()); } } @@ -362,11 +370,12 @@ public class CompetitionServiceImpl extends ServiceImpl competitions = competitionMapper.selectCompetitionList(Competition.builder() @@ -374,11 +383,11 @@ public class CompetitionServiceImpl extends ServiceImpl0){ + if (competitions.size() > 0) { throw new ServiceException("当前约战数据已存在,毋须重复提交!"); } //获取场馆数据 - if(!StringUtils.isEmpty(entity.getBuildingId())){ + if (!StringUtils.isEmpty(entity.getBuildingId())) { WxBuildingInfo buildingInfo = wxBuildingInfoService.selectWxBuildingInfoById(entity.getBuildingId()); entity.setBuildingName(buildingInfo.getBuildingName()); entity.setCityCode(buildingInfo.getCityCode()); @@ -391,12 +400,12 @@ public class CompetitionServiceImpl extends ServiceImpl map = new HashMap<>(); - map.put("thing1",new TemplateDataVo(entity.getMainTeamName())); - map.put("thing2",new TemplateDataVo(entity.getGuestTeamName())); - map.put("thing3",new TemplateDataVo("您有新的约战信息,请在小程序中进行处理")); + map.put("thing1", new TemplateDataVo(entity.getMainTeamName())); + map.put("thing2", new TemplateDataVo(entity.getGuestTeamName())); + map.put("thing3", new TemplateDataVo("您有新的约战信息,请在小程序中进行处理")); wxMssVo.setData(map); wxAppletsService.pushOneUser(wxMssVo); } } - if(StringUtils.isEmpty(id)) { + if (StringUtils.isEmpty(id)) { //保存创建人到比赛参与人员表 CompetitionMembers competitionMembers = new CompetitionMembers(); competitionMembers.setCompetitionId(entity.getId()); @@ -439,6 +448,7 @@ public class CompetitionServiceImpl extends ServiceImpl maplist, Sheet sheet) { + public CompetitionExcleVo importExcleData(Long competitionId, Map maplist, Sheet sheet) { CompetitionExcleVo excleVo = new CompetitionExcleVo(); String time = new SimpleDateFormat("yyyy-MM-dd").format(new Date()); //System.out.println("获取到精确到日的时间格式为"+time); @@ -531,13 +541,13 @@ public class CompetitionServiceImpl extends ServiceImpl