From bfe04233716902dbbe946187fb7f88855eee4353 Mon Sep 17 00:00:00 2001
From: gssong <1742057357@qq.com>
Date: Sun, 6 Aug 2023 21:01:19 +0800
Subject: [PATCH] =?UTF-8?q?add=20=E6=B7=BB=E5=8A=A0=E5=BC=95=E6=93=8E?=
 =?UTF-8?q?=E8=B0=83=E5=BA=A6=E7=9B=91=E5=90=AC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../flowable/config/FlowableConfig.java       |  7 ++
 .../config/GlobalFlowableListener.java        | 88 +++++++++++++++++++
 2 files changed, 95 insertions(+)
 create mode 100644 ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/flowable/config/GlobalFlowableListener.java

diff --git a/ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/flowable/config/FlowableConfig.java b/ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/flowable/config/FlowableConfig.java
index c591bd642..9315f8dd7 100644
--- a/ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/flowable/config/FlowableConfig.java
+++ b/ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/flowable/config/FlowableConfig.java
@@ -3,8 +3,12 @@ package org.dromara.workflow.flowable.config;
 import com.baomidou.mybatisplus.core.toolkit.IdWorker;
 import org.flowable.spring.SpringProcessEngineConfiguration;
 import org.flowable.spring.boot.EngineConfigurationConfigurer;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Configuration;
 
+import java.util.Collections;
+
+
 /**
  * flowable配置
  *
@@ -13,8 +17,11 @@ import org.springframework.context.annotation.Configuration;
 @Configuration
 public class FlowableConfig implements EngineConfigurationConfigurer<SpringProcessEngineConfiguration> {
 
+    @Autowired
+    private GlobalFlowableListener globalFlowableListener;
     @Override
     public void configure(SpringProcessEngineConfiguration processEngineConfiguration) {
         processEngineConfiguration.setIdGenerator(IdWorker::getIdStr);
+        processEngineConfiguration.setEventListeners(Collections.singletonList(globalFlowableListener));
     }
 }
diff --git a/ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/flowable/config/GlobalFlowableListener.java b/ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/flowable/config/GlobalFlowableListener.java
new file mode 100644
index 000000000..43f0de282
--- /dev/null
+++ b/ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/flowable/config/GlobalFlowableListener.java
@@ -0,0 +1,88 @@
+package org.dromara.workflow.flowable.config;
+
+import cn.hutool.core.collection.CollUtil;
+import org.dromara.workflow.common.enums.TaskStatusEnum;
+import org.flowable.bpmn.model.*;
+import org.flowable.common.engine.api.delegate.event.*;
+import org.flowable.common.engine.impl.cfg.TransactionState;
+import org.flowable.engine.RepositoryService;
+import org.flowable.engine.RuntimeService;
+import org.flowable.engine.TaskService;
+import org.flowable.engine.runtime.Execution;
+import org.flowable.engine.task.Comment;
+import org.flowable.task.api.Task;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Lazy;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+
+/**
+ * 引擎调度监听
+ *
+ * @author may
+ */
+@Component
+public class GlobalFlowableListener implements FlowableEventListener {
+
+    @Autowired
+    @Lazy
+    private TaskService taskService;
+
+    @Autowired
+    @Lazy
+    private RuntimeService runtimeService;
+
+    @Autowired
+    @Lazy
+    private RepositoryService repositoryService;
+
+    @Override
+    public void onEvent(FlowableEvent flowableEvent) {
+        if (flowableEvent instanceof FlowableEngineEvent flowableEngineEvent) {
+            FlowableEngineEventType engineEventType = (FlowableEngineEventType) flowableEvent.getType();
+            switch (engineEventType) {
+                case JOB_EXECUTION_SUCCESS:
+                    jobExecutionSuccess((FlowableEngineEntityEvent) flowableEngineEvent);
+                    break;
+                default:
+                    break;
+            }
+        }
+    }
+
+    @Override
+    public boolean isFailOnException() {
+        return true;
+    }
+
+    @Override
+    public boolean isFireOnTransactionLifecycleEvent() {
+        return false;
+    }
+
+    @Override
+    public String getOnTransaction() {
+        return TransactionState.COMMITTED.name();
+    }
+
+    protected void jobExecutionSuccess(FlowableEngineEntityEvent event) {
+        Execution execution = runtimeService.createExecutionQuery().executionId(event.getExecutionId()).singleResult();
+        BpmnModel bpmnModel = repositoryService.getBpmnModel(event.getProcessDefinitionId());
+        FlowElement flowElement = bpmnModel.getFlowElement(execution.getActivityId());
+        if (flowElement instanceof BoundaryEvent) {
+            String attachedToRefId = ((BoundaryEvent) flowElement).getAttachedToRefId();
+            List<Execution> list = runtimeService.createExecutionQuery().activityId(attachedToRefId).list();
+            for (Execution ex : list) {
+                Task task = taskService.createTaskQuery().executionId(ex.getId()).singleResult();
+                if (task != null) {
+                    List<Comment> taskComments = taskService.getTaskComments(task.getId());
+                    if (CollUtil.isEmpty(taskComments)) {
+                        taskService.addComment(task.getId(), task.getProcessInstanceId(), TaskStatusEnum.PASS.getStatus(), "自动审批！");
+                    }
+                }
+            }
+        }
+    }
+}