|
@@ -64,8 +64,7 @@ public class TournamentTask {
|
|
|
LocalDateTime startTime = tournament.getStartTime().toInstant()
|
|
LocalDateTime startTime = tournament.getStartTime().toInstant()
|
|
|
.atZone(java.time.ZoneId.systemDefault())
|
|
.atZone(java.time.ZoneId.systemDefault())
|
|
|
.toLocalDateTime();
|
|
.toLocalDateTime();
|
|
|
-
|
|
|
|
|
- // 比较时间 当前比赛时间是 十一点开始 十一点十分在来跑到这个job 比赛则不能开始了
|
|
|
|
|
|
|
+ // 比较时间 当前比赛时间是 十一点开始 十一点十分在来跑到这个job 比赛则不能开始了
|
|
|
if (startTime.equals(LocalDateTime.now().withSecond(0).withNano(0))) {
|
|
if (startTime.equals(LocalDateTime.now().withSecond(0).withNano(0))) {
|
|
|
//操作级别历史记录
|
|
//操作级别历史记录
|
|
|
PhysicalTournamentLevelHistory history=new PhysicalTournamentLevelHistory();
|
|
PhysicalTournamentLevelHistory history=new PhysicalTournamentLevelHistory();
|
|
@@ -76,6 +75,7 @@ public class TournamentTask {
|
|
|
physicalTournamentRuntime.setCurrentLevelStartTime(new Date());
|
|
physicalTournamentRuntime.setCurrentLevelStartTime(new Date());
|
|
|
physicalTournamentRuntime.setLastLevelSwitchTime(new Date());
|
|
physicalTournamentRuntime.setLastLevelSwitchTime(new Date());
|
|
|
physicalTournamentRuntime.setPauseStatus(0L);
|
|
physicalTournamentRuntime.setPauseStatus(0L);
|
|
|
|
|
+ physicalTournamentRuntime.setTournamentBeginTime(new Date());
|
|
|
if(tournamentBlindStructuresVo!=null){
|
|
if(tournamentBlindStructuresVo!=null){
|
|
|
List<PhysicalBlindLevelsVo> physicalBlindLevelsVoList = physicalBlindLevelsMapper.selectPhysicalBlindLevelsInfoObj(tournamentBlindStructuresVo.getBlindStructureId());
|
|
List<PhysicalBlindLevelsVo> physicalBlindLevelsVoList = physicalBlindLevelsMapper.selectPhysicalBlindLevelsInfoObj(tournamentBlindStructuresVo.getBlindStructureId());
|
|
|
if(physicalBlindLevelsVoList!=null && physicalBlindLevelsVoList.size()>0){
|
|
if(physicalBlindLevelsVoList!=null && physicalBlindLevelsVoList.size()>0){
|
|
@@ -128,6 +128,7 @@ public class TournamentTask {
|
|
|
*/
|
|
*/
|
|
|
@Scheduled(fixedRate = 5000)
|
|
@Scheduled(fixedRate = 5000)
|
|
|
public void generateTournamentUpdateLevelAndStatusMaxNewTask() {
|
|
public void generateTournamentUpdateLevelAndStatusMaxNewTask() {
|
|
|
|
|
+ // todo 监控当前赛事是否到达指定级别的截止时间 到了则进行状态记录 是否需要增加字段 是否截止报名记录
|
|
|
List<PhysicalTournamentRuntimeVo> physicalTournamentRuntimeVoList = physicalTournamentRuntimeMapper.selectPhysicalTournamentRuntimeAllList("ONGOING");
|
|
List<PhysicalTournamentRuntimeVo> physicalTournamentRuntimeVoList = physicalTournamentRuntimeMapper.selectPhysicalTournamentRuntimeAllList("ONGOING");
|
|
|
for (PhysicalTournamentRuntimeVo runtime : physicalTournamentRuntimeVoList) {
|
|
for (PhysicalTournamentRuntimeVo runtime : physicalTournamentRuntimeVoList) {
|
|
|
// 跳过暂停赛事
|
|
// 跳过暂停赛事
|
|
@@ -135,7 +136,6 @@ public class TournamentTask {
|
|
|
Long currentLevelId = runtime.getCurrentLevelId();
|
|
Long currentLevelId = runtime.getCurrentLevelId();
|
|
|
PhysicalBlindLevelsVo currentLevel = physicalBlindLevelsMapper.selectPhysicalBlindLevelById(currentLevelId);
|
|
PhysicalBlindLevelsVo currentLevel = physicalBlindLevelsMapper.selectPhysicalBlindLevelById(currentLevelId);
|
|
|
if(currentLevel!= null){
|
|
if(currentLevel!= null){
|
|
|
-
|
|
|
|
|
PhysicalTournamentLevelAdjustmentVo adjustment=physicalTournamentLevelAdjustmentMapper.findByTournamentIdAndLevelId(runtime.getTournamentId(),runtime.getCurrentLevelId());
|
|
PhysicalTournamentLevelAdjustmentVo adjustment=physicalTournamentLevelAdjustmentMapper.findByTournamentIdAndLevelId(runtime.getTournamentId(),runtime.getCurrentLevelId());
|
|
|
Long effectiveDurationMinutes;
|
|
Long effectiveDurationMinutes;
|
|
|
if (adjustment != null) {
|
|
if (adjustment != null) {
|