feat: adjust mvp function to new DB
This commit is contained in:
parent
c42231907d
commit
1067b12be8
10
analysis.py
10
analysis.py
@ -1,4 +1,3 @@
|
|||||||
from datetime import datetime
|
|
||||||
import io
|
import io
|
||||||
import base64
|
import base64
|
||||||
from fastapi import APIRouter
|
from fastapi import APIRouter
|
||||||
@ -203,17 +202,16 @@ async def render_sociogram(params: Params):
|
|||||||
def mvp():
|
def mvp():
|
||||||
ranks = dict()
|
ranks = dict()
|
||||||
with Session(engine) as session:
|
with Session(engine) as session:
|
||||||
|
players = {p.id: p.display_name for p in session.exec(select(P)).fetchall()}
|
||||||
subquery = (
|
subquery = (
|
||||||
select(R.user, func.max(R.time).label("latest"))
|
select(R.user, func.max(R.time).label("latest")).group_by(R.user).subquery()
|
||||||
.where(R.time > datetime(2025, 2, 8))
|
|
||||||
.group_by(R.user)
|
|
||||||
.subquery()
|
|
||||||
)
|
)
|
||||||
statement2 = select(R).join(
|
statement2 = select(R).join(
|
||||||
subquery, (R.user == subquery.c.user) & (R.time == subquery.c.latest)
|
subquery, (R.user == subquery.c.user) & (R.time == subquery.c.latest)
|
||||||
)
|
)
|
||||||
for r in session.exec(statement2):
|
for r in session.exec(statement2):
|
||||||
for i, p in enumerate(r.mvps):
|
for i, p_id in enumerate(r.mvps):
|
||||||
|
p = players[p_id]
|
||||||
ranks[p] = ranks.get(p, []) + [i + 1]
|
ranks[p] = ranks.get(p, []) + [i + 1]
|
||||||
return [
|
return [
|
||||||
{
|
{
|
||||||
|
Loading…
x
Reference in New Issue
Block a user