|
|
@@ -74,7 +74,9 @@ class CLog {
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
- * 断言,
|
|
|
+ * 断言日志,注意此断言不是打断程序执行的那种.
|
|
|
+ * 如果断言失败,则会在日志里面留下一条Err记录,记录内容为errmsg.
|
|
|
+ * 如果判断成功,且设置了okmsg, 则会在日志里面留下一条info记录记录内容为OKmsg.
|
|
|
* @param bool $condition 条件/条件表达式
|
|
|
* @param string $errmsg 条件不成立时输出到日志中的信息, 日志级别err
|
|
|
* @param string $okmsg 【可选】默认(null), 当条件成立时不记录任何消息, 除非特别指定了消息内容.日志级别info
|
|
|
@@ -123,20 +125,13 @@ class CLog {
|
|
|
* 将缓存中的数据写入存储设备并清除缓存
|
|
|
*/
|
|
|
public static function flush() {
|
|
|
- if (GAME_ONLINE) { # 外网错误日志写入redis
|
|
|
- self::flush2Redis(enum_LogLevel::Info);
|
|
|
- self::flush2Redis(enum_LogLevel::Warn);
|
|
|
- self::flush2Redis(enum_LogLevel::Err);
|
|
|
- } else {
|
|
|
-// self::flush2MySQL(enum_LogLevel::Info); # 内网写入MySQL
|
|
|
-// self::flush2MySQL(enum_LogLevel::Warn);
|
|
|
-// self::flush2MySQL(enum_LogLevel::Err);
|
|
|
- self::flush2Redis(enum_LogLevel::Info);
|
|
|
- self::flush2Redis(enum_LogLevel::Warn);
|
|
|
- self::flush2Redis(enum_LogLevel::Err);
|
|
|
- }
|
|
|
+ self::flush2Redis(enum_LogLevel::Info);
|
|
|
+ self::flush2Redis(enum_LogLevel::Warn);
|
|
|
+ self::flush2Redis(enum_LogLevel::Err);
|
|
|
}
|
|
|
|
|
|
+// <editor-fold defaultstate="collapsed" desc="辅助方法">
|
|
|
+
|
|
|
/**
|
|
|
* 将日志写入文件
|
|
|
* @global type $zoneid
|
|
|
@@ -154,12 +149,8 @@ class CLog {
|
|
|
foreach ($arr as $msg) {
|
|
|
$n = fputs($fd, $msg . PHP_EOL);
|
|
|
if (false === $n) { # 写入时失败
|
|
|
- throw new \Exception("写入 $fileName 时失败");
|
|
|
+ throw new \Exception("写入 $fileName 时失败"); # 这种的就得靠查找系统(nginx/php-fpm)日志了
|
|
|
}
|
|
|
- // todo: 其实写入日志也是有失败几率的, 当写入日志也失败的时候,
|
|
|
- // 抛出异常, 让nginx来记录下些东西, 但是如果是在errorhandler
|
|
|
- // 中写日志的时候出错呢......
|
|
|
- // -wg 2017年8月5日 08:56:29
|
|
|
}
|
|
|
self::$$typename = array(); # 清空数据
|
|
|
}
|
|
|
@@ -175,7 +166,9 @@ class CLog {
|
|
|
$key = "log-" . $typename;
|
|
|
$arr = self::$$typename; # 取对应类型的数组
|
|
|
if (count($arr) > 0) {
|
|
|
- $arr[] = JsonUtil::encode(req()->__toString());
|
|
|
+ if (null != req()) {
|
|
|
+ $arr[] = "" . req();
|
|
|
+ }
|
|
|
gMem()->lpush($key, $arr);
|
|
|
if (gMem()->llen($key) > self::redis_log_trim_max + self::redis_log_trim_once) {# 达到清理条件
|
|
|
gMem()->ltrim($key, 0, -self::redis_log_trim_once); # 缩减记录
|
|
|
@@ -194,19 +187,15 @@ class CLog {
|
|
|
$arr = self::$$typename; # 取对应类型的数组
|
|
|
|
|
|
if (count($arr) > 0) {
|
|
|
- // 创建表
|
|
|
$sql = "create table if not exists `$key` (`row` INT(11) NOT NULL AUTO_INCREMENT COMMENT '自增行号', `msg` TEXT NULL COMMENT '错误消息内容', PRIMARY KEY (`row`)) COLLATE='utf8_general_ci' ENGINE=InnoDB;";
|
|
|
- daoInst()->exec($sql);
|
|
|
- // 插入数据
|
|
|
+ daoInst()->exec($sql); # 创建表
|
|
|
$data = array();
|
|
|
array_map(function($v) use(&$data) {
|
|
|
$s = daoInst()->quote($v);
|
|
|
-// var_dump($s);
|
|
|
$data[] = "(" . $s . ")";
|
|
|
}, $arr);
|
|
|
$sql_insert = "insert into `$key` (`msg`) values " . implode(',', $data) . " ;";
|
|
|
- daoInst()->exec($sql_insert);
|
|
|
- // 检查表大小
|
|
|
+ daoInst()->exec($sql_insert); # 执行插入操作
|
|
|
$n = daoInst()->select()->from("`$key`")->count(); # 查一下当前表大小
|
|
|
$max = 150000; # 最多保留15万条记录
|
|
|
$del_once = 10000; # 超过15万,清理一次,一次删除1万条
|
|
|
@@ -214,10 +203,37 @@ class CLog {
|
|
|
$sql = "delete from `$key` order by `row` limit $del_once ;"; # 一次清理一批
|
|
|
daoInst()->exec($sql);
|
|
|
}
|
|
|
-// self::$$typename = array(); # 清空数据
|
|
|
+ self::$$typename = array(); # 清空数据
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 生成日志,格式: [x区][时间][文件][tag]: msg
|
|
|
+ * @global \loyalsoft\type $zoneid
|
|
|
+ * @param type $msg
|
|
|
+ * @param type $tag
|
|
|
+ * @return string
|
|
|
+ */
|
|
|
+ private static function makeLogMsg($msg, $tag = null) {
|
|
|
+ global $zoneid;
|
|
|
+ $array = debug_backtrace();
|
|
|
+ while (isset($array[0]) && isset($array[0]['file']) && $array[0]['file'] == __FILE__) {
|
|
|
+ array_shift($array);
|
|
|
}
|
|
|
+ $row = $array[0];
|
|
|
+ $server_addr = isset($_SERVER['SERVER_ADDR']) ? $_SERVER['SERVER_ADDR'] : "-";
|
|
|
+ $client_addr = isset($_SERVER['REMOTE_ADDR']) ? $_SERVER['REMOTE_ADDR'] : "-";
|
|
|
+ $str = "[" . $server_addr . "][$zoneid 区][" . date('Y-m-d H:i:s') # # 主机地址、分区、时间
|
|
|
+ . "][" . $client_addr . "][" # # 客户端地址
|
|
|
+ . (isset($row['file']) ? CommUtil::str2UTF8(basename($row['file'])) : '-') # 所在文件名
|
|
|
+ . ":" . (isset($row['line']) ? $row['line'] : "???")# # 所在行
|
|
|
+ . "]" . (isset($tag) ? "[" . CommUtil::str2UTF8($tag) . "]" : "") #
|
|
|
+ . "=> " . var_export($msg, true)# # 标签、内容
|
|
|
+ . PHP_EOL;
|
|
|
+ return $str;
|
|
|
}
|
|
|
|
|
|
+// </editor-fold>
|
|
|
//
|
|
|
// 避免异常导致缓存丢失, 付费模块的日志直接写入文件
|
|
|
// <editor-fold defaultstate="collapsed" desc=" 付费相关日志, 无缓存 ">
|
|
|
@@ -227,11 +243,12 @@ class CLog {
|
|
|
* @param mixed $msg 参数是字符串则直接输出,否则调用json_encode
|
|
|
*/
|
|
|
public static function pay($msg) {
|
|
|
+ $str = self::makeLogMsg($msg); # 统一日志格式字符串
|
|
|
if (GAME_ONLINE) {
|
|
|
- self::Paylog2Mysql($msg);
|
|
|
+ self::Paylog2Mysql($str);
|
|
|
} else {
|
|
|
- $fileName = self::GetDir() . "pay.log";
|
|
|
- self::Log2File($fileName, $msg);
|
|
|
+ $fileName = self::GetDir() . "pay" . date('Ym') . ".log";
|
|
|
+ self::Log2File($fileName, $str);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -242,54 +259,22 @@ class CLog {
|
|
|
* @param string $msg
|
|
|
*/
|
|
|
private static function Log2File($fileName, $msg) {
|
|
|
-
|
|
|
$fd = fopen($fileName, "a");
|
|
|
- if ($fd === FALSE) { # 打开文件失败
|
|
|
+ if ($fd === FALSE) { # 打开文件失败
|
|
|
throw new \Exception('open file failed! ' . $fileName);
|
|
|
}
|
|
|
- // todo: 文件写入也是有机会出错的, 此处出错应予监控,
|
|
|
- // 并抛出异常到nginx/phpfpm层,记录日志.
|
|
|
- // -wg 2017年8月5日 09:10:16
|
|
|
- $str = self::makeLogMsg($msg);
|
|
|
- fputs($fd, $str . PHP_EOL);
|
|
|
- fclose($fd); # 关闭文件
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 生成日志,格式: [x区][时间][文件][tag]: msg
|
|
|
- * @global \loyalsoft\type $zoneid
|
|
|
- * @param type $msg
|
|
|
- * @param type $tag
|
|
|
- * @return string
|
|
|
- */
|
|
|
- private static function makeLogMsg($msg, $tag = null) {
|
|
|
- global $zoneid;
|
|
|
- $array = debug_backtrace();
|
|
|
- while (isset($array[0]) && isset($array[0]['file']) && $array[0]['file'] == __FILE__) {
|
|
|
- array_shift($array);
|
|
|
- }
|
|
|
- $row = $array[0];
|
|
|
- $server_addr = isset($_SERVER['SERVER_ADDR']) ? $_SERVER['SERVER_ADDR'] : "-";
|
|
|
- $client_addr = isset($_SERVER['REMOTE_ADDR']) ? $_SERVER['REMOTE_ADDR'] : "-";
|
|
|
- return "[" . $server_addr . "][$zoneid 区][" . date('Y-m-d H:i:s') # # 主机地址、分区、时间
|
|
|
- . "][" . $client_addr . "][" # # 客户端地址
|
|
|
- . (isset($row['file']) ? CommUtil::str2UTF8(basename($row['file'])) : '-') # 所在文件名
|
|
|
- . ":" . (isset($row['line']) ? $row['line'] : "???")# # 所在行
|
|
|
- . "]" . (isset($tag) ? "[$tag]" : "") . "=> " . var_export($msg, true)# # 标签、内容
|
|
|
- . PHP_EOL;
|
|
|
-
|
|
|
-// . "req: " . JsonUtil::encode($req);
|
|
|
+ fputs($fd, $msg . PHP_EOL);
|
|
|
+ fclose($fd); # 关闭文件
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 将pay日志写入mysql
|
|
|
* @param type $msg
|
|
|
*/
|
|
|
- public static function Paylog2Mysql($msg) {
|
|
|
- $str = self::makeLogMsg($msg); # 统一日志格式字符串
|
|
|
+ private static function Paylog2Mysql($msg) {
|
|
|
$t = "tab_paylog_" . date('Ym');
|
|
|
- $sql = "create table if not exists $t like tpl_paylog_tab_ym;"
|
|
|
- . " insert into $t (msg) values ('$str');";
|
|
|
+ $sql = "create table if not exists $t like tpl_paylog_tab_ym;" # 组装SQL
|
|
|
+ . " insert into $t (msg) values ('$msg');";
|
|
|
$n = daoInst()->exec($sql);
|
|
|
if ($n < 0) {
|
|
|
self::err("写入数据库失败." . $sql);
|
gwang