Commit df711da8 by huangfusuper

解决任务实例重复BUG

parent 65ae6a22
...@@ -146,7 +146,13 @@ public class RunRecordingAndLogServiceImpl implements RunRecordingAndLogService, ...@@ -146,7 +146,13 @@ public class RunRecordingAndLogServiceImpl implements RunRecordingAndLogService,
} catch (UnknownHostException e) { } catch (UnknownHostException e) {
e.printStackTrace(); e.printStackTrace();
} }
RunRecording runRecordingByFlowIdAndRunId = runRecordingService.findRunRecordingByFlowIdAndRunId(mapFlowId, virtualTask.getRunId());
if(runRecordingByFlowIdAndRunId == null){
runRecordingService.saveRunRecording(virtualRunRecording); runRecordingService.saveRunRecording(virtualRunRecording);
}else {
runRecordingService.updateRunRecordingById(virtualRunRecording);
}
}); });
//删除task里面的数据 //删除task里面的数据
......
...@@ -575,7 +575,7 @@ public class JobUtils { ...@@ -575,7 +575,7 @@ public class JobUtils {
} }
/** /**
* 功能描述 修改任务 * 功能描述 删除任务
* @author gml * @author gml
* @date 2020-04-14 16:50 * @date 2020-04-14 16:50
* @param jobName * @param jobName
......
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