| 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") | 
|     public AjaxResult deptTree(SysDept dept) { | 
|         return success(deptService.selectDeptTreeList(dept)); | 
|     } | 
|     /** | 
|      * 获取部门树列表 | 
|      */ | 
|     @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("修改密码成功!"); | 
|         } | 
|     } | 
| } |