no message

kimi42345

2020-03-23 5bac93baf5659ce013163f884c9dce41990a860e

 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;
    }
}