From 59a3c28134c913317dd4683c63deaae58a72e36d Mon Sep 17 00:00:00 2001 From: akanyan Date: Mon, 20 Jan 2025 22:34:05 +0000 Subject: [PATCH] ongeki: use the latest applicable version --- titles/ongeki/schema/profile.py | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/titles/ongeki/schema/profile.py b/titles/ongeki/schema/profile.py index b42a0a3..2196c9d 100644 --- a/titles/ongeki/schema/profile.py +++ b/titles/ongeki/schema/profile.py @@ -277,8 +277,8 @@ class OngekiProfileData(BaseData): async def get_profile_name(self, aime_id: int, version: int) -> Optional[str]: sql = select(profile.c.userName).where( - and_(profile.c.user == aime_id, profile.c.version == version) - ) + and_(profile.c.user == aime_id, profile.c.version <= version) + ).order_by(profile.c.version.desc()) result = await self.execute(sql) if result is None: @@ -294,7 +294,8 @@ class OngekiProfileData(BaseData): sql = ( select([profile, option]) .join(option, profile.c.user == option.c.user) - .filter(and_(profile.c.user == aime_id, profile.c.version == version)) + .filter(and_(profile.c.user == aime_id, profile.c.version <= version)) + .order_by(profile.c.version.desc()) ) result = await self.execute(sql) @@ -306,9 +307,9 @@ class OngekiProfileData(BaseData): sql = select(profile).where( and_( profile.c.user == aime_id, - profile.c.version == version, + profile.c.version <= version, ) - ) + ).order_by(profile.c.version.desc()) result = await self.execute(sql) if result is None: