From b5636e416a2fe029f96aec6ddfd3489394925b15 Mon Sep 17 00:00:00 2001
From: kimi <kimi42345@gmail.com>
Date: 星期二, 24 三月 2020 19:33:53 +0800
Subject: [PATCH] add 数据权限
---
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