+global\PlayerEloCalculations::up()

Complexity

Conditions	8
Paths	6

Size

Total Lines	111
Code Lines	46

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function up()
    {
        $pageCountQuery = "
            SELECT
                COUNT(*)
            FROM
                matches
            WHERE
                team_a_players IS NOT NULL AND team_a_players != '' AND
                team_b_players IS NOT NULL AND team_b_players != '' AND 
                match_type = 'official' AND status = 'entered'
        ";
        $matchesQuery = "
            SELECT
                *
            FROM
                matches
            WHERE
                team_a_players IS NOT NULL AND team_a_players != '' AND
                team_b_players IS NOT NULL AND team_b_players != '' AND 
                match_type = 'official' AND status = 'entered' AND
                id > {id}
            ORDER BY
                `timestamp`
            LIMIT 1000
        ";

        $pageCount = ceil($this->fetchRow($pageCountQuery)[0] / 1000);
        $lastSeason = [];
        $lastID = 0;

        for ($i = 1; $i <= $pageCount; $i++) {
            $matches = $this->fetchAll(strtr($matchesQuery, [
                '{id}' => $lastID,
            ]));

            foreach ($matches as $match) {
                $timestamp = new \DateTime($match['timestamp']);
                $seasonInfo = [
                    'season' => $this->literalSeasonFromMonth($timestamp->format('n')),
                    'year' => (int)$timestamp->format('Y'),
                ];

                // Clear the model cache every season since Elos are cached internally
                if ($seasonInfo != $lastSeason) {
                    $lastSeason = $seasonInfo;
                }

                $teamA = explode(',', $match['team_a_players']);
                $teamB = explode(',', $match['team_b_players']);

                if (empty($teamA) || empty($teamB)) {
                    continue;
                }

                $getElo = function($n) use ($seasonInfo) {
                    $query = "
                        SELECT
                            elo_new
                        FROM
                            player_elo
                        WHERE
                            user_id = $n AND 
                            season_period = '{$seasonInfo['season']}' AND
                            season_year = {$seasonInfo['year']}
                        ORDER BY
                            match_id DESC
                        LIMIT 1
                    ";

                    $result = $this->fetchRow($query);

                    if (empty($result)) {
                        return 1200;
                    }

                    return $result[0];
                };

                $teamA_Avg = array_sum(array_map($getElo, $teamA)) / count($teamA);
                $teamB_Avg = array_sum(array_map($getElo, $teamB)) / count($teamB);

                $diff = self::calculateEloDiff(
                    $teamA_Avg, $teamB_Avg, $match['team_a_points'], $match['team_b_points'], $match['duration']
                );

                // We need to disable transactions so our Player::adjustElo() fxn won't hold up execution
                $this->getAdapter()->commitTransaction();

                $this->query("UPDATE matches SET player_elo_diff = {$diff} WHERE id = {$match['id']} LIMIT 1;");

                $walkFxn = function ($v, $k, $positive) use ($diff, $match, $seasonInfo, $getElo) {
                    $eloDiff = ($positive) ? $diff : -$diff;
                    $prevElo = $getElo($v);
                    $newElo = $prevElo + $eloDiff;
                    $query = "
                        INSERT INTO player_elo VALUES ($v, {$match['id']}, '{$seasonInfo['season']}', {$seasonInfo['year']}, $prevElo, $newElo)
                    ";

                    $this->execute($query);
                };

                array_walk($teamA, $walkFxn, true);
                array_walk($teamB, $walkFxn, false);

                $this->getAdapter()->beginTransaction();

                $lastSeason = $match['id'];
            }
        }
    }