diff --git a/rc-service/rc-service-live/live-application/src/main/java/com/red/circle/live/app/command/user/LiveQuitRoomExe.java b/rc-service/rc-service-live/live-application/src/main/java/com/red/circle/live/app/command/user/LiveQuitRoomExe.java index d75ad23c..4f8384b1 100644 --- a/rc-service/rc-service-live/live-application/src/main/java/com/red/circle/live/app/command/user/LiveQuitRoomExe.java +++ b/rc-service/rc-service-live/live-application/src/main/java/com/red/circle/live/app/command/user/LiveQuitRoomExe.java @@ -1,13 +1,11 @@ package com.red.circle.live.app.command.user; import com.red.circle.common.business.dto.cmd.app.AppRoomIdCmd; -import com.red.circle.component.redis.service.RedisService; import com.red.circle.live.domain.gateway.LiveMicrophoneGateway; import com.red.circle.live.domain.live.LiveMicrophone; import com.red.circle.live.domain.live.LiveMusicStatus; import com.red.circle.live.infra.database.cache.service.LiveMicCacheService; import com.red.circle.live.infra.database.cache.service.LiveMusicHeartbeatService; -import com.red.circle.other.inner.endpoint.user.region.UserRegionClient; import com.red.circle.tool.core.collection.CollectionUtils; import java.util.List; import java.util.Objects; @@ -26,8 +24,6 @@ public class LiveQuitRoomExe { private final LiveMicCacheService liveMicCacheService; private final LiveMicrophoneGateway liveMicrophoneGateway; private final LiveMusicHeartbeatService liveMusicHeartbeatService; - private final UserRegionClient userRegionClient; - private final RedisService redisService; public void execute(AppRoomIdCmd cmd) { // 移除在线用户 @@ -54,16 +50,6 @@ public class LiveQuitRoomExe { && Objects.equals(musicStatus.getUserId(), cmd.requiredReqUserId())) { liveMusicHeartbeatService.removeMickUser(cmd.getRoomId()); } - - try { - //清空房间列表缓存 - String region = userRegionClient.getRegionCode(cmd.requiredReqUserId()).getBody(); - String key = cmd.requireReqSysOrigin() + region; - redisService.delete("USER:REGION_ROOM:" + key); - } catch (Exception e) { - // ignore - } - } }