zqy
5 天以前 b02beccf4567068cb47a3f1181a00039456c872d
ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysUserServiceImpl.java
@@ -1,9 +1,20 @@
package com.ruoyi.system.service.impl;
import java.util.ArrayList;
import java.util.List;
import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors;
import javax.annotation.Resource;
import javax.validation.Validator;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.extension.service.IService;
import com.ruoyi.domain.ZInfoUser;
import com.ruoyi.domain.ZfAncestor;
import com.ruoyi.service.ZInfoUserService;
import com.ruoyi.service.ZfAncestorService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -36,8 +47,7 @@
 * @author ruoyi
 */
@Service
public class SysUserServiceImpl implements ISysUserService
{
public class SysUserServiceImpl implements ISysUserService {
    private static final Logger log = LoggerFactory.getLogger(SysUserServiceImpl.class);
    @Autowired
@@ -53,6 +63,9 @@
    private SysUserRoleMapper userRoleMapper;
    @Autowired
    private SysUserRoleMapper sysUserRoleMapper;
    @Autowired
    private SysUserPostMapper userPostMapper;
    @Autowired
@@ -60,6 +73,24 @@
    @Autowired
    protected Validator validator;
    @Autowired
    private ZfAncestorService zfService;
    @Resource
    private ZInfoUserService zInfoUserService;
    @Override
    public List<String> findUserNames(Long[] ids) {
        List<String> usNames = userMapper.findUserNames(ids).stream().map(SysUser::getUserName).collect(Collectors.toList());
                //.stream().map(SysUser::getUserName).collect(Collectors.toList());;
        System.out.println("99999999999900000000000");
        System.out.println(usNames);
                //.stream().map(SysUser::getUserName).collect(Collectors.toList());
        return usNames;
    }
    /**
     * 根据条件分页查询用户列表
@@ -72,6 +103,11 @@
    public List<SysUser> selectUserList(SysUser user)
    {
        return userMapper.selectUserList(user);
    }
    @Override
    public List<SysUser> selectCommonUserList(SysUser user) {
        return userMapper.selectCommonUserList(user);
    }
    /**
@@ -110,6 +146,11 @@
    public SysUser selectUserByUserName(String userName)
    {
        return userMapper.selectUserByUserName(userName);
    }
    @Override
    public SysUser selectUserByNickName(String nickName) {
        return userMapper.selectUserByNickName(nickName);
    }
    /**
@@ -176,6 +217,17 @@
        return UserConstants.UNIQUE;
    }
    @Override
    public boolean checkNickNameUnique(SysUser user) {
        Long userId = StringUtils.isNull(user.getUserId()) ? -1L : user.getUserId();
        SysUser info = userMapper.checkNickNameUnique(user.getNickName());
        if (StringUtils.isNotNull(info) && info.getUserId().longValue() != userId.longValue())
        {
            return UserConstants.NOT_UNIQUE;
        }
        return UserConstants.UNIQUE;
    }
    /**
     * 校验手机号码是否唯一
     *
@@ -234,7 +286,16 @@
    @Override
    public void checkUserDataScope(Long userId)
    {
        if (!SysUser.isAdmin(SecurityUtils.getUserId()))
        //判断是否是管理员
        ZfAncestor zfAncestor = new ZfAncestor();
        zfAncestor.setSysId(userId);
        zfAncestor = zfService.selectZfAncestor(zfAncestor);
        System.out.println("---------++++++++____________");
        System.out.println(zfAncestor);
        //判断是否是超级管理员
        if(zfAncestor!=null && zfAncestor.getId()==1L && zfAncestor.getRoleId()==0L)
//        if (!SysUser.isAdmin(SecurityUtils.getUserId()))
        {
            SysUser user = new SysUser();
            user.setUserId(userId);
@@ -262,6 +323,8 @@
        insertUserPost(user);
        // 新增用户与角色管理
        insertUserRole(user);
        return rows;
    }
@@ -274,7 +337,16 @@
    @Override
    public boolean registerUser(SysUser user)
    {
        return userMapper.insertUser(user) > 0;
        int satisfyCount = userMapper.insertUser(user);
        if (satisfyCount > 0) {
            List<SysUserRole> roleList = new ArrayList<>();
            SysUserRole roleId = new SysUserRole();
            roleId.setUserId(user.getUserId());
            roleId.setRoleId(2L);
            roleList.add(roleId);
            sysUserRoleMapper.batchUserRole(roleList);
        }
        return satisfyCount > 0;
    }
    /**
@@ -289,13 +361,16 @@
    {
        Long userId = user.getUserId();
        // 删除用户与角色关联
        userRoleMapper.deleteUserRoleByUserId(userId);
        // 新增用户与角色管理
        insertUserRole(user);
//        userRoleMapper.deleteUserRoleByUserId(userId);
//        // 新增用户与角色管理
//        insertUserRole(user);
        // 删除用户与岗位关联
        userPostMapper.deleteUserPostByUserId(userId);
        // 新增用户与岗位管理
        insertUserPost(user);
        //更新用户信息表
        return userMapper.updateUser(user);
    }
@@ -382,6 +457,7 @@
     */
    public void insertUserRole(SysUser user)
    {
        this.insertUserRole(user.getUserId(), user.getRoleIds());
    }
@@ -445,7 +521,7 @@
        userRoleMapper.deleteUserRoleByUserId(userId);
        // 删除用户与岗位表
        userPostMapper.deleteUserPostByUserId(userId);
        return userMapper.deleteUserById(userId);
        return userMapper.deleteById(userId);
    }
    /**
@@ -467,7 +543,29 @@
        userRoleMapper.deleteUserRole(userIds);
        // 删除用户与岗位关联
        userPostMapper.deleteUserPost(userIds);
        return userMapper.deleteUserByIds(userIds);
        //找到用户名
        for(long uid : userIds) {
          //  System.out.println(name.equals(""));
         //   System.out.println(name==null);
         //   if(name!="" || name != null) {
                ZInfoUser fs = zInfoUserService.getInfoBysysId(uid);
                if(fs!=null)
                {
                    userMapper.deleteUserById(uid);
                }
                else
                {
                    userMapper.deleteById(uid);
                }
          //  }
        }
        return 1;
//        zInfoUserService.removeByUserName( findUserNames(userIds));
    }
    /**
@@ -490,6 +588,8 @@
        StringBuilder successMsg = new StringBuilder();
        StringBuilder failureMsg = new StringBuilder();
        String password = configService.selectConfigByKey("sys.user.initPassword");
        List<SysUserRole> roleList = new ArrayList<>();
        for (SysUser user : userList)
        {
            try
@@ -502,7 +602,12 @@
                    user.setPassword(SecurityUtils.encryptPassword(password));
                    user.setCreateBy(operName);
                    this.insertUser(user);
                    SysUserRole roleId = new SysUserRole();
                    roleId.setUserId(user.getUserId());
                    roleId.setRoleId(2L);
                    roleList.add(roleId);
                    successNum++;
                    successMsg.append("<br/>" + successNum + "、账号 " + user.getUserName() + " 导入成功");
                }
                else if (isUpdateSupport)
@@ -529,6 +634,7 @@
                log.error(msg, e);
            }
        }
        sysUserRoleMapper.batchUserRole(roleList);
        if (failureNum > 0)
        {
            failureMsg.insert(0, "很抱歉,导入失败!共 " + failureNum + " 条数据格式不正确,错误如下:");
@@ -540,4 +646,49 @@
        }
        return successMsg.toString();
    }
    @Override
    public boolean saveBatch(Collection<SysUser> entityList, int batchSize) {
        return false;
    }
    @Override
    public boolean saveOrUpdateBatch(Collection<SysUser> entityList, int batchSize) {
        return false;
    }
    @Override
    public boolean updateBatchById(Collection<SysUser> entityList, int batchSize) {
        return false;
    }
    @Override
    public boolean saveOrUpdate(SysUser entity) {
        return false;
    }
    @Override
    public SysUser getOne(Wrapper<SysUser> queryWrapper, boolean throwEx) {
        return null;
    }
    @Override
    public Map<String, Object> getMap(Wrapper<SysUser> queryWrapper) {
        return null;
    }
    @Override
    public <V> V getObj(Wrapper<SysUser> queryWrapper, Function<? super Object, V> mapper) {
        return null;
    }
    @Override
    public BaseMapper<SysUser> getBaseMapper() {
        return null;
    }
    @Override
    public Class<SysUser> getEntityClass() {
        return null;
    }
}