快速失败时，执行结束事件

byit-myth-core/myth-admin-core/src/main/java/com/byit/service/mapservice/impl/RunRecordingAndLogServiceImpl.java

@@ -4,11 +4,14 @@ import com.byit.enums.EmailEnum;
 import com.byit.enums.FlowPropertyEnum;
 import com.byit.enums.RunRecordingEnum;
 import com.byit.enums.task.RunResultEnum;
+import com.byit.event.EndFlowEvent;
 import com.byit.model.*;
 import com.byit.service.*;
 import com.byit.service.mapservice.RunRecordingAndLogService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
+import org.springframework.context.ApplicationEventPublisher;
+import org.springframework.context.ApplicationEventPublisherAware;
 import org.springframework.stereotype.Service;
 
 import java.net.InetAddress;
@@ -23,13 +26,14 @@ import java.util.stream.Collectors;
  */
 @Service
 @Slf4j
-public class RunRecordingAndLogServiceImpl implements RunRecordingAndLogService {
+public class RunRecordingAndLogServiceImpl implements RunRecordingAndLogService, ApplicationEventPublisherAware {
     public static final String TRIGGER_MSG = "任务执行超时，被强制执行快速失败！";
     private final JobTaskRunLogService jobTaskRunLogService;
     private final RunRecordingService runRecordingService;
     private final NodeVersionService nodeVersionService;
     private final JobTaskService jobTaskService;
     private final FlowService flowService;
+    private ApplicationEventPublisher applicationEventPublisher;
 
     public RunRecordingAndLogServiceImpl(JobTaskRunLogService jobTaskRunLogService, RunRecordingService runRecordingService,
                                          NodeVersionService nodeVersionService, JobTaskService jobTaskService, FlowService flowService) {
@@ -79,6 +83,7 @@ public class RunRecordingAndLogServiceImpl implements RunRecordingAndLogService
         runRecording.setFlowRunResult(RunRecordingEnum.RUN_FLOW_FAILURE.getCode());
         runRecording.setFailFast(RunRecordingEnum.FAIL_FAST_YES.getCode());
         runRecordingService.updateRunRecordingById(runRecording);
+        applicationEventPublisher.publishEvent(new EndFlowEvent(this,runRecording.getFlowId()));
 
         //筛选虚节点
         List<JobTask> virtualTasks = byRunId.stream().filter(task -> "0".equals(task.getIsVirtual())).collect(Collectors.toList());
@@ -142,4 +147,9 @@ public class RunRecordingAndLogServiceImpl implements RunRecordingAndLogService
 
 
     }
+
+    @Override
+    public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
+        this.applicationEventPublisher = applicationEventPublisher;
+    }
 }