feat: 监听器处理

ruoyi-flowable/src/main/java/com/ruoyi/flowable/listener/FlowExecutionListener.java

@@ -0,0 +1,37 @@
+package com.ruoyi.flowable.listener;
+
+import com.alibaba.fastjson2.JSON;
+import lombok.extern.slf4j.Slf4j;
+import org.flowable.common.engine.api.delegate.Expression;
+import org.flowable.engine.delegate.DelegateExecution;
+import org.flowable.engine.delegate.ExecutionListener;
+import org.springframework.stereotype.Component;
+
+/**
+ * 执行监听器
+ *
+ * 执行监听器允许在执行过程中执行Java代码。
+ * 执行监听器可以捕获事件的类型：
+ * 流程实例启动，结束
+ * 输出流捕获
+ * 获取启动，结束
+ * 路由开始，结束
+ * 中间事件开始，结束
+ * 触发开始事件，触发结束事件
+ *
+ * @author Xuan xuan
+ * @date 2022/12/16
+ */
+@Slf4j
+@Component
+public class FlowExecutionListener implements ExecutionListener {
+    /**
+     * 流程设计器添加的参数
+     */
+    private Expression param;
+
+    @Override
+    public void notify(DelegateExecution execution) {
+        log.info("执行监听器:{}", JSON.toJSONString(execution));
+    }
+}

ruoyi-flowable/src/main/java/com/ruoyi/flowable/listener/FlowTaskListener.java

@@ -0,0 +1,31 @@
+package com.ruoyi.flowable.listener;
+
+import com.alibaba.fastjson2.JSON;
+import lombok.extern.slf4j.Slf4j;
+import org.flowable.engine.delegate.TaskListener;
+import org.flowable.task.service.delegate.DelegateTask;
+import org.springframework.stereotype.Component;
+
+/**
+ * 任务监听器
+ *
+ * create（创建）:在任务被创建且所有的任务属性设置完成后才触发
+ * assignment（指派）：在任务被分配给某个办理人之后触发
+ * complete（完成）：在配置了监听器的上一个任务完成时触发
+ * delete（删除）：在任务即将被删除前触发。请注意任务由completeTask正常完成时也会触发
+ *
+ * @author Xuan xuan
+ * @date 2021/4/20
+ */
+@Slf4j
+@Component
+public class FlowTaskListener implements TaskListener{
+
+    @Override
+    public void notify(DelegateTask delegateTask) {
+
+        log.info("任务监听器:{}", JSON.toJSONString(delegateTask));
+        // TODO  获取事件类型 delegateTask.getEventName(),可以通过监听器给任务执行人发送相应的通知消息
+    }
+
+}

ruoyi-flowable/src/main/java/com/ruoyi/flowable/listener/UserTaskListener.java

@@ -1,18 +0,0 @@
-package com.ruoyi.flowable.listener;
-
-import org.flowable.engine.delegate.TaskListener;
-import org.flowable.task.service.delegate.DelegateTask;
-import org.springframework.stereotype.Component;
-
-/**
- * @author Xuan xuan
- * @date 2021/4/20
- */
-public class UserTaskListener implements TaskListener{
-
-    @Override
-    public void notify(DelegateTask delegateTask) {
-
-    }
-
-}

ruoyi-flowable/src/main/java/com/ruoyi/flowable/service/impl/FlowDefinitionServiceImpl.java

@@ -193,7 +193,8 @@ public class FlowDefinitionServiceImpl extends FlowServiceFactory implements IFl
             if (Objects.nonNull(processDefinition) && processDefinition.isSuspended()) {
                 return AjaxResult.error("流程已被挂起,请先激活流程");
             }
-
+//            // 加入多实例用户到流程变量中
+//            variables.put("userList", sysUserService.selectUserList(null));
             // 设置流程发起人Id到流程中
             SysUser sysUser = SecurityUtils.getLoginUser().getUser();
             identityService.setAuthenticatedUserId(sysUser.getUserId().toString());