Skip to content

B
byit-myth-job
Commit 19ffd49d by huangfusuper
Options

修改开始调度接口

parent f9e8c709
Showing with 3 additions and 1 deletion
byit-myth-admin/src/main/java/com/byit/service/impl/ApiFlowServiceImpl.java
...@@ -1483,8 +1483,10 @@ public class ApiFlowServiceImpl implements ApiFlowService { ...@@ -1483,8 +1483,10 @@ 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) {
JSONObject jsonObject = JSON.parseObject(runIds);
String runIdStr = jsonObject.getString("runId");
ValidationUtil.dataNotBank(runIds, "运行id不允许为空！"); ValidationUtil.dataNotBank(runIds, "运行id不允许为空！");
List<String> runIdList = Arrays.asList(runIds.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);
ValidationUtil.dataNotNull(runRecordList, "运行记录" + runId + "不存在暂停中运行记录！"); ValidationUtil.dataNotNull(runRecordList, "运行记录" + runId + "不存在暂停中运行记录！");
......
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