merge dev into dev

修复了在过滤无效 token 时,没有增加对StpUtil.getLoginIdByToken 返回 null情况处理,导致 执行 groupingBy 报错

Created-by: onekr-billy
Commit-by: Billy
Merged-by: Charles_7c
Description: <!--
  非常感谢您的 PR!在提交之前,请务必确保您 PR 的代码经过了完整测试,并且通过了代码规范检查。
-->

<!-- 在 [] 中输入 x 来勾选) -->

## PR 类型

<!-- 您的 PR 引入了哪种类型的变更? -->
<!-- 只支持选择一种类型,如果有多种类型,可以在更新日志中增加 “类型” 列。 -->

- [ ] 新 feature
- [x] Bug 修复
- [ ] 功能增强
- [ ] 文档变更
- [ ] 代码样式变更
- [ ] 重构
- [ ] 性能改进
- [ ] 单元测试
- [ ] CI/CD
- [ ] 其他

## PR 目的

<!-- 描述一下您的 PR 解决了什么问题。如果可以,请链接到相关 issues。 -->

## 解决方案

<!-- 详细描述您是如何解决的问题 -->

## PR 测试

<!-- 如果可以,请为您的 PR 添加或更新单元测试。 -->
<!-- 请描述一下您是如何测试 PR 的。例如:创建/更新单元测试或添加相关的截图。 -->

## Changelog

| 模块  | Changelog | Related issues |
|-----|-----------| -------------- |
|     |           |                |

<!-- 如果有多种类型的变更,可以在变更日志表中增加 “类型” 列,该列的值与上方 “PR 类型” 相同。 -->
<!-- Related issues 格式为 Closes #<issue号>,或者 Fixes #<issue号>,或者 Resolves #<issue号>。 -->

## 其他信息

<!-- 请描述一下还有哪些注意事项。例如:如果引入了一个不向下兼容的变更,请描述其影响。 -->

## 提交前确认

- [x] PR 代码经过了完整测试,并且通过了代码规范检查
- [ ] 已经完整填写 Changelog,并链接到了相关 issues
- [x] PR 代码将要提交到 dev 分支

See merge request: continew/continew-admin!3
This commit is contained in:
2025-07-02 17:43:20 +08:00

View File

@@ -62,13 +62,26 @@ public class OnlineUserServiceImpl implements OnlineUserService {
List<OnlineUserResp> list = new ArrayList<>();
// 查询所有在线 Token
List<String> tokenKeyList = StpUtil.searchTokenValue(StringConstants.EMPTY, 0, -1, false);
Map<Long, List<String>> tokenMap = tokenKeyList.stream().filter(tokenKey -> {
String token = StrUtil.subAfter(tokenKey, StringConstants.COLON, true);
// 忽略已过期或失效 Token
return StpUtil.getStpLogic().getTokenActiveTimeoutByToken(token) >= SaTokenDao.NEVER_EXPIRE;
})
.map(tokenKey -> StrUtil.subAfter(tokenKey, StringConstants.COLON, true))
.collect(Collectors.groupingBy(token -> Convert.toLong(StpUtil.getLoginIdByToken(token))));
Map<Long, List<String>> tokenMap = tokenKeyList.stream()
// 提前映射,避免重复调用
.map(tokenKey -> StrUtil.subAfter(tokenKey, StringConstants.COLON, true))
.map(token -> {
Object loginIdObj = StpUtil.getLoginIdByToken(token);
long tokenTimeout = StpUtil.getStpLogic().getTokenActiveTimeoutByToken(token);
// 将相关信息打包成对象或简单的Entry对便于后续过滤与归类
return new AbstractMap.SimpleEntry<>(token, new AbstractMap.SimpleEntry<>(loginIdObj, tokenTimeout));
})
// 过滤出未过期且loginId存在的Token
.filter(entry -> {
Object loginIdObj = entry.getValue().getKey();
long tokenTimeout = entry.getValue().getValue();
return loginIdObj != null && tokenTimeout >= SaTokenDao.NEVER_EXPIRE;
})
// 此时数据都有效,进行收集
.collect(Collectors.groupingBy(
entry -> Convert.toLong(entry.getValue().getKey()),
Collectors.mapping(AbstractMap.SimpleEntry::getKey, Collectors.toList()))
);
// 筛选数据
for (Map.Entry<Long, List<String>> entry : tokenMap.entrySet()) {
Long userId = entry.getKey();