修改json工具类

accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/room/RoomService.java

@@ -3705,7 +3705,7 @@ public class RoomService extends BaseService {
         List<Long> micUidList = new ArrayList<>();
         String roomMicUpJson = jedisService.hget(RedisKey.room_mic_up.getKey(), String.valueOf(roomUid));
         if (StrUtil.isNotEmpty(roomMicUpJson)) {
-            PlayRoomVo playRoom = GsonUtil.getDefGson().fromJson(roomMicUpJson, PlayRoomVo.class);
+            PlayRoomVo playRoom = gson.fromJson(roomMicUpJson, PlayRoomVo.class);
             List<MicUserVo> micUsers = playRoom.getMicUsers();
             for (int i = micUsers.size() - 1; i >= 0; i--) {
                 MicUserVo micUser = micUsers.get(i);

python/peko_act_christmas_2023_rank_total.py

@@ -0,0 +1,87 @@
+import redis
+
+
+class RedisUtil:
+    def __init__(self, host, port, db, password):
+        self.host = host
+        self.port = port
+        self.db = db
+        self.password = password
+
+    def scan(self, match: str):
+        keys = []
+        res = redis.StrictRedis(host=self.host, port=self.port, db=self.db, password=self.password)
+        try:
+            cursor = 0
+            while True:
+                tup = res.scan(cursor=cursor, match=match, count=1000)
+                print(tup)
+                if isinstance(tup[0], int):
+                    cursor = tup[0]
+                if isinstance(tup[1], list):
+                    keys.extend(tup[1])
+                if cursor == 0:
+                    break
+        except Exception as e:
+            print('scan is error.', e)
+        finally:
+            res.close()
+        return keys
+
+    def delete(self, name: str):
+        res = redis.StrictRedis(host=self.host, port=self.port, db=self.db, password=self.password)
+        try:
+            res.delete(name)
+        except Exception as e:
+            print('delete ', name, ' is error.', e)
+        finally:
+            res.close()
+
+    def hgetall(self, name: str):
+        data = None
+        res = redis.StrictRedis(host=self.host, port=self.port, db=self.db, password=self.password)
+        try:
+            data = res.hgetall(name)
+        except Exception as e:
+            print('hget ', name, ' is error.', e)
+        finally:
+            res.close()
+        return data
+
+    def hincrby(self, name: str, field, increment):
+        res = redis.StrictRedis(host=self.host, port=self.port, db=self.db, password=self.password)
+        try:
+            res.hincrby(name, field, increment)
+        except Exception as e:
+            print('hincrby ', name, ' is error.', e)
+        finally:
+            res.close()
+
+    def hdel(self, name: str, field):
+        res = redis.StrictRedis(host=self.host, port=self.port, db=self.db, password=self.password)
+        try:
+            res.hdel(name, field)
+        except Exception as e:
+            print('hdel ', name, ' is error.', e)
+        finally:
+            res.close()
+
+    def zrange(self, name: str, start: int, end: int, withscores: bool):
+        data = None
+        res = redis.StrictRedis(host=self.host, port=self.port, db=self.db, password=self.password)
+        try:
+            data = res.zrange(name, start=start, end=end, withscores=withscores)
+        except Exception as e:
+            print('hdel ', name, ' is error.', e)
+        finally:
+            res.close()
+        return data
+
+
+if __name__ == '__main__':
+    util = RedisUtil(host='172.16.0.2', port=6379, db=0, password='mehpec-vybgig-Demri6')
+    members = util.zrange('yinmeng_act_christmas_2023_rank_total', start=0, end=-1, withscores=True)
+    for member in members:
+        if member is not None:
+            print(member[0].decode('utf-8'), ',', str(member[1]))
+