package jnpf.flowable.util; import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.util.ObjectUtil; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.google.common.collect.ImmutableList; import jnpf.base.ActionResult; import jnpf.base.Pagination; import jnpf.base.UserInfo; import jnpf.constant.JnpfConst; import jnpf.constant.MsgCode; import jnpf.constant.PermissionConst; import jnpf.exception.WorkFlowException; import jnpf.flowable.entity.*; import jnpf.flowable.enums.*; import jnpf.flowable.model.candidates.CandidateUserVo; import jnpf.flowable.model.flowable.*; import jnpf.flowable.model.message.FlowMsgModel; import jnpf.flowable.model.record.NodeRecordModel; import jnpf.flowable.model.task.*; import jnpf.flowable.model.templatejson.FlowFormModel; import jnpf.flowable.model.templatejson.FlowParamModel; import jnpf.flowable.model.templatenode.FlowErrorModel; import jnpf.flowable.model.templatenode.nodejson.*; import jnpf.flowable.model.util.FlowConstant; import jnpf.flowable.model.util.FlowContextHolder; import jnpf.flowable.model.util.FlowNature; import jnpf.flowable.service.*; import jnpf.permission.entity.*; import jnpf.util.*; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.util.*; import java.util.stream.Collectors; /** * 类的描述 * * @author JNPF@YinMai Info. Co., Ltd * @version 5.0.x * @since 2024/4/22 16:46 */ @Component public class TaskUtil { @Autowired private ServiceUtil serviceUtil; @Autowired private LaunchUserService launchUserService; @Autowired private CandidatesService candidatesService; @Autowired private RecordService recordService; @Autowired private MsgUtil msgUtil; @Autowired private FlowAbleUrl flowAbleUrl; @Autowired private TaskService taskService; @Autowired private OperatorService operatorService; @Autowired private OperatorUtil operatorUtil; @Autowired private TemplateService templateService; @Autowired private TemplateJsonService templateJsonService; @Autowired private TemplateNodeService templateNodeService; @Autowired private ConditionService conditionService; @Autowired private TaskLineService taskLineService; @Autowired private RevokeService revokeService; @Autowired private NodeRecordService nodeRecordService; @Autowired private RecordUtil recordUtil; @Autowired private SubtaskDataService subtaskDataService; // 提交撤销流程 public void submitOfRevoke(FlowModel flowModel) throws Exception { TaskEntity task = flowModel.getTaskEntity(); List lineList = taskLineService.getList(task.getId()); if (CollectionUtil.isEmpty(lineList)) { throw new WorkFlowException("无法撤销"); } // 委托人的处理 UserInfo userInfo = flowModel.getUserInfo(); String creatorUserId = task.getCreatorUserId(); String delegateUserId = task.getDelegateUserId(); boolean isDelegate = !ObjectUtil.equals(userInfo.getUserId(), creatorUserId); if (isDelegate) { if (StringUtil.isNotEmpty(delegateUserId)) { String token = AuthUtil.loginTempUser(task.getCreatorUserId(), UserProvider.getUser().getTenantId()); userInfo = UserProvider.getUser(token); flowModel.setUserInfo(userInfo); } } Map variables = new HashMap<>(); for (TaskLineEntity condition : lineList) { variables.put(condition.getLineKey(), Boolean.valueOf(condition.getLineValue())); } TaskEntity entity = new TaskEntity(); entity.setId(RandomUtil.uuId()); entity.setType(1); entity.setUrgent(task.getUrgent()); entity.setCreatorUserId(task.getCreatorUserId()); entity.setStartTime(new Date()); entity.setCreatorTime(new Date()); entity.setFullName(task.getFullName() + "的撤销申请"); entity.setFlowCategory(task.getFlowCategory()); entity.setFlowCode(task.getFlowCode()); entity.setFlowName(task.getFlowName()); entity.setFlowVersion(task.getFlowVersion()); entity.setFlowId(task.getFlowId()); entity.setTemplateId(task.getTemplateId()); entity.setParentId(task.getParentId()); entity.setFlowType(task.getFlowType()); entity.setStatus(TaskStatusEnum.RUNNING.getCode()); entity.setEngineType(task.getEngineType()); if (isDelegate) { entity.setDelegateUserId(delegateUserId); } TemplateJsonEntity jsonEntity = templateJsonService.getInfo(task.getFlowId()); String instanceId = flowAbleUrl.startInstance(jsonEntity.getFlowableId(), variables); entity.setInstanceId(instanceId); if (taskService.save(entity)) { List nodeEntityList = flowModel.getNodeEntityList(); TemplateNodeEntity nodeEntity = nodeEntityList.stream() .filter(e -> StringUtil.equals(NodeEnum.start.getType(), e.getNodeType())).findFirst().orElse(new TemplateNodeEntity()); NodeModel nodeModel = JsonUtil.getJsonToBean(nodeEntity.getNodeJson(), NodeModel.class); // 记录 FlowMethod method = new FlowMethod(); method.setFlowModel(flowModel); method.setType(RecordEnum.submit.getCode()); OperatorEntity operatorEntity = new OperatorEntity(); operatorEntity.setNodeCode(nodeEntity.getNodeCode()); operatorEntity.setNodeName(nodeModel.getNodeName()); operatorEntity.setTaskId(entity.getId()); operatorEntity.setHandleId(entity.getCreatorUserId()); if (StringUtil.isNotBlank(flowModel.getUserId())) { method.setHandId(flowModel.getUserId()); } operatorEntity.setHandleTime(entity.getStartTime()); method.setOperatorEntity(operatorEntity); recordUtil.createRecord(method); // 节点记录 NodeRecordModel nodeRecordModel = new NodeRecordModel(); nodeRecordModel.setTaskId(entity.getId()); nodeRecordModel.setNodeCode(nodeEntity.getNodeCode()); nodeRecordModel.setNodeName(nodeModel.getNodeName()); nodeRecordModel.setNodeStatus(NodeStateEnum.submit.getCode()); nodeRecordService.create(nodeRecordModel); // 保存到撤销表 RevokeEntity revokeEntity = new RevokeEntity(); revokeEntity.setId(RandomUtil.uuId()); revokeEntity.setTaskId(task.getId()); revokeEntity.setRevokeTaskId(entity.getId()); RevokeFormDataModel model = new RevokeFormDataModel(); String billNumber = serviceUtil.getBillNumber(); model.setBillRule(billNumber); model.setHandleOpinion(flowModel.getHandleOpinion()); Date date = new Date(); model.setCreatorTime(date.getTime()); model.setRevokeTaskId(task.getId()); model.setRevokeTaskName(task.getFullName()); String str = JsonUtil.getObjectToString(model); revokeEntity.setFormData(str); revokeService.save(revokeEntity); // 处理撤销经办 FlowMethod flowMethod = new FlowMethod(); flowMethod.setFlowModel(flowModel); flowMethod.setTaskId(task.getId()); flowMethod.setTaskEntity(entity); operatorUtil.handleRevokeOperator(flowMethod); // 自动审批 FlowModel revokeModel = JsonUtil.getJsonToBean(flowModel, FlowModel.class); revokeModel.setTaskEntity(entity); operatorUtil.autoAudit(revokeModel); // 判断结束 flowModel.setTaskEntity(entity); if (this.isFinished(flowModel)) { this.endRevoke(task); } } } public void endRevoke(TaskEntity task) { QueryWrapper wrapper = new QueryWrapper<>(); wrapper.lambda().in(TaskEntity::getParentId, task.getId()); List subTaskList = taskService.list(wrapper); // 变更子流程任务状态 if (CollectionUtil.isNotEmpty(subTaskList)) { for (TaskEntity subTask : subTaskList) { subTask.setStatus(TaskStatusEnum.REVOKED.getCode()); } taskService.updateBatchById(subTaskList); } task.setStatus(TaskStatusEnum.REVOKED.getCode()); taskService.updateById(task); } // 更新当前节点 public void updateCurrentNode(List taskModelList, Map nodes, TaskEntity taskEntity) { List currentNodeList = new ArrayList<>(); List currentNodeNameList = new ArrayList<>(); List nodeTypes = ImmutableList.of(NodeEnum.approver.getType(), NodeEnum.subFlow.getType(), NodeEnum.processing.getType(), NodeEnum.outside.getType()); for (FlowableTaskModel model : taskModelList) { NodeModel nodeModel = nodes.get(model.getTaskKey()); if (null != nodeModel && nodeTypes.contains(nodeModel.getType())) { currentNodeList.add(nodeModel.getNodeId()); currentNodeNameList.add(nodeModel.getNodeName()); } } if (CollectionUtil.isNotEmpty(currentNodeList)) { // 更新任务的当前节点信息 taskEntity.setCurrentNodeName(String.join(",", currentNodeNameList)); taskEntity.setCurrentNodeCode(String.join(",", currentNodeList)); taskService.updateById(taskEntity); } } // 拒绝结束流程 public void handleEndTask(FlowMethod flowMethod) throws Exception { OperatorEntity operator = flowMethod.getOperatorEntity(); List circulateList = flowMethod.getCirculateList(); FlowModel flowModel = flowMethod.getFlowModel(); TaskEntity taskEntity = flowModel.getTaskEntity(); List nodeEntityList = flowModel.getNodeEntityList(); // 触发 if (!flowMethod.getIsRevoke()) { flowModel.setAction(2); flowModel.setRejectTrigger(true); operatorUtil.handleTrigger(operator, flowModel); } // 直接结束流程 flowMethod.setState(TaskStatusEnum.REJECTED.getCode()); this.endTask(flowMethod); // 处理当前节点 flowModel.setFinishFlag(false); List codes = Arrays.stream(taskEntity.getCurrentNodeCode().split(",")).collect(Collectors.toList()); codes.remove(operator.getNodeCode()); taskEntity.setCurrentNodeCode(String.join(",", codes)); // 节点记录 NodeRecordModel nodeRecordModel = new NodeRecordModel(); nodeRecordModel.setTaskId(operator.getTaskId()); nodeRecordModel.setNodeId(operator.getNodeId()); nodeRecordModel.setNodeCode(operator.getNodeCode()); nodeRecordModel.setNodeName(operator.getNodeName()); nodeRecordModel.setNodeStatus(NodeStateEnum.reject.getCode()); nodeRecordService.create(nodeRecordModel); FlowMsgModel flowMsgModel = new FlowMsgModel(); flowMsgModel.setNodeList(nodeEntityList); flowMsgModel.setFlowModel(flowModel); flowMsgModel.setTaskEntity(taskEntity); flowMsgModel.setNodeCode(operator.getNodeCode()); flowMsgModel.setWait(false); flowMsgModel.setReject(true); flowMsgModel.setCopy(true); List operatorList = new ArrayList<>(); OperatorEntity entity = new OperatorEntity(); entity.setNodeCode(operator.getNodeCode()); entity.setHandleId(taskEntity.getCreatorUserId()); operatorList.add(entity); flowMsgModel.setOperatorList(operatorList); flowMsgModel.setCirculateList(circulateList); flowMsgModel.setFormData(FlowContextHolder.getAllData()); msgUtil.message(flowMsgModel); this.isFinished(flowModel); } public List getTaskByTemplate(String templateId) { QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.lambda().eq(TaskEntity::getTemplateId, templateId); return taskService.list(queryWrapper); } public void updateGlobalParam(TaskEntity taskEntity, NodeModel nodeModel, NodeModel global, Map formData) throws WorkFlowException { this.getGlobalParam(taskEntity, nodeModel, global, formData); taskService.updateById(taskEntity); } public void getGlobalParam(TaskEntity taskEntity, NodeModel nodeModel, NodeModel global, Map formData) throws WorkFlowException { List paramModelList = global.getGlobalParameterList(); if (CollectionUtil.isEmpty(paramModelList)) { return; } formData = formData == null ? new HashMap<>() : formData; List list = new ArrayList<>(); for (GroupsModel group : nodeModel.getParameterList()) { TemplateJsonModel model = new TemplateJsonModel(); model.setField(group.getField()); model.setSourceType(Objects.equals(FieldEnum.Condition.getCode(), group.getFieldValueType()) ? FieldEnum.System.getCode() : group.getFieldValueType()); model.setRelationField(String.valueOf(group.getFieldValue())); model.setMsgTemplateId(group.getField()); list.add(model); } Map taskMap = taskEntity.getGlobalParameter() != null ? JsonUtil.stringToMap(taskEntity.getGlobalParameter()) : new HashMap<>(); if (CollectionUtil.isEmpty(taskMap)) { for (FlowParamModel model : paramModelList) { if (model.getDefaultValue() != null) { taskMap.put(model.getFieldName(), model.getDefaultValue()); } } } RecordEntity record = new RecordEntity(); record.setNodeCode(nodeModel.getNodeId()); // UserEntity createUser = serviceUtil.getUserInfo(taskEntity.getCreatorUserId()); // UserEntity delegate = StringUtil.isNotEmpty(taskEntity.getDelegateUserId()) ? serviceUtil.getUserInfo(taskEntity.getDelegateUserId()) : null; FlowModel parameterModel = new FlowModel(); parameterModel.setFormData(formData); parameterModel.setRecordEntity(record); parameterModel.setTaskEntity(taskEntity); Map map = msgUtil.parameterMap(parameterModel, list); taskMap.putAll(map); for (FlowParamModel model : paramModelList) { if (ObjectUtil.equals(model.getDataType(), "datetime")) { String fieldName = model.getFieldName(); Long longVal = Long.valueOf(String.valueOf(taskMap.get(fieldName))); taskMap.put(fieldName, longVal); } } taskEntity.setGlobalParameter(JsonUtil.getObjectToString(taskMap)); } /** * 根据主键集合获取任务实体 * * @param ids 主键集合 */ public List getOrderStaList(List ids) { List list = new ArrayList<>(); if (CollectionUtil.isNotEmpty(ids)) { QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.lambda().in(TaskEntity::getId, ids); list = taskService.list(queryWrapper); } return list; } /** * 设置参数 * * @param taskId 任务主键 * @param flowModel 参数 */ public void setFlowModel(String taskId, FlowModel flowModel) throws WorkFlowException { if (flowModel.getUserInfo() == null) { flowModel.setUserInfo(UserProvider.getUser()); } TaskEntity taskEntity = taskService.getInfo(taskId); if (null == taskEntity) { throw new WorkFlowException(MsgCode.FA001.get()); } TemplateJsonEntity jsonEntity = templateJsonService.getInfo(taskEntity.getFlowId()); flowModel.setJsonEntity(jsonEntity); flowModel.setDeploymentId(jsonEntity.getFlowableId()); flowModel.setTaskEntity(taskEntity); List nodeEntityList = templateNodeService.getList(taskEntity.getFlowId()); flowModel.setNodeEntityList(nodeEntityList); Map nodes = new HashMap<>(); for (TemplateNodeEntity nodeEntity : nodeEntityList) { nodes.put(nodeEntity.getNodeCode(), JsonUtil.getJsonToBean(nodeEntity.getNodeJson(), NodeModel.class)); } flowModel.setNodes(nodes); } /** * 依次审批的排序 * * @param userIds 用户主键集合 * @param nodeModel 节点属性 */ public List improperSort(List userIds, NodeModel nodeModel) { List list = new ArrayList<>(); List sortList = nodeModel.getApproversSortList(); if (sortList.isEmpty()) { return userIds; } for (String id : sortList) { List collect = userIds.stream().filter(id::contains).collect(Collectors.toList()); list.addAll(collect); } return list.stream().distinct().collect(Collectors.toList()); } // 结束任务 public void endTask(FlowMethod flowMethod) throws Exception { TaskEntity taskEntity = flowMethod.getTaskEntity(); Integer state = flowMethod.getState(); taskEntity.setStatus(state); taskEntity.setEndTime(new Date()); if (taskService.updateById(taskEntity)) { flowMethod.setTaskId(taskEntity.getId()); flowMethod.setNodeCode(null); operatorUtil.endOperator(flowMethod); flowAbleUrl.deleteInstance(taskEntity.getInstanceId(), "reject"); } } /** * 判断任务是否结束 * * @param flowModel 参数 */ public boolean isFinished(FlowModel flowModel) throws Exception { TaskEntity taskEntity = flowModel.getTaskEntity(); if (null == taskEntity.getId()) { return false; } TaskEntity task = taskService.getById(taskEntity.getId()); if (null != task && ObjectUtil.equals(task.getStatus(), TaskStatusEnum.CANCEL.getCode())) { return false; } List nodeEntityList = flowModel.getNodeEntityList(); String instanceId = taskEntity.getInstanceId(); boolean flag; FlowableInstanceModel instance = flowAbleUrl.getInstance(instanceId); if (null != instance && null != instance.getEndTime()) { flag = true; } else { List historicEnd = flowAbleUrl.getHistoricEnd(instanceId); flag = CollectionUtil.isNotEmpty(historicEnd); } if (flag) { TemplateNodeEntity endNodeEntity = nodeEntityList.stream() .filter(e -> StringUtil.equals(e.getNodeType(), NodeEnum.end.getType())).findFirst().orElse(null); if (null != endNodeEntity) { if (flowModel.getFinishFlag()) { taskEntity.setCurrentNodeCode(FlowNature.END_CODE); taskEntity.setCurrentNodeName(FlowNature.END_NAME); } Integer status = flowModel.getHandleStatus().equals(FlowNature.AuditCompletion) ? TaskStatusEnum.PASSED.getCode() : TaskStatusEnum.REJECTED.getCode(); taskEntity.setStatus(status); taskEntity.setEndTime(new Date()); if (taskService.updateById(taskEntity)) { this.subFlowOfEnd(flowModel); //结束事件 flowModel.setEventStatus(EventEnum.End.getStatus()); operatorUtil.addEvent(flowModel); // 发送结束消息 FlowMsgModel flowMsgModel = new FlowMsgModel(); flowMsgModel.setNodeList(nodeEntityList); flowMsgModel.setTaskEntity(taskEntity); flowMsgModel.setFlowModel(flowModel); flowMsgModel.setEnd(true); flowMsgModel.setFormData(FlowContextHolder.getAllData()); msgUtil.message(flowMsgModel); return true; } } } return false; } // 判断能否归档 public AuditModel getAuditModel(String taskId, FlowModel flowModel, OperatorEntity operator) { TaskEntity task = taskService.getById(taskId); AuditModel model = new AuditModel(); if (operator != null && ObjectUtil.equals(operator.getStatus(), OperatorStateEnum.Revoke.getCode())) { return model; } if (task != null) { model.setTaskId(taskId); if (task.getEndTime() != null) { NodeModel global = flowModel.getNodes().get(NodeEnum.global.getType()); FileConfig config = global.getFileConfig(); if (config.getOn() && StringUtil.isNotBlank(config.getTemplateId())) { model.setIsEnd(true); } } } return model; } // 子流程结束 要处理的事情 public void subFlowOfEnd(FlowModel flowModel) throws Exception { TaskEntity taskEntity = flowModel.getTaskEntity(); if (StringUtil.equals(FlowNature.ParentId, taskEntity.getParentId())) { return; } // 获取父级节点集合 TaskEntity parentTask = taskService.getInfo(taskEntity.getParentId()); if (null == parentTask) { throw new WorkFlowException(MsgCode.FA001.get()); } TemplateJsonEntity jsonEntity = templateJsonService.getById(parentTask.getFlowId()); String deploymentId = jsonEntity.getFlowableId(); List parentNodeList = templateNodeService.getList(parentTask.getFlowId()); String subCode = taskEntity.getSubCode(); SubParameterModel subParameter = JsonUtil.getJsonToBean(taskEntity.getSubParameter(), SubParameterModel.class); String flowableTaskId = subParameter.getNodeId(); String parentCode = subParameter.getParentCode(); TemplateNodeEntity parentNode = parentNodeList.stream() .filter(e -> e.getNodeCode().equals(parentCode)).findFirst().orElse(new TemplateNodeEntity()); TemplateNodeEntity subNode = parentNodeList.stream() .filter(e -> e.getNodeCode().equals(subCode)).findFirst().orElse(new TemplateNodeEntity()); NodeModel nodeModel = JsonUtil.getJsonToBean(subNode.getNodeJson(), NodeModel.class); if (nodeModel == null) { return; } // 判断是否依次创建，存在依次创建的子流程数据，则发起子流程 if (!ObjectUtil.equals(nodeModel.getCreateRule(), FlowNature.ChildSync)) { List list = subtaskDataService.getList(taskEntity.getParentId(), subCode); if (CollectionUtil.isNotEmpty(list)) { SubtaskDataEntity subtaskData = list.get(0); FlowModel model = JsonUtil.getJsonToBean(subtaskData.getSubtaskJson(), FlowModel.class); taskService.batchSaveOrSubmit(model); subtaskDataService.removeById(subtaskData); operatorUtil.autoAudit(model); return; } } // 判断下一级是否子流程节点，且是否存在候选人 NextOrPrevFo fo = new NextOrPrevFo(); fo.setDeploymentId(deploymentId); fo.setTaskKey(subCode); List nextModels = flowAbleUrl.getNext(fo); for (FlowableNodeModel nextModel : nextModels) { TemplateNodeEntity nodeEntity = parentNodeList.stream().filter(e -> ObjectUtil.equals(e.getNodeCode(), nextModel.getId())) .findFirst().orElse(new TemplateNodeEntity()); if (ObjectUtil.equals(nodeEntity.getNodeType(), NodeEnum.subFlow.getType())) { NodeModel subFlow = JsonUtil.getJsonToBean(nodeEntity.getNodeJson(), NodeModel.class); TemplateEntity template = templateService.getById(subFlow.getFlowId()); TemplateJsonEntity subJsonEntity = templateJsonService.getById(template.getFlowId()); List subNodeList = templateNodeService.getList(template.getFlowId()); Map subNodes = new HashMap<>(); for (TemplateNodeEntity node : subNodeList) { subNodes.put(node.getNodeCode(), JsonUtil.getJsonToBean(node.getNodeJson(), NodeModel.class)); } TemplateNodeEntity subStart = subNodeList.stream() .filter(e -> StringUtil.equals(NodeEnum.start.getType(), e.getNodeType())).findFirst().orElse(new TemplateNodeEntity()); FlowMethod method = new FlowMethod(); method.setDeploymentId(subJsonEntity.getFlowableId()); method.setNodes(subNodes); method.setNodeEntityList(subNodeList); method.setNodeCode(subStart.getNodeCode()); if (this.checkBranch(subStart)) { throw new WorkFlowException(MsgCode.WF121.get()); } List nextApprover = this.getNextApprover(method); if (!this.checkNextCandidates(nextApprover)) { throw new WorkFlowException(MsgCode.WF121.get()); } FlowModel model = new FlowModel(); model.setDeploymentId(flowModel.getDeploymentId()); model.setNodeEntityList(subNodeList); if (this.checkNextError(model, nextApprover, false, false) != 0) { throw new WorkFlowException(MsgCode.WF121.get()); } } } if (nodeModel.getIsAsync().equals(FlowNature.ChildAsync)) { // 异步已经完成节点 return; } // 父节点下的子流程 QueryWrapper wrapper = new QueryWrapper<>(); wrapper.lambda().eq(TaskEntity::getParentId, taskEntity.getParentId()) .eq(TaskEntity::getSubCode, subCode); List subList = taskService.list(wrapper); // 未审批集合 List unfinishedList = subList.stream() .filter(e -> !e.getStatus().equals(TaskStatusEnum.PASSED.getCode()) && !e.getStatus().equals(TaskStatusEnum.REJECTED.getCode())) .collect(Collectors.toList()); if (unfinishedList.isEmpty()) { FlowModel model = JsonUtil.getJsonToBean(flowModel, FlowModel.class); model.setFinishFlag(true); subList = subList.stream().filter(e -> null != e.getEndTime()) .sorted(Comparator.comparing(TaskEntity::getEndTime).reversed()).collect(Collectors.toList()); if (CollectionUtil.isNotEmpty(subList)) { TaskEntity finalTask = subList.get(0); model.setHandleStatus(ObjectUtil.equals(finalTask.getStatus(), TaskStatusEnum.PASSED.getCode()) ? 1 : 0); } else { model.setHandleStatus(1); } String formId = parentNode.getFormId(); this.setFlowModel(parentTask.getId(), model); Map nodes = model.getNodes(); Map formData = serviceUtil.infoData(formId, parentTask.getId()); model.setFormData(formData); FlowMethod flowMethod = new FlowMethod(); flowMethod.setDeploymentId(model.getDeploymentId()); flowMethod.setNodeCode(subCode); flowMethod.setFormData(formData); flowMethod.setNodes(nodes); flowMethod.setTaskEntity(parentTask); Map resMap = conditionService.handleCondition(flowMethod); conditionService.checkCondition(resMap, nodes); flowMethod.setFlowModel(model); flowMethod.setFlowableTaskId(flowableTaskId); flowMethod.setResMap(resMap); flowMethod.setNodeEntityList(parentNodeList); // 递归subCode的所有上级节点，获取审批节点的经办 model.setOperatorEntity(new OperatorEntity()); List nodeCodeList = new ArrayList<>(); prevNodeList(flowModel.getDeploymentId(), subCode, parentNodeList, nodeCodeList); if (CollectionUtil.isNotEmpty(nodeCodeList)) { List list = operatorUtil.getList(parentTask.getId(), nodeCodeList); if (CollectionUtil.isNotEmpty(list)) { model.setOperatorEntity(list.get(0)); } } operatorUtil.completeNode(flowMethod); } } // 删除子流程（退回时若是重新审批） public void deleteSubflow(String taskId, List nodeCodeList) { QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.lambda().eq(TaskEntity::getParentId, taskId); if (CollectionUtil.isNotEmpty(nodeCodeList)) { queryWrapper.lambda().in(TaskEntity::getSubCode, nodeCodeList); } List list = taskService.list(queryWrapper); if (CollectionUtil.isNotEmpty(list)) { List idList = list.stream().map(TaskEntity::getId).distinct().collect(Collectors.toList()); List idAll = new ArrayList<>(); taskService.deleTaskAll(idList, idAll); List childList = taskService.getInfosSubmit(idAll.toArray(new String[]{}), TaskEntity::getId, TaskEntity::getFlowId); for (TaskEntity entity : childList) { operatorUtil.addDelTask(entity.getId(), entity.getFlowId()); } taskService.setIgnoreLogicDelete().removeByIds(idAll); taskService.clearIgnoreLogicDelete(); } } /** * 判断任务是否在挂起状态 * * @param taskEntity 任务 */ public void isSuspend(TaskEntity taskEntity) throws WorkFlowException { Integer status = taskEntity != null ? taskEntity.getStatus() : null; if (TaskStatusEnum.PAUSED.getCode().equals(status)) { throw new WorkFlowException(MsgCode.WF114.get()); } } /** * 判断任务是否终止状态 * * @param taskEntity 任务 */ public void isCancel(TaskEntity taskEntity) throws WorkFlowException { Integer status = taskEntity != null ? taskEntity.getStatus() : null; if (ObjectUtil.equals(TaskStatusEnum.CANCEL.getCode(), status)) { throw new WorkFlowException(MsgCode.WF123.get()); } } /** * 获取审批人 * * @param flowMethod * @return */ public List userListAll(FlowMethod flowMethod) throws WorkFlowException { List nodeEntityList = flowMethod.getNodeEntityList(); TemplateNodeEntity nodeEntity = flowMethod.getNodeEntity(); NodeModel nodeModel = JsonUtil.getJsonToBean(nodeEntity.getNodeJson(), NodeModel.class); TemplateNodeEntity globalEntity = nodeEntityList.stream().filter(t -> NodeEnum.global.getType().equals(t.getNodeType())).findFirst().get(); NodeModel global = JsonUtil.getJsonToBean(globalEntity.getNodeJson(), NodeModel.class); Integer errRule = global.getErrorRule(); List errRuleUser = global.getErrorRuleUser(); // 子流程去获取指定成员、异常处理 if (StringUtil.equals(nodeModel.getType(), NodeEnum.subFlow.getType())) { errRule = nodeModel.getErrorRule(); errRuleUser = nodeModel.getErrorRuleUser(); } Boolean errorRule = flowMethod.getErrorRule(); int pass = 0; int notSubmit = 0; int node = 0; Boolean extraRule = flowMethod.getExtraRule(); TaskEntity taskEntity = flowMethod.getTaskEntity(); List userIdAll = user(flowMethod, nodeModel.getAssigneeType()); // String admin = serviceUtil.getAdmin(); // userIdAll = userIdAll.stream().filter(e -> !ObjectUtil.equals(e, admin)).distinct().collect(Collectors.toList()); //附加规则 if (extraRule && !nodeModel.getIsCandidates()) { rule(userIdAll, taskEntity.getId(), nodeModel.getExtraRule()); } //获取最新用户 List userList = serviceUtil.getUserName(userIdAll, true); // 子流程权限 if (StringUtil.equals(nodeModel.getType(), NodeEnum.subFlow.getType())) { String flowId = nodeModel.getFlowId(); TemplateEntity template = templateService.getById(flowId); if (template != null && template.getVisibleType().equals(FlowNature.Authority) && ObjectUtil.equals(template.getStatus(), TemplateStatueEnum.up.getCode())) { List list = new ArrayList<>(userList); if (nodeModel.getHasPermission()) { for (UserEntity user : list) { if (serviceUtil.isCommonUser(user.getId())) { List flowIds = serviceUtil.getPermission(user.getId()); // 权限中不存在 该流程版本 if (!flowIds.contains(flowId)) { UserEntity userEntity = list.stream().filter(e -> e.getId().equals(user.getId())).findFirst().orElse(null); if (null != userEntity) { userList.remove(user); } } } } } } } userIdAll = userList.stream().map(UserEntity::getId).collect(Collectors.toList()); //异常规则 if (errorRule && userList.isEmpty()) { //异常处理规则 switch (ErrorRuleEnum.getByCode(errRule)) { case administrator: userIdAll.add(serviceUtil.getAdmin()); break; case initiator: List errorRuleUser = serviceUtil.getUserName(errRuleUser, true); if (!errorRuleUser.isEmpty()) { userIdAll.addAll(errorRuleUser.stream().map(UserEntity::getId).collect(Collectors.toList())); } else { userIdAll.add(serviceUtil.getAdmin()); } break; case node: String nodeId = nodeEntity.getNodeCode(); List userId = new ArrayList<>(); List list = candidatesService.getList(taskEntity.getId(), nodeId); for (CandidatesEntity t : list) { List candidates = StringUtil.isNotEmpty(t.getCandidates()) ? Arrays.stream(t.getCandidates().split(",")).collect(Collectors.toList()) : new ArrayList<>(); userId.addAll(candidates); } if (!list.isEmpty()) { List errorRuleUserList = serviceUtil.getUserName(userId, true); if (!errorRuleUserList.isEmpty()) { userIdAll.addAll(errorRuleUserList.stream().map(UserEntity::getId).collect(Collectors.toList())); } else { userIdAll.add(serviceUtil.getAdmin()); } } node++; break; case pass: pass++; break; case notSubmit: notSubmit++; break; case creatorUserId: userIdAll.add(taskEntity.getCreatorUserId()); break; default: break; } } flowMethod.setPass(pass); flowMethod.setNotSubmit(notSubmit); flowMethod.setNode(node); return userIdAll; } /** * 附加条件 */ public void rule(List userIdAll, String taskId, int rule) { LaunchUserEntity flowUser = launchUserService.getInfoByTask(taskId); if (flowUser != null) { rule(userIdAll, flowUser, rule); } } // 附加条件过滤 public void rule(List userIdAll, LaunchUserEntity flowUser, int rule) { List ruleList = ImmutableList.of(ExtraRuleEnum.organize.getCode(), ExtraRuleEnum.position.getCode(), ExtraRuleEnum.manager.getCode(), ExtraRuleEnum.subordinate.getCode(), ExtraRuleEnum.department.getCode()); if (ruleList.contains(rule)) { if (flowUser != null) { List organizeList = flowUser.getOrganizeId() != null ? Arrays.asList(flowUser.getOrganizeId().split(",")) : new ArrayList<>(); List positionList = flowUser.getPositionId() != null ? Arrays.asList(flowUser.getPositionId().split(",")) : new ArrayList<>(); List managerList = flowUser.getManagerId() != null ? Arrays.asList(flowUser.getManagerId().split(",")) : new ArrayList<>(); List subordinateList = flowUser.getSubordinate() != null ? Arrays.asList(flowUser.getSubordinate().split(",")) : new ArrayList<>(); List userList = serviceUtil.getUserName(userIdAll, true); List userListAll = userList.stream().map(UserEntity::getId).collect(Collectors.toList()); //同一部门、公司的用户 Map> userMap = new HashMap<>(); Map> relationUserList = serviceUtil.getListByUserIdAll(userListAll).stream().filter(t -> StringUtil.isNotEmpty(t.getObjectId())).collect(Collectors.groupingBy(UserRelationEntity::getObjectId)); //附加条件 switch (ExtraRuleEnum.getByCode(rule)) { case organize: for (String organizeId : organizeList) { OrganizeEntity organizeInfo = serviceUtil.getOrganizeInfo(organizeId); if (null != organizeInfo && Objects.equals(organizeInfo.getCategory(), PermissionConst.DEPARTMENT)) { List userId = userMap.get(organizeId) != null ? userMap.get(organizeId) : new ArrayList<>(); if (relationUserList.get(organizeId) != null) { userId.addAll(relationUserList.get(organizeId).stream().map(UserRelationEntity::getUserId).collect(Collectors.toList())); } userMap.put(organizeId, userId); } } List userIdList = new ArrayList<>(); for (String key : userMap.keySet()) { List id = userMap.get(key); if (ObjectUtil.isEmpty(id)) { continue; } userIdList.addAll(id); } userIdAll.retainAll(userIdList); break; case position: List position = new ArrayList<>(); for (String positionId : positionList) { if (relationUserList.get(positionId) != null) { position.addAll(relationUserList.get(positionId).stream().map(UserRelationEntity::getUserId).collect(Collectors.toList())); } } userIdAll.retainAll(position); break; case manager: List manager = new ArrayList<>(); manager.addAll(managerList); userIdAll.retainAll(manager); break; case subordinate: List subordinate = new ArrayList<>(); for (String subordinateId : subordinateList) { if (StringUtil.isNotEmpty(subordinateId)) { subordinate.addAll(new ArrayList<>(Arrays.asList(subordinateId.split(",")))); } } userIdAll.retainAll(subordinate); break; case department: List categoryList = ImmutableList.of("agency", "office"); for (String organizeId : organizeList) { OrganizeEntity organizeInfo = serviceUtil.getOrganizeInfo(organizeId); if (organizeInfo == null || categoryList.contains(organizeInfo.getCategory())) { continue; } List orgList = serviceUtil.getDepartmentAll(organizeId).stream().map(OrganizeEntity::getId).collect(Collectors.toList()); List departmentAll = serviceUtil.getListByOrgIds(orgList).stream().map(PositionEntity::getId).collect(Collectors.toList()); for (String id : departmentAll) { List userId = userMap.get(id) != null ? userMap.get(id) : new ArrayList<>(); if (relationUserList.get(id) != null) { userId.addAll(relationUserList.get(id).stream().map(UserRelationEntity::getUserId).collect(Collectors.toList())); } userMap.put(id, userId); } } if (!userMap.isEmpty()) { List userId = new ArrayList<>(); for (String key : userMap.keySet()) { List id = userMap.get(key); if (ObjectUtil.isEmpty(id)) { continue; } userId.addAll(id); } userIdAll.retainAll(userId); } break; default: break; } } } } public void getByRule(List userIdAll, UserEntity flowUser, int rule) { if (flowUser != null) { String userId = flowUser.getId(); //附加条件 switch (ExtraRuleEnum.getByCode(rule)) { case role: List roleId = serviceUtil.getRoleObjectId(ImmutableList.of(userId)).stream().map(RoleRelationEntity::getRoleId).collect(Collectors.toList()); List userIdList = serviceUtil.getListByRoleId(roleId).stream().map(RoleRelationEntity::getObjectId).collect(Collectors.toList()); List roleUserId = userIdList.stream().filter(e -> !ObjectUtil.equals(e, userId)).collect(Collectors.toList()); userIdAll.addAll(roleUserId); break; case organize: case group: case position: String type = Objects.equals(ExtraRuleEnum.group.getCode(), rule) ? PermissionConst.GROUP : PermissionConst.POSITION; List userRelationList = serviceUtil.getListByUserIdAll(ImmutableList.of(userId)); List objectIdList = new ArrayList<>(); List idList = userRelationList.stream().filter(e -> ObjectUtil.equals(e.getObjectType(), type)) .map(UserRelationEntity::getObjectId).collect(Collectors.toList()); if (Objects.equals(ExtraRuleEnum.organize.getCode(), rule)) { List positionList = serviceUtil.getPosList(idList); List organizeList = positionList.stream().map(PositionEntity::getOrganizeId).collect(Collectors.toList()); List orgList = serviceUtil.getOrganizeList(organizeList).stream().filter(e -> Objects.equals(e.getCategory(), PermissionConst.DEPARTMENT)).map(OrganizeEntity::getId).collect(Collectors.toList()); objectIdList.addAll(orgList); } else { objectIdList.addAll(idList); } List userIds = serviceUtil.getListByObjectIdAll(objectIdList).stream().map(UserRelationEntity::getUserId) .filter(e -> !ObjectUtil.equals(e, userId)).collect(Collectors.toList()); userIdAll.addAll(userIds); break; } } } /** * 封装查询审批人 */ private List user(FlowMethod flowMethod, int type) throws WorkFlowException { List userIdAll = new ArrayList<>(); Boolean isCandidates = flowMethod.getIsCandidates(); TemplateNodeEntity nodeEntity = flowMethod.getNodeEntity(); NodeModel nodeModel = JsonUtil.getJsonToBean(nodeEntity.getNodeJson(), NodeModel.class); TaskEntity taskEntity = flowMethod.getTaskEntity(); String createUserId = taskEntity.getCreatorUserId(); FlowModel flowModel = flowMethod.getFlowModel(); OperatorEntity operator = flowModel.getOperatorEntity(); String deploymentId = flowModel.getDeploymentId(); Boolean autoAudit = flowModel.getAutoAudit(); List nodeEntityList = flowMethod.getNodeEntityList(); List prevList = new ArrayList<>(); TemplateNodeEntity startNode = nodeEntityList.stream().filter(e -> ObjectUtil.equals(e.getNodeType(), NodeEnum.start.getType())).findFirst().orElse(null); boolean prevIsStart = false; if (nodeModel.getIsCandidates() && isCandidates) { String nodeCode = nodeEntity.getNodeCode(); List candidatesList = candidatesService.getList(taskEntity.getId(), nodeCode); if (CollectionUtil.isNotEmpty(candidatesList)) { List opIds = candidatesList.stream().map(CandidatesEntity::getOperatorId).collect(Collectors.toList()); List operators = operatorService.listByIds(opIds); for (CandidatesEntity t : candidatesList) { OperatorEntity op = operators.stream().filter(e -> ObjectUtil.equals(e.getId(), t.getOperatorId())).findFirst().orElse(null); if (null != op && null == op.getHandleStatus() && null != op.getHandleParameter()) { continue; } List candidates = StringUtil.isNotEmpty(t.getCandidates()) ? Arrays.stream(t.getCandidates().split(",")).collect(Collectors.toList()) : new ArrayList<>(); userIdAll.addAll(candidates); } } return userIdAll; } //发起者【发起者主管】 if (OperatorEnum.LaunchCharge.getCode().equals(type)) { this.prevNode(deploymentId, nodeEntity.getNodeCode(), nodeEntityList, prevList); if (null != startNode) { prevIsStart = prevList.contains(startNode.getNodeCode()); } List userId = new ArrayList<>(); // 判断 发起人、上一节点 Integer approverType = nodeModel.getApproverType(); if (ObjectUtil.equals(approverType, FlowNature.Previously) && !prevIsStart) { List handleIds = new ArrayList<>(); if (!isCandidates) { if (prevList.contains(operator.getNodeCode())) { handleIds.add(operator.getHandleId()); } } else { handleIds.addAll(this.getHandleIds(taskEntity.getId(), operator, autoAudit)); } List userList = serviceUtil.getUserName(handleIds); userId.addAll(userList.stream().map(UserEntity::getId).collect(Collectors.toList())); } else { userId.add(createUserId); } for (String id : userId) { List userPositionList = serviceUtil.getListByUserIdAll(ImmutableList.of(id)).stream() .filter(t -> PermissionConst.POSITION.equals(t.getObjectType())).collect(Collectors.toList()); for (UserRelationEntity relation : userPositionList) { UserEntity user = new UserEntity(); user.setPositionId(relation.getObjectId()); String managerByLevel = getManagerByLevel(user, nodeModel.getManagerLevel()); if (StringUtil.isNotEmpty(managerByLevel)) { userIdAll.add(managerByLevel); } } } } //【发起本人】 if (OperatorEnum.InitiatorMe.getCode().equals(type)) { userIdAll.add(createUserId); } //【变量】 if (OperatorEnum.Variate.getCode().equals(type)) { flowMethod.setIsAssign(false); Map dataAll = flowMethod.getSubFormData(); if (CollectionUtil.isEmpty(dataAll)) { dataAll = !isCandidates ? flowModel.getFormData() : createOrUpdate(flowMethod); } Object data = this.getOneData(dataAll, nodeModel.getFormField()); List handleIdAll = this.getUserId(data); userIdAll.addAll(handleIdAll); } //【环节】 if (OperatorEnum.Link.getCode().equals(type)) { List list = recordUtil.getList(taskEntity.getId()); list = list.stream().filter(e -> ObjectUtil.equals(e.getNodeCode(), nodeModel.getApproverNodeId()) && (FlowNature.AuditCompletion.equals(e.getHandleType()) || FlowNature.RejectCompletion.equals(e.getHandleType())) && !FlowNature.Invalid.equals(e.getStatus()) && !e.getHandleId().equals(FlowNature.SYSTEM_CODE) && !e.getHandleId().equals(FlowNature.ParentId)) .collect(Collectors.toList()); List handleId = list.stream().map(RecordEntity::getHandleId).collect(Collectors.toList()); if (CollectionUtil.isEmpty(handleId) && autoAudit) { handleId.add(operator.getHandleId()); } userIdAll.addAll(handleId); } //【服务】 if (OperatorEnum.Serve.getCode().equals(type)) { flowMethod.setIsAssign(false); Map dataAll = !isCandidates ? flowModel.getFormData() : createOrUpdate(flowMethod); InterfaceConfig interfaceConfig = nodeModel.getInterfaceConfig(); String interfaceId = interfaceConfig.getInterfaceId(); if (StringUtil.isNotEmpty(interfaceId)) { UserInfo userInfo = UserProvider.getUser(); List templateJsonModelList = interfaceConfig.getTemplateJson(); RecordEntity record = new RecordEntity(); record.setTaskId(taskEntity.getId()); record.setNodeCode(nodeEntity.getNodeCode()); record.setHandleId(userInfo.getUserId()); FlowModel parameterModel = new FlowModel(); parameterModel.setFormData(dataAll); parameterModel.setRecordEntity(record); parameterModel.setTaskEntity(taskEntity); Map parameterMap = msgUtil.parameterMap(parameterModel, templateJsonModelList); ActionResult result = serviceUtil.infoToId(interfaceId, parameterMap); if (Objects.equals(200, result.getCode())) { Object data = result.getData(); if (data instanceof Map) { JSONObject map = new JSONObject((Map) data); List handleId = StringUtil.isNotEmpty(map.getString("handleId")) ? Arrays.asList(map.getString("handleId").split(",")) : new ArrayList<>(); userIdAll.addAll(handleId); } } } } //【指定人】 if (OperatorEnum.Nominator.getCode().equals(type)) { List handleIdAll = serviceUtil.getUserListAll(nodeModel.getApprovers()); userIdAll.addAll(handleIdAll); } //【逐级】 if (OperatorEnum.Step.getCode().equals(type)) { LaunchUserEntity launchUser = new LaunchUserEntity(); launchUser.setId(RandomUtil.uuId()); launchUser.setNodeCode(nodeModel.getNodeId()); launchUser.setTaskId(taskEntity.getId()); launchUser.setType(FlowNature.StepInitiation); launchUser.setCreatorTime(new Date()); this.prevNode(deploymentId, nodeEntity.getNodeCode(), nodeEntityList, prevList); if (null != startNode) { prevIsStart = prevList.contains(startNode.getNodeCode()); } // 判断 发起人、上一节点 String userId = createUserId; ApproversConfig approversConfig = nodeModel.getApproversConfig(); Integer start = approversConfig.getStart(); if (ObjectUtil.equals(start, FlowNature.Previously) && !prevIsStart) { List handleIds = this.getHandleIds(taskEntity.getId(), operator, autoAudit); userId = !handleIds.isEmpty() ? handleIds.get(0) : ""; } UserEntity info = serviceUtil.getUserInfo(userId); String managerByLevel = getManagerByLevel(info, 1); //直属主管 UserEntity managerInfo = serviceUtil.getUserInfo(managerByLevel); if (managerInfo != null) { userIdAll.add(managerInfo.getId()); //保存逐级对象 PositionEntity positionInfo = serviceUtil.getPositionInfo(info.getPositionId()); if (positionInfo != null) { launchUser.setPositionId(positionInfo.getPositionIdTree()); launchUser.setOrganizeId(positionInfo.getOrganizeId()); OrganizeEntity organizeInfo = serviceUtil.getOrganizeInfo(positionInfo.getOrganizeId()); if (organizeInfo != null) { launchUser.setOrganizeId(organizeInfo.getOrganizeIdTree()); } launchUser.setCreatorUserId(userId); flowMethod.setLaunchUser(launchUser); } } } return userIdAll; } public Object getOneData(Map map, String key) { Object obj = null; if (null != map) { obj = map.get(key + FlowNature.FORM_FIELD_SUFFIX); if (null == obj) { obj = map.get(key); } } return obj; } //字段的值获取用户 public List getUserId(Object data) { List userIdList = new ArrayList<>(); if (ObjectUtil.isNotEmpty(data)) { List list = new ArrayList<>(); try { list.addAll(JsonUtil.getJsonToList(String.valueOf(data), String.class)); } catch (Exception e) { } if (data instanceof List) { list.addAll((List) data); } else { list.addAll(Arrays.asList(String.valueOf(data).split(","))); } List id = new ArrayList<>(); for (String s : list) { id.add(s.split("--")[0]); } List userRelationList = serviceUtil.getListByObjectIdAll(id); List roleRelationList = serviceUtil.getListByRoleId(id); List userList = serviceUtil.getUserListAll(list); List userRelation = userRelationList.stream().map(UserRelationEntity::getUserId).collect(Collectors.toList()); List roleRelation = roleRelationList.stream().map(RoleRelationEntity::getObjectId).collect(Collectors.toList()); Set handleIdAll = new HashSet<>(); handleIdAll.addAll(userRelation); handleIdAll.addAll(roleRelation); handleIdAll.addAll(id); handleIdAll.addAll(userList); userIdList.addAll(handleIdAll); } return userIdList; } //封装用户对象 public List getUserModel(List ids, Pagination pagination) { List userIds = serviceUtil.getUserListAll(ids); List userList = serviceUtil.getUserName(userIds, pagination); pagination.setTotal(pagination.getTotal()); List userIdList = userList.stream().map(UserEntity::getId).collect(Collectors.toList()); List userRelationList = serviceUtil.getListByUserIdAll(userIdList); Map> userMap = userRelationList.stream() .filter(t -> PermissionConst.POSITION.equals(t.getObjectType())).collect(Collectors.groupingBy(UserRelationEntity::getUserId)); List list = new ArrayList<>(); for (UserEntity user : userList) { CandidateUserVo vo = JsonUtil.getJsonToBean(user, CandidateUserVo.class); vo.setFullName(user.getRealName() + "/" + user.getAccount()); vo.setHeadIcon(UploaderUtil.uploaderImg(user.getHeadIcon())); List listByUserId = userMap.get(user.getId()) != null ? userMap.get(user.getId()) : new ArrayList<>(); StringJoiner joiner = new StringJoiner(","); for (UserRelationEntity relation : listByUserId) { StringJoiner name = new StringJoiner("/"); PositionEntity position = serviceUtil.getPositionInfo(relation.getObjectId()); if (position != null) { OrganizeEntity organize = serviceUtil.getOrganizeInfo(position.getOrganizeId()); if (organize != null) { List organizeIdTree = new ArrayList<>(Arrays.asList(organize.getOrganizeIdTree().split(","))); List organizeList = serviceUtil.getOrganizeList(organizeIdTree); for (String organizeId : organizeIdTree) { OrganizeEntity entity = organizeList.stream().filter(e -> Objects.equals(e.getId(), organizeId)).findFirst().orElse(null); if (entity != null) { name.add(entity.getFullName()); } } } List positionIdTree = new ArrayList<>(Arrays.asList(position.getPositionIdTree().split(","))); List positionList = serviceUtil.getPosList(positionIdTree); for (String positionId : positionIdTree) { PositionEntity entity = positionList.stream().filter(e -> Objects.equals(e.getId(), positionId)).findFirst().orElse(null); if (entity != null) { name.add(entity.getFullName()); } } } joiner.add(name.toString()); } vo.setOrganize(joiner.toString()); list.add(vo); } return list; } // 根据经办获取上一审批节点的审批人 public List getHandleIds(String taskId, OperatorEntity operator, boolean autoAudit) { List handleIds = new ArrayList<>(); List operatorList = operatorUtil.getList(taskId); if (CollectionUtil.isNotEmpty(operatorList)) { List list = operatorList.stream() .filter(e -> e.getHandleTime() != null && ObjectUtil.equals(e.getNodeId(), operator.getNodeId())).sorted(Comparator.comparing(OperatorEntity::getHandleTime).reversed()).collect(Collectors.toList()); handleIds = list.stream().map(OperatorEntity::getHandleId).collect(Collectors.toList()); } if (CollectionUtil.isEmpty(handleIds) && autoAudit) { handleIds.add(operator.getHandleId()); } return handleIds; } /** * 递归主管 * * @param userEntity 用户 * @param level 第几级 * @return */ public String getManagerByLevel(UserEntity userEntity, int level) { return getManagerByLevel(userEntity, level, false); } public String getManagerByLevel(UserEntity userEntity, int level, boolean isOrganize) { String managerUser = ""; if (userEntity == null) { return managerUser; } String positionId = ""; if (isOrganize) { PositionEntity positionEntity = serviceUtil.getPositionInfo(userEntity.getPositionId()); if (positionEntity != null) { OrganizeEntity organizeInfo = serviceUtil.getOrganizeInfo(positionEntity.getOrganizeId()); positionId = getManageOrg(organizeInfo, level); } } else { PositionEntity positionEntity = serviceUtil.getPositionInfo(userEntity.getPositionId()); positionId = getManagerPos(positionEntity, level); } PositionEntity position = serviceUtil.getPositionInfo(positionId); return position != null && StringUtil.isNotEmpty(position.getDutyUser()) ? position.getDutyUser() : ""; } /** * 查询岗位 */ public String getManagerPos(PositionEntity position, int level) { String positionId = ""; if (position != null) { String[] tree = position.getPositionIdTree().split(","); positionId = position.getId(); for (int i = tree.length - 1; i >= 0; i--) { String id = tree[i]; if (Objects.equals(id, position.getId())) { continue; } --level; positionId = id; if (level == 0) { break; } } if (level > 0) { PositionEntity positionInfo = serviceUtil.getPositionInfo(positionId); if (positionInfo != null) { OrganizeEntity organizeInfo = serviceUtil.getOrganizeInfo(positionInfo.getOrganizeId()); return getManageOrg(organizeInfo, level); } } } return positionId; } /** * 查询组织 */ private String getManageOrg(OrganizeEntity organize, long level) { List organizeList = new ArrayList<>(); organizeList.add(organize.getId()); String[] tree = organize.getOrganizeIdTree().split(","); for (int i = tree.length - 1; i >= 0; i--) { String id = tree[i]; if (Objects.equals(id, organize.getId())) { continue; } --level; organizeList.add(id); if (level == 0) { break; } } OrganizeEntity entity = serviceUtil.getOrganizeInfo(organizeList.get(organizeList.size() - 1)); return level == 0 && entity != null ? entity.getDutyPosition() : ""; } /** * 保存、更新数据，仅处理数据 */ public Map createOrUpdate(FlowMethod flowMethod) throws WorkFlowException { TaskEntity taskEntity = flowMethod.getTaskEntity(); TemplateNodeEntity nodeEntity = flowMethod.getNodeEntity(); NodeModel nodeModel = JsonUtil.getJsonToBean(nodeEntity.getNodeJson(), NodeModel.class); FlowModel flowModel = flowMethod.getFlowModel(); Map formData = flowModel.getFormData(); Map data = new HashMap<>(); //保存数据的表单 String formId = nodeEntity.getFormId(); // 子流程选择的流程版本id String taskId = taskEntity.getId(); String resultNodeCode = resultNodeCode(flowMethod); flowMethod.setResultNodeCode(resultNodeCode); List assignList = nodeModel.getAssignList().stream().filter(e -> e.getNodeId().equals(resultNodeCode)).collect(Collectors.toList()); //获取当前表单 Map thisNodeData = infoData(formId, taskId); data.putAll(thisNodeData); data.putAll(formData(formData, assignList, taskEntity, flowMethod)); return data; } /** * 获取节点的最后一个审批节点 */ public String resultNodeCode(FlowMethod flowMethod) throws WorkFlowException { TaskEntity taskEntity = flowMethod.getTaskEntity(); TemplateNodeEntity nodeEntity = flowMethod.getNodeEntity(); List nodeEntityList = flowMethod.getNodeEntityList(); FlowModel flowModel = flowMethod.getFlowModel(); Map formData = flowModel.getFormData(); // 子流程选择的流程版本id String taskId = taskEntity.getId(); List handleStatus = ImmutableList.of(RecordEnum.audit.getCode(), RecordEnum.submit.getCode()); //递归 List nodeIdList = new ArrayList<>(); prevNodeList(flowModel.getDeploymentId(), nodeEntity.getNodeCode(), nodeEntityList, nodeIdList); List list = recordService.getRecordList(taskId, handleStatus).stream().filter(t -> nodeIdList.contains(t.getNodeCode())).sorted(Comparator.comparing(RecordEntity::getHandleTime).reversed()).collect(Collectors.toList()); List recordNodeIdList = new ArrayList<>(); for (int i = 0; i < list.size(); i++) { if (i == 0) { recordNodeIdList.add(list.get(i).getNodeCode()); } } List taskNodeEntity = nodeEntityList.stream().filter(t -> nodeIdList.contains(t.getNodeCode())).collect(Collectors.toList()); if (taskNodeEntity.isEmpty()) { taskNodeEntity.addAll(nodeEntityList.stream().filter(t -> recordNodeIdList.contains(t.getNodeCode())).collect(Collectors.toList())); } String nodeCode = ""; if (CollectionUtil.isNotEmpty(list)) { nodeCode = list.get(0).getNodeCode(); } else { if (!taskNodeEntity.isEmpty()) { nodeCode = taskNodeEntity.get(0).getNodeCode(); } } if (!taskNodeEntity.isEmpty()) { formData.put(FlowConstant.PREV_NODE_FORM_ID, taskNodeEntity.get(0).getFormId()); } return nodeCode; } /** * 处理数据传递，并存储在线程，后续保存数据库 */ public Map dataTransfer(FlowMethod flowMethod) throws WorkFlowException { List nodeEntityList = flowMethod.getNodeEntityList(); FlowModel flowModel = flowMethod.getFlowModel(); Map formData = flowModel.getFormData(); TemplateNodeEntity globalEntity = nodeEntityList.stream().filter(e -> ObjectUtil.equals(e.getNodeType(), NodeEnum.global.getType())).findFirst().orElse(null); // 判断是否能数据传递 if (null != globalEntity) { NodeModel global = JsonUtil.getJsonToBean(globalEntity.getNodeJson(), NodeModel.class); if (!global.getHasAloneConfigureForms()) { return formData; } } TemplateNodeEntity nodeEntity = flowMethod.getNodeEntity(); NodeModel nodeModel = JsonUtil.getJsonToBean(nodeEntity.getNodeJson(), NodeModel.class); if (CollectionUtil.isEmpty(nodeModel.getAssignList())) { return formData; } TaskEntity taskEntity = flowMethod.getTaskEntity(); String rejectDataId = taskEntity.getRejectDataId(); //保存数据的表单 String formId = nodeEntity.getFormId(); String taskId = taskEntity.getId(); boolean isAssign = flowMethod.getIsAssign(); Map data = createOrUpdate(flowMethod); String resultNodeCode = flowMethod.getResultNodeCode(); //判断是否是外部节点最后一个审批 TemplateNodeEntity resultNode = nodeEntityList.stream().filter(e -> Objects.equals(e.getNodeCode(), resultNodeCode)).findFirst().orElse(null); if (resultNode != null && Objects.equals(resultNode.getNodeType(), NodeEnum.outside.getType())) { //判断是否是从当前节点回来 if (StringUtil.isNotEmpty(rejectDataId)) { return formData; } } List typeList = ImmutableList.of(NodeEnum.end.getType(), NodeEnum.subFlow.getType()); if (isAssign) { boolean isWrite = !typeList.contains(nodeModel.getType()); FlowContextHolder.addChildData(taskId, formId, data, new ArrayList<>(), isWrite); } return data; } /** * 获取上级节点 * * @param deploymentId 部署id * @param nodeCode 节点编码 * @param nodeEntityList 节点集合 * @param nodeCodeList 上一级节点编码集合 */ public void prevNodeList(String deploymentId, String nodeCode, List nodeEntityList, List nodeCodeList) throws WorkFlowException { NextOrPrevFo fo = new NextOrPrevFo(); fo.setDeploymentId(deploymentId); fo.setTaskKey(nodeCode); List prevList = flowAbleUrl.getPrev(fo); if (CollectionUtil.isNotEmpty(prevList)) { for (String prev : prevList) { TemplateNodeEntity nodeEntity = nodeEntityList.stream().filter(e -> e.getNodeCode().equals(prev)).findFirst().orElse(null); if (nodeEntity != null) { // 获取 不是子流程类型的节点 if (nodeEntity.getNodeType().equals(NodeEnum.subFlow.getType())) { prevNodeList(deploymentId, nodeEntity.getNodeCode(), nodeEntityList, nodeCodeList); } else { nodeCodeList.add(nodeEntity.getNodeCode()); } } } } } /** * 获取上级节点，不过滤子流程节点 * * @param deploymentId 部署id * @param nodeCode 节点编码 * @param nodeEntityList 节点集合 * @param nodeCodeList 上一级节点编码集合 */ public void prevNode(String deploymentId, String nodeCode, List nodeEntityList, List nodeCodeList) throws WorkFlowException { NextOrPrevFo fo = new NextOrPrevFo(); fo.setDeploymentId(deploymentId); fo.setTaskKey(nodeCode); List prevList = flowAbleUrl.getPrev(fo); if (CollectionUtil.isNotEmpty(prevList)) { for (String prev : prevList) { TemplateNodeEntity nodeEntity = nodeEntityList.stream().filter(e -> e.getNodeCode().equals(prev)).findFirst().orElse(null); if (nodeEntity != null) { nodeCodeList.add(nodeEntity.getNodeCode()); } } } } /** * 查询表单值 * * @return */ public Map infoData(String formId, String taskId) throws WorkFlowException { Map> allData = FlowContextHolder.getAllData(); Map dataAll = allData.get(taskId + JnpfConst.SIDE_MARK + formId) != null ? allData.get(taskId + JnpfConst.SIDE_MARK + formId) : serviceUtil.infoData(formId, taskId); return dataAll; } // 截取数据传递字段，获取表单id public List handleAssignRule(List ruleList) { List list = new ArrayList<>(); if (CollectionUtil.isNotEmpty(ruleList)) { for (AssignRule assignRule : ruleList) { AssignRule rule = JsonUtil.getJsonToBean(assignRule, AssignRule.class); String parentField = assignRule.getParentField(); int index = parentField.lastIndexOf("|"); if (index != -1) { String field = parentField.substring(0, index); rule.setParentField(field); String substring = parentField.substring(index + 1); rule.setFormId(substring); } list.add(rule); } } return list; } // 表单赋值 public Map formData(Map formData, List assignListAll, TaskEntity taskEntity, FlowMethod flowMethod) throws WorkFlowException { String taskId = taskEntity.getId(); List nodeEntityList = flowMethod.getNodeEntityList(); TemplateNodeEntity startNode = nodeEntityList.stream().filter(e -> ObjectUtil.equals(e.getNodeType(), NodeEnum.start.getType())).findFirst().orElse(null); if (startNode != null) { formData.put(FlowConstant.StartNodeFormId, startNode.getFormId()); } Map result = new HashMap<>(formData); Map oldData = new HashMap<>(formData); Map> map = new HashMap<>(); // 全局参数 String globalParameter = taskEntity.getGlobalParameter(); Map taskMap = globalParameter != null ? JsonUtil.stringToMap(globalParameter) : new HashMap<>(); for (Assign assignModel : assignListAll) { List ruleList = this.handleAssignRule(assignModel.getRuleList()); for (AssignRule assignMode : ruleList) { String parentField = assignMode.getParentField(); String[] parentFieldList = parentField.split("-"); String childField = assignMode.getChildField(); String[] childFieldList = childField.split("-"); if (childFieldList.length > 1 && parentFieldList.length > 1) { int end = 0; if (oldData.get(parentFieldList[0]) instanceof List) { List> parentList = (List>) oldData.get(parentFieldList[0]); end = parentList.size(); } if (result.get(childFieldList[0]) instanceof List) { List> childList = (List>) result.get(childFieldList[0]); for (int i = 0; i < childList.size() - end; i++) { childList.add(new HashMap<>()); } } else { List> childList = new ArrayList<>(); for (int i = 0; i < end; i++) { childList.add(new HashMap<>()); } result.put(childFieldList[0], childList); result.put(childFieldList[0] + FlowNature.FORM_FIELD_SUFFIX, childList); } } } } for (Assign assignModel : assignListAll) { List ruleList = this.handleAssignRule(assignModel.getRuleList()); for (AssignRule assignMode : ruleList) { String formId = assignMode.getFormId(); if (StringUtil.equals(formId, FlowNature.GLOBAL_PARAMETER)) { oldData.putAll(taskMap); } else { if (StringUtil.isNotEmpty(formId)) { Map mapData = map.get(formId); if (CollectionUtil.isEmpty(mapData)) { Map data = serviceUtil.infoData(formId, taskId); map.put(formId, data); oldData.putAll(data); } } else { oldData.putAll(formData); } } //子表处理规则 String parentField = assignMode.getParentField(); String[] parentFieldList = parentField.split("-"); String childField = assignMode.getChildField(); String[] childFieldList = childField.split("-"); Object childData = getSysParamData(oldData, parentField, taskId); if (childFieldList.length > 1) { List> childMapAll = new ArrayList<>(); if (result.get(childFieldList[0]) instanceof List) { List> childList = (List>) result.get(childFieldList[0]); for (Map objectMap : childList) { Map childMap = new HashMap<>(objectMap); childMapAll.add(childMap); } } if (parentFieldList.length > 1) { if (oldData.get(parentFieldList[0]) instanceof List) { List> parentList = (List>) oldData.get(parentFieldList[0]); int num = parentList.size() - childMapAll.size(); for (int i = 0; i < num; i++) { childMapAll.add(new HashMap<>()); } for (int i = 0; i < parentList.size(); i++) { Map parentMap = parentList.get(i); Map childMap = childMapAll.get(i); childMap.put(childFieldList[1], parentMap.get(parentFieldList[1])); } } } else { // 主传子 if (1 > childMapAll.size()) { childMapAll.add(new HashMap<>()); } for (Map childMap : childMapAll) { childMap.put(childFieldList[1], childData); } } result.put(childFieldList[0], childMapAll); result.put(childFieldList[0] + FlowNature.FORM_FIELD_SUFFIX, childMapAll); } else { if (parentFieldList.length > 1) { if (oldData.get(parentFieldList[0]) instanceof List) { List> parentList = (List>) oldData.get(parentFieldList[0]); for (int i = 0; i < parentList.size(); i++) { Map parentMap = parentList.get(i); if (i == 0) { childData = parentMap.get(parentFieldList[1]); } } } } result.put(childField, childData); result.put(childField + FlowNature.FORM_FIELD_SUFFIX, childData); } } } return result; } /** * 处理系统参数： * * @prevNodeFormId上节点表单id */ private Object getSysParamData(Map formData, String parentField, String taskId) { Object data; if (FlowConstant.PREV_NODE_FORM_ID.equals(parentField)) { data = taskId; } else { data = formData.get(parentField); } return data; } // true为选择分支 public boolean checkBranch(TemplateNodeEntity nodeEntity) { NodeModel nodeModel = JsonUtil.getJsonToBean(nodeEntity.getNodeJson(), NodeModel.class); return this.checkBranch(nodeModel); } public boolean checkBranch(NodeModel nodeModel) { String divideRule = nodeModel.getDivideRule(); return ObjectUtil.equals(DivideRuleEnum.CHOOSE.getType(), divideRule); } // false为候选人 public boolean checkNextCandidates(List nodeList) { if (CollectionUtil.isNotEmpty(nodeList)) { for (NodeModel node : nodeList) { if (node.getIsCandidates()) { return false; } } } return true; } public int checkNextError(FlowModel flowModel, List nextApprover, boolean nodeFlag, boolean notSubmitFlag) throws WorkFlowException { return this.checkNextError(flowModel, nextApprover, nodeFlag, notSubmitFlag, false); } // 判断异常处理是否是 上一节点审批人指定处理人、无法提交 public int checkNextError(FlowModel flowModel, List nextApprover, boolean nodeFlag, boolean notSubmitFlag, boolean errorFlag) throws WorkFlowException { List nodeEntityList = flowModel.getNodeEntityList(); TaskEntity taskEntity = flowModel.getTaskEntity(); List errorList = new ArrayList<>(); for (NodeModel nodeModel : nextApprover) { // 候选人节点跳过 if (nodeModel.getIsCandidates()) { continue; } TemplateNodeEntity nodeEntity = nodeEntityList.stream().filter(e -> e.getNodeCode().equals(nodeModel.getNodeId())).findFirst().orElse(null); // 获取审批人 FlowMethod flowMethod = new FlowMethod(); flowMethod.setFlowModel(flowModel); flowMethod.setTaskEntity(taskEntity); flowMethod.setNodeEntity(nodeEntity); flowMethod.setNodeEntityList(nodeEntityList); flowMethod.setErrorRule(true); flowMethod.setExtraRule(true); List userIds = this.userListAll(flowMethod); Integer node = flowMethod.getNode(); Integer notSubmit = flowMethod.getNotSubmit(); if (node > 0) { if (nodeFlag) { operatorUtil.handleErrorRule(nodeModel, errorList); } else { return 1; } } if (notSubmit > 0) { if (notSubmitFlag) { throw new WorkFlowException(MsgCode.WF061.get()); } return 2; } } if (errorFlag && CollectionUtil.isNotEmpty(errorList)) { flowModel.setErrorList(errorList); return 3; } if (!errorList.isEmpty()) { AuditModel model = new AuditModel(); model.setErrorCodeList(errorList); throw new WorkFlowException(200, JsonUtil.getObjectToString(model)); } return 0; } /** * 获取下一级审批节点 */ public List getNextApprover(FlowMethod flowMethod) throws WorkFlowException { String deploymentId = flowMethod.getDeploymentId(); String nodeCode = flowMethod.getNodeCode(); Map nodes = flowMethod.getNodes(); List nextNode = flowMethod.getNextNode(); // 获取下一级节点 NextOrPrevFo fo = new NextOrPrevFo(); fo.setDeploymentId(deploymentId); fo.setTaskKey(nodeCode); List nextList = flowAbleUrl.getNext(fo); if (CollectionUtil.isNotEmpty(nextList)) { OutgoingFlowsFo flowsFo = new OutgoingFlowsFo(); flowsFo.setDeploymentId(deploymentId); flowsFo.setTaskKey(nodeCode); List outgoingFlows = flowAbleUrl.getOutgoingFlows(flowsFo); Map res = new HashMap<>(); flowMethod.setOutgoingFlows(outgoingFlows); flowMethod.setResMap(res); conditionService.getConditionResult(flowMethod); conditionService.checkCondition(res, nodes); for (FlowableNodeModel next : nextList) { // 判断条件，子流程的出线 条件都为false 则跳过 Map resMap = new HashMap<>(); flowMethod.setOutgoingFlows(next.getIncomingList()); flowMethod.setResMap(resMap); flowMethod.setNodeCode(next.getId()); conditionService.getConditionResult(flowMethod); try { conditionService.checkCondition(resMap, nodes); } catch (WorkFlowException e) { continue; } NodeModel nodeModel = nodes.get(next.getId()); if (null != nodeModel) { // 子流程、外部节点往下递归 List typeList = ImmutableList.of(NodeEnum.subFlow.getType(), NodeEnum.outside.getType()); if (typeList.contains(nodeModel.getType())) { if (flowMethod.getNextSubFlow()) { nextNode.add(nodeModel); } getNextApprover(flowMethod); } else { nextNode.add(nodeModel); } } } } return nextNode; } // 删除表单数据 public void deleteFormData(List taskList) throws Exception { if (taskList.isEmpty()) { return; } List nodeEntityList = new ArrayList<>(); List flowIds = taskList.stream().map(TaskEntity::getFlowId).collect(Collectors.toList()); if (!flowIds.isEmpty()) { nodeEntityList = templateNodeService.getList(flowIds, null); } for (TaskEntity taskEntity : taskList) { List formIds = nodeEntityList.stream().filter(e -> e.getFlowId().equals(taskEntity.getFlowId()) && StringUtil.isNotBlank(e.getFormId())).map(TemplateNodeEntity::getFormId).distinct().collect(Collectors.toList()); for (String formId : formIds) { serviceUtil.deleteFormData(formId, taskEntity.getId()); } } } public List getNextList(String deploymentId, String nodeCode, Map nodes, List nextList) throws WorkFlowException { nextList = nextList != null ? nextList : new ArrayList<>(); NextOrPrevFo fo = new NextOrPrevFo(); fo.setDeploymentId(deploymentId); fo.setTaskKey(nodeCode); List nextModels = flowAbleUrl.getNext(fo); for (FlowableNodeModel next : nextModels) { NodeModel nodeModel = nodes.get(next.getId()); if (null != nodeModel) { // 子流程往下递归 List typeList = ImmutableList.of(NodeEnum.subFlow.getType()); if (typeList.contains(nodeModel.getType())) { nextList.add(next.getId()); getNextList(deploymentId, next.getId(), nodes, nextList); } else { nextList.add(next.getId()); } } } return nextList; } public List getSubTask(String taskId, List nodeCodes) { if (StringUtil.isEmpty(taskId)) { return new ArrayList<>(); } QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.lambda().eq(TaskEntity::getParentId, taskId); if (CollectionUtil.isNotEmpty(nodeCodes)) { queryWrapper.lambda().in(TaskEntity::getSubCode, nodeCodes); } return taskService.list(queryWrapper); } public void checkTemplateHide(String templateId) throws WorkFlowException { TemplateEntity template = templateService.getById(templateId); if (null != template) { List templateStatus = ImmutableList.of(TemplateStatueEnum.up.getCode(), TemplateStatueEnum.downContinue.getCode()); if (!templateStatus.contains(template.getStatus())) { throw new WorkFlowException(MsgCode.WF140.get()); } } } public ActionResult launchFlow(FlowModel flowModel) throws Exception { String templateId = flowModel.getTemplateId(); List userIds = flowModel.getUserIds(); List> formDataList = flowModel.getFormDataList(); if (CollectionUtil.isEmpty(formDataList)) { return ActionResult.fail("未选择记录，发起失败"); } TemplateEntity template = templateService.getById(templateId); if (null == template) { return ActionResult.fail(MsgCode.WF122.get()); } if (!ObjectUtil.equals(template.getStatus(), TemplateStatueEnum.up.getCode())) { throw new WorkFlowException(MsgCode.WF140.get()); } TemplateJsonEntity jsonEntity = templateJsonService.getById(template.getFlowId()); List nodeEntityList = templateNodeService.getList(jsonEntity.getId()); Map nodes = new HashMap<>(); for (TemplateNodeEntity node : nodeEntityList) { nodes.put(node.getNodeCode(), JsonUtil.getJsonToBean(node.getNodeJson(), NodeModel.class)); } FlowMethod method = new FlowMethod(); method.setDeploymentId(jsonEntity.getFlowableId()); TemplateNodeEntity startNode = nodeEntityList.stream().filter(e -> StringUtil.equals(NodeEnum.start.getType(), e.getNodeType())).findFirst().orElse(new TemplateNodeEntity()); if (this.checkBranch(startNode)) { throw new WorkFlowException(MsgCode.WF147.get()); } method.setNodeCode(startNode.getNodeCode()); method.setNodes(nodes); method.setNodeEntityList(nodeEntityList); Map resMap = conditionService.handleCondition(method); // 判断条件、候选人 try { conditionService.checkCondition(resMap, nodes); } catch (WorkFlowException e) { throw new WorkFlowException(MsgCode.WF133.get()); } method.setNextSubFlow(true); List nextApprover = this.getNextApprover(method); if (!this.checkNextCandidates(nextApprover)) { throw new WorkFlowException(MsgCode.WF134.get()); } String flowId = jsonEntity.getId(); // 判断流程权限 List userListAll = serviceUtil.getUserListAll(userIds); FlowFormModel formIdAndFlowId = templateService.getFormIdAndFlowId(userListAll, templateId); List userList = serviceUtil.getUserName(flowModel.getHasPermission() ? formIdAndFlowId.getUserId() : formIdAndFlowId.getUserIdAll(), true); if (CollectionUtil.isEmpty(userList)) { throw new WorkFlowException(MsgCode.WF136.get()); } for (UserEntity user : userList) { UserInfo userInfo = new UserInfo(); userInfo.setUserId(user.getId()); userInfo.setUserName(user.getRealName()); FlowModel model = new FlowModel(); model.setUserInfo(userInfo); model.setFlowId(flowId); model.setStatus(TaskStatusEnum.RUNNING.getCode()); model.setDeploymentId(jsonEntity.getFlowableId()); model.setNodeEntityList(nodeEntityList); for (Map formData : formDataList) { model.setFormData(formData); if (this.checkNextError(model, nextApprover, false, false) != 0) { throw new WorkFlowException(MsgCode.WF135.get()); } taskService.batchSaveOrSubmit(model); operatorUtil.event(model, 1); TaskEntity taskEntity = model.getTaskEntity(); if (taskEntity.getRejectDataId() == null) { operatorUtil.autoAudit(model); operatorUtil.handleEvent(); } operatorUtil.handleTaskStatus(); } } return ActionResult.success(MsgCode.SU006.get()); } /** * 用户的信息 */ public void launchUser(LaunchUserEntity flowUser, UserEntity userEntity) { if (userEntity != null) { //全部岗位 List userPositionList = serviceUtil.getListByUserIdAll(ImmutableList.of(userEntity.getId())).stream() .filter(t -> PermissionConst.POSITION.equals(t.getObjectType())).collect(Collectors.toList()); List pos = new ArrayList<>(); List org = new ArrayList<>(); List managerId = new ArrayList<>(); List subordinateList = new ArrayList<>(); for (UserRelationEntity relation : userPositionList) { PositionEntity positionInfo = serviceUtil.getPositionInfo(relation.getObjectId()); if (positionInfo != null) { userEntity.setPositionId(positionInfo.getId()); pos.add(positionInfo.getId()); OrganizeEntity organizeInfo = serviceUtil.getOrganizeInfo(positionInfo.getOrganizeId()); if (organizeInfo != null) { org.add(organizeInfo.getId()); } String managerByLevel = getManagerByLevel(userEntity, 1); if (StringUtil.isNotEmpty(managerByLevel)) { managerId.add(managerByLevel); } List childPosition = serviceUtil.getChildPosition(userEntity.getPositionId()); List positionList = childPosition.stream().map(PositionEntity::getId).collect(Collectors.toList()); positionList.remove(userEntity.getPositionId()); List userRelationList = serviceUtil.getListByObjectIdAll(positionList); subordinateList.addAll(userRelationList.stream().map(UserRelationEntity::getUserId).collect(Collectors.toList())); } } flowUser.setPositionId(String.join(",", pos)); flowUser.setOrganizeId(String.join(",", org)); flowUser.setManagerId(String.join(",", managerId)); String subordinate = serviceUtil.getUserName(subordinateList, true).stream().map(UserEntity::getId).collect(Collectors.joining(",")); flowUser.setSubordinate(subordinate); } } }