'.$data.'

'; $current_module = empty($_GET['module']) ? '' : $_GET['module']; if($current_module) { $st_dir = WORKERMAN_LOG_DIR . 'statistic/st/'.$current_module.'/'; $all_interface = array(); foreach(glob($st_dir."*") as $file) { if(is_dir($file)) { continue; } $tmp = explode("|", basename($file)); $interface = trim($tmp[0]); if(isset($all_interface[$interface])) { continue; } $all_interface[$interface] = $interface; $left_detail .= '
•     '.$interface.'
'; } } $modules_name_array = $this->getModules(); if($modules_name_array) { foreach($modules_name_array as $module_file) { $tmp = explode("/", $module_file); $module = end($tmp); $html_left .= '
• '.$module.'
'; if($module == $current_module) { $html_left .= $left_detail; } } } $display_str = <<

$html_left

$data

EOC; return $this->sendToClient(\WORKERMAN\Protocols\SimpleHttp::encode($display_str)); } /** * 日志二分查找法 * @param int $start_point * @param int $end_point * @param int $time * @param fd $fd * @return int */ protected function binarySearch($start_point, $end_point, $time, $fd) { // 计算中点 $mid_point = (int)(($end_point+$start_point)/2); // 定位文件指针在中点 fseek($fd, $mid_point); // 读第一行 $line = fgets($fd); if(feof($fd) || false === $line) { return ftell($fd); } // 第一行可能数据不全，再读一行 $line = fgets($fd); if(feof($fd) || false === $line || trim($line) == '') { return ftell($fd); } // 判断是否越界 $current_point = ftell($fd); if($current_point>=$end_point) { return $end_point; } // 获得时间 $tmp = explode("\t", $line); $tmp_time = strtotime($tmp[0]); // 判断时间，返回指针位置 if($tmp_time > $time) { return $this->binarySearch($start_point, $current_point, $time, $fd); } elseif($tmp_time < $time) { return $this->binarySearch($current_point, $end_point, $time, $fd); } else { return $current_point; } } /** * 获取指定日志 * @return array */ protected function getStasticLog($module, $interface , $start_time = '', $end_time = '', $code = '', $msg = '', $pointer='', $count=100) { // log文件 $log_file = WORKERMAN_LOG_DIR . 'statistic/log/'. ($start_time === '' ? date('Y-m-d') : date('Y-m-d', $start_time)); if(!is_readable($log_file)) { return array('pointer'=>0, 'data'=>$log_file . 'not exists or not readable'); } // 读文件 $h = fopen($log_file, 'r'); // 如果有时间，则进行二分查找，加速查询 if($start_time && $pointer === '' && ($file_size = filesize($log_file) > 5000)) { $pointer = $this->binarySearch(0, $file_size, $start_time-1, $h); $pointer = $pointer < 1000 ? 0 : $pointer - 1000; } // 正则表达式 $pattern = "/^([\d: \-]+)\t"; if($module) { $pattern .= $module."::"; } else { $pattern .= ".*::"; } if($interface) { $pattern .= $interface."\t"; } else { $pattern .= ".*\t"; } if($code !== '') { $pattern .= "code:$code\t"; } else { $pattern .= "code:\d+\t"; } if($msg) { $pattern .= "msg:$msg"; } $pattern .= '/'; // 指定偏移位置 if($pointer >= 0) { fseek($h, (int)$pointer); } // 查找符合条件的数据 $now_count = 0; $log_buffer = ''; while(1) { if(feof($h)) { break; } // 读1行 $line = fgets($h); if(preg_match($pattern, $line, $match)) { // 判断时间是否符合要求 $time = strtotime($match[1]); if($start_time) { if($time<$start_time) { continue; } } if($end_time) { if($time>$end_time) { break; } } // 收集符合条件的log $log_buffer .= $line; if(++$now_count >= $count) { break; } } } // 记录偏移位置 $pointer = ftell($h); return array('pointer'=>$pointer, 'data'=>$log_buffer); } /** * 获取统计数据 * @param string $module * @param string $interface * @param integer $start_time * @param integer $end_time * @return array */ protected function getStatistic($module, $interface, $start_time='',$end_time='') { // 正则表达式 $need_preg_match = $start_time || $end_time; $pattern = ''; if($need_preg_match) { $pattern .= "/^[\d\.]+\t(\d+)\t/"; } // log文件 $log_file = WORKERMAN_LOG_DIR . "statistic/st/{$module}/{$interface}|". ($start_time === '' ? date('Y-m-d') : date('Y-m-d', $start_time)); if(!is_readable($log_file)) { return false; } // 读文件 $h = fopen($log_file, 'r'); // time:[suc_count:xx,suc_cost_time:xx,fail_count:xx,fail_cost_time:xx] $st_data = array(); // 汇总计算 while(1) { if(feof($h)) { break; } // 读1行 $line = fgets($h); if(empty($line)) { continue; } if($need_preg_match && preg_match($pattern, $line, $match)) { // 判断时间是否符合要求 $time = $match[1]; if($start_time) { if($time<=$start_time) { continue; } } if($end_time) { if($time>=$end_time) { continue; } } } // line = IP time suc_count suc_cost_time fail_count fail_cost_time code_json $line_data = explode("\t", $line); $time_line = $line_data[1]; $suc_count = $line_data[2]; $suc_cost_time = $line_data[3]; $fail_count = $line_data[4]; $fail_cost_time = $line_data[5]; if(!isset($st_data[$time_line])) { $st_data[$time_line] = array('suc_count'=>0, 'suc_cost_time'=>0, 'fail_count'=>0, 'fail_cost_time'=>0); } $st_data[$time_line]['suc_count'] += $suc_count; $st_data[$time_line]['suc_cost_time'] += $suc_cost_time; $st_data[$time_line]['fail_count'] += $fail_count; $st_data[$time_line]['fail_cost_time'] += $fail_cost_time; } // 按照时间排序 ksort($st_data); // time => [total_count:xx,suc_count:xx,suc_avg_time:xx,fail_count:xx,fail_avg_time:xx,percent:xx] $data = array(); // 计算成功率 耗时 foreach($st_data as $time_line=>$item) { $data[$time_line] = array( 'time' => date('Y-m-d H:i:s', $time_line), 'total_count' => $item['suc_count']+$item['fail_count'], 'total_avg_time'=> $item['suc_count']+$item['fail_count'] == 0 ? 0 : round(($item['suc_cost_time']+$item['fail_cost_time'])/($item['suc_count']+$item['fail_count']), 4), 'suc_count' => $item['suc_count'], 'suc_avg_time' => $item['suc_count'] == 0 ? $item['suc_count'] : round($item['suc_cost_time']/$item['suc_count'], 4), 'fail_count' => $item['fail_count'], 'fail_avg_time' => $item['fail_count'] == 0 ? 0 : round($item['fail_cost_time']/$item['fail_count'], 4), 'precent' => $item['suc_count']+$item['fail_count'] == 0 ? 0 : round(($item['suc_count']*100/($item['suc_count']+$item['fail_count'])), 4), ); } $max_time_line = $time_line; $time_point = $start_time ? strtotime(date('Y-m-d', $start_time)) : strtotime(date('Y-m-d'))+300; for($i=0;$i<288,$time_point<=$max_time_line;$i++) { $data[$time_point] = isset($data[$time_point]) ? $data[$time_point] : array( 'time' => date('Y-m-d H:i:s', $time_point), 'total_count' => 0, 'total_avg_time'=> 0, 'suc_count' => 0, 'suc_avg_time' => 0, 'fail_count' => 0, 'fail_avg_time' => 0, 'precent' => 100, ); $time_point +=300; } ksort($data); return $data; } /** * 获取能展示统计数据的日期 * @param string $module * @param string $interface * @return array */ protected function getAvailableStDate($module, $interface) { $date_array = array(); $st_dir = WORKERMAN_LOG_DIR . 'statistic/st/'.$module.'/'; foreach(glob($st_dir."$interface|*") as $stFile) { $base_name = basename($stFile); $tmp = explode('|', $base_name); $date_array[strtotime($tmp[1])] = $tmp[1]; } ksort($date_array); return $date_array; } /** * 缓冲页面输出(non-PHPdoc) * @see SocketWorker::onStart() */ public function onStart() { ob_start(); } /** * 获取缓冲(non-PHPdoc) * @see SocketWorker::onAlarm() */ public function onAlarm() { $ob_content = ob_get_contents(); if($ob_content) { \WORKERMAN\Core\Lib\Log::add('StatisticService:ob_content:'.$ob_content); ob_clean(); } } } /** * * 画图的一个类 * */ class buildGraph { protected $graphwidth=800; protected $graphheight=300; protected $width_num=0; // 宽分多少等分 protected $height_num=10; // 高分多少等分，默认为10 protected $height_var=0; // 高度增量（用户数据平均数） protected $width_var=0; // 宽度增量（用户数据平均数） protected $height_max=0; // 最大数据值 protected $array_data=array(); // 用户待分析的数据的二维数组 protected $array_error=array(); // 收集错误信息 protected $colorBg=array(255,255,255); // 图形背景-白色 protected $colorGrey=array(192,192,192); // 灰色画框 protected $colorBlue=array(0,0,255); // 蓝色 protected $colorRed=array(255,0,0); // 红色（点） protected $colorDarkBlue=array(0, 0, 255); // 深色 protected $colorBlack=array(0,0,0); protected $colorLightBlue=array(200,200,255); // 浅色 protected $array_color; // 曲线着色（存储十六进制数） protected $image; // 我们的图像 /** * 方法：接受用户数据 */ function addData($array_user_data){ if(!is_array($array_user_data) or empty($array_user_data)){ $this->array_error['addData']="没有可供分析的数据"; return false; } $i=count($this->array_data); $this->array_data[$i]=$array_user_data; } /** * 方法：定义画布宽和长 */ function setImg($img_width,$img_height){ $this->graphwidth=$img_width; $this->graphheight=$img_height; } /** * 设定Y轴的增量等分，默认为10份 */ function setHeightNum($var_y){ $this->height_num=$var_y; } /** * 定义各图形各部分色彩 */ function getRgb($color){ // 得到十进制色彩 $R=($color>>16) &0xff; $G=($color>>8) &0xff; $B=($color) & 0xff; return(array($R,$G,$B)); } /** * 定义背景色 * @param unknown_type $c1 * @param unknown_type $c2 * @param unknown_type $c3 */ function setColorBg($c1,$c2,$c3){ $this->colorBg=array($c1,$c2,$c3); } /** * 定义画框色 */ function setColorGrey($c1,$c2,$c3){ $this->colorGrey=array($c1,$c2,$c3); } /** * 定义蓝色 * @param unknown_type $c1 * @param unknown_type $c2 * @param unknown_type $c3 */ function setColorBlue($c1,$c2,$c3){ $this->colorBlue=array($c1,$c2,$c3); } /** * 定义色Red */ function setColorRed($c1,$c2,$c3){ $this->colorRed=array($c1,$c2,$c3); } /** * 定义深色 * @param unknown_type $c1 * @param unknown_type $c2 * @param unknown_type $c3 */ function setColorDarkBlue($c1,$c2,$c3){ $this->colorDarkBlue=array($c1,$c2,$c3); } /** * 定义浅色 * @param unknown_type $c1 * @param unknown_type $c2 * @param unknown_type $c3 */ function setColorLightBlue($c1,$c2,$c3){ $this->colorLightBlue=array($c1,$c2,$c3); } /** * 方法:由用户数据将画布分成若干等份宽 * 并计算出每份多少像素 */ function getWidthNum(){ $this->width_num=count($this->array_data[0]); } /** * * @return mixed */ function getMaxHeight(){ // 获得用户数据的最大值 $tmpvar=array(); foreach($this->array_data as$tmp_value){ $tmpvar[]=max($tmp_value); } $this->height_max=max($tmpvar); return max($tmpvar); } /** * * @return number */ function getHeightLength(){ // 计算出每格的增量长度(用户数据，而不是图形的像素值) $max_var=$this->getMaxHeight(); $max_var=ceil($max_var/$this->height_num); $first_num=substr($max_var,0,1); if(substr($max_var,1,1)){ if(substr($max_var,1,1)>=5) $first_num+=1; } for($i=1;$igetWidthNum(); // 得到高度增量和宽度增量 $this->height_var=$this->getHeightLength(); $this->width_var=$this->graphwidth/$this->width_num; } /** * * @param unknown_type $str_colors */ function setColors($str_colors){ // 用于多条曲线的不同着色，如$str_colors="ee00ff,dd0000,cccccc" $this->array_color=explode(",",$str_colors); } /** * * @param unknown_type $var_num */ function buildLine($var_num){ if(!empty($var_num)){ // 如果用户只选择显示一条曲线 $array_tmp[0]=$this->array_data[$var_num-1]; $this->array_data=$array_tmp; } for($j=0;$jarray_data);$j++){ list($R,$G,$B)=$this->getRgb(hexdec($this->array_color[$j])); $colorBlue=imagecolorallocate($this->image,$R,$G,$B); for($i=0;$i<$this->width_num-1;$i++){ $height_pix=$this->height_max == 0 ? 0 : round(($this->array_data[$j][$i]/$this->height_max)*$this->graphheight); $height_next_pix= $this->height_max*$this->graphheight == 0 ? 0 : round($this->array_data[$j][$i+1]/$this->height_max*$this->graphheight); imageline($this->image,$this->width_var*$i,$this->graphheight-$height_pix,$this->width_var*($i+1),$this->graphheight-$height_next_pix,$colorBlue); } } } /** * * @param unknown_type $select_gra */ function buildRectangle($select_gra){ if(!empty($select_gra)){ // 用户选择显示一个矩形 $select_gra-=1; } // 画矩形 // 配色 $colorDarkBlue=imagecolorallocate($this->image,$this->colorDarkBlue[0], $this->colorDarkBlue[1],$this->colorDarkBlue[2]); $colorLightBlue=imagecolorallocate($this->image,$this->colorLightBlue[0], $this->colorLightBlue[1],$this->colorLightBlue[2]); if(empty($select_gra)) $select_gra=0; for($i=0; $i<$this->width_num; $i++){ $height_pix = $this->height_max == 0 ? 0 : round(($this->array_data[$select_gra][$i]/$this->height_max)*$this->graphheight); imagefilledrectangle($this->image,$this->width_var*$i,$this->graphheight-$height_pix,$this->width_var*($i+1),$this->graphheight,$colorDarkBlue); imagefilledrectangle($this->image,($i*$this->width_var)+1,($this->graphheight-$height_pix)+1,$this->width_var*($i+1)-5,$this->graphheight-2,$colorLightBlue); } } /** * */ function createCloths(){ // 创建画布 $this->image=imagecreate($this->graphwidth+20,$this->graphheight+20); } /** * */ function createFrame(){ // 创建画框 $this->getVarWh(); // 配色 $colorBg=imagecolorallocate($this->image,$this->colorBg[0], $this->colorBg[1],$this->colorBg[2]); $colorGrey=imagecolorallocate($this->image,$this->colorGrey[0], $this->colorGrey[1],$this->colorGrey[2]); // 创建图像周围的框 imageline($this->image, 0, 0, 0,$this->graphheight,$colorGrey); imageline($this->image, 0, 0,$this->graphwidth, 0,$colorGrey); imageline($this->image,($this->graphwidth-1),0,($this->graphwidth-1),($this->graphheight-1),$colorGrey); imageline($this->image,0,($this->graphheight-1),($this->graphwidth-1),($this->graphheight-1),$colorGrey); } /** * */ function createLine(){ // 创建网格。 $this->getVarWh(); $colorBg=imagecolorallocate($this->image,$this->colorBg[0], $this->colorBg[1],$this->colorBg[2]); $colorGrey=imagecolorallocate($this->image,$this->colorGrey[0], $this->colorGrey[1],$this->colorGrey[2]); $colorRed=imagecolorallocate($this->image,$this->colorRed[0], $this->colorRed[1],$this->colorRed[2]); $colorBlack=imagecolorallocate($this->image,$this->colorBlack[0], $this->colorBlack[1],$this->colorBlack[2]); for($j=0;$j<$this->width_num;$j++){ if($j%12 == 0){ // 画竖线 imageline($this->image,$j*$this->width_var,0,$j*$this->width_var,$this->graphheight,$colorGrey); // 标出数字 imagestring($this->image,2,$this->width_var*$j,$this->graphheight,$j/12,$colorBlack); } } for($i=1;$i<=$this->height_num;$i++){ // 画横线 imageline($this->image,0,$this->graphheight-($this->height_max*$this->graphheight == 0 ? 0 : ($this->height_var/$this->height_max*$this->graphheight)*$i),$this->graphwidth,$this->graphheight - ($this->height_max*$this->graphheight == 0 ? 0 : ($this->height_var/$this->height_max*$this->graphheight)*$i),$colorGrey); // 标出数字 imagestring($this->image,2,0,$this->graphheight-($this->height_max*$this->graphheight == 0 ? 0 : ($this->height_var/$this->height_max*$this->graphheight)*$i),$this->height_var*$i,$colorBlack); } } /** * * @param unknown_type $graph * @param unknown_type $str_var */ function build($graph,$str_var){ // $graph是用户指定的图形种类,$str_var是生成哪个数据的图 $this->createCloths(); // 先要有画布啊~~ switch ($graph){ case"line": $this->createFrame(); // 画个框先：） $this->createLine(); // 打上底格线 $this->buildLine($str_var); // 画曲线 break; case"rectangle": $this->createFrame(); // 画个框先：） $this->buildRectangle($str_var); // 画矩形 $this->createLine(); // 打上底格线 break; } // 输出图形并清除内存 imagepng($this->image); imagedestroy($this->image); } }