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.
557 lines
20 KiB
PHP
557 lines
20 KiB
PHP
<?php
|
|
|
|
namespace Base\Repository;
|
|
|
|
class UserRepository
|
|
{
|
|
|
|
public function __construct()
|
|
{
|
|
|
|
}
|
|
|
|
private function assembleRecords($items, $keys, $valueColumn, $keyColumn = 'day')
|
|
{
|
|
$records = [];
|
|
foreach ($keys as $key) {
|
|
$value = 0;
|
|
foreach ($items as $item) {
|
|
if ($item[$keyColumn] == $key) {
|
|
$value = $item[$valueColumn];
|
|
}
|
|
}
|
|
$records[$key] = $value;
|
|
}
|
|
return $records;
|
|
}
|
|
|
|
private function setKeys($params, $alias)
|
|
{
|
|
$records = [];
|
|
foreach ($params as $key => $value) {
|
|
$records[$alias . '.' . $key] = $value;
|
|
}
|
|
return $records;
|
|
}
|
|
|
|
private function getDayGroupConditions($params)
|
|
{
|
|
$beginTime = $params['begin_time'] ?? 0;
|
|
$endTime = $params['end_time'] ?? 0;
|
|
$gameId = $params['game_id'] ?? 0;
|
|
$ids = $params['promote_id'] ?? [];
|
|
|
|
$conditions = [];
|
|
$conditions['promote_id'] = ['in', $ids];
|
|
$conditions[$params['time_column']] = ['between', [$beginTime, $endTime]];
|
|
if ($gameId > 0) {
|
|
$conditions['game_id'] = $gameId;
|
|
}
|
|
$conditions['pay_way'] = $isBan ? ['neq', '-10'] : ['neq', '-1'];
|
|
|
|
return $conditions;
|
|
}
|
|
|
|
private function getGameGroupConditions($params)
|
|
{
|
|
$beginTime = $params['begin_time'] ?? 0;
|
|
$endTime = $params['end_time'] ?? 0;
|
|
$ids = $params['promote_ids'] ?? [];
|
|
$gameIds = $params['game_ids'] ?? [];
|
|
|
|
$conditions = [];
|
|
$conditions['promote_id'] = ['in', $ids];
|
|
if (!empty($gameIds)) {
|
|
$conditions['game_id'] = ['in', $gameIds];
|
|
}
|
|
$conditions[$params['time_column']] = ['between', [$beginTime, $endTime]];
|
|
|
|
return $conditions;
|
|
}
|
|
|
|
private function getCreateRoleConditions($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'] ?? [];
|
|
|
|
$conditions = [];
|
|
$conditions['promote_id'] = ['in', $ids];
|
|
$conditions[$params['time_column']] = ['between', [$beginTime, $endTime]];
|
|
if ($gameId > 0) {
|
|
$conditions['game_id'] = $gameId;
|
|
}
|
|
if ($serverId > 0) {
|
|
$conditions['server_id'] = $serverId;
|
|
}
|
|
|
|
return $conditions;
|
|
}
|
|
|
|
private function getCreateRoleByGameConditions($params)
|
|
{
|
|
$beginTime = $params['begin_time'] ?? 0;
|
|
$endTime = $params['end_time'] ?? 0;
|
|
$ids = $params['promote_ids'] ?? [];
|
|
$gameIds = $params['game_ids'] ?? [];
|
|
$serverId = $params['server_id'] ?? 0;
|
|
|
|
$conditions = [];
|
|
$conditions['promote_id'] = ['in', $ids];
|
|
$conditions['game_id'] = ['in', $gameIds];
|
|
if ($serverId > 0) {
|
|
$conditions['server_id'] = $serverId;
|
|
}
|
|
$conditions[$params['time_column']] = ['between', [$beginTime, $endTime]];
|
|
|
|
return $conditions;
|
|
}
|
|
|
|
/**
|
|
* 按照时间分组统计登录总数
|
|
*/
|
|
public function getLoginCountGroupByDay($params)
|
|
{
|
|
$dayList = $params['dayList'] ?? [];
|
|
$params['time_column'] = 'create_time';
|
|
$conditions = $this->getDayGroupConditions($params);
|
|
$items = M('login_daily_record', 'tab_')->field('FROM_UNIXTIME(create_time, "%Y-%m-%d") as day, count(DISTINCT user_id) as count')
|
|
->where($conditions)
|
|
->group('day')
|
|
->select();
|
|
|
|
return $this->assembleRecords($items, $dayList, 'count');
|
|
}
|
|
|
|
/**
|
|
* 按照时间分组统计登录总数
|
|
*/
|
|
public function getLoginCountGroupByDayNew($params)
|
|
{
|
|
$dayList = $params['dayList'] ?? [];
|
|
$params['time_column'] = 'create_time';
|
|
$conditions = $this->getDayGroupConditions($params);
|
|
$subQuery = M('login_daily_record', 'tab_')->field('FROM_UNIXTIME(create_time, "%Y-%m-%d") as day,count(DISTINCT user_id) as count')
|
|
->where($conditions)
|
|
->group('day,game_id')
|
|
->buildSql();
|
|
$items = M()->field('*,sum(count) as count')
|
|
->table($subQuery)
|
|
->alias('a')
|
|
->group('day')
|
|
->select();
|
|
|
|
return $this->assembleRecords($items, $dayList, 'count');
|
|
}
|
|
|
|
/**
|
|
* 按照游戏分组统计登录总数
|
|
*/
|
|
public function getLoginCountGroupByGame($params)
|
|
{
|
|
$gameIds = $params['game_ids'] ?? [];
|
|
$params['time_column'] = 'create_time';
|
|
$conditions = $this->getGameGroupConditions($params);
|
|
if (isset($params['all_data'])) {
|
|
$sql = M('login_daily_record', 'tab_')->field('distinct game_id, user_id')
|
|
->where($conditions)
|
|
->fetchSql(true)
|
|
->select();
|
|
$model = new \Think\Model();
|
|
return $model->query("select count(*) as num from ($sql) as t")[0]['num'];
|
|
} else {
|
|
$items = M('login_daily_record', 'tab_')->field('game_id, count(DISTINCT user_id) as count')
|
|
->where($conditions)
|
|
->group('game_id')
|
|
->select();
|
|
|
|
return $this->assembleRecords($items, $gameIds, 'count', 'game_id');
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 按照时间分组统计注册总数
|
|
*/
|
|
public function getRegisterCountGroupByDay($params)
|
|
{
|
|
$dayList = $params['dayList'] ?? [];
|
|
$params['time_column'] = 'register_time';
|
|
$conditions = $this->getDayGroupConditions($params);
|
|
|
|
$items = M('user', 'tab_')->field('count(*) count, FROM_UNIXTIME(register_time, "%Y-%m-%d") as day')
|
|
->where($conditions)
|
|
->group('day')
|
|
->select();
|
|
return $this->assembleRecords($items, $dayList, 'count');
|
|
}
|
|
|
|
/**
|
|
* 按照游戏分分组统计注册总数
|
|
*/
|
|
public function getRegisterCountGroupByGame($params)
|
|
{
|
|
$gameIds = $params['game_ids'] ?? [];
|
|
$params['time_column'] = 'register_time';
|
|
$conditions = $this->getGameGroupConditions($params);
|
|
|
|
$items = M('user', 'tab_')->field('count(*) count, fgame_id')
|
|
->where($conditions)
|
|
->group('fgame_id')
|
|
->select();
|
|
return $this->assembleRecords($items, $gameIds, 'count', 'fgame_id');
|
|
}
|
|
|
|
/**
|
|
* 按照时间分组统计注册编号序列
|
|
* @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;
|
|
}
|
|
|
|
/**
|
|
* 按照时间统计创角数
|
|
*/
|
|
public function getCreateRoleCountByDay($params)
|
|
{
|
|
$dayList = $params['dayList'] ?? [];
|
|
$params['time_column'] = 'create_time';
|
|
$conditions = $this->getCreateRoleConditions($params);
|
|
|
|
$items = M('user_play_info', 'tab_')->field('count(*) count, FROM_UNIXTIME(create_time, "%Y-%m-%d") as day')
|
|
->where($conditions)
|
|
->group('day')
|
|
->select();
|
|
return $this->assembleRecords($items, $dayList, 'count');
|
|
}
|
|
|
|
/**
|
|
* 按照游戏统计创角数
|
|
*/
|
|
public function getCreateRoleCountByGame($params)
|
|
{
|
|
$gameIds = $params['game_ids'] ?? [];
|
|
$params['time_column'] = 'create_time';
|
|
$conditions = $this->getCreateRoleByGameConditions($params);
|
|
|
|
if (isset($params['all_data'])) {
|
|
return M('user_play_info', 'tab_')
|
|
->where($conditions)
|
|
->count();
|
|
} else {
|
|
$items = M('user_play_info', 'tab_')->field('count(*) count, game_id')
|
|
->where($conditions)
|
|
->group('game_id')
|
|
->select();
|
|
return $this->assembleRecords($items, $gameIds, 'count', 'game_id');
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 按照时间统计创角用户(去重)
|
|
*/
|
|
public function getCreateRoleUserCountByDay($params)
|
|
{
|
|
$dayList = $params['dayList'] ?? [];
|
|
$params['time_column'] = 'create_time';
|
|
$conditions = $this->getCreateRoleConditions($params);
|
|
|
|
$subQuery = M('user_play_info', 'tab_')->field('FROM_UNIXTIME(create_time, "%Y-%m-%d") as day,count(DISTINCT user_id) as count')
|
|
->where($conditions)
|
|
->group('day,game_id')
|
|
->buildSql();
|
|
$items = M()->field('*,sum(count) as count')
|
|
->table($subQuery)
|
|
->alias('a')
|
|
->group('day')
|
|
->select();
|
|
return $this->assembleRecords($items, $dayList, 'count');
|
|
}
|
|
|
|
/**
|
|
* 按照游戏统计创角用户(去重)
|
|
*/
|
|
public function getCreateRoleUserCountByGame($params)
|
|
{
|
|
$gameIds = $params['game_ids'] ?? [];
|
|
$params['time_column'] = 'create_time';
|
|
$conditions = $this->getCreateRoleByGameConditions($params);
|
|
|
|
if (isset($params['all_data'])) {
|
|
$sql = M('user_play_info', 'tab_')->field('distinct game_id, user_id')
|
|
->where($conditions)
|
|
->fetchSql(true)
|
|
->select();
|
|
$model = new \Think\Model();
|
|
return $model->query("select count(*) as num from ($sql) as t")[0]['num'];
|
|
} else {
|
|
$items = M('user_play_info', 'tab_')->field('count(distinct user_id) count, game_id')
|
|
->where($conditions)
|
|
->group('game_id')
|
|
->select();
|
|
return $this->assembleRecords($items, $gameIds, 'count', 'game_id');
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 按照时间统计新创角用户(去重)
|
|
*/
|
|
public function getNewCreateRoleUserCountByDay($params)
|
|
{
|
|
$dayList = $params['dayList'] ?? [];
|
|
$params['time_column'] = 'create_time';
|
|
$conditions = $this->getCreateRoleConditions($params);
|
|
$conditionsSql = $conditions;
|
|
unset($conditionsSql['begin_time']);
|
|
unset($conditionsSql['end_time']);
|
|
$alias = 'ti';
|
|
$conditionsSql = $this->setKeys($conditionsSql, $alias);
|
|
$model = M('user_play_info', 'tab_');
|
|
|
|
$sql = $model->alias($alias)
|
|
->where($conditionsSql)
|
|
->where("ti.user_id = user_id and ti.game_id = game_id and ti.create_time < " . $params['begin_time'])
|
|
->fetchSql(true)
|
|
->count();
|
|
$subQuery = $model->field('FROM_UNIXTIME(create_time, "%Y-%m-%d") as day,count(DISTINCT user_id) as count')
|
|
->where($conditions)
|
|
->group('day,game_id')
|
|
->buildSql();
|
|
$items = M()->field("*,sum(count) as count,(" . $sql . ") as num")
|
|
->table($subQuery)
|
|
->alias('a')
|
|
->group('day')
|
|
->having('num = 0')
|
|
->select();
|
|
return $this->assembleRecords($items, $dayList, 'count');
|
|
}
|
|
|
|
/**
|
|
* 按照游戏统计新创角用户(去重)
|
|
*/
|
|
public function getNewCreateRoleUserCountByGame($params)
|
|
{
|
|
$gameIds = $params['game_ids'] ?? [];
|
|
$params['time_column'] = 'create_time';
|
|
$conditions = $this->getCreateRoleByGameConditions($params);
|
|
$conditionsSql = $conditions;
|
|
unset($conditionsSql['begin_time']);
|
|
unset($conditionsSql['end_time']);
|
|
$alias = 'ti';
|
|
$conditionsSql = $this->setKeys($conditionsSql, $alias);
|
|
$model = M('user_play_info', 'tab_');
|
|
|
|
$sql = $model->alias($alias)
|
|
->where($conditionsSql)
|
|
->where("ti.user_id = user_id and ti.game_id = game_id and ti.create_time < " . $params['begin_time'])
|
|
->fetchSql(true)
|
|
->count();
|
|
if (isset($params['all_data'])) {
|
|
return count($model->field("game_id, (" . $sql . ") as num")
|
|
->where($conditions)
|
|
->group('game_id, user_id')
|
|
->having('num = 0')
|
|
->select());
|
|
} else {
|
|
$items = $model->field("count(distinct user_id) count, game_id, (" . $sql . ") as num")
|
|
->where($conditions)
|
|
->group("game_id")
|
|
->having('num = 0')
|
|
->select();
|
|
return $this->assembleRecords($items, $gameIds, 'count', 'game_id');
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 按照时间统计新创角设备(去重)
|
|
*/
|
|
public function getNewCreateRoleDeviceCountByDay($params)
|
|
{
|
|
$dayList = $params['dayList'] ?? [];
|
|
$params['time_column'] = 'create_time';
|
|
$conditions = $this->getCreateRoleConditions($params);
|
|
$conditionsSql = $conditions;
|
|
unset($conditionsSql['begin_time']);
|
|
unset($conditionsSql['end_time']);
|
|
$alias = 'ti';
|
|
$conditionsSql = $this->setKeys($conditionsSql, $alias);
|
|
$model = M('user_play_info', 'tab_');
|
|
|
|
$sql = $model->alias($alias)
|
|
->where($conditionsSql)
|
|
->where("ti.create_device_number = create_device_number and ti.game_id = game_id and ti.create_time < " . $params['begin_time'])
|
|
->fetchSql(true)
|
|
->count();
|
|
$subQuery = $model->field('FROM_UNIXTIME(create_time, "%Y-%m-%d") as day,count(DISTINCT create_device_number) as count')
|
|
->where($conditions)
|
|
->group('day,game_id')
|
|
->buildSql();
|
|
$items = M()->field("*,sum(count) as count,(" . $sql . ") as num")
|
|
->table($subQuery)
|
|
->alias('a')
|
|
->group('day')
|
|
->having('num = 0')
|
|
->select();
|
|
return $this->assembleRecords($items, $dayList, 'count');
|
|
}
|
|
|
|
/**
|
|
* 按照游戏统计新创角设备(去重)
|
|
*/
|
|
public function getNewCreateRoleDeviceCountByGame($params)
|
|
{
|
|
$gameIds = $params['game_ids'] ?? [];
|
|
$params['time_column'] = 'create_time';
|
|
$conditions = $this->getCreateRoleByGameConditions($params);
|
|
$conditionsSql = $conditions;
|
|
unset($conditionsSql['begin_time']);
|
|
unset($conditionsSql['end_time']);
|
|
$alias = 'ti';
|
|
$conditionsSql = $this->setKeys($conditionsSql, $alias);
|
|
$model = M('user_play_info', 'tab_');
|
|
|
|
$sql = $model->alias($alias)
|
|
->where($conditionsSql)
|
|
->where("ti.create_device_number = create_device_number and ti.game_id = game_id and ti.create_time < " . $params['begin_time'])
|
|
->fetchSql(true)
|
|
->count();
|
|
if (isset($params['all_data'])) {
|
|
return count($model->field("game_id, (" . $sql . ") as num")
|
|
->where($conditions)
|
|
->group('game_id, create_device_number')
|
|
->having('num = 0')
|
|
->select());
|
|
} else {
|
|
$items = $model->field("count(distinct game_id,create_device_number) count, game_id, (" . $sql . ") as num")
|
|
->where($conditions)
|
|
->group("game_id")
|
|
->having('num = 0')
|
|
->select();
|
|
return $this->assembleRecords($items, $gameIds, 'count', 'game_id');
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 按照时间统计新创角IP(去重)
|
|
*/
|
|
public function getNewCreateRoleIpCountByDay($params)
|
|
{
|
|
$dayList = $params['dayList'] ?? [];
|
|
$params['time_column'] = 'create_time';
|
|
$conditions = $this->getCreateRoleConditions($params);
|
|
$conditionsSql = $conditions;
|
|
unset($conditionsSql['begin_time']);
|
|
unset($conditionsSql['end_time']);
|
|
$alias = 'ti';
|
|
$conditionsSql = $this->setKeys($conditionsSql, $alias);
|
|
$model = M('user_play_info', 'tab_');
|
|
|
|
$sql = $model->alias($alias)
|
|
->where($conditionsSql)
|
|
->where("ti.create_ip = create_ip and ti.game_id = game_id and ti.create_time < " . $params['begin_time'])
|
|
->fetchSql(true)
|
|
->count();
|
|
$subQuery = $model->field('FROM_UNIXTIME(create_time, "%Y-%m-%d") as day,count(DISTINCT create_ip) as count')
|
|
->where($conditions)
|
|
->group('day,game_id')
|
|
->buildSql();
|
|
$items = M()->field("*,sum(count) as count,(" . $sql . ") as num")
|
|
->table($subQuery)
|
|
->alias('a')
|
|
->group('day')
|
|
->having('num = 0')
|
|
->select();
|
|
return $this->assembleRecords($items, $dayList, 'count');
|
|
}
|
|
|
|
/**
|
|
* 按照游戏统计新创角IP(去重)
|
|
*/
|
|
public function getNewCreateRoleIpCountByGame($params)
|
|
{
|
|
$gameIds = $params['game_ids'] ?? [];
|
|
$params['time_column'] = 'create_time';
|
|
$conditions = $this->getCreateRoleByGameConditions($params);
|
|
$conditionsSql = $conditions;
|
|
unset($conditionsSql['begin_time']);
|
|
unset($conditionsSql['end_time']);
|
|
$alias = 'ti';
|
|
$conditionsSql = $this->setKeys($conditionsSql, $alias);
|
|
$model = M('user_play_info', 'tab_');
|
|
|
|
$sql = $model->alias($alias)
|
|
->where($conditionsSql)
|
|
->where("ti.create_ip = create_ip and ti.game_id = game_id and ti.create_time < " . $params['begin_time'])
|
|
->fetchSql(true)
|
|
->count();
|
|
if (isset($params['all_data'])) {
|
|
return count($model->field("game_id, (" . $sql . ") as num")
|
|
->where($conditions)
|
|
->group('game_id, create_ip')
|
|
->having('num = 0')
|
|
->select());
|
|
} else {
|
|
$items = $model->field("count(distinct game_id,create_ip) count, game_id, (" . $sql . ") as num")
|
|
->where($conditions)
|
|
->group("game_id")
|
|
->having('num = 0')
|
|
->select();
|
|
return $this->assembleRecords($items, $gameIds, 'count', 'game_id');
|
|
}
|
|
}
|
|
|
|
public function getActiveUserCountRecently($dayCount = 1, $params = [])
|
|
{
|
|
$conditions = [];
|
|
$endTime = strtotime(date('Y-m-d 23:59:59'));
|
|
$beginTime = $endTime + 1 - $dayCount * 24 * 3600;
|
|
$conditions = ['login_time' => ['between', [$beginTime, $endTime]]];
|
|
$item = M('user_login_record', 'tab_')->field('count(DISTINCT user_id) as count')
|
|
->where($conditions)
|
|
->find();
|
|
return $item['count'];
|
|
}
|
|
} |