@ -25,9 +25,7 @@ import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional ;
import javax.annotation.Resource ;
import java.util.ArrayList ;
import java.util.Arrays ;
import java.util.List ;
import java.util.* ;
import java.util.concurrent.atomic.AtomicInteger ;
/ * *
@ -137,12 +135,12 @@ public class CompeteTaskService implements ICompeteTaskService {
log . info ( "本项目参加的人数:{}" , playerIdOrTeamIdList ) ;
if ( CollectionUtil . isNotEmpty ( playerIdOrTeamIdList ) ) {
//计算场次
int order = ( int ) Math . ceil ( playerIdOrTeamIdList . size ( ) / projectConfig . getSiteNum ( ) ) ;
int order = ( int ) Math . ceil ( ( float ) playerIdOrTeamIdList . size ( ) / ( float ) projectConfig . getSiteNum ( ) ) ;
//计算每个场次时间
long projectStartTime = projectConfig . getStartTime ( ) ;
long orderTime = 0 ;
if ( order ! = 0 ) {
orderTime = ( long ) Math . floor ( ( projectConfig . getEndTime ( ) - projectStartTime ) / order ) ;
orderTime = ( long ) Math . floor ( ( ( float ) projectConfig . getEndTime ( ) - ( float ) projectStartTime ) / ( float ) order ) ;
} else {
log . info ( "场次为0的比赛:{}------{}" , project , projectConfig ) ;
}
@ -172,7 +170,12 @@ public class CompeteTaskService implements ICompeteTaskService {
JsonResponse < TaskVo . NormalTask > normalTaskJsonResponse = tallFeignClient . updataTask ( updateTaskInfo ) ;
log . info ( "修改tall的任务信息后返回:{}" , normalTaskJsonResponse ) ;
//失败return
if ( ObjectUtil . isNull ( normalTaskJsonResponse ) | | normalTaskJsonResponse . getCode ( ) ! = 200 ) {
if ( ObjectUtil . isNull ( normalTaskJsonResponse ) ) {
log . info ( "调用tall返回null" ) ;
return ;
}
if ( normalTaskJsonResponse . getCode ( ) ! = 200 ) {
log . info ( "调用tall异常后返回:{}" , normalTaskJsonResponse . getMsg ( ) ) ;
return ;
}
}
@ -192,7 +195,12 @@ public class CompeteTaskService implements ICompeteTaskService {
JsonResponse < TaskVo . NormalTask > normalTaskJsonResponse = tallFeignClient . saveTask ( addTask ) ;
//异常return
log . info ( "添加任务后返回:{}" , normalTaskJsonResponse ) ;
if ( ObjectUtil . isNull ( normalTaskJsonResponse ) | | normalTaskJsonResponse . getCode ( ) ! = 200 ) {
if ( ObjectUtil . isNull ( normalTaskJsonResponse ) ) {
log . info ( "调用tall返回null" ) ;
return ;
}
if ( normalTaskJsonResponse . getCode ( ) ! = 200 ) {
log . info ( "调用tall异常后返回:{}" , normalTaskJsonResponse . getMsg ( ) ) ;
return ;
}
TaskVo . NormalTask normalTask = normalTaskJsonResponse . getData ( ) ;
@ -423,40 +431,71 @@ public class CompeteTaskService implements ICompeteTaskService {
List < ProvinceCompeteVo . QueryJudgment > queryJudgmentList = competeJudgmentDao . queryJudgment ( param . getCompeteTimeId ( ) , param . getProjectId ( ) ) ;
if ( CollectionUtil . isNotEmpty ( queryJudgmentList ) ) {
queryJudgmentList . forEach ( projectJudgment - > {
// for(ProvinceCompeteVo.QueryJudgment projectJudgment : queryJudgmentList){
//裁判数量
int count = projectJudgment . getProjectType ( ) = = 0 ? 3 : 7 ;
for ( int i = 0 ; i < projectJudgment . getSiteNums ( ) ; i + + ) {
if ( i < projectJudgment . getSiteList ( ) . size ( ) ) {
ProvinceCompeteVo . ProjectSite siteJudgment = projectJudgment . getSiteList ( ) . get ( i ) ;
if ( CollectionUtil . isEmpty ( siteJudgment . getJudgmentList ( ) ) ) {
siteJudgment . setJudgmentList ( new ArrayList < > ( ) ) ;
Map < Integer , Integer > siteMap = new HashMap < > ( ) ;
Map < Integer , Integer > judgmentMap = new HashMap < > ( ) ;
projectJudgment . getSiteList ( ) . forEach ( site - > {
siteMap . put ( site . getSiteNum ( ) , site . getSiteNum ( ) ) ;
if ( CollectionUtil . isEmpty ( site . getJudgmentList ( ) ) ) {
site . setJudgmentList ( new ArrayList < > ( ) ) ;
} else {
site . getJudgmentList ( ) . forEach ( judgment - > judgmentMap . put ( judgment . getJudgmentNum ( ) , judgment . getJudgmentNum ( ) ) ) ;
}
for ( int j = 0 ; j < count ; j + + ) {
if ( judgmentMap . get ( j ) = = null ) {
ProvinceCompeteVo . SiteJudgment siteJudgment1 = new ProvinceCompeteVo . SiteJudgment ( ) ;
siteJudgment1 . setJudgmentNum ( j ) ;
site . getJudgmentList ( ) . add ( siteJudgment1 ) ;
}
int a = siteJudgment . getJudgmentList ( ) . size ( ) ;
for ( int j = 0 ; j < count - a ; j + + ) {
}
CollectionUtil . sort ( site . getJudgmentList ( ) , Comparator . comparingInt ( ProvinceCompeteVo . SiteJudgment : : getJudgmentNum ) ) ;
} ) ;
for ( int j = 0 ; j < projectJudgment . getSiteNums ( ) ; j + + ) {
if ( siteMap . get ( j + 1 ) = = null ) {
ProvinceCompeteVo . ProjectSite siteJudgment = new ProvinceCompeteVo . ProjectSite ( ) ;
siteJudgment . setSiteNum ( j + 1 ) ;
projectJudgment . getSiteList ( ) . add ( siteJudgment ) ;
for ( int x = 0 ; x < count ; x + + ) {
ProvinceCompeteVo . SiteJudgment siteJudgment1 = new ProvinceCompeteVo . SiteJudgment ( ) ;
siteJudgment1 . setJudgmentNum ( a + j ) ;
siteJudgment1 . setJudgmentNum ( x ) ;
siteJudgment . getJudgmentList ( ) . add ( siteJudgment1 ) ;
}
} else {
int a = projectJudgment . getSiteList ( ) . size ( ) ;
System . out . println ( "===========" + a ) ;
System . out . println ( "===========" + projectJudgment . getSiteNums ( ) ) ;
System . out . println ( "===========" + ( projectJudgment . getSiteNums ( ) - a ) ) ;
for ( int j = 0 ; j < projectJudgment . getSiteNums ( ) - a ; j + + ) {
ProvinceCompeteVo . ProjectSite siteJudgment = new ProvinceCompeteVo . ProjectSite ( ) ;
siteJudgment . setSiteNum ( a + j + 1 ) ;
projectJudgment . getSiteList ( ) . add ( siteJudgment ) ;
int b = siteJudgment . getJudgmentList ( ) . size ( ) ;
for ( int x = 0 ; x < count - b ; x + + ) {
ProvinceCompeteVo . SiteJudgment siteJudgment1 = new ProvinceCompeteVo . SiteJudgment ( ) ;
siteJudgment1 . setJudgmentNum ( b + x ) ;
siteJudgment . getJudgmentList ( ) . add ( siteJudgment1 ) ;
}
}
}
}
// }
//
// projectJudgment.getSiteList().forEach(site-> judgmentMap.put(site.getSiteNum(),site.getSiteNum()));
// for (int i = 0; i < projectJudgment.getSiteNums(); i++) {
// if (i < projectJudgment.getSiteList().size()) {
// ProvinceCompeteVo.ProjectSite siteJudgment = projectJudgment.getSiteList().get(i);
// if (CollectionUtil.isEmpty(siteJudgment.getJudgmentList())) {
// siteJudgment.setJudgmentList(new ArrayList<>());
// }else {
// siteJudgment.getJudgmentList().forEach(judgment -> siteMap.put(judgment.getJudgmentNum(),judgment.getJudgmentNum()));
// }
// for (int j = 0; j < count; j++) {
// if(siteMap.get(j) == null) {
// ProvinceCompeteVo.SiteJudgment siteJudgment1 = new ProvinceCompeteVo.SiteJudgment();
// siteJudgment1.setJudgmentNum(j);
// siteJudgment.getJudgmentList().add(siteJudgment1);
// }
// }
// CollectionUtil.sort(siteJudgment.getJudgmentList(), Comparator.comparingInt(ProvinceCompeteVo.SiteJudgment::getJudgmentNum));
// } else {
// int a = projectJudgment.getSiteList().size();
// for (int j = 0; j < projectJudgment.getSiteNums(); j++) {
// ProvinceCompeteVo.ProjectSite siteJudgment = new ProvinceCompeteVo.ProjectSite();
// siteJudgment.setSiteNum(a + j + 1);
// projectJudgment.getSiteList().add(siteJudgment);
// int b = siteJudgment.getJudgmentList().size();
// for (int x = 0; x < count - b; x++) {
// ProvinceCompeteVo.SiteJudgment siteJudgment1 = new ProvinceCompeteVo.SiteJudgment();
// siteJudgment1.setJudgmentNum(b + x);
// siteJudgment.getJudgmentList().add(siteJudgment1);
// }
// }
// }
// }
} ) ;
}
return queryJudgmentList ;
@ -532,7 +571,12 @@ public class CompeteTaskService implements ICompeteTaskService {
JsonResponse < MemberVo . RoleInfo > roleJsonResponse = tallFeignClient . saveRole ( saveRole ) ;
log . info ( "添加角色后返回:{}" , roleJsonResponse ) ;
//失败return
if ( ObjectUtil . isNull ( roleJsonResponse ) | | roleJsonResponse . getCode ( ) ! = 200 ) {
if ( ObjectUtil . isNull ( roleJsonResponse ) ) {
log . info ( "调用tall返回null" ) ;
return ;
}
if ( roleJsonResponse . getCode ( ) ! = 200 ) {
log . info ( "调用tall异常后返回:{}" , roleJsonResponse . getMsg ( ) ) ;
return ;
}
MemberVo . RoleInfo roleInfo = roleJsonResponse . getData ( ) ;
@ -554,37 +598,60 @@ public class CompeteTaskService implements ICompeteTaskService {
Long userId = null ;
//失败return
if ( ObjectUtil . isNull ( memberJsonResponse ) ) {
log . info ( "调用tall返回null" ) ;
return ;
}
if ( memberJsonResponse . getCode ( ) ! = 200 & & memberJsonResponse . getCode ( ) ! = 21 ) {
log . info ( "调用tall异常后返回:{}" , memberJsonResponse . getMsg ( ) ) ;
return ;
}
if ( roleJsonResponse . getCode ( ) = = 200 ) {
MemberVo . Member member = memberJsonResponse . getData ( ) ;
userId = member . getUserId ( ) ;
if ( ObjectUtil . isNotNull ( member ) ) {
userId = member . getUserId ( ) ;
}
}
//code等于21代表成员已存在
if ( memberJsonResponse . getCode ( ) = = 21 ) {
log . info ( "该成员已存在:{}" , memberJsonResponse . getMsg ( ) ) ;
//查询该手机号在项目内的成员的id
MemberRoleDto . GetMemberByPhone getMemberByPhone = new MemberRoleDto . GetMemberByPhone ( ) ;
getMemberByPhone . setProjectId ( tallProjectId ) ;
getMemberByPhone . setPhone ( judgmentInfo . getJudgmentPhone ( ) ) ;
getMemberByPhone . setToken ( token ) ;
log . info ( "查找该手机号以前的成员信息:{}" , judgmentInfo . getJudgmentPhone ( ) ) ;
JsonResponse < MemberVo . MemberList > memberListJsonResponse = tallFeignClient . queryMemberByPhone ( getMemberByPhone ) ;
if ( ObjectUtil . isNotNull ( memberListJsonResponse ) ) {
MemberVo . MemberList memberList = memberListJsonResponse . getData ( ) ;
if ( ObjectUtil . isNotN ull ( memberList ) ) {
memberId = memberList . getMemberId ( ) ;
}
log . info ( "查找该手机号以前的成员信息返回:{}" , memberListJsonResponse ) ;
//失败return
if ( ObjectUtil . isNull ( memberListJsonResponse ) ) {
log . info ( "调用tall返回null" ) ;
return ;
}
if ( memberListJsonResponse . getCode ( ) ! = 200 ) {
log . info ( "调用tall异常后返回:{}" , memberJsonResponse . getMsg ( ) ) ;
return ;
}
MemberVo . MemberList memberList = memberListJsonResponse . getData ( ) ;
if ( ObjectUtil . isNotNull ( memberList ) ) {
memberId = memberList . getMemberId ( ) ;
userId = memberList . getUserId ( ) ;
}
//将该成员添加至角色下
if ( ObjectUtil . isNotNull ( roleId ) & & ObjectUtil . isNotNull ( memberId ) ) {
MemberRoleDto . SaveMemberInRole saveMemberInRole = new MemberRoleDto . SaveMemberInRole ( ) ;
saveMemberInRole . setRoleId ( roleId ) ;
saveMemberInRole . setMemberId ( memberId ) ;
saveMemberInRole . setToken ( token ) ;
log . info ( "将该成员添加至角色内" ) ;
JsonResponse jsonResponse = tallFeignClient . saveMemberInRole ( saveMemberInRole ) ;
if ( ObjectUtil . isNull ( jsonResponse ) | | jsonResponse . getCode ( ) ! = 200 ) {
if ( ObjectUtil . isNull ( jsonResponse ) ) {
log . info ( "调用tall返回null" ) ;
return ;
}
if ( jsonResponse . getCode ( ) ! = 200 ) {
log . info ( "调用tall异常后返回:{}" , jsonResponse . getMsg ( ) ) ;
return ;
}
}
@ -610,7 +677,12 @@ public class CompeteTaskService implements ICompeteTaskService {
log . info ( "在tall内添加任务:{}" , addTask ) ;
JsonResponse < TaskVo . NormalTask > normalTaskJsonResponse = tallFeignClient . saveTask ( addTask ) ;
log . info ( "添加任务后返回:{}" , normalTaskJsonResponse ) ;
if ( ObjectUtil . isNull ( normalTaskJsonResponse ) | | normalTaskJsonResponse . getCode ( ) ! = 200 ) {
if ( ObjectUtil . isNull ( normalTaskJsonResponse ) ) {
log . info ( "调用tall返回null" ) ;
return ;
}
if ( normalTaskJsonResponse . getCode ( ) ! = 200 ) {
log . info ( "调用tall异常后返回:{}" , normalTaskJsonResponse . getMsg ( ) ) ;
return ;
}
if ( ObjectUtil . isNotNull ( normalTaskJsonResponse ) ) {
@ -624,7 +696,12 @@ public class CompeteTaskService implements ICompeteTaskService {
log . info ( "修改tall内任务插件配置:{}" , updatePluginConfig ) ;
JsonResponse < TaskVo . PluginVo > pluginVoJsonResponse = tallFeignClient . updatePluginConfig ( updatePluginConfig ) ;
log . info ( "修改任务插件配置后返回:{}" , pluginVoJsonResponse ) ;
if ( ObjectUtil . isNull ( pluginVoJsonResponse ) | | pluginVoJsonResponse . getCode ( ) ! = 200 ) {
if ( ObjectUtil . isNull ( pluginVoJsonResponse ) ) {
log . info ( "调用tall返回null" ) ;
return ;
}
if ( pluginVoJsonResponse . getCode ( ) ! = 200 ) {
log . info ( "调用tall异常后返回:{}" , pluginVoJsonResponse . getMsg ( ) ) ;
return ;
}
}