/**
* TODO:统计{$data}.{$op}.log记录数
* @param string $date
* @param int $appid
* @param string $op
* @param array $condition
* @return array
*/
public function countFile($date , $appid , $op ,$condition=array())
{
$data['count'] = 0;
$handle = self::_openFile($date , $appid , $op );
if($handle)
{
$handle->setMaxLineLen($this->length);
while (!$handle->eof())
{
$tmp = $handle->current();
if(empty($tmp)) continue;
$tmp = self::_parseData($tmp);
if($condition && is_array($condition) )
{
$key = array_keys($condition);
if(isset($tmp['data'][$key[0]]) && $tmp['data'][$key[0]] && in_array($tmp['data'][$key[0]], $condition[$key[0]]))
{
$data['count']++;
}
}
else
{
$data['count']++;
}
unset($tmp);
$handle->next();
}
}
unset($handle , $condition , $tmp , $key , $val);
self::closeFile($date , $appid , $op );
$data['diffTime'] = doubleval(microtime(true)) - doubleval($this->startTime);
$data['memory'] = doubleval((doubleval(memory_get_usage(true)) - doubleval(self::$startMemory))/1024/1024) . ' M';
return $data;
}
/**
* TODO:统计用户数
* @param string $date
* @param int $appid
* @param string $op
* @param bool $midflag :默认为false 则 mid返回空数组;如设为true,则mid数组不为空
* * @param bool $jsonFlag:默认为true, 则保留jsondata字段;设为false,则去掉jsondata字段
* @param array $condition
* @return : array:形如({"mid":[],"count":2181,"diffTime":0.0397667884827,"memory":"3.75 M"})
*/
public function countFileMID($date , $appid , $op , $midflag=false , $jsonFlag=false, $condition=array())
{
//$count = self::total_lineFile($date , $appid , $op );
$count = self::countFile($date , $appid , $op );
$index = ceil($count['count'] / $this->limit);
$result = array('mid'=>array() , 'count'=>0 , 'diffTime'=>0 , 'memory'=>0);
for ($i=0 ; $i<$index ; $i++)
{
$startNum = $this->limit*$i;
$endNum = $this->limit;
$data = self::readFile($date , $appid , $op , $startNum , $endNum , $jsonFlag);
var_dump($data);exit();
if($data['data'] && is_array($data['data']))
{
foreach ($data['data'] as $arr)
{
if($condition && is_array($condition))
{
$key = array_keys($condition);
if(isset($arr['data'][$key[0]]) && (in_array($arr['data'][$key[0]] , $condition[$key]) || empty($condition[$key[0]])))
{
$result['mid'][$arr["mid"]] =1;
$result['count']++;
}
}
else
{
$result['mid'][$arr["mid"]] =1;
$result['count']++;
}
unset($data);
}
}
}
unset($index , $count , $condition , $data , $arr);
self::closeFile($date , $appid , $op);
$result['mid'] = array_keys($result['mid']);
if(empty($midflag)) unset($result['mid']);
$result['diffTime'] = doubleval(microtime(true)) - doubleval($this->startTime);
$result['memory'] = (memory_get_usage(true) - self::$startMemory)/1024/1024 . ' M';
return $result;
}
/**
* TODO:跨时间段 统计参加$op用户数据
* @param string $date
* @param int $appid
* @param string $op
* @param number $day
* @param bool $midflag :默认为false 则 mid返回空数组;如设为true,则mid数组不为空
* @return array 形如("20140326":{"mid":[],"count":4571,"diffTime":0.0806441307068,"memory":"3.75 M"},
* "20140325":{"mid":[],"count":2181,"diffTime":0.0397667884827,"memory":"3.75 M"})
*/
public function getReturnUser($date , $appid , $op , $day=1 , $midflag=false)
{
$date_i=0;
for ($i =0; $i<$day ; $i++){
$date_i = date('Ymd' , strtotime($date)-$i*86400);
$result[$date_i] = self::countFileMID($date_i , $appid , $op , $midflag);
}
unset($date , $date_i , $appid , $op , $day);
return $result;
}
}
?>
Lib_File1.php
复制代码 代码如下: