SquadsActivityMonitor/model/postgres_sql_requests.py

schema_create = """create table if not exists squads_stats_states (
action_id integer,
leaderboard_type text,
platform text,
squadron_id integer,
score bigint,
percentile integer,
rank integer,
name text,
tag text,
timestamp timestamp default timezone('utc', now()));

create index if not exists idx_action_id_0 on squads_stats_states (action_id);
create index if not exists idx_platform_leaderboard_type_1 on squads_stats_states(platform, leaderboard_type);
create index if not exists idx_timestamp_0 on squads_stats_states(timestamp);
"""

select_last_action_id = """select action_id 
from squads_stats_states
order by action_id desc
limit 1;"""

insert_leader_board = """insert into squads_stats_states (action_id, leaderboard_type, platform, squadron_id, score, 
percentile, rank, name, tag) 
values 
(%(action_id)s, %(LB_type)s, %(platform)s, %(squadron)s, %(score)s, %(percentile)s, %(rank)s, %(name)s, %(tag)s);"""

select_activity_pretty_names = """select 
sum_score::bigint as "sum_score", 
to_char(timestamp, 'YYYY-MM-DD HH24:MI:SS') as "timestamp",
action_id::bigint as "action_id", 
sum_score_old::bigint as "sum_score_old", 
(sum_score - sum_score_old)::bigint as "diff" 
from 
    (
        select 
            sum_score, 
            min(timestamp) as timestamp, 
            action_id, 
            lag (sum_score, 1) over (order by action_id) sum_score_old
        from (
                select sum(score) as sum_score, min(timestamp) as timestamp, action_id 
                from squads_stats_states 
                where 
                    leaderboard_type = %(LB_type)s and 
                    platform = %(platform)s and
                    %(high_timestamp)s::timestamp >=  timestamp and 
                    timestamp >= %(low_timestamp)s::timestamp 
                group by action_id
             ) as foo
    group by sum_score, action_id 
    order by timestamp desc 
    
    ) as foo1
where (sum_score - sum_score_old) <> 0 
limit %(limit)s;"""

select_diff_by_action_id = """select 
    coalesce(new_stats.name, old_stats.name) as "squadron_name",
    coalesce(new_stats.tag, old_stats.tag) as "tag", 
    coalesce(new_stats.score, 0) as "total_experience", 
    coalesce(old_stats.score, 0) as "total_experience_old", 
    coalesce(new_stats.score, 0) - coalesce(old_stats.score, 0) as "total_experience_diff", 
    coalesce(new_stats.leaderboard_type, old_stats.leaderboard_type) as "leaderboard_type", 
    coalesce(new_stats.platform, old_stats.platform) as "platform"
from (
    select * 
    from squads_stats_states 
    where action_id = %(action_id)s) new_stats 
full join 
    (
        select * 
        from squads_stats_states 
        where action_id in (
                            select distinct squads_stats_states.action_id 
                            from squads_stats_states, (
                                                        select timestamp, platform, leaderboard_type, action_id 
                                                        from squads_stats_states 
                                                        where action_id = %(action_id)s limit 1) sub1 
                            where 
                                squads_stats_states.platform = sub1.platform and 
                                squads_stats_states.leaderboard_type = sub1.leaderboard_type and 
                                squads_stats_states.action_id < sub1.action_id 
                            order by squads_stats_states.action_id desc 
                            limit 1)) old_stats 
on new_stats.squadron_id = old_stats.squadron_id 
where coalesce(new_stats.score, 0) - coalesce(old_stats.score, 0) <> 0
order by coalesce(new_stats.score, 0) - coalesce(old_stats.score, 0) desc;"""

select_leaderboard_sum_history = """select 
    sum(score)::bigint as "Score Sum", 
    to_char(max(timestamp), 'YYYY-MM-DD HH24:MI:SS') as "Timestamp UTC"
from squads_stats_states 
where leaderboard_type = %(LB_type)s and platform = %(platform)s 
group by action_id 
order by "Timestamp UTC" desc
limit 1000;
"""

select_leaderboard_by_action_id = """select
    name as squadron_name,
    tag,
    rank,
    score,
    to_char(timestamp, 'YYYY-MM-DD HH24:MI:SS') as timestamp,
    leaderboard_type,
    platform,
    squadron_id
from squads_stats_states
where action_id = %(action_id)s
order by score desc;
"""

select_latest_leaderboard = """select 
    name as squadron_name,
    tag,
    rank,
    score,
    to_char(timestamp, 'YYYY-MM-DD HH24:MI:SS') as timestamp,
    leaderboard_type,
    platform,
    squadron_id
from squads_stats_states 
where action_id = (
                    select max(action_id) as action_id 
                    from squads_stats_states 
                    where leaderboard_type = %(LB_type)s and platform = %(platform)s)
order by score desc;
"""