diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/IBusProcessHistoryServiceImpl.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/IBusProcessHistoryServiceImpl.java index d9e4dd20..b6363be7 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/IBusProcessHistoryServiceImpl.java +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/IBusProcessHistoryServiceImpl.java @@ -9,6 +9,7 @@ import com.ydw.bat.wkflow.business_main.datas.entity.*; import com.ydw.bat.wkflow.business_main.datas.mapper.BusProcessHistoryMapper; import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessHistoryService; import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessNameService; +import com.ydw.bat.wkflow.util.enums.BussLibraryNodeKeyEnum; import com.ydw.bat.wkflow.util.enums.FlowTypeEnum; import com.ydw.bat.wkflow.util.enums.StandardCommentNewProcessNodeKeyEnum; import com.ydw.bat.wkflow.util.enums.TaskStatusEnum; @@ -38,7 +39,7 @@ public class IBusProcessHistoryServiceImpl extends ServiceImpl query.isNull(BusProcessHistory::getTaskId).eq(BusProcessHistory::getIsMany,"1").or().isNotNull(BusProcessHistory::getTaskId) + query -> query.isNull(BusProcessHistory::getTaskId).isNull(BusProcessHistory::getUserId).eq(BusProcessHistory::getIsMany,"1").or().isNotNull(BusProcessHistory::getTaskId) ); // bphQueryWrap.isNotNull("task_id"); List bphList = this.list(bphQueryWrap); @@ -57,14 +58,14 @@ public class IBusProcessHistoryServiceImpl extends ServiceImpl(){ - @Override - public int compare(BusProcessHistory o1, BusProcessHistory o2) { - return o2.getEndTime().compareTo(o1.getEndTime()); - } - }); +// Collections.sort(childList,new Comparator(){ +// @Override +// public int compare(BusProcessHistory o1, BusProcessHistory o2) { +// return o2.getEndTime().compareTo(o1.getEndTime()); +// } +// }); - endTime = childList.get(0).getEndTime(); + endTime = childList.get(childList.size()-1).getEndTime(); } String userNames = childList.stream().map(BusProcessHistory::getUserName).distinct().collect(Collectors.joining(",")); @@ -78,7 +79,17 @@ public class IBusProcessHistoryServiceImpl extends ServiceImpl results = new ArrayList<>(); + if (CollectionUtils.isNotEmpty(firstBphList)) { + results = firstBphList.stream().filter(bph -> { + boolean flag = false; + if (StringUtils.equals(bph.getIsMany(),"2") || (StringUtils.equals(bph.getIsMany(),"1") && CollectionUtils.isNotEmpty(bph.getChildren()))) { + flag = true; + } + return flag; + }).distinct().collect(Collectors.toList()); + } + return results; } @Override @@ -153,6 +164,8 @@ public class IBusProcessHistoryServiceImpl extends ServiceImpl> getQbzxdJsbzImgDataList(List bphList) { + List> result = new ArrayList<>(); + + for (BussLibraryNodeKeyEnum nodeKeyEnum : BussLibraryNodeKeyEnum.values()) { + Map tasksMap = this.getTasksMap( + bphList, + nodeKeyEnum.getValue(), + nodeKeyEnum.getLable() + ); + if (ObjectUtils.isNotEmpty(tasksMap)) { + result.add(tasksMap); + } + } + return result; + } private Map getTasksMap(List bphList,String taskKey,String taskKeyName) { Map tasksMap = new HashMap<>(); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/bussLibrary/BLApplicantAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/bussLibrary/BLApplicantAfter.java index c5021341..d2ffb64c 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/bussLibrary/BLApplicantAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/bussLibrary/BLApplicantAfter.java @@ -229,7 +229,7 @@ public class BLApplicantAfter implements TaskListener{ qbbxPBph.setId(qbbxPBphId); qbbxPBph.setActiProcInstId(delegateTask.getProcessInstanceId()); qbbxPBph.setTaskKey(BussLibraryNodeKeyEnum.BUSS_LIBRARY2.getValue()); - qbbxPBph.setFlowType(FlowTypeEnum.BZZQYJLC.getValue()); + qbbxPBph.setFlowType(FlowTypeEnum.QBZXD_JSBZ.getValue()); qbbxPBph.setOrderNum(BussLibraryNodeKeyEnum.BUSS_LIBRARY2.getOrderNum()); qbbxPBph.setIsSub("2"); qbbxPBph.setIsMany("1"); @@ -283,7 +283,7 @@ public class BLApplicantAfter implements TaskListener{ zqyjPBph.setId(zqyjPBphId); zqyjPBph.setActiProcInstId(delegateTask.getProcessInstanceId()); zqyjPBph.setTaskKey(BussLibraryNodeKeyEnum.BUSS_LIBRARY5.getValue()); - zqyjPBph.setFlowType(FlowTypeEnum.BZZQYJLC.getValue()); + zqyjPBph.setFlowType(FlowTypeEnum.QBZXD_JSBZ.getValue()); zqyjPBph.setOrderNum(BussLibraryNodeKeyEnum.BUSS_LIBRARY5.getOrderNum()); zqyjPBph.setIsSub("2"); zqyjPBph.setIsMany("1");