前置任务节点查出来未走的节点bug

xiangpei

2025-02-26 a22c582a4867ee5a3f27e89da7d20fa52008b32c

前置任务节点查出来未走的节点bug

 business/src/main/java/com/ycl/service/impl/FlowTaskServiceImpl.java

@@ -1264,13 +1264,14 @@
        // 判断前置任务是不是和当前任务为同一个executeId
        // 判断当前任务是否被挂起中
        String finalProcessInsId = processInsId;
        beforeNodes.stream().filter(node -> {
        beforeNodes = beforeNodes.stream().filter(node -> {
            if (node.getCurrent()) {
                return Boolean.TRUE;
            }
            HistoricTaskInstance beforeTask = historyService.createHistoricTaskInstanceQuery().processInstanceId(finalProcessInsId).finished().taskDefinitionKey(node.getBeforeNodeDefId()).singleResult();
            return Objects.nonNull(beforeTask);
        }).forEach(node -> {
        }).collect(Collectors.toList());
        beforeNodes.forEach(node -> {
            if (node.getCurrent()) {
                if (processLogService.taskIsHangup(taskId, finalProcessInsId)) {
                    node.setTaskStatus(TaskStatusEnum.HANGUP);

 business/src/main/java/com/ycl/service/impl/ProjectProcessServiceImpl.java

@@ -204,7 +204,7 @@
        identityService.setAuthenticatedUserId(sysUser.getUserId().toString());
        variables.put(ProcessConstants.PROCESS_INITIATOR, sysUser.getUserId());
        //测试容缺
        variables.put("miss", true);
        variables.put("a", 10);
        // 将该项目的申请人（业主方）作为流程中某些环节的处理人
        variables.put(ProcessConstants.DATA_LAUNCH, "dept:" + createBy);
        ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefId, projectId + "", variables);