| | |
| | | |
| | | // 将用户列表存入 Redis,使用用户 ID 作为 Redis 键 |
| | | userList.forEach(user -> { |
| | | redisCache.setCacheObject(CacheConstants.SYS_USER_KEY + user.getUserId(), user); |
| | | redisCache.setCacheMapValue(CacheConstants.SYS_USER, user.getUserId().toString(), user); |
| | | }); |
| | | |
| | | log.info("用户信息已成功加载到 Redis!"); |
| | |
| | | // 新增用户信息 |
| | | int rows = userMapper.insertUser(user); |
| | | // 同步到 Redis |
| | | redisCache.setCacheObject(CacheConstants.SYS_USER_KEY + user.getUserId(), user); |
| | | redisCache.setCacheMapValue(CacheConstants.SYS_USER, user.getUserId().toString(), user); |
| | | // 新增用户岗位关联 |
| | | insertUserPost(user); |
| | | // 新增用户与角色管理 |
| | |
| | | // 更新用户信息 |
| | | int result = userMapper.updateUser(user); |
| | | // 同步到 Redis |
| | | redisCache.setCacheObject(CacheConstants.SYS_USER_KEY + user.getUserId(), user); |
| | | redisCache.setCacheMapValue(CacheConstants.SYS_USER, user.getUserId().toString(), user); |
| | | return result; |
| | | } |
| | | |
| | |
| | | // 删除用户信息 |
| | | int result = userMapper.deleteUserById(userId); |
| | | // 从 Redis 删除用户信息 |
| | | redisCache.deleteObject(CacheConstants.SYS_USER_KEY + userId); |
| | | redisCache.deleteCacheMapValue(CacheConstants.SYS_USER, userId.toString()); |
| | | return result; |
| | | } |
| | | |
| | |
| | | |
| | | // 批量删除 Redis 中的用户信息 |
| | | for (Long userId : userIds) { |
| | | redisCache.deleteObject(CacheConstants.SYS_USER_KEY + userId); |
| | | redisCache.deleteCacheMapValue(CacheConstants.SYS_USER, userId.toString()); |
| | | } |
| | | return result; |
| | | } |