|
@@ -266,6 +266,72 @@ public class ProjectServiceImpl extends ServiceImpl<ProjectMapper, Project> impl
|
|
return httpRespMsg;
|
|
return httpRespMsg;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ public HttpRespMsg getProjectEstimatedWork(Integer pageIndex, Integer pageSize, Integer projectId, HttpServletRequest request) {
|
|
|
|
+ HttpRespMsg httpRespMsg = new HttpRespMsg();
|
|
|
|
+ //通过公司id获取该公司所有的项目列表
|
|
|
|
+ User user = userMapper.selectById(request.getHeader("Token"));
|
|
|
|
+ Integer companyId = user.getCompanyId();
|
|
|
|
+ //该公司下的allday
|
|
|
|
+ float allday=timeTypeMapper.selectOne(new QueryWrapper<TimeType>()
|
|
|
|
+ .eq("company_id",companyId)).getAllday();
|
|
|
|
+ //根据公司的id搜索该公司有哪些项目 20231108之前完成的不统计,状态为进行中/已完成
|
|
|
|
+ List<Project> selectList = projectMapper.selectList(new QueryWrapper<Project>().eq("company_id", companyId).in("status", 1, 2));
|
|
|
|
+ List<Integer> collectProjectIds = selectList.stream().map(Project::getId).collect(Collectors.toList());
|
|
|
|
+
|
|
|
|
+ IPage<Project> projectIPage = projectMapper.selectPage(new Page<>(pageIndex, pageSize), new QueryWrapper<Project>().in("id", collectProjectIds)
|
|
|
|
+ .isNull("finish_date").or().ge("finish_date", "2023-11-08").eq(projectId!=null,"project_id",projectId));
|
|
|
|
+
|
|
|
|
+ //查询到的project列表
|
|
|
|
+ List<Project> records = projectIPage.getRecords();
|
|
|
|
+ List<Integer> collectIds = records.stream().map(Project::getId).collect(Collectors.toList());
|
|
|
|
+
|
|
|
|
+ //根据查询道德project列表查询总的reporeList
|
|
|
|
+ List<Report> reportList = reportMapper.selectList(new QueryWrapper<Report>()
|
|
|
|
+ .in("project_id", collectIds));
|
|
|
|
+ //根据查询道德project列表查询总的task_groupList
|
|
|
|
+ List<TaskGroup> taskGroups = taskGroupMapper.selectList(new QueryWrapper<TaskGroup>()
|
|
|
|
+ .in("project_id", collectIds));
|
|
|
|
+
|
|
|
|
+ for (Project project : records) {
|
|
|
|
+ Double reallWorkTime = reportList.stream().filter(r -> r.getProjectId() .equals( project.getId()))
|
|
|
|
+ .mapToDouble(r->r.getWorkingTime()).sum();
|
|
|
|
+ String rWorkTime=reallWorkTime==null ? "0":reallWorkTime+"";
|
|
|
|
+ project.setReallyWorkTime(rWorkTime);
|
|
|
|
+ String pEstimatedWork=project.getManDay()==null ? 0*allday+"": project.getManDay()*allday+"";
|
|
|
|
+ project.setEstimatedWorkTime(pEstimatedWork);
|
|
|
|
+ List<TaskGroup> taskGroupCollect = taskGroups.stream().filter(t -> t.getProjectId() == project.getId())
|
|
|
|
+ .collect(Collectors.toList());
|
|
|
|
+
|
|
|
|
+ ArrayList<GroupEstimatedWorkVO> groupEstimatedWorkVOS = new ArrayList<>();
|
|
|
|
+
|
|
|
|
+ if (taskGroupCollect.size()>0){
|
|
|
|
+ List<Integer> groupIds = taskGroupCollect.stream().map(TaskGroup::getId).collect(Collectors.toList());
|
|
|
|
+ List<Report> getByProjectAndGroup = reportMapper.selectList(new QueryWrapper<Report>()
|
|
|
|
+ .eq("project_id", project.getId())
|
|
|
|
+ .in("group_id", groupIds));
|
|
|
|
+ for (TaskGroup taskGroup : taskGroupCollect) {
|
|
|
|
+ Double gReallWorkTime = getByProjectAndGroup.stream().filter(r -> r.getGroupId().equals( taskGroup.getId()))
|
|
|
|
+ .mapToDouble(r->r.getWorkingTime()).sum();
|
|
|
|
+ GroupEstimatedWorkVO groupEstimatedWorkVO = new GroupEstimatedWorkVO();
|
|
|
|
+ String grWorkTime=gReallWorkTime==null ? "0":gReallWorkTime+"";
|
|
|
|
+ String gEstimatedWork=taskGroup.getManDay()==null ? 0*allday+"": taskGroup.getManDay()*allday+"";
|
|
|
|
+
|
|
|
|
+ groupEstimatedWorkVO.setWorkTime(grWorkTime);
|
|
|
|
+ groupEstimatedWorkVO.setEstimatedWorkTime(gEstimatedWork);
|
|
|
|
+ groupEstimatedWorkVO.setId(taskGroup.getId());
|
|
|
|
+ groupEstimatedWorkVO.setGroupName(taskGroup.getName());
|
|
|
|
+
|
|
|
|
+ groupEstimatedWorkVOS.add(groupEstimatedWorkVO);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ project.setGroupEstimatedWorkVOList(groupEstimatedWorkVOS);
|
|
|
|
+ }
|
|
|
|
+ projectIPage.setRecords(records);
|
|
|
|
+
|
|
|
|
+ httpRespMsg.data=projectIPage;
|
|
|
|
+ return httpRespMsg;
|
|
|
|
+ }
|
|
|
|
+
|
|
//分页获取项目列表
|
|
//分页获取项目列表
|
|
@Override
|
|
@Override
|
|
@Transactional(readOnly = true)
|
|
@Transactional(readOnly = true)
|