判断工作空间是否存在

byit-myth-executor/myth-executor-plugin/src/main/java/com/byit/utils/JobUtils.java

@@ -36,6 +36,10 @@ public class JobUtils {
      */
     private static final String REQUEST_WORKSPACE_ADD = "/api/workspace/add";
     /**
+     * 判断工作空间是否存在
+     */
+    private static final String REQUEST_WORKSPACE_EXIST = "/api/workspace/exist";
+    /**
      * 开始工作流
      */
     private static final String REQUEST_FLOW_START = "/api/flow/start";
@@ -75,6 +79,8 @@ public class JobUtils {
      * 手动置为成功
      */
     private static final String REQUEST_FLOW_MAKESUCCESS = "/api/flow/madeSuccess";
+
+    private static final String REQUEST_REAL_EXECT = "/api/node/runNode";
     /**
      * 当前项目运行环境   jar    file
      */
@@ -317,6 +323,19 @@ public class JobUtils {
     }
 
     /**
+     * 判断工作空间是否存在
+     * @param workspaceName
+     * @return
+     */
+    public static String existWorkspace(String workspaceName){
+        log.info("---------------判断工作空间是否存在,workspaceName:{}---------------------", workspaceName);
+        //发送请求 添加任务
+        String addRequestResult = createHttpRequest(REQUEST_WORKSPACE_EXIST, "workspaceName="+ workspaceName);
+        log.info("--------------------判断工作空间是否存在接口调用成功，结果为：{}------------------------",addRequestResult);
+        return addRequestResult;
+    }
+
+    /**
      * 立即运行节点
      * @param nodeId
      * @param nodeName
@@ -338,7 +357,7 @@ public class JobUtils {
         map.put("runSource", runSource);
         map.put("jobType", jobType);
         //立即运行节点
-        String addRequestResult = createHttpRequest(REQUEST_WORKSPACE_ADD, "param=" + JSON.toJSONString(map));
+        String addRequestResult = createHttpRequest(REQUEST_REAL_EXECT, "param=" + JSON.toJSONString(map));
         log.info("--------------------立即运行节点，结果为：{}------------------------",addRequestResult);
         return addRequestResult;
     }