update MediaConnection

message/message-service/src/main/java/cn/reghao/tnb/message/app/redis/RedisKeys.java

@@ -5,11 +5,7 @@ package cn.reghao.tnb.message.app.redis;
  * @date 2023-02-03 15:57:06
  */
 public class RedisKeys {
-    public static String getMediaProgressKey(String videoId) {
-        return String.format("tnb:message:progress:%s", videoId);
-    }
-
-    public static String getVideoUsersKey(String videoId) {
-        return String.format("tnb:message:progress:%s", videoId);
+    public static String getVideoUsersKey() {
+        return String.format("tnb:message:video_progress");
     }
 }

message/message-service/src/main/java/cn/reghao/tnb/message/app/ws/media/MediaConnection.java

@@ -56,7 +56,7 @@ public class MediaConnection {
         if (authedAccount != null) {
             String loginId = authedAccount.getLoginId();
             long userId = authedAccount.getUserId();
-            String redisKey = RedisKeys.getVideoUsersKey(videoId);
+            String redisKey = RedisKeys.getVideoUsersKey();
             HashSet<Long> userIds = redisHash.get(redisKey, videoId);
             if (userIds == null) {
                 userIds = new HashSet<>();
@@ -86,7 +86,7 @@ public class MediaConnection {
         sessionUsers.remove(userId);
 
         String videoId = (String) webSocketSession.getAttributes().get("videoId");
-        String redisKey = RedisKeys.getVideoUsersKey(videoId);
+        String redisKey = RedisKeys.getVideoUsersKey();
         HashSet<Long> userIds = redisHash.get(redisKey, videoId);
         if (userIds != null) {
             userIds.remove(userId);
@@ -159,7 +159,7 @@ public class MediaConnection {
     }
 
     public void sendViewCount(String videoId) {
-        String redisKey = RedisKeys.getVideoUsersKey(videoId);
+        String redisKey = RedisKeys.getVideoUsersKey();
         Set<Long> userIds = redisHash.get(redisKey, videoId);
         if (userIds == null) {
             return;