o G$Gi@s<ddlmZddlZddlmZedZGdddZdS)) annotationsN)Optionalzagents.analyzerc@s&eZdZdZd d ddZd dd Zd S) AnalyzerAgentu Считает силу команд (attack/defense) по последним N завершённым матчам. Под твою схему matches: - home_team, away_team - home_score, away_score - kickoff_ts - status windowintcCs||_||_dS)N)dbr)selfrrr ?/var/www/www-root/data/www/77.83.87.30/agents/analyzer_agent.py__init__s zAnalyzerAgent.__init__returnc sd}d|jd|jd}|j|t|IdH}|s#tddSd}|D]C}|d}|d dur9t|d nd }|d durGt|d nd }td t|d } td t|d } |j d||| | IdH|d7}q't d||j|S)uz Возвращает количество команд, по которым обновили team_stats. )finishedFTAETFT_PENendedFinishedFINISHEDa' WITH team_games AS ( SELECT home_team AS team, home_score::float AS goals_for, away_score::float AS goals_against, kickoff_ts AS ts FROM matches WHERE status = ANY($1) AND home_score IS NOT NULL AND away_score IS NOT NULL AND kickoff_ts IS NOT NULL UNION ALL SELECT away_team AS team, away_score::float AS goals_for, home_score::float AS goals_against, kickoff_ts AS ts FROM matches WHERE status = ANY($1) AND home_score IS NOT NULL AND away_score IS NOT NULL AND kickoff_ts IS NOT NULL ), ranked AS ( SELECT team, goals_for, goals_against, ts, ROW_NUMBER() OVER (PARTITION BY team ORDER BY ts DESC) AS rn FROM team_games ), weighted AS ( SELECT team, goals_for, goals_against, CASE WHEN rn <= 5 THEN 1.5 WHEN rn <= 15 THEN 1.0 WHEN rn <= zn THEN 0.6 ELSE 0 END AS w FROM ranked WHERE rn <= a& ) SELECT team, (SUM(goals_for * w) / NULLIF(SUM(w), 0))::float AS gf, (SUM(goals_against * w) / NULLIF(SUM(w), 0))::float AS ga, COUNT(*)::int AS n FROM weighted GROUP BY team HAVING COUNT(*) >= 2 NzAteam_strengths: no rows computed (maybe no finished matches yet).rteamgfggagffffff?g @aN INSERT INTO team_stats(team_id, team_name, attack, defense) VALUES ($1, $2, $3, $4) ON CONFLICT (team_id) DO UPDATE SET attack = EXCLUDED.attack, defense = EXCLUDED.defense, updated_at = now() z,team_strengths: updated=%d teams (window=%d)) rr fetch_alllistlogwarningfloatmaxminexecuteinfo) r finished_statusesqueryrowsupdatedrrrrattackdefenser r r recompute_team_strengthss2+/;  z&AnalyzerAgent.recompute_team_strengthsN)r)rr)r r)__name__ __module__ __qualname____doc__r r)r r r r r s r) __future__rloggingtypingr getLoggerrrr r r r s