Commit 16799693 by huangfusuper

解决工作流重复发送的BUg

parent 90b55c40
...@@ -74,7 +74,7 @@ public class ClosingExampleThreadRunHelper extends BaseThreadRunHelper implement ...@@ -74,7 +74,7 @@ public class ClosingExampleThreadRunHelper extends BaseThreadRunHelper implement
runRecordingService.updateRunRecordingById(runRecording); runRecordingService.updateRunRecordingById(runRecording);
applicationEventPublisher.publishEvent(new EndFlowEvent(this,flowId)); applicationEventPublisher.publishEvent(new EndFlowEvent(this,flowId));
if (StringUtils.isNotBlank(runRecording.getReRunId())) { /*if (StringUtils.isNotBlank(runRecording.getReRunId())) {
String reRunId = runRecording.getReRunId(); String reRunId = runRecording.getReRunId();
Integer flowId1 = runRecording.getFlowId(); Integer flowId1 = runRecording.getFlowId();
RunRecording runRecordingByFlowIdAndRunId = runRecordingService.findRunRecordingByFlowIdAndRunId(flowId1, reRunId); RunRecording runRecordingByFlowIdAndRunId = runRecordingService.findRunRecordingByFlowIdAndRunId(flowId1, reRunId);
...@@ -82,7 +82,7 @@ public class ClosingExampleThreadRunHelper extends BaseThreadRunHelper implement ...@@ -82,7 +82,7 @@ public class ClosingExampleThreadRunHelper extends BaseThreadRunHelper implement
runRecordingByFlowIdAndRunId.setEndTime(new Date()); runRecordingByFlowIdAndRunId.setEndTime(new Date());
runRecordingByFlowIdAndRunId.setFlowStatus(RunRecordingEnum.FLOW_STATUS_IS_END.getCode()); runRecordingByFlowIdAndRunId.setFlowStatus(RunRecordingEnum.FLOW_STATUS_IS_END.getCode());
runRecordingService.updateRunRecordingById(runRecordingByFlowIdAndRunId); runRecordingService.updateRunRecordingById(runRecordingByFlowIdAndRunId);
} }*/
} }
}); });
return UNIVERSAL_WAIT_TIME; return UNIVERSAL_WAIT_TIME;
......
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