|
|
@ -307,8 +307,8 @@ public class CompeteTaskService implements ICompeteTaskService{ |
|
|
|
* 查看裁判分配信息 |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
public List<ProvinceCompeteVo.QueryJudgment> queryJudgment(CompeteDto.CompeteTime param) { |
|
|
|
List<ProvinceCompeteVo.QueryJudgment> queryJudgmentList = competeJudgmentDao.queryJudgment(param.getCompeteTimeId()); |
|
|
|
public List<ProvinceCompeteVo.QueryJudgment> queryJudgment(ProvinceCompeteDto.QueryJudgment param) { |
|
|
|
List<ProvinceCompeteVo.QueryJudgment> queryJudgmentList = competeJudgmentDao.queryJudgment(param.getCompeteTimeId(),param.getProjectId()); |
|
|
|
if(CollectionUtil.isNotEmpty(queryJudgmentList)){ |
|
|
|
queryJudgmentList.forEach(projectJudgment -> { |
|
|
|
//裁判数量
|
|
|
@ -359,7 +359,7 @@ public class CompeteTaskService implements ICompeteTaskService{ |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
return competeJudgmentDao.queryJudgment(param.getCompeteTimeId()); |
|
|
|
return competeJudgmentDao.queryJudgment(param.getCompeteTimeId(),null); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
@ -369,81 +369,155 @@ public class CompeteTaskService implements ICompeteTaskService{ |
|
|
|
, ProvinceCompeteDto.SiteJudgment siteJudgment, ProvinceCompeteDto.JudgmentInfo judgmentInfo,String token) { |
|
|
|
// TODO 查找该手机号在此项目之前的裁判信息,修改,同时修改tall内的成员角色信息
|
|
|
|
//添加裁判信息
|
|
|
|
CompeteJudgment competeJudgment = new CompeteJudgment(); |
|
|
|
competeJudgment.setId(snowflake.nextId()); |
|
|
|
competeJudgment.setName(judgmentInfo.getJudgmentName()); |
|
|
|
competeJudgment.setPhone(judgmentInfo.getJudgmentPhone()); |
|
|
|
competeJudgment.setRemark(judgmentInfo.getRemark()); |
|
|
|
competeJudgment.setCompeteTimeId(competeTimeId); |
|
|
|
competeJudgment.setProjectId(project.getId()); |
|
|
|
competeJudgment.setSite(siteJudgment.getSite()); |
|
|
|
competeJudgment.setChiefJudgment((byte) judgmentInfo.getJudgmentNum()); |
|
|
|
competeJudgmentDao.insertSelective(competeJudgment); |
|
|
|
//添加角色
|
|
|
|
MemberRoleDto.SaveRole saveRole = new MemberRoleDto.SaveRole(); |
|
|
|
saveRole.setProjectId(tallProjectId); |
|
|
|
String jdgmentNum = ""; |
|
|
|
if(judgmentInfo.getJudgmentNum() == 0){ |
|
|
|
jdgmentNum = "主裁判"; |
|
|
|
//查找该项目下的该场地的裁判信息
|
|
|
|
CompeteJudgment competeJudgment; |
|
|
|
CompeteJudgmentExample competeJudgmentExample = new CompeteJudgmentExample(); |
|
|
|
competeJudgmentExample.createCriteria().andProjectIdEqualTo(project.getId()).andCompeteTimeIdEqualTo(competeTimeId) |
|
|
|
.andSiteEqualTo(siteJudgment.getSite()).andChiefJudgmentEqualTo((byte) judgmentInfo.getJudgmentNum()); |
|
|
|
List<CompeteJudgment> competeJudgmentList = competeJudgmentDao.selectByExample(competeJudgmentExample); |
|
|
|
if(CollectionUtil.isNotEmpty(competeJudgmentList)){ |
|
|
|
competeJudgment = competeJudgmentList.get(0); |
|
|
|
competeJudgment.setName(judgmentInfo.getJudgmentName()); |
|
|
|
competeJudgment.setPhone(judgmentInfo.getJudgmentPhone()); |
|
|
|
competeJudgment.setRemark(judgmentInfo.getRemark()); |
|
|
|
competeJudgment.setCompeteTimeId(competeTimeId); |
|
|
|
competeJudgment.setProjectId(project.getId()); |
|
|
|
competeJudgment.setSite(siteJudgment.getSite()); |
|
|
|
competeJudgment.setChiefJudgment((byte) judgmentInfo.getJudgmentNum()); |
|
|
|
competeJudgmentDao.updateByPrimaryKeySelective(competeJudgment); |
|
|
|
//修改角色
|
|
|
|
//修改成员
|
|
|
|
//修改任务
|
|
|
|
}else { |
|
|
|
jdgmentNum = "裁判"+judgmentInfo.getJudgmentNum(); |
|
|
|
} |
|
|
|
saveRole.setRoleName(project.getName()+"-场地"+siteJudgment.getSite()+"-"+jdgmentNum); |
|
|
|
Long roleId = null; |
|
|
|
saveRole.setToken(token); |
|
|
|
log.info("在tall内添加角色:{}",saveRole); |
|
|
|
JsonResponse<MemberVo.RoleInfo> roleJsonResponse = tallFeignClient.saveRole(saveRole); |
|
|
|
log.info("添加角色后返回:{}",roleJsonResponse); |
|
|
|
if (ObjectUtil.isNotNull(roleJsonResponse)) { |
|
|
|
MemberVo.RoleInfo roleInfo = roleJsonResponse.getData(); |
|
|
|
if (ObjectUtil.isNotNull(roleInfo)) { |
|
|
|
roleId = roleInfo.getRoleId(); |
|
|
|
competeJudgment = new CompeteJudgment(); |
|
|
|
competeJudgment.setId(snowflake.nextId()); |
|
|
|
competeJudgment.setName(judgmentInfo.getJudgmentName()); |
|
|
|
competeJudgment.setPhone(judgmentInfo.getJudgmentPhone()); |
|
|
|
competeJudgment.setRemark(judgmentInfo.getRemark()); |
|
|
|
competeJudgment.setCompeteTimeId(competeTimeId); |
|
|
|
competeJudgment.setProjectId(project.getId()); |
|
|
|
competeJudgment.setSite(siteJudgment.getSite()); |
|
|
|
competeJudgment.setChiefJudgment((byte) judgmentInfo.getJudgmentNum()); |
|
|
|
competeJudgmentDao.insertSelective(competeJudgment); |
|
|
|
//添加角色
|
|
|
|
MemberRoleDto.SaveRole saveRole = new MemberRoleDto.SaveRole(); |
|
|
|
saveRole.setProjectId(tallProjectId); |
|
|
|
String jdgmentNum = ""; |
|
|
|
if (judgmentInfo.getJudgmentNum() == 0) { |
|
|
|
jdgmentNum = "主裁判"; |
|
|
|
} else { |
|
|
|
jdgmentNum = "裁判" + judgmentInfo.getJudgmentNum(); |
|
|
|
} |
|
|
|
} |
|
|
|
//添加成员
|
|
|
|
MemberRoleDto.SaveMember saveMember = new MemberRoleDto.SaveMember(); |
|
|
|
saveMember.setMemberName(judgmentInfo.getJudgmentName()); |
|
|
|
saveMember.setProjectId(tallProjectId); |
|
|
|
saveMember.setPhone(judgmentInfo.getJudgmentPhone()); |
|
|
|
saveMember.setRoleId(Arrays.asList(roleId)); |
|
|
|
saveMember.setToken(token); |
|
|
|
log.info("在tall内添加成员:{}",saveMember); |
|
|
|
JsonResponse<MemberVo.Member> memberJsonResponse = tallFeignClient.saveMember(saveMember); |
|
|
|
log.info("添加成员后返回:{}",memberJsonResponse); |
|
|
|
//添加任务
|
|
|
|
//查找场次信息表
|
|
|
|
CompeteStartOrderExample startOrderExample = new CompeteStartOrderExample(); |
|
|
|
startOrderExample.createCriteria().andProjectIdEqualTo(project.getId()) |
|
|
|
.andSiteEqualTo((byte) siteJudgment.getSite()); |
|
|
|
List<CompeteStartOrder> startOrderList = startOrderMapper.selectByExample(startOrderExample); |
|
|
|
if(CollectionUtil.isNotEmpty(startOrderList)){ |
|
|
|
for(CompeteStartOrder startOrder : startOrderList) { |
|
|
|
TallTaskDto.AddTask addTask = new TallTaskDto.AddTask(); |
|
|
|
addTask.setProjectId(tallProjectId); |
|
|
|
addTask.setTaskName(project.getName() + startOrder.getCompeteOrder() + "-" |
|
|
|
+ startOrder.getSite() + "-" + jdgmentNum); |
|
|
|
addTask.setBeginTime(startOrder.getStartTime()); |
|
|
|
addTask.setEndTime(startOrder.getEndTime()); |
|
|
|
addTask.setExecutorId(roleId); |
|
|
|
addTask.setParentTaskId(startOrder.getTaskId()); |
|
|
|
addTask.setToken(token); |
|
|
|
log.info("在tall内添加任务:{}",addTask); |
|
|
|
JsonResponse<TaskVo.NormalTask> normalTaskJsonResponse = tallFeignClient.saveTask(addTask); |
|
|
|
log.info("添加任务后返回:{}",normalTaskJsonResponse); |
|
|
|
if (ObjectUtil.isNotNull(normalTaskJsonResponse)) { |
|
|
|
TaskVo.NormalTask normalTask = normalTaskJsonResponse.getData(); |
|
|
|
if (ObjectUtil.isNotNull(normalTask)) { |
|
|
|
//修改任务插件配置信息
|
|
|
|
TallTaskDto.UpdatePluginConfig updatePluginConfig = new TallTaskDto.UpdatePluginConfig(); |
|
|
|
updatePluginConfig.setWebPath("/home/osct/video-score"); |
|
|
|
updatePluginConfig.setTaskId(normalTask.getDetailId()); |
|
|
|
updatePluginConfig.setToken(token); |
|
|
|
log.info("修改tall内任务插件配置:{}",updatePluginConfig); |
|
|
|
JsonResponse<TaskVo.PluginVo> pluginVoJsonResponse = tallFeignClient.updatePluginConfig(updatePluginConfig); |
|
|
|
log.info("修改任务插件配置后返回:{}",pluginVoJsonResponse); |
|
|
|
saveRole.setRoleName(project.getName() + "-场地" + siteJudgment.getSite() + "-" + jdgmentNum); |
|
|
|
Long roleId = null; |
|
|
|
saveRole.setToken(token); |
|
|
|
log.info("在tall内添加角色:{}", saveRole); |
|
|
|
JsonResponse<MemberVo.RoleInfo> roleJsonResponse = tallFeignClient.saveRole(saveRole); |
|
|
|
log.info("添加角色后返回:{}", roleJsonResponse); |
|
|
|
if (ObjectUtil.isNotNull(roleJsonResponse)) { |
|
|
|
MemberVo.RoleInfo roleInfo = roleJsonResponse.getData(); |
|
|
|
if (ObjectUtil.isNotNull(roleInfo)) { |
|
|
|
roleId = roleInfo.getRoleId(); |
|
|
|
} |
|
|
|
} |
|
|
|
//添加成员
|
|
|
|
MemberRoleDto.SaveMember saveMember = new MemberRoleDto.SaveMember(); |
|
|
|
saveMember.setMemberName(judgmentInfo.getJudgmentName()); |
|
|
|
saveMember.setProjectId(tallProjectId); |
|
|
|
saveMember.setPhone(judgmentInfo.getJudgmentPhone()); |
|
|
|
saveMember.setRoleId(Arrays.asList(roleId)); |
|
|
|
saveMember.setToken(token); |
|
|
|
log.info("在tall内添加成员:{}", saveMember); |
|
|
|
JsonResponse<MemberVo.Member> memberJsonResponse = tallFeignClient.saveMember(saveMember); |
|
|
|
log.info("添加成员后返回:{}", memberJsonResponse); |
|
|
|
//如果成员已存在,查询成员信息然后添加至角色内
|
|
|
|
Long memberId = null; |
|
|
|
if (ObjectUtil.isNotNull(memberJsonResponse)) { |
|
|
|
//code等于21代表成员已存在
|
|
|
|
if(memberJsonResponse.getCode() == 21){ |
|
|
|
//查询该手机号在项目内的成员的id
|
|
|
|
MemberRoleDto.GetMemberByPhone getMemberByPhone = new MemberRoleDto.GetMemberByPhone(); |
|
|
|
getMemberByPhone.setProjectId(tallProjectId); |
|
|
|
getMemberByPhone.setPhone(judgmentInfo.getJudgmentPhone()); |
|
|
|
getMemberByPhone.setToken(token); |
|
|
|
JsonResponse<MemberVo.MemberList> memberListJsonResponse = tallFeignClient.queryMemberByPhone(getMemberByPhone); |
|
|
|
if (ObjectUtil.isNotNull(memberListJsonResponse)) { |
|
|
|
MemberVo.MemberList memberList = memberListJsonResponse.getData(); |
|
|
|
if (ObjectUtil.isNotNull(memberList)) { |
|
|
|
memberId = memberList.getMemberId(); |
|
|
|
} |
|
|
|
} |
|
|
|
//将该成员添加至角色下
|
|
|
|
if(ObjectUtil.isNotNull(roleId) && ObjectUtil.isNotNull(memberId)){ |
|
|
|
MemberRoleDto.SaveMemberInRole saveMemberInRole = new MemberRoleDto.SaveMemberInRole(); |
|
|
|
saveMemberInRole.setRoleId(roleId); |
|
|
|
saveMemberInRole.setMemberId(memberId); |
|
|
|
saveMemberInRole.setToken(token); |
|
|
|
tallFeignClient.saveMemberInRole(saveMemberInRole); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
//添加任务
|
|
|
|
//查找场次信息表
|
|
|
|
CompeteStartOrderExample startOrderExample = new CompeteStartOrderExample(); |
|
|
|
startOrderExample.createCriteria().andProjectIdEqualTo(project.getId()) |
|
|
|
.andSiteEqualTo((byte) siteJudgment.getSite()); |
|
|
|
List<CompeteStartOrder> startOrderList = startOrderMapper.selectByExample(startOrderExample); |
|
|
|
if (CollectionUtil.isNotEmpty(startOrderList)) { |
|
|
|
for (CompeteStartOrder startOrder : startOrderList) { |
|
|
|
TallTaskDto.AddTask addTask = new TallTaskDto.AddTask(); |
|
|
|
addTask.setProjectId(tallProjectId); |
|
|
|
addTask.setTaskName(project.getName() + startOrder.getCompeteOrder() + "-" |
|
|
|
+ startOrder.getSite() + "-" + jdgmentNum); |
|
|
|
addTask.setBeginTime(startOrder.getStartTime()); |
|
|
|
addTask.setEndTime(startOrder.getEndTime()); |
|
|
|
addTask.setExecutorId(roleId); |
|
|
|
addTask.setParentTaskId(startOrder.getTaskId()); |
|
|
|
addTask.setToken(token); |
|
|
|
log.info("在tall内添加任务:{}", addTask); |
|
|
|
JsonResponse<TaskVo.NormalTask> normalTaskJsonResponse = tallFeignClient.saveTask(addTask); |
|
|
|
log.info("添加任务后返回:{}", normalTaskJsonResponse); |
|
|
|
if (ObjectUtil.isNotNull(normalTaskJsonResponse)) { |
|
|
|
TaskVo.NormalTask normalTask = normalTaskJsonResponse.getData(); |
|
|
|
if (ObjectUtil.isNotNull(normalTask)) { |
|
|
|
//修改任务插件配置信息
|
|
|
|
TallTaskDto.UpdatePluginConfig updatePluginConfig = new TallTaskDto.UpdatePluginConfig(); |
|
|
|
updatePluginConfig.setWebPath("/home/osct/video-score"); |
|
|
|
updatePluginConfig.setTaskId(normalTask.getDetailId()); |
|
|
|
updatePluginConfig.setToken(token); |
|
|
|
log.info("修改tall内任务插件配置:{}", updatePluginConfig); |
|
|
|
JsonResponse<TaskVo.PluginVo> pluginVoJsonResponse = tallFeignClient.updatePluginConfig(updatePluginConfig); |
|
|
|
log.info("修改任务插件配置后返回:{}", pluginVoJsonResponse); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 通过tall查看裁判和比赛项目的信息 |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
public ProvinceCompeteVo.QueryProjectByTall queryProjectByTall(ProvinceCompeteDto.ProjectByTall param) { |
|
|
|
//查询比赛项目信息
|
|
|
|
ProvinceCompeteVo.QueryProjectByTall queryProjectByTall = projectConfigDao.queryProjectByTaskDetailId(param.getTaskDetailId()); |
|
|
|
log.info("根据taskDetailId查询到的场次和项目信息:{}",queryProjectByTall); |
|
|
|
if(ObjectUtil.isNull(queryProjectByTall)){ |
|
|
|
queryProjectByTall = new ProvinceCompeteVo.QueryProjectByTall(); |
|
|
|
} |
|
|
|
//查询裁判信息
|
|
|
|
CompeteJudgment judgment = new CompeteJudgment(); |
|
|
|
CompeteJudgmentExample judgmentExample = new CompeteJudgmentExample(); |
|
|
|
judgmentExample.createCriteria().andRoleIdEqualTo(param.getRoleId()); |
|
|
|
List<CompeteJudgment> judgmentList = competeJudgmentDao.selectByExample(judgmentExample); |
|
|
|
if(CollectionUtil.isNotEmpty(judgmentList)){ |
|
|
|
judgment = judgmentList.get(0); |
|
|
|
log.info("根据roleId查询到的裁判信息:{}",judgment); |
|
|
|
queryProjectByTall.setJudgmentId(judgment.getId()); |
|
|
|
queryProjectByTall.setJudgmentNum(judgment.getChiefJudgment()); |
|
|
|
} |
|
|
|
|
|
|
|
return queryProjectByTall; |
|
|
|
} |
|
|
|
} |
|
|
|