网站建设与单位干部作风的关系,网站竞价推广都有哪些,wordpress只有三个主题,单位建设网站申请报告有些粉丝#xff0c;希望对自定义业务中#xff0c;驳回到发起人进行处理#xff0c;比如可以重新进行发起流程#xff0c;下面就给出一种方式#xff0c;当然不一定是最好的方式#xff0c;只是提供一种参考而已#xff0c;以后可以考虑动态根据流程状态或节点信息进行…       有些粉丝希望对自定义业务中驳回到发起人进行处理比如可以重新进行发起流程下面就给出一种方式当然不一定是最好的方式只是提供一种参考而已以后可以考虑动态根据流程状态或节点信息进行更加好的处理。 这种方式目前前端不做修改只做后端的一种处理。 主要是增加两个逻辑: 1、增加一个判断是发起人节点isFirstInitiator  以后可以考虑增加驳回与退回的处理 2、对于驳回里对于驳回到发起人后进行流程删除与关联删除以便进行重新发起流程 /*** 驳回任务 for自定义业务** param flowTaskVo*/Overridepublic void taskRejectForDataId(FlowTaskVo flowTaskVo) {if (taskService.createTaskQuery().taskId(flowTaskVo.getTaskId()).singleResult().isSuspended()) {throw new CustomException(任务处于挂起状态);}// 当前任务 taskTask task taskService.createTaskQuery().taskId(flowTaskVo.getTaskId()).singleResult();// 获取流程定义信息ProcessDefinition processDefinition repositoryService.createProcessDefinitionQuery().processDefinitionId(task.getProcessDefinitionId()).singleResult();// 获取所有节点信息Process process repositoryService.getBpmnModel(processDefinition.getId()).getProcesses().get(0);// 获取全部节点列表包含子节点CollectionFlowElement allElements FlowableUtils.getAllElements(process.getFlowElements(), null);// 获取当前任务节点元素FlowElement source null;if (allElements ! null) {for (FlowElement flowElement : allElements) {// 类型为用户节点if (flowElement.getId().equals(task.getTaskDefinitionKey())) {// 获取节点信息source flowElement;}}}// 目的获取所有跳转到的节点 targetIds// 获取当前节点的所有父级用户任务节点// 深度优先算法思想延边迭代深入ListUserTask parentUserTaskList FlowableUtils.iteratorFindParentUserTasks(source, null, null);if (parentUserTaskList null || parentUserTaskList.size() 0) {throw new CustomException(当前节点为初始任务节点不能驳回);}// 获取活动 ID 即节点 KeyListString parentUserTaskKeyList new ArrayList();parentUserTaskList.forEach(item - parentUserTaskKeyList.add(item.getId()));// 获取全部历史节点活动实例即已经走过的节点历史数据采用开始时间升序ListHistoricTaskInstance historicTaskInstanceList historyService.createHistoricTaskInstanceQuery().processInstanceId(task.getProcessInstanceId()).orderByHistoricTaskInstanceStartTime().asc().list();// 数据清洗将回滚导致的脏数据清洗掉ListString lastHistoricTaskInstanceList FlowableUtils.historicTaskInstanceClean(allElements, historicTaskInstanceList);// 此时历史任务实例为倒序获取最后走的节点ListString targetIds new ArrayList();// 循环结束标识遇到当前目标节点的次数int number 0;StringBuilder parentHistoricTaskKey new StringBuilder();for (String historicTaskInstanceKey : lastHistoricTaskInstanceList) {// 当会签时候会出现特殊的连续都是同一个节点历史数据的情况这种时候跳过if (parentHistoricTaskKey.toString().equals(historicTaskInstanceKey)) {continue;}parentHistoricTaskKey new StringBuilder(historicTaskInstanceKey);if (historicTaskInstanceKey.equals(task.getTaskDefinitionKey())) {number;}// 在数据清洗后历史节点就是唯一一条从起始到当前节点的历史记录理论上每个点只会出现一次// 在流程中如果出现循环那么每次循环中间的点也只会出现一次再出现就是下次循环// number 1第一次遇到当前节点// number 2第二次遇到代表最后一次的循环范围if (number 2) {break;}// 如果当前历史节点属于父级的节点说明最后一次经过了这个点需要退回这个点if (parentUserTaskKeyList.contains(historicTaskInstanceKey)) {targetIds.add(historicTaskInstanceKey);}}// 目的获取所有需要被跳转的节点 currentIds// 取其中一个父级任务因为后续要么存在公共网关要么就是串行公共线路UserTask oneUserTask parentUserTaskList.get(0);// 获取所有正常进行的任务节点 Key这些任务不能直接使用需要找出其中需要撤回的任务ListTask runTaskList taskService.createTaskQuery().processInstanceId(task.getProcessInstanceId()).list();ListString runTaskKeyList new ArrayList();runTaskList.forEach(item - runTaskKeyList.add(item.getTaskDefinitionKey()));// 需驳回任务列表ListString currentIds new ArrayList();// 通过父级网关的出口连线结合 runTaskList 比对获取需要撤回的任务ListUserTask currentUserTaskList FlowableUtils.iteratorFindChildUserTasks(oneUserTask, runTaskKeyList, null, null);currentUserTaskList.forEach(item - currentIds.add(item.getId()));// 规定并行网关之前节点必须需存在唯一用户任务节点如果出现多个任务节点则并行网关节点默认为结束节点原因为不考虑多对多情况if (targetIds.size() 1 currentIds.size() 1) {throw new CustomException(任务出现多对多情况无法撤回);}// 循环获取那些需要被撤回的节点的ID用来设置驳回原因ListString currentTaskIds new ArrayList();currentIds.forEach(currentId - runTaskList.forEach(runTask - {if (currentId.equals(runTask.getTaskDefinitionKey())) {currentTaskIds.add(runTask.getId());}}));// 设置驳回意见currentTaskIds.forEach(item - taskService.addComment(item, task.getProcessInstanceId(), FlowComment.REJECT.getType(), flowTaskVo.getComment()));SysUser loginUser iFlowThirdService.getLoginUser();try {// 设置处理人taskService.setAssignee(task.getId(), loginUser.getUsername());// 如果父级任务多于 1 个说明当前节点不是并行节点原因为不考虑多对多情况if (targetIds.size() 1) {// 1 对 多任务跳转currentIds 当前节点(1)targetIds 跳转到的节点(多)runtimeService.createChangeActivityStateBuilder().processInstanceId(task.getProcessInstanceId()).moveSingleActivityIdToActivityIds(currentIds.get(0), targetIds).changeState();}// 如果父级任务只有一个因此当前任务可能为网关中的任务if (targetIds.size() 1) {// 1 对 1 或 多 对 1 情况currentIds 当前要跳转的节点列表(1或多)targetIds.get(0) 跳转到的节点(1)runtimeService.createChangeActivityStateBuilder().processInstanceId(task.getProcessInstanceId()).moveActivityIdsToSingleActivityId(currentIds, targetIds.get(0)).changeState();}/*驳回 回调以及关键数据保存*///业务数据idString dataId flowTaskVo.getDataId();if (dataIdnull) return;//如果保存数据前未调用必调的FlowCommonService.initActBusiness方法就会有问题FlowMyBusiness business flowMyBusinessService.getByDataId(dataId);// 驳回到了上一个节点等待处理Task targetTask taskService.createTaskQuery().processInstanceId(business.getProcessInstanceId()).active().singleResult();//spring容器类名String serviceImplName business.getServiceImplName();FlowCallBackServiceI flowCallBackService (FlowCallBackServiceI) SpringContextUtils.getBean(serviceImplName);MapString, Object values flowTaskVo.getValues();if (values null){values MapUtil.newHashMap();values.put(dataId,dataId);} else {values.put(dataId,dataId);}ListString beforeParamsCandidateUsernames flowCallBackService.flowCandidateUsernamesOfTask(targetTask.getTaskDefinitionKey(), values);//设置数据String doneUsers business.getDoneUsers();// 处理过流程的人JSONArray doneUserList new JSONArray();if (StrUtil.isNotBlank(doneUsers)){doneUserList JSON.parseArray(doneUsers);}if (!doneUserList.contains(loginUser.getUsername())){doneUserList.add(loginUser.getUsername());}business.setActStatus(ActStatus.reject).setTaskId(targetTask.getId()).setTaskNameId(targetTask.getTaskDefinitionKey()).setTaskName(targetTask.getName()).setDoneUsers(doneUserList.toJSONString());FlowElement targetElement null;if (allElements ! null) {for (FlowElement flowElement : allElements) {// 类型为用户节点if (flowElement.getId().equals(targetTask.getTaskDefinitionKey())) {// 获取节点信息targetElement flowElement;}}}ProcessInstance processInstance runtimeService.createProcessInstanceQuery().processInstanceId(targetTask.getProcessInstanceId()).singleResult();String startUserId processInstance.getStartUserId();if (targetElement!null){UserTask targetUserTask (UserTask) targetElement;business.setPriority(targetUserTask.getPriority());if (StrUtil.equals(targetUserTask.getIncomingFlows().get(0).getSourceRef(),startNode1)) {//是否为发起人节点// 开始节点。设置处理人为申请人business.setTodoUsers(JSON.toJSONString(Lists.newArrayList(business.getProposer())));taskService.setAssignee(business.getTaskId(),business.getProposer());} else {ListSysUser sysUserFromTask getSysUserFromTask(targetUserTask,startUserId);ListString collect_username sysUserFromTask.stream().map(SysUser::getUsername).collect(Collectors.toList());//collect_username转换成realnameListString newusername new ArrayListString();for (String oldUser : collect_username) {if(StringUtils.equalsAnyIgnoreCase(oldUser, ${INITIATOR})) {//对发起人做特殊处理SysUser sysUser iFlowThirdService.getUserByUsername(startUserId);newusername.add(sysUser.getRealname());}else {SysUser sysUser iFlowThirdService.getUserByUsername(oldUser);newusername.add(sysUser.getRealname());}}business.setTodoUsers(JSON.toJSONString(newusername));// 删除后重写for (String oldUser : collect_username) {taskService.deleteCandidateUser(targetTask.getId(),oldUser);}if (CollUtil.isNotEmpty(beforeParamsCandidateUsernames)){// 业务层有指定候选人覆盖for (String newUser : beforeParamsCandidateUsernames) {taskService.addCandidateUser(targetTask.getId(),newUser);}business.setTodoUsers(JSON.toJSONString(beforeParamsCandidateUsernames));} else {for (String oldUser : collect_username) {taskService.addCandidateUser(targetTask.getId(),oldUser);}}if(collect_username.size() 1) {targetTask.setAssignee(newusername.get(0).toString());taskService.addUserIdentityLink(targetTask.getId(), collect_username.get(0).toString(), IdentityLinkType.ASSIGNEE);}else if(collect_username.size() 1){ListHistoricActivityInstance list historyService.createHistoricActivityInstanceQuery().activityId(targetTask.getTaskDefinitionKey()).orderByHistoricActivityInstanceStartTime().desc().list();for (HistoricActivityInstance historicActivityInstance : list) {if (StrUtil.isNotBlank(historicActivityInstance.getAssignee())) {targetTask.setAssignee(historicActivityInstance.getAssignee());taskService.addUserIdentityLink(targetTask.getId(), historicActivityInstance.getAssignee(), IdentityLinkType.ASSIGNEE);break;}}}}}// 重新查询当前任务Task currentTask taskService.createTaskQuery().processInstanceId(targetTask.getProcessInstanceId()).singleResult();//判断是否是发起人节点,恢复自定义业务表单重新提交if(isFirstInitiator(currentTask)) {//删除自定义业务任务关联表与流程历史表以便可以重新发起流程。//(要是需要重新进行提交的话那就要保留第一个发起人历史信息,自定义业务表单最好增加一个再次发起按钮来处理这种情况if (business ! null) {flowMyBusinessService.removeById(business);// 对自定义业务删除运行和历史的节点信息 this.deleteActivity(targetTask.getTaskDefinitionKey(), targetTask.getProcessInstanceId(), dataId);}}else {flowMyBusinessService.updateById(business);// 流程处理完后进行回调业务层business.setValues(values);if (flowCallBackService!null) flowCallBackService.afterFlowHandle(business);}} catch (FlowableObjectNotFoundException e) {throw new CustomException(未找到流程实例流程可能已发生变化);} catch (FlowableException e) {throw new CustomException(无法取消或开始活动);}}/*** 判断当前节点是否是第一个发起人节点** param flowTaskVo 请求实体参数*/boolean isFirstInitiator(Task task) {BpmnModel bpmnModel repositoryService.getBpmnModel(task.getProcessDefinitionId());// 获取当前活动节点FlowNode currentFlowNode (FlowNode) bpmnModel.getMainProcess().getFlowElement(task.getTaskDefinitionKey());// 输入连线ListSequenceFlow inFlows currentFlowNode.getIncomingFlows();for (SequenceFlow sequenceFlow : inFlows) {FlowElement sourceFlowElement sequenceFlow.getSourceFlowElement();// 如果上个节点为开始节点if (sourceFlowElement instanceof StartEvent) {log.info(当前节点为发起人节点,上个节点为开始节点id sourceFlowElement.getId() ,name sourceFlowElement.getName());return true;}}return false; }