|
|
@ -3,7 +3,9 @@ package com.ccsens.mt.service; |
|
|
|
import cn.hutool.core.collection.CollectionUtil; |
|
|
|
import cn.hutool.core.lang.Snowflake; |
|
|
|
import cn.hutool.core.util.ObjectUtil; |
|
|
|
import com.ccsens.cloudutil.bean.tall.dto.MemberRoleDto; |
|
|
|
import com.ccsens.cloudutil.bean.tall.dto.TallTaskDto; |
|
|
|
import com.ccsens.cloudutil.bean.tall.vo.MemberVo; |
|
|
|
import com.ccsens.cloudutil.bean.tall.vo.TaskVo; |
|
|
|
import com.ccsens.cloudutil.feign.TallFeignClient; |
|
|
|
import com.ccsens.mt.bean.dto.CompeteDto; |
|
|
@ -23,6 +25,7 @@ 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.concurrent.atomic.AtomicInteger; |
|
|
|
|
|
|
@ -69,7 +72,7 @@ public class CompeteTaskService implements ICompeteTaskService{ |
|
|
|
* 修改项目的日程配置 |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
public List<TableVo.CompeteProjectConfig> updateCompeteProjectConfig(ProvinceCompeteDto.UpdateCompeteProjectConfig param) { |
|
|
|
public List<TableVo.CompeteProjectConfig> updateCompeteProjectConfig(ProvinceCompeteDto.UpdateCompeteProjectConfig param,String token) { |
|
|
|
//获取比赛类型
|
|
|
|
AtomicInteger type = new AtomicInteger(); |
|
|
|
if(CollectionUtil.isNotEmpty(param.getUpdateCompeteTaskList())){ |
|
|
@ -89,8 +92,8 @@ public class CompeteTaskService implements ICompeteTaskService{ |
|
|
|
competeProjectConfig = projectConfigList.get(0); |
|
|
|
competeProjectConfig.setProjectDuration(projectConfig.getDuration()); |
|
|
|
competeProjectConfig.setSiteNum(projectConfig.getSiteNum()); |
|
|
|
competeProjectConfig.setStartTime(projectConfig.getStartTime()); |
|
|
|
competeProjectConfig.setEndTime(projectConfig.getEndTime()); |
|
|
|
competeProjectConfig.setStartTime(projectConfig.getStartTime() == null ? 0 : projectConfig.getStartTime()); |
|
|
|
competeProjectConfig.setEndTime(projectConfig.getEndTime() == null ? 0 : projectConfig.getEndTime()); |
|
|
|
projectConfigDao.updateByPrimaryKeySelective(competeProjectConfig); |
|
|
|
}else { |
|
|
|
//没有则添加
|
|
|
@ -99,12 +102,12 @@ public class CompeteTaskService implements ICompeteTaskService{ |
|
|
|
competeProjectConfig.setProjectId(projectConfig.getProjectId()); |
|
|
|
competeProjectConfig.setProjectDuration(projectConfig.getDuration()); |
|
|
|
competeProjectConfig.setSiteNum(projectConfig.getSiteNum()); |
|
|
|
competeProjectConfig.setStartTime(projectConfig.getStartTime()); |
|
|
|
competeProjectConfig.setEndTime(projectConfig.getEndTime()); |
|
|
|
competeProjectConfig.setStartTime(projectConfig.getStartTime() == null ? 0 : projectConfig.getStartTime()); |
|
|
|
competeProjectConfig.setEndTime(projectConfig.getEndTime() == null ? 0 : projectConfig.getEndTime()); |
|
|
|
projectConfigDao.insertSelective(competeProjectConfig); |
|
|
|
} |
|
|
|
// TODO 生成出场顺序表,存入数据库。在tall内添加对应的任务
|
|
|
|
setStartOrder(competeProjectConfig,param.getProjectId()); |
|
|
|
// 生成出场顺序表,存入数据库。在tall内添加对应的任务
|
|
|
|
setStartOrder(competeProjectConfig,param.getProjectId(),param.getTallRoleId(),token); |
|
|
|
}); |
|
|
|
} |
|
|
|
return projectConfigDao.queryProjectConfig(type.get()); |
|
|
@ -112,7 +115,8 @@ public class CompeteTaskService implements ICompeteTaskService{ |
|
|
|
/** |
|
|
|
* 修改配置时生成出场顺序 |
|
|
|
*/ |
|
|
|
public void setStartOrder(CompeteProjectConfig projectConfig, Long tallProjectId) { |
|
|
|
public void setStartOrder(CompeteProjectConfig projectConfig, Long tallProjectId,Long tallRoleId,String token) { |
|
|
|
|
|
|
|
if (ObjectUtil.isNotNull(projectConfig)) { |
|
|
|
//查找项目
|
|
|
|
CompeteProject project = competeProjectDao.selectByPrimaryKey(projectConfig.getProjectId()); |
|
|
@ -125,10 +129,15 @@ public class CompeteTaskService implements ICompeteTaskService{ |
|
|
|
List<CompeteProjectPlayer> projectPlayerList = projectPlayerMapper.selectByExample(projectPlayerExample); |
|
|
|
if (CollectionUtil.isNotEmpty(projectPlayerList)) { |
|
|
|
//计算场次
|
|
|
|
int order = (int) Math.ceil(projectConfig.getSiteNum() / projectPlayerList.size()); |
|
|
|
int order = (int) Math.ceil(projectPlayerList.size() / projectConfig.getSiteNum()); |
|
|
|
//计算每个场次时间
|
|
|
|
long projectStartTime = projectConfig.getStartTime() + Constant.UPLOAD_VIDEO_TIME; |
|
|
|
long orderTime = (long) Math.floor((projectConfig.getEndTime() - projectStartTime) / order); |
|
|
|
long orderTime = 0; |
|
|
|
if(order != 0) { |
|
|
|
orderTime = (long) Math.floor((projectConfig.getEndTime() - projectStartTime) / order); |
|
|
|
}else { |
|
|
|
log.info("场次为0的比赛:{}------{}",project,projectConfig); |
|
|
|
} |
|
|
|
//场次
|
|
|
|
int competeOrder = 1; |
|
|
|
//场地
|
|
|
@ -144,12 +153,15 @@ public class CompeteTaskService implements ICompeteTaskService{ |
|
|
|
if(orderTime > 0 && (competeStartOrder.getStartTime() == projectStartTime || competeStartOrder.getEndTime() == projectStartTime + orderTime)){ |
|
|
|
competeStartOrder.setStartTime(projectStartTime); |
|
|
|
competeStartOrder.setEndTime(projectStartTime + orderTime); |
|
|
|
// TODO 修改tall的任务
|
|
|
|
// 修改tall的任务
|
|
|
|
TallTaskDto.UpdateTaskInfo updateTaskInfo = new TallTaskDto.UpdateTaskInfo(); |
|
|
|
updateTaskInfo.setId(competeStartOrder.getId()); |
|
|
|
updateTaskInfo.setBeginTime(competeStartOrder.getId()); |
|
|
|
updateTaskInfo.setBeginTime(competeStartOrder.getEndTime()); |
|
|
|
updateTaskInfo.setToken(token); |
|
|
|
log.info("修改tall的任务信息:{}",updateTaskInfo); |
|
|
|
tallFeignClient.updataTask(updateTaskInfo); |
|
|
|
log.info("修改tall的任务信息后返回:{}",updateTaskInfo); |
|
|
|
} |
|
|
|
startOrderMapper.updateByPrimaryKeySelective(competeStartOrder); |
|
|
|
|
|
|
@ -161,8 +173,11 @@ public class CompeteTaskService implements ICompeteTaskService{ |
|
|
|
addTask.setTaskName(project.getName() + competeOrder +"-" + site); |
|
|
|
addTask.setBeginTime(projectStartTime); |
|
|
|
addTask.setEndTime(projectStartTime + orderTime); |
|
|
|
addTask.setExecutorId(1L); |
|
|
|
addTask.setExecutorId(tallRoleId); |
|
|
|
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)) { |
|
|
@ -197,10 +212,16 @@ public class CompeteTaskService implements ICompeteTaskService{ |
|
|
|
List<CompeteTeam> teamList = competeTeamDao.selectByExample(teamExample); |
|
|
|
if(CollectionUtil.isNotEmpty(teamList)){ |
|
|
|
//计算场次
|
|
|
|
int order = (int) Math.ceil(projectConfig.getSiteNum() / teamList.size()); |
|
|
|
int order = (int) Math.ceil(teamList.size() / projectConfig.getSiteNum()); |
|
|
|
//计算每个场次时间
|
|
|
|
long projectStartTime = projectConfig.getStartTime() + Constant.UPLOAD_VIDEO_TIME; |
|
|
|
long orderTime = (long) Math.floor((projectConfig.getEndTime() - projectStartTime) / order); |
|
|
|
long orderTime = 0; |
|
|
|
if(order != 0) { |
|
|
|
orderTime = (long) Math.floor((projectConfig.getEndTime() - projectStartTime) / order); |
|
|
|
}else { |
|
|
|
log.info("场次为0的比赛:{}------{}",project,projectConfig); |
|
|
|
} |
|
|
|
// long orderTime = (long) Math.floor((projectConfig.getEndTime() - projectStartTime) / order);
|
|
|
|
//场次
|
|
|
|
int competeOrder = 1; |
|
|
|
//场地
|
|
|
@ -216,12 +237,15 @@ public class CompeteTaskService implements ICompeteTaskService{ |
|
|
|
if(orderTime > 0 && (competeStartOrder.getStartTime() == projectStartTime || competeStartOrder.getEndTime() == projectStartTime + orderTime)){ |
|
|
|
competeStartOrder.setStartTime(projectStartTime); |
|
|
|
competeStartOrder.setEndTime(projectStartTime + orderTime); |
|
|
|
// TODO 修改tall的任务
|
|
|
|
//修改tall的任务
|
|
|
|
TallTaskDto.UpdateTaskInfo updateTaskInfo = new TallTaskDto.UpdateTaskInfo(); |
|
|
|
updateTaskInfo.setId(competeStartOrder.getId()); |
|
|
|
updateTaskInfo.setBeginTime(competeStartOrder.getId()); |
|
|
|
updateTaskInfo.setBeginTime(competeStartOrder.getEndTime()); |
|
|
|
updateTaskInfo.setToken(token); |
|
|
|
log.info("修改tall的任务信息:{}",updateTaskInfo); |
|
|
|
tallFeignClient.updataTask(updateTaskInfo); |
|
|
|
log.info("修改tall的任务信息后返回:{}",updateTaskInfo); |
|
|
|
} |
|
|
|
startOrderMapper.updateByPrimaryKeySelective(competeStartOrder); |
|
|
|
|
|
|
@ -233,8 +257,11 @@ public class CompeteTaskService implements ICompeteTaskService{ |
|
|
|
addTask.setTaskName(project.getName() + competeOrder +"-" + site); |
|
|
|
addTask.setBeginTime(projectStartTime); |
|
|
|
addTask.setEndTime(projectStartTime + orderTime); |
|
|
|
addTask.setExecutorId(1L); |
|
|
|
addTask.setExecutorId(tallRoleId); |
|
|
|
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)) { |
|
|
@ -280,16 +307,217 @@ public class CompeteTaskService implements ICompeteTaskService{ |
|
|
|
* 查看裁判分配信息 |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
public List<ProvinceCompeteVo.QueryJudgment> queryJudgment(CompeteDto.CompeteTime param) { |
|
|
|
return 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 -> { |
|
|
|
//裁判数量
|
|
|
|
int count = 0; |
|
|
|
|
|
|
|
if(CollectionUtil.isNotEmpty(projectJudgment.getSiteList())){ |
|
|
|
for(ProvinceCompeteVo.ProjectSite siteJudgment : projectJudgment.getSiteList()) { |
|
|
|
if(projectJudgment.getProjectType() == 0){ |
|
|
|
count = 3; |
|
|
|
}else { |
|
|
|
count = 7; |
|
|
|
} |
|
|
|
if (CollectionUtil.isEmpty(siteJudgment.getJudgmentList())) { |
|
|
|
siteJudgment.setJudgmentList(new ArrayList<>()); |
|
|
|
} |
|
|
|
int a = siteJudgment.getJudgmentList().size(); |
|
|
|
for (int i = 0; i < count - a; i++) { |
|
|
|
ProvinceCompeteVo.SiteJudgment siteJudgment1 = new ProvinceCompeteVo.SiteJudgment(); |
|
|
|
siteJudgment1.setJudgmentNum(a + i); |
|
|
|
siteJudgment.getJudgmentList().add(siteJudgment1); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
}); |
|
|
|
} |
|
|
|
return queryJudgmentList; |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 分配裁判 |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
public List<ProvinceCompeteVo.QueryJudgment> allocationJudgment(ProvinceCompeteDto.AllocationJudgment param) { |
|
|
|
public List<ProvinceCompeteVo.QueryJudgment> allocationJudgment(ProvinceCompeteDto.AllocationJudgmentAndTall param,String token) { |
|
|
|
//查找项目
|
|
|
|
if(CollectionUtil.isNotEmpty(param.getAllocationJudgmentList())){ |
|
|
|
for(ProvinceCompeteDto.AllocationJudgment allocationJudgment : param.getAllocationJudgmentList()) { |
|
|
|
CompeteProject project = competeProjectDao.selectByPrimaryKey(allocationJudgment.getProjectId()); |
|
|
|
if (ObjectUtil.isNotNull(project)) { |
|
|
|
if (CollectionUtil.isNotEmpty(allocationJudgment.getSiteJudgmentList())) { |
|
|
|
allocationJudgment.getSiteJudgmentList().forEach(siteJudgment -> { |
|
|
|
if (ObjectUtil.isNotNull(siteJudgment)) { |
|
|
|
siteJudgment.getJudgmentInfoList().forEach(judgmentInfo -> { |
|
|
|
saveJudgmentAndTask(param.getCompeteTimeId(),param.getTallProjectId(), project, siteJudgment, judgmentInfo,token); |
|
|
|
}); |
|
|
|
} |
|
|
|
}); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
return competeJudgmentDao.queryJudgment(param.getCompeteTimeId(),null); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 添加裁判信息和tall内的角色成员任务 |
|
|
|
*/ |
|
|
|
private void saveJudgmentAndTask(Long competeTimeId,Long tallProjectId,CompeteProject project |
|
|
|
, ProvinceCompeteDto.SiteJudgment siteJudgment, ProvinceCompeteDto.JudgmentInfo judgmentInfo,String token) { |
|
|
|
// TODO 查找该手机号在此项目之前的裁判信息,修改,同时修改tall内的成员角色信息
|
|
|
|
//添加裁判信息
|
|
|
|
//查找该项目下的该场地的裁判信息
|
|
|
|
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 { |
|
|
|
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(); |
|
|
|
} |
|
|
|
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 null; |
|
|
|
return queryProjectByTall; |
|
|
|
} |
|
|
|
} |
|
|
|