commit

src/main/java/com/budwk/app/flow/controller/FlowDesignController.java

@@ -4,6 +4,7 @@ import cn.dev33.satoken.annotation.SaCheckLogin;
 import cn.dev33.satoken.annotation.SaCheckPermission;
 import cn.hutool.core.lang.ClassScanner;
 import cn.hutool.core.util.ReflectUtil;
+import cn.hutool.core.util.StrUtil;
 import cn.hutool.json.JSONObject;
 import com.budwk.app.base.page.Pagination;
 import com.budwk.app.base.param.PageForm;
@@ -21,6 +22,7 @@ import org.nutz.dao.Cnd;
 import org.nutz.dao.Dao;
 import org.nutz.dao.Sqls;
 import org.nutz.dao.sql.Sql;
+import org.nutz.dao.util.cri.SqlExpressionGroup;
 import org.nutz.ioc.aop.Aop;
 import org.nutz.ioc.loader.annotation.Inject;
 import org.nutz.ioc.loader.annotation.IocBean;
@@ -220,9 +222,16 @@ public class FlowDesignController {
     @At
     @SaCheckLogin
     @ApiOperation("获取流程设计任务参与者分页数据")
-    public Result assigneePage(Integer pageNumber, Integer pageSize, String keyword, @Param("userIds") String[] userIds) {
+    public Result assigneePage(Integer pageNumber, Integer pageSize, String searchKeyword, @Param("userIds") String[] userIds) {
         Sql sql = Sqls.create("select id,loginname,username,unitName from vw_user $condition");
         Cnd cnd = Cnd.NEW();
+		if(StrUtil.isNotBlank(searchKeyword)) {
+			SqlExpressionGroup group = new SqlExpressionGroup();
+			group.orLike("username", searchKeyword);
+			group.orLike("loginname", searchKeyword);
+			cnd.and(group);
+		}
+		sql.setCondition(cnd);
 //        cnd.andEX("id", "in", userIds);
         Pagination pagination = sysUserService.listPageMap(pageNumber, pageSize, sql);
         return Result.success(pagination);

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

@@ -0,0 +1,55 @@
+package com.budwk.app.flow.handler;
+
+import com.budwk.app.base.constant.RoleConstant;
+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 com.budwk.app.web.commons.auth.utils.SecurityUtil;
+import org.nutz.dao.Cnd;
+import org.nutz.dao.Dao;
+import org.nutz.lang.Lang;
+
+import java.util.List;
+
+/**
+ * @ClassName FlowUnitPartySecretaryHandler
+ * @Author JyuHsin
+ * @Date 2025/10/15 10:55
+ * @Version 1.0
+ * @Description TODO
+ */
+public class FlowUnitPartySecretaryHandler implements AssignmentHandler {
+
+	@Override
+	public List<String> assign(TaskModel model, Execution execution) {
+		String unitId = SecurityUtil.getUnitId();
+
+		SysRoleService sysRoleService = ServiceContext.find(SysRoleService.class);
+		Sys_role role = sysRoleService.getByCode(RoleConstant.UNIT_PARTY_SECRETARY);
+
+		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::getUnitId, "=", unitId)
+		);
+
+		if (Lang.isEmpty(roles)) {
+			throw new RuntimeException("当前登录用户所在单位未设置单位党委书记，请联系校工会进行设置。");
+		}
+		return roles.stream().map(Sys_user_role::getUserId).toList();
+	}
+
+	@Override
+	public String getMessage() {
+		return "获取当前登录用户所在单位党委书记";
+	}
+
+	@Override
+	public int getOrder() {
+		return AssignmentHandler.super.getOrder();
+	}
+}