增加杀死运行中的节点接口

byit-myth-core/myth-admin-core/src/main/java/com/byit/enums/EmailEnum.java

@@ -6,7 +6,13 @@ package com.byit.enums;
 
 public enum EmailEnum {
     IS_ALARM_YES("1","已经告警"),
-    IS_ALARM_NO("0","没有告警")
+    IS_ALARM_NO("0","没有告警"),
+
+    EMAIL_NOT_ALARML("0","不告警"),
+    EMAIL_END_ALARML("1","完成时告警"),
+    EMAIL_ERROR_ALARML("2","错误时告警"),
+    EMAIL_SUCCESS_ALARML("3","成功时告警"),
+
     ;
     private String code;
     private String msg;

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

@@ -30,6 +30,9 @@ public class JobUtils {
     private static String REQUEST_URL;
     private static String TOKEN;
     private static final String REQUEST_ADD_JOB_RESOURCES_SUFFIX = "/job/addJob";
+
+
+    private static final String KILL_NODE_RUN_ING = "/api/node/killNode";
     /**
      * 发布工作流
      */
@@ -644,6 +647,18 @@ public class JobUtils {
     }
 
     /**
+     * 杀死正在运行中的节点
+     * @param logId
+     * @return
+     */
+    public static ResponseResult killRunNode(Integer logId) {
+        log.info("-------------杀死当前运行的节点----------------------");
+        String response = createHttpRequest(KILL_NODE_RUN_ING, "logId=" + logId);
+        log.info("--------------------获取当前的运行状态，结果为：{}------------------------",response);
+        return JSON.parseObject(response, ResponseResult.class);
+    }
+
+    /**
      * 判断当前的运行环境是什么  jar   :    table of Contents(目录)
      * @return jar -->true      目录 -->false
      */