|
@@ -235,7 +235,7 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
List<ProcessParamConfig> processParamConfigs = workflowSchemaConfig.getProcessConfig().getProcessParamConfigs();
|
|
|
|
|
|
long count = historyService.createHistoricProcessInstanceQuery().count();
|
|
|
- Map<String, Object> processParam = WorkFlowUtil.getProcessParam(processParamConfigs, workflowSchema, count + 1,null);
|
|
|
+ Map<String, Object> processParam = WorkFlowUtil.getProcessParam(processParamConfigs, workflowSchema, count + 1, null);
|
|
|
|
|
|
Map<String, Map<String, Object>> formAssignmentData = new HashMap<>();
|
|
|
|
|
@@ -1106,7 +1106,7 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
|
|
|
long count = historyService.createHistoricProcessInstanceQuery().count();
|
|
|
|
|
|
- Map<String, Object> processParam = WorkFlowUtil.getProcessParam(processParamConfigs, workflowSchema, count + 1,null);
|
|
|
+ Map<String, Object> processParam = WorkFlowUtil.getProcessParam(processParamConfigs, workflowSchema, count + 1, null);
|
|
|
|
|
|
|
|
|
|
|
@@ -1263,7 +1263,7 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
|
|
|
long count = historyService.createHistoricProcessInstanceQuery().count();
|
|
|
|
|
|
- Map<String, Object> processParam = WorkFlowUtil.getProcessParam(processParamConfigs, workflowSchema, count + 1,null);
|
|
|
+ Map<String, Object> processParam = WorkFlowUtil.getProcessParam(processParamConfigs, workflowSchema, count + 1, null);
|
|
|
|
|
|
|
|
|
|
|
@@ -1494,7 +1494,7 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
result.add(vo);
|
|
|
}
|
|
|
}
|
|
|
- if (StrUtil.isNotBlank(dto.getSerialNumber()) && !StrUtil.isNumeric(dto.getSerialNumber())){
|
|
|
+ if (StrUtil.isNotBlank(dto.getSerialNumber()) && !StrUtil.isNumeric(dto.getSerialNumber())) {
|
|
|
result.clear();
|
|
|
}
|
|
|
PageOutput<PendingTaskVo> output = new PageOutput<>();
|
|
@@ -1611,7 +1611,7 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
Map<String, Object> param = new HashMap<>();
|
|
|
param.put("language", buttonConfig.getScriptLanguage());
|
|
|
param.put("content", buttonConfig.getScriptContent());
|
|
|
- redisUtil.set(WorkflowConstant.BUTTON_EVENT_CACHE_PRE + task.getId(), param,10);
|
|
|
+ redisUtil.set(WorkflowConstant.BUTTON_EVENT_CACHE_PRE + task.getId(), param, 10);
|
|
|
}
|
|
|
|
|
|
|
|
@@ -1799,7 +1799,7 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
|
|
|
Object resultName = new Object();
|
|
|
|
|
|
- if (userTaskConfig.getCountersignConfig().getMultipleInstancesType() != WorkflowMultiInstanceType.NONE.getCode()){
|
|
|
+ if (userTaskConfig.getCountersignConfig().getMultipleInstancesType() != WorkflowMultiInstanceType.NONE.getCode()) {
|
|
|
resultName = runtimeService.getVariable(task.getProcessInstanceId(), resultVarName);
|
|
|
}
|
|
|
|
|
@@ -1831,7 +1831,7 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
invokeAutoAgree(task.getProcessInstanceId(), workflowSchema.getId(), workflowSchemaConfig, list);
|
|
|
|
|
|
|
|
|
- addWorkflowRecord(userTaskConfig, nextTaskNameList, user, record, oldTaskName, buttonConfig.getButtonName(), dto.getApprovedContent(), task,resultName);
|
|
|
+ addWorkflowRecord(userTaskConfig, nextTaskNameList, user, record, oldTaskName, buttonConfig.getButtonName(), dto.getApprovedContent(), task, resultName);
|
|
|
|
|
|
}
|
|
|
|
|
@@ -2145,7 +2145,7 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
|
|
|
Object resultName = new Object();
|
|
|
|
|
|
- if (userTaskConfig.getCountersignConfig().getMultipleInstancesType() != WorkflowMultiInstanceType.NONE.getCode()){
|
|
|
+ if (userTaskConfig.getCountersignConfig().getMultipleInstancesType() != WorkflowMultiInstanceType.NONE.getCode()) {
|
|
|
resultName = runtimeService.getVariable(task.getProcessInstanceId(), resultVarName);
|
|
|
}
|
|
|
|
|
@@ -2179,7 +2179,7 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
approveMultiVo.setCurrentNodeName(task.getName());
|
|
|
if (dto.getApprovedType() == WorkflowApproveType.AGREE.getCode()) {
|
|
|
|
|
|
- addWorkflowRecord(userTaskConfig, nextTaskNameList, user, record, task.getName(), "同意", dto.getApprovedContent(), task,resultName);
|
|
|
+ addWorkflowRecord(userTaskConfig, nextTaskNameList, user, record, task.getName(), "同意", dto.getApprovedContent(), task, resultName);
|
|
|
|
|
|
if (nextTaskNameList.size() == 0) {
|
|
|
String message = "【" + user.getName() + "】【同意】审批,审批意见为:“【" + dto.getApprovedContent() + "】”,由【" + task.getName() + "】 流转到【结束节点】";
|
|
@@ -2201,7 +2201,7 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
}
|
|
|
if (dto.getApprovedType() == WorkflowApproveType.DISAGREE.getCode()) {
|
|
|
|
|
|
- addWorkflowRecord(userTaskConfig, nextTaskNameList, user, record, task.getName(), "拒绝", dto.getApprovedContent(), task,resultName);
|
|
|
+ addWorkflowRecord(userTaskConfig, nextTaskNameList, user, record, task.getName(), "拒绝", dto.getApprovedContent(), task, resultName);
|
|
|
if (nextTaskNameList.size() == 0) {
|
|
|
String message = "【" + user.getName() + "】【拒绝】审批,审批意见为:“【" + dto.getApprovedContent() + "】”,由【" + task.getName() + "】 流转到【结束节点】";
|
|
|
approveMultiVo.setApproveDetail(message);
|
|
@@ -2889,7 +2889,7 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
modelElementById = bpmnModelInstance.getModelElementById(replace);
|
|
|
}
|
|
|
Collection<SequenceFlow> outgoing = ((FlowNodeImpl) modelElementById).getOutgoing();
|
|
|
- if (outgoing !=null && outgoing.size()>0){
|
|
|
+ if (outgoing != null && outgoing.size() > 0) {
|
|
|
for (SequenceFlow sequenceFlow : outgoing) {
|
|
|
outgoingList.add(sequenceFlow.getId());
|
|
|
}
|
|
@@ -2907,16 +2907,16 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
Collection<SequenceFlow> incoming = ((FlowNodeImpl) modelElementById).getIncoming();
|
|
|
|
|
|
if (incoming != null && incoming.size() > 0) {
|
|
|
- if (incoming.size() > 1){
|
|
|
+ if (incoming.size() > 1) {
|
|
|
|
|
|
- if (CollectionUtil.isNotEmpty(outgoingList)){
|
|
|
+ if (CollectionUtil.isNotEmpty(outgoingList)) {
|
|
|
for (SequenceFlow sequenceFlow : incoming) {
|
|
|
- if (outgoingList.contains(sequenceFlow.getId())){
|
|
|
+ if (outgoingList.contains(sequenceFlow.getId())) {
|
|
|
finishedActivity.add(sequenceFlow.getId());
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
for (SequenceFlow sequenceFlow : incoming) {
|
|
|
finishedActivity.add(sequenceFlow.getId());
|
|
|
}
|
|
@@ -3010,7 +3010,7 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
.orderByDesc(WorkflowCirculated::getId)
|
|
|
.like(StrUtil.isNotBlank(dto.getTaskName()), WorkflowCirculated::getTaskName, dto.getTaskName())
|
|
|
.like(StrUtil.isNotBlank(dto.getName()), WorkflowSchema::getName, dto.getName())
|
|
|
- .like(StrUtil.isNotBlank(dto.getKeyword()),WorkflowSchema::getName,dto.getKeyword())
|
|
|
+ .like(StrUtil.isNotBlank(dto.getKeyword()), WorkflowSchema::getName, dto.getKeyword())
|
|
|
.eq(StrUtil.isNotBlank(dto.getOriginator()), User::getId, dto.getOriginator())
|
|
|
.eq(StrUtil.isNotBlank(dto.getSerialNumber()), WorkflowCirculated::getSerialNumber, dto.getSerialNumber())
|
|
|
.between(ObjectUtil.isNotNull(dto.getStartTime()) && ObjectUtil.isNotNull(dto.getEndTime()), WorkflowCirculated::getCreateTime, dto.getStartTime(), dto.getEndTime())
|
|
@@ -3070,7 +3070,7 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
.orderByDesc(WorkflowApproveRecord::getId)
|
|
|
.like(StrUtil.isNotBlank(dto.getTaskName()), WorkflowCirculated::getTaskName, dto.getTaskName())
|
|
|
.like(StrUtil.isNotBlank(dto.getName()), WorkflowSchema::getName, dto.getName())
|
|
|
- .like(StrUtil.isNotBlank(dto.getKeyword()),WorkflowSchema::getName,dto.getKeyword())
|
|
|
+ .like(StrUtil.isNotBlank(dto.getKeyword()), WorkflowSchema::getName, dto.getKeyword())
|
|
|
.eq(StrUtil.isNotBlank(dto.getOriginator()), WorkflowExtra::getStartUserId, dto.getOriginator())
|
|
|
.eq(StrUtil.isNotBlank(dto.getSerialNumber()), WorkflowCirculated::getSerialNumber, dto.getSerialNumber())
|
|
|
.between(ObjectUtil.isNotNull(dto.getStartTime()) && ObjectUtil.isNotNull(dto.getEndTime()), WorkflowExtra::getLaunchTime, dto.getStartTime(), dto.getEndTime())
|
|
@@ -3112,7 +3112,10 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
if (StrUtil.isNotBlank(dto.getName())) {
|
|
|
historicProcessInstanceQuery.variableValueLike(WorkflowConstant.PROCESS_SCHEMA_NAME_KEY, StringPool.PERCENT + dto.getName() + StringPool.PERCENT);
|
|
|
}
|
|
|
- if (StrUtil.isNotBlank(dto.getKeyword())){
|
|
|
+ if (StrUtil.isNotBlank(dto.getSchemaId())) {
|
|
|
+ historicProcessInstanceQuery.variableValueEquals(WorkflowConstant.PROCESS_SCHEMA_ID_KEY, Convert.toLong(dto.getSchemaId()));
|
|
|
+ }
|
|
|
+ if (StrUtil.isNotBlank(dto.getKeyword())) {
|
|
|
historicProcessInstanceQuery.variableValueLike(WorkflowConstant.PROCESS_SCHEMA_NAME_KEY, StringPool.PERCENT + dto.getKeyword() + StringPool.PERCENT);
|
|
|
}
|
|
|
if (StrUtil.isNotBlank(dto.getOriginator())) {
|
|
@@ -3122,6 +3125,13 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
.endOr();
|
|
|
}
|
|
|
|
|
|
+ if (!ObjectUtil.isNull(dto.getType()) && dto.getType() == 1) {
|
|
|
+ historicProcessInstanceQuery.finished();
|
|
|
+ }
|
|
|
+ if (!ObjectUtil.isNull(dto.getType()) && dto.getType() == 2) {
|
|
|
+ historicProcessInstanceQuery.unfinished();
|
|
|
+ }
|
|
|
+
|
|
|
|
|
|
long count = historicProcessInstanceQuery.count();
|
|
|
List<HistoricProcessInstance> historicProcessInstances = historicProcessInstanceQuery.orderByProcessInstanceStartTime().desc().listPage(Convert.toInt((dto.getLimit() - 1) * dto.getSize()), dto.getSize());
|
|
@@ -3173,7 +3183,7 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- if (StrUtil.isNotBlank(dto.getSerialNumber()) && !StrUtil.isNumeric(dto.getSerialNumber())){
|
|
|
+ if (StrUtil.isNotBlank(dto.getSerialNumber()) && !StrUtil.isNumeric(dto.getSerialNumber())) {
|
|
|
result.clear();
|
|
|
}
|
|
|
PageOutput<MyProcessPageVo> output = new PageOutput<>();
|
|
@@ -3488,7 +3498,7 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
|
|
|
List<Long> ids = new ArrayList<>();
|
|
|
|
|
|
- if (StrUtil.isNotBlank(dto.getOriginator())){
|
|
|
+ if (StrUtil.isNotBlank(dto.getOriginator())) {
|
|
|
String allUserIdStr = StrUtil.join(StringPool.COMMA, dto.getOriginator());
|
|
|
ids = Arrays.stream(allUserIdStr.split(StringPool.COMMA)).map(Convert::toLong).collect(Collectors.toList());
|
|
|
}
|
|
@@ -3498,7 +3508,7 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
MPJWrappers.<WorkflowDraft>lambdaJoin()
|
|
|
.disableSubLogicDel()
|
|
|
.eq(StrUtil.isNotBlank(dto.getName()), WorkflowSchema::getName, dto.getName())
|
|
|
- .in(CollectionUtil.isNotEmpty(ids),WorkflowDraft::getCreateUserId,ids)
|
|
|
+ .in(CollectionUtil.isNotEmpty(ids), WorkflowDraft::getCreateUserId, ids)
|
|
|
.between(ObjectUtil.isNotNull(dto.getStartTime()) && ObjectUtil.isNotNull(dto.getEndTime()), WorkflowDraft::getCreateDate, dto.getStartTime(), dto.getEndTime())
|
|
|
.orderByDesc(WorkflowDraft::getCreateDate)
|
|
|
.select(WorkflowDraft::getId)
|
|
@@ -4747,7 +4757,7 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
* @param oldTaskName 前一个节点的名称
|
|
|
* @param buttonName 按钮名称
|
|
|
*/
|
|
|
- private void addWorkflowRecord(UserTaskConfig userTaskConfig, List<String> nextTaskNameList, User user, WorkflowRecord record, String oldTaskName, String buttonName, String approvedContent, Task task,Object resultName) {
|
|
|
+ private void addWorkflowRecord(UserTaskConfig userTaskConfig, List<String> nextTaskNameList, User user, WorkflowRecord record, String oldTaskName, String buttonName, String approvedContent, Task task, Object resultName) {
|
|
|
|
|
|
if (userTaskConfig.getCountersignConfig().getMultipleInstancesType() == WorkflowMultiInstanceType.NONE.getCode()) {
|
|
|
|
|
@@ -4873,7 +4883,7 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public Boolean dealTimeoutTask(Integer handleType,String taskId) {
|
|
|
+ public Boolean dealTimeoutTask(Integer handleType, String taskId) {
|
|
|
|
|
|
Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
|
|
|
|
|
@@ -4901,7 +4911,7 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
|
|
|
List<LaunchAndApproveVo> result = new ArrayList<>();
|
|
|
|
|
|
- if (handleType == 1){
|
|
|
+ if (handleType == 1) {
|
|
|
|
|
|
ActivityInstance activityInstance = runtimeService.getActivityInstance(task.getProcessInstanceId());
|
|
|
|
|
@@ -4915,19 +4925,19 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
.asc()
|
|
|
.list();
|
|
|
|
|
|
- if(null == resultList || resultList.size() == 0){
|
|
|
+ if (null == resultList || resultList.size() == 0) {
|
|
|
throw new MyException("当前任务之前不存在用户任务无法驳回!");
|
|
|
}
|
|
|
|
|
|
HistoricActivityInstance historicActivityInstance = resultList.get(0);
|
|
|
String startActId = historicActivityInstance.getActivityId();
|
|
|
- if(startActId.equals(task.getTaskDefinitionKey())){
|
|
|
+ if (startActId.equals(task.getTaskDefinitionKey())) {
|
|
|
throw new MyException("开始节点无法驳回!");
|
|
|
}
|
|
|
|
|
|
|
|
|
- Map<String,String> lastNode = getLastNode(resultList,task.getTaskDefinitionKey());
|
|
|
- if(null == lastNode){
|
|
|
+ Map<String, String> lastNode = getLastNode(resultList, task.getTaskDefinitionKey());
|
|
|
+ if (null == lastNode) {
|
|
|
throw new MyException("回退节点异常!");
|
|
|
}
|
|
|
String toActId = lastNode.get("toActId");
|
|
@@ -4965,7 +4975,7 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
record.setMessage("审批信息:由于审批超时,【系统】【自动驳回】审批,审批意见为:“系统自动驳回审批”,由【" + task.getName() + "】 流转到【" + rejectUserTaskConfig.getName() + "】");
|
|
|
workflowRecordMapper.insert(record);
|
|
|
});
|
|
|
- }else if(handleType == 2){
|
|
|
+ } else if (handleType == 2) {
|
|
|
|
|
|
WorkflowRecord record = new WorkflowRecord();
|
|
|
record.setNodeId(task.getId());
|
|
@@ -4996,11 +5006,11 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
}
|
|
|
|
|
|
if (nextTaskNameList.size() == 1) {
|
|
|
- String message = "审批信息:由于审批超时,【系统】【自动同意】审批,审批意见为:“系统自动同意审批”,由【" + oldTaskName + "】 流转到【" + nextTaskNameList.get(0) + "】";
|
|
|
+ String message = "审批信息:由于审批超时,【系统】【自动同意】审批,审批意见为:“系统自动同意审批”,由【" + oldTaskName + "】 流转到【" + nextTaskNameList.get(0) + "】";
|
|
|
record.setMessage(message);
|
|
|
}
|
|
|
if (nextTaskNameList.size() > 1) {
|
|
|
- String message = "审批信息:由于审批超时,【系统】【自动同意】审批,审批意见为:“系统自动同意审批”,由【" + oldTaskName + "】 流转到【" + nextTaskNameList.get(0) + "】";
|
|
|
+ String message = "审批信息:由于审批超时,【系统】【自动同意】审批,审批意见为:“系统自动同意审批”,由【" + oldTaskName + "】 流转到【" + nextTaskNameList.get(0) + "】";
|
|
|
for (int i = 1; i < nextTaskNameList.size(); i++) {
|
|
|
message = message + "、【" + nextTaskNameList.get(i) + "】";
|
|
|
}
|
|
@@ -5018,20 +5028,20 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
* 1、当前节点不在历史节点里
|
|
|
* 2、当前节点在历史节点里
|
|
|
* 比如,resultList={1,2,3}
|
|
|
- * (1)当前节点是4,表示3是完成节点,4驳回需要回退到3
|
|
|
- * (2)当前节点是2,表示3是驳回节点,3驳回到当前2节点,2驳回需要回退到1
|
|
|
+ * (1)当前节点是4,表示3是完成节点,4驳回需要回退到3
|
|
|
+ * (2)当前节点是2,表示3是驳回节点,3驳回到当前2节点,2驳回需要回退到1
|
|
|
* 其他驳回过的情况也都包含在情况2中。
|
|
|
*
|
|
|
- * @param resultList 历史节点列表
|
|
|
+ * @param resultList 历史节点列表
|
|
|
* @param currentActivityId 当前待办节点ActivityId
|
|
|
* @return 返回值:上一节点的ActivityId和待办人(toActId, assignee)
|
|
|
*/
|
|
|
- private static Map<String,String> getLastNode(List<HistoricActivityInstance> resultList, String currentActivityId){
|
|
|
- Map<String,String> backNode = new HashMap<>();
|
|
|
+ private static Map<String, String> getLastNode(List<HistoricActivityInstance> resultList, String currentActivityId) {
|
|
|
+ Map<String, String> backNode = new HashMap<>();
|
|
|
|
|
|
- LinkedHashMap<String,String> linkedHashMap = new LinkedHashMap();
|
|
|
- for(HistoricActivityInstance hai : resultList){
|
|
|
- linkedHashMap.put(hai.getActivityId(),hai.getAssignee());
|
|
|
+ LinkedHashMap<String, String> linkedHashMap = new LinkedHashMap();
|
|
|
+ for (HistoricActivityInstance hai : resultList) {
|
|
|
+ linkedHashMap.put(hai.getActivityId(), hai.getAssignee());
|
|
|
}
|
|
|
|
|
|
|
|
@@ -5040,13 +5050,13 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
|
|
|
|
|
|
boolean flag = false;
|
|
|
- for(Map.Entry entry: linkedHashMap.entrySet()){
|
|
|
- if(currentActivityId.equals(entry.getKey())){
|
|
|
+ for (Map.Entry entry : linkedHashMap.entrySet()) {
|
|
|
+ if (currentActivityId.equals(entry.getKey())) {
|
|
|
flag = true;
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
- if(!flag) {
|
|
|
+ if (!flag) {
|
|
|
|
|
|
HistoricActivityInstance historicActivityInstance = resultList.get(originSize - 1);
|
|
|
backNode.put("toActId", historicActivityInstance.getActivityId());
|
|
@@ -5078,18 +5088,18 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
return null;
|
|
|
}
|
|
|
|
|
|
- private static Map<String,String> currentNodeInHis(LinkedHashMap<String,String> linkedHashMap,String currentActivityId){
|
|
|
+ private static Map<String, String> currentNodeInHis(LinkedHashMap<String, String> linkedHashMap, String currentActivityId) {
|
|
|
|
|
|
- Map<String,String> backNode = new HashMap<>();
|
|
|
- ListIterator<Map.Entry<String,String>> li = new ArrayList<>(linkedHashMap.entrySet()).listIterator();
|
|
|
+ Map<String, String> backNode = new HashMap<>();
|
|
|
+ ListIterator<Map.Entry<String, String>> li = new ArrayList<>(linkedHashMap.entrySet()).listIterator();
|
|
|
|
|
|
- while (li.hasNext()){
|
|
|
- Map.Entry<String,String> entry = li.next();
|
|
|
- if(currentActivityId.equals(entry.getKey())){
|
|
|
+ while (li.hasNext()) {
|
|
|
+ Map.Entry<String, String> entry = li.next();
|
|
|
+ if (currentActivityId.equals(entry.getKey())) {
|
|
|
li.previous();
|
|
|
- Map.Entry<String,String> previousEntry = li.previous();
|
|
|
- backNode.put("toActId",previousEntry.getKey());
|
|
|
- backNode.put("assignee",previousEntry.getValue());
|
|
|
+ Map.Entry<String, String> previousEntry = li.previous();
|
|
|
+ backNode.put("toActId", previousEntry.getKey());
|
|
|
+ backNode.put("assignee", previousEntry.getValue());
|
|
|
return backNode;
|
|
|
}
|
|
|
}
|