2 Commits

Author SHA1 Message Date
KilLze
ea5c95584d 优化会话列表,添加用户在线状态 2026-01-14 11:31:10 +08:00
KilLze
e170016019 完成用户在线状态查询 2026-01-14 11:21:06 +08:00
6 changed files with 41 additions and 0 deletions

View File

@@ -203,4 +203,15 @@ public class UserController {
return Result.success(ResultCode.SUCCESS,"用户登录成功",userLoginVO); return Result.success(ResultCode.SUCCESS,"用户登录成功",userLoginVO);
} }
/**
* 判断用户是否在线
* @param userId 用户ID
* @return 用户是否在线
*/
@GetMapping("/{userId}/online")
public Result<Boolean> isUserOnline(@PathVariable Long userId) {
boolean online = userService.isUserOnline(userId);
return Result.success(ResultCode.SUCCESS, "查询成功", online);
}
} }

View File

@@ -29,4 +29,6 @@ public class ChatSessionsVO {
private Integer topStatus; private Integer topStatus;
/** 免打扰状态 */ /** 免打扰状态 */
private Integer muteStatus; private Integer muteStatus;
/** 会话状态 */
private Boolean online;
} }

View File

@@ -26,4 +26,5 @@ public class UserInfoVO implements Serializable {
private LocalDateTime createdAt; private LocalDateTime createdAt;
private Double latitude; private Double latitude;
private Double longitude; private Double longitude;
private Boolean online;
} }

View File

@@ -92,4 +92,11 @@ public interface UserService {
* @return 用户列表 * @return 用户列表
*/ */
List<UserInfoVO> findNearbyUsers(double lat,double lng,double radiusKm); List<UserInfoVO> findNearbyUsers(double lat,double lng,double radiusKm);
/**
* 判断用户是否在线
* @param userId 用户ID
* @return 是否在线
*/
boolean isUserOnline(Long userId);
} }

View File

@@ -236,6 +236,7 @@ public class ChatServiceImpl implements ChatService {
vo.setSessionName("用户" + session.getTargetUserId()); vo.setSessionName("用户" + session.getTargetUserId());
vo.setAvatarUrl(null); vo.setAvatarUrl(null);
} }
vo.setOnline(userService.isUserOnline(currentUserId));
return vo; return vo;
}).collect(Collectors.toList()); }).collect(Collectors.toList());
} }

View File

@@ -491,4 +491,23 @@ public class UserServiceImpl implements UserService {
} }
return result; return result;
} }
@Override
public boolean isUserOnline(Long userId) {
if (userId == null) {
return false;
}
// 1. 是否被封禁
String banKey = "user:ban:" + userId;
if (Boolean.TRUE.equals(redisTemplate.hasKey(banKey))) {
return false;
}
// 2. 是否存在登录 token
String tokenKey = "login:token:" + userId;
Boolean online = redisTemplate.hasKey(tokenKey);
return Boolean.TRUE.equals(online);
}
} }