commit

src/main/java/com/budwk/app/flow/handler/FlowGeneralRoleCodeByArgsAssignmentHandler.java

@@ -0,0 +1,57 @@
+package com.budwk.app.flow.handler;
+
+import cn.hutool.core.util.StrUtil;
+import com.budwk.app.base.exception.BaseException;
+import com.budwk.app.flow.engine.AssignmentHandler;
+import com.budwk.app.flow.engine.core.Execution;
+import com.budwk.app.flow.engine.core.ServiceContext;
+import com.budwk.app.flow.engine.model.TaskModel;
+import com.budwk.app.sys.models.Sys_role;
+import com.budwk.app.sys.models.Sys_user_role;
+import com.budwk.app.sys.services.SysRoleService;
+import org.nutz.dao.Cnd;
+import org.nutz.dao.Dao;
+import org.nutz.lang.Lang;
+
+import java.util.List;
+
+/**
+ * @ClassName FlowGeneralRoleCodeByArgsAssignmentHandler
+ * @Author JyuHsin
+ * @Date 2026/1/31 16:58
+ * @Version 1.0
+ * @Description 根据参数的roleCode获取审核人
+ */
+public class FlowGeneralRoleCodeByArgsAssignmentHandler implements AssignmentHandler {
+	@Override
+	public List<String> assign(TaskModel model, Execution execution) {
+		String roleCode = execution.getArgs().getStr("roleCode");
+		if (StrUtil.isBlank(roleCode)) {
+			throw new BaseException("参数 roleCode 不能为空");
+		}
+
+		SysRoleService sysRoleService = ServiceContext.find(SysRoleService.class);
+		Sys_role role = sysRoleService.getByCode(roleCode);
+
+		List<Sys_user_role> roles = ServiceContext.find(Dao.class).query(
+				Sys_user_role.class,
+				Cnd.where(Sys_user_role::getRoleId, "=", role.getId())
+		);
+
+		if (Lang.isEmpty(roles)) {
+			throw new RuntimeException(role.getName() + "未设置用户。");
+		}
+
+		return roles.stream().map(Sys_user_role::getUserId).distinct().toList();
+	}
+
+	@Override
+	public String getMessage() {
+		return "根据角色编码获取审核人（根据args中的roleCode）";
+	}
+
+	@Override
+	public int getOrder() {
+		return AssignmentHandler.super.getOrder();
+	}
+}