Bennett/g0v0-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(daily-challenge): fix don't calculate user's statistics

Browse Source
This commit is contained in:
MingxuanGame
2025-08-29 16:19:37 +08:00
committed by GitHub
parent 224e890e31
commit d38cf12826
1 changed files with 29 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

59
app/service/daily_challenge.py
View File

@@ -138,42 +138,41 @@ async def process_daily_challenge_top():
) )
) )
).first() ).first()
if room is None:
return
scores = (
await session.exec(
select(PlaylistBestScore)
.where(
PlaylistBestScore.room_id == room.id,
PlaylistBestScore.playlist_id == 0,
col(PlaylistBestScore.score).has(col(Score.passed).is_(True)),
)
.order_by(col(PlaylistBestScore.total_score).desc())
)
).all()
total_score_count = len(scores)
s = []
participated_users = [] participated_users = []
for i, score in enumerate(scores): if room is not None:
stats = await session.get(DailyChallengeStats, score.user_id) scores = (
if stats is None: # not execute await session.exec(
return select(PlaylistBestScore)
if stats.last_update is None or stats.last_update.replace(tzinfo=UTC).date() != now.date(): .where(
if total_score_count < 10 or ceil(i + 1 / total_score_count) <= 0.1: PlaylistBestScore.room_id == room.id,
stats.top_10p_placements += 1 PlaylistBestScore.playlist_id == 0,
if total_score_count < 2 or ceil(i + 1 / total_score_count) <= 0.5: col(PlaylistBestScore.score).has(col(Score.passed).is_(True)),
stats.top_50p_placements += 1 )
s.append(s) .order_by(col(PlaylistBestScore.total_score).desc())
participated_users.append(score.user_id) )
stats.last_update = now ).all()
await session.commit() total_score_count = len(scores)
del s s = []
for i, score in enumerate(scores):
stats = await session.get(DailyChallengeStats, score.user_id)
if stats is None: # not execute
continue
if stats.last_update is None or stats.last_update.replace(tzinfo=UTC).date() != now.date():
if total_score_count < 10 or ceil(i + 1 / total_score_count) <= 0.1:
stats.top_10p_placements += 1
if total_score_count < 2 or ceil(i + 1 / total_score_count) <= 0.5:
stats.top_50p_placements += 1
s.append(s)
participated_users.append(score.user_id)
stats.last_update = now
await session.commit()
del s
user_ids = (await session.exec(select(User.id).where(col(User.id).not_in(participated_users)))).all() user_ids = (await session.exec(select(User.id).where(col(User.id).not_in(participated_users)))).all()
for id in user_ids: for id in user_ids:
stats = await session.get(DailyChallengeStats, id) stats = await session.get(DailyChallengeStats, id)
if stats is None: # not execute if stats is None: # not execute
return continue
stats.daily_streak_current = 0 stats.daily_streak_current = 0
if stats.last_weekly_streak and not are_same_weeks( if stats.last_weekly_streak and not are_same_weeks(
stats.last_weekly_streak.replace(tzinfo=UTC), now - timedelta(days=7) stats.last_weekly_streak.replace(tzinfo=UTC), now - timedelta(days=7)