|
|
@ -50,7 +50,7 @@ public class TaskOverdueHandler { |
|
|
|
if(CollectionUtil.isNotEmpty(taskEntitySet)) { |
|
|
|
if(CollectionUtil.isNotEmpty(taskEntitySet)) { |
|
|
|
taskEntitySet.forEach(operMaintenanceTaskEntity -> { |
|
|
|
taskEntitySet.forEach(operMaintenanceTaskEntity -> { |
|
|
|
OperMaintenanceTaskEntity taskEntity = taskService.getById(operMaintenanceTaskEntity.getId()); |
|
|
|
OperMaintenanceTaskEntity taskEntity = taskService.getById(operMaintenanceTaskEntity.getId()); |
|
|
|
if(StringUtil.isBlank(taskEntity.getFlowTaskName())) { |
|
|
|
if(Func.isEmpty(taskEntity) || StringUtil.isBlank(taskEntity.getFlowTaskName())) { |
|
|
|
redisTemplate.opsForZSet().remove(RedisKeyConstants.MAINTENANCE_TASK_DELAY_LIST,operMaintenanceTaskEntity); |
|
|
|
redisTemplate.opsForZSet().remove(RedisKeyConstants.MAINTENANCE_TASK_DELAY_LIST,operMaintenanceTaskEntity); |
|
|
|
} |
|
|
|
} |
|
|
|
//如果任务仍在待执行则自动结束
|
|
|
|
//如果任务仍在待执行则自动结束
|
|
|
|