329 lines
12 KiB
PHP
329 lines
12 KiB
PHP
<?php
|
|
/*-----------------------------------------------------+
|
|
* 用户登录处理
|
|
* @author yeahoo2000@gmail.com
|
|
+-----------------------------------------------------*/
|
|
class server{
|
|
private static $instance = null;
|
|
private $server;
|
|
private $gamenode;
|
|
private $logfile;
|
|
|
|
private function __construct(){
|
|
$this->logfile = ROOT.'/var/server.log';
|
|
}
|
|
|
|
private function checkArgs(){
|
|
if(!isset(App::request()->get()->name)){
|
|
throw new ErrorException("缺少必要参数name");
|
|
}
|
|
$name = App::request()->get()->name;
|
|
|
|
$this->gamenode = App::cfg()->gamenodes->$name;
|
|
if(!$this->gamenode){
|
|
throw new ErrorException("找不到游戏节点{$name}的配置信息");
|
|
}
|
|
|
|
$name = $this->gamenode->server;
|
|
$this->server = App::cfg()->servers->$name;
|
|
if(!$this->server){
|
|
throw new ErrorException("找不到游戏节点对应服务器{$this->gamenode['server']}的配置信息");
|
|
}
|
|
}
|
|
|
|
// 当前脚本被载入时会自动调用此方法
|
|
public static function __awake(){
|
|
App::sess()->close(); // 这里必须关闭session，不然无法并发，用户体验不好
|
|
}
|
|
|
|
private static function getInstance(){
|
|
if(is_null(self::$instance)){
|
|
self::$instance = new self();
|
|
}
|
|
return self::$instance;
|
|
}
|
|
|
|
// 写日志文件
|
|
private static function writeLog($msg){
|
|
error_log($msg, 3, self::getInstance()->logfile);
|
|
}
|
|
|
|
// 输出一条信息到控制台
|
|
private static function info($msg){
|
|
$name = App::sess()->username;
|
|
$time = date("y/m/d H:i:s", time());
|
|
self::writeLog(sprintf("[o0m[INFO][%s %s][0;0m %s", $time, $name, $msg));
|
|
}
|
|
|
|
// 获取控制台内容
|
|
public static function console(){
|
|
$view = App::view();
|
|
$view->vars->content = Common::formatConsole(Util::tail(self::getInstance()->logfile));
|
|
$view->render('console');
|
|
}
|
|
|
|
// 显示主界面
|
|
public static function index(){
|
|
// echo system("locale");
|
|
$nodes = [];
|
|
foreach(APP::cfg()->gamenodes->getArray() as $k => $v){
|
|
$nodes[$k] = $v->name;
|
|
}
|
|
$datafiles = Common::datafiles();
|
|
$update_file_num = 0;
|
|
foreach($datafiles as $file){
|
|
if(strlen($file['update_flag']) > 0) $update_file_num++;
|
|
}
|
|
$view = App::view();
|
|
$view->vars->update_file_num = $update_file_num;
|
|
$view->vars->datafiles = $datafiles;
|
|
$view->vars->form_url = App::url('/server/gen/data');
|
|
$view->vars->console = App::url('/server/console');
|
|
$view->vars->select_gamenode = Form::dropdown('select-gamenode', $nodes);
|
|
$view->render('server');
|
|
}
|
|
|
|
// 编译服务器
|
|
public static function make(){
|
|
$self = self::getInstance();
|
|
$self->checkArgs();
|
|
self::info("正在编译服务端源码...\n");
|
|
$root = App::cfg()->project_root;
|
|
$cmd = "bash {$root}/dev.sh srv_pmake";
|
|
$rtn = SSH::exec($self->server, $cmd, $stdout, $stderr);
|
|
if(0 != $rtn){
|
|
self::writeLog("编译服务端源码时发生错误[$rtn]:\n$stderr\n");
|
|
return;
|
|
}
|
|
self::writeLog($stdout);
|
|
}
|
|
|
|
// 编译服务器配置文件
|
|
public static function make_cfg(){
|
|
$self = self::getInstance();
|
|
$self->checkArgs();
|
|
self::info("正在编译服务端源码...\n");
|
|
// $cmd = "bash {$self->gamenode->root}/srv.sh make_mod data && {$self->gamenode->root}/srv.sh make_mod battle";
|
|
$root = App::cfg()->project_root;
|
|
$cmd = "bash {$root}/dev.sh srv_makedata";
|
|
$rtn = SSH::exec($self->server, $cmd, $stdout, $stderr);
|
|
if(0 != $rtn){
|
|
self::writeLog("编译服务端源码时发生错误[$rtn]:\n$stderr\n");
|
|
return;
|
|
}
|
|
if (preg_match ( "/.*(undefined.in.record).*/", $stdout)) {
|
|
App::alert("编译有错，热更失败");
|
|
}
|
|
$str = preg_replace('/(\>error.*|.*undefined.in.record.*)/', '<font color="red">[\1]</font>', $stdout);
|
|
self::writeLog($str);
|
|
}
|
|
|
|
// 校验AI技能配置文件
|
|
public static function data_check(){
|
|
$self = self::getInstance();
|
|
$self->checkArgs();
|
|
self::info("正在校验数据表配置信息...\n");
|
|
$root = App::cfg()->project_root;
|
|
$cmd = "bash {$root}/dev.sh srv exec dev 5 t check_data";
|
|
$rtn = SSH::exec($self->server, $cmd, $stdout, $stderr);
|
|
if(0 != $rtn){
|
|
self::writeLog("编译服务端源码时发生错误[$rtn]:\n$stderr\n");
|
|
return;
|
|
}
|
|
self::writeLog($stdout);
|
|
}
|
|
|
|
// 校验AI技能配置文件
|
|
public static function ai_check(){
|
|
$self = self::getInstance();
|
|
$self->checkArgs();
|
|
self::info("正在校验AI、技能、战斗BUFF...\n");
|
|
$cmd = "bash {$self->gamenode->root}/srv.sh exec {$self->gamenode->platform} {$self->gamenode->zone_id} ai_err check";
|
|
$rtn = SSH::exec($self->server, $cmd, $stdout, $stderr);
|
|
if(0 != $rtn){
|
|
self::writeLog("编译服务端源码时发生错误[$rtn]:\n$stderr\n");
|
|
return;
|
|
}
|
|
self::writeLog($stdout);
|
|
}
|
|
|
|
// 热更新服务器
|
|
public static function hotswap(){
|
|
$self = self::getInstance();
|
|
$self->checkArgs();
|
|
// self::info("正在热更新服务器 {$self->gamenode->name} ...\n");
|
|
self::info("正在热更新服务器 ...\n");
|
|
$root = App::cfg()->project_root;
|
|
# $cmd = "bash {$root}/dev.sh srv_exec {$self->gamenode->platform} {$self->gamenode->zone_id} dev u";
|
|
$cmd = "cd {$root}/server && bash ./all.sh update";
|
|
$rtn = SSH::exec($self->server, $cmd, $stdout, $stderr);
|
|
if(0 != $rtn){
|
|
self::writeLog("热更新服务器 {$self->gamenode->name} 时发生错误[$rtn]:\n$stderr\n");
|
|
return;
|
|
}
|
|
self::writeLog($stdout);
|
|
// $cmd = "bash {$root}/dev.sh srv_exec dev 2 dev u";
|
|
// $rtn = SSH::exec($self->server, $cmd, $stdout, $stderr);
|
|
// self::writeLog($stdout);
|
|
// $cmd = "bash {$root}/dev.sh srv_exec dev 3 dev u";
|
|
// $rtn = SSH::exec($self->server, $cmd, $stdout, $stderr);
|
|
// self::writeLog($stdout);
|
|
// $cmd = "bash {$root}/dev.sh srv_exec dev 4 dev u";
|
|
// $rtn = SSH::exec($self->server, $cmd, $stdout, $stderr);
|
|
// self::writeLog($stdout);
|
|
// $cmd = "bash {$root}/dev.sh srv_exec center 0 dev u";
|
|
// $rtn = SSH::exec($self->server, $cmd, $stdout, $stderr);
|
|
// self::writeLog($stdout);
|
|
}
|
|
|
|
// 更新SVN
|
|
public static function upsvn(){
|
|
$self = self::getInstance();
|
|
$self->checkArgs();
|
|
self::info("正在更新SVN数据 ...\n");
|
|
|
|
$root = App::cfg()->project_root;
|
|
$cmd = "bash {$root}/dev.sh pull docs";
|
|
|
|
$rtn = SSH::exec($self->server, $cmd, $stdout, $stderr);
|
|
if(0 != $rtn){
|
|
self::writeLog("更新SVN时发生错误[$rtn]:\n$stderr\n");
|
|
return;
|
|
}
|
|
self::info("更新SVN数据结束 ...\n");
|
|
self::writeLog($stdout);
|
|
}
|
|
|
|
// 生成配置数据
|
|
public static function genData(){
|
|
$files = App::request()->get()->files;
|
|
if(!$files) return;
|
|
self::info("正在生成配置数据[$files]，某些数据需要处理比较长的时间...\n");
|
|
$is_err = Common::genData(explode(',', $files), self::getInstance()->logfile);
|
|
self::info("生成配置数据完毕\n");
|
|
if(!$is_err && App::request()->get()->hotswap == 'true'){
|
|
self::make_cfg();
|
|
self::hotswap();
|
|
}
|
|
}
|
|
|
|
// 生成地图数据
|
|
public static function genMap(){
|
|
$self = self::getInstance();
|
|
$self->checkArgs();
|
|
|
|
self::info("正在生成地图数据...\n");
|
|
$cmd = "bash {$self->server->project_root}/dev.sh gen_data map_data";
|
|
$rtn = SSH::exec($self->server, $cmd, $stdout, $stderr);
|
|
if(0 != $rtn){
|
|
self::writeLog("生成地图数据失败[$rtn]:\n$stderr\n");
|
|
}
|
|
self::writeLog($stdout);
|
|
}
|
|
|
|
// 生成战场数据
|
|
public static function genBattle(){
|
|
$self = self::getInstance();
|
|
$self->checkArgs();
|
|
|
|
self::info("正在生成战场数据...\n");
|
|
$cmd = "bash {$self->server->project_root}/dev.sh battle all";
|
|
$rtn = SSH::exec($self->server, $cmd, $stdout, $stderr);
|
|
if(0 != $rtn){
|
|
self::writeLog("生成战场数据失败[$rtn]:\n$stderr\n");
|
|
}
|
|
self::writeLog($stdout);
|
|
}
|
|
|
|
// 启动服务器
|
|
public static function start(){
|
|
$self = self::getInstance();
|
|
$self->checkArgs();
|
|
self::info("正在启动服务器 {$self->gamenode->name} ...\n");
|
|
$cmd = "bash {$self->server->project_root}/dev.sh srv_start {$self->gamenode->platform} {$self->gamenode->zone_id}";
|
|
$rtn = SSH::exec($self->server, $cmd, $stdout, $stderr);
|
|
if(0 != $rtn){
|
|
self::writeLog("启动服务器 {$self->gamenode->name} 时发生错误[$rtn]:\n$stderr\n");
|
|
return;
|
|
}
|
|
self::writeLog($stdout);
|
|
}
|
|
|
|
// 关闭服务器
|
|
public static function stop(){
|
|
$self = self::getInstance();
|
|
$self->checkArgs();
|
|
self::info("正在关闭服务器 {$self->gamenode->name} ...\n");
|
|
|
|
$cmd = "bash {$self->server->project_root}/dev.sh srv_stop {$self->gamenode->platform} {$self->gamenode->zone_id}";
|
|
|
|
$rtn = SSH::exec($self->server, $cmd, $stdout, $stderr);
|
|
if(0 != $rtn){
|
|
self::writeLog("关闭服务器 {$self->gamenode->name} 时发生错误[$rtn]:\n$stderr\n");
|
|
return;
|
|
}
|
|
self::writeLog($stdout);
|
|
}
|
|
|
|
// 服务器状态
|
|
public static function status(){
|
|
$self = self::getInstance();
|
|
$self->checkArgs();
|
|
self::info("正在查询服务器 {$self->gamenode->name} 的状态...\n");
|
|
|
|
$cmd = "bash {$self->server->project_root}/dev.sh srv_exec {$self->gamenode->platform} {$self->gamenode->zone_id} info i";
|
|
|
|
$rtn = SSH::exec($self->server, $cmd, $stdout, $stderr);
|
|
if(0 != $rtn){
|
|
self::writeLog("查询服务器 {$self->gamenode->name} 的状态时发生错误[$rtn]:\n$stderr\n");
|
|
return;
|
|
}
|
|
self::writeLog($stdout);
|
|
}
|
|
|
|
// 获取游戏节点日志内容
|
|
public static function log(){
|
|
$self = self::getInstance();
|
|
$self->checkArgs();
|
|
$cmd = "tail -n 3000 {$self->gamenode->root}/screenlog.0";
|
|
$rtn = SSH::exec($self->server, $cmd, $stdout, $stderr);
|
|
if(0 != $rtn){
|
|
echo "无法读取服务器 {$self->gamenode->name} 的日志文件，原因[$rtn]:\n$stderr";
|
|
return;
|
|
}
|
|
|
|
$view = App::view();
|
|
$view->vars->content = Common::formatConsole($stdout);
|
|
$view->render('console');
|
|
}
|
|
|
|
public static function cmd(){
|
|
// sleep(5);
|
|
$self = self::getInstance();
|
|
$self->checkArgs();
|
|
$cmdstr = App::request()->get()->cmd;
|
|
if(!$cmdstr) return;
|
|
if(!preg_match('/^[^\|\$\(\)`&><]+$/is', $cmdstr)) return App::alert("命令[$cmdstr]中包含有特殊字符, 执行失败");
|
|
self::info("正在执行命令[./dev.sh $cmdstr]，某些命令需要处理比较长的时间...\n");
|
|
$cmd = "bash {$self->server->project_root}/dev.sh $cmdstr";
|
|
$rtn = SSH::exec($self->server, $cmd, $stdout, $stderr);
|
|
if(0 != $rtn){
|
|
self::writeLog("执行命令失败[$rtn]:\n$stderr\n");
|
|
}else{
|
|
self::writeLog("执行命令结果：\n$stdout\n$stderr");
|
|
}
|
|
self::info("执行命令[./dev.sh $cmdstr]完毕\n");
|
|
}
|
|
|
|
public static function holiday_cfg(){
|
|
$path = App::cfg()->project_root;
|
|
$filename = $path."/tools/gen_data/out/holiday.cfg.php";
|
|
$fileinfo = pathinfo($filename);
|
|
header('Content-type: application/x-'.$fileinfo['extension']);
|
|
header('Content-Disposition: attachment; filename='.$fileinfo['basename']);
|
|
header('Content-Length: '.filesize($filename));
|
|
readfile($filename);
|
|
exit();
|
|
}
|
|
}
|