From 1698792d4299a0b81b9695d8a56e3d3088c7a7ee Mon Sep 17 00:00:00 2001
From: xiangpei <xiangpei@timesnew.cn>
Date: 星期一, 31 三月 2025 11:39:50 +0800
Subject: [PATCH] 超时计算排除节假日，超时统计调整
---
business/src/main/java/com/ycl/service/impl/ProjectProcessServiceImpl.java | 262 +++++++++++++++++++++++++++++++++++++---------------
1 files changed, 186 insertions(+), 76 deletions(-)
diff --git a/business/src/main/java/com/ycl/service/impl/ProjectProcessServiceImpl.java b/business/src/main/java/com/ycl/service/impl/ProjectProcessServiceImpl.java
index b6ed61c..c4fdcc2 100644
--- a/business/src/main/java/com/ycl/service/impl/ProjectProcessServiceImpl.java
+++ b/business/src/main/java/com/ycl/service/impl/ProjectProcessServiceImpl.java
@@ -13,6 +13,7 @@
import com.ycl.common.core.domain.entity.SysRole;
import com.ycl.common.core.domain.entity.SysUser;
import com.ycl.common.enums.business.*;
+import com.ycl.common.utils.DateUtils;
import com.ycl.common.utils.SecurityUtils;
import com.ycl.constant.TaskTypeConstant;
import com.ycl.domain.entity.*;
@@ -435,7 +436,7 @@
Long overtime = getTime(processCoding.getRedTime());
long durationTime = 0l;
if (Objects.nonNull(processCoding.getStartTaskTime())) {
- durationTime = ((new Date()).getTime() - processCoding.getStartTaskTime().getTime()) / 1000;
+ durationTime = DateUtils.getWorkingSed(processCoding.getStartTaskTime(), new Date());
}
if (overtime > durationTime) {
order.setNum((overtime - durationTime) / 3600);
@@ -1435,6 +1436,10 @@
jumpAndWaitTaskKeys.addAll(runtimeTaskKey);
hisTaskList = hisTaskList.stream().filter(hisTask -> jumpAndWaitTaskKeys.indexOf(hisTask.getTaskDefinitionKey()) == -1).collect(Collectors.toList());
List<String> hisTaskKeys = hisTaskList.stream().map(HistoricTaskInstance::getTaskDefinitionKey).distinct().collect(Collectors.toList());
+
+ if (CollectionUtils.isEmpty(hisTaskKeys)) {
+ return 0L;
+ }
Map<String, HistoricTaskInstance> hisTaskMap = hisTaskList.stream().collect(Collectors.toMap(HistoricTaskInstance::getTaskDefinitionKey, his -> his));
// 鏌ュ嚭鏃堕棿姝ｅ父鐨勪换鍔ey
List<ProcessCoding> codeList = new LambdaQueryChainWrapper<>(processCodingService.getBaseMapper())
@@ -1501,6 +1506,11 @@
jumpAndWaitTaskKeys.addAll(runtimeTaskKey);
hisTaskList = hisTaskList.stream().filter(hisTask -> jumpAndWaitTaskKeys.indexOf(hisTask.getTaskDefinitionKey()) == -1).collect(Collectors.toList());
List<String> hisTaskKeys = hisTaskList.stream().map(HistoricTaskInstance::getTaskDefinitionKey).distinct().collect(Collectors.toList());
+
+ if (CollectionUtils.isEmpty(hisTaskKeys)) {
+ result.total(0);
+ return new ArrayList<>();
+ }
Map<String, HistoricTaskInstance> hisTaskMap = hisTaskList.stream().collect(Collectors.toMap(HistoricTaskInstance::getTaskDefinitionKey, his -> his));
// 鏌ュ嚭鏃堕棿姝ｅ父鐨勪换鍔ey
List<ProcessCoding> codeList = new LambdaQueryChainWrapper<>(processCodingService.getBaseMapper())
@@ -1607,6 +1617,81 @@
}
/**
+ * 璁剧疆鍘嗗彶浠诲姟淇℃伅
+ *
+ * @param hisTask
+ * @param vo
+ * @param projectId
+ * @param processInsId
+ */
+ private void setHisTaskInfo(HistoricTaskInstance hisTask, CustomerTaskVO vo, String projectId, String processInsId) {
+ // 鏌ュ嚭娴佺▼
+ ProcessInstance process = runtimeService.createProcessInstanceQuery().processInstanceId(processInsId).singleResult();
+ String deployId = "";
+ String processName = "";
+ String processDefinitionId = "";
+ if (Objects.nonNull(process)) {
+ deployId = process.getDeploymentId();
+ processName = process.getProcessDefinitionName();
+ processDefinitionId = process.getProcessDefinitionId();
+ } else {
+ HistoricProcessInstance hisProcess = historyService.createHistoricProcessInstanceQuery().processInstanceId(processInsId).singleResult();
+ deployId = hisProcess.getDeploymentId();
+ processName = hisProcess.getProcessDefinitionName();
+ processDefinitionId = hisProcess.getProcessDefinitionId();
+ }
+
+ vo.setProcessInsId(processInsId);
+ vo.setProcessDefId(processDefinitionId);
+ vo.setDeployId(deployId);
+ vo.setTaskName(hisTask.getName());
+ vo.setProcessName(processName);
+
+ // 涓�涓换鍔″彲鑳芥湁澶氫釜鍊欓�変汉/缁勶紝鎵�浠ラ渶瑕佷娇鐢╨ist
+ List<Long> handlerIds = new ArrayList<>(2);
+ List<String> handlerNames = new ArrayList<>(2);
+ List<Long> handlerUnitIds = new ArrayList<>(2);
+ List<String> handlerUnitNames = new ArrayList<>(2);
+ List<String> promoterNames = new ArrayList<>(2);
+ List<String> promoterUnitNames = new ArrayList<>(2);
+ vo.setHandlerId(handlerIds);
+ vo.setHandlerName(handlerNames);
+ vo.setHandlerUnitId(handlerUnitIds);
+ vo.setHandlerUnitName(handlerUnitNames);
+ vo.setPromoterName(promoterNames);
+ vo.setPromoterUnitName(promoterUnitNames);
+ List<UserTask> targetUserTasks = this.getAllUserTaskElement(processDefinitionId).stream().filter(userTask -> hisTask.getTaskDefinitionKey().equals(userTask.getId())).collect(Collectors.toList());
+ UserTask userTask = null;
+ if (! CollectionUtils.isEmpty(targetUserTasks)) {
+ userTask = targetUserTasks.get(0);
+ }
+ this.setCandidateInfo(userTask, vo, projectId, processInsId);
+
+
+ vo.setTaskStatus(TaskStatusEnum.FINISHED);
+ // 濡傛灉鏄凡瀹屾垚鐨勶紝淇℃伅闇�瑕佸崟鐙祴鍊�
+ vo.setTaskId(hisTask.getId());
+ vo.setExecutionId(hisTask.getExecutionId());
+ vo.setCreateTime(hisTask.getStartTime());
+
+ // 鏌ヨ瀹為檯澶勭悊浜�
+ if (StringUtils.isNotBlank(hisTask.getAssignee())) {
+ long handlerUserId = Long.parseLong(hisTask.getAssignee());
+ SysUser handlerUser = sysUserService.selectUserById(handlerUserId);
+ if (Objects.nonNull(handlerUser)) {
+ vo.getHandlerId().add(handlerUserId);
+ vo.getHandlerName().add(this.getUserShowName(handlerUser));
+ if (Objects.nonNull(handlerUser.getDept())) {
+ vo.getHandlerUnitId().add(handlerUser.getDept().getDeptId());
+ vo.getHandlerUnitName().add(handlerUser.getDept().getDeptName());
+ }
+ }
+ }
+ vo.setTaskDefinitionKey(hisTask.getTaskDefinitionKey());
+ this.distinctVo(vo);
+ }
+
+ /**
* 鐢ㄦ埛鍚嶇О鍚庨潰璺熺數璇濆彿鐮�
*
* @param user
@@ -1655,36 +1740,16 @@
* @return
*/
private Long getOvertimeTaskNum(String processInsId) {
- // 鏌ュ嚭杩愯鍦ㄧ殑浠诲姟key
- List<Task> taskList = taskService.createTaskQuery().processInstanceId(processInsId).list();
-
- if (CollectionUtils.isEmpty(taskList)) {
+ // 鏌ュ嚭宸茶秴鏃剁殑浠诲姟id
+ List<ProcessCoding> overtimeRecords = new LambdaQueryChainWrapper<>(processCodingService.getBaseMapper())
+ .eq(ProcessCoding::getProcessInsId, processInsId)
+ .eq(ProcessCoding::getOvertimeStatus, ProcessOverTimeConstants.OVERTIME)
+ .orderByDesc(ProcessCoding::getGmtCreate)
+ .list();
+ if (CollectionUtils.isEmpty(overtimeRecords)) {
return 0L;
}
- List<String> taskKeys = taskList.stream().map(Task::getTaskDefinitionKey).distinct().collect(Collectors.toList());
- Map<String, Task> taskMap = taskList.stream().collect(Collectors.toMap(Task::getTaskDefinitionKey, his -> his));
- // 鏌ュ嚭鏁版嵁搴撶殑浠诲姟key
- List<ProcessCoding> codeList = new LambdaQueryChainWrapper<>(processCodingService.getBaseMapper())
- .eq(ProcessCoding::getProcessInsId, processInsId)
- .in(ProcessCoding::getTaskDefKey, taskKeys)
- .list();
- List<Task> tList = new ArrayList<>();
- // 鍒ゆ柇
- for (String key : taskMap.keySet()) {
- List<ProcessCoding> targetProcessCodings = codeList.stream().filter(code -> key.equals(code.getTaskDefKey())).collect(Collectors.toList());
- // 濡傛灉宸插畬鎴愮殑浠诲姟娌′粠鏁版嵁搴撴煡鎵惧嚭鏉ワ紝璇存槑璇ヤ换鍔℃病閰嶇疆璧嬬爜绛夋椂闂达紝鐩存帴璁剧疆涓烘寜鏃跺畬鎴�
- if (CollectionUtils.isEmpty(targetProcessCodings)) {
- tList.add(taskMap.get(key));
- } else {
- // 鎸夌収鏃堕棿闄嶅簭鎺掑垪
- targetProcessCodings.sort(Comparator.comparing(ProcessCoding::getGmtCreate).reversed());
- ProcessCoding latestProjectProcess = targetProcessCodings.get(0);
- if (Objects.nonNull(latestProjectProcess) && ProcessOverTimeConstants.OVERTIME.equals(latestProjectProcess.getOvertimeStatus())) {
- tList.add(taskMap.get(key));
- }
- }
- }
- return Long.valueOf(taskList.size());
+ return Long.valueOf(overtimeRecords.size());
}
/**
@@ -1703,63 +1768,108 @@
int startNum = pageSize * (pageNum - 1);
int endNum = startNum + pageSize;
- // 鏌ュ嚭杩愯鍦ㄧ殑浠诲姟key
- List<Task> taskList = new ArrayList<>(12);
- if (StringUtils.isNotBlank(taskName)) {
- taskList = taskService.createTaskQuery().processInstanceId(processInsId).taskNameLike(taskName).orderByTaskCreateTime().desc().list();
- } else {
- taskList = taskService.createTaskQuery().processInstanceId(processInsId).orderByTaskCreateTime().desc().list();
- }
- if (CollectionUtils.isEmpty(taskList)) {
+ // 鏌ュ嚭宸茶秴鏃剁殑浠诲姟id
+ List<ProcessCoding> overtimeRecords = new LambdaQueryChainWrapper<>(processCodingService.getBaseMapper())
+ .eq(ProcessCoding::getProcessInsId, processInsId)
+ .eq(ProcessCoding::getOvertimeStatus, ProcessOverTimeConstants.OVERTIME)
+ .orderByDesc(ProcessCoding::getGmtCreate)
+ .list();
+ if (CollectionUtils.isEmpty(overtimeRecords)) {
result.total(0);
return new ArrayList<>();
}
- List<String> taskKeys = taskList.stream().map(Task::getTaskDefinitionKey).distinct().collect(Collectors.toList());
- Map<String, Task> taskMap = taskList.stream().collect(Collectors.toMap(Task::getTaskDefinitionKey, his -> his));
- // 鏌ュ嚭鏁版嵁搴撶殑浠诲姟key
- List<ProcessCoding> codeList = new LambdaQueryChainWrapper<>(processCodingService.getBaseMapper())
- .eq(ProcessCoding::getProcessInsId, processInsId)
- .in(ProcessCoding::getTaskDefKey, taskKeys)
- .list();
- List<Task> tList = new ArrayList<>();
- // 鍒ゆ柇
- for (String key : taskMap.keySet()) {
- List<ProcessCoding> targetProcessCodings = codeList.stream().filter(code -> key.equals(code.getTaskDefKey())).collect(Collectors.toList());
- // 濡傛灉宸插畬鎴愮殑浠诲姟娌′粠鏁版嵁搴撴煡鎵惧嚭鏉ワ紝璇存槑璇ヤ换鍔℃病閰嶇疆璧嬬爜绛夋椂闂达紝鐩存帴璁剧疆涓烘寜鏃跺畬鎴�
- if (CollectionUtils.isEmpty(targetProcessCodings)) {
- tList.add(taskMap.get(key));
- } else {
- // 鎸夌収鏃堕棿闄嶅簭鎺掑垪
- targetProcessCodings.sort(Comparator.comparing(ProcessCoding::getGmtCreate).reversed());
- ProcessCoding latestProjectProcess = targetProcessCodings.get(0);
- if (Objects.nonNull(latestProjectProcess) && ProcessOverTimeConstants.OVERTIME.equals(latestProjectProcess.getOvertimeStatus())) {
- tList.add(taskMap.get(key));
- }
- }
- }
-
- if (startNum >= tList.size()) {
+ if (startNum >= overtimeRecords.size()) {
// 濡傛灉璧峰绱㈠紩瓒呭嚭浜嗗垪琛ㄧ殑澶у皬锛岃繑鍥炰竴涓┖鍒楄〃
return new ArrayList<>();
}
- result.total(tList.size());
- int end = Math.min(endNum, tList.size());
- List<Task> pageTaskList = tList.subList(startNum, end);
- List<String> taskDefs = pageTaskList.stream().map(Task::getTaskDefinitionKey).collect(Collectors.toList());
- Map<String, Task> keyMap = pageTaskList.stream().collect(Collectors.toMap(Task::getTaskDefinitionKey, his -> his));
+ result.total(overtimeRecords.size());
+ int end = Math.min(endNum, overtimeRecords.size());
+ List<ProcessCoding> pageOvertimeRecords = overtimeRecords.subList(startNum, end);
- // 寰楀埌鐩爣浠诲姟瀵瑰簲鐨勫畾涔�
- List<UserTask> finishedUserTaskElement = this.getAllUserTaskElement(processDefinitionId).stream().filter(el -> taskDefs.contains(el.getId())).collect(Collectors.toList());
-
- // 鏌ヨ浠诲姟鐩稿叧淇℃伅
- List<CustomerTaskVO> vos = finishedUserTaskElement.stream().map(userTask -> {
- Task task = keyMap.get(userTask.getId());
+ List<CustomerTaskVO> vos = pageOvertimeRecords.stream().map(record -> {
CustomerTaskVO vo = new CustomerTaskVO();
- this.setRuntimeTaskInfo(task, vo, projectId);
- return vo;
- }).collect(Collectors.toList());
+ Task task = taskService.createTaskQuery().processInstanceId(processInsId).taskId(record.getTaskId()).singleResult();
+ if (Objects.nonNull(task)) {
+ this.setRuntimeTaskInfo(task, vo, projectId);
+ vo.setTaskStatus(TaskStatusEnum.OVER_TIME);
+ return vo;
+ } else {
+ List<HistoricTaskInstance> list = historyService.createHistoricTaskInstanceQuery()
+ .finished()
+ .processInstanceId(processInsId)
+ .taskId(record.getTaskId())
+ .orderByHistoricTaskInstanceStartTime()
+ .desc()
+ .list();
+ if (CollectionUtils.isEmpty(list)) {
+ return null;
+ }
+ List<HistoricTaskInstance> hisTask = this.distinctHisTask(list);
+ this.setHisTaskInfo(hisTask.get(0), vo, projectId, processInsId);
+ vo.setTaskStatus(TaskStatusEnum.OVER_TIME_FINISHED);
+ return vo;
+ }
+ }).filter(Objects::nonNull).collect(Collectors.toList());
result.data(vos);
return vos;
+
+// // 鏌ュ嚭杩愯鍦ㄧ殑浠诲姟key
+// List<Task> taskList = new ArrayList<>(12);
+// if (StringUtils.isNotBlank(taskName)) {
+// taskList = taskService.createTaskQuery().processInstanceId(processInsId).taskNameLike(taskName).orderByTaskCreateTime().desc().list();
+// } else {
+// taskList = taskService.createTaskQuery().processInstanceId(processInsId).orderByTaskCreateTime().desc().list();
+// }
+// if (CollectionUtils.isEmpty(taskList)) {
+// result.total(0);
+// return new ArrayList<>();
+// }
+// List<String> taskKeys = taskList.stream().map(Task::getTaskDefinitionKey).distinct().collect(Collectors.toList());
+// Map<String, Task> taskMap = taskList.stream().collect(Collectors.toMap(Task::getTaskDefinitionKey, his -> his));
+// // 鏌ュ嚭鏁版嵁搴撶殑浠诲姟key
+// List<ProcessCoding> codeList = new LambdaQueryChainWrapper<>(processCodingService.getBaseMapper())
+// .eq(ProcessCoding::getProcessInsId, processInsId)
+// .in(ProcessCoding::getTaskDefKey, taskKeys)
+// .list();
+// List<Task> tList = new ArrayList<>();
+// // 鍒ゆ柇
+// for (String key : taskMap.keySet()) {
+// List<ProcessCoding> targetProcessCodings = codeList.stream().filter(code -> key.equals(code.getTaskDefKey())).collect(Collectors.toList());
+// // 濡傛灉宸插畬鎴愮殑浠诲姟娌′粠鏁版嵁搴撴煡鎵惧嚭鏉ワ紝璇存槑璇ヤ换鍔℃病閰嶇疆璧嬬爜绛夋椂闂达紝鐩存帴璁剧疆涓烘寜鏃跺畬鎴�
+// if (CollectionUtils.isEmpty(targetProcessCodings)) {
+// tList.add(taskMap.get(key));
+// } else {
+// // 鎸夌収鏃堕棿闄嶅簭鎺掑垪
+// targetProcessCodings.sort(Comparator.comparing(ProcessCoding::getGmtCreate).reversed());
+// ProcessCoding latestProjectProcess = targetProcessCodings.get(0);
+// if (Objects.nonNull(latestProjectProcess) && ProcessOverTimeConstants.OVERTIME.equals(latestProjectProcess.getOvertimeStatus())) {
+// tList.add(taskMap.get(key));
+// }
+// }
+// }
+//
+// if (startNum >= tList.size()) {
+// // 濡傛灉璧峰绱㈠紩瓒呭嚭浜嗗垪琛ㄧ殑澶у皬锛岃繑鍥炰竴涓┖鍒楄〃
+// return new ArrayList<>();
+// }
+// result.total(tList.size());
+// int end = Math.min(endNum, tList.size());
+// List<Task> pageTaskList = tList.subList(startNum, end);
+// List<String> taskDefs = pageTaskList.stream().map(Task::getTaskDefinitionKey).collect(Collectors.toList());
+// Map<String, Task> keyMap = pageTaskList.stream().collect(Collectors.toMap(Task::getTaskDefinitionKey, his -> his));
+//
+// // 寰楀埌鐩爣浠诲姟瀵瑰簲鐨勫畾涔�
+// List<UserTask> finishedUserTaskElement = this.getAllUserTaskElement(processDefinitionId).stream().filter(el -> taskDefs.contains(el.getId())).collect(Collectors.toList());
+//
+// // 鏌ヨ浠诲姟鐩稿叧淇℃伅
+// List<CustomerTaskVO> vos = finishedUserTaskElement.stream().map(userTask -> {
+// Task task = keyMap.get(userTask.getId());
+// CustomerTaskVO vo = new CustomerTaskVO();
+// this.setRuntimeTaskInfo(task, vo, projectId);
+// return vo;
+// }).collect(Collectors.toList());
+// result.data(vos);
+// return vos;
}
/**
--
Gitblit v1.8.0