package com.ruoyi.web.controller.system; 
 | 
  
 | 
import java.util.List; 
 | 
import java.util.stream.Collectors; 
 | 
import javax.servlet.http.HttpServletResponse; 
 | 
  
 | 
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport; 
 | 
import com.github.xiaoymin.knife4j.annotations.ApiSupport; 
 | 
import com.ruoyi.utils.result.Results; 
 | 
import io.swagger.annotations.*; 
 | 
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.DeleteMapping; 
 | 
import org.springframework.web.bind.annotation.GetMapping; 
 | 
import org.springframework.web.bind.annotation.PathVariable; 
 | 
import org.springframework.web.bind.annotation.PostMapping; 
 | 
import org.springframework.web.bind.annotation.PutMapping; 
 | 
import org.springframework.web.bind.annotation.RequestBody; 
 | 
import org.springframework.web.bind.annotation.RequestMapping; 
 | 
import org.springframework.web.bind.annotation.RestController; 
 | 
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.SysDept; 
 | 
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.ISysDeptService; 
 | 
import com.ruoyi.system.service.ISysPostService; 
 | 
import com.ruoyi.system.service.ISysRoleService; 
 | 
import com.ruoyi.system.service.ISysUserService; 
 | 
  
 | 
/** 
 | 
 * 用户信息 
 | 
 * 
 | 
 * @author ruoyi 
 | 
 */ 
 | 
@Api(tags = "用户信息") 
 | 
@RestController 
 | 
@RequestMapping("/system/user") 
 | 
public class SysUserController extends BaseController { 
 | 
    @Autowired 
 | 
    private ISysUserService userService; 
 | 
  
 | 
    @Autowired 
 | 
    private ISysRoleService roleService; 
 | 
  
 | 
    @Autowired 
 | 
    private ISysDeptService deptService; 
 | 
  
 | 
    @Autowired 
 | 
    private ISysPostService postService; 
 | 
  
 | 
    /** 
 | 
     * 获取用户列表 
 | 
     */ 
 | 
    @ApiOperation("获取用户列表") 
 | 
//    @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')") 
 | 
    @PostMapping("/export") 
 | 
    public void export(HttpServletResponse response, SysUser user) { 
 | 
        List<SysUser> list = userService.selectUserList(user); 
 | 
        ExcelUtil<SysUser> util = new ExcelUtil<SysUser>(SysUser.class); 
 | 
        util.exportExcel(response, 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 success(message); 
 | 
    } 
 | 
  
 | 
    @PostMapping("/importTemplate") 
 | 
    public void importTemplate(HttpServletResponse response) { 
 | 
        ExcelUtil<SysUser> util = new ExcelUtil<SysUser>(SysUser.class); 
 | 
        util.importTemplateExcel(response, "用户数据"); 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 根据用户编号获取详细信息 
 | 
     */ 
 | 
    @ApiOperation("根据用户编号获取详细信息") 
 | 
    @PreAuthorize("@ss.hasPermi('system:user:query')") 
 | 
    @GetMapping(value = {"/", "/{userId}"}) 
 | 
    public AjaxResult getInfo(@PathVariable(value = "userId", required = false) String 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)) { 
 | 
            SysUser sysUser = userService.selectUserById(userId); 
 | 
            ajax.put(AjaxResult.DATA_TAG, sysUser); 
 | 
            ajax.put("postIds", postService.selectPostListByUserId(userId)); 
 | 
            ajax.put("roleIds", sysUser.getRoles().stream().map(SysRole::getRoleId).collect(Collectors.toList())); 
 | 
        } 
 | 
        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))) { 
 | 
            return error("新增用户'" + user.getUserName() + "'失败,登录账号已存在"); 
 | 
        } else if (StringUtils.isNotEmpty(user.getPhonenumber()) 
 | 
                && UserConstants.NOT_UNIQUE.equals(userService.checkPhoneUnique(user))) { 
 | 
            return error("新增用户'" + user.getUserName() + "'失败,手机号码已存在"); 
 | 
        } else if (StringUtils.isNotEmpty(user.getEmail()) 
 | 
                && UserConstants.NOT_UNIQUE.equals(userService.checkEmailUnique(user))) { 
 | 
            return error("新增用户'" + user.getUserName() + "'失败,邮箱账号已存在"); 
 | 
        } 
 | 
        user.setCreateBy(getUsername()); 
 | 
        user.setPassword(SecurityUtils.encryptPassword(user.getPassword())); 
 | 
        return toAjax(userService.insertUser(user)); 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 修改用户 
 | 
     */ 
 | 
    @ApiOperation("修改用户") 
 | 
    @PreAuthorize("@ss.hasPermi('system:user:edit')") 
 | 
    @Log(title = "用户管理", businessType = BusinessType.UPDATE) 
 | 
    @PutMapping 
 | 
    public AjaxResult edit(@Validated @RequestBody SysUser user) { 
 | 
        userService.checkUserAllowed(user); 
 | 
        userService.checkUserDataScope(user.getUserId()); 
 | 
        if (UserConstants.NOT_UNIQUE.equals(userService.checkUserNameUnique(user))) { 
 | 
            return error("修改用户'" + user.getUserName() + "'失败,登录账号已存在"); 
 | 
        } else if (StringUtils.isNotEmpty(user.getPhonenumber()) 
 | 
                && UserConstants.NOT_UNIQUE.equals(userService.checkPhoneUnique(user))) { 
 | 
            return error("修改用户'" + user.getUserName() + "'失败,手机号码已存在"); 
 | 
        } else if (StringUtils.isNotEmpty(user.getEmail()) 
 | 
                && UserConstants.NOT_UNIQUE.equals(userService.checkEmailUnique(user))) { 
 | 
            return error("修改用户'" + user.getUserName() + "'失败,邮箱账号已存在"); 
 | 
        } 
 | 
        user.setUpdateBy(getUsername()); 
 | 
        return toAjax(userService.updateUser(user)); 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 删除用户 
 | 
     */ 
 | 
    @PreAuthorize("@ss.hasPermi('system:user:remove')") 
 | 
    @Log(title = "用户管理", businessType = BusinessType.DELETE) 
 | 
    @DeleteMapping("/{userIds}") 
 | 
    public AjaxResult remove(@PathVariable String[] userIds) { 
 | 
        if (ArrayUtils.contains(userIds, getUserId())) { 
 | 
            return error("当前用户不能删除"); 
 | 
        } 
 | 
        return toAjax(userService.deleteUserByIds(userIds)); 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 重置密码 
 | 
     */ 
 | 
    @PreAuthorize("@ss.hasPermi('system:user:resetPwd')") 
 | 
    @Log(title = "用户管理", businessType = BusinessType.UPDATE) 
 | 
    @PutMapping("/resetPwd") 
 | 
    public AjaxResult resetPwd(@RequestBody SysUser user) { 
 | 
        userService.checkUserAllowed(user); 
 | 
        userService.checkUserDataScope(user.getUserId()); 
 | 
        user.setPassword(SecurityUtils.encryptPassword(user.getPassword())); 
 | 
        user.setUpdateBy(getUsername()); 
 | 
        return toAjax(userService.resetPwd(user)); 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 状态修改 
 | 
     */ 
 | 
    @PreAuthorize("@ss.hasPermi('system:user:edit')") 
 | 
    @Log(title = "用户管理", businessType = BusinessType.UPDATE) 
 | 
    @PutMapping("/changeStatus") 
 | 
    public AjaxResult changeStatus(@RequestBody SysUser user) { 
 | 
        userService.checkUserAllowed(user); 
 | 
        userService.checkUserDataScope(user.getUserId()); 
 | 
        user.setUpdateBy(getUsername()); 
 | 
        return toAjax(userService.updateUserStatus(user)); 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 根据用户编号获取授权角色 
 | 
     */ 
 | 
    @PreAuthorize("@ss.hasPermi('system:user:query')") 
 | 
    @GetMapping("/authRole/{userId}") 
 | 
    @ApiOperation("根据用户编号获取授权角色") 
 | 
    public AjaxResult authRole(@PathVariable("userId") String 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) 
 | 
    @PutMapping("/authRole") 
 | 
    public AjaxResult insertAuthRole(String userId, Long[] roleIds) { 
 | 
        userService.checkUserDataScope(userId); 
 | 
        userService.insertUserAuth(userId, roleIds); 
 | 
        return success(); 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 获取部门树列表 
 | 
     */ 
 | 
    @PreAuthorize("@ss.hasPermi('system:user:list')") 
 | 
    @GetMapping("/deptTree") 
 | 
    @ApiOperation("获取部门树列表") 
 | 
    public AjaxResult deptTree(SysDept dept) { 
 | 
        return success(deptService.selectDeptTreeList(dept)); 
 | 
    } 
 | 
    /** 
 | 
     * 获取部门树列表 
 | 
     */ 
 | 
    @GetMapping("/deptTreeNoDataScope") 
 | 
    @ApiOperation("获取部门树列表无数据权限") 
 | 
    public AjaxResult deptTree1(SysDept dept) { 
 | 
        return success(deptService.selectDeptTreeListNoDataScope(dept)); 
 | 
    } 
 | 
    /** 
 | 
     * 获取部门树列表 
 | 
     */ 
 | 
    @ApiOperation("获取部门树列表noPerm") 
 | 
    @GetMapping("/deptTree/noPerm") 
 | 
    public AjaxResult deptTreeNoPerm(SysDept dept) { 
 | 
        return success(deptService.selectDeptTreeList(dept)); 
 | 
    } 
 | 
    /** 
 | 
     * 修改密码 
 | 
     */ 
 | 
    @ApiOperation("修改密码") 
 | 
//    @PreAuthorize("@ss.hasPermi('system:user:changePwd')") 
 | 
    @PutMapping("/changePwd") 
 | 
    public Results changePwd(String newPassword) { 
 | 
        String userId = SecurityUtils.getUserId(); 
 | 
        SysUser sysUser = userService.selectUserById(userId); 
 | 
        userService.checkUserAllowed(sysUser); 
 | 
        userService.checkUserDataScope(userId); 
 | 
        sysUser.setPassword(SecurityUtils.encryptPassword(newPassword)); 
 | 
        sysUser.setUpdateBy(getUsername()); 
 | 
        int num = userService.resetPwd(sysUser); 
 | 
        if(num == 0){ 
 | 
            return Results.error("修改密码失败!"); 
 | 
        }else { 
 | 
            return Results.succeed("修改密码成功!"); 
 | 
        } 
 | 
    } 
 | 
  
 | 
} 
 |