arriej/TSN-Ranksystem
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Files
ce3c88d8336a181d5e086c855b0be360bcd93314
TSN-Ranksystem/jobs/bot.php
Newcomer1989 ce3c88d833 release 1.2.11
2018-09-27 19:24:17 +02:00

432 lines
20 KiB
PHP
Raw Blame History

#!/usr/bin/php
<?PHP
set_time_limit(0);
ini_set('default_charset', 'UTF-8');
setlocale(LC_ALL, 'UTF-8');
error_reporting(0);
function shutdown($mysqlcon = NULL, $logpath, $timezone, $loglevel, $reason, $nodestroypid = TRUE) {
if($nodestroypid === TRUE) {
if (file_exists(substr(__DIR__,0,-4).'logs/pid')) {
unlink(substr(__DIR__,0,-4).'logs/pid');
}
}
enter_logfile($logpath,$timezone,$loglevel,$reason." Shutting down!");
if(isset($mysqlcon)) {
$mysqlcon->close();
}
exit;
}
function enter_logfile($logpath,$timezone,$loglevel,$logtext,$norotate = false) {
global $phpcommand;
$file = $logpath.'ranksystem.log';
if ($loglevel == 1) {
$loglevel = " CRITICAL ";
} elseif ($loglevel == 2) {
$loglevel = " ERROR ";
} elseif ($loglevel == 3) {
$loglevel = " WARNING ";
} elseif ($loglevel == 4) {
$loglevel = " NOTICE ";
} elseif ($loglevel == 5) {
$loglevel = " INFO ";
} elseif ($loglevel == 6) {
$loglevel = " DEBUG ";
}
$loghandle = fopen($file, 'a');
fwrite($loghandle, DateTime::createFromFormat('U.u', number_format(microtime(true), 6, '.', ''))->setTimeZone(new DateTimeZone($timezone))->format("Y-m-d H:i:s.u ").$loglevel.$logtext."\n");
fclose($loghandle);
if($norotate == false && filesize($file) > 5242880) {
$loghandle = fopen($file, 'a');
fwrite($loghandle, DateTime::createFromFormat('U.u', number_format(microtime(true), 6, '.', ''))->setTimeZone(new DateTimeZone($timezone))->format("Y-m-d H:i:s.u ")." NOTICE Logfile filesie of 5 MiB reached.. Rotate logfile.\n");
fclose($loghandle);
$file2 = "$file.old";
if (file_exists($file2)) {
unlink($file2);
}
rename($file, $file2);
$loghandle = fopen($file, 'a');
fwrite($loghandle, DateTime::createFromFormat('U.u', number_format(microtime(true), 6, '.', ''))->setTimeZone(new DateTimeZone($timezone))->format("Y-m-d H:i:s.u ")." NOTICE Rotated logfile...\n");
fclose($loghandle);
}
}
require_once(substr(__DIR__,0,-4).'other/config.php');
require_once(substr(__DIR__,0,-4).'other/phpcommand.php');
if(isset($_SERVER['HTTP_HOST']) || isset($_SERVER['REMOTE_ADDR'])) {
shutdown($mysqlcon, $logpath, $timezone, 1, "Request to start the Ranksystem from ".$_SERVER['REMOTE_ADDR'].". It seems the request came not from the command line!");
}
if(version_compare(phpversion(), '5.5.0', '<')) {
shutdown($mysqlcon, $logpath, $timezone, 1, "Your PHP version (".phpversion().") is below 5.5.0. Update of PHP is required!");
}
if(!function_exists('simplexml_load_file')) {
shutdown($mysqlcon, $logpath, $timezone, 1, "SimpleXML is missed. Installation of SimpleXML is required!");
}
if(!in_array('curl', get_loaded_extensions())) {
shutdown($mysqlcon, $logpath, $timezone, 1, "PHP cURL is missed. Installation of PHP cURL is required!");
}
if(!in_array('zip', get_loaded_extensions())) {
shutdown($mysqlcon, $logpath, $timezone, 1, "PHP Zip is missed. Installation of PHP Zip is required!");
}
if(!in_array('ssh2', get_loaded_extensions()) && $ts['tsencrypt'] == 1) {
shutdown($mysqlcon, $logpath, $timezone, 1, "PHP SSH2 is missed. Installation of PHP SSH2 is required, when using secured (SSH) connection to TeamSpeak! If you are not able to install PHP SSH2 (i.e. hosted webspace), you need to deactivate the TS3 Query encryption inside the Webinterface.");
}
enter_logfile($logpath,$timezone,5,"###################################################################");
enter_logfile($logpath,$timezone,5,"");
enter_logfile($logpath,$timezone,5,"###################################################################");
enter_logfile($logpath,$timezone,5,"Initialize Bot...");
require_once(substr(__DIR__,0,-4).'libs/ts3_lib/TeamSpeak3.php');
require_once(substr(__DIR__,0,-4).'jobs/calc_user.php');
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/calc_userstats.php');
require_once(substr(__DIR__,0,-4).'jobs/clean.php');
require_once(substr(__DIR__,0,-4).'jobs/check_db.php');
require_once(substr(__DIR__,0,-4).'jobs/handle_messages.php');
require_once(substr(__DIR__,0,-4).'jobs/event_userenter.php');
require_once(substr(__DIR__,0,-4).'jobs/update_rs.php');
enter_logfile($logpath,$timezone,6,"Running on OS: ".php_uname("s")." ".php_uname("r"));
enter_logfile($logpath,$timezone,6,"Using PHP Version: ".phpversion());
enter_logfile($logpath,$timezone,6,"Database Version: ".$mysqlcon->getAttribute(PDO::ATTR_SERVER_VERSION));
$currvers = check_db($mysqlcon,$lang,$dbname,$timezone,$currvers,$logpath);
enter_logfile($logpath,$timezone,5,"Check Ranksystem files for updates...");
if(isset($currvers) && isset($newversion) && $newversion != NULL && version_compare($newversion, $currvers, '>')) {
update_rs($mysqlcon,$lang,$dbname,$logpath,$timezone,$newversion,$phpcommand);
}
enter_logfile($logpath,$timezone,5,"Check Ranksystem files for updates [done]");
function check_shutdown($timezone,$logpath) {
if(!is_file(substr(__DIR__,0,-4).'logs/pid')) {
shutdown(NULL, $logpath, $timezone, 5, "Received signal to stop!");
}
}
enter_logfile($logpath,$timezone,5,"Ranksystem Version: ".$currvers);
enter_logfile($logpath,$timezone,5,"Loading addons...");
require_once(substr(__DIR__,0,-4).'other/load_addons_config.php');
$addons_config = load_addons_config($mysqlcon,$lang,$dbname,$timezone,$logpath);
if($addons_config['assign_groups_active']['value'] == '1') {
enter_logfile($logpath,$timezone,5," Addon: 'assign_groups' [ON]");
include(substr(__DIR__,0,-4).'jobs/addon_assign_groups.php');
define('assign_groups',1);
} else {
enter_logfile($logpath,$timezone,5," Addon: 'assign_groups' [OFF]");
}
enter_logfile($logpath,$timezone,5,"Loading addons [done]");
enter_logfile($logpath,$timezone,5,"Connect to TS3 Server (Address: \"".$ts['host']."\" Voice-Port: \"".$ts['voice']."\" Query-Port: \"".$ts['query']."\" SSH: \"".$ts['tsencrypt']."\").");
try {
if($ts['tsencrypt'] == 1) {
$ts3host = TeamSpeak3::factory("serverquery://".rawurlencode($ts['user']).":".rawurlencode($ts['pass'])."@".$ts['host'].":".$ts['query']."/?ssh=1");
} else {
$ts3host = TeamSpeak3::factory("serverquery://".rawurlencode($ts['user']).":".rawurlencode($ts['pass'])."@".$ts['host'].":".$ts['query']."/?blocking=0");
}
enter_logfile($logpath,$timezone,5,"Connection to TS3 Server established.");
try{
$ts3version = $ts3host->version();
enter_logfile($logpath,$timezone,5," TS3 Server version: ".$ts3version['version']." on ".$ts3version['platform']." [Build: ".$ts3version['build']." from ".date("Y-m-d H:i:s",$ts3version['build'])."]");
} catch (Exception $e) {
enter_logfile($logpath,$timezone,2," Error due getting TS3 server version - ".$e->getCode().': '.$e->getMessage());
}
enter_logfile($logpath,$timezone,5," Select virtual server...");
try {
if(version_compare($ts3version['version'],'3.4.0','>=')) {
usleep($slowmode);
$ts3server = $ts3host->serverGetByPort($ts['voice'], $queryname);
} else {
enter_logfile($logpath,$timezone,3," Your TS3 server is outdated, please update it!");
usleep($slowmode);
$ts3server = $ts3host->serverGetByPort($ts['voice']);
for ($updcld = 0; $updcld < 10; $updcld++) {
try {
usleep($slowmode);
if($updcld == 0) {
$ts3server->selfUpdate(array('client_nickname' => $queryname));
} else {
$ts3server->selfUpdate(array('client_nickname' => $queryname.$updcld));
}
break;
}
catch (Exception $e) {
enter_logfile($logpath,$timezone,3,' '.$lang['errorts3'].$e->getCode().': '.$e->getMessage());
}
}
}
enter_logfile($logpath,$timezone,5," Select virtual server [done]");
} catch (Exception $e) {
enter_logfile($logpath,$timezone,2," Error due selecting virtual server - ".$e->getCode().': '.$e->getMessage());
}
try {
usleep($slowmode);
$ts3server->notifyRegister("server");
$ts3server->notifyRegister("textprivate");
$ts3server->notifyRegister("textchannel");
$ts3server->notifyRegister("textserver");
TeamSpeak3_Helper_Signal::getInstance()->subscribe("notifyTextmessage", "handle_messages");
TeamSpeak3_Helper_Signal::getInstance()->subscribe("notifyCliententerview", "event_userenter");
} catch (Exception $e) {
enter_logfile($logpath,$timezone,2," Error due notifyRegister on TS3 server - ".$e->getCode().': '.$e->getMessage());
}
$whoami = $ts3server->whoami();
if($defchid != 0) {
try {
usleep($slowmode);
$ts3server->clientMove($whoami['client_id'],$defchid);
enter_logfile($logpath,$timezone,5," Joined to specified Channel.");
} catch (Exception $e) {
if($e->getCode() != 770) {
enter_logfile($logpath,$timezone,2," Could not join specified channel (Channel ID: ".$defchid.") - ".$e->getCode().': '.$e->getMessage());
} else {
enter_logfile($logpath,$timezone,5," Joined to specified channel (already member of it).");
}
}
} else {
enter_logfile($logpath,$timezone,4," No channel defined where the Ranksystem Bot should be entered.");
}
enter_logfile($logpath,$timezone,5,"Config check started...");
if(($groupslist = $mysqlcon->query("SELECT * FROM `$dbname`.`groups`")->fetchAll(PDO::FETCH_UNIQUE|PDO::FETCH_ASSOC)) === false) {
enter_logfile($logpath,$timezone,1," Select on DB failed for group check: ".print_r($mysqlcon->errorInfo(), true));
}
$checkgroups = 0;
if(isset($groupslist) && $groupslist != NULL) {
if(isset($grouptime) && $grouptime != NULL) {
foreach($grouptime as $time => $groupid) {
if(!isset($groupslist[$groupid]) && $groupid != NULL) {
$checkgroups++;
}
}
}
if(isset($boostarr) && $boostarr != NULL) {
foreach($boostarr as $groupid => $value) {
if(!isset($groupslist[$groupid]) && $groupid != NULL) {
$checkgroups++;
}
}
}
if(isset($exceptgroup) && $exceptgroup != NULL) {
foreach($exceptgroup as $groupid => $value) {
if(!isset($groupslist[$groupid]) && $groupid != NULL) {
$checkgroups++;
}
}
}
}
if($checkgroups > 0) {
enter_logfile($logpath,$timezone,4," Found servergroups in config, which are unknown. Redownload all servergroups from TS3 server.");
if($mysqlcon->exec("DELETE FROM groups;") === false) {
enter_logfile($logpath,$timezone,2," Executing SQL commands failed: ".print_r($mysqlcon->errorInfo(), true));
}
$nobreak = 1;
$sqlexec = '';
$serverinfo = $ts3server->serverInfo();
$select_arr = array();
$sqlexec .= update_groups($ts3server,$mysqlcon,$lang,$dbname,$slowmode,$timezone,$serverinfo,$logpath,$grouptime,$boostarr,$exceptgroup,$select_arr,$adminuuid,$nobreak);
if($mysqlcon->exec($sqlexec) === false) {
enter_logfile($logpath,$timezone,2,"Executing SQL commands failed: ".print_r($mysqlcon->errorInfo(), true));
}
unset($sqlexec, $select_arr, $groupslist);
$errcnf = 0;
enter_logfile($logpath,$timezone,4," Downloading of servergroups finished. Recheck the config.");
if(($groupslist = $mysqlcon->query("SELECT * FROM `$dbname`.`groups`")->fetchAll(PDO::FETCH_UNIQUE|PDO::FETCH_ASSOC)) === false) {
enter_logfile($logpath,$timezone,1," Select on DB failed for group check: ".print_r($mysqlcon->errorInfo(), true));
}
if(isset($groupslist) && $groupslist != NULL) {
if(isset($grouptime) && $grouptime != NULL) {
foreach($grouptime as $time => $groupid) {
if(!isset($groupslist[$groupid]) && $groupid != NULL) {
enter_logfile($logpath,$timezone,1,' '.sprintf($lang['upgrp0001'], $groupid, $lang['wigrptime']));
$errcnf++;
}
}
}
if(isset($boostarr) && $boostarr != NULL) {
foreach($boostarr as $groupid => $value) {
if(!isset($groupslist[$groupid]) && $groupid != NULL) {
enter_logfile($logpath,$timezone,2,' '.sprintf($lang['upgrp0001'], $groupid, $lang['wiboost']));
}
}
}
if(isset($exceptgroup) && $exceptgroup != NULL) {
foreach($exceptgroup as $groupid => $value) {
if(!isset($groupslist[$groupid]) && $groupid != NULL) {
enter_logfile($logpath,$timezone,2,' '.sprintf($lang['upgrp0001'], $groupid, $lang['wiexgrp']));
}
}
}
}
if($errcnf > 0) {
shutdown($mysqlcon, $logpath, $timezone, 1, "Critical Config error!");
} else {
enter_logfile($logpath,$timezone,4," No critical problems found! All seems to be fine...");
}
}
if(($lastupdate = $mysqlcon->query("SELECT `timestamp` FROM `$dbname`.`job_check` WHERE `job_name`='last_update'")->fetch()) === false) {
enter_logfile($logpath,$timezone,1," Select on DB failed for job check: ".print_r($mysqlcon->errorInfo(), true));
} else {
if($lastupdate['timestamp'] != 0 && ($lastupdate['timestamp'] + 10) > time()) {
if(isset($adminuuid) && $adminuuid != NULL) {
foreach ($adminuuid as $clientid) {
usleep($slowmode);
try {
$ts3server->clientGetByUid($clientid)->message(sprintf($lang['upmsg2'], $currvers));
enter_logfile($logpath,$timezone,4," ".sprintf($lang['upusrinf'], $clientid));
}
catch (Exception $e) {
enter_logfile($logpath,$timezone,6," ".sprintf($lang['upusrerr'], $clientid));
}
}
}
}
}
unset($groupslist,$errcnf,$checkgroups);
enter_logfile($logpath,$timezone,5,"Config check [done]");
enter_logfile($logpath,$timezone,5,"Bot starts now his work!");
$looptime = $rotated_cnt = 0; $rotated = '';
usleep(3000000);
while(1) {
$sqlexec = $sqlexec2 = '';
$starttime = microtime(true);
$weekago = time() - 604800;
$monthago = time() - 2592000;
if(($get_db_data = $mysqlcon->query("SELECT * FROM `$dbname`.`user`; SELECT MAX(`timestamp`) AS `timestamp` FROM `$dbname`.`user_snapshot`; 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 `timestamp` FROM `$dbname`.`user_snapshot` WHERE `timestamp`>$weekago ORDER BY `timestamp` ASC LIMIT 1; SELECT `timestamp` FROM `$dbname`.`user_snapshot` WHERE `timestamp`>$monthago ORDER BY `timestamp` ASC LIMIT 1; SELECT * FROM `$dbname`.`groups`; SELECT * FROM `$dbname`.`addon_assign_groups`; SELECT * FROM `$dbname`.`admin_addtime`; ")) === false) {
shutdown($mysqlcon, $logpath, $timezone, 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++;
switch ($count_select) {
case 1:
$select_arr['all_user'] = $fetched_array;
break;
case 2:
$select_arr['max_timestamp_user_snapshot'] = $fetched_array;
break;
case 3:
$select_arr['count_version_user'] = $fetched_array;
break;
case 4:
$select_arr['max_timestamp_server_usage'] = $fetched_array;
break;
case 5:
$select_arr['job_check'] = $fetched_array;
break;
case 6:
$select_arr['uuid_stats_user'] = $fetched_array;
break;
case 7:
$select_arr['usersnap_min_week'] = $fetched_array;
break;
case 8:
$select_arr['usersnap_min_month'] = $fetched_array;
break;
case 9:
$select_arr['groups'] = $fetched_array;
break;
case 10:
$select_arr['addon_assign_groups'] = $fetched_array;
break;
case 11:
$select_arr['admin_addtime'] = $fetched_array;
break 2;
}
$get_db_data->nextRowset();
}
unset($get_db_data, $fetched_array, $single_select);
check_shutdown($timezone,$logpath);
$addons_config = load_addons_config($mysqlcon,$lang,$dbname,$timezone,$logpath);
$ts3server->clientListReset();
usleep($slowmode);
$allclients = $ts3server->clientList();
$ts3server->serverInfoReset();
usleep($slowmode);
$serverinfo = $ts3server->serverInfo();
$sqlexec .= calc_user($ts3server,$mysqlcon,$lang,$dbname,$slowmode,$timezone,$grouptime,$boostarr,$resetbydbchange,$msgtouser,$currvers,$substridle,$exceptuuid,$exceptgroup,$allclients,$logpath,$rankupmsg,$ignoreidle,$exceptcid,$resetexcept,$phpcommand,$select_arr);
get_avatars($ts3server,$slowmode,$timezone,$logpath,$avatar_delay);
$sqlexec .= clean($ts3server,$mysqlcon,$lang,$dbname,$slowmode,$timezone,$cleanclients,$cleanperiod,$logpath,$select_arr);
$sqlexec .= calc_serverstats($ts3server,$mysqlcon,$dbname,$dbtype,$slowmode,$timezone,$serverinfo,$substridle,$grouptime,$logpath,$ts,$currvers,$upchannel,$select_arr,$phpcommand,$adminuuid);
$sqlexec .= calc_userstats($ts3server,$mysqlcon,$dbname,$slowmode,$timezone,$logpath,$select_arr);
$sqlexec .= update_groups($ts3server,$mysqlcon,$lang,$dbname,$slowmode,$timezone,$serverinfo,$logpath,$grouptime,$boostarr,$exceptgroup,$select_arr,$adminuuid);
$sqlexec .= $sqlexec2;
if($addons_config['assign_groups_active']['value'] == '1') {
if(!defined('assign_groups')) {
enter_logfile($logpath,$timezone,5,"Loading new addon...");
enter_logfile($logpath,$timezone,5," Addon: 'assign_groups' [ON]");
include(substr(__DIR__,0,-4).'jobs/addon_assign_groups.php');
define('assign_groups',1);
enter_logfile($logpath,$timezone,5,"Loading new addon [done]");
}
$sqlexec .= addon_assign_groups($addons_config,$ts3server,$dbname,$slowmode,$timezone,$logpath,$allclients,$select_arr);
}
if($mysqlcon->exec($sqlexec) === false) {
enter_logfile($logpath,$timezone,2,"Executing SQL commands failed: ".print_r($mysqlcon->errorInfo(), true));
}
unset($sqlexec, $sqlexec2, $select_arr);
$looptime = microtime(true) - $starttime;
$rotated = substr((number_format(round($looptime, 5),5) . ';' . $rotated),0,79);
if($looptime < 1) {
$loopsleep = (1 - $looptime) * 1000000;
#enter_logfile($logpath,$timezone,6,"last loop: ".round($looptime, 5)." sec.");
usleep($loopsleep);
} elseif($slowmode == 0) {
#enter_logfile($logpath,$timezone,6,"last loop: ".round($looptime, 5)." sec.");
$rotated_cnt++;
if($rotated_cnt > 3600) {
$rotated_arr = explode(';', $rotated);
$sum_time = 0;
foreach ($rotated_arr as $time) {
$sum_time = $sum_time + $time;
}
if(($sum_time / 10) > 1) {
$rotated_cnt = 0;
enter_logfile($logpath,$timezone,4," Your Ranksystem seems to be slow. This is not a big deal, but it needs more ressources then necessary.");
enter_logfile($logpath,$timezone,4," Here you'll find some information to optimize it: https://ts-n.net/ranksystem.php#optimize");
enter_logfile($logpath,$timezone,4," Last 10 runtimes in seconds (lower values are better): ".$rotated);
foreach ($uniqueid as $clientid) {
usleep($slowmode);
try {
$ts3server->clientGetByUid($clientid)->message("\nYour Ranksystem seems to be slow. This is not a big deal, but it needs more ressources then necessary.\nHere you'll find some information to optimize it: [URL]https://ts-n.net/ranksystem.php#optimize[/URL]\nLast 10 runtimes in seconds (lower values are better):\n".$rotated);
} catch (Exception $e) { }
}
}
}
}
}
} catch (Exception $e) {
enter_logfile($logpath,$timezone,2,$lang['errorts3'].$e->getCode().': '.$e->getMessage());
$offline_status = array(110,257,258,1024,1026,1031,1032,1033,1034,1280,1793);
if(in_array($e->getCode(), $offline_status)) {
if($mysqlcon->exec("UPDATE $dbname.stats_server SET server_status='0'") === false) {
enter_logfile($logpath,$timezone,2,$lang['error'].print_r($mysqlcon->errorInfo(), true));
}
}
shutdown($mysqlcon, $logpath, $timezone, 1, "Critical TS3 error on core function!");
}
?>
Reference in New Issue View Git Blame Copy Permalink