From 2ca28e0229212164d94a6f1f7c787e2706be4f8c Mon Sep 17 00:00:00 2001
From: wangzhijiang <1358525938@qq.com>
Date: Tue, 13 Jun 2023 11:33:24 +0800
Subject: [PATCH] =?UTF-8?q?=E6=89=8B=E6=9C=BA=E7=AB=AF-=E6=9F=A5=E8=AF=A2?=
 =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E7=BB=9F=E8=AE=A1=E6=8E=A5=E5=8F=A3-preHomo?=
 =?UTF-8?q?=E6=95=B0=E9=87=8F=E5=AE=8C=E5=96=84=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/TaskStatisticsServiceImpl.java       | 41 ++++++++++++++++++-
 1 file changed, 40 insertions(+), 1 deletion(-)

diff --git a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/phone/service/impl/TaskStatisticsServiceImpl.java b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/phone/service/impl/TaskStatisticsServiceImpl.java
index 7d89c4b30..94e4ddba0 100644
--- a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/phone/service/impl/TaskStatisticsServiceImpl.java
+++ b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/phone/service/impl/TaskStatisticsServiceImpl.java
@@ -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;
+    }
 }