diff --git a/pmapi/src/main/java/com/ningdatech/pmapi/todocenter/manage/TodoCenterManage.java b/pmapi/src/main/java/com/ningdatech/pmapi/todocenter/manage/TodoCenterManage.java index d11230d..58e2f41 100644 --- a/pmapi/src/main/java/com/ningdatech/pmapi/todocenter/manage/TodoCenterManage.java +++ b/pmapi/src/main/java/com/ningdatech/pmapi/todocenter/manage/TodoCenterManage.java @@ -65,6 +65,7 @@ import org.flowable.bpmn.model.*; import org.flowable.engine.HistoryService; import org.flowable.engine.history.HistoricProcessInstance; import org.flowable.engine.runtime.ActivityInstance; +import org.mockito.internal.matchers.CompareTo; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Component; import org.springframework.transaction.annotation.Transactional; @@ -122,7 +123,27 @@ public class TodoCenterManage { } List instCodes = userTodoList.stream().map(ProcessTaskVo::getInstanceId).collect(Collectors.toList()); - Map taskVoMap = userTodoList.stream().collect(Collectors.toMap(ProcessTaskVo::getInstanceId, v -> v)); + List resList = new ArrayList<>(); + List instList = new ArrayList<>(); + for (ProcessTaskVo processTaskVo : userTodoList) { + Map map = resList.stream().collect(Collectors.toMap(ProcessTaskVo::getInstanceId, v -> v)); + if (instList.contains(processTaskVo.getInstanceId())){ + // 比较两个processTaskVo的endTime,保留最后处理的 + ProcessTaskVo vo = map.get(processTaskVo.getInstanceId()); + int compare = processTaskVo.getTaskEndTime().compareTo(vo.getTaskEndTime()); + if (compare > 0){ + instList.remove(processTaskVo.getInstanceId()); + resList.remove(vo); + }else { + continue; + } + } + instList.add(processTaskVo.getInstanceId()); + resList.add(processTaskVo); + } + + Map taskVoMap = resList.stream().collect(Collectors.toMap(ProcessTaskVo::getInstanceId, v -> v)); + //2.再分页查询项目信息 ProjectListReq projectListReq = new ProjectListReq(); projectListReq.setInstCodes(instCodes); @@ -620,10 +641,29 @@ public class TodoCenterManage { if (CollUtil.isEmpty(userIdoList)) { return PageVo.empty(); } + List instCodes = userIdoList.stream().map(ProcessTaskVo::getInstanceId).collect(Collectors.toList()); - Map taskVoMap = userIdoList.stream().collect(Collectors.toMap(ProcessTaskVo::getInstanceId, v -> v)); + List resList = new ArrayList<>(); + List instList = new ArrayList<>(); + for (ProcessTaskVo processTaskVo : userIdoList) { + Map map = resList.stream().collect(Collectors.toMap(ProcessTaskVo::getInstanceId, v -> v)); + if (instList.contains(processTaskVo.getInstanceId())){ + // 比较两个processTaskVo的endTime,保留最后处理的 + ProcessTaskVo vo = map.get(processTaskVo.getInstanceId()); + int compare = processTaskVo.getTaskEndTime().compareTo(vo.getTaskEndTime()); + if (compare > 0){ + instList.remove(processTaskVo.getInstanceId()); + resList.remove(vo); + }else { + continue; + } + } + instList.add(processTaskVo.getInstanceId()); + resList.add(processTaskVo); + } + Map taskVoMap = resList.stream().collect(Collectors.toMap(ProcessTaskVo::getInstanceId, v -> v)); // 分页查询项目信息 ProjectListReq projectListReq = new ProjectListReq(); projectListReq.setInstCodes(instCodes);