修改开始调度接口

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

@@ -85,8 +85,8 @@ public class ApiFlowController {
 
     @PostMapping("reStartSchedule")
     @ApiOperation("重新开始某次调度")
-    public ResponseResult reStartSchedule(String runId){
-        apiFlowService.reStartSchedule(runId);
+    public ResponseResult reStartSchedule(String param){
+        apiFlowService.reStartSchedule(param);
         return ResponseResult.ok("SUCCESS");
     }
 

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

@@ -1486,6 +1486,7 @@ public class ApiFlowServiceImpl implements ApiFlowService {
         ValidationUtil.dataNotBank(runIds, "运行id不允许为空！");
         JSONObject jsonObject = JSON.parseObject(runIds);
        String runIdStr = jsonObject.getString("runId");
+
         List<String> runIdList = Arrays.asList(runIdStr.split(","));
         runIdList.forEach(runId -> {
             List<RunRecording>  runRecordList = runRecordingMapper.findStopRunCordByRunId(runId);

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

@@ -285,7 +285,7 @@ public class JobUtils {
         Map<String,Object> map = new HashMap<>(5);
         map.put("runId", runId);
         //发送请求 添加任务
-        String response = createHttpRequest(REQUEST_FLOW_REREPEAL, "runId="+JSON.toJSONString(map,WriteClassName));
+        String response = createHttpRequest(REQUEST_FLOW_REREPEAL, "param="+JSON.toJSONString(map,WriteClassName));
         log.info("--------------------重新开始调度接口调用成功，结果为：{}------------------------", response);
         return JSON.parseObject(response, ResponseResult.class);
     }