增加班组长接口

huminmin

2026-05-12 c07b492b6f7c8423d5fe9197f7b3da24e78cd349

 src/main/java/com/ruoyi/project/system/service/impl/SysUserServiceImpl.java

@@ -1,15 +1,6 @@
package com.ruoyi.project.system.service.impl;



import java.util.ArrayList;

import java.util.List;

import java.util.stream.Collectors;

import javax.validation.Validator;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import org.springframework.util.CollectionUtils;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;

import com.ruoyi.common.constant.UserConstants;

import com.ruoyi.common.exception.ServiceException;

import com.ruoyi.common.utils.SecurityUtils;

@@ -17,53 +8,45 @@
import com.ruoyi.common.utils.bean.BeanValidators;

import com.ruoyi.common.utils.spring.SpringUtils;

import com.ruoyi.framework.aspectj.lang.annotation.DataScope;

import com.ruoyi.project.system.domain.SysPost;

import com.ruoyi.project.system.domain.SysRole;

import com.ruoyi.project.system.domain.SysUser;

import com.ruoyi.project.system.domain.SysUserPost;

import com.ruoyi.project.system.domain.SysUserRole;

import com.ruoyi.project.system.mapper.SysPostMapper;

import com.ruoyi.project.system.mapper.SysRoleMapper;

import com.ruoyi.project.system.mapper.SysUserMapper;

import com.ruoyi.project.system.mapper.SysUserPostMapper;

import com.ruoyi.project.system.mapper.SysUserRoleMapper;

import com.ruoyi.project.system.domain.*;

import com.ruoyi.project.system.mapper.*;

import com.ruoyi.project.system.service.ISysConfigService;

import com.ruoyi.project.system.service.ISysUserService;

import jakarta.validation.Validator;

import lombok.RequiredArgsConstructor;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import org.springframework.util.CollectionUtils;



import java.util.ArrayList;

import java.util.List;

import java.util.stream.Collectors;



/**

 * 用户 业务层处理

 * 
 *

 * @author ruoyi

 */

@Service

@RequiredArgsConstructor

public class SysUserServiceImpl implements ISysUserService

{

    private static final Logger log = LoggerFactory.getLogger(SysUserServiceImpl.class);



    @Autowired

    private SysUserMapper userMapper;



    @Autowired

    private SysRoleMapper roleMapper;



    @Autowired

    private SysPostMapper postMapper;



    @Autowired

    private SysUserRoleMapper userRoleMapper;



    @Autowired

    private SysUserPostMapper userPostMapper;



    @Autowired

    private ISysConfigService configService;



    @Autowired

    protected Validator validator;

    private final SysUserDeptMapper sysUserDeptMapper;

    private final SysUserMapper userMapper;

    private final SysRoleMapper roleMapper;

    private final SysPostMapper postMapper;

    private final SysUserRoleMapper userRoleMapper;

    private final SysUserPostMapper userPostMapper;

    private final ISysConfigService configService;

    protected final Validator validator;



    /**

     * 根据条件分页查询用户列表

     * 
     *

     * @param user 用户信息

     * @return 用户信息集合信息

     */

@@ -76,7 +59,7 @@


    /**

     * 根据条件分页查询已分配用户角色列表

     * 
     *

     * @param user 用户信息

     * @return 用户信息集合信息

     */

@@ -89,7 +72,7 @@


    /**

     * 根据条件分页查询未分配用户角色列表

     * 
     *

     * @param user 用户信息

     * @return 用户信息集合信息

     */

@@ -102,7 +85,7 @@


    /**

     * 通过用户名查询用户

     * 
     *

     * @param userName 用户名

     * @return 用户对象信息

     */

@@ -114,7 +97,7 @@


    /**

     * 通过用户ID查询用户

     * 
     *

     * @param userId 用户ID

     * @return 用户对象信息

     */

@@ -126,7 +109,7 @@


    /**

     * 查询用户所属角色组

     * 
     *

     * @param userName 用户名

     * @return 结果

     */

@@ -143,7 +126,7 @@


    /**

     * 查询用户所属岗位组

     * 
     *

     * @param userName 用户名

     * @return 结果

     */

@@ -160,7 +143,7 @@


    /**

     * 校验用户名称是否唯一

     * 
     *

     * @param user 用户信息

     * @return 结果

     */

@@ -214,7 +197,7 @@


    /**

     * 校验用户是否允许操作

     * 
     *

     * @param user 用户信息

     */

    @Override

@@ -228,7 +211,7 @@


    /**

     * 校验用户是否有数据权限

     * 
     *

     * @param userId 用户id

     */

    @Override

@@ -248,7 +231,7 @@


    /**

     * 新增保存用户信息

     * 
     *

     * @param user 用户信息

     * @return 结果

     */

@@ -262,12 +245,14 @@
        insertUserPost(user);

        // 新增用户与角色管理

        insertUserRole(user);

        // 新增部门关联

        bindUserDept(user);

        return rows;

    }



    /**

     * 注册用户信息

     * 
     *

     * @param user 用户信息

     * @return 结果

     */

@@ -279,7 +264,7 @@


    /**

     * 修改保存用户信息

     * 
     *

     * @param user 用户信息

     * @return 结果

     */

@@ -301,7 +286,7 @@


    /**

     * 用户授权角色

     * 
     *

     * @param userId 用户ID

     * @param roleIds 角色组

     */

@@ -315,7 +300,7 @@


    /**

     * 修改用户状态

     * 
     *

     * @param user 用户信息

     * @return 结果

     */

@@ -327,7 +312,7 @@


    /**

     * 修改用户基本信息

     * 
     *

     * @param user 用户信息

     * @return 结果

     */

@@ -339,7 +324,7 @@


    /**

     * 修改用户头像

     * 
     *

     * @param userName 用户名

     * @param avatar 头像地址

     * @return 结果

@@ -352,7 +337,7 @@


    /**

     * 重置用户密码

     * 
     *

     * @param user 用户信息

     * @return 结果

     */

@@ -364,7 +349,7 @@


    /**

     * 重置用户密码

     * 
     *

     * @param userName 用户名

     * @param password 密码

     * @return 结果

@@ -377,7 +362,7 @@


    /**

     * 新增用户角色信息

     * 
     *

     * @param user 用户对象

     */

    public void insertUserRole(SysUser user)

@@ -387,7 +372,7 @@


    /**

     * 新增用户岗位信息

     * 
     *

     * @param user 用户对象

     */

    public void insertUserPost(SysUser user)

@@ -410,7 +395,7 @@


    /**

     * 新增用户角色信息

     * 
     *

     * @param userId 用户ID

     * @param roleIds 角色组

     */

@@ -433,7 +418,7 @@


    /**

     * 通过用户ID删除用户

     * 
     *

     * @param userId 用户ID

     * @return 结果

     */

@@ -450,7 +435,7 @@


    /**

     * 批量删除用户信息

     * 
     *

     * @param userIds 需要删除的用户ID

     * @return 结果

     */

@@ -467,12 +452,15 @@
        userRoleMapper.deleteUserRole(userIds);

        // 删除用户与岗位关联

        userPostMapper.deleteUserPost(userIds);

        // 删除用户与部门数据

        sysUserDeptMapper.delete(new LambdaQueryWrapper<SysUserDept>()

                .in(SysUserDept::getUserId, userIds));

        return userMapper.deleteUserByIds(userIds);

    }



    /**

     * 导入用户数据

     * 
     *

     * @param userList 用户数据列表

     * @param isUpdateSupport 是否更新支持，如果已存在，则进行更新数据

     * @param operName 操作用户

@@ -489,7 +477,6 @@
        int failureNum = 0;

        StringBuilder successMsg = new StringBuilder();

        StringBuilder failureMsg = new StringBuilder();

        String password = configService.selectConfigByKey("sys.user.initPassword");

        for (SysUser user : userList)

        {

            try

@@ -499,9 +486,10 @@
                if (StringUtils.isNull(u))

                {

                    BeanValidators.validateWithException(validator, user);

                    String password = configService.selectConfigByKey("sys.user.initPassword");

                    user.setPassword(SecurityUtils.encryptPassword(password));

                    user.setCreateBy(operName);

                    this.insertUser(user);

                    userMapper.insertUser(user);

                    successNum++;

                    successMsg.append("<br/>" + successNum + "、账号 " + user.getUserName() + " 导入成功");

                }

@@ -512,7 +500,7 @@
                    checkUserDataScope(u.getUserId());

                    user.setUserId(u.getUserId());

                    user.setUpdateBy(operName);

                    this.updateUser(user);

                    userMapper.updateUser(user);

                    successNum++;

                    successMsg.append("<br/>" + successNum + "、账号 " + user.getUserName() + " 更新成功");

                }

@@ -541,4 +529,44 @@
        }

        return successMsg.toString();

    }



    /**

     * 不分页用户查询

     * @param user

     * @return

     */

    @Override

    public List<SysUser> userListNoPage(SysUser user) {

        return userMapper.selectUserList(user);

    }



    /**

     * 查询角色为teamLeader的用户列表（不分页）

     * @return

     */

    @Override

    public List<SysUser> selectTeamLeaderUserList() {

        return userMapper.selectTeamLeaderUserList();

    }



    /**

     * 绑定用户部门

     * @param user

     * @return

     */

    @Override

    public int bindUserDept(SysUser user) {

        // 删除所有关联绑定

        LambdaQueryWrapper<SysUserDept> delWrapper = new LambdaQueryWrapper<>();

        delWrapper.eq(SysUserDept::getUserId, user.getUserId());

        sysUserDeptMapper.delete(delWrapper);

        // 重新绑定

        for (int i = 0; i < user.getDeptIds().length; i++) {

            SysUserDept sysUserDept = new SysUserDept();

            sysUserDept.setDeptId(user.getDeptIds()[i]);

            sysUserDept.setUserId(user.getUserId());

            sysUserDeptMapper.insert(sysUserDept);

        }

        return user.getDeptIds().length;

    }

}