| | |
| | | public void expireTask() { |
| | | log.info("开始赋码"); |
| | | //当前正在运行的所有任务节点 |
| | | List<Task> taskList = taskService.createTaskQuery().list(); |
| | | List<Task> taskList = taskService.createTaskQuery().active().list(); |
| | | if (CollectionUtils.isEmpty(taskList)) return; |
| | | List<String> taskIds = taskList.stream().map(TaskInfo::getId).collect(Collectors.toList()); |
| | | //需要监控的赋码任务 |
| | |
| | | String overtimeStatus = NORMAL; |
| | | if (overtime != null && overtime !=0 && durationDay >= overtime) { |
| | | overtimeStatus = OVERTIME; // 如果超过办理期限 |
| | | } else if (overtime != null && overtime != 0 && durationDay >= (overtime - 12 * 60 * 60)) { |
| | | } |
| | | else if (overtime != null && overtime != 0 && durationDay >= (overtime - 12 * 60 * 60)) { |
| | | overtimeStatus = WILLOVERTIME; // 如果临期(固定超时前12小时为临期) |
| | | } |
| | | // else if (overtime != null && overtime != 0 && durationDay >= (overtime - 60)) { |
| | | // overtimeStatus = WILLOVERTIME; // 如果临期(固定超时前12小时为临期) |
| | | // } |
| | | List<String> processInsIds = map.get(status); |
| | | processInsIds.add(task.getProcessInstanceId()); |
| | | |
| | |
| | | hours = Integer.parseInt(timeArr[1]); |
| | | } |
| | | time = (days * 24L + hours) * 3600L; |
| | | // //分-秒 |
| | | // time= (days * 60L) + hours; |
| | | } |
| | | return time; |
| | | } |