|
|
@@ -46,30 +46,32 @@ public class WorkbenchManage { |
|
|
|
|
|
|
|
private final ProjectLibManage projectLibManage; |
|
|
|
|
|
|
|
public WorkbenchVO getWorkbenchData(Integer year){ |
|
|
|
public WorkbenchVO getWorkbenchData(Integer year) { |
|
|
|
WorkbenchVO res = new WorkbenchVO(); |
|
|
|
UserFullInfoDTO user = userInfoHelper.getUserFullInfo(LoginUserUtil.getUserId()); |
|
|
|
Long userId = LoginUserUtil.getUserId(); |
|
|
|
UserFullInfoDTO user = userInfoHelper.getUserFullInfo(userId); |
|
|
|
|
|
|
|
CompletableFuture.allOf( |
|
|
|
CompletableFuture.runAsync(()-> { |
|
|
|
CompletableFuture.runAsync(() -> { |
|
|
|
//1.待办中心数据 |
|
|
|
TodoCenterStatisticsVO statisticsVO = todoCenterManage.todoCenterStatistics(user.getEmployeeCode()); |
|
|
|
ToBeProcessedReq toBeProcessedReq = new ToBeProcessedReq(); |
|
|
|
toBeProcessedReq.setPageNumber(1); |
|
|
|
toBeProcessedReq.setPageSize(5); |
|
|
|
toBeProcessedReq.setLoginUserId(userId); |
|
|
|
toBeProcessedReq.setEmployeeCode(user.getEmployeeCode()); |
|
|
|
statisticsVO.setTodoList(todoCenterManage.todoProjectList(toBeProcessedReq).getRecords() |
|
|
|
.stream().map(WorkbenchConverter::convert).collect(Collectors.toList())); |
|
|
|
res.setTodoCerter(statisticsVO); |
|
|
|
}, ForkJoinPool.commonPool()), |
|
|
|
CompletableFuture.runAsync(()-> { |
|
|
|
CompletableFuture.runAsync(() -> { |
|
|
|
//2.项目统计数据 |
|
|
|
res.setOrgDeclared(WorkbenchConverter.convert(defaultDeclaredProjectManage.declaredProjectOrgStatistics(year,user))); |
|
|
|
if(userInfoHelper.isSuperOrRegionAdmin(user.getUserId())){ |
|
|
|
res.setRegionDeclared(WorkbenchConverter.convert(defaultDeclaredProjectManage.declaredProjectRegionStatistics(year,user))); |
|
|
|
res.setOrgDeclared(WorkbenchConverter.convert(defaultDeclaredProjectManage.declaredProjectOrgStatistics(year, user))); |
|
|
|
if (userInfoHelper.isSuperOrRegionAdmin(user.getUserId())) { |
|
|
|
res.setRegionDeclared(WorkbenchConverter.convert(defaultDeclaredProjectManage.declaredProjectRegionStatistics(year, user))); |
|
|
|
} |
|
|
|
}, ForkJoinPool.commonPool()), |
|
|
|
CompletableFuture.runAsync(()-> { |
|
|
|
CompletableFuture.runAsync(() -> { |
|
|
|
//3.所有公告按类型分 |
|
|
|
NoticeListReq noticeListReq = new NoticeListReq(); |
|
|
|
noticeListReq.setPageNumber(1); |
|
|
|