沈丘营商办后台
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
ZQN
2024-08-15 2562d6ce39aa405514c9e22ff0237f3f145040b6 
 project-system/src/main/java/com/project/system/service/impl/SysUserServiceImpl.java


@@ -16,6 +16,7 @@


import com.project.common.utils.bean.BeanValidators;


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


import com.project.system.domain.*;


import com.project.system.domain.bo.editBo.UserDeptBo;


import com.project.system.domain.vo.SysUserResultVo;


import com.project.system.domain.vo.SysUserVo;


import com.project.system.mapper.*;


@@ -27,6 +28,7 @@


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


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


import org.springframework.cache.annotation.CacheEvict;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.CollectionUtils;


@@ -56,6 +58,19 @@


    private final ISysUserDeptService userDeptService;


    private final ISysDeptService deptService;


    protected final Validator validator;




    /**


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


     *


     * @param user 用户信息


     * @return 用户信息集合信息


     */


    @Override


    @DataScope(deptAlias = "d", userAlias = "u")


    public List<SysUser> selectUserListCommon(SysUser user)


    {


        return userMapper.selectUserListCommon(user);


    }




    /**


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


@@ -250,6 +265,7 @@


     */


    @Override


    @Transactional


    @CacheEvict(value = "sysUser:peerList",allEntries = true)


    public int insertUser(SysUser user)


    {


        // 新增用户信息


@@ -285,6 +301,7 @@


     */


    @Override


    @Transactional


    @CacheEvict(value = "sysUser:peerList",allEntries = true)


    public int updateUser(SysUser user)


    {


        Long userId = user.getUserId();


@@ -296,9 +313,9 @@


        userPostMapper.deleteUserPostByUserId(userId);


        // 新增用户与岗位管理


        insertUserPost(user);




        SysUser old = this.selectUserById(userId);


        // 新增用户与部门管理


        if (!"02".equals(user.getUserType())){


        if (!"02".equals(user.getUserType()) && !old.getDeptId().equals(user.getDeptId())){


            insertUserDept(user);


        }


        return userMapper.updateUser(user);


@@ -397,12 +414,20 @@


     */


    public void insertUserDept(SysUser user)


    {


       userDeptService.remove(userDeptService.lq()


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


                .eq(SysUserDept::getDeptId, user.getDeptId())


        );


        SysUserDept userDept = new SysUserDept().setUserId(user.getUserId()).setDeptId(user.getDeptId());


        userDeptService.save(userDept);


        if (deptService.getCheckDeptIdByLoginDeptId(user.getDeptId()).equals(user.getDeptId())) { //分管局内所有部门


            List<SysDept> list = deptService.list(deptService.lq().eq(SysDept::getParentId, user.getDeptId()));


            List<Long> deptIds = list.stream().map(SysDept::getDeptId).collect(Collectors.toList());


            deptIds.add(user.getDeptId());


            UserDeptBo bo = new UserDeptBo();


            bo.setUserId(user.getUserId());


            bo.setDeptIds(deptIds);


            userDeptService.batchUserDeptSave(bo);


        } else { //分管单独部门


            userDeptService.remove(userDeptService.lq().eq(SysUserDept::getUserId, user.getUserId()));


            SysUserDept userDept = new SysUserDept().setUserId(user.getUserId()).setDeptId(user.getDeptId());


            userDeptService.save(userDept);


        }




    }




    /**


@@ -459,6 +484,7 @@


     */


    @Override


    @Transactional


    @CacheEvict(value = "sysUser:peerList",allEntries = true)


    public int deleteUserById(Long userId)


    {


        // 删除用户与角色关联


@@ -476,6 +502,7 @@


     */


    @Override


    @Transactional


    @CacheEvict(value = "sysUser:peerList",allEntries = true)


    public int deleteUserByIds(Long[] userIds)


    {


        for (Long userId : userIds)


@@ -565,14 +592,14 @@


    /**


     * 批量删除用户信息


     *


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


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


     * @return 结果


     */


    @Override


    @Transactional


    public int deleteUserByDeptId(Long deptId)


    public int deleteUserByCompanyPhone(String phone)


    {


        List<SysUser> sysUsers = userMapper.selectList(new LambdaQueryWrapper<SysUser>().eq(SysUser::getDeptId, deptId));


        List<SysUser> sysUsers = userMapper.selectList(new LambdaQueryWrapper<SysUser>().eq(SysUser::getPhonenumber, phone));


        Long[] ids = sysUsers.stream().map(SysUser::getUserId).toArray(Long[]::new);


        return this.deleteUserByIds(ids);


    }


@@ -709,4 +736,10 @@


        }


        return true;


    }




    @Override


    public String getDeptNameByUserId(Long userId)


    {


        return deptService.selectDeptById(selectUserById(userId).getDeptId()).getDeptName();


    }


}