QueryManagerPostgresqlMonocleAlternate::getGymData() - Code Metrics - Inspection of "Improve Nests page" - brusselopole/Worldopole - Measure and Improve Code Quality continuously with Scrutinizer

Failed Conditions

Pull Request — master (#363)

by Florian

created 2018-02-22 19:22 UTC

getGymData() A

↳ Parent: QueryManagerPostgresqlMonocleAlternate

Complexity

Conditions	1
Paths	1

Size

Total Lines	10
Code Lines	6

Duplication

Lines	10
Ratio	100 %

Importance

Changes

Metric	Value
cc	1
eloc	6
nc	1
nop	1
dl	10
loc	10
rs	9.4285
c	0
b	0
f	0

<?php
/**
 * Created by PhpStorm.
 * User: floriankostenzer
 * Date: 27.01.18
 * Time: 02:26
 */

class QueryManagerPostgresqlMonocleAlternate extends QueryManagerPostgresql {
namespace YourVendor;

class YourClass { }

	public function __construct() {
		parent::__construct();
	}

	public function __destruct() {
		parent::__destruct();
	}

	///////////
	// Tester
	///////////

	function testTotalPokemon() {

		$req = "SELECT COUNT(*) as total FROM sightings";
		$result = pg_query($this->db, $req);
		if ($result === false) {
			return 1;
		} else {
			$data = pg_fetch_object($result);
			$total = $data->total;

			if ($total == 0) {
				return 2;
			}
		}
		return 0;
	}

	function testTotalGyms() {

		$req = "SELECT COUNT(*) as total FROM forts";
		$result = pg_query($this->db, $req);
		if ($result === false) {
			return 1;
		} else {
			$data = pg_fetch_object($result);
			$total = $data->total;

			if ($total == 0) {
				return 2;
			}
		}
		return 0;
	}

	function testTotalPokestops() {

		$req = "SELECT COUNT(*) as total FROM pokestops";
		$result = pg_query($this->db, $req);
		if ($result === false) {
			return 1;
		} else {
			$data = pg_fetch_object($result);
			$total = $data->total;

			if ($total == 0) {
				return 2;
			}
		}
		return 0;
	}


	/////////////
	// Homepage
	/////////////

	function getTotalPokemon() {

		$req = "SELECT COUNT(*) AS total FROM sightings WHERE expire_timestamp >= EXTRACT(EPOCH FROM NOW())";
		$result = pg_query($this->db, $req);
		$data = pg_fetch_object($result);
		return $data;
	}

	function getTotalLures() {

		$data = (object) array("total" => 0);
		return $data;
	}

	function getTotalGyms() {

		$req = "SELECT COUNT(*) AS total FROM forts";
		$result = pg_query($this->db, $req);
		$data = pg_fetch_object($result);
		return $data;
	}

	function getTotalRaids() {

		$req = "SELECT COUNT(*) AS total FROM raids WHERE time_battle <= EXTRACT(EPOCH FROM NOW()) AND time_end >= EXTRACT(EPOCH FROM NOW())";
		$result = pg_query($this->db, $req);
		$data = pg_fetch_object($result);
		return $data;
	}


	function getTotalGymsForTeam($team_id) {

		$req = "SELECT COUNT(*) AS total 
					FROM forts f
					LEFT JOIN fort_sightings fs ON (fs.fort_id = f.id AND fs.last_modified = (SELECT MAX(last_modified) FROM fort_sightings fs2 WHERE fs2.fort_id=f.id))
					WHERE team = '$team_id'";
		$result = pg_query($this->db, $req);
		$data = pg_fetch_object($result);
		return $data;
	}

	function getRecentAll() {

		$req = "SELECT pokemon_id, encounter_id, TO_TIMESTAMP(expire_timestamp) AS disappear_time, TO_TIMESTAMP(updated) AS last_modified, TO_TIMESTAMP(expire_timestamp) AS disappear_time_real,
              lat AS latitude, lon AS longitude, cp, atk_iv AS individual_attack, def_iv AS individual_defense, sta_iv AS individual_stamina
              FROM sightings
              ORDER BY updated DESC
              LIMIT 12 OFFSET 0";
		$result = pg_query($this->db, $req);
		$data = array();
		if ($result->num_rows > 0) {
			while ($row = pg_fetch_object($result)) {
				$data[] = $row;
			}
		}
		return $data;
	}

	function getRecentMythic($mythic_pokemon) {

		$req = "SELECT pokemon_id, encounter_id, TO_TIMESTAMP(expire_timestamp) AS disappear_time, TO_TIMESTAMP(updated) AS last_modified, TO_TIMESTAMP(expire_timestamp) AS disappear_time_real,
                lat AS latitude, lon AS longitude, cp, atk_iv AS individual_attack, def_iv AS individual_defense, sta_iv AS individual_stamina
                FROM sightings
                WHERE pokemon_id IN (".implode(",", $mythic_pokemon).")
                ORDER BY updated DESC
                LIMIT 12 OFFSET 0";
		$result = pg_query($this->db, $req);
		$data = array();
		if ($result->num_rows > 0) {
			while ($row = pg_fetch_object($result)) {
				$data[] = $row;
			}
		}
		return $data;
	}

	///////////////////
	// Single Pokemon
	///////////////////

	function getGymsProtectedByPokemon($pokemon_id) {

		$req = "SELECT COUNT(f.id) AS total 
					FROM forts f
					LEFT JOIN fort_sightings fs ON (fs.fort_id = f.id AND fs.last_modified = (SELECT MAX(last_modified) FROM fort_sightings fs2 WHERE fs2.fort_id=f.id))
					WHERE guard_pokemon_id = '".$pokemon_id."'";
		$result = pg_query($this->db, $req);
		$data = pg_fetch_object($result);
		return $data;
	}

	function getPokemonLastSeen($pokemon_id) {

		$req = "SELECT TO_TIMESTAMP(expire_timestamp) AS expire_timestamp, TO_TIMESTAMP(expire_timestamp) AS disappear_time_real, lat AS latitude, lon AS longitude
                FROM sightings
                WHERE pokemon_id = '".$pokemon_id."'
                ORDER BY expire_timestamp DESC
                LIMIT 1 OFFSET 0";
		$result = pg_query($this->db, $req);
		$data = pg_fetch_object($result);
		return $data;
	}

	function getTop50Pokemon($pokemon_id, $top_order_by, $top_direction) {

		$req = "SELECT expire_timestamp, TO_TIMESTAMP(expire_timestamp) AS distime, pokemon_id as pokemon_id, TO_TIMESTAMP(expire_timestamp) as disappear_time, lat as latitude, lon as longitude,
                cp, atk_iv as individual_attack, def_iv as individual_defense, sta_iv as individual_stamina,
                ROUND(100*(atk_iv+def_iv+sta_iv)/45,1) AS \"IV\", move_1 as move_1, move_2, form
                FROM sightings
	            WHERE pokemon_id = '" . $pokemon_id . "' AND move_1 IS NOT NULL AND move_1 <> '0'
	            ORDER BY $top_order_by $top_direction, expire_timestamp DESC
	            LIMIT 50 OFFSET 0";
		$result = pg_query($this->db, $req);
		$top = array();
		while ($data = pg_fetch_object($result)) {
			$top[] = $data;
		}
		return $top;
	}

	function getTop50Trainers($pokemon_id, $best_order_by, $best_direction) {

		$trainer_blacklist = "";
		if (!empty(self::$config->system->trainer_blacklist)) {
			$trainer_blacklist = " AND owner_name NOT IN ('" . implode("','", self::$config->system->trainer_blacklist) . "')";
		}

		$req = "SELECT owner_name as trainer_name, ROUND((100.0*((atk_iv)+(def_iv)+(sta_iv))/45),1) AS \"IV\", move_1, move_2, cp as cp,
                TO_TIMESTAMP(last_modified) AS lasttime, last_modified as last_seen
                FROM gym_defenders
				WHERE pokemon_id = '" . $pokemon_id . "'" . $trainer_blacklist . "
				ORDER BY $best_order_by $best_direction, owner_name ASC
				LIMIT 50 OFFSET 0";

		$result = pg_query($this->db, $req);
		$toptrainer = array();
		while ($data = pg_fetch_object($result)) {
			$toptrainer[] = $data;
		}
		return $toptrainer;
	}

	public function getPokemonHeatmap($pokemon_id, $start, $end) {
		$where = " WHERE pokemon_id = ".$pokemon_id." "
			. "AND TO_TIMESTAMP(expire_timestamp) BETWEEN '".$start."' AND '".$end."'";
		$req 		= "SELECT lat AS latitude, lon AS longitude FROM sightings".$where." ORDER BY expire_timestamp DESC LIMIT 100000";
		$result = pg_query($this->db, $req);
		$points = array();
		while ($data = pg_fetch_object($result)) {
			$points[] = $data;
		}
		return $points;
	}

	public function getPokemonGraph($pokemon_id) {
		$req = "SELECT COUNT(*) AS total, EXTRACT(HOUR FROM disappear_time) AS disappear_hour
					FROM (SELECT TO_TIMESTAMP(expire_timestamp) as disappear_time FROM sightings WHERE pokemon_id = '".$pokemon_id."' ORDER BY disappear_time LIMIT 100000) AS pokemonFiltered
				GROUP BY disappear_hour
				ORDER BY disappear_hour";
		$result = pg_query($this->db, $req);
		$array = array_fill(0, 24, 0);
		while ($result && $data = pg_fetch_object($result)) {
			$array[$data->disappear_hour] = $data->total;
		}
		// shift array because AM/PM starts at 1AM not 0:00
		$array[] = $array[0];
		array_shift($array);
		return $array;
	}

	public function getPokemonLive($pokemon_id, $ivMin, $ivMax, $inmap_pokemons) {
		$inmap_pkms_filter = "";
		$where = " WHERE expire_timestamp >= EXTRACT(EPOCH FROM NOW()) AND pokemon_id = " . $pokemon_id;

		$reqTestIv = "SELECT MAX(atk_iv) AS iv FROM sightings " . $where;
		$resultTestIv = pg_query($this->db, $reqTestIv);
		$testIv = pg_fetch_object($resultTestIv);
		if (!is_null($inmap_pokemons) && ($inmap_pokemons != "")) {
			foreach ($inmap_pokemons as $inmap) {
				$inmap_pkms_filter .= "'".$inmap."',";
			}
			$inmap_pkms_filter = rtrim($inmap_pkms_filter, ",");
			$where .= " AND encounter_id NOT IN (" . $inmap_pkms_filter . ") ";
		}
		if ($testIv->iv != null && !is_null($ivMin) && ($ivMin != "")) {
			$where .= " AND ((100/45)*(atk_iv + def_iv + sta_iv)) >= (" . $ivMin . ") ";
		}
		if ($testIv->iv != null && !is_null($ivMax) && ($ivMax != "")) {
			$where .= " AND ((100/45)*(atk_iv + def_iv + sta_iv)) <= (" . $ivMax . ") ";
		}
		$req = "SELECT pokemon_id, lat AS latitude, lon AS longitude,
    					TO_TIMESTAMP(expire_timestamp) AS disappear_time,
    					TO_TIMESTAMP(expire_timestamp) AS disappear_time_real,
    					atk_iv AS individual_attack, def_iv AS individual_defense, sta_iv AS individual_stamina,
   						move_1, move_2
					FROM sightings " . $where . "
					ORDER BY disappear_time DESC
					LIMIT 5000";
		$result = pg_query($this->db, $req);
		$spawns = array();
		while ($data = pg_fetch_object($result)) {
			$spawns[] = $data;
		}
		return $spawns;
	}

	public function getPokemonSliderMinMax() {

		$req = "SELECT TO_TIMESTAMP(MIN(expire_timestamp)) AS min, TO_TIMESTAMP(MAX(expire_timestamp)) AS max FROM sightings";
		$result = pg_query($this->db, $req);
		$data = pg_fetch_object($result);
		return $data;
	}

	public function getMapsCoords() {

		$req = "SELECT MAX(lat) AS max_latitude, MIN(lat) AS min_latitude, MAX(lon) AS max_longitude, MIN(lon) as min_longitude FROM spawnpoints";
		$result = pg_query($this->db, $req);
		$data = pg_fetch_object($result);
		return $data;
	}


	///////////////
	// Pokestops
	//////////////


	function getTotalPokestops() {

		$req = "SELECT COUNT(*) as total FROM pokestops";
		$result = pg_query($this->db, $req);
		$data = pg_fetch_object($result);
		return $data;
	}

	public function getAllPokestops() {
		$req = "SELECT lat as latitude, lon as longitude, null AS lure_expiration, EXTRACT(EPOCH FROM NOW()) AS now, null AS lure_expiration_real FROM pokestops";
		$result = pg_query($this->db, $req);
		$pokestops = array();
		while ($data = pg_fetch_object($result)) {
			$pokestops[] = $data;
		}
		return $pokestops;
	}


	/////////
	// Gyms
	/////////

	function getTeamGuardians($team_id) {

		$req = "SELECT COUNT(*) AS total, guard_pokemon_id 
					FROM forts f
					LEFT JOIN fort_sightings fs ON (fs.fort_id = f.id AND fs.last_modified = (SELECT MAX(last_modified) FROM fort_sightings fs2 WHERE fs2.fort_id=f.id))
					WHERE team = '".$team_id."' GROUP BY guard_pokemon_id ORDER BY total DESC LIMIT 3 OFFSET 0";
		$result = pg_query($this->db, $req);

		$datas = array();
		while ($data = pg_fetch_object($result)) {
			$datas[] = $data;
		}

		return $datas;
	}

	function getOwnedAndPoints($team_id) {

		$req = "SELECT COUNT(f.id) AS total, ROUND(AVG(fs.total_cp))AS average_points
        			FROM forts f
					LEFT JOIN fort_sightings fs ON (fs.fort_id = f.id AND fs.last_modified = (SELECT MAX(last_modified) FROM fort_sightings fs2 WHERE fs2.fort_id=f.id))
        			WHERE fs.team = '" . $team_id . "'";
		$result = pg_query($this->db, $req);
		$data = pg_fetch_object($result);
		return $data;
	}

	function getAllGyms() {

		$req = "SELECT f.id as gym_id, team as team_id, f.lat as latitude, f.lon as longitude, updated as last_scanned, (6 - fs.slots_available) AS level 
					FROM forts f
					LEFT JOIN fort_sightings fs ON (fs.fort_id = f.id AND fs.last_modified = (SELECT MAX(last_modified) FROM fort_sightings fs2 WHERE fs2.fort_id=f.id))";
		$result = pg_query($this->db, $req);
		$gyms = array();
		while ($data = pg_fetch_object($result)) {
			$gyms[] = $data;
		}
		return $gyms;
	}

	public function getGymData($gym_id) {

		$req = "SELECT f.name AS name, null AS description, f.url AS url, fs.team AS team, TO_TIMESTAMP(fs.updated) AS last_scanned, fs.guard_pokemon_id AS guard_pokemon_id, (6 - fs.slots_available) AS level, fs.total_cp	
			FROM forts f
			LEFT JOIN fort_sightings fs ON (fs.fort_id = f.id AND fs.last_modified = (SELECT MAX(last_modified) FROM fort_sightings fs2 WHERE fs2.fort_id=f.id))
			WHERE f.id ='".$gym_id."'
			GROUP BY f.name, f.url, fs.team, fs.updated, fs.guard_pokemon_id, fs.slots_available, gd.cp";
		$result = pg_query($this->db, $req);
		$data = pg_fetch_object($result);
		return $data;
	}

	public function getGymDefenders($gym_id) {
		$req = "SELECT external_id as pokemon_uid, pokemon_id, atk_iv as iv_attack, def_iv as iv_defense, sta_iv as iv_stamina, cp, fort_id as gym_id
			FROM gym_defenders 
			WHERE fort_id='".$gym_id."'
			ORDER BY deployment_time";
		$result = pg_query($this->db, $req);
		$defenders = array();
		while ($data = pg_fetch_object($result)) {
			$defenders[] = $data;
		}
		return $defenders;
	}



	////////////////
	// Gym History
	////////////////

	public function getGymHistories($gym_name, $team, $page, $ranking)

	{
		$where = "";
		if (isset($gym_name) && $gym_name != '') {
			$where = " WHERE name LIKE '%".$gym_name."%'";
		}
		if (isset($team) && $team != '') {
			$where .= ($where === "" ? " WHERE" : " AND")." fs.team = ".$team;
		}
		switch ($ranking) {
			case 1:
				$order = " ORDER BY name, last_modified DESC";
				break;
			case 2:
				$order = " ORDER BY total_cp DESC, last_modified DESC";
				break;
			default:
				$order = " ORDER BY last_modified DESC, name";
		}

		$limit = " LIMIT 10 OFFSET ".($page * 10);

		$req = "SELECT f.id as gym_id, fs.total_cp, f.name, fs.team as team_id, (6 - slots_available) as pokemon_count, TO_TIMESTAMP(last_modified) AS last_modified 
			FROM forts f
			LEFT JOIN fort_sightings fs ON (fs.fort_id = f.id AND fs.last_modified = (SELECT MAX(last_modified) FROM fort_sightings fs2 WHERE fs2.fort_id=f.id))
			".$where.$order.$limit;

		$result = $this->mysqli->query($req);
class MyClass { }

$x = new MyClass();
$x->foo = true;
		$gym_history = array();
		while ($data = $result->fetch_object()) {
			$gym_history[] = $data;
		}
		return $gym_history;
	}

	public function getGymHistoriesPokemon($gym_id)
	{
		$req = "SELECT external_id AS pokemon_uid, pokemon_id, cp_now as cp, owner_name AS trainer_name
					FROM gym_defenders
					WHERE fort_id = '". $gym_id ."'
					ORDER BY deployment_time";
		$result = $this->mysqli->query($req);
		$pokemons = array();
		while ($data = $result->fetch_object()) {
			$pokemons[] = $data;
		}
		return $pokemons;
	}

	public function getHistoryForGym($page, $gym_id)

	{
		if (isset(self::$config->system->gymhistory_hide_cp_changes) && self::$config->system->gymhistory_hide_cp_changes === true) {
			$pageSize = 25;
		} else {
			$pageSize = 10;
		}
		$req = "SELECT f.id as gym_id, fs.team as team_id, total_cp, TO_TIMESTAMP(fs.last_modified) as last_modified, last_modified as last_modified_real
					FROM fort_sightings fs
					LEFT JOIN forts f ON f.id = fs.fort_id
					WHERE f.id = '". $gym_id ."'
					ORDER BY fs.last_modified DESC
					LIMIT ".($pageSize+1)." OFFSET ".($page * $pageSize);
		$result = $this->mysqli->query($req);
		$history = array();
		$count = 0;
		while ($data = $result->fetch_object()) {
			$count++;
			if ($data->total_cp == 0) {
				$data->pokemon = array();
				$data->pokemon_count = 0;
				$data->pokemon_uids = "";
			} else {
				$data->pokemon = $this->getHistoryForGymPokemon($gym_id, $data->last_modified_real);
				$data->pokemon_count = count($data->pokemon);
				$data->pokemon_uids = implode(",", array_keys($data->pokemon));
			}
			if ($data->total_cp === 0 || $data->pokemon_count !== 0) {
				$history[] = $data;
			}
		}
		if ($count !== ($pageSize + 1)) {
			$last_page = true;
		} else {
			$last_page = false;
		}
		return array("last_page" => $last_page, "data" => $history);
	}

	private function getHistoryForGymPokemon($gym_id, $last_modified)

	{
		$req = "SELECT ghd.defender_id, gd.pokemon_id, ghd.cp, gd.owner_name as trainer_name
					FROM gym_history_defenders ghd
					JOIN gym_defenders gd ON ghd.defender_id = gd.external_id
					WHERE ghd.fort_id = '". $gym_id ."' AND date = '".$last_modified."'
					ORDER BY gd.deployment_time";
		$result = $this->mysqli->query($req);
		$pokemons = array();
		while ($data = $result->fetch_object()) {
			$pokemons[$data->defender_id] = $data;
		}
		return $pokemons;
	}

	///////////
	// Raids
	///////////

	public function getAllRaids($page) {

		$limit = " LIMIT 10 OFFSET ". ($page * 10);
		$req = "SELECT r.fort_id AS gym_id, r.level AS level, r.pokemon_id AS pokemon_id, r.cp AS cp, r.move_1 AS move_1, r.move_2 AS move_2, TO_TIMESTAMP(r.time_spawn) AS spawn, TO_TIMESTAMP(r.time_battle) AS start, TO_TIMESTAMP(r.time_end) AS end, TO_TIMESTAMP(fs.updated) AS last_scanned, f.name, f.lat AS latitude, f.lon as longitude 
					FROM forts f
					LEFT JOIN fort_sightings fs ON (fs.fort_id = f.id AND fs.last_modified = (SELECT MAX(last_modified) FROM fort_sightings fs2 WHERE fs2.fort_id=f.id))
				 	LEFT JOIN raids r ON (r.fort_id = f.id AND r.time_end >= UNIX_TIMESTAMP()) 
					WHERE r.time_end > EXTRACT(EPOCH FROM NOW()) 
					ORDER BY r.level DESC, r.time_battle" . $limit;
		$result = pg_query($this->db, $req);
		$raids = array();
		while ($data = pg_fetch_object($result)) {
			$raids[] = $data;
		}
		return $raids;
	}


	//////////////
	// Trainers
	//////////////

	public function getTrainers($trainer_name, $team, $page, $rankingNumber) {

		$ranking = $this->getTrainerLevelRanking();
		$where = "";
		if (!empty(self::$config->system->trainer_blacklist)) {
			$where .= " AND gd.owner_name NOT IN ('".implode("','", self::$config->system->trainer_blacklist)."')";
		}
		if ($trainer_name != "") {
			$where = " AND gd.owner_name LIKE '%".$trainer_name."%'";
		}
		if ($team != 0) {
			$where .= ($where == "" ? " HAVING" : " AND")." team = ".$team;
		}
		switch ($rankingNumber) {
			case 1:
				$order = " ORDER BY active DESC, level DESC";
				break;
			case 2:
				$order = " ORDER BY maxCp DESC, level DESC";
				break;
			default:
				$order = " ORDER BY level DESC, active DESC";
		}
		$order .= ", last_seen DESC, name ";
		$limit = " LIMIT 10 OFFSET ".($page * 10);
		$req = "SELECT gd.owner_name AS name, MAX(owner_level) AS level, MAX(cp) AS maxCp, MAX(active) AS active, MAX(team) AS team, TO_TIMESTAMP(MAX(last_modified)) as last_seen
				  	FROM gym_defenders gd
				  	LEFT JOIN (
				  		SELECT owner_name, COUNT(*) as active
				  		FROM gym_defenders gd2
						WHERE fort_id IS NOT NULL
				  		GROUP BY owner_name
				  	) active ON active.owner_name = gd.owner_name
				  	WHERE level IS NOT NULL " . $where . "
				  	GROUP BY gd.owner_name" . $order  . $limit;
		$result = $this->mysqli->query($req);
		$trainers = array();
		while ($data = $result->fetch_object()) {
			$data->last_seen = date("Y-m-d", strtotime($data->last_seen));
			if (is_null($data->active)) {
				$data->active = 0;
			}
			$trainers[$data->name] = $data;

			$pokemon = array_merge($this->getActivePokemon($data->name),  $this->getInactivePokemon($data->name));


			$trainers[$data->name]->gyms = $data->active;
			$trainers[$data->name]->pokemons = $pokemon;
			$trainers[$data->name]->rank = $ranking[$data->level];
		}
		return $trainers;
	}

	public function getTrainerLevelRanking() {

		$exclue = "";
		if (!empty(self::$config->system->trainer_blacklist)) {
			$exclue .= " AND owner_name NOT IN ('".implode("','", self::$config->system->trainer_blacklist)."')";
		}
		$req = "SELECT COUNT(*) AS count, level FROM (SELECT MAX(owner_level) as level FROM gym_defenders WHERE owner_level IS NOT NULL ".$exclue." GROUP BY owner_level, owner_name) x GROUP BY level";
		$result = $this->mysqli->query($req);
		$levelData = array();
		while ($data = $result->fetch_object()) {
			$levelData[$data->level] = $data->count;
		}
		for ($i = 5; $i <= 40; $i++) {
			if (!isset($levelData[$i])) {
				$levelData[$i] = 0;
			}
		}
		# sort array again
		ksort($levelData);
		return $levelData;
	}

	public function getActivePokemon($trainer_name) {
		$req = "SELECT pokemon_id, cp, atk_iv AS iv_attack, sta_iv AS iv_stamina, def_iv AS iv_defense, TO_TIMESTAMP(deployment_time) AS deployment_time, '1' AS active, fort_id as gym_id, FLOOR((UNIX_TIMESTAMP() - created) / 86400) AS last_scanned
						FROM gym_defenders 
						WHERE owner_name = '".$trainer_name."' AND fort_id IS NOT NULL
						ORDER BY deployment_time";
		$result = $this->mysqli->query($req);
		$pokemon = array();
		while ($data = $result->fetch_object()) {
			$pokemon[] = $data;
		}
		return $pokemon;
	}

	public function getInactivePokemon($trainer_name) {
		$req = "SELECT pokemon_id, cp, atk_iv AS iv_attack, sta_iv AS iv_stamina, def_iv AS iv_defense, NULL AS deployment_time, '0' AS active, fort_id as gym_id, FLOOR((UNIX_TIMESTAMP() - created) / 86400) AS last_scanned
					FROM gym_defenders 
					WHERE owner_name = '".$trainer_name."' AND fort_id IS NULL
					ORDER BY last_scanned";
		$result = $this->mysqli->query($req);
		$pokemon = array();
		while ($data = $result->fetch_object()) {
			$pokemon[] = $data;
		}
		return $pokemon;
	}

	public function getTrainerLevelCount($team_id) {

		$exclue = "";
		if (!empty(self::$config->system->trainer_blacklist)) {
			$exclue .= " AND owner_name NOT IN ('".implode("','", self::$config->system->trainer_blacklist)."')";
		}
		$req = "SELECT COUNT(*) AS count, level FROM (SELECT MAX(owner_level) as level FROM gym_defenders WHERE owner_level IS NOT NULL AND team = '".$team_id."' ".$exclue." GROUP BY owner_level, owner_name) x GROUP BY level";
		$result = $this->mysqli->query($req);
		$levelData = array();
		while ($data = $result->fetch_object()) {
			$levelData[$data->level] = $data->count;
		}
		for ($i = 5; $i <= 40; $i++) {
			if (!isset($levelData[$i])) {
				$levelData[$i] = 0;
			}
		}
		# sort array again
		ksort($levelData);
		return $levelData;
	}


	/////////
	// Cron
	/////////

	public function getPokemonCountsActive() {
		$req = "SELECT pokemon_id, COUNT(*) as total FROM sightings WHERE expire_timestamp >= EXTRACT(EPOCH FROM NOW()) GROUP BY pokemon_id";
		$result = pg_query($this->db, $req);
		$counts = array();
		while ($data = pg_fetch_object($result)) {
			$counts[$data->pokemon_id] = $data->total;
		}
		return $counts;
	}

	public function getPokemonCountsLastDay() {
		$req = "SELECT pokemon_id, COUNT(*) AS spawns_last_day
					FROM sightings
					WHERE expire_timestamp >= (SELECT MAX(expire_timestamp) - 86400 FROM sightings)
					GROUP BY pokemon_id
				  	ORDER BY pokemon_id ASC";
		$result = pg_query($this->db, $req);
		$counts = array();
		while ($data = pg_fetch_object($result)) {
			$counts[$data->pokemon_id] = $data->spawns_last_day;
		}
		return $counts;
	}

	public function getPokemonSinceLastUpdate($pokemon_id, $last_update) {

		$where = "WHERE p.pokemon_id = '".$pokemon_id."' AND p.expire_timestamp - (coalesce(CASE WHEN duration = 0 THEN NULL ELSE duration END ,30)*60) > '".$last_update."'";
		$req = "SELECT count, p.expire_timestamp - (coalesce(CASE WHEN duration = 0 THEN NULL ELSE duration END ,30)*60) AS last_timestamp, (TO_TIMESTAMP(expire_timestamp)) AS disappear_time_real, lat as latitude, lon as longitude
					FROM sightings p
					LEFT JOIN spawnpoints s ON p.spawn_id = s.spawn_id
				  	JOIN (SELECT COUNT(*) AS count
						FROM FROM sightings p
						LEFT JOIN spawnpoints s ON p.spawn_id = s.spawn_id
                    	" . $where. "
                    ) count ON 1 = 1
					" . $where . "
					ORDER BY last_timestamp DESC
					LIMIT 1 OFFSET 0";
		$result = pg_query($this->db, $req);
		$data = pg_fetch_object($result);
		return $data;
	}

	public function getRaidsSinceLastUpdate($pokemon_id, $last_update) {

		$where = "WHERE pokemon_id = '".$pokemon_id."' AND time_battle > '".$last_update."'";
		$req = "SELECT time_battle AS start_timestamp, time_end as end, (TO_TIMESTAMP(time_end)) AS end_time_real, lat as latitude, lon as longitude, count
					FROM raids r
					JOIN forts g ON r.fort_id = g.id
					JOIN (SELECT COUNT(*) AS count
						FROM raids
                    	" . $where."
                    ) count ON 1 = 1 
	                " . $where."
	                ORDER BY time_battle DESC
					LIMIT 1 OFFSET 0";
		$result = pg_query($this->db, $req);
		$data = pg_fetch_object($result);
		return $data;
	}

	public function getCaptchaCount() {

		$req = " SELECT COUNT(*) as total FROM accounts WHERE captchaed IS NOT NULL AND reason IS NULL";
		$result = pg_query($this->db, $req);
		$data = pg_fetch_object($result);
		return $data;
	}

	public function getNestData($time) {
		$pokemon_exclude_sql = "";
		if (!empty(self::$config->system->nest_exclude_pokemon)) {
			$pokemon_exclude_sql = "AND p.pokemon_id NOT IN (" . implode(",", self::$config->system->nest_exclude_pokemon) . ")";
		}
		$req = "SELECT p.spawn_id, p.pokemon_id, MAX(p.lat) AS latitude, MAX(p.lon) AS longitude, count(p.pokemon_id) AS total_pokemon, MAX(s.updated) as latest_seen, coalesce(CASE WHEN MAX(duration) = 0 THEN NULL ELSE MAX(duration) END ,30)*60 as duration
			          FROM sightings p
			          INNER JOIN spawnpoints s ON (p.spawn_id = s.spawn_id)
			          WHERE p.expire_timestamp > EXTRACT(EPOCH FROM NOW()) - ".($time * 3600)."
			          " . $pokemon_exclude_sql . "
			          GROUP BY p.spawn_id, p.pokemon_id
			          HAVING COUNT(p.pokemon_id) >= ".($time / 4)."
			          ORDER BY p.pokemon_id";
		$result = pg_query($this->db, $req);
		$nests = array();
		while ($data = pg_fetch_object($result)) {
			$nests[] = $data;
		}
		return $nests;
	}

}


1		<?php
2		/**
3		* Created by PhpStorm.
4		* User: floriankostenzer
5		* Date: 27.01.18
6		* Time: 02:26
7		*/
8
9		class QueryManagerPostgresqlMonocleAlternate extends QueryManagerPostgresql {
		0 ignored issues – show Coding Style Compatibility introduced 2018-01-28 22:07 UTC by Report Bug Copy Issue Report PSR1 recommends that each class must be in a namespace of at least one level to avoid collisions. You can fix this by adding a namespace to your class: namespace YourVendor; class YourClass { } When choosing a vendor namespace, try to pick something that is not too generic to avoid conflicts with other libraries. Loading history...
10
11		public function __construct() {
12		parent::__construct();
13		}
14
15		public function __destruct() {
16		parent::__destruct();
17		}
18
19		///////////
20		// Tester
21		///////////
22
23	View Code Duplication	function testTotalPokemon() {
		0 ignored issues – show Best Practice introduced 2018-01-28 22:07 UTC by Report Bug Copy Issue Report It is generally recommended to explicitly declare the visibility for methods. Adding explicit visibility (`private`, `protected`, or `public`) is generally recommend to communicate to other developers how, and from where this method is intended to be used. Loading history... Duplication introduced 2018-01-28 22:07 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history... Comprehensibility Best Practice introduced 2018-01-26 16:04 UTC by Report Bug Copy Issue Report It is recommend to declare an explicit visibility for `testTotalPokemon`. Generally, we recommend to declare visibility for all methods in your source code. This has the advantage of clearly communication to other developers, and also yourself, how this method should be consumed. If you are not sure which visibility to choose, it is a good idea to start with the most restrictive visibility, and then raise visibility as needed, i.e. start with `private`, and only raise it to `protected` if a sub-class needs to have access, or `public` if an external class needs access. Loading history...
24		$req = "SELECT COUNT(*) as total FROM sightings";
25		$result = pg_query($this->db, $req);
26		if ($result === false) {
27		return 1;
28		} else {
29		$data = pg_fetch_object($result);
30		$total = $data->total;
31
32		if ($total == 0) {
33		return 2;
34		}
35		}
36		return 0;
37		}
38

brusselopole / Worldopole

Pull Request — master (#363)

getGymData() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like