Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public List<String> getProcessSubjectLoginsWithoutTask(String snID_Process_Activiti, String sFilterLoginRole) throws RecordInmemoryException, org.json.simple.parser.ParseException {
- LOG.info("getProcessSubjectLoginsWithoutTask started...").send();
- LOG.info("snID_Process_Activiti {}", snID_Process_Activiti).send();
- LOG.info("sFilterLoginRole {}", sFilterLoginRole).send();
- /* String sKeyMongo = (String) oRuntimeService.getVariable(snID_Process_Activiti, "sID_File_StorateTemp");
- byte[] aByteTaskBody = oBytesDataStaticStorage.getData(sKeyMongo);
- JSONParser parser = new JSONParser();
- List<String> aResultLogins = new ArrayList<>();
- if (aByteTaskBody != null) {
- JSONArray aJsonProcessSubject
- = (JSONArray) ((JSONObject) parser.parse(new String(aByteTaskBody))).get("aProcessSubject");
- LOG.info("aJsonProcessSubject in getProcessSubjectLoginsWithoutTask: {}",
- aJsonProcessSubject.toJSONString());
- for (Object oJsonProcessSubject : aJsonProcessSubject) {
- String sLogin = (String) ((JSONObject) oJsonProcessSubject).get("sLogin");
- aResultLogins.add(sLogin);
- }
- }*/
- Long nID_ProcessTask = (Long) oRuntimeService.getVariable(snID_Process_Activiti, PROCESS_TASK_VARIABLE);
- LOG.info("nID_ProcessTask={}", nID_ProcessTask).send();
- List<ProcessTaskSubject> aoProcessTaskSubject =
- oProcessTaskSubjectService.getProcessTaskSubjectsByProcessTask(nID_ProcessTask);
- LOG.info("Found {} ProcessTaskSubjects for nID_ProcessTask={}", aoProcessTaskSubject.size(),
- nID_ProcessTask).send();
- List<String> asResultLogin = aoProcessTaskSubject.stream()
- .filter(p -> Objects.isNull(p.getSnID_Process_Activiti()) ||
- snID_Process_Activiti.equals(p.getSnID_Process_Activiti()))
- .map(ProcessTaskSubject::getsLogin)
- .distinct()
- .sorted()
- .collect(Collectors.toList());
- LOG.info("asResultLogin: {}", asResultLogin).send();
- return asResultLogin;
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement