pref#ncu_commit

2025-12-20 16:38:57 +08:00
parent ee0f56bf13
commit 2efb8dea92
15 changed files with 460 additions and 31 deletions
@@ -0,0 +1,68 @@
+package com.budwk.app.flow.handler;
+
+import cn.hutool.core.util.StrUtil;
+import com.budwk.app.base.constant.RoleConstant;
+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;
+
+/**
+ * @version 1.0
+ * @Author FKY
+ * @name：FlowGeneralViceDelegationByArgsAssignmentHandler
+ * @Date 2025/12/17 10:08
+ * @注释  获取副团长(通用版本，根据args中的sessionId和delegationId)
+ */
+public class FlowGeneralViceDelegationByArgsAssignmentHandler implements AssignmentHandler {
+
+
+    @Override
+    public List<String> assign(TaskModel model, Execution execution) {
+        String sessionId = execution.getArgs().getStr("sessionId");
+        String delegationId = execution.getArgs().getStr("delegationId");
+
+        if (StrUtil.isBlank(sessionId)) {
+            throw new BaseException("参数 sessionId 不能为空");
+        }
+        if (StrUtil.isBlank(delegationId)) {
+            throw new BaseException("参数 delegationId 不能为空");
+        }
+
+        SysRoleService sysRoleService = ServiceContext.find(SysRoleService.class);
+        Sys_role role = sysRoleService.getByCode(RoleConstant.TEACHER_CONGRESS_VICE_DELEGATION_HEAD);
+
+        List<Sys_user_role> roles = ServiceContext.find(Dao.class).query(
+                Sys_user_role.class,
+                Cnd.where(Sys_user_role::getRoleId, "=", role.getId())
+                        .and(Sys_user_role::getTcDelegationId, "=", delegationId)
+                        .and(Sys_user_role::getTcSessionId, "=", sessionId)
+        );
+
+        if (Lang.isEmpty(roles)) {
+            throw new RuntimeException("您所在的代表团没有设置副团长，无法流转到下一步，请联系校工会进行设置。");
+        }
+        return roles.stream().map(Sys_user_role::getUserId).toList();
+    }
+
+
+    @Override
+    public String getMessage() {
+        return "获取代表团副团长(通用版本，根据args中的sessionId和delegationId)";
+    }
+
+    @Override
+    public int getOrder() {
+        return AssignmentHandler.super.getOrder();
+    }
+
+}