增加工作流校验

byit-myth-admin/src/main/java/com/byit/service/impl/ApiFlowOperatingServiceImpl.java

@@ -70,8 +70,8 @@ public class ApiFlowOperatingServiceImpl implements ApiFlowOperatingService {
     @Override
     public void specialRunBatch(SpecialJobParam specialJobParam) {
         //获取操作人
-        //String operator = currentUserUtils.account();
-        String operator = "huangfusuper";
+        String operator = currentUserUtils.account();
+        //String operator = "huangfusuper"
         //生成本次补批的运行标识
         String runId = IDGenerationStrategy.runIdGenerationStrategy(serverPort);
         //工作空间名称
@@ -99,7 +99,7 @@ public class ApiFlowOperatingServiceImpl implements ApiFlowOperatingService {
         log.debug("-----开始补批工作空间：{}下的工作流------", workspace);
         //获取对应的工作流
         Flow flowByName = flowService.findFlowByName(flowName, workspace.getWorkspaceId());
-        ValidationUtil.dataNotNull(workspace, String.format("查询不到%s对应的工作流！", flowName));
+        ValidationUtil.dataNotNull(flowByName, String.format("查询不到%s对应的工作流！", flowName));
         //查询对应工作流下的所由节点 当前版本
         List<Node> nodeByFlowIdAndVersionName = nodeService.findNodeByFlowIdAndVersionName(flowByName.getFlowId());
         ValidationUtil.isTrueValidation(CollectionUtil.isEmpty(nodeByFlowIdAndVersionName), String.format("查询到工作流%s下不存在任何节点！请联系调度中心人员！", flowName));