diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/workbench/WorkbenchApprovalMessageServiceImpl.java b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/workbench/WorkbenchApprovalMessageServiceImpl.java index d25adf0..473b6fb 100644 --- a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/workbench/WorkbenchApprovalMessageServiceImpl.java +++ b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/workbench/WorkbenchApprovalMessageServiceImpl.java @@ -23,10 +23,7 @@ import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; -import java.util.ArrayList; -import java.util.Comparator; -import java.util.List; -import java.util.Objects; +import java.util.*; import java.util.stream.Collectors; /** @@ -61,14 +58,14 @@ List resultList = new ArrayList<>(); //审批消息 if(Objects.nonNull(request.getStatus()) && 0 == request.getStatus()){ - for (ApplyFromIdEnum applyFromIdEnum : ApplyFromIdEnum.values()) { + Arrays.stream(ApplyFromIdEnum.values()).parallel().forEach(applyFromIdEnum -> { if(StringUtils.isNotEmpty(request.getMessageSourceModule()) && !applyFromIdEnum.getSource().equals(request.getMessageSourceModule())){ - continue; + return; } List toBeApprovedList = baseApprovalService.getToBeApprovedList(applyFromIdEnum.getCode()); if(CollectionUtils.isEmpty(toBeApprovedList)){ - continue; + return; } toBeApprovedList.forEach(a -> { WorkbenchApprovalMessage message = new WorkbenchApprovalMessage(); @@ -80,7 +77,10 @@ message.setStatus(0);//待审批消息都是未读/未处理,处理后就不会在这个列表显示 resultList.add(message); }); - } + }); +// for (ApplyFromIdEnum applyFromIdEnum : ApplyFromIdEnum.values()) { +// +// } } //通知消息 QueryWrapper wrapper = new QueryWrapper<>();