load->model('servers'); $this->load->model('servers/dedicated_servers'); $this->load->model('servers/games'); $this->load->model('servers/game_types'); $this->load->driver('rcon'); $this->load->library('ssh'); $this->load->library('telnet'); set_time_limit(0); $this->load->database(); } // ---------------------------------------------------------------- /** * Получает информацию о сервере информации о котором * еще нет в массиве $this->server_data */ function _get_server_data($server_id) { if(!array_key_exists($server_id, $this->servers_data)) { $this->servers_data[$server_id] = $this->servers->get_server_data($server_id); $this->servers_data[$server_id]['app_id'] = $this->games->games_list[0]['app_id']; $this->servers_data[$server_id]['app_set_config'] = $this->games->games_list[0]['app_set_config']; } return $this->servers_data[$server_id]; } // ---------------------------------------------------------------- /** * Создает директорию на выделенном сервере * * @param string * @param integer * @param bool * @param string * @return bool */ function _mkdir($server_id) { $commands = array(); switch(strtolower($this->servers_data[$server_id]['os'])) { case 'windows': $commands[] = 'mkdir ' . $this->servers_data[$server_id]['dir']; break; default: $commands[] = 'mkdir -p ' . $this->servers_data[$server_id]['dir']; $commands[] = 'chmod 777 ' . $this->servers_data[$server_id]['dir']; break; } if ($this->servers->command($commands, $this->servers_data[$server_id])) { return TRUE; } else { return FALSE; } } // ---------------------------------------------------------------- /** * Загружает файлы на удаленный сервер * * @param string * @param integer * @param bool * @param string * @return bool */ function _wget_files($server_id, $link, $rep_type = 'local') { $commands = array(); if ($rep_type == 'local') { /* Загружаем данные на сервер по FTP */ if ($this->servers_data[$server_id]['control_protocol'] != 'local') { $connection = @ftp_connect($this->servers_data[$server_id]['ftp_host']); if (!$connection) { return FALSE; } if (!ftp_login($connection, $this->servers_data[$server_id]['ftp_login'], $this->servers_data[$server_id]['ftp_passwd'])) { return FALSE; } /* Загружаем файл на удаленный сервер */ $ftp_put_result = ftp_put( $connection, $this->servers_data[$server_id]['ftp_path'] . '/' . $this->servers_data[$server_id]['dir'] . '/' . basename($link), $link, FTP_BINARY ); if (!$ftp_put_result) { ftp_close($connection); return FALSE; } ftp_close($connection); } else { /* Установка на локальный сервер */ $commands = array(); switch (strtolower($this->servers_data[$server_id]['os'])) { case 'windows': $commands[] = 'copy ' . $link . ' ' . $this->config->config['local_script_path'] . '\\' .$this->servers_data[$server_id]['dir']; break; default: $commands[] = 'cp ' . $link . ' ' . $this->config->config['local_script_path'] . '/' .$this->servers_data[$server_id]['dir']; break; } } $this->servers->command($commands, $this->servers_data[$server_id], $this->servers_data[$server_id]['script_path'] . '/' . $this->servers_data[$server_id]['dir']); return TRUE; } elseif ($rep_type == 'remote') { switch (strtolower($this->servers_data[$server_id]['os'])) { case 'windows': $command = 'wget ' . $link; break; default: $command = 'wget ' . $link; break; } $result = $this->servers->command( $command, $this->servers_data[$server_id], $this->servers_data[$server_id]['script_path'] . '/' . $this->servers_data[$server_id]['dir'] ); //~ if ($result) { //~ return TRUE; //~ } return TRUE; } else { return FALSE; } } // ---------------------------------------------------------------- /** * Распаковка архивов на выделенном сервере * * @param integer * @param string * @return bool */ function _unpack_files($server_id, $pack_file) { switch (strtolower($this->servers_data[$server_id]['os'])) { case 'windows': $commands[] = '"%PROGRAMFILES%/7-Zip/7z.exe" x ' . basename($pack_file) . ' -o' . $this->servers_data[$server_id]['script_path'] . '/' . $this->servers_data[$server_id]['dir'] . ' && del /F ' . basename($pack_file); break; default: $commands[] = 'unzip ' . basename($pack_file) . ' && rm ' . basename($pack_file); break; } $result = $this->servers->command( $commands, $this->servers_data[$server_id], $this->servers_data[$server_id]['script_path'] . '/' . $this->servers_data[$server_id]['dir'] ); if ($result) { return TRUE; } } // ---------------------------------------------------------------- /** * Установка игрового сервера с помощью SteamCMD */ function _install_from_steamcmd($server_id) { /* Установка через SteamCMD */ //steamcmd +login anonymous +force_install_dir ../czero +app_set_config 90 mod czero +app_update 90 validate +quit $cmd['app'] = ''; if($this->servers_data[$server_id]['app_set_config']) { $cmd['app'] .= '+app_set_config ' . $this->servers_data[$server_id]['app_set_config'] . ' '; } $cmd['app'] .= '+app_update ' . $this->servers_data[$server_id]['app_id']; $cmd['login'] = '+login anonymous'; $cmd['install_dir'] = '+force_install_dir ' . $this->servers_data[$server_id]['script_path'] . '/' . $this->servers_data[$server_id]['dir']; switch(strtolower($this->servers_data[$server_id]['os'])) { case 'windows': $command = 'steamcmd.exe ' . $cmd['login'] . ' ' . $cmd['install_dir'] . ' ' . $cmd['app'] . ' validate +quit'; break; default: $command = './steamcmd.sh ' . $cmd['login'] . ' ' . $cmd['install_dir'] . ' ' . $cmd['app'] . ' validate +quit'; break; } $result = $this->servers->command($command, $this->servers_data[$server_id], $this->servers_data[$server_id]['steamcmd_path']); $exec_command = array_pop($this->servers->commands); if(strpos($result, 'Success! App \'' . $this->servers_data[$server_id]['app_id'] . '\' fully installed.') !== FALSE OR strpos($result, 'Success! App \'' . $this->servers_data[$server_id]['app_id'] . '\' already up to date.') !== FALSE ) { $server_data = array('installed' => '1'); $server_installed = TRUE; $log_data['msg'] = 'Update server success'; $this->_cron_result .= "Install server success\n"; return TRUE; } elseif(strpos($result, 'Failed to request AppInfo update') !== FALSE) { /* Сервер не установлен до конца */ $server_data = array('installed' => '0'); $log_data['msg'] = 'Update server failed'; $this->_cron_result .= "Install server failure\n"; return FALSE; } elseif(strpos($result, 'Error! App \'' . $this->games->games_list[0]['app_id'] . '\' state is') !== FALSE) { /* Сервер не установлен до конца */ $server_data = array('installed' => '0'); $log_data['msg'] = 'Error. App state after update job'; $this->_cron_result .= "Install server failure\n"; return FALSE; } else { /* Неизвестная ошибка */ $server_data = array('installed' => '1'); $log_data['msg'] = 'Unknown error'; $command = array_pop($this->servers->commands); $this->_cron_result .= "Install server failure\n"; return FALSE; } } // ---------------------------------------------------------------- /** * Обрабатывает полученные данные статистики */ function _stats_processing($ds) { // Определение протокола управления switch (strtolower($ds['control_protocol'])) { case 'ssh': $control_protocol = 'ssh'; break; case 'telnet': $control_protocol = 'telnet'; break; case 'local': $control_protocol = 'local'; break; default: if ($ds['os'] == 'windows') { $control_protocol = 'telnet'; } else { $control_protocol = 'ssh'; } break; } /* * Для Windows будут следующие команды: * Загруженность процессора: wmic cpu get LoadPercentage * Получение свободной памяти: wmic os get FreePhysicalMemory * Получение всей памяти: wmic os get TotalVisibleMemorySize * * Для Linux команды будут следующими: * vmstats */ if (strtolower($ds['os']) == 'windows') { if ($control_protocol == 'telnet') { $telnet_data = explode(':', $ds['telnet_host']); $telnet_ip = $telnet_data['0']; $telnet_port = 23; if (isset($telnet_data['1'])) { $telnet_port = $telnet_data['1']; } $this->telnet->connect($telnet_ip, $telnet_port); $this->telnet->auth($ds['telnet_login'], $ds['telnet_password']); $stats_string['cpu_load'] = $this->telnet->command('wmic cpu get LoadPercentage'); $stats_string['free_memory'] = $this->telnet->command('wmic os get FreePhysicalMemory'); $stats_string['total_memory'] = $this->telnet->command('wmic os get TotalVisibleMemorySize'); } elseif ($control_protocol == 'local') { $stats_string['cpu_load'] = shell_exec('wmic cpu get LoadPercentage'); $stats_string['free_memory'] = shell_exec('wmic os get FreePhysicalMemory'); $stats_string['total_memory'] = shell_exec('wmic os get TotalVisibleMemorySize'); } else { $ssh_data = explode(':', $ds['ssh_host']); $ssh_ip = $ssh_data['0']; $ssh_port = 22; if (isset($ssh_data['1'])) { $ssh_port = $ssh_data['1']; } $this->ssh->connect($ssh_ip, $ssh_port); $this->ssh->auth($ds['ssh_login'], $ds['ssh_password']); $stats_string['cpu_load'] = $this->ssh->command('wmic cpu get LoadPercentage'); $stats_string['free_memory'] = $this->ssh->command('wmic os get FreePhysicalMemory'); $stats_string['total_memory'] = $this->ssh->command('wmic os get TotalVisibleMemorySize'); } /* Обработака загруженности процессора */ /* * Пример значения $stats['cpu_load_string']: LoadPercentage 16 0 * LoadPercentage - ненужная намс строка, ее убираем * 16 - загруженность первого ядра (%) * 0 - загруженность второго ядра (%) * * Загруженность процессора = суммарная загруженность ядер / количество ядер * В данном случае загруженность процессора = 8% */ $explode = explode("\n", $stats_string['cpu_load']); unset($explode[0]); $a = 0; // Количество строк (количество ядер процессора + 1) $value = 0; // Сумма значений в строках (суммарная загруженность каждого ядра) foreach($explode as &$arr) { if (trim($arr) == '') { continue;} $arr = trim($arr); $arr = (int)$arr; $value = $value + $arr; $a ++; } $stats['cpu_usage'] = (int)round($value/$a); /* Свободно памяти */ $explode = explode("\n", $stats_string['free_memory']); unset($explode[0]); $free_memory = (int)trim($explode[1]); /* Всего памяти */ $explode = explode("\n", $stats_string['total_memory']); unset($explode[0]); $total_memory = (int)trim($explode[1]); $usage_memory = $total_memory - $free_memory; $stats['memory_usage'] = (int)round(($usage_memory/$total_memory) * 100); if($stats['cpu_usage'] > 100) {$stats['cpu_usage'] = 100;} if($stats['memory_usage'] > 100) {$stats['memory_usage'] = 100;} return $stats; } else { if ($control_protocol == 'telnet') { $telnet_data = explode(':', $ds['telnet_host']); $telnet_ip = $telnet_data['0']; $telnet_port = 23; if (isset($telnet_data['1'])) { $telnet_port = $telnet_data['1']; } $this->telnet->connect($telnet_ip, $telnet_port); $this->telnet->auth($ds['telnet_login'], $ds['telnet_password']); $stats_string['cpu_load'] = $this->telnet->command('vmstat'); $stats_string['memory_usage'] = $this->telnet->command('free'); } elseif ($control_protocol == 'local') { $stats_string['cpu_load'] = shell_exec('vmstat'); $stats_string['memory_usage'] = shell_exec('free'); } else { $ssh_data = explode(':', $ds['ssh_host']); $ssh_ip = $ssh_data['0']; $ssh_port = 22; if (isset($ssh_data['1'])) { $ssh_port = $ssh_data['1']; } $this->ssh->connect($ssh_ip, $ssh_port); $this->ssh->auth($ds['ssh_login'], $ds['ssh_password']); $stats_string['cpu_load'] = $this->ssh->command('vmstat'); $stats_string['memory_usage'] = $this->ssh->command('free'); } /* Использование процессора */ $stats_explode = preg_replace('| +|', ' ', array_pop(explode("\n", trim($stats_string['cpu_load'])))); $stats_explode = explode(' ', trim($stats_explode)); $stats['cpu_usage'] = (int)$stats_explode[12] + $stats_explode[13]; /* Использование памяти */ $stats_explode = preg_replace('| +|', ' ', $stats_string['memory_usage']); $stats_explode = explode("\n", trim($stats_explode)); $stats_explode = explode(' ', $stats_explode[1]); $stats['memory_usage'] = (int)round(($stats_explode[2]/$stats_explode[1])*100); if($stats['cpu_usage'] > 100) {$stats['cpu_usage'] = 100;} if($stats['memory_usage'] > 100) {$stats['memory_usage'] = 100;} return $stats; } } // ---------------------------------------------------------------- /** * Выполняет cron скрипты модулей */ function _modules_cron() { /* Массив с именами cron скриптов * нужен для записи выполненных скриптов * В случае одинаковых имен в разных модулях, второй и * последующие скрипты будут пропущены, иначе появится * ошибка об одинаковых классах. */ $array_scripts = array(); foreach($this->gameap_modules->modules_data as &$value) { if ($value['short_name'] == 'cron') { /* Пропускает самого себя */ continue; } if (!$value['cron_script']) { /* Скрипт не задан */ continue; } $value['cron_script'] = str_replace('.php', '', $value['cron_script']); $value['cron_script'] = str_replace('..', '', $value['cron_script']); $value['short_name'] = str_replace('..', '', $value['short_name']); if ($value['cron_script'] == 'cron') { /* Нельзя запускать скрипты с именем cron */ $this->_cron_result .= "Script {$value['cron_script']} on module {$value['short_name']} omitted\n"; continue; } if (in_array($value['cron_script'], $array_scripts)) { /* Нельзя запускать скрипты с именем cron */ $this->_cron_result .= "Script {$value['cron_script']} on module {$value['short_name']} omitted\n"; continue; } if (!file_exists(APPPATH . 'modules/' . $value['short_name'] . '/controllers/' . $value['cron_script'] . '.php')) { /* Скрипт отсутствует */ $this->_cron_result .= "Script not found on {$value['short_name']} module\n"; continue; } $array_scripts[] = $value['cron_script']; //~ $this->_cron_result .= $value['short_name'] . " cron started\n"; /* Выполняем cron скрипт из модуля */ $this->_cron_result .= modules::run($value['short_name'] . '/' . $value['cron_script'] . '/index'); } } // ---------------------------------------------------------------- /** * Функция, выполняющаяся при запуске cron */ public function index() { $time = time(); $this->_cron_result = ''; $cron_stats = array( 'success' => 0, 'failed' => 0, 'skipped' => 0, ); $log_data['user_name'] = 'System (cron)'; /* Получение заданий из базы данных * Задания ограничиваются последним часом, если по какой либо * причине задания двухчасовой давносте не были выполнены они не * будут выполнены вновь * */ $where = array('date_perform >' => $time - 3600, 'date_perform <' => $time); $query = $this->db->get_where('cron', $where); $task_list = $query->result_array(); /*==================================================*/ /* Выполняем задания */ /*==================================================*/ $this->_cron_result .= "== Task manager ==\n"; $i = 0; $a = 0; $count_i = count($task_list); while($i < $count_i) { // Если достигнут предел выполняемых задания, то оставляем оставшиеся на потом if($i >= 100) { $cron_stats['skipped'] += $count_i - $i; break; } $cron_success = FALSE; /* Проверяем дату, чтобы выполнить то что нужно * Возможно задание уже было выполнено ранее*/ if($task_list[$i]['date_performed'] > $task_list[$i]['date_perform']){ $cron_stats['skipped'] ++; $i ++; continue; } /* * Получение данных сервера */ if(isset($task_list[$i]['server_id'])) { $server_id = $task_list[$i]['server_id']; // Получение данных сервера $this->_get_server_data($server_id); } else { $cron_stats['skipped'] ++; $i ++; continue; } /* * Отправляем данны о том, что задание начало выполняться * чтобы исключить повторное выполнение при следующем запуске cron скрипта, * в случаях когда задание не завершилось */ $this->db->where('id', $task_list[$i]['id']); $this->db->update('cron', array('started' => '1')); // Выполняем задание switch($task_list[$i]['code']) { case 'server_start': if($response = $this->servers->start($this->servers_data[$server_id])){ $cron_success = TRUE; $cron_stats['success'] ++; $this->_cron_result .= 'Task: server #' . $server_id . ' start success' . "\n"; // Сохраняем логи $log_data['type'] = 'server_command'; $log_data['command'] = 'start'; $log_data['server_id'] = $server_id; $log_data['msg'] = 'Start server success'; $log_data['log_data'] = $response; $this->panel_log->save_log($log_data); }else{ $cron_stats['failed'] ++; $this->_cron_result .= 'Task: server #' . $server_id . ' start failed' . "\n"; // Сохраняем логи $log_data['type'] = 'server_command'; $log_data['command'] = 'start'; $log_data['server_id'] = $server_id; $log_data['msg'] = 'Start server Error'; $log_data['log_data'] = $response; $this->panel_log->save_log($log_data); } break; case 'server_stop': if($response = $this->servers->stop($this->servers_data[$server_id])){ $cron_success = TRUE; $cron_stats['success'] ++; $this->_cron_result .= 'Task: server #' . $server_id . ' stop success' . "\n"; // Сохраняем логи $log_data['type'] = 'server_command'; $log_data['command'] = 'stop'; $log_data['server_id'] = $server_id; $log_data['msg'] = 'Stop server success'; $log_data['log_data'] = $response; $this->panel_log->save_log($log_data); }else{ $cron_stats['failed'] ++; $this->_cron_result .= 'Task: server #' . $server_id . ' stop failed' . "\n"; // Сохраняем логи $log_data['type'] = 'server_command'; $log_data['command'] = 'stop'; $log_data['server_id'] = $server_id; $log_data['msg'] = 'Sop server Error'; $log_data['log_data'] = $response; $this->panel_log->save_log($log_data); } break; case 'server_restart': if($response = $this->servers->restart($this->servers_data[$server_id])){ $cron_success = TRUE; $cron_stats['success'] ++; $this->_cron_result .= 'Task: server #' . $server_id . ' restart success' . "\n"; // Сохраняем логи $log_data['type'] = 'server_command'; $log_data['command'] = 'restart'; $log_data['server_id'] = $server_id; $log_data['msg'] = 'Restart server success'; $log_data['log_data'] = $response; $this->panel_log->save_log($log_data); }else{ $cron_stats['failed'] ++; $this->_cron_result .= 'Task: server #' . $server_id . ' restart failed' . "\n"; // Сохраняем логи $log_data['type'] = 'server_command'; $log_data['command'] = 'restart'; $log_data['server_id'] = $server_id; $log_data['msg'] = 'Restart server Error'; $log_data['log_data'] = $response; $this->panel_log->save_log($log_data); } break; case 'server_update': if($response = $this->servers->update($this->servers_data[$server_id])) { $cron_success = TRUE; $cron_stats['success'] ++; $this->_cron_result .= 'Task: server #' . $server_id . ' update success' . "\n"; // Сохраняем логи $log_data['type'] = 'server_command'; $log_data['command'] = 'update'; $log_data['server_id'] = $server_id; $log_data['msg'] = 'Update server success'; $log_data['log_data'] = 'Command: ' . array_pop($this->servers->commands) . "\nResponse: \n" . $response; $this->panel_log->save_log($log_data); } else { $cron_stats['failed'] ++; $this->_cron_result .= 'Task: server #' . $server_id . ' update failed' . "\n"; // Сохраняем логи $log_data['type'] = 'server_command'; $log_data['command'] = 'update'; $log_data['server_id'] = $server_id; $log_data['msg'] = 'Update server Error'; $log_data['log_data'] = $response; $this->panel_log->save_log($log_data); } break; case 'server_rcon': if($this->servers->server_status($this->servers_data[$server_id]['server_ip'], $this->servers_data[$server_id]['query_port'])) { $this->rcon->set_variables( $this->servers_data[$server_id]['server_ip'], $this->servers_data[$server_id]['server_port'], $this->servers_data[$server_id]['rcon'], $this->servers_data[$server_id]['engine'], $this->servers_data[$server_id]['engine_version'] ); $rcon_connect = $this->rcon->connect(); if($rcon_connect) { $rcon_string = $this->rcon->command($task_list[$i]['command']); $cron_success = TRUE; $cron_stats['success'] ++; $this->_cron_result .= 'Task: server #' . $server_id . ' rcon send success' . "\n"; // Сохраняем логи $log_data['type'] = 'server_rcon'; $log_data['command'] = $task_list[$i]['command']; $log_data['server_id'] = $server_id; $log_data['msg'] = 'Rcon command'; $log_data['log_data'] = 'Rcon string: ' . $rcon_string; $this->panel_log->save_log($log_data); } else { $cron_stats['failed'] ++; $this->_cron_result .= 'Task: server #' . $server_id . ' rcon send failed' . "\n"; // Сохраняем логи $log_data['type'] = 'server_rcon'; $log_data['command'] = $task_list[$i]['command']; $log_data['server_id'] = $server_id; $log_data['msg'] = 'Rcon connect error'; $log_data['log_data'] = ''; $this->panel_log->save_log($log_data); } } else { $cron_stats['failed'] ++; $this->_cron_result .= 'Task: server #' . $server_id . ' rcon send failed' . "\n"; // Сохраняем логи $log_data['type'] = 'server_rcon'; $log_data['command'] = $task_list[$i]['command']; $log_data['server_id'] = $server_id; $log_data['msg'] = 'Server is down'; $log_data['log_data'] = ''; $this->panel_log->save_log($log_data); } break; default: $i ++; continue; break; } /* Задание было успешно выполнено */ if($cron_success) { $sql_data[$a]['id'] = $task_list[$i]['id']; $sql_data[$a]['started'] = '0'; // Устанавливаем дату выполнения $sql_data[$a]['date_performed'] = $time; // Устанавливаем дату следующего выполнения $sql_data[$a]['date_perform'] = $task_list[$i]['date_perform'] + $task_list[$i]['time_add']; } $i ++; $a ++; } // Обновляем данные if(!empty($sql_data)) { $this->db->update_batch('cron', $sql_data, 'id'); } // Отображаем статистику заданий $this->_cron_result .= "Success: $cron_stats[success] Failed: $cron_stats[failed] Skipped: $cron_stats[skipped]\n"; /*==================================================*/ /* БЕГУН */ /* Пробегаем по каждому серверу */ /*==================================================*/ $this->_cron_result .= "== Runner ==\n"; $this->servers->get_server_list(FALSE, FALSE, array('enabled' => '1')); //~ $this->games->get_game_list(); $i = 0; $count_i = count($this->servers->servers_list); while($i < $count_i) { $server_id = $this->servers->servers_list[$i]['id']; // Получение данных сервера $this->_get_server_data($server_id); /*==================================================*/ /* Установка сервера */ /*==================================================*/ if ($this->servers_data[$server_id]['installed'] == '0' OR $this->servers_data[$server_id]['installed'] == '3' ) { // Сервер не установлен $this->_cron_result .= "Server #" . $server_id . " not installed\n"; $server_installed = FALSE; /* Получение данных об игровой модификации */ $this->game_types->get_gametypes_list(array('id' => $this->servers_data[$server_id]['dir'])); /* * Полю installed устанавливаем значение 2, что сервер начал устанавливаться */ $this->servers->edit_game_server($server_id, array('installed' => '2')); $this->_mkdir($server_id); if ($this->games->games_list[0]['local_repository']) { /* Установка из локального репозитория */ if ($this->_wget_files($server_id, $this->games->games_list[0]['local_repository'], 'local')) { $this->_unpack_files($server_id, $this->games->games_list[0]['local_repository']); $server_installed = TRUE; } } elseif ($this->games->games_list[0]['remote_repository']) { /* Установка из удаленного репозитория */ if ($this->_wget_files($server_id, $this->games->games_list[0]['remote_repository'], 'remote')) { $this->_unpack_files($server_id, $this->games->games_list[0]['remote_repository']); $server_installed = TRUE; } } elseif ($this->games->games_list[0]['app_id']) { /* Установка через SteamCMD */ if ($this->_install_from_steamcmd($server_id)) { $server_installed = TRUE; } } else { /* * Не удалость выбрать тип установки * отсутствуют данные локального репозитория, удаленного репозитория и steamcmd */ $this->_cron_result .= "Server #" . $server_id . " install failed. App_id and Repository data not specified\n"; $server_installed = FALSE; } /* * Завершение установки. * Установка прав на директории, задание ркон пароля */ if ($server_installed == TRUE) { /* Загружаем дополнительный файлы игровой модификации */ if ($this->game_types->game_types_list[0]['local_repository']) { if ($this->_wget_files($server_id, $this->game_types->game_types_list[0]['local_repository'], 'local')) { $this->_unpack_files($server_id, $this->game_types->game_types_list[0]['local_repository']); } } elseif ($this->game_types->game_types_list[0]['remote_repository']) { if ($this->_wget_files($server_id, $this->game_types->game_types_list[0]['remote_repository'], 'remote')) { $this->_unpack_files($server_id, $this->game_types->game_types_list[0]['remote_repository']); } } /* Устанавливаем 777 права на директории, в которые загружается контент (карты, модели и пр.) * и 666 на конфиг файлы, которые можно редактировать через админпанель */ if(strtolower($this->servers_data[$server_id]['os']) != 'windows') { $config_files = json_decode($this->servers_data[$server_id]['config_files'], TRUE); $content_dirs = json_decode($this->servers_data[$server_id]['content_dirs'], TRUE); $log_dirs = json_decode($this->servers_data[$server_id]['log_dirs'], TRUE); $command = array(); $log = ''; foreach($config_files as $file) { $command[] = 'chmod 666 ' . './' . $this->servers_data[$server_id]['dir'] . '/' . $file['file']; $log .= 'chmod 666 ' . './' . $this->servers_data[$server_id]['dir'] . '/' . $file['file'] . "\n"; } foreach($content_dirs as $dir) { $command[] = 'chmod 777 ' . './' . $this->servers_data[$server_id]['dir']. '/' . $dir['path']; $log .= 'chmod 777 ' . './' . $this->servers_data[$server_id]['dir'] . '/'. $dir['path'] . "\n"; } foreach($log_dirs as $dir) { $command[] = 'chmod 777 ' . './' . $this->servers_data[$server_id]['dir'] . '/' . $dir['path']; $log .= 'chmod 777 ' . './' . $this->servers_data[$server_id]['dir'] . '/' . $dir['path'] . "\n"; } $log .= "\n---\nCHMOD\n" . $log . "\n" . $this->servers->command($command, $this->servers_data[$server_id]); } /* Устанавливаем серверу rcon пароль */ $this->load->helper('safety'); $new_rcon = generate_code(8); $this->servers->change_rcon($new_rcon, $this->servers_data[$server_id]); $server_data['rcon'] = $this->encrypt->encode($new_rcon); $server_data = array('installed' => '1'); $this->servers->edit_game_server($server_id, $server_data); $log_data['type'] = 'server_command'; $log_data['command'] = 'install'; $log_data['server_id'] = $server_id; $log_data['msg'] = 'Server install successful'; $log_data['log_data'] = 'Commands: ' . var_export($this->servers->commands, TRUE); $this->panel_log->save_log($log_data); } else { $server_data = array('installed' => '0'); $this->servers->edit_game_server($server_id, $server_data); $log_data['type'] = 'server_command'; $log_data['command'] = 'install'; $log_data['server_id'] = $server_id; $log_data['msg'] = 'Server install failed'; $log_data['log_data'] = 'Commands: ' . var_export($this->servers->commands, TRUE); $this->panel_log->save_log($log_data); $this->_cron_result .= 'Server install #' . $server_id . ' failed'; } $i ++; continue; } $this->servers->get_server_settings($server_id); /*==================================================*/ /* Перезапуск сервера в случае падения */ /*==================================================*/ /* В настройках указано, что сервер перезапускать не нужно */ if($this->servers->server_settings['SERVER_AUTOSTART']) { /* Получение id игры в массиве */ $a = 0; $count = count($this->games->games_list); while($a < $count) { if ($this->servers->servers_list[$i] == $this->games->games_list[$a]['code']) { $game_arr_id = $a; break; } $a++; } // Проверка статуса сервера $status = $this->servers->server_status($this->servers_data[$server_id]['server_ip'], $this->servers_data[$server_id]['query_port'], $this->servers_data[$server_id]['engine'], $this->servers_data[$server_id]['engine_version']); if(!$status) { /* Смотрим данные предыдущих проверок, если сервер был в оффе, то запускаем его */ /* Получение данных проверки крона из логов */ $where = array('date >=' => $time - 780, 'type' => 'cron_check', 'command' => 'server_status', 'server_id' => $server_id, 'log_data' => 'Server is down'); $logs = $this->panel_log->get_log($where); // Логи сервера в админпанели $response = FALSE; if(count($logs) >= 1) { /* При последней проверке сервер был оффлайн, запускаем его*/ $response = $this->servers->start($this->servers_data[$server_id]); $log_data['command'] = 'start'; $log_data['msg'] = 'Start server success'; if(strpos($response, 'Server is already running') !== FALSE) { /* Сервер запущен, видимо завис */ $response = $this->servers->restart($this->servers_data[$server_id]); $log_data['command'] = 'restart'; if(strpos($response, 'Server restarted') !== FALSE) { $log_data['msg'] = 'Restart server success'; } } } if($response) { // Записываем лог запуска $log_data['type'] = 'server_command'; $log_data['server_id'] = $server_id; $log_data['log_data'] = $response; $this->panel_log->save_log($log_data); } // Записываем лог проверки $log_data['type'] = 'cron_check'; $log_data['command'] = 'server_status'; $log_data['server_id'] = $server_id; $log_data['log_data'] = 'Server is down'; $this->panel_log->save_log($log_data); } } /*==================================================*/ /* Смена rcon пароля */ /*==================================================*/ if($this->servers->server_settings['SERVER_RCON_AUTOCHANGE']) { if($this->servers->server_status($this->servers_data[$server_id]['server_ip'], $this->servers_data[$server_id]['server_port'], $this->servers_data[$server_id]['engine'], $this->servers_data[$server_id]['engine_version'])) { $this->rcon->set_variables( $this->servers_data[$server_id]['server_ip'], $this->servers_data[$server_id]['server_port'], $this->servers_data[$server_id]['rcon'], $this->servers_data[$server_id]['engine'], $this->servers_data[$server_id]['engine_version'] ); $rcon_connect = $this->rcon->connect(); } else { $rcon_connect = FALSE; } if($rcon_connect) { $rcon_string = $this->rcon->command('status'); $rcon_string = trim($rcon_string); if(strpos($rcon_string, 'Bad rcon_password.') !== FALSE) { $this->load->helper('safety'); $new_rcon = generate_code(8); $this->servers->server_data = $this->servers_data[$server_id]; $this->servers->change_rcon($new_rcon); // Меняем пароль в базе $sql_data['rcon'] = $this->encrypt->encode($new_rcon); $this->servers->edit_game_server($server_id, $sql_data); // Сохраняем логи $log_data['type'] = 'server_rcon'; $log_data['command'] = 'rcon_password'; $log_data['server_id'] = $server_id; $log_data['msg'] = 'Change rcon password'; $log_data['log_data'] = 'Rcon command: rcon_password ' . $new_rcon . "\n"; $this->panel_log->save_log($log_data); // Перезагружаем сервер $response = $this->servers->restart($this->servers_data[$server_id]); // Сохраняем логи $log_data['type'] = 'server_command'; $log_data['command'] = 'restart'; $log_data['server_id'] = $server_id; $log_data['msg'] = 'Restart server success'; $log_data['log_data'] = $response; $this->panel_log->save_log($log_data); $cron_stats['success'] ++; } else { $cron_stats['skipped'] ++; } } else { // Не удалось соединиться с сервером, либо он выключен $cron_stats['failed'] ++; } } else { $cron_stats['skipped'] ++; } $i ++; } /*==================================================*/ /* СТАТИСТИКА ВЫДЕЛЕННОГО СЕРВЕРА */ /*==================================================*/ $this->_cron_result .= "== DS Stats ==\n"; $this->dedicated_servers->get_ds_list(); if (!empty($this->dedicated_servers->ds_list)) { foreach($this->dedicated_servers->ds_list as $ds) { if (!$ds['ssh_host'] && !$ds['telnet_host']) { continue; } $stats = $this->_stats_processing($ds); if(isset($stats['cpu_usage']) && isset($stats['cpu_usage'])) { $this->_cron_result .= 'Stats server #' . $ds['id'] . ' successful' . "\n"; } else { $this->_cron_result .= 'Stats server #' . $ds['id'] . ' failed'. "\n"; continue; } /* * Обновляем статистику * Добавляем новое значение в существующий массив * date - дата проверки (unix time) * cpu_usage - использование cpu (%) * memory_usage - использование памяти (%) */ $stats_array = json_decode($ds['stats'], TRUE); $stats_array[] = array('date' => $time, 'cpu_usage' => $stats['cpu_usage'], 'memory_usage' => $stats['memory_usage']); $data['stats'] = json_encode($stats_array); $this->dedicated_servers->edit_dedicated_server($ds['id'], $data); } } // Статистика для локального сервера $ds = array('os' => $this->config->config['local_os'], 'control_protocol' => 'local'); $stats = $this->_stats_processing($ds); if(isset($stats['cpu_usage']) && isset($stats['cpu_usage'])) { $stats_array = json_decode(@file_get_contents(APPPATH . 'cache/local_server_stats.json', TRUE)); $stats_array[] = array('date' => $time, 'cpu_usage' => $stats['cpu_usage'], 'memory_usage' => $stats['memory_usage']); $data['stats'] = json_encode($stats_array); file_put_contents(APPPATH . 'cache/local_server_stats.json', $data['stats']); $this->_cron_result .= 'Local server stats successful' . "\n"; } else { $this->_cron_result .= 'Local server stats failed'. "\n"; } /*==================================================*/ /* ВЫПОЛНЕНИЕ CRON СКРИПТОВ ИЗ МОДУЛЕЙ */ /*==================================================*/ $this->_cron_result .= "== Modules cron ==\n"; /* Чтобы данные выполнения пользовательского крона выводились правильно * и на своем месте, то записываем весь вывод предыдущих задач * а после этого запускаем пользовательский крон */ $this->output->append_output($this->_cron_result); $this->_cron_result = ''; $this->_modules_cron(); $this->_cron_result .= "Cron end\n"; $this->output->append_output($this->_cron_result); $log_data['type'] = 'cron'; $log_data['command'] = 'cron work'; $log_data['msg'] = 'Cron end working'; $log_data['log_data'] = $this->output->get_output(); $this->panel_log->save_log($log_data); } }