基于jeecgboot的支持flowable的排它网关之后的会签功能(二)
對(duì)于審批完成的處理也要對(duì)這種特殊情況做處理,目前暫時(shí)不支持子流程
?taskService.setAssignee(taskVo.getTaskId(), loginUser.getUsername());
? ? ? ? ? ? // 獲取下一節(jié)點(diǎn)數(shù)據(jù)
? ? ? ? ? ? FlowNextDto nextFlowNode = flowTaskService.getNextFlowNode(task.getId(), taskVo.getValues());
? ? ? ? ? ??
? ? ? ? ??? ?String definitionld = runtimeService.createProcessInstanceQuery().processInstanceId(taskVo.getInstanceId()).singleResult().getProcessDefinitionId(); ? ? ? ?//獲取bpm(模型)對(duì)象
? ? ? ? ? ? BpmnModel bpmnModel = repositoryService.getBpmnModel(definitionld);
? ? ? ? ? ? //傳節(jié)點(diǎn)定義key獲取當(dāng)前節(jié)點(diǎn)
? ? ? ? ? ? FlowNode flowNode = (FlowNode) bpmnModel.getFlowElement(task.getTaskDefinitionKey());
? ? ? ? ? ? if(Objects.nonNull(nextFlowNode)) {
? ? ? ? ? ? ?? ?
?? ? ? ? ? ? ? ?if(flowNode instanceof UserTask ){//當(dāng)前節(jié)點(diǎn)是用戶任務(wù)
?? ? ? ? ? ? ? ??? ?UserTask userTask = (UserTask) flowNode;
?? ? ? ? ? ? ? ??? ?MultiInstanceLoopCharacteristics multiInstance = userTask.getLoopCharacteristics();
?? ? ? ? ? ? ? ??? ?if (Objects.nonNull(multiInstance)) {//當(dāng)前節(jié)點(diǎn)是會(huì)簽節(jié)點(diǎn)
?? ? ? ? ? ? ? ??? ??? ?if(nextFlowNode.getType().equals(ProcessConstants.PROCESS_MULTI_INSTANCE)) {//若下個(gè)節(jié)點(diǎn)也是會(huì)簽節(jié)點(diǎn)
?? ? ? ? ? ? ? ??? ??? ??? ?taskService.complete(taskVo.getTaskId());
?? ? ? ? ? ? ? ??? ??? ?}
?? ? ? ? ? ? ? ??? ??? ?else if(Objects.nonNull(taskVo.getValues()) && (taskVo.getValues().containsKey("approval"))) {//不是會(huì)簽而且有approval
?? ? ? ? ? ? ? ??? ??? ??? ?//complete方法來流傳任務(wù)到下一個(gè)節(jié)點(diǎn)。其中第二個(gè)參數(shù)variables為下一個(gè)節(jié)點(diǎn)需要的參數(shù)Map,主要指流程設(shè)置的一些變量信息
?? ? ? ? ? ? ? ??? ??? ??? ?taskService.complete(taskVo.getTaskId(), taskVo.getValues(),true);
?? ? ? ? ? ? ? ??? ??? ??? ?Task nexttask = taskService.createTaskQuery().processInstanceId(taskVo.getInstanceId()).active().singleResult();
?? ? ? ? ? ? ? ??? ??? ??? ?String assignee = taskVo.getValues().get("approval").toString();?? ?
?? ? ? ? ? ? ? ??? ??? ??? ?taskService.setAssignee(nexttask.getId(), assignee);
?? ? ? ? ? ? ? ??? ??? ?}
?? ? ? ? ? ? ? ??? ??? ?else {
?? ? ? ? ? ? ? ??? ??? ??? ?taskService.complete(taskVo.getTaskId());
?? ? ? ? ? ? ? ??? ??? ?}
?? ? ? ? ? ? ? ??? ?}
?? ? ? ? ? ? ? ??? ?else if(Objects.nonNull(taskVo.getValues())) {//當(dāng)前節(jié)點(diǎn)不是會(huì)簽節(jié)點(diǎn),而且有變量值
?? ? ? ? ? ? ? ??? ??? ?if(nextFlowNode.getType().equals(ProcessConstants.PROCESS_MULTI_INSTANCE)) {//若下個(gè)節(jié)點(diǎn)也是會(huì)簽節(jié)點(diǎn)
?? ? ? ? ? ? ? ??? ??? ??? ?if(Objects.nonNull(nextFlowNode.getUserList())) {//有下個(gè)節(jié)點(diǎn)有用戶
?? ? ? ? ? ? ? ??? ??? ??? ??? ?Map<String, Object> approvalmap = new HashMap<>();
?? ? ? ? ? ? ? ??? ? ? ? ? ? ? ?List<String> sysuserlist = nextFlowNode.getUserList().stream().map(obj-> (String) obj.getUsername()).collect(Collectors.toList());
?? ? ? ? ? ? ? ??? ??? ??? ??? ?approvalmap.put("approval", sysuserlist);
?? ? ? ? ? ? ? ??? ??? ??? ??? ?taskService.complete(taskVo.getTaskId(), approvalmap);
?? ? ? ? ? ? ? ??? ??? ??? ??? ?if(!nextFlowNode.isBisSequential()){//對(duì)并發(fā)會(huì)簽進(jìn)行assignee單獨(dú)賦值
?? ? ? ? ? ? ? ??? ??? ??? ??? ? ?List<Task> nexttasklist = taskService.createTaskQuery().processInstanceId(taskVo.getInstanceId()).active().list();
?? ? ? ? ? ? ? ??? ??? ??? ??? ? ?int i=0;
?? ? ? ? ? ? ? ??? ??? ??? ??? ? ?for (Task nexttask : nexttasklist) {
?? ? ? ? ? ? ? ??? ??? ??? ??? ??? ? ? String assignee = sysuserlist.get(i).toString();?? ?
?? ? ? ? ? ? ? ? ? ??? ??? ??? ? ? ? ? taskService.setAssignee(nexttask.getId(), assignee);
?? ? ? ? ? ? ? ? ? ??? ??? ??? ? ? ? ? i++;
?? ? ? ? ? ? ? ??? ??? ??? ??? ? ?}
?? ? ? ? ? ? ? ??? ??? ??? ??? ??
?? ? ? ? ? ? ? ??? ??? ??? ??? ?}
?? ? ? ? ? ? ? ? ? ??? ??? ??? ?
?? ? ? ? ? ? ? ??? ??? ??? ?}
?? ? ? ? ? ? ? ??? ??? ??? ?else {//有下個(gè)節(jié)點(diǎn)無用戶
?? ? ? ? ? ? ? ??? ??? ??? ??? ?taskService.complete(taskVo.getTaskId(),taskVo.getValues());
?? ? ? ? ? ? ? ? ? ?? ??? ? ? ?}
?? ? ? ? ? ? ? ??? ??? ?}
?? ? ? ? ? ? ? ??? ??? ?else {//下個(gè)節(jié)點(diǎn)也不是會(huì)簽而且有approval
?? ? ? ? ? ? ? ??? ??? ??? ? taskService.complete(taskVo.getTaskId(), taskVo.getValues(),true);
?? ? ? ? ? ? ? ? ? ??? ??? ? ?Task nexttask = taskService.createTaskQuery().processInstanceId(taskVo.getInstanceId()).active().singleResult();
?? ? ? ? ? ? ? ? ? ??? ??? ? ?if(taskVo.getValues().containsKey("approval")) {//前端傳回的審批人變量值
?? ? ? ? ? ? ? ??? ??? ??? ? ? ? String assignee = taskVo.getValues().get("approval").toString();?? ?
?? ? ? ? ? ? ? ??? ??? ??? ? ? ? taskService.setAssignee(nexttask.getId(), assignee);
?? ? ? ? ? ? ? ? ? ??? ??? ? ?}
?? ? ? ? ? ? ? ??? ??? ?}
?? ? ? ? ? ? ?? ? ? ?}
?? ? ? ? ? ? ?? ? ? ?else {//無傳值情況
?? ? ? ? ? ? ?? ? ? ??? ? ?taskService.complete(taskVo.getTaskId());
?? ? ? ? ? ? ?? ? ? ??? ?}
?? ? ? ? ? ? ?? ? ? ?}
? ? ? ? ? ? ? ?}
? ? ? ? ? ? else { //下一個(gè)節(jié)點(diǎn)是空
? ? ? ? ? ? ?? ?taskService.complete(taskVo.getTaskId());
? ? ? ? ? ? }
總結(jié)
以上是生活随笔為你收集整理的基于jeecgboot的支持flowable的排它网关之后的会签功能(二)的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 数据安全分类分级实施指南_不平衡数据集分
- 下一篇: 兴趣爱好选择程序java+Swing界面