Commit ffc89b10 by huangfusuper

修改开始调度接口

parent 19ffd49d
...@@ -1483,9 +1483,9 @@ public class ApiFlowServiceImpl implements ApiFlowService { ...@@ -1483,9 +1483,9 @@ public class ApiFlowServiceImpl implements ApiFlowService {
@Override @Override
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void reStartSchedule(String runIds) { public void reStartSchedule(String runIds) {
ValidationUtil.dataNotBank(runIds, "运行id不允许为空!");
JSONObject jsonObject = JSON.parseObject(runIds); JSONObject jsonObject = JSON.parseObject(runIds);
String runIdStr = jsonObject.getString("runId"); String runIdStr = jsonObject.getString("runId");
ValidationUtil.dataNotBank(runIds, "运行id不允许为空!");
List<String> runIdList = Arrays.asList(runIdStr.split(",")); List<String> runIdList = Arrays.asList(runIdStr.split(","));
runIdList.forEach(runId -> { runIdList.forEach(runId -> {
List<RunRecording> runRecordList = runRecordingMapper.findStopRunCordByRunId(runId); List<RunRecording> runRecordList = runRecordingMapper.findStopRunCordByRunId(runId);
......
...@@ -285,7 +285,7 @@ public class JobUtils { ...@@ -285,7 +285,7 @@ public class JobUtils {
Map<String,Object> map = new HashMap<>(5); Map<String,Object> map = new HashMap<>(5);
map.put("runId", runId); map.put("runId", runId);
//发送请求 添加任务 //发送请求 添加任务
String response = createHttpRequest(REQUEST_FLOW_REREPEAL, "runId="+JSON.toJSONString(map)); String response = createHttpRequest(REQUEST_FLOW_REREPEAL, "runId="+JSON.toJSONString(map,WriteClassName));
log.info("--------------------重新开始调度接口调用成功,结果为:{}------------------------", response); log.info("--------------------重新开始调度接口调用成功,结果为:{}------------------------", response);
return JSON.parseObject(response, ResponseResult.class); return JSON.parseObject(response, ResponseResult.class);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment