| | |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
| | | import com.ruoyi.common.core.constant.CacheConstants; |
| | | import com.ruoyi.common.core.constant.SecurityConstants; |
| | | import com.ruoyi.common.core.domain.R; |
| | | import com.ruoyi.common.core.exception.ServiceException; |
| | | import com.ruoyi.common.core.utils.StringUtils; |
| | |
| | | import com.ruoyi.common.core.web.page.PageInfo; |
| | | import com.ruoyi.common.log.annotation.Log; |
| | | import com.ruoyi.common.log.enums.BusinessType; |
| | | import com.ruoyi.common.redis.service.RedisService; |
| | | import com.ruoyi.common.security.annotation.InnerAuth; |
| | | import com.ruoyi.common.security.annotation.RequiresPermissions; |
| | | import com.ruoyi.common.security.utils.SecurityUtils; |
| | | import com.ruoyi.system.api.domain.SysDept; |
| | | import com.ruoyi.system.api.domain.SysRole; |
| | | import com.ruoyi.system.api.domain.SysUser; |
| | | import com.ruoyi.system.api.feignClient.AuthClient; |
| | | import com.ruoyi.system.api.model.LoginUser; |
| | | import com.ruoyi.system.api.validate.InsertGroup; |
| | | import com.ruoyi.system.api.validate.UpdateGroup; |
| | |
| | | |
| | | @Autowired |
| | | private ISysUserRoleService sysUserRoleService; |
| | | @Autowired |
| | | private AuthClient authClient; |
| | | @Autowired |
| | | private RedisService redisService; |
| | | /** |
| | | * 获取用户列表 |
| | | */ |
| | |
| | | public AjaxResult add(@Validated(InsertGroup.class) @RequestBody SysUserDTO dto) { |
| | | SysUser user = BeanUtils.copyBean(dto, SysUser.class); |
| | | user.setUserId(null); |
| | | user.setUserType(dto.getIsAuctioneer() == 1 ? "04" : "00"); |
| | | user.setUserType(dto.getIsAuctioneer() == 1 ? "00" : "01"); |
| | | user.setUserName(user.getPhonenumber()); |
| | | if(!org.springframework.util.StringUtils.hasLength(user.getNickName())){ |
| | | user.setNickName(user.getPhonenumber()); |
| | |
| | | userService.checkUserDataScope(user.getUserId()); |
| | | SysUser sysUser = userService.getOne(Wrappers.lambdaQuery(SysUser.class) |
| | | .eq(SysUser::getPhonenumber, user.getPhonenumber()) |
| | | .in(SysUser::getUserType, "00", "01", "04") |
| | | .eq(SysUser::getDelFlag,0) |
| | | .last("LIMIT 1")); |
| | | |
| | |
| | | if (user.getPhonenumber() != null) { |
| | | user.setUserName(user.getPhonenumber()); |
| | | } |
| | | user.setUserType(dto.getIsAuctioneer() == 1 ? "00" : "01"); |
| | | user.setPassword(null); |
| | | user.setUpdateBy(SecurityUtils.getUsername()); |
| | | user.setUpdateTime(new Date()); |
| | |
| | | SysUser sysUser = userService.selectUserById(userId); |
| | | if (sysUser.getStatus().equals("0")) { |
| | | sysUser.setStatus("1"); |
| | | Object tokenObj = redisService.getCacheObject(getUserTokenKey(userId)); |
| | | if (Objects.nonNull(tokenObj)) { |
| | | authClient.logout(tokenObj.toString(), SecurityConstants.INNER); |
| | | } |
| | | } else { |
| | | sysUser.setStatus("0"); |
| | | } |
| | | return toAjax(userService.updateUser(sysUser)); |
| | | } |
| | | |
| | | private String getUserTokenKey(Long userId) { |
| | | return CacheConstants.USER_TOKEN_KEY + userId; |
| | | } |
| | | |
| | | @Autowired |
| | | private ISysUserRoleService iSysUserRoleService; |
| | |
| | | if (StringUtils.isNull(sysUser)) { |
| | | return R.fail("用户名或密码错误"); |
| | | } |
| | | // 角色集合 |
| | | Set<String> roles = permissionService.getRolePermission(sysUser); |
| | | // 权限集合 |
| | | Set<String> permissions = permissionService.getMenuPermission(sysUser); |
| | | LoginUser sysUserVo = new LoginUser(); |
| | | sysUserVo.setSysUser(sysUser); |
| | | sysUserVo.setRoles(roles); |
| | | sysUserVo.setPermissions(permissions); |
| | | |
| | | if (sysUser.getUserType().equals("00")) { |
| | | // 角色集合 |
| | | Set<String> roles = permissionService.getRolePermission(sysUser); |
| | | // 权限集合 |
| | | Set<String> permissions = permissionService.getMenuPermission(sysUser); |
| | | sysUserVo.setRoles(roles); |
| | | sysUserVo.setPermissions(permissions); |
| | | } |
| | | return R.ok(sysUserVo); |
| | | } |
| | | |
| | |
| | | /** |
| | | * 重置密码 |
| | | */ |
| | | @RequiresPermissions("system:user:edit") |
| | | @ApiOperation("重置密码") |
| | | @Log(title = "用户管理", businessType = BusinessType.UPDATE) |
| | | @PostMapping("/resetPwd") |
| | |
| | | public R<List<SysUser>> queryUserByPhoneList(@RequestBody List<String> phoneList){ |
| | | List<SysUser> list = userService.list(Wrappers.lambdaQuery(SysUser.class) |
| | | .in(SysUser::getPhonenumber, phoneList) |
| | | .ne(SysUser::getDelFlag,2)); |
| | | .eq(SysUser::getUserType,"01") |
| | | .eq(SysUser::getDelFlag,0)); |
| | | return R.ok(list); |
| | | } |
| | | |
| | | @PostMapping("/queryUserByPhoneList1") |
| | | public R<List<SysUser>> queryUserByPhoneList1(@RequestBody List<String> phoneList){ |
| | | List<SysUser> list = userService.list(Wrappers.lambdaQuery(SysUser.class) |
| | | .in(SysUser::getPhonenumber, phoneList)); |
| | | return R.ok(list); |
| | | } |
| | | |
| | |
| | | public R<SysUser> queryUserByPhone(@RequestBody String phone){ |
| | | SysUser user = userService.getOne(Wrappers.lambdaQuery(SysUser.class) |
| | | .eq(SysUser::getPhonenumber, phone) |
| | | .eq(SysUser::getUserType,"01") |
| | | .eq(SysUser::getStatus,0) |
| | | .eq(SysUser::getDelFlag,0) |
| | | .last("LIMIT 1")); |
| | | return R.ok(user); |
| | | |
| | | } |
| | | |
| | | @PostMapping("/queryUserByPhone1") |
| | | public R<SysUser> queryUserByPhone1(@RequestBody String phone) { |
| | | SysUser user = userService.getOne(Wrappers.lambdaQuery(SysUser.class) |
| | | .eq(SysUser::getPhonenumber, phone) |
| | | .eq(SysUser::getDelFlag, 0) |
| | | .eq(SysUser::getUserType,"01") |
| | | .last("LIMIT 1")); |
| | | return R.ok(user); |
| | | } |
| | | // @PostMapping("/queryUserByPhone1") |
| | | // public R<SysUser> queryUserByPhone1(@RequestBody String phone){ |
| | | // SysUser user = userService.getOne(Wrappers.lambdaQuery(SysUser.class) |
| | | // .eq(SysUser::getPhonenumber, phone) |
| | | // .eq(SysUser::get, phone) |
| | | // .last("LIMIT 1")); |
| | | // return R.ok(user); |
| | | // } |
| | | |
| | | |
| | | /** |
| | |
| | | public R<SysUser> queryUserByUserName(@RequestBody String userName){ |
| | | SysUser user = userService.getOne(Wrappers.lambdaQuery(SysUser.class) |
| | | .eq(SysUser::getUserName, userName) |
| | | .eq(SysUser::getDelFlag, "0") |
| | | .last("LIMIT 1")); |
| | | return R.ok(user); |
| | | } |
| | |
| | | } |
| | | |
| | | @InnerAuth |
| | | @GetMapping("/list-by-name") |
| | | @PostMapping("/list-by-name") |
| | | R<List<SysUser>> getUserListByName(@RequestBody SysUser sysUser) { |
| | | List<SysUser> list = userService.lambdaQuery() |
| | | .like(StringUtils.isNotBlank(sysUser.getNickName()), SysUser::getNickName, |