新加暂停指定实例接口

byit-myth-admin/src/main/java/com/byit/api/ApiFlowController.java

@@ -85,11 +85,17 @@ public class ApiFlowController {
     }
 
     @PostMapping("stopSchedule")
-    @ApiOperation("暂停本次调度")
+    @ApiOperation("暂停工作流所有调度")
     public ResponseResult stopSchedule(String param){
         return ResponseResult.ok(apiFlowService.stopSchedule(param));
     }
 
+    @PostMapping("stopScheduleByRunId")
+    @ApiOperation("暂停指定的工作流调度")
+    public ResponseResult stopScheduleByRunId(String runId){
+        return ResponseResult.ok(apiFlowService.stopScheduleByRunId(runId));
+    }
+
     @PostMapping("reStartSchedule")
     @ApiOperation("重新开始某次调度")
     public ResponseResult reStartSchedule(String runIds){
@@ -133,13 +139,6 @@ public class ApiFlowController {
         return ResponseResult.ok(result);
     }
 
-    public static void main(String[] args) {
-        int maxValue = Integer.MAX_VALUE;
-        System.out.println(maxValue+3);
-        //5184000000
-        //2147483647
-    }
-
     /**
      *
      * @param param

byit-myth-admin/src/main/java/com/byit/service/ApiFlowService.java

@@ -112,4 +112,6 @@ public interface ApiFlowService {
      * @return java.lang.Boolean
      */
     Boolean exist(String param);
+
+    Boolean stopScheduleByRunId(String runId);
 }

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

@@ -1109,6 +1109,19 @@ public class ApiFlowServiceImpl implements ApiFlowService {
         return true;
     }
 
+    @Override
+    public Boolean stopScheduleByRunId(String runId) {
+        RunRecording recording = runRecordingMapper.findAllByRunID(runId);
+        ValidationUtil.dataNotNull(recording , "查无此运行实例！");
+        ValidationUtil.isTrueValidation("3".equals(recording.getFlowStatus()) || "4".equals(recording.getFlowStatus()) , "该运行实例没有在运行中！");
+
+        //暂停工作流调度
+        runRecordingMapper.stopByRunId(runId);
+        jobTaskMapper.stopByRunId(runId);
+
+        return true;
+    }
+
     /**
      * runState  补批机制   1 补批当前节点   2   补批当前节点及以下节点
      * @param param

byit-myth-core/myth-admin-core/src/main/java/com/byit/mapper/RunRecordingMapper.java

@@ -148,7 +148,7 @@ public interface RunRecordingMapper {
      * @param runId
      * @return
      */
-    int killUnFinshFlow(@Param("runId")String runId, @Param("flowId")Integer flowId);
+    int killUnFinshFlow(@Param("runId")String runId);
 
     /**
      * 杀死工作流内的某个内嵌工作流

byit-myth-core/myth-admin-core/src/main/resources/mapper/RunRecordingMapper.xml

@@ -630,9 +630,9 @@
             and flow_status = '3'
   </update>
 
-  <update id="killUnFinshFlow" parameterType="string">
+  <update id="killUnFinshFlow">
     update run_recording set flow_status = '4',flow_run_result = '5'
-     where run_id = #{runId,jdbcType=VARCHAR} and flow_id = #{flowId,jdbcType=INTEGER}
+     where run_id = #{runId,jdbcType=VARCHAR}
         and flow_status != '4'
   </update>