projects-jenz/stoat_admin_activity_ze/python/main_ze_player_activity.py

#!/home/nonroot/stoat_admin_activity_ze/venv/bin/python3
from settings import get_connection_unloze_playtime, stoat_token, stoat_url_top_15_ze, api_key
import requests
from datetime import datetime
import sys

unloze_user_upgrade_api = f"https://unloze.com/api/private_user_upgrade_api.php?api_key={api_key}&steam_id="

def check_if_new_weekly_session():
    with get_connection_unloze_playtime() as conn:
        with conn.cursor() as cur:
            sql_statement = f"""
                select 1 from unloze_playtimestats.player_activity_ze limit 1
            """
            cur.execute(sql_statement)
            res = cur.fetchone()
            return res

def check_if_oldest_timestamp_older_than_week():
    with get_connection_unloze_playtime() as conn:
        with conn.cursor() as cur:
            sql_statement = f"""
                SELECT MIN(inserted_on) < CURDATE() - INTERVAL 7 DAY AS is_older_than_week, MIN(inserted_on) as oldest_timestamp
                    FROM unloze_playtimestats.player_activity_ze
            """
            cur.execute(sql_statement)
            res = cur.fetchone()
            return res

def get_top15_player_activity_ze():
    with get_connection_unloze_playtime() as conn:
        with conn.cursor() as cur:
            #excluding the autism bots
            sql_statement = f"""
                select pt.steam_id, pt.player_name, SUM(pt.ze_time) - pa.ze_time_start_week AS time_this_week
                    from unloze_playtimestats.player_activity_ze pa
                    inner join unloze_playtimestats.player_time pt 
                        on pa.steamid = pt.steam_id 
                        where pa.steamid not in ('STEAM_0:0:518094602', 'STEAM_0:0:204398871', 'STEAM_0:1:60189040', 'STEAM_0:0:610560766')
                  GROUP BY pt.steam_id, pt.player_name 
                  ORDER BY time_this_week DESC
                  limit 15
            """
            cur.execute(sql_statement)
            res = cur.fetchall()
            return res

def get_untracked_players_active_in_last_week():
    with get_connection_unloze_playtime() as conn:
        with conn.cursor() as cur:
            sql_statement = f"""
                SELECT 
                    pt.steam_id, 
                    pt.player_name, 
                    SUM(pt.ze_time) AS total_time
                FROM unloze_playtimestats.player_time pt
                WHERE pt.steam_id IN (
                    SELECT DISTINCT pt_inner.steam_id 
                    FROM unloze_playtimestats.player_time pt_inner
                        LEFT JOIN unloze_playtimestats.player_activity_ze pt1 
                            ON pt1.steamid = pt_inner.steam_id
                    WHERE pt_inner.modified_on > CURDATE() - INTERVAL 7 DAY
                      AND pt1.steamid IS NULL
                )
                GROUP BY pt.steam_id;
            """
            cur.execute(sql_statement)
            res = cur.fetchall()
            return res

def insert_untracked_players(player_timestats_to_insert):
    with get_connection_unloze_playtime() as conn:
        with conn.cursor() as cur:
            placeholders = ','.join(['(%s, %s, %s)'] * len(player_timestats_to_insert))
            flattened_values = [val for row in player_timestats_to_insert for val in row]
    
            sql_statement = f"""
                INSERT INTO unloze_playtimestats.player_activity_ze 
                    (steamid, name, ze_time_start_week) 
                    VALUES {placeholders}
            """
            cur.execute(sql_statement, flattened_values)
            conn.commit()

def send_post_message_to_stoat():
    message = f"This is the beginning of a new Weekly Session started at **{datetime.now().strftime('%Y-%m-%d %H:%M:%S')}** for Zombie Escape Players. First results come in around 30 minutes."
    headers = {
        "x-bot-token": f"{stoat_token}",
        "Content-Type": "application/json"
    }
    data = {
        "content": message
    }
    response = requests.post(stoat_url_top_15_ze, headers=headers, json=data)

def send_patch_message_to_stoat(top15_weekly_activity_ze, oldest_timestamp):
    message = f"Started Weekly Time Tracking from **{oldest_timestamp}** until **{datetime.now().strftime('%Y-%m-%d %H:%M:%S')}** for Zombie Escape Players:\n\n"
    
    for index, player in enumerate(top15_weekly_activity_ze):
        steam_id = player[0]
        name = player[1]
        time_this_week = player[2]

        hours_server = int((time_this_week / 60) / 60)
        minutes_server = int((time_this_week / 60) % 60)
        message += f"{index + 1}: {name} ({steam_id}) Playtime: {hours_server} hours and {minutes_server} minutes.\n\n"

    message += f"When one week has gone by will VIP rewards be automatically given to top15. This message is updated every 30 minutes."
    headers = {
        "x-bot-token": f"{stoat_token}",
        "Content-Type": "application/json"
    }

    data = {
        "content": message
    }

    #get most recent message that has to be edited.
    last_message_to_patch = requests.get(stoat_url_top_15_ze + "?limit=1", headers=headers)
    if last_message_to_patch.status_code > 299:
        print(last_message_to_patch.status_code, " ", last_message_to_patch.text)
        sys.exit(1)

    latest_message_id = last_message_to_patch.json()[0]['_id']

    response = requests.patch(stoat_url_top_15_ze + f"/{latest_message_id}", headers=headers, json=data)
    if response.status_code > 299:
        print(response.status_code, " ", response.text)
        sys.exit(1)

def send_final_stoat_edit(players_vip_status):
    message = "Finished Time Tracking from **{oldest_timestamp}** until **{datetime.now().strftime('%Y-%m-%d %H:%M:%S')}** for Zombie Escape Players. The final results of the week are:\n\n"
    for index, player_vip_status in enumerate(players_vip_status):
        steamid, name, hours_server, minutes_server, reward_status, days_rewarded = player_vip_status
        message += f"{index + 1}: {name} ({steam_id}) Playtime: {hours_server} hours and {minutes_server} minutes. {reward_status} Reward was {days_rewarded} days.\n\n"
    
    headers = {
        "x-bot-token": f"{stoat_token}",
        "Content-Type": "application/json"
    }

    data = {
        "content": message
    }

    #get most recent message that has to be edited.
    last_message_to_patch = requests.get(stoat_url_top_15_ze + "?limit=1", headers=headers)
    if last_message_to_patch.status_code > 299:
        print(last_message_to_patch.status_code, " ", last_message_to_patch.text)
        sys.exit(1)

    latest_message_id = last_message_to_patch.json()[0]['_id']

    response = requests.patch(stoat_url_top_15_ze + f"/{latest_message_id}", headers=headers, json=data)
    if response.status_code > 299:
        print(response.status_code, " ", response.text)
        sys.exit(1)

def truncate_player_activity_ze():
    with get_connection_unloze_playtime() as conn:
        with conn.cursor() as cur:
            sql_statement = f"""
                truncate table unloze_playtimestats.player_activity_ze
            """
            cur.execute(sql_statement)
            conn.commit()

def steamid_to_commid(steamid):
    steamid64ident = 76561197960265728
    sid_split = steamid.split(':')
    commid = int(sid_split[2]) * 2
    if sid_split[1] == '1':
      commid += 1
    commid += steamid64ident
    return commid

def give_vip_rewards(top15_weekly_activity_ze):
    players_vip_status = []
    for index, result in enumerate(top15_weekly_activity_ze):
        steamid = result[0]
        name = result[1]
        time_this_week = result[2]
        hours_server = int((time_this_week / 60) / 60)
        minutes_server = int((time_this_week / 60) % 60)

        if index < 5:
            days_rewarded = 7
        if index < 10:
            days_rewarded = 3
        if index < 15:
            days_rewarded = 1
        steam_community_id = steamid_to_commid(steamid)

        print(f'index: {index}. steamid: {steamid}. name: {name}. days_rewarded: {days_rewarded}')
        r = requests.get(f"{unloze_user_upgrade_api}{steam_community_id}&days_reward={days_rewarded}")
        if r.content.decode('utf8').startswith("NOACCOUNT"): #not registed with associated steam account
            players_vip_status.append([steamid, name, hours_server, minutes_server, "NO FORUM ACCOUNT ASSOCIATED WITH STEAM.", days_rewarded])
        else:
            players_vip_status.append([steamid, name, hours_server, minutes_server, "VIP REWARDED.", days_rewarded])
    return players_vip_status

def main():
    #if new session variable is None
    same_weekly_session = check_if_new_weekly_session()

    player_timestats_to_insert = get_untracked_players_active_in_last_week()
    if player_timestats_to_insert:
        insert_untracked_players(player_timestats_to_insert)

    if same_weekly_session:
        top15_weekly_activity_ze = get_top15_player_activity_ze()
        timestamp_older_than_week, oldest_timestamp = check_if_oldest_timestamp_older_than_week()
        send_patch_message_to_stoat(top15_weekly_activity_ze, oldest_timestamp)

        if timestamp_older_than_week:
            players_vip_status = give_vip_rewards(top15_weekly_activity_ze)
            send_final_stoat_edit(players_vip_status, oldest_timestamp)
            truncate_player_activity_ze()
    else:
        send_post_message_to_stoat()

if __name__ == '__main__':
    main()