arriej/TSN-Ranksystem
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Files
53982186af14703fa00434d2815d467a11e3318b
TSN-Ranksystem/jobs/calc_serverstats.php
Newcomer1989 3a333716a2 release 1.3.12
2020-09-22 18:56:47 +02:00

447 lines
20 KiB
PHP
Raw Blame History

<?PHP
function calc_serverstats($ts3,$mysqlcon,&$cfg,$dbname,$dbtype,$serverinfo,&$db_cache,$phpcommand,$lang) {
$starttime = microtime(true);
$nowtime = time();
$sqlexec = '';
if($db_cache['job_check']['calc_donut_chars']['timestamp'] < ($nowtime - 8)) {
$db_cache['job_check']['calc_donut_chars']['timestamp'] = $nowtime;
$sqlexec .= "UPDATE `$dbname`.`job_check` SET `timestamp`={$nowtime} WHERE `job_name`='calc_donut_chars';\n";
$total_user = $total_online_time = $total_inactive_time = $server_used_slots = $server_channel_amount = $user_today = $user_week = $user_month = $user_quarter = 0;
$country_array = $platform_array = $count_version_user = array();
foreach($db_cache['all_user'] as $uuid) {
if ($uuid['lastseen']>($nowtime-86400)) {
$user_quarter++; $user_month++; $user_week++; $user_today++;
} elseif ($uuid['lastseen']>($nowtime-604800)) {
$user_quarter++; $user_month++; $user_week++;
} elseif ($uuid['lastseen']>($nowtime-2592000)) {
$user_quarter++; $user_month++;
} elseif ($uuid['lastseen']>($nowtime-7776000)) {
$user_quarter++;
}
if(isset($country_array[$uuid['nation']])) {
$country_array[$uuid['nation']]++;
} else {
$country_array[$uuid['nation']] = 1;
}
if(isset($platform_array[$uuid['platform']])) {
$platform_array[$uuid['platform']]++;
} else {
$platform_array[$uuid['platform']] = 1;
}
if(isset($count_version_user[$uuid['version']])) {
$count_version_user[$uuid['version']]++;
} else {
$count_version_user[$uuid['version']] = 1;
}
$total_online_time = $total_online_time + $uuid['count'];
$total_inactive_time = $total_inactive_time + $uuid['idle'];
}
arsort($country_array);
arsort($platform_array);
arsort($count_version_user);
$total_online_time = round($total_online_time);
$total_inactive_time = round($total_inactive_time);
$total_active_time = $total_online_time - $total_inactive_time;
$total_user = count($db_cache['all_user']);
if($serverinfo['virtualserver_status']=="online") {
$server_status = 1;
} elseif($serverinfo['virtualserver_status']=="offline") {
$server_status = 2;
} elseif($serverinfo['virtualserver_status']=="virtual online") {
$server_status = 3;
} else {
$server_status = 4;
}
$platform_other = $platform_1 = $platform_2 = $platform_3 = $platform_4 = $platform_5 = 0;
if(!isset($cfg['temp_cache_platforms'])) {
$allinsertplatform = '';
foreach ($platform_array as $platform => $count) {
switch ($platform) {
case "Windows":
$platform_1 = $count;
break;
case "iOS":
$platform_2 = $count;
break;
case "Linux":
$platform_3 = $count;
break;
case "Android":
$platform_4 = $count;
break;
case "OSX":
$platform_5 = $count;
break;
default:
$platform_other = $platform_other + $count;
}
$allinsertplatform .= "('{$platform}',{$count}),";
$cfg['temp_cache_platforms'][$platform] = $count;
}
if($allinsertplatform != '') {
$allinsertplatform = substr($allinsertplatform, 0, -1);
$sqlexec .= "DELETE FROM `$dbname`.`stats_platforms`;\nINSERT INTO `$dbname`.`stats_platforms` (`platform`,`count`) VALUES $allinsertplatform;\n";
}
unset($platform_array,$allinsertplatform,$platform,$count);
} else {
$allupdateplatform = $updateplatform = $insertplatform = '';
if(isset($cfg['temp_cache_platforms'])) {
foreach ($platform_array as $platform => $count) {
switch ($platform) {
case "Windows":
$platform_1 = $count;
break;
case "iOS":
$platform_2 = $count;
break;
case "Linux":
$platform_3 = $count;
break;
case "Android":
$platform_4 = $count;
break;
case "OSX":
$platform_5 = $count;
break;
default:
$platform_other = $platform_other + $count;
}
if(isset($cfg['temp_cache_platforms'][$platform]) && $cfg['temp_cache_platforms'][$platform] == $count) {
continue;
} elseif(isset($cfg['temp_cache_platforms'][$platform])) {
$cfg['temp_cache_platforms'][$platform] = $count;
$allupdateplatform = "'{$platform}',";
$updateplatform .= "WHEN `platform`='{$platform}' THEN {$count} ";
} else {
$cfg['temp_cache_platforms'][$platform] = $count;
$insertplatform .= "('{$platform}',{$count}),";
}
}
}
if($updateplatform != '' && $allupdateplatform != '') {
$allupdateplatform = substr($allupdateplatform, 0, -1);
$sqlexec .= "UPDATE `$dbname`.`stats_platforms` SET `count`=CASE {$updateplatform}END WHERE `platform` IN ({$allupdateplatform});\n";
}
if($insertplatform != '') {
$insertplatform = substr($insertplatform, 0, -1);
$sqlexec .= "INSERT INTO `$dbname`.`stats_platforms` (`platform`,`count`) VALUES $insertplatform;\n";
}
unset($platform_array,$allupdateplatform,$updateplatform,$insertplatform,$platform,$count);
}
$country_counter = $country_nation_other = $country_nation_name_1 = $country_nation_name_2 = $country_nation_name_3 = $country_nation_name_4 = $country_nation_name_5 = $country_nation_1 = $country_nation_2 = $country_nation_3 = $country_nation_4 = $country_nation_5 = 0;
$allinsertnation = '';
if(!isset($cfg['temp_cache_nations'])) {
foreach ($country_array as $nation => $count) {
$country_counter++;
switch ($country_counter) {
case 1:
$country_nation_name_1 = $nation;
$country_nation_1 = $count;
break;
case 2:
$country_nation_name_2 = $nation;
$country_nation_2 = $count;
break;
case 3:
$country_nation_name_3 = $nation;
$country_nation_3 = $count;
break;
case 4:
$country_nation_name_4 = $nation;
$country_nation_4 = $count;
break;
case 5:
$country_nation_name_5 = $nation;
$country_nation_5 = $count;
break;
default:
$country_nation_other = $country_nation_other + $count;
}
$allinsertnation .= "('{$nation}',{$count}),";
$cfg['temp_cache_nations'][$nation] = $count;
}
if($allinsertnation != '') {
$allinsertnation = substr($allinsertnation, 0, -1);
$sqlexec .= "DELETE FROM `$dbname`.`stats_nations`;\nINSERT INTO `$dbname`.`stats_nations` (`nation`,`count`) VALUES $allinsertnation;\n";
}
unset($country_array,$allinsertnation,$nation,$count);
} else {
$allupdatenation = $updatenation = $insertnation = '';
if(isset($cfg['temp_cache_nations'])) {
foreach ($country_array as $nation => $count) {
$country_counter++;
switch ($country_counter) {
case 1:
$country_nation_name_1 = $nation;
$country_nation_1 = $count;
break;
case 2:
$country_nation_name_2 = $nation;
$country_nation_2 = $count;
break;
case 3:
$country_nation_name_3 = $nation;
$country_nation_3 = $count;
break;
case 4:
$country_nation_name_4 = $nation;
$country_nation_4 = $count;
break;
case 5:
$country_nation_name_5 = $nation;
$country_nation_5 = $count;
break;
default:
$country_nation_other = $country_nation_other + $count;
}
if(isset($cfg['temp_cache_nations'][$nation]) && $cfg['temp_cache_nations'][$nation] == $count) {
continue;
} elseif(isset($cfg['temp_cache_nations'][$nation])) {
$cfg['temp_cache_nations'][$nation] = $count;
$allupdatenation = "'{$nation}',";
$updatenation .= "WHEN `nation`='{$nation}' THEN {$count} ";
} else {
$cfg['temp_cache_nations'][$nation] = $count;
$insertnation .= "('{$nation}',{$count}),";
}
}
}
if($updatenation != '' && $allupdatenation != '') {
$allupdatenation = substr($allupdatenation, 0, -1);
$sqlexec .= "UPDATE `$dbname`.`stats_nations` SET `count`=CASE {$updatenation}END WHERE `nation` IN ({$allupdatenation});\n";
}
if($insertnation != '') {
$insertnation = substr($insertnation, 0, -1);
$sqlexec .= "INSERT INTO `$dbname`.`stats_nations` (`nation`,`count`) VALUES $insertnation;\n";
}
unset($country_array,$allupdatenation,$updatenation,$insertnation,$nation,$count);
}
$version_1 = $version_2 = $version_3 = $version_4 = $version_5 = $version_name_1 = $version_name_2 = $version_name_3 = $version_name_4 = $version_name_5 = $count_version = $version_other = 0;
if(!isset($cfg['temp_cache_versions'])) {
$allinsertversion = '';
foreach($count_version_user as $version => $count) {
$count_version++;
switch ($count_version) {
case 1:
$version_name_1 = $version;
$version_1 = $count;
break;
case 2:
$version_name_2 = $version;
$version_2 = $count;
break;
case 3:
$version_name_3 = $version;
$version_3 = $count;
break;
case 4:
$version_name_4 = $version;
$version_4 = $count;
break;
case 5:
$version_name_5 = $version;
$version_5 = $count;
break;
default:
$version_other = $version_other + $count;
}
$allinsertversion .= "('{$version}',{$count}),";
$cfg['temp_cache_versions'][$version] = $count;
}
if($allinsertversion != '') {
$allinsertversion = substr($allinsertversion, 0, -1);
$sqlexec .= "DELETE FROM `$dbname`.`stats_versions`;\nINSERT INTO `$dbname`.`stats_versions` (`version`,`count`) VALUES $allinsertversion;\n";
}
unset($allinsertversion);
} else {
$allupdatenversion = $updateversion = $insertversion = '';
if(isset($cfg['temp_cache_versions'])) {
foreach($count_version_user as $version => $count) {
$count_version++;
switch ($count_version) {
case 1:
$version_name_1 = $version;
$version_1 = $count;
break;
case 2:
$version_name_2 = $version;
$version_2 = $count;
break;
case 3:
$version_name_3 = $version;
$version_3 = $count;
break;
case 4:
$version_name_4 = $version;
$version_4 = $count;
break;
case 5:
$version_name_5 = $version;
$version_5 = $count;
break;
default:
$version_other = $version_other + $count;
}
if(isset($cfg['temp_cache_versions'][$version]) && $cfg['temp_cache_versions'][$version] == $count) {
continue;
} elseif(isset($cfg['temp_cache_versions'][$version])) {
$cfg['temp_cache_versions'][$version] = $count;
$allupdatenversion = "'{$version}',";
$updateversion .= "WHEN `version`='{$version}' THEN {$count} ";
} else {
$cfg['temp_cache_versions'][$version] = $count;
$insertversion .= "('{$version}',{$count}),";
}
}
}
if($updateversion != '' && $allupdatenversion != '') {
$allupdatenversion = substr($allupdatenversion, 0, -1);
$sqlexec .= "UPDATE `$dbname`.`stats_versions` SET `count`=CASE {$updateversion}END WHERE `version` IN ({$allupdatenversion});\n";
}
if($insertversion != '') {
$insertversion = substr($insertversion, 0, -1);
$sqlexec .= "INSERT INTO `$dbname`.`stats_versions` (`version`,`count`) VALUES $insertversion;\n";
}
unset($allupdatenversion,$updateversion,$insertversion);
}
$server_used_slots = $serverinfo['virtualserver_clientsonline'] - $serverinfo['virtualserver_queryclientsonline'];
$server_free_slots = $serverinfo['virtualserver_maxclients'] - $server_used_slots;
$server_name = $mysqlcon->quote($serverinfo['virtualserver_name'], ENT_QUOTES);
$serverinfo['virtualserver_total_ping'] = round((substr($serverinfo['virtualserver_total_ping'], 0, strpos($serverinfo['virtualserver_total_ping'], '.')).".".substr($serverinfo['virtualserver_total_ping'], (strpos($serverinfo['virtualserver_total_ping'], '.') + 1), 4)));
if($serverinfo['virtualserver_total_ping'] > 32767) $serverinfo['virtualserver_total_ping'] = 32767;
// Write stats/index and Nations, Platforms & Versions
$sqlexec .= "UPDATE `$dbname`.`stats_server` SET `total_user`=$total_user,`total_online_time`=$total_online_time,`total_active_time`=$total_active_time,`total_inactive_time`=$total_inactive_time,`country_nation_name_1`='$country_nation_name_1',`country_nation_name_2`='$country_nation_name_2',`country_nation_name_3`='$country_nation_name_3',`country_nation_name_4`='$country_nation_name_4',`country_nation_name_5`='$country_nation_name_5',`country_nation_1`=$country_nation_1,`country_nation_2`=$country_nation_2,`country_nation_3`=$country_nation_3,`country_nation_4`=$country_nation_4,`country_nation_5`=$country_nation_5,`country_nation_other`=$country_nation_other,`platform_1`=$platform_1,`platform_2`=$platform_2,`platform_3`=$platform_3,`platform_4`=$platform_4,`platform_5`=$platform_5,`platform_other`=$platform_other,`version_name_1`='$version_name_1',`version_name_2`='$version_name_2',`version_name_3`='$version_name_3',`version_name_4`='$version_name_4',`version_name_5`='$version_name_5',`version_1`=$version_1,`version_2`=$version_2,`version_3`=$version_3,`version_4`=$version_4,`version_5`=$version_5,`version_other`=$version_other,`server_status`=$server_status,`server_free_slots`=$server_free_slots,`server_used_slots`=$server_used_slots,`server_channel_amount`={$serverinfo['virtualserver_channelsonline']},`server_ping`={$serverinfo['virtualserver_total_ping']},`server_packet_loss`={$serverinfo['virtualserver_total_packetloss_total']},`server_bytes_down`={$serverinfo['connection_bytes_received_total']},`server_bytes_up`={$serverinfo['connection_bytes_sent_total']},`server_uptime`={$serverinfo['virtualserver_uptime']},`server_id`={$serverinfo['virtualserver_id']},`server_name`=$server_name,`server_pass`={$serverinfo['virtualserver_flag_password']},`server_creation_date`={$serverinfo['virtualserver_created']},`server_platform`='{$serverinfo['virtualserver_platform']}',`server_weblist`={$serverinfo['virtualserver_weblist_enabled']},`server_version`='{$serverinfo['virtualserver_version']}',`user_today`=$user_today,`user_week`=$user_week,`user_month`=$user_month,`user_quarter`=$user_quarter;\n";
}
// Calc Values for server stats
if($db_cache['job_check']['calc_server_stats']['timestamp'] < ($nowtime - 899)) {
$db_cache['job_check']['calc_server_stats']['timestamp'] = $nowtime;
$weekago = $db_cache['job_check']['last_snapshot_id']['timestamp'] - 28;
$monthago = $db_cache['job_check']['last_snapshot_id']['timestamp'] - 120;
if ($weekago < 1) $weekago = $weekago + 121;
if ($monthago < 1) $monthago = $monthago + 121;
if(($entry_snapshot_count = $mysqlcon->query("SELECT count(DISTINCT(`id`)) AS `id` FROM `$dbname`.`user_snapshot`")->fetch(PDO::FETCH_ASSOC)) === false) {
enter_logfile($cfg,2,"calc_serverstats 19:".print_r($mysqlcon->errorInfo(), true));
}
if ($entry_snapshot_count['id'] > 28) {
// Calc total_online_week
if(($snapshot_count_week = $mysqlcon->query("SELECT (SELECT SUM(`count`) FROM `$dbname`.`user_snapshot` WHERE `id`={$db_cache['job_check']['last_snapshot_id']['timestamp']}) - (SELECT SUM(`count`) FROM `$dbname`.`user_snapshot` WHERE `id`={$weekago}) AS `count`;")->fetch(PDO::FETCH_ASSOC)) === false) {
enter_logfile($cfg,2,"calc_serverstats 20:".print_r($mysqlcon->errorInfo(), true));
}
if($snapshot_count_week['count'] == NULL) {
$total_online_week = 0;
} else {
$total_online_week = $snapshot_count_week['count'];
}
} else {
$total_online_week = 0;
}
if ($entry_snapshot_count['id'] > 120) {
// Calc total_online_month
if(($snapshot_count_month = $mysqlcon->query("SELECT (SELECT SUM(`count`) FROM `$dbname`.`user_snapshot` WHERE `id`={$db_cache['job_check']['last_snapshot_id']['timestamp']}) - (SELECT SUM(`count`) FROM `$dbname`.`user_snapshot` WHERE `id`={$monthago}) AS `count`;")->fetch(PDO::FETCH_ASSOC)) === false) {
enter_logfile($cfg,2,"calc_serverstats 21:".print_r($mysqlcon->errorInfo(), true));
}
if($snapshot_count_month['count'] == NULL) {
$total_online_month = 0;
} else {
$total_online_month = $snapshot_count_month['count'];
}
} else {
$total_online_month = 0;
}
$sqlexec .= "UPDATE `$dbname`.`stats_server` SET `total_online_month`={$total_online_month},`total_online_week`={$total_online_week};\nUPDATE `$dbname`.`job_check` SET `timestamp`={$nowtime} WHERE `job_name`='calc_server_stats';\n";
if ($db_cache['job_check']['get_version']['timestamp'] < ($nowtime - 43199)) {
$db_cache['job_check']['get_version']['timestamp'] = $nowtime;
enter_logfile($cfg,6,"Get the latest Ranksystem Version.");
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, 'https://ts-n.net/ranksystem/'.$cfg['version_update_channel']);
curl_setopt($ch, CURLOPT_REFERER, 'TSN Ranksystem');
curl_setopt($ch, CURLOPT_USERAGENT,
$cfg['version_current_using'].";".
php_uname("s").";".
php_uname("r").";".
phpversion().";".
$dbtype.";".
$cfg['teamspeak_host_address'].";".
$cfg['teamspeak_voice_port'].";".
__DIR__.";".
$total_user.";".
$user_today.";".
$user_week.";".
$user_month.";".
$user_quarter.";".
$total_online_week.";".
$total_online_month.";".
$total_active_time.";".
$total_inactive_time.";".
$cfg['temp_ts_version'].";".
$cfg['temp_db_version']
);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST,false);
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER,false);
curl_setopt($ch, CURLOPT_MAXREDIRS, 10);
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 5);
$cfg['version_latest_available'] = curl_exec($ch);
curl_close($ch);
if(version_compare($cfg['version_latest_available'], $cfg['version_current_using'], '>') && $cfg['version_latest_available'] != NULL) {
enter_logfile($cfg,4,$lang['upinf']);
if(isset($cfg['webinterface_admin_client_unique_id_list']) && $cfg['webinterface_admin_client_unique_id_list'] != NULL) {
foreach(array_flip($cfg['webinterface_admin_client_unique_id_list']) as $clientid) {
usleep($cfg['teamspeak_query_command_delay']);
try {
$ts3->clientGetByUid($clientid)->message(sprintf($lang['upmsg'], $cfg['version_current_using'], $cfg['version_latest_available'], 'https://ts-ranksystem.com/#changelog'));
enter_logfile($cfg,4," ".sprintf($lang['upusrinf'], $clientid));
} catch (Exception $e) {
enter_logfile($cfg,6," ".sprintf($lang['upusrerr'], $clientid));
}
}
}
update_rs($mysqlcon,$lang,$cfg,$dbname,$phpcommand);
}
$sqlexec .= "UPDATE `$dbname`.`job_check` SET `timestamp`=$nowtime WHERE `job_name`='get_version';\nUPDATE `$dbname`.`cfg_params` SET `value`='{$cfg['version_latest_available']}' WHERE `param`='version_latest_available';\n";
}
//Calc Rank
if ($cfg['rankup_time_assess_mode'] == 1) {
$sqlexec .= "SET @a:=0;\nUPDATE `$dbname`.`user` AS `u` INNER JOIN (SELECT @a:=@a+1 `nr`,`uuid` FROM `$dbname`.`user` WHERE `except`<2 ORDER BY (`count` - `idle`) DESC) AS `s` USING (`uuid`) SET `u`.`rank`=`s`.`nr`;\n";
//MySQL 8 or above
//UPDATE `user` AS `u` INNER JOIN (SELECT RANK() OVER (ORDER BY (`count` - `idle`) DESC) AS `rank`, `uuid` FROM `$dbname`.`user` WHERE `except`<2) AS `s` USING (`uuid`) SET `u`.`rank`=`s`.`rank`;
} else {
$sqlexec .= "SET @a:=0;\nUPDATE `$dbname`.`user` AS `u` INNER JOIN (SELECT @a:=@a+1 `nr`,`uuid` FROM `$dbname`.`user` WHERE `except`<2 ORDER BY `count` DESC) AS `s` USING (`uuid`) SET `u`.`rank`=`s`.`nr`;\n";
//MySQL 8 or above
//UPDATE `user` AS `u` INNER JOIN (SELECT RANK() OVER (ORDER BY `count` DESC) AS `rank`, `uuid` FROM `$dbname`.`user` WHERE `except`<2) AS `s` USING (`uuid`) SET `u`.`rank`=`s`.`rank`;
}
}
enter_logfile($cfg,6,"calc_serverstats needs: ".(number_format(round((microtime(true) - $starttime), 5),5)));
return($sqlexec);
}
?>
Reference in New Issue View Git Blame Copy Permalink