From 2e83439e5e951921b1391a30fd9eae739d22683f Mon Sep 17 00:00:00 2001
From: AprilWind <2100166581@qq.com>
Date: Wed, 13 Nov 2024 14:27:02 +0800
Subject: [PATCH] =?UTF-8?q?update=20=E6=96=B0=E5=A2=9E=E6=B5=81=E7=A8=8B?=
=?UTF-8?q?=E5=90=AF=E5=8A=A8=E7=9B=91=E5=90=AC=E5=99=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../listener/WorkflowStartListener.java | 85 +++++++++++++++++++
1 file changed, 85 insertions(+)
create mode 100644 ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/listener/WorkflowStartListener.java
diff --git a/ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/listener/WorkflowStartListener.java b/ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/listener/WorkflowStartListener.java
new file mode 100644
index 000000000..456d81e88
--- /dev/null
+++ b/ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/listener/WorkflowStartListener.java
@@ -0,0 +1,85 @@
+package org.dromara.workflow.listener;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.dromara.common.core.domain.model.LoginUser;
+import org.dromara.common.satoken.utils.LoginHelper;
+import org.dromara.warm.flow.core.dto.FlowParams;
+import org.dromara.warm.flow.core.listener.Listener;
+import org.dromara.warm.flow.core.listener.ListenerVariable;
+import org.dromara.workflow.common.enums.TaskAssigneeEnum;
+import org.springframework.stereotype.Component;
+
+import java.util.Collection;
+import java.util.List;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
+/**
+ * 流程启动监听器，用于处理流程开始时的用户信息和权限设置
+ *
+ * 该监听器在流程启动阶段执行，主要任务是获取当前登录用户的信息，并为流程设置办理人ID及其相关权限
+ * 它通过监听器变量从流程中获取参数，并设置当前用户的权限信息，如角色、岗位、用户ID和部门ID等
+ * 该监听器可以避免重复编写相同的权限设置逻辑，简化流程的启动配置
+ *
+ *
+ * @author AprilWind
+ */
+@RequiredArgsConstructor
+@Component
+@Slf4j
+public class WorkflowStartListener implements Listener {
+
+ /**
+ * 全局开始监听器，用于在流程开始时，设置当前办理人的信息和权限
+ *
+ * 此方法通过监听器变量获取流程参数，获取当前登录用户，并设置当前办理人的ID和其权限信息
+ * 该监听器可以用于流程的开始阶段，避免重复设置办理人信息和权限
+ *
+ *
+ * @param listenerVariable 监听器变量，包含流程参数等信息
+ */
+ @Override
+ public void notify(ListenerVariable listenerVariable) {
+ log.info("流程启动监听器");
+ FlowParams flowParams = listenerVariable.getFlowParams();
+ LoginUser loginUser = LoginHelper.getLoginUser();
+ // 设置当前办理人id
+ flowParams.handler(loginUser.getUserId().toString());
+ // 设置办理人所拥有的权限，比如角色、部门、用户等
+ flowParams.permissionFlag(buildUserPermissions(loginUser));
+ log.info("流程启动监听器结束;{}", "开启流程完成");
+ }
+
+ /**
+ * 构建当前用户的所有权限列表，包括角色、岗位、用户和部门权限
+ *
+ * 通过合并用户的角色、岗位、用户ID和部门ID来构建用户的权限列表，格式化为字符串列表
+ *
+ *
+ * @param loginUser 当前登录的用户对象，包含用户的角色、岗位、ID等信息
+ * @return 权限列表，包含角色、岗位、用户和部门的权限，格式化为字符串列表
+ */
+ private List buildUserPermissions(LoginUser loginUser) {
+ // 使用一个流来构建权限列表
+ return Stream.of(
+ // 角色权限前缀
+ loginUser.getRoles().stream()
+ .map(role -> TaskAssigneeEnum.ROLE.getCode() + role.getRoleId()),
+
+ // 岗位权限前缀
+ Stream.ofNullable(loginUser.getPosts())
+ .flatMap(Collection::stream)
+ .map(post -> TaskAssigneeEnum.POST.getCode() + post.getPostId()),
+
+ // 用户和部门权限
+ Stream.of(
+ TaskAssigneeEnum.USER.getCode() + loginUser.getUserId(),
+ TaskAssigneeEnum.DEPT.getCode() + loginUser.getDeptId()
+ )
+ )
+ .flatMap(stream -> stream)
+ .collect(Collectors.toList());
+ }
+
+}