From d0451fdd55195901e65e5c4b3b64028a86f9e669 Mon Sep 17 00:00:00 2001
From: kimi42345 <kimi42345@outlook.com>
Date: 星期日, 22 三月 2020 22:10:54 +0800
Subject: [PATCH] no message
---
src/main/java/com/highdatas/mdm/service/impl/MaintainFieldServiceImpl.java | 20 ++++++++++++++++++++
1 files changed, 20 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/highdatas/mdm/service/impl/MaintainFieldServiceImpl.java b/src/main/java/com/highdatas/mdm/service/impl/MaintainFieldServiceImpl.java
index 9e22278..3c1f5bf 100644
--- a/src/main/java/com/highdatas/mdm/service/impl/MaintainFieldServiceImpl.java
+++ b/src/main/java/com/highdatas/mdm/service/impl/MaintainFieldServiceImpl.java
@@ -227,4 +227,24 @@
}
}
}
+
+ @Override
+ public int getUnFlowCount(String tableName, String userId) {
+ List<MaintainField> maintainFields = selectList(new EntityWrapper<MaintainField>().eq("table_name", tableName));
+ List<String> flowIdList = maintainFields.stream().filter(maintainField -> maintainField.getFlowId() != null).map(MaintainField::getFlowId).collect(Collectors.toList());
+ if (flowIdList.size() == 0) {
+ return 0;
+ }
+ List<Flows> flowsList = flowsService.selectBatchIds(flowIdList);
+ List<Flows> unFlowedList = flowsList.stream().filter(flows -> flows.getStatus().equals(ActivitiStatus.working) || flows.getStatus().equals(ActivitiStatus.refuse)).collect(Collectors.toList());
+ int cnt = 0;
+ for (Flows flows : unFlowedList) {
+ boolean nextAudit = flowsService.isNextAudit(flows, userId);
+ if (nextAudit) {
+
+ cnt++;
+ }
+ }
+ return cnt;
+ }
}
--
Gitblit v1.8.0