diff --git a/accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/room/RoomService.java b/accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/room/RoomService.java index 52180cfc5..4866f3083 100644 --- a/accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/room/RoomService.java +++ b/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 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 micUsers = playRoom.getMicUsers(); for (int i = micUsers.size() - 1; i >= 0; i--) { MicUserVo micUser = micUsers.get(i); diff --git a/python/peko_act_christmas_2023_rank_total.py b/python/peko_act_christmas_2023_rank_total.py new file mode 100644 index 000000000..268be943b --- /dev/null +++ b/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])) +