You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
134 lines
4.2 KiB
PHP
134 lines
4.2 KiB
PHP
<?php
|
|
namespace Base\Repository;
|
|
|
|
class UserRepository {
|
|
|
|
public function __construct()
|
|
{
|
|
|
|
}
|
|
|
|
private function assembleDayRecords($items, $dayList, $valueColumn, $dayColumn = 'day')
|
|
{
|
|
$records = [];
|
|
foreach ($dayList as $day) {
|
|
$dayValue = 0;
|
|
foreach ($items as $item) {
|
|
if ($item[$dayColumn] == $day) {
|
|
$dayValue = $item[$valueColumn];
|
|
}
|
|
}
|
|
$records[$day] = $dayValue;
|
|
}
|
|
return $records;
|
|
}
|
|
|
|
/**
|
|
* 按照时间分组统计登录总数
|
|
*/
|
|
public function getLoginCountByDay($params) {
|
|
$beginTime = $params['begin_time'] ?? 0;
|
|
$endTime = $params['end_time'] ?? 0;
|
|
$gameId = $params['game_id'] ?? 0;
|
|
$serverId = $params['server_id'] ?? 0;
|
|
$ids = $params['promote_id'] ?? [];
|
|
$dayList = $params['dayList'] ?? [];
|
|
|
|
$map = [];
|
|
$map['login_time'] = ['between', [$beginTime, $endTime]];
|
|
|
|
if ($gameId > 0) {
|
|
$map['game_id'] = $gameId;
|
|
}
|
|
if ($serverId > 0) {
|
|
$map['server_id'] = $serverId;
|
|
}
|
|
$map['promote_id'] = ['in', $ids];
|
|
|
|
$items = M('user_login_record', 'tab_')->field('FROM_UNIXTIME(login_time, "%Y-%m-%d") as day, count(DISTINCT user_id) as count')
|
|
->where($map)
|
|
->group('day')
|
|
->select();
|
|
|
|
return $this->assembleDayRecords($items, $dayList, 'count');
|
|
}
|
|
|
|
/**
|
|
* 按照时间分组统计注册总数
|
|
*/
|
|
public function getRegisterCountByDay($params) {
|
|
$beginTime = $params['begin_time'] ?? 0;
|
|
$endTime = $params['end_time'] ?? 0;
|
|
$gameId = $params['game_id'] ?? 0;
|
|
$serverId = $params['server_id'] ?? 0;
|
|
$ids = $params['promote_id'] ?? [];
|
|
$dayList = $params['dayList'] ?? [];
|
|
|
|
$dateform = '%Y-%m-%d';
|
|
|
|
$map = [];
|
|
$map['register_time'] = ['between', [$beginTime, $endTime]];
|
|
|
|
if ($gameId > 0) {
|
|
$map['fgame_id'] = $gameId;
|
|
}
|
|
|
|
$map['promote_id'] = ['in', $ids];
|
|
$map['puid'] = 0;
|
|
|
|
$items = M('user', 'tab_')->field('count(*) count, FROM_UNIXTIME(register_time,"'.$dateform.'") as day')
|
|
->where($map)
|
|
->group('day')
|
|
->select();
|
|
return $this->assembleDayRecords($items, $dayList, 'count');
|
|
}
|
|
|
|
/**
|
|
* 按照时间分组统计注册编号序列
|
|
* @param string $newslist 新玩家序列
|
|
* @param integer $end 结束时间（时间戳）
|
|
* @param integer $game_id 游戏编号
|
|
* @param integer/string $promote_id 渠道编号或渠道编号列表字符串（字符串逗号分隔）
|
|
* @param integer $flag 留存类型
|
|
* @return array 详细数据
|
|
* @author 鹿文学
|
|
*/
|
|
public function getRatentionRate($newslist,$game_id=0,$promote_id=0,$flag=1) {
|
|
|
|
|
|
$map['lock_status']=1;
|
|
if($game_id>0) {
|
|
$map['up.game_id'] = $game_id;
|
|
}
|
|
$map['tab_user.promote_id'] = is_numeric($promote_id)?$promote_id:array('in',$promote_id);
|
|
|
|
$group = 'up.login_time';
|
|
|
|
$fieldname = 'retention_rate'.$flag;
|
|
|
|
foreach ($newslist as $value) {
|
|
$ct1 = strtotime("+$flag day",strtotime($value['time']));
|
|
$ct2 = strtotime("+1 day",$ct1)-1;
|
|
|
|
$map[$group] = array(array('egt',$ct1),array('elt',$ct2));
|
|
|
|
$map['user_id']=array('in',$value['id']);
|
|
$count = count(explode(',',$value['id']));
|
|
|
|
|
|
$d = $this
|
|
->field('count(distinct up.user_id) as '.$fieldname.' ,FROM_UNIXTIME(up.login_time,"%Y-%m-%d") as play_time')
|
|
->join('tab_user_login_record up on tab_user.id=up.user_id','right')
|
|
->where($map)
|
|
->group('play_time')
|
|
->select();
|
|
|
|
if ($d)
|
|
$data[]=array(
|
|
"play_time"=>$value['time'],
|
|
$fieldname=>($d[0][$fieldname]==0)?0:sprintf("%.2f",($d[0][$fieldname]/$count)*100)
|
|
);
|
|
}
|
|
return $data;
|
|
}
|
|
} |