增加班组长接口

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,15 +143,16 @@


    /**

     * 校验用户名称是否唯一

     * 
     * @param userName 用户名称

     *

     * @param user 用户信息

     * @return 结果

     */

    @Override

    public String checkUserNameUnique(String userName)

    public boolean checkUserNameUnique(SysUser user)

    {

        int count = userMapper.checkUserNameUnique(userName);

        if (count > 0)

        Long userId = StringUtils.isNull(user.getUserId()) ? -1L : user.getUserId();

        SysUser info = userMapper.checkUserNameUnique(user.getUserName());

        if (StringUtils.isNotNull(info) && info.getUserId().longValue() != userId.longValue())

        {

            return UserConstants.NOT_UNIQUE;

        }

@@ -182,7 +166,7 @@
     * @return

     */

    @Override

    public String checkPhoneUnique(SysUser user)

    public boolean checkPhoneUnique(SysUser user)

    {

        Long userId = StringUtils.isNull(user.getUserId()) ? -1L : user.getUserId();

        SysUser info = userMapper.checkPhoneUnique(user.getPhonenumber());

@@ -200,7 +184,7 @@
     * @return

     */

    @Override

    public String checkEmailUnique(SysUser user)

    public boolean checkEmailUnique(SysUser user)

    {

        Long userId = StringUtils.isNull(user.getUserId()) ? -1L : user.getUserId();

        SysUser info = userMapper.checkEmailUnique(user.getEmail());

@@ -213,7 +197,7 @@


    /**

     * 校验用户是否允许操作

     * 
     *

     * @param user 用户信息

     */

    @Override

@@ -227,7 +211,7 @@


    /**

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

     * 
     *

     * @param userId 用户id

     */

    @Override

@@ -247,7 +231,7 @@


    /**

     * 新增保存用户信息

     * 
     *

     * @param user 用户信息

     * @return 结果

     */

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

        // 新增用户与角色管理

        insertUserRole(user);

        // 新增部门关联

        bindUserDept(user);

        return rows;

    }



    /**

     * 注册用户信息

     * 
     *

     * @param user 用户信息

     * @return 结果

     */

@@ -278,7 +264,7 @@


    /**

     * 修改保存用户信息

     * 
     *

     * @param user 用户信息

     * @return 结果

     */

@@ -300,7 +286,7 @@


    /**

     * 用户授权角色

     * 
     *

     * @param userId 用户ID

     * @param roleIds 角色组

     */

@@ -314,7 +300,7 @@


    /**

     * 修改用户状态

     * 
     *

     * @param user 用户信息

     * @return 结果

     */

@@ -326,7 +312,7 @@


    /**

     * 修改用户基本信息

     * 
     *

     * @param user 用户信息

     * @return 结果

     */

@@ -338,7 +324,7 @@


    /**

     * 修改用户头像

     * 
     *

     * @param userName 用户名

     * @param avatar 头像地址

     * @return 结果

@@ -351,7 +337,7 @@


    /**

     * 重置用户密码

     * 
     *

     * @param user 用户信息

     * @return 结果

     */

@@ -363,7 +349,7 @@


    /**

     * 重置用户密码

     * 
     *

     * @param userName 用户名

     * @param password 密码

     * @return 结果

@@ -376,7 +362,7 @@


    /**

     * 新增用户角色信息

     * 
     *

     * @param user 用户对象

     */

    public void insertUserRole(SysUser user)

@@ -386,7 +372,7 @@


    /**

     * 新增用户岗位信息

     * 
     *

     * @param user 用户对象

     */

    public void insertUserPost(SysUser user)

@@ -409,7 +395,7 @@


    /**

     * 新增用户角色信息

     * 
     *

     * @param userId 用户ID

     * @param roleIds 角色组

     */

@@ -432,7 +418,7 @@


    /**

     * 通过用户ID删除用户

     * 
     *

     * @param userId 用户ID

     * @return 结果

     */

@@ -449,7 +435,7 @@


    /**

     * 批量删除用户信息

     * 
     *

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

     * @return 结果

     */

@@ -466,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 操作用户

@@ -488,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

@@ -498,17 +486,21 @@
                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() + " 导入成功");

                }

                else if (isUpdateSupport)

                {

                    BeanValidators.validateWithException(validator, user);

                    checkUserAllowed(u);

                    checkUserDataScope(u.getUserId());

                    user.setUserId(u.getUserId());

                    user.setUpdateBy(operName);

                    this.updateUser(user);

                    userMapper.updateUser(user);

                    successNum++;

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

                }

@@ -537,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;

    }

}