|
|
|
@ -2031,7 +2031,7 @@ public class JobMainTask { |
|
|
|
private boolean isTaskSlotEmpty(String taskCode) { |
|
|
|
String taskCurrentCode = redisService.getCacheObjectOfTask(RedisConst.TASK_CURRENT_CODE, taskCode); |
|
|
|
Integer redisRecCnt = redisService.getCacheObjectOfTask(RedisConst.TASK_RECORD_CNT, taskCode); |
|
|
|
log.info(Color.YELLOW + "[JOB] TASK_CURRENT_CODE: {}, TASK_RECORD_CNT: {}" + Color.END, taskCurrentCode, redisRecCnt); |
|
|
|
log.debug(Color.YELLOW + "[JOB] TASK_CURRENT_CODE: {}, TASK_RECORD_CNT: {}" + Color.END, taskCurrentCode, redisRecCnt); |
|
|
|
return StringUtils.isEmpty(taskCurrentCode) || |
|
|
|
!StringUtils.isEmpty(taskCurrentCode) && (redisRecCnt == null || redisRecCnt == 0); |
|
|
|
} |
|
|
|
|