Upload 67 files

app/routes/auth.py

@@ -8,7 +8,8 @@ from app.auth import get_current_admin, get_current_user, sign_in_admin, sign_in
 from app.database import get_db
 from app.models import Admin, Group, User
 from app.security import hash_password, verify_password
-from app.services.presence import should_write_presence, unix_seconds
+from app.services.presence import is_online, should_write_presence, unix_seconds
+from app.services.review_queue import rebalance_pending_reviews
 from app.web import add_flash, local_now, redirect, render
 
 
@@ -173,6 +174,7 @@ def presence_ping(request: Request, db: Session = Depends(get_db)):
 
     now = local_now()
     wrote = False
+    admin_was_online = bool(admin and is_online(admin.last_seen_at, now))
     if should_write_presence(request.session, now):
         if admin:
             admin.last_seen_at = now
@@ -183,6 +185,11 @@ def presence_ping(request: Request, db: Session = Depends(get_db)):
         db.commit()
         wrote = True
 
+        # Only rebalance on an offline -> online transition. Fresh uploads are handled
+        # at submit time, so this keeps the 5s heartbeat lightweight.
+        if admin and not admin_was_online:
+            rebalance_pending_reviews(db)
+
     return JSONResponse(
         {
             "ok": True,
@@ -192,3 +199,5 @@ def presence_ping(request: Request, db: Session = Depends(get_db)):
         headers={"Cache-Control": "no-store"},
     )
 
+
+

app/routes/user.py

@@ -17,7 +17,8 @@ from app.services.group_progress import (
     pick_primary_submission,
 )
 from app.services.images import compress_to_limit, persist_submission_image, read_and_validate_upload
-from app.services.leaderboard import build_leaderboard
+from app.services.leaderboard import build_leaderboard
+from app.services.review_queue import rebalance_pending_reviews
 from app.web import add_flash, local_now, redirect, render
 
 
@@ -200,6 +201,9 @@ async def submit_task(
     submission.created_at = now
     db.commit()
 
+    # If admins are already online, dispatch the queued review immediately.
+    rebalance_pending_reviews(db)
+
     add_flash(request, "success", "小组图片已提交，等待管理员审核。")
     return redirect(f"/activities/{activity_id}")
 
@@ -288,3 +292,4 @@ def activity_status(activity_id: int, request: Request, db: Session = Depends(ge
 
 
 
+

app/services/review_queue.py

@@ -32,6 +32,16 @@ def rebalance_pending_reviews(db: Session, activity_id: int | None = None) -> li
     pending_submissions = pending_query.all()
     admins = online_admins(db)
     if not admins:
+        changed = False
+        for submission in pending_submissions:
+            if submission.assigned_admin_id is None and submission.assigned_at is None:
+                continue
+            submission.assigned_admin_id = None
+            submission.assigned_at = None
+            changed = True
+        if changed:
+            db.commit()
+            pending_submissions = pending_query.all()
         return pending_submissions
 
     now = local_now()
@@ -69,3 +79,4 @@ def rebalance_pending_reviews(db: Session, activity_id: int | None = None) -> li
         db.commit()
         pending_submissions = pending_query.all()
     return pending_submissions
+