手机端-查询任务统计接口-preHomo数量完善。

This commit is contained in:
wangzhijiang
2023-06-13 11:33:24 +08:00
parent eb7b8e7fa8
commit 2ca28e0229
@@ -71,7 +71,9 @@ public class TaskStatisticsServiceImpl implements ITaskStatisticsService {
List<ProcessInfoEO> preHomoList = piEoList.stream().filter(piEo -> {
return StringUtils.equals(piEo.getFlowType(), FlowTypeEnum.CERTIFICATION_LC.getValue());
}).collect(Collectors.toList());
preHomoCount = preHomoList.size();
if (CollectionUtils.isNotEmpty(preHomoList)) {
preHomoCount = this.getPreHomoCount(pidEoList, preHomoList);
}
List<ProcessInfoEO> technologyEvaluationList = piEoList.stream().filter(piEo -> {
return StringUtils.equals(piEo.getFlowType(), FlowTypeEnum.FGJSPG.getValue());
@@ -93,4 +95,41 @@ public class TaskStatisticsServiceImpl implements ITaskStatisticsService {
result.put("opinionCollectionCount", opinionCollectionCount);
return Result.OK(result);
}
private int getPreHomoCount(List<ProcessInfoDetailEO> pidEoList, List<ProcessInfoEO> preHomoList) {
int preHomoCount = 0;
for (ProcessInfoEO piEo : preHomoList) {
List<ProcessInfoDetailEO> pidEosTemp = pidEoList.stream().filter(pidEo -> {
boolean flag = false;
if (StringUtils.equals(piEo.getId(), pidEo.getProcessInfoId())) {
flag = true;
}
return flag;
}).collect(Collectors.toList());
if (CollectionUtils.isNotEmpty(pidEosTemp)) {
List<ProcessInfoDetailEO> zrrjsrwPidEos = pidEosTemp.stream().filter(pidEo -> {
return StringUtils.equals(pidEo.getTaskDefinitionKey(), CertificationFlowNodeEnum.ZRRJSRW.getKey());
}).collect(Collectors.toList());
if (CollectionUtils.isNotEmpty(zrrjsrwPidEos)) {
preHomoCount += 1;
}
List<ProcessInfoDetailEO> rzgcsscPidEos = pidEosTemp.stream().filter(pidEo -> {
return StringUtils.equals(pidEo.getTaskDefinitionKey(), CertificationFlowNodeEnum.RZGCSSC.getKey());
}).collect(Collectors.toList());
if (CollectionUtils.isNotEmpty(rzgcsscPidEos)) {
preHomoCount += 1;
}
List<ProcessInfoDetailEO> zrrtjrwPidEos = pidEosTemp.stream().filter(pidEo -> {
return StringUtils.equals(pidEo.getTaskDefinitionKey(), CertificationFlowNodeEnum.ZRRTJRW.getKey());
}).collect(Collectors.toList());
if (CollectionUtils.isNotEmpty(zrrtjrwPidEos)) {
preHomoCount += 1;
}
}
}
return preHomoCount;
}
}