Skip to content

Commit

Permalink
release 1.3.9
Browse files Browse the repository at this point in the history
  • Loading branch information
@Newcomer1989
Newcomer1989 committed Aug 3, 2020
1 parent 2336177 commit d196dfb
Show file tree
Hide file tree
Showing 62 changed files with 3,718 additions and 4,198 deletions.
272 changes: 229 additions & 43 deletions api/index.php
View file

Large diffs are not rendered by default.

105 changes: 60 additions & 45 deletions install.php
View file

Large diffs are not rendered by default.

12 changes: 6 additions & 6 deletions jobs/addon_assign_groups.php
View file
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
<?PHP
function addon_assign_groups($addons_config,$ts3,$cfg,$dbname,$allclients,$select_arr) {
function addon_assign_groups($addons_config,$ts3,$cfg,$dbname,$allclients,&$db_cache) {
$sqlexec = '';

if(isset($select_arr['addon_assign_groups']) && count($select_arr['addon_assign_groups']) != 0) {
foreach($select_arr['addon_assign_groups'] as $uuid => $value) {
if(isset($db_cache['addon_assign_groups']) && count($db_cache['addon_assign_groups']) != 0) {
foreach($db_cache['addon_assign_groups'] as $uuid => $value) {
$cld_groups = explode(',', $value['grpids']);
foreach($cld_groups as $group) {
foreach ($allclients as $client) {
Expand All @@ -30,15 +30,15 @@ function addon_assign_groups($addons_config,$ts3,$cfg,$dbname,$allclients,$selec
usleep($cfg['teamspeak_query_command_delay']);
$ts3->serverGroupClientAdd($group, $cldbid);
enter_logfile($cfg,6,"Added servergroup $group from user $nickname (UID: $uid), requested by Add-on 'Assign Servergroups'");
}
catch (Exception $e) {
} catch (Exception $e) {
enter_logfile($cfg,2,"addon_assign_groups:".$e->getCode().': '."Error while adding group: ".$e->getMessage());
}
}
}
}
}
$sqlexec .= "DELETE FROM `$dbname`.`addon_assign_groups`; ";
$sqlexec .= "DELETE FROM `$dbname`.`addon_assign_groups`;\n";
unset($db_cache['addon_assign_groups']);
}
return $sqlexec;
}
Expand Down
214 changes: 116 additions & 98 deletions jobs/bot.php
View file
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,6 @@
$memory_limit = "{none set}";
}
set_time_limit(0);
error_reporting(0);

function shutdown($mysqlcon = NULL,$cfg,$loglevel,$reason,$nodestroypid = TRUE) {
if($nodestroypid === TRUE) {
Expand All @@ -33,26 +32,13 @@ function enter_logfile($cfg,$loglevel,$logtext,$norotate = false) {
if($loglevel!=9 && $loglevel > $cfg['logs_debug_level']) return;
$file = $cfg['logs_path'].'ranksystem.log';
switch ($loglevel) {
case 1:
$loglevel = " CRITICAL ";
break;
case 2:
$loglevel = " ERROR ";
break;
case 3:
$loglevel = " WARNING ";
break;
case 4:
$loglevel = " NOTICE ";
break;
case 5:
$loglevel = " INFO ";
break;
case 6:
$loglevel = " DEBUG ";
break;
default:
$loglevel = " NONE ";
case 1: $loglevel = " CRITICAL "; break;
case 2: $loglevel = " ERROR "; break;
case 3: $loglevel = " WARNING "; break;
case 4: $loglevel = " NOTICE "; break;
case 5: $loglevel = " INFO "; break;
case 6: $loglevel = " DEBUG "; break;
default:$loglevel = " NONE ";
}
$loghandle = fopen($file, 'a');
fwrite($loghandle, DateTime::createFromFormat('U.u', number_format(microtime(true), 6, '.', ''))->setTimeZone(new DateTimeZone($cfg['logs_timezone']))->format("Y-m-d H:i:s.u ").$loglevel.$logtext."\n");
Expand Down Expand Up @@ -103,6 +89,8 @@ function enter_logfile($cfg,$loglevel,$logtext,$norotate = false) {
require_once(substr(__DIR__,0,-4).'jobs/get_avatars.php');
require_once(substr(__DIR__,0,-4).'jobs/update_groups.php');
require_once(substr(__DIR__,0,-4).'jobs/calc_serverstats.php');
require_once(substr(__DIR__,0,-4).'jobs/server_usage.php');
require_once(substr(__DIR__,0,-4).'jobs/calc_user_snapshot.php');
require_once(substr(__DIR__,0,-4).'jobs/calc_userstats.php');
require_once(substr(__DIR__,0,-4).'jobs/clean.php');
require_once(substr(__DIR__,0,-4).'jobs/check_db.php');
Expand Down Expand Up @@ -221,8 +209,8 @@ function run_bot() {
enter_logfile($cfg,2," Error due getting TS3 server version - ".$e->getCode().': '.$e->getMessage());
}

if(version_compare($ts3version['version'],'3.6.9','=<')) {
enter_logfile($cfg,3," Your TS3 server is outdated, please update it.. also to be ready for TS5!");
if(version_compare($ts3version['version'],'3.11.9','<=')) {
enter_logfile($cfg,3," Your TS3 server is outdated, please update it!");
}

enter_logfile($cfg,9," Select virtual server...");
Expand Down Expand Up @@ -304,7 +292,7 @@ function run_bot() {
$loglevel = "6 - DEBUG";
break;
default:
$loglevel = "UNKOWN";
$loglevel = "UNKNOWN";
}
enter_logfile($cfg,9," Log Level: ".$loglevel);
enter_logfile($cfg,6," Serverside config 'max_execution_time' (PHP.ini): ".$max_execution_time." sec.");
Expand Down Expand Up @@ -348,11 +336,12 @@ function run_bot() {

$serverinfo = $ts3server->serverInfo();
$select_arr = array();
$sqlexec2 .= update_groups($ts3server,$mysqlcon,$lang,$cfg,$dbname,$serverinfo,$select_arr,1);
$db_cache = array();
$sqlexec2 .= update_groups($ts3server,$mysqlcon,$lang,$cfg,$dbname,$serverinfo,$db_cache,1);
if($mysqlcon->exec($sqlexec2) === false) {
enter_logfile($cfg,2,"Executing SQL commands failed: ".print_r($mysqlcon->errorInfo(), true));
}
unset($sqlexec2,$select_arr,$groupslist,$serverinfo,$ts3version);
unset($sqlexec2,$select_arr,$db_cache,$groupslist,$serverinfo,$ts3version);
$errcnf = 0;
enter_logfile($cfg,4," Downloading of servergroups finished. Recheck the config.");

Expand Down Expand Up @@ -402,115 +391,144 @@ function run_bot() {
}
}
}

if($cfg['webinterface_fresh_installation'] == 1) {
if($mysqlcon->exec("UPDATE `$dbname`.`cfg_params` SET `value`=0 WHERE `param`='webinterface_fresh_installation'") === false) {
enter_logfile($cfg,2,"Executing SQL commands failed: ".print_r($mysqlcon->errorInfo(), true));
}
}

unset($groupslist,$errcnf,$checkgroups,$lastupdate,$updcld,$loglevel,$whoami,$ts3host,$max_execution_time,$memory_limit,$memory_limit);
enter_logfile($cfg,9,"Config check [done]");

enter_logfile($cfg,9,"Bot starts now his work!");
$looptime = $cfg['temp_count_laps'] = $cfg['temp_whole_laptime'] = $cfg['temp_count_laptime'] = 0; $cfg['temp_last_laptime'] = '';
usleep(3000000);

if(($get_db_data = $mysqlcon->query("SELECT * FROM `$dbname`.`user`; SELECT MAX(`timestamp`) AS `timestamp` FROM `$dbname`.`server_usage`; SELECT * FROM `$dbname`.`job_check`; SELECT * FROM `$dbname`.`groups`; SELECT * FROM `$dbname`.`addon_assign_groups`; SELECT * FROM `$dbname`.`admin_addtime`; ")) === false) {
shutdown($mysqlcon,$cfg,1,"Select on DB failed: ".print_r($mysqlcon->errorInfo(), true));
}

$count_select = 0;
$db_cache = array();
while($single_select = $get_db_data) {
$fetched_array = $single_select->fetchAll(PDO::FETCH_UNIQUE|PDO::FETCH_ASSOC);
$count_select++;

switch ($count_select) {
case 1:
$db_cache['all_user'] = $fetched_array;
break;
case 2:
$db_cache['max_timestamp_server_usage'] = $fetched_array;
break;
case 3:
$db_cache['job_check'] = $fetched_array;
break;
case 4:
$db_cache['groups'] = $fetched_array;
break;
case 5:
$db_cache['addon_assign_groups'] = $fetched_array;
break;
case 6:
$db_cache['admin_addtime'] = $fetched_array;
break 2;
}
$get_db_data->nextRowset();
}
unset($get_db_data,$fetched_array,$single_select);

$addons_config = load_addons_config($mysqlcon,$lang,$cfg,$dbname);

while(1) {
$sqlexec = '';
$starttime = microtime(true);

if(($get_db_data = $mysqlcon->query("SELECT * FROM `$dbname`.`user`; SELECT `version`, COUNT(`version`) AS `count` FROM `$dbname`.`user` GROUP BY `version` ORDER BY `count` DESC; SELECT MAX(`timestamp`) AS `timestamp` FROM `$dbname`.`server_usage`; SELECT * FROM `$dbname`.`job_check`; SELECT `uuid` FROM `$dbname`.`stats_user`; SELECT * FROM `$dbname`.`groups`; SELECT * FROM `$dbname`.`addon_assign_groups`; SELECT * FROM `$dbname`.`admin_addtime`; ")) === false) {
shutdown($mysqlcon,$cfg,1,"Select on DB failed: ".print_r($mysqlcon->errorInfo(), true));
}

$count_select = 0;
$select_arr = array();
while($single_select = $get_db_data) {
$fetched_array = $single_select->fetchAll(PDO::FETCH_UNIQUE|PDO::FETCH_ASSOC);
$count_select++;
unset($db_cache['job_check']);
if(($db_cache['job_check'] = $mysqlcon->query("SELECT * FROM `$dbname`.`job_check`")->fetchAll(PDO::FETCH_UNIQUE|PDO::FETCH_ASSOC)) === false) {
enter_logfile($cfg,3," Select on DB failed for job check: ".print_r($mysqlcon->errorInfo(), true));
}

if($db_cache['job_check']['reload_trigger']['timestamp'] == 1) {
unset($db_cache['addon_assign_groups'],$db_cache['admin_addtime']);
if(($get_db_data = $mysqlcon->query("SELECT * FROM `$dbname`.`addon_assign_groups`; SELECT * FROM `$dbname`.`admin_addtime`;")) === false) {
shutdown($mysqlcon,$cfg,1,"Select on DB failed: ".print_r($mysqlcon->errorInfo(), true));
}

switch ($count_select) {
case 1:
$select_arr['all_user'] = $fetched_array;
break;
case 2:
$select_arr['count_version_user'] = $fetched_array;
break;
case 3:
$select_arr['max_timestamp_server_usage'] = $fetched_array;
break;
case 4:
$select_arr['job_check'] = $fetched_array;
break;
case 5:
$select_arr['uuid_stats_user'] = $fetched_array;
break;
case 6:
$select_arr['groups'] = $fetched_array;
break;
case 7:
$select_arr['addon_assign_groups'] = $fetched_array;
break;
case 8:
$select_arr['admin_addtime'] = $fetched_array;
break 2;
$count_select = 0;
while($single_select = $get_db_data) {
$fetched_array = $single_select->fetchAll(PDO::FETCH_UNIQUE|PDO::FETCH_ASSOC);
$count_select++;

switch ($count_select) {
case 1:
$db_cache['addon_assign_groups'] = $fetched_array;
break;
case 2:
$db_cache['admin_addtime'] = $fetched_array;
break 2;
}
$get_db_data->nextRowset();
}
$get_db_data->nextRowset();
unset($get_db_data,$fetched_array,$single_select,$count_select);
$db_cache['job_check']['reload_trigger']['timestamp'] = 0;
$sqlexec .= "UPDATE `$dbname`.`job_check` SET `timestamp`=0 WHERE `job_name`='reload_trigger';\n";
}
unset($get_db_data,$fetched_array,$single_select);
enter_logfile($cfg,6,"SQL select needs: ".(number_format(round((microtime(true) - $starttime), 5),5)));

enter_logfile($cfg,6,"SQL Select needs: ".(number_format(round((microtime(true) - $starttime), 5),5)));

check_shutdown($cfg);
$addons_config = load_addons_config($mysqlcon,$lang,$cfg,$dbname);

$ts3server->clientListReset();
usleep($cfg['teamspeak_query_command_delay']);
$allclients = $ts3server->clientList();
$allclients = $ts3server->clientListtsn("-uid -groups -times -info -country");
usleep($cfg['teamspeak_query_command_delay']);
$ts3server->serverInfoReset();
usleep($cfg['teamspeak_query_command_delay']);
$serverinfo = $ts3server->serverInfo();
$sqlexec .= calc_user($ts3server,$mysqlcon,$lang,$cfg,$dbname,$allclients,$phpcommand,$select_arr);
get_avatars($ts3server,$cfg);
$sqlexec .= clean($ts3server,$mysqlcon,$lang,$cfg,$dbname,$select_arr);
$sqlexec .= calc_serverstats($ts3server,$mysqlcon,$cfg,$dbname,$dbtype,$serverinfo,$select_arr,$phpcommand,$lang);
$sqlexec .= calc_userstats($ts3server,$mysqlcon,$cfg,$dbname,$select_arr);
$sqlexec .= update_groups($ts3server,$mysqlcon,$lang,$cfg,$dbname,$serverinfo,$select_arr);
usleep($cfg['teamspeak_query_command_delay']);

$sqlexec .= calc_user($ts3server,$mysqlcon,$lang,$cfg,$dbname,$allclients,$phpcommand,$db_cache);
$sqlexec .= calc_userstats($ts3server,$mysqlcon,$cfg,$dbname,$db_cache);
$sqlexec .= get_avatars($ts3server,$cfg,$dbname,$db_cache);
$sqlexec .= clean($ts3server,$mysqlcon,$lang,$cfg,$dbname,$db_cache);
$sqlexec .= calc_serverstats($ts3server,$mysqlcon,$cfg,$dbname,$dbtype,$serverinfo,$db_cache,$phpcommand,$lang);
$sqlexec .= server_usage($mysqlcon,$cfg,$dbname,$serverinfo,$db_cache);
$sqlexec .= calc_user_snapshot($cfg,$dbname,$db_cache);
$sqlexec .= update_groups($ts3server,$mysqlcon,$lang,$cfg,$dbname,$serverinfo,$db_cache);

if($addons_config['assign_groups_active']['value'] == '1') {
if($cfg['temp_addon_assign_groups'] == "disabled") {
enter_logfile($cfg,5,"Loading new addon...");
enter_logfile($cfg,5," Addon: 'assign_groups' [ON]");
if(!function_exists('addon_assign_groups')) {
include(substr(__DIR__,0,-4).'jobs/addon_assign_groups.php');
}
$cfg['temp_addon_assign_groups'] = "enabled";
enter_logfile($cfg,5,"Loading new addon [done]");
}
$sqlexec .= addon_assign_groups($addons_config,$ts3server,$cfg,$dbname,$allclients,$select_arr);
} elseif ($cfg['temp_addon_assign_groups'] == "enabled") {
enter_logfile($cfg,5,"Disable addon...");
enter_logfile($cfg,5," Addon: 'assign_groups' [OFF]");
$cfg['temp_addon_assign_groups'] = "disabled";
enter_logfile($cfg,5,"Disable addon [done]");
$sqlexec .= addon_assign_groups($addons_config,$ts3server,$cfg,$dbname,$allclients,$db_cache);
}

$startsql = microtime(true);
if($mysqlcon->exec($sqlexec) === false) {
enter_logfile($cfg,2,"Executing SQL commands failed: ".print_r($mysqlcon->errorInfo(), true));
}
enter_logfile($cfg,6,"SQL exections needs: ".(number_format(round((microtime(true) - $startsql), 5),5)));
if($cfg['logs_debug_level'] > 5) {
$sqlexec = substr($sqlexec, 0, -1);
$sqlarr = explode(";\n", $sqlexec);
foreach($sqlarr as $singlesql) {
if(strpos($singlesql, 'UPDATE') !== false || strpos($singlesql, 'INSERT') !== false || strpos($singlesql, 'DELETE') !== false || strpos($singlesql, 'SET') !== false) {
if($mysqlcon->exec($singlesql) === false) {
enter_logfile($cfg,4,"Executing SQL: ".$singlesql);
enter_logfile($cfg,2,"Executing SQL commands failed: ".print_r($mysqlcon->errorInfo(), true));
}
} elseif(strpos($singlesql, ' ') === false) {
enter_logfile($cfg,2,"Command not recognized as SQL: ".$singlesql);
}
}
$sqlfile = $cfg['logs_path'].'temp_sql_dump.sql';
$sqldump = fopen($sqlfile, 'wa+');
fwrite($sqldump, DateTime::createFromFormat('U.u', number_format(microtime(true), 6, '.', ''))->setTimeZone(new DateTimeZone($cfg['logs_timezone']))->format("Y-m-d H:i:s.u ").' SQL: '.$sqlexec."\n");
fwrite($sqldump, DateTime::createFromFormat('U.u', number_format(microtime(true), 6, '.', ''))->setTimeZone(new DateTimeZone($cfg['logs_timezone']))->format("Y-m-d H:i:s.u ")." SQL:\n".$sqlexec);
fclose($sqldump);
} else {
if($mysqlcon->exec($sqlexec) === false) {
enter_logfile($cfg,2,"Executing SQL commands failed: ".print_r($mysqlcon->errorInfo(), true));
}
}
enter_logfile($cfg,6,"SQL executions needs: ".(number_format(round((microtime(true) - $startsql), 5),5)));

reset_rs($ts3server,$mysqlcon,$lang,$cfg,$dbname,$select_arr);
reset_rs($ts3server,$mysqlcon,$lang,$cfg,$dbname,$db_cache);

unset($sqlexec,$select_arr,$sqldump);

$looptime = microtime(true) - $starttime;
$cfg['temp_whole_laptime'] = $cfg['temp_whole_laptime'] + $looptime;
$cfg['temp_count_laptime']++;
Expand Down
Loading

0 comments on commit d196dfb

Please sign in to comment.