Commit b54c8079 by huangfusuper

暂停异常

parent bef04779
...@@ -1667,7 +1667,7 @@ public class ApiFlowServiceImpl implements ApiFlowService { ...@@ -1667,7 +1667,7 @@ public class ApiFlowServiceImpl implements ApiFlowService {
//ValidationUtil.isTrueValidation(FlowPropertyEnum.IS_INNER.getCode().equals(flow.getIsInner()), "内嵌工作流不允许暂停调度!"); //ValidationUtil.isTrueValidation(FlowPropertyEnum.IS_INNER.getCode().equals(flow.getIsInner()), "内嵌工作流不允许暂停调度!");
//判断是否在调度中 //判断是否在调度中
List<RunRecording> recordingList = runRecordingMapper.findUnFinishByFlowId(flow.getFlowId()); List<RunRecording> recordingList = runRecordingMapper.findUnFinishByFlowId(flow.getFlowId());
ValidationUtil.isTrueValidation(null == recordingList || recordingList.size() == 0, flowName + "工作流没有正在运行的调度!"); ValidationUtil.isTrueValidation(CollectionUtil.isEmpty(recordingList), flowName + "工作流没有正在运行的调度!");
StringBuffer runids = new StringBuffer(); StringBuffer runids = new StringBuffer();
//暂停工作流调度 //暂停工作流调度
recordingList.forEach(runRecording -> { recordingList.forEach(runRecording -> {
......
...@@ -683,7 +683,7 @@ ...@@ -683,7 +683,7 @@
and flow_status != '4' and flow_status != '4'
</update> </update>
<update id="stopByRunIdAndFlowId" parameterType="string"> <update id="stopByRunIdAndFlowId">
update run_recording set flow_status = '3', stop_count = (stop_count+1) update run_recording set flow_status = '3', stop_count = (stop_count+1)
where run_id = #{runId,jdbcType=VARCHAR} and flow_id = #{flowId, jdbcType=INTEGER} where run_id = #{runId,jdbcType=VARCHAR} and flow_id = #{flowId, jdbcType=INTEGER}
and flow_status != '4' and flow_status != '4'
......
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