工作流数量与对应的等待节点数量不对等BUG

byit-myth-core/myth-admin-core/src/main/java/com/byit/service/mapservice/impl/RunRecordingAndJobTaskServiceImpl.java

@@ -242,6 +242,10 @@ public class RunRecordingAndJobTaskServiceImpl implements RunRecordingAndJobTask
         runRecordingService.updateRunRecordingById(runRecording);
         log.info("-------修改运行实例表成功，查询对应等待实例{}，的等待节点-------",waitingRecord);
         List<WaitingTask> allByWaitId = taskService.findAllByWaitId(waitingRecord.getWaitId());
+        if(waitingRecord.getFlowNodeCount() != allByWaitId.size()){
+            log.info("------发现工作流数量与对应的等待节点数量不对等，实例节点数量为{}，查出的等待节点数量为{}，本次补批或重跑操作跳过----------",waitingRecord.getFlowNodeCount(), allByWaitId.size());
+            return;
+        }
         log.info("-------查询等待节点成功，查询对应的等待节点成功，开始保存对应的等待节点{}-------",allByWaitId);
         List<Integer> ids = new ArrayList<>(2);
         List<JobTask> jobTasks = allByWaitId.stream().map(waitingTask -> {