|
|
@@ -70,43 +70,45 @@ public class ComprehensiveStatisticsManagerImpl implements ComprehensiveStatisti
|
|
|
}
|
|
|
List<CostProjectTask> projectTasks = costProjectTaskManager.list(taskWrapper);
|
|
|
taskIds.addAll(projectTasks.stream().map(CostProjectTask::getId).distinct().collect(Collectors.toList()));
|
|
|
- List<CostSurveysVo> costSurveysVos= costSurveyTemplateUploadDataManager.analyze(taskIds);
|
|
|
- List<String> ids = costSurveysVos.stream().map(CostSurveysVo::getTaskId).distinct().collect(Collectors.toList());
|
|
|
+ if(!taskIds.isEmpty()){
|
|
|
+ List<CostSurveysVo> costSurveysVos= costSurveyTemplateUploadDataManager.analyze(taskIds);
|
|
|
+ List<String> ids = costSurveysVos.stream().map(CostSurveysVo::getTaskId).distinct().collect(Collectors.toList());
|
|
|
|
|
|
- List<CostSurveysVo> costSurveysVoList = new ArrayList<>();
|
|
|
- //根据任务进行重组数据
|
|
|
- List<CostSurveysVo> costSurveysVoArrayList = new ArrayList<>();
|
|
|
- ids.forEach(i->{
|
|
|
- List<CostSurveysVo> surveysVos = costSurveysVos.stream().filter(c -> c.getTaskId().equals(i)).collect(Collectors.toList());
|
|
|
- List<String> rowids = surveysVos.stream().map(CostSurveysVo::getRowid).distinct().collect(Collectors.toList());
|
|
|
- rowids.forEach(r->{
|
|
|
- List<CostSurveysVo> costSurveysVos1=surveysVos.stream().filter(v -> v.getRowid().equals(r)).collect(Collectors.toList());
|
|
|
- if (!costSurveysVos1.isEmpty()) {
|
|
|
- CostSurveysVo costSurveysVo1 = costSurveysVos1.get(0);
|
|
|
- List<SurveysVo> collect = costSurveysVos1.stream().map(csv -> {
|
|
|
- SurveysVo surveysVo = new SurveysVo();
|
|
|
- String nianfen = (String) csv.getNianfen();
|
|
|
- if (nianfen != null && nianfen.length() >= 4) {
|
|
|
- String year = nianfen.substring(0, 4);
|
|
|
- surveysVo.setName(year);// 2024, 2025, 2023
|
|
|
- }
|
|
|
- surveysVo.setValue(csv.getRvalue());
|
|
|
- return surveysVo;
|
|
|
- }).collect(Collectors.toList());
|
|
|
- costSurveysVo1.setSurveysVos(collect);
|
|
|
- costSurveysVo1.setNianfen(null);
|
|
|
- costSurveysVoArrayList.add(costSurveysVo1);
|
|
|
- }
|
|
|
- });
|
|
|
- List<CostSurveysVo> vos = costSurveysVoArrayList.stream().filter(c -> c.getParentId().equals("-1")).collect(Collectors.toList());
|
|
|
- vos.forEach(v->{
|
|
|
- List<CostSurveysVo> voList = costSurveysVoArrayList.stream().filter(su -> su.getParentId().equals(v.getRowid())).sorted(Comparator.comparing(CostSurveysVo::getOrderNum)).collect(Collectors.toList());
|
|
|
- v.setCostSurveysVos(voList);
|
|
|
- });
|
|
|
- costSurveysVoList.addAll(vos);
|
|
|
+ List<CostSurveysVo> costSurveysVoList = new ArrayList<>();
|
|
|
+ //根据任务进行重组数据
|
|
|
+ List<CostSurveysVo> costSurveysVoArrayList = new ArrayList<>();
|
|
|
+ ids.forEach(i->{
|
|
|
+ List<CostSurveysVo> surveysVos = costSurveysVos.stream().filter(c -> c.getTaskId().equals(i)).collect(Collectors.toList());
|
|
|
+ List<String> rowids = surveysVos.stream().map(CostSurveysVo::getRowid).distinct().collect(Collectors.toList());
|
|
|
+ rowids.forEach(r->{
|
|
|
+ List<CostSurveysVo> costSurveysVos1=surveysVos.stream().filter(v -> v.getRowid().equals(r)).collect(Collectors.toList());
|
|
|
+ if (!costSurveysVos1.isEmpty()) {
|
|
|
+ CostSurveysVo costSurveysVo1 = costSurveysVos1.get(0);
|
|
|
+ List<SurveysVo> collect = costSurveysVos1.stream().map(csv -> {
|
|
|
+ SurveysVo surveysVo = new SurveysVo();
|
|
|
+ String nianfen = (String) csv.getNianfen();
|
|
|
+ if (nianfen != null && nianfen.length() >= 4) {
|
|
|
+ String year = nianfen.substring(0, 4);
|
|
|
+ surveysVo.setName(year);// 2024, 2025, 2023
|
|
|
+ }
|
|
|
+ surveysVo.setValue(csv.getRvalue());
|
|
|
+ return surveysVo;
|
|
|
+ }).collect(Collectors.toList());
|
|
|
+ costSurveysVo1.setSurveysVos(collect);
|
|
|
+ costSurveysVo1.setNianfen(null);
|
|
|
+ costSurveysVoArrayList.add(costSurveysVo1);
|
|
|
+ }
|
|
|
+ });
|
|
|
+ List<CostSurveysVo> vos = costSurveysVoArrayList.stream().filter(c -> c.getParentId().equals("-1")).collect(Collectors.toList());
|
|
|
+ vos.forEach(v->{
|
|
|
+ List<CostSurveysVo> voList = costSurveysVoArrayList.stream().filter(su -> su.getParentId().equals(v.getRowid())).sorted(Comparator.comparing(CostSurveysVo::getOrderNum)).collect(Collectors.toList());
|
|
|
+ v.setCostSurveysVos(voList);
|
|
|
+ });
|
|
|
+ costSurveysVoList.addAll(vos);
|
|
|
|
|
|
- });
|
|
|
- comprehensiveStatisticsVo.setCostSurveysList(costSurveysVoList);
|
|
|
+ });
|
|
|
+ comprehensiveStatisticsVo.setCostSurveysList(costSurveysVoList);
|
|
|
+ }
|
|
|
return CommonResult.<ComprehensiveStatisticsVo>ok().value(comprehensiveStatisticsVo);
|
|
|
}
|
|
|
}
|