renamed server id to index
This commit is contained in:
parent
eb37af0579
commit
7eb1091511
@ -57,10 +57,10 @@ class ScriptSettings implements ConfiguratorMenu, CallbackListener {
|
|||||||
private function initTables() {
|
private function initTables() {
|
||||||
$mysqli = $this->maniaControl->database->mysqli;
|
$mysqli = $this->maniaControl->database->mysqli;
|
||||||
$query = "CREATE TABLE IF NOT EXISTS `" . self::TABLE_SCRIPT_SETTINGS . "` (
|
$query = "CREATE TABLE IF NOT EXISTS `" . self::TABLE_SCRIPT_SETTINGS . "` (
|
||||||
`serverId` int(11) NOT NULL AUTO_INCREMENT,
|
`serverIndex` int(11) NOT NULL AUTO_INCREMENT,
|
||||||
`settingName` varchar(100) COLLATE utf8_unicode_ci NOT NULL,
|
`settingName` varchar(100) COLLATE utf8_unicode_ci NOT NULL,
|
||||||
`settingValue` varchar(500) COLLATE utf8_unicode_ci NOT NULL,
|
`settingValue` varchar(500) COLLATE utf8_unicode_ci NOT NULL,
|
||||||
UNIQUE KEY `setting` (`serverId`, `settingName`)
|
UNIQUE KEY `setting` (`serverIndex`, `settingName`)
|
||||||
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci COMMENT='Script Settings' AUTO_INCREMENT=1;";
|
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci COMMENT='Script Settings' AUTO_INCREMENT=1;";
|
||||||
|
|
||||||
$statement = $mysqli->prepare($query);
|
$statement = $mysqli->prepare($query);
|
||||||
@ -371,7 +371,7 @@ class ScriptSettings implements ConfiguratorMenu, CallbackListener {
|
|||||||
// Save Settings into Database
|
// Save Settings into Database
|
||||||
$mysqli = $this->maniaControl->database->mysqli;
|
$mysqli = $this->maniaControl->database->mysqli;
|
||||||
$query = "INSERT INTO `" . self::TABLE_SCRIPT_SETTINGS . "` (
|
$query = "INSERT INTO `" . self::TABLE_SCRIPT_SETTINGS . "` (
|
||||||
`serverId`,
|
`serverIndex`,
|
||||||
`settingName`,
|
`settingName`,
|
||||||
`settingValue`
|
`settingValue`
|
||||||
) VALUES (
|
) VALUES (
|
||||||
@ -384,7 +384,7 @@ class ScriptSettings implements ConfiguratorMenu, CallbackListener {
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
$serverId = $this->maniaControl->server->getServerId();
|
$serverIndex = $this->maniaControl->server->getIndex();
|
||||||
|
|
||||||
// Notifications
|
// Notifications
|
||||||
$settingsCount = count($newSettings);
|
$settingsCount = count($newSettings);
|
||||||
@ -400,7 +400,7 @@ class ScriptSettings implements ConfiguratorMenu, CallbackListener {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Add To Database
|
// Add To Database
|
||||||
$statement->bind_param('iss', $serverId, $setting, $value);
|
$statement->bind_param('iss', $serverIndex, $setting, $value);
|
||||||
$statement->execute();
|
$statement->execute();
|
||||||
if ($statement->error) {
|
if ($statement->error) {
|
||||||
trigger_error($statement->error);
|
trigger_error($statement->error);
|
||||||
|
@ -56,10 +56,10 @@ class ServerSettings implements ConfiguratorMenu, CallbackListener {
|
|||||||
private function initTables() {
|
private function initTables() {
|
||||||
$mysqli = $this->maniaControl->database->mysqli;
|
$mysqli = $this->maniaControl->database->mysqli;
|
||||||
$query = "CREATE TABLE IF NOT EXISTS `" . self::TABLE_SERVER_SETTINGS . "` (
|
$query = "CREATE TABLE IF NOT EXISTS `" . self::TABLE_SERVER_SETTINGS . "` (
|
||||||
`serverId` int(11) NOT NULL AUTO_INCREMENT,
|
`serverIndex` int(11) NOT NULL AUTO_INCREMENT,
|
||||||
`settingName` varchar(100) COLLATE utf8_unicode_ci NOT NULL,
|
`settingName` varchar(100) COLLATE utf8_unicode_ci NOT NULL,
|
||||||
`settingValue` varchar(500) COLLATE utf8_unicode_ci NOT NULL,
|
`settingValue` varchar(500) COLLATE utf8_unicode_ci NOT NULL,
|
||||||
UNIQUE KEY `setting` (`serverId`, `settingName`)
|
UNIQUE KEY `setting` (`serverIndex`, `settingName`)
|
||||||
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci COMMENT='Server Settings' AUTO_INCREMENT=1;";
|
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci COMMENT='Server Settings' AUTO_INCREMENT=1;";
|
||||||
$statement = $mysqli->prepare($query);
|
$statement = $mysqli->prepare($query);
|
||||||
if ($mysqli->error) {
|
if ($mysqli->error) {
|
||||||
@ -338,7 +338,7 @@ class ServerSettings implements ConfiguratorMenu, CallbackListener {
|
|||||||
$mysqli = $this->maniaControl->database->mysqli;
|
$mysqli = $this->maniaControl->database->mysqli;
|
||||||
|
|
||||||
$query = "INSERT INTO `" . self::TABLE_SERVER_SETTINGS . "` (
|
$query = "INSERT INTO `" . self::TABLE_SERVER_SETTINGS . "` (
|
||||||
`serverId`,
|
`serverIndex`,
|
||||||
`settingName`,
|
`settingName`,
|
||||||
`settingValue`
|
`settingValue`
|
||||||
) VALUES (
|
) VALUES (
|
||||||
@ -351,7 +351,7 @@ class ServerSettings implements ConfiguratorMenu, CallbackListener {
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
$serverId = $this->maniaControl->server->getServerId();
|
$serverIndex = $this->maniaControl->server->getIndex();
|
||||||
|
|
||||||
// Notifications
|
// Notifications
|
||||||
$settingsCount = count($newSettings);
|
$settingsCount = count($newSettings);
|
||||||
@ -360,7 +360,7 @@ class ServerSettings implements ConfiguratorMenu, CallbackListener {
|
|||||||
// $chatMessage = '$ff0' . $title . ' $<' . $player->nickname . '$> set ScriptSetting' . ($settingsCount > 1 ? 's' : '') . ' ';
|
// $chatMessage = '$ff0' . $title . ' $<' . $player->nickname . '$> set ScriptSetting' . ($settingsCount > 1 ? 's' : '') . ' ';
|
||||||
foreach ($newSettings as $setting => $value) {
|
foreach ($newSettings as $setting => $value) {
|
||||||
|
|
||||||
$statement->bind_param('iss', $serverId, $setting, $value);
|
$statement->bind_param('iss', $serverIndex, $setting, $value);
|
||||||
$statement->execute();
|
$statement->execute();
|
||||||
if ($statement->error) {
|
if ($statement->error) {
|
||||||
trigger_error($statement->error);
|
trigger_error($statement->error);
|
||||||
|
@ -308,7 +308,8 @@ class PlayerManager implements CallbackListener {
|
|||||||
$playerStatement->close();
|
$playerStatement->close();
|
||||||
|
|
||||||
// Increment the Player Join Count
|
// Increment the Player Join Count
|
||||||
$this->maniaControl->statisticManager->incrementStat(self::STAT_JOIN_COUNT, $player, $this->maniaControl->server->getServerId());
|
$serverIndex = $this->maniaControl->server->getIndex();
|
||||||
|
$this->maniaControl->statisticManager->incrementStat(self::STAT_JOIN_COUNT, $player, $serverIndex);
|
||||||
|
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
@ -325,6 +326,7 @@ class PlayerManager implements CallbackListener {
|
|||||||
}
|
}
|
||||||
$playedTime = time() - $player->joinTime;
|
$playedTime = time() - $player->joinTime;
|
||||||
|
|
||||||
return $this->maniaControl->statisticManager->insertStat(self::STAT_SERVERTIME, $player, $this->maniaControl->server->getServerId(), $playedTime);
|
$serverIndex = $this->maniaControl->server->getIndex();
|
||||||
|
return $this->maniaControl->statisticManager->insertStat(self::STAT_SERVERTIME, $player, $serverIndex, $playedTime);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -11,7 +11,7 @@ use ManiaControl\Players\Player;
|
|||||||
require_once __DIR__ . '/ServerCommands.php';
|
require_once __DIR__ . '/ServerCommands.php';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Class providing information and commands for the connected maniaplanet server
|
* Class providing Information about theconnected ManiaPlanet Server
|
||||||
*
|
*
|
||||||
* @author steeffeen & kremsy
|
* @author steeffeen & kremsy
|
||||||
*/
|
*/
|
||||||
@ -23,16 +23,17 @@ class Server implements CallbackListener {
|
|||||||
const TABLE_SERVERS = 'mc_servers';
|
const TABLE_SERVERS = 'mc_servers';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Public properties
|
* Public Properties
|
||||||
*/
|
*/
|
||||||
public $config = null;
|
public $config = null;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Private properties
|
* Private Properties
|
||||||
*/
|
*/
|
||||||
private $maniaControl = null;
|
private $maniaControl = null;
|
||||||
private $serverCommands = null;
|
private $serverCommands = null;
|
||||||
private $serverId = 0;
|
private $index = null;
|
||||||
|
private $login = null;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Construct server
|
* Construct server
|
||||||
@ -41,6 +42,7 @@ class Server implements CallbackListener {
|
|||||||
*/
|
*/
|
||||||
public function __construct(ManiaControl $maniaControl) {
|
public function __construct(ManiaControl $maniaControl) {
|
||||||
$this->maniaControl = $maniaControl;
|
$this->maniaControl = $maniaControl;
|
||||||
|
$this->initTables();
|
||||||
|
|
||||||
// Load config
|
// Load config
|
||||||
$this->config = FileUtil::loadConfig('server.xml');
|
$this->config = FileUtil::loadConfig('server.xml');
|
||||||
@ -49,91 +51,66 @@ class Server implements CallbackListener {
|
|||||||
$this->maniaControl->callbackManager->registerCallbackListener(CallbackManager::CB_MC_ONINIT, $this, 'onInit');
|
$this->maniaControl->callbackManager->registerCallbackListener(CallbackManager::CB_MC_ONINIT, $this, 'onInit');
|
||||||
|
|
||||||
$this->serverCommands = new ServerCommands($maniaControl);
|
$this->serverCommands = new ServerCommands($maniaControl);
|
||||||
|
|
||||||
$this->initTables();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Initialize necessary database tables
|
* Initialize necessary Database Tables
|
||||||
*
|
*
|
||||||
* @return bool
|
* @return bool
|
||||||
*/
|
*/
|
||||||
private function initTables() {
|
private function initTables() {
|
||||||
$mysqli = $this->maniaControl->database->mysqli;
|
$mysqli = $this->maniaControl->database->mysqli;
|
||||||
$query = "CREATE TABLE IF NOT EXISTS `" . self::TABLE_SERVERS . "` (
|
$query = "CREATE TABLE IF NOT EXISTS `" . self::TABLE_SERVERS . "` (
|
||||||
`serverId` int(11) NOT NULL AUTO_INCREMENT,
|
`index` int(11) NOT NULL AUTO_INCREMENT,
|
||||||
`login` varchar(100) COLLATE utf8_unicode_ci NOT NULL,
|
`login` varchar(100) COLLATE utf8_unicode_ci NOT NULL,
|
||||||
PRIMARY KEY (`serverId`),
|
PRIMARY KEY (`index`),
|
||||||
UNIQUE KEY `login` (`login`)
|
UNIQUE KEY `login` (`login`)
|
||||||
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci COMMENT='Servers' AUTO_INCREMENT=1;";
|
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci COMMENT='Servers' AUTO_INCREMENT=1;";
|
||||||
|
|
||||||
$statement = $mysqli->prepare($query);
|
$statement = $mysqli->prepare($query);
|
||||||
if ($mysqli->error) {
|
if ($mysqli->error) {
|
||||||
trigger_error($mysqli->error, E_USER_ERROR);
|
trigger_error($mysqli->error, E_USER_ERROR);
|
||||||
|
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
$statement->execute();
|
$statement->execute();
|
||||||
if ($statement->error) {
|
if ($statement->error) {
|
||||||
trigger_error($statement->error, E_USER_ERROR);
|
trigger_error($statement->error, E_USER_ERROR);
|
||||||
|
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
$statement->close();
|
$statement->close();
|
||||||
|
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Handle OnInit callback
|
* Handle OnInit Callback
|
||||||
*
|
*
|
||||||
* @param array $callback
|
* @param array $callback
|
||||||
*/
|
*/
|
||||||
public function onInit(array $callback) {
|
public function onInit(array $callback) {
|
||||||
$mysqli = $this->maniaControl->database->mysqli;
|
$mysqli = $this->maniaControl->database->mysqli;
|
||||||
|
|
||||||
$login = $this->getLogin();
|
|
||||||
|
|
||||||
$query = "INSERT IGNORE INTO `" . self::TABLE_SERVERS . "` (
|
$query = "INSERT IGNORE INTO `" . self::TABLE_SERVERS . "` (
|
||||||
`login`
|
`login`
|
||||||
) VALUES (
|
) VALUES (
|
||||||
?
|
?
|
||||||
);";
|
);";
|
||||||
|
|
||||||
$statement = $mysqli->prepare($query);
|
$statement = $mysqli->prepare($query);
|
||||||
if ($mysqli->error) {
|
if ($mysqli->error) {
|
||||||
trigger_error($mysqli->error);
|
trigger_error($mysqli->error);
|
||||||
return false;
|
return;
|
||||||
}
|
}
|
||||||
|
$login = $this->getLogin();
|
||||||
$statement->bind_param('s', $login);
|
$statement->bind_param('s', $login);
|
||||||
$statement->execute();
|
$statement->execute();
|
||||||
if ($statement->error) {
|
if ($statement->error) {
|
||||||
trigger_error($statement->error);
|
trigger_error($statement->error);
|
||||||
$statement->close();
|
$statement->close();
|
||||||
return false;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
$statement->close();
|
$statement->close();
|
||||||
|
|
||||||
$query = "SELECT serverId FROM `" . self::TABLE_SERVERS . "` WHERE `login` = '" . $login . "';";
|
|
||||||
|
|
||||||
|
|
||||||
$result = $mysqli->query($query);
|
|
||||||
if(!$result) {
|
|
||||||
trigger_error($mysqli->error);
|
|
||||||
}
|
|
||||||
|
|
||||||
$row = $result->fetch_object();
|
|
||||||
|
|
||||||
$result->close();
|
|
||||||
|
|
||||||
$this->serverId = $row->serverId;
|
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Fetch game data directory
|
* Fetch Game Data Directory
|
||||||
*
|
*
|
||||||
* @return string
|
* @return string
|
||||||
*/
|
*/
|
||||||
@ -146,7 +123,7 @@ class Server implements CallbackListener {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Fetch maps directory
|
* Fetch Maps Directory
|
||||||
*
|
*
|
||||||
* @return string
|
* @return string
|
||||||
*/
|
*/
|
||||||
@ -159,33 +136,53 @@ class Server implements CallbackListener {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Checks if ManiaControl has access to the given directory
|
* Checks if ManiaControl has Access to the given Directory
|
||||||
*
|
*
|
||||||
* @param string $directory
|
* @param string $directory
|
||||||
* @return bool
|
* @return bool
|
||||||
*/
|
*/
|
||||||
public function checkAccess($directory) {
|
public function checkAccess($directory) {
|
||||||
if(!$directory) {
|
if (!$directory) return false;
|
||||||
return false;
|
|
||||||
}
|
|
||||||
return (is_dir($directory) && is_writable($directory));
|
return (is_dir($directory) && is_writable($directory));
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Fetch server login
|
* Fetch Server Index
|
||||||
*
|
*
|
||||||
* @return array
|
* @return int
|
||||||
*/
|
*/
|
||||||
public function getLogin() { //TODO save the info locally
|
public function getIndex() {
|
||||||
$systemInfo = $this->getSystemInfo();
|
if ($this->index) return $this->index;
|
||||||
if(!$systemInfo) {
|
$mysqli = $this->maniaControl->database->mysqli;
|
||||||
return null;
|
$login = $this->getLogin();
|
||||||
|
$query = "SELECT `index` FROM `" . self::TABLE_SERVERS . "`
|
||||||
|
WHERE `login` = '" . $login . "';";
|
||||||
|
$result = $mysqli->query($query);
|
||||||
|
if (!$result) {
|
||||||
|
trigger_error($mysqli->error);
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
return $systemInfo['ServerLogin'];
|
$row = $result->fetch_object();
|
||||||
|
$result->close();
|
||||||
|
$this->index = $row->index;
|
||||||
|
return $this->index;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Get server info
|
* Fetch Server Login
|
||||||
|
*
|
||||||
|
* @return string
|
||||||
|
*/
|
||||||
|
public function getLogin() {
|
||||||
|
if ($this->login) return $this->login;
|
||||||
|
$systemInfo = $this->getSystemInfo();
|
||||||
|
if (!$systemInfo) return null;
|
||||||
|
$this->login = $systemInfo['ServerLogin'];
|
||||||
|
return $this->login;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Get the Server Info
|
||||||
*
|
*
|
||||||
* @param bool $detailed
|
* @param bool $detailed
|
||||||
* @return array
|
* @return array
|
||||||
@ -207,7 +204,7 @@ class Server implements CallbackListener {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Get server options
|
* Get Server Options
|
||||||
*
|
*
|
||||||
* @return array
|
* @return array
|
||||||
*/
|
*/
|
||||||
@ -220,7 +217,7 @@ class Server implements CallbackListener {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Fetch server name
|
* Fetch current Server Name
|
||||||
*
|
*
|
||||||
* @return string
|
* @return string
|
||||||
*/
|
*/
|
||||||
@ -233,7 +230,7 @@ class Server implements CallbackListener {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Fetch server version
|
* Fetch Server Version
|
||||||
*
|
*
|
||||||
* @return string
|
* @return string
|
||||||
*/
|
*/
|
||||||
@ -246,7 +243,7 @@ class Server implements CallbackListener {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Fetch server system info
|
* Fetch Server System Info
|
||||||
*
|
*
|
||||||
* @return array
|
* @return array
|
||||||
*/
|
*/
|
||||||
@ -259,7 +256,7 @@ class Server implements CallbackListener {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Fetch current game mode
|
* Fetch current Game Mode
|
||||||
*
|
*
|
||||||
* @param bool $stringValue
|
* @param bool $stringValue
|
||||||
* @param int $parseValue
|
* @param int $parseValue
|
||||||
@ -268,7 +265,8 @@ class Server implements CallbackListener {
|
|||||||
public function getGameMode($stringValue = false, $parseValue = null) {
|
public function getGameMode($stringValue = false, $parseValue = null) {
|
||||||
if (is_int($parseValue)) {
|
if (is_int($parseValue)) {
|
||||||
$gameMode = $parseValue;
|
$gameMode = $parseValue;
|
||||||
} else {
|
}
|
||||||
|
else {
|
||||||
if (!$this->maniaControl->client->query('GetGameMode')) {
|
if (!$this->maniaControl->client->query('GetGameMode')) {
|
||||||
trigger_error("Couldn't fetch current game mode. " . $this->maniaControl->getClientErrorText());
|
trigger_error("Couldn't fetch current game mode. " . $this->maniaControl->getClientErrorText());
|
||||||
return null;
|
return null;
|
||||||
@ -315,7 +313,7 @@ class Server implements CallbackListener {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Retrieve validation replay for given player
|
* Retrieve Validation Replay for the given Player
|
||||||
*
|
*
|
||||||
* @param Player $player
|
* @param Player $player
|
||||||
* @return string
|
* @return string
|
||||||
@ -329,16 +327,14 @@ class Server implements CallbackListener {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Retrieve ghost replay for the given player
|
* Retrieve Ghost Replay for the given Player
|
||||||
*
|
*
|
||||||
* @param Player $player
|
* @param Player $player
|
||||||
* @return string
|
* @return string
|
||||||
*/
|
*/
|
||||||
public function getGhostReplay(Player $player) {
|
public function getGhostReplay(Player $player) {
|
||||||
$dataDir = $this->getDataDirectory();
|
$dataDir = $this->getDataDirectory();
|
||||||
if(!$this->checkAccess($dataDir)) {
|
if (!$this->checkAccess($dataDir)) return null;
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Build file name
|
// Build file name
|
||||||
$map = $this->getMap();
|
$map = $this->getMap();
|
||||||
@ -362,7 +358,7 @@ class Server implements CallbackListener {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Waits for the server to have the given status
|
* Wait for the Server to have the given Status
|
||||||
*
|
*
|
||||||
* @param int $statusCode
|
* @param int $statusCode
|
||||||
* @return bool
|
* @return bool
|
||||||
@ -396,11 +392,4 @@ class Server implements CallbackListener {
|
|||||||
}
|
}
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* @return int
|
|
||||||
*/
|
|
||||||
public function getServerId() {
|
|
||||||
return $this->serverId;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
@ -90,9 +90,9 @@ class StatisticCollector implements CallbackListener {
|
|||||||
|
|
||||||
//Write Shoot Data into database
|
//Write Shoot Data into database
|
||||||
if($this->onShootArray[$login] > $this->maniaControl->settingManager->getSetting($this, self::SETTING_ON_SHOOT_PRESTORE)) {
|
if($this->onShootArray[$login] > $this->maniaControl->settingManager->getSetting($this, self::SETTING_ON_SHOOT_PRESTORE)) {
|
||||||
$serverId = $this->maniaControl->server->getServerId();
|
$serverIndex = $this->maniaControl->server->getIndex();
|
||||||
$player = $this->maniaControl->playerManager->getPlayer($login);
|
$player = $this->maniaControl->playerManager->getPlayer($login);
|
||||||
$this->maniaControl->statisticManager->insertStat(self::STAT_ON_SHOOT, $player, $serverId, $this->onShootArray[$login]);
|
$this->maniaControl->statisticManager->insertStat(self::STAT_ON_SHOOT, $player, $serverIndex, $this->onShootArray[$login]);
|
||||||
$this->onShootArray[$login] = 0;
|
$this->onShootArray[$login] = 0;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -114,8 +114,8 @@ class StatisticCollector implements CallbackListener {
|
|||||||
//Insert Data into Database, and destroy player
|
//Insert Data into Database, and destroy player
|
||||||
if(isset($this->onShootArray[$player->login])) {
|
if(isset($this->onShootArray[$player->login])) {
|
||||||
if($this->onShootArray[$player->login] > 0) {
|
if($this->onShootArray[$player->login] > 0) {
|
||||||
$serverId = $this->maniaControl->server->getServerId();
|
$serverIndex = $this->maniaControl->server->getIndex();
|
||||||
$this->maniaControl->statisticManager->insertStat(self::STAT_ON_SHOOT, $player, $serverId, $this->onShootArray[$player->login]);
|
$this->maniaControl->statisticManager->insertStat(self::STAT_ON_SHOOT, $player, $serverIndex, $this->onShootArray[$player->login]);
|
||||||
}
|
}
|
||||||
unset($this->onShootArray[$player->login]);
|
unset($this->onShootArray[$player->login]);
|
||||||
}
|
}
|
||||||
|
@ -20,7 +20,6 @@ class StatisticManager {
|
|||||||
*/
|
*/
|
||||||
const TABLE_STATMETADATA = 'mc_statmetadata';
|
const TABLE_STATMETADATA = 'mc_statmetadata';
|
||||||
const TABLE_STATISTICS = 'mc_statistics';
|
const TABLE_STATISTICS = 'mc_statistics';
|
||||||
|
|
||||||
const STAT_TYPE_INT = '0';
|
const STAT_TYPE_INT = '0';
|
||||||
const STAT_TYPE_TIME = '1';
|
const STAT_TYPE_TIME = '1';
|
||||||
|
|
||||||
@ -55,10 +54,10 @@ class StatisticManager {
|
|||||||
*
|
*
|
||||||
* @param $statName
|
* @param $statName
|
||||||
* @param $playerId
|
* @param $playerId
|
||||||
* @param int $serverId
|
* @param int $serverIndex
|
||||||
* @return int
|
* @return int
|
||||||
*/
|
*/
|
||||||
public function getStatisticData($statName, $playerId, $serverId = -1) {
|
public function getStatisticData($statName, $playerId, $serverIndex = -1) {
|
||||||
$mysqli = $this->maniaControl->database->mysqli;
|
$mysqli = $this->maniaControl->database->mysqli;
|
||||||
$statId = $this->getStatId($statName);
|
$statId = $this->getStatId($statName);
|
||||||
|
|
||||||
@ -66,10 +65,13 @@ class StatisticManager {
|
|||||||
return -1;
|
return -1;
|
||||||
}
|
}
|
||||||
|
|
||||||
if($serverId == -1) {
|
if ($serverIndex == -1) {
|
||||||
$query = "SELECT SUM(value) as value FROM `" . self::TABLE_STATISTICS . "` WHERE `statId` = " . $statId . " AND `playerId` = " . $playerId . ";";
|
$query = "SELECT SUM(value) as value FROM `" . self::TABLE_STATISTICS . "` WHERE `statId` = " . $statId . " AND `playerId` = " . $playerId .
|
||||||
} else {
|
";";
|
||||||
$query = "SELECT value FROM `" . self::TABLE_STATISTICS . "` WHERE `statId` = " . $statId . " AND `playerId` = " . $playerId . " AND `serverLogin` = '" . $serverId . "';";
|
}
|
||||||
|
else {
|
||||||
|
$query = "SELECT value FROM `" . self::TABLE_STATISTICS . "` WHERE `statId` = " . $statId . " AND `playerId` = " . $playerId .
|
||||||
|
" AND `serverIndex` = '" . $serverIndex . "';";
|
||||||
}
|
}
|
||||||
|
|
||||||
$result = $mysqli->query($query);
|
$result = $mysqli->query($query);
|
||||||
@ -112,23 +114,23 @@ class StatisticManager {
|
|||||||
if (isset($this->stats[$statName])) {
|
if (isset($this->stats[$statName])) {
|
||||||
$stat = $this->stats[$statName];
|
$stat = $this->stats[$statName];
|
||||||
return (int) $stat->index;
|
return (int) $stat->index;
|
||||||
} else {
|
}
|
||||||
|
else {
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Get all statistics of a certain palyer
|
* Get all statistics of a certain palyer
|
||||||
*
|
*
|
||||||
* @param Player $player
|
* @param Player $player
|
||||||
* @param int $serverId
|
* @param int $serverIndex
|
||||||
* @return array
|
* @return array
|
||||||
*/
|
*/
|
||||||
public function getAllPlayerStats(Player $player, $serverId = -1) {
|
public function getAllPlayerStats(Player $player, $serverIndex = -1) {
|
||||||
$playerStats = array(); // TODO improve performence
|
$playerStats = array(); // TODO improve performence
|
||||||
foreach ($this->stats as $stat) {
|
foreach ($this->stats as $stat) {
|
||||||
$value = $this->getStatisticData($stat->name, $player->index, $serverId);
|
$value = $this->getStatisticData($stat->name, $player->index, $serverIndex);
|
||||||
$playerStats[$stat->name] = array($stat, $value);
|
$playerStats[$stat->name] = array($stat, $value);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -138,15 +140,14 @@ class StatisticManager {
|
|||||||
/**
|
/**
|
||||||
* Inserts a Stat into the database
|
* Inserts a Stat into the database
|
||||||
*
|
*
|
||||||
* @param $statName
|
* @param string $statName
|
||||||
* @param Player $player
|
* @param Player $player
|
||||||
* @param int $serverId
|
* @param int $serverIndex
|
||||||
* @param $value , value to Add
|
* @param mixed $value , value to Add
|
||||||
* @param string $statType
|
* @param string $statType
|
||||||
* @internal param string $serverLogin
|
|
||||||
* @return bool
|
* @return bool
|
||||||
*/
|
*/
|
||||||
public function insertStat($statName, $player, $serverId = -1, $value, $statType = self::STAT_TYPE_INT) {
|
public function insertStat($statName, $player, $serverIndex = -1, $value, $statType = self::STAT_TYPE_INT) {
|
||||||
$statId = $this->getStatId($statName);
|
$statId = $this->getStatId($statName);
|
||||||
|
|
||||||
if ($player == null) {
|
if ($player == null) {
|
||||||
@ -161,15 +162,14 @@ class StatisticManager {
|
|||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
if($serverId == -1) {
|
if ($serverIndex == -1) {
|
||||||
$serverId = $this->maniaControl->server->getServerId();
|
$serverIndex = $this->maniaControl->server->getIndex();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
$mysqli = $this->maniaControl->database->mysqli;
|
$mysqli = $this->maniaControl->database->mysqli;
|
||||||
|
|
||||||
$query = "INSERT INTO `" . self::TABLE_STATISTICS . "` (
|
$query = "INSERT INTO `" . self::TABLE_STATISTICS . "` (
|
||||||
`serverId`,
|
`serverIndex`,
|
||||||
`playerId`,
|
`playerId`,
|
||||||
`statId`,
|
`statId`,
|
||||||
`value`
|
`value`
|
||||||
@ -184,7 +184,7 @@ class StatisticManager {
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
$statement->bind_param('iiii', $serverId, $player->index, $statId, $value);
|
$statement->bind_param('iiii', $serverIndex, $player->index, $statId, $value);
|
||||||
$statement->execute();
|
$statement->execute();
|
||||||
if ($statement->error) {
|
if ($statement->error) {
|
||||||
trigger_error($statement->error);
|
trigger_error($statement->error);
|
||||||
@ -199,18 +199,15 @@ class StatisticManager {
|
|||||||
/**
|
/**
|
||||||
* Increments a Statistic by one
|
* Increments a Statistic by one
|
||||||
*
|
*
|
||||||
* @param $statName
|
* @param string $statName
|
||||||
* @param \ManiaControl\Players\Player $player
|
* @param Player $player
|
||||||
* @param int $serverId
|
* @param int $serverIndex
|
||||||
* @internal param string $serverLogin
|
|
||||||
* @internal param \ManiaControl\Players\Player $playerId
|
|
||||||
* @return bool
|
* @return bool
|
||||||
*/
|
*/
|
||||||
public function incrementStat($statName, $player, $serverId = -1) {
|
public function incrementStat($statName, Player $player, $serverIndex = -1) {
|
||||||
return $this->insertStat($statName, $player, $serverId, 1);
|
return $this->insertStat($statName, $player, $serverIndex, 1);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Defines a Stat
|
* Defines a Stat
|
||||||
*
|
*
|
||||||
@ -248,7 +245,6 @@ class StatisticManager {
|
|||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Initialize necessary database tables
|
* Initialize necessary database tables
|
||||||
*
|
*
|
||||||
@ -281,12 +277,12 @@ class StatisticManager {
|
|||||||
|
|
||||||
$query = "CREATE TABLE IF NOT EXISTS `" . self::TABLE_STATISTICS . "` (
|
$query = "CREATE TABLE IF NOT EXISTS `" . self::TABLE_STATISTICS . "` (
|
||||||
`index` int(11) NOT NULL AUTO_INCREMENT,
|
`index` int(11) NOT NULL AUTO_INCREMENT,
|
||||||
`serverId` int(11) NOT NULL,
|
`serverIndex` int(11) NOT NULL,
|
||||||
`playerId` int(11) NOT NULL,
|
`playerId` int(11) NOT NULL,
|
||||||
`statId` int(11) NOT NULL,
|
`statId` int(11) NOT NULL,
|
||||||
`value` int(20) COLLATE utf8_unicode_ci NOT NULL,
|
`value` int(20) COLLATE utf8_unicode_ci NOT NULL,
|
||||||
PRIMARY KEY (`index`),
|
PRIMARY KEY (`index`),
|
||||||
UNIQUE KEY `unique` (`statId`,`playerId`,`serverId`)
|
UNIQUE KEY `unique` (`statId`,`playerId`,`serverIndex`)
|
||||||
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci COMMENT='Statistics' AUTO_INCREMENT=1;";
|
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci COMMENT='Statistics' AUTO_INCREMENT=1;";
|
||||||
|
|
||||||
$statement = $mysqli->prepare($query);
|
$statement = $mysqli->prepare($query);
|
||||||
|
@ -424,8 +424,8 @@ class DonationPlugin implements CallbackListener, CommandListener, Plugin {
|
|||||||
$message = 'Donation successful! Thanks.';
|
$message = 'Donation successful! Thanks.';
|
||||||
}
|
}
|
||||||
$this->maniaControl->chat->sendSuccess($message, $login);
|
$this->maniaControl->chat->sendSuccess($message, $login);
|
||||||
$this->maniaControl->statisticManager->insertStat(self::STAT_PLAYER_DONATIONS, $player,
|
$serverIndex = $this->maniaControl->server->getIndex();
|
||||||
$this->maniaControl->server->getServerId(), $amount);
|
$this->maniaControl->statisticManager->insertStat(self::STAT_PLAYER_DONATIONS, $player, $serverIndex, $amount);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
|
@ -272,7 +272,8 @@ class KarmaPlugin implements CallbackListener, Plugin {
|
|||||||
$voted = $this->getPlayerVote($player, $map);
|
$voted = $this->getPlayerVote($player, $map);
|
||||||
var_dump($voted);
|
var_dump($voted);
|
||||||
if(!$voted){
|
if(!$voted){
|
||||||
$this->maniaControl->statisticManager->incrementStat(self::STAT_PLAYER_MAPVOTES, $player, $this->maniaControl->server->getServerId());
|
$serverIndex = $this->maniaControl->server->getIndex();
|
||||||
|
$this->maniaControl->statisticManager->incrementStat(self::STAT_PLAYER_MAPVOTES, $player, $serverIndex);
|
||||||
}
|
}
|
||||||
|
|
||||||
$success = $this->savePlayerVote($player, $map, $vote);
|
$success = $this->savePlayerVote($player, $map, $vote);
|
||||||
|
Loading…
Reference in New Issue
Block a user