package com.ruoyi.web.controller.system; 
 | 
  
 | 
import java.util.List; 
 | 
import java.util.stream.Collectors; 
 | 
  
 | 
import io.swagger.annotations.ApiOperation; 
 | 
import org.apache.commons.lang3.ArrayUtils; 
 | 
import org.springframework.beans.factory.annotation.Autowired; 
 | 
import org.springframework.security.access.prepost.PreAuthorize; 
 | 
import org.springframework.validation.annotation.Validated; 
 | 
import org.springframework.web.bind.annotation.*; 
 | 
import org.springframework.web.multipart.MultipartFile; 
 | 
import com.ruoyi.common.annotation.Log; 
 | 
import com.ruoyi.common.constant.UserConstants; 
 | 
import com.ruoyi.common.core.controller.BaseController; 
 | 
import com.ruoyi.common.core.domain.AjaxResult; 
 | 
import com.ruoyi.common.core.domain.entity.SysRole; 
 | 
import com.ruoyi.common.core.domain.entity.SysUser; 
 | 
import com.ruoyi.common.core.page.TableDataInfo; 
 | 
import com.ruoyi.common.enums.BusinessType; 
 | 
import com.ruoyi.common.utils.SecurityUtils; 
 | 
import com.ruoyi.common.utils.StringUtils; 
 | 
import com.ruoyi.common.utils.poi.ExcelUtil; 
 | 
import com.ruoyi.system.service.ISysPostService; 
 | 
import com.ruoyi.system.service.ISysRoleService; 
 | 
import com.ruoyi.system.service.ISysUserService; 
 | 
  
 | 
/** 
 | 
 * 用户信息 
 | 
 * 
 | 
 * @author ruoyi 
 | 
 */ 
 | 
@RestController 
 | 
@RequestMapping("/system/user") 
 | 
public class SysUserController extends BaseController { 
 | 
    @Autowired 
 | 
    private ISysUserService userService; 
 | 
  
 | 
    @Autowired 
 | 
    private ISysRoleService roleService; 
 | 
  
 | 
    @Autowired 
 | 
    private ISysPostService postService; 
 | 
  
 | 
    /** 
 | 
     * 获取用户列表 
 | 
     */ 
 | 
    // @PreAuthorize("@ss.hasPermi('system:user:list')") 
 | 
    @GetMapping("/list") 
 | 
    public TableDataInfo list(SysUser user) { 
 | 
        startPage(); 
 | 
        List<SysUser> list = userService.selectUserList(user); 
 | 
        return getDataTable(list); 
 | 
    } 
 | 
  
 | 
    @Log(title = "用户管理", businessType = BusinessType.EXPORT) 
 | 
    // @PreAuthorize("@ss.hasPermi('system:user:export')") 
 | 
    @GetMapping("/export") 
 | 
    public AjaxResult export(SysUser user) { 
 | 
        List<SysUser> list = userService.selectUserList(user); 
 | 
        ExcelUtil<SysUser> util = new ExcelUtil<SysUser>(SysUser.class); 
 | 
        return util.exportExcel(list, "用户数据"); 
 | 
    } 
 | 
  
 | 
    @Log(title = "用户管理", businessType = BusinessType.IMPORT) 
 | 
    // @PreAuthorize("@ss.hasPermi('system:user:import')") 
 | 
    @PostMapping("/importData") 
 | 
    public AjaxResult importData(MultipartFile file, boolean updateSupport) throws Exception { 
 | 
        ExcelUtil<SysUser> util = new ExcelUtil<SysUser>(SysUser.class); 
 | 
        List<SysUser> userList = util.importExcel(file.getInputStream()); 
 | 
        String operName = getUsername(); 
 | 
        String message = userService.importUser(userList, updateSupport, operName); 
 | 
        return AjaxResult.success(message); 
 | 
    } 
 | 
  
 | 
    @GetMapping("/importTemplate") 
 | 
    public AjaxResult importTemplate() { 
 | 
        ExcelUtil<SysUser> util = new ExcelUtil<SysUser>(SysUser.class); 
 | 
        return util.importTemplateExcel("用户数据"); 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 根据用户编号获取详细信息 
 | 
     */ 
 | 
    // @PreAuthorize("@ss.hasPermi('system:user:query')") 
 | 
    @GetMapping(value = {"/", "/{userId}"}) 
 | 
    public AjaxResult getInfo(@PathVariable(value = "userId", required = false) Long userId) { 
 | 
        userService.checkUserDataScope(userId); 
 | 
        AjaxResult ajax = AjaxResult.success(); 
 | 
        List<SysRole> roles = roleService.selectRoleAll(); 
 | 
        ajax.put("roles", SysUser.isAdmin(userId) ? roles : roles.stream().filter(r -> !r.isAdmin()).collect(Collectors.toList())); 
 | 
        ajax.put("posts", postService.selectPostAll()); 
 | 
        if (StringUtils.isNotNull(userId)) { 
 | 
            ajax.put(AjaxResult.DATA_TAG, userService.selectUserById(userId)); 
 | 
            ajax.put("postIds", postService.selectPostListByUserId(userId)); 
 | 
            ajax.put("roleIds", roleService.selectRoleListByUserId(userId)); 
 | 
        } 
 | 
        return ajax; 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 新增用户 
 | 
     */ 
 | 
    // @PreAuthorize("@ss.hasPermi('system:user:add')") 
 | 
    @Log(title = "用户管理", businessType = BusinessType.INSERT) 
 | 
    @PostMapping 
 | 
    public AjaxResult add(@Validated @RequestBody SysUser user) { 
 | 
        if (UserConstants.NOT_UNIQUE.equals(userService.checkUserNameUnique(user.getUserName()))) { 
 | 
            return AjaxResult.error("新增用户'" + user.getUserName() + "'失败,登录账号已存在"); 
 | 
        } else if (StringUtils.isNotEmpty(user.getPhonenumber()) && UserConstants.NOT_UNIQUE.equals(userService.checkPhoneUnique(user))) { 
 | 
            return AjaxResult.error("新增用户'" + user.getUserName() + "'失败,手机号码已存在"); 
 | 
        } else if (StringUtils.isNotEmpty(user.getEmail()) && UserConstants.NOT_UNIQUE.equals(userService.checkEmailUnique(user))) { 
 | 
            return AjaxResult.error("新增用户'" + user.getUserName() + "'失败,邮箱账号已存在"); 
 | 
        } 
 | 
        user.setCreateBy(getUsername()); 
 | 
        if (checkPasswordRule(user.getPassword())) { 
 | 
            user.setPassword(SecurityUtils.encryptPassword(user.getPassword())); 
 | 
        } else { 
 | 
            AjaxResult.error("密码格式: 大小写字母、数字、特殊字符中的至少三种(长度大于等于8位)"); 
 | 
        } 
 | 
        return toAjax(userService.insertUser(user)); 
 | 
    } 
 | 
  
 | 
    public static final String REG_NUMBER = ".*\\d+.*"; 
 | 
    //小写字母 
 | 
    public static final String REG_UPPERCASE = ".*[A-Z]+.*"; 
 | 
    //大写字母 
 | 
    public static final String REG_LOWERCASE = ".*[a-z]+.*"; 
 | 
    //特殊符号 
 | 
    public static final String REG_SYMBOL = ".*[~!@#$%^&*()_+|<>,.?/:;'\\[\\]{}\"]+.*"; 
 | 
  
 | 
    public static boolean checkPasswordRule(String password) { 
 | 
        //密码为空或者长度小于8位则返回false 
 | 
        if (password == null || password.length() < 8) return false; 
 | 
        int i = 0; 
 | 
        if (password.matches(REG_NUMBER)) i++; 
 | 
        if (password.matches(REG_LOWERCASE)) i++; 
 | 
        if (password.matches(REG_UPPERCASE)) i++; 
 | 
        if (password.matches(REG_SYMBOL)) i++; 
 | 
        if (i < 3) return false; 
 | 
        return true; 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 修改用户 
 | 
     */ 
 | 
    // @PreAuthorize("@ss.hasPermi('system:user:edit')") 
 | 
    @Log(title = "用户管理", businessType = BusinessType.UPDATE) 
 | 
    @PostMapping("/edit") 
 | 
    public AjaxResult edit(@Validated @RequestBody SysUser user) { 
 | 
        userService.checkUserAllowed(user); 
 | 
        if (StringUtils.isNotEmpty(user.getPhonenumber()) && UserConstants.NOT_UNIQUE.equals(userService.checkPhoneUnique(user))) { 
 | 
            return AjaxResult.error("修改用户'" + user.getUserName() + "'失败,手机号码已存在"); 
 | 
        } else if (StringUtils.isNotEmpty(user.getEmail()) && UserConstants.NOT_UNIQUE.equals(userService.checkEmailUnique(user))) { 
 | 
            return AjaxResult.error("修改用户'" + user.getUserName() + "'失败,邮箱账号已存在"); 
 | 
        } 
 | 
        user.setUpdateBy(getUsername()); 
 | 
        return toAjax(userService.updateUser(user)); 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 删除用户 
 | 
     */ 
 | 
    // @PreAuthorize("@ss.hasPermi('system:user:remove')") 
 | 
    @Log(title = "用户管理", businessType = BusinessType.DELETE) 
 | 
    @GetMapping("/remove/{userIds}") 
 | 
    public AjaxResult remove(@PathVariable Long[] userIds) { 
 | 
        if (ArrayUtils.contains(userIds, getUserId())) { 
 | 
            return error("当前用户不能删除"); 
 | 
        } 
 | 
        return toAjax(userService.deleteUserByIds(userIds)); 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 重置密码 
 | 
     */ 
 | 
    // @PreAuthorize("@ss.hasPermi('system:user:resetPwd')") 
 | 
    @Log(title = "用户管理", businessType = BusinessType.UPDATE) 
 | 
    @PostMapping("/resetPwd") 
 | 
    public AjaxResult resetPwd(@RequestBody SysUser user) { 
 | 
        userService.checkUserAllowed(user); 
 | 
        if (checkPasswordRule(user.getPassword())) { 
 | 
            user.setPassword(SecurityUtils.encryptPassword(user.getPassword())); 
 | 
        } else { 
 | 
            AjaxResult.error("密码格式: 大小写字母、数字、特殊字符中的至少三种(长度大于等于8位)"); 
 | 
        } 
 | 
        user.setUpdateBy(getUsername()); 
 | 
        return toAjax(userService.resetPwd(user)); 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 状态修改 
 | 
     */ 
 | 
    // @PreAuthorize("@ss.hasPermi('system:user:edit')") 
 | 
    @Log(title = "用户管理", businessType = BusinessType.UPDATE) 
 | 
    @PostMapping("/changeStatus") 
 | 
    public AjaxResult changeStatus(@RequestBody SysUser user) { 
 | 
        userService.checkUserAllowed(user); 
 | 
        user.setUpdateBy(getUsername()); 
 | 
        return toAjax(userService.updateUserStatus(user)); 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 根据用户编号获取授权角色 
 | 
     */ 
 | 
    // @PreAuthorize("@ss.hasPermi('system:user:query')") 
 | 
    @GetMapping("/authRole/{userId}") 
 | 
    public AjaxResult authRole(@PathVariable("userId") Long userId) { 
 | 
        AjaxResult ajax = AjaxResult.success(); 
 | 
        SysUser user = userService.selectUserById(userId); 
 | 
        List<SysRole> roles = roleService.selectRolesByUserId(userId); 
 | 
        ajax.put("user", user); 
 | 
        ajax.put("roles", SysUser.isAdmin(userId) ? roles : roles.stream().filter(r -> !r.isAdmin()).collect(Collectors.toList())); 
 | 
        return ajax; 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 用户授权角色 
 | 
     */ 
 | 
    // @PreAuthorize("@ss.hasPermi('system:user:edit')") 
 | 
    @Log(title = "用户管理", businessType = BusinessType.GRANT) 
 | 
    @PostMapping("/authRole/insertAuthRole") 
 | 
    public AjaxResult insertAuthRole(@RequestBody SysUser user) { 
 | 
        userService.insertUserAuth(user.getUserId(), user.getRoleIds()); 
 | 
        return success(); 
 | 
    } 
 | 
  
 | 
    @ApiOperation("获取用户姓名") 
 | 
    @GetMapping("/getNickname") 
 | 
    public AjaxResult getNickname() { 
 | 
        return AjaxResult.success(userService.getNickName()); 
 | 
    } 
 | 
  
 | 
    @ApiOperation("清理错误次数") 
 | 
    @GetMapping("/cleanErrorNums/{userName}") 
 | 
    public AjaxResult cleanErrorNums(@PathVariable String userName) { 
 | 
        return AjaxResult.success(userService.cleanErrorNums(userName)); 
 | 
    } 
 | 
  
 | 
  
 | 
} 
 |