*/ class StatController extends ThinkController { public function user($p=1) { $page = intval($p); $page = $page ? $page : 1; //默认显示第一页数据 if(isset($_REQUEST['row'])) {$row = $_REQUEST['row'];}else{$row = 10;} if(is_numeric($_REQUEST['game_id']) && $_REQUEST['game_id']>0) { $game_id = I('game_id',''); $gamesource = get_source_from_game($game_id); } else { $gamesource = '全部'; } if(is_numeric($_REQUEST['promote_id'])) { $promote_id = I('promote_id',0); $promoteaccount = get_promote_name($promote_id); } else { $promoteaccount = '全部'; } $list = D('user')->user($promote_id,$game_id); $count = count($list); $data = array_slice($list,($page-1)*$row,$row,true); file_put_contents(dirname(__FILE__).'/access_data_user.txt',json_encode($list)); $page = set_pagination($count,$row); if($page) {$this->assign('_page', $page);} $this->meta_title = '用户统计'; $this->assign('data',$data); $this->assign('game_source',$gamesource); $this->assign('promote_account',$promoteaccount); $this->display(); } public function user1($p=1) { $page = intval($p); $page = $page ? $page : 1; //默认显示第一页数据 if(isset($_REQUEST['row'])) {$row = $_REQUEST['row'];}else{$row = 10;}//10; $start = $_GET['start']= I('start',date('Y-m-d',strtotime('-2 day'))); $end = I('end',date('Y-m-d',strtotime('-1 day'))); $end = strtotime($end)>=strtotime(date('Y-m-d'))?date('Y-m-d',strtotime('-1 day')):$end; $_GET['end'] = $end; if(is_numeric($_REQUEST['game_id']) && $_REQUEST['game_id']>0) { $game_id = I('game_id',''); $gamesource = get_source_from_game($game_id); } else { $gamesource = '全部'; } if(is_numeric($_REQUEST['promote_id'])) { $promote_id = I('promote_id',0); $promoteaccount = get_promote_name($promote_id); } else { $promoteaccount = '全部'; } $list = D('user')->user1(strtotime($start),strtotime($end),$promote_id,$game_id); $count = count($list); $data = array_slice($list,($page-1)*$row,$row,true); file_put_contents(dirname(__FILE__).'/access_data_user.txt',json_encode($list)); if($count > $row){ $page = new \Think\Page($count, $row); $page->setConfig('theme','%FIRST% %UP_PAGE% %LINK_PAGE% %DOWN_PAGE% %END% %HEADER%'); $this->assign('_page', $page->show()); } $this->meta_title = '用户统计'; $this->assign('data',$data); $this->assign('game_source',$gamesource); $this->assign('promote_account',$promoteaccount); $this->display(); } /** * 留存统计 * @param int $p * 06.12.3 * xmy */ public function userretention($p = 0) { $request=$_REQUEST; $page = intval($p); $page = $page ? $page : 1; //默认显示第一页数据 $arraypage=$page; if(isset($_REQUEST['row'])) {$row = $_REQUEST['row'];}else{$row = 10;} $start = I('start',date('Y-m-d',strtotime('-7 day'))); $end = empty(I('end')) ? time_format(time(),'Y-m-d') : I('end'); if(!empty($start)){ $game_id = I('game_id'); $promote_id = I('promote_id'); $map_list = array(); if(I('game_id') !=0){ $map['ur.game_id']=$map_list['tab_user.fgame_id'] = $game_id; $this->assign('game_name',get_game_name(I('game_id'))); } if(I('promote_id') !=0){ $map['tab_user.promote_id']=$map_list['tab_user.promote_id']=$promote_id; $this->assign('promote_name',get_promote_account(I('promote_id'))); } //统计每日注册数 $data = $this->count_register($start,$end,$game_id,$promote_id,$page); $day = array(1,2,3,4,5,6,7,15,30,60); foreach ($data as $k=>$v) { //当日注册人帐号 $time = $v['time']; //$map["FROM_UNIXTIME(register_time,'%Y-%m-%d')"] = $time; //每日留存 if(intval($v['register_num'])==0) {$data[$k][$value]=0;continue;} $map['tab_user.id'] = array('in',explode(',',$v['register'])); foreach ($day as $key => $value) { $map["register_time"] = array('between',array(strtotime($time),strtotime($time)+24*60*60-1)); $login_time = strtotime("+{$value} day",strtotime($time)); $login_time_end = $login_time+86399; $num = M('user','tab_') ->field('count(DISTINCT tab_user.id) as num') ->join("right join tab_user_login_record as ur on ur.user_id = tab_user.id and ur.login_time between $login_time and $login_time_end") ->where($map) ->find(); $data[$k][$value] = $num['num']; } } //分页 $time_map['time'] = array('between',array($start,$end)); $count = M('date_list')->where($time_map)->count(); $page = set_pagination($count,$row); if($page) {$this->assign('_page', $page);} }else{ unset($_REQUEST['data_order']); if(count(I('get.'))!=0){ $this->error('时间选择错误,请重新选择!'); } } if($request['data_order']!=''){ $data_order=reset(explode(',',$request['data_order'])); $data_order_type=end(explode(',',$request['data_order'])); $this->assign('userarpu_order',$data_order); $this->assign('userarpu_order_type',$data_order_type); } $data=my_sort($data,$data_order_type,(int)$data_order,SORT_STRING); $size=$row;//每页显示的记录数 $pnum = ceil(count($data) / $size); //总页数,ceil()函数用于求大于数字的最小整数 //用array_slice(array,offset,length) 函数在数组中根据条件取出一段值;array(数组),offset(元素的开始位置),length(组的长度) $data = array_slice($data, ($arraypage-1)*$size, $size); $this->assign('data',$data); $this->meta_title = '留存统计'; $this->display(); } /** * 流失分析 */ public function userloss(){ $start=get_lastweek_name(6); $end=date('Y-m-d'); $this->assign('start',$start); $this->assign('end',$end); $result=$this->loss_pic($_REQUEST); foreach ($result['day'] as $key => $value) { $res['lossplayer']['loss'][$value]=$result['loss_count'][$key]; $res['lossplayer']['lossrate'][$value]=$result['loss_rate'][$key]; } $money_arr=array( ">$2000","$1000~2000","$600~1000","$200~600","$100~200","$40~100","$20~40","$10~20","$2~$10","<$2", ); foreach ($money_arr as $key => $value) { $res['lossmoney'][$value]=$result['loss_money'][$key]; } $times_arr=array( ">50次","41~50次","31~40次","21~30次","11~20次","6~10次","5次","4次","3次","2次","1次","未付费", ); foreach ($times_arr as $key => $value) { $res['losstimes'][$value]=$result['loss_times'][$key]; } $this->meta_title = '流失分析'; $this->assign("json_data",json_encode($res)); $this->display(); } //流失率分析 public function loss_pic($para){ if(isset($para['time_start'])&&isset($para['time_end'])&&$para['time_start']!==null&&$para['time_end']!==null){ $dd=prDates($para['time_start'],$para['time_end']); $day=$dd; $this->assign('tt',array_chunk($dd,1)); }else{ $defTimeE=date("Y-m-d",time()); $defTimeS=date("Y-m-d",time()-24*60*60*6); $day=every_day(7); $dd=prDates($defTimeS,$defTimeE); } if(isset($para['game_id'])){ $map['r.fgame_id']=$para['game_id']; $map1['r.fgame_id']=$para['game_id']; } if(isset($para['channel_id'])&&$para['channel_id']!=""){ if($para['channel_id']==2){ $d=7; }else{ $d=3; } }else{ $d=3; } $limitI=count($dd); $usermodel = D('User'); for($i=0;$i<$limitI;$i++){ $start=$this->get_time($dd[$i],$d); $end=$start+24*60*60-1; $map['r.register_time']=array('between',array($start,$end)); if(isset($para['promote_id'])&&$para['promote_id']!=""){ $map['r.promote_id']=$para['promote_id']; } $logins=$usermodel->getPlayers($map); if($logins==null){ $loss=null; }else{ $loss=null; foreach ($logins as $key => $value) { $start=date("Y-m-d", $value['register_time']+24*60*60); $start=$this->get_time($start,0); $end=$start+24*60*60*$d; $map1['r.login_time']=array('between',array($start,$end)); $map1['r.user_id']=$value['id']; if(isset($para['promote_id'])&&$para['promote_id']!=""){ $map1['promote_id']=$para['promote_id']; } $result1=$usermodel->findPlayer($map1); if($result1==null){ $loss[]=$logins[$key]; } } } if($loss!=null){ $loser[]=$loss; } $loss_count[]=count($loss); $loss_rate[]=count($loss)/count($logins)*100?sprintf("%.2f",count($loss)/count($logins)*100):0; } foreach ($loser as $key => $value) { foreach ($value as $k => $v) { $losers[]=$v['user_id']; } } $data2=$this->loss_pic2($losers); $data3=$this->loss_pic3($losers); $result['day']=$day; $result['loss_count']=$loss_count; $result['loss_rate']=$loss_rate; $result['loss_money']=$data2; $result['loss_times']=$data3; return $result; } /** * 流失用户消费金额分析,包括不同等级的人数和所占比例 * @param [type] $data [description] * @return [type] [description] */ function loss_pic2($data){ $Spend=new SpendModel(); foreach ($data as $key => $value) { $list[$key]['user_id']=$value; $list[$key]['amount']=$Spend->totalSpend($list[$key]); } foreach ($list as $k => $v) { if($v['amount']<2){ $two[]=$v; }elseif($v['amount']<10){ $ten[]=$v; }elseif($v['amount']<20){ $twenty[]=$v; }elseif($v['amount']<40){ $forty[]=$v; }elseif($v['amount']<100){ $hundred[]=$v; }elseif($v['amount']<200){ $thundred[]=$v; }elseif($v['amount']<600){ $shundred[]=$v; }elseif($v['amount']<1000){ $thousand[]=$v; }elseif($v['amount']<2000){ $tthousand[]=$v; }else{ $thousands[]=$v; } } $result=[count($thousands),count($tthousand),count($thousand),count($shundred),count($thundred),count($hundred),count($forty),count($twenty),count($ten),count($two)]; return $result; } /** * 流失用户消费次数分析,包括不同次数所占人数和比例 * @param [type] $data [description] * @return [type] [description] */ public function loss_pic3($data){ $Spend=new SpendModel(); foreach ($data as $key => $value) { $list[$key]['user_id']=$value; $list[$key]['count']=$Spend->totalSpendTimes($list[$key]); } foreach ($list as $k => $v) { if($v['count']==0){ $zero[]=$v; }elseif($v['count']==1){ $one[]=$v; }elseif($v['count']==2){ $two[]=$v; }elseif($v['count']==3){ $three[]=$v; }elseif($v['count']==4){ $four[]=$v; }elseif($v['count']==5){ $five[]=$v; }elseif($v['count']<11){ $ten[]=$v; }elseif($v['count']<21){ $twenty[]=$v; }elseif($v['count']<31){ $thirty[]=$v; }elseif($v['count']<41){ $forty[]=$v; }elseif($v['count']<51){ $fifty[]=$v; }else{ $fiftys[]=$v; } } $result=[count($fiftys),count($fifty),count($forty),count($thirty),count($twenty),count($ten),count($five),count($four),count($three),count($two),count($one),count($zero)]; return $result; } /** * 统计注册数 * @param $start 开始时间 * @param $end 结束时间 * @param string $game_name 游戏名称 * @param string $promote_id 渠道ID * @param int $page */ public function count_register($start,$end,$game_id="",$promote_id="",$page=0,$row=10){ $map["register_time"] = array('between',array(strtotime($start),strtotime($end)+86399)); $maps["time"] = array('between',array($start,$end)); if($game_id != ''){ $map['fgame_id'] = $game_id; } if($promote_id != ''){ $map['promote_id'] = $promote_id; } $map['puid']=0; $user = M('user','tab_')->field("FROM_UNIXTIME(register_time, '%Y-%m-%d') as time,COUNT(id) AS register_num,GROUP_CONCAT(id) as register") ->where($map) ->group("time") ->select(); $user2 = array_combine(array_column($user,'time'),array_column($user,'register')); $user = array_combine(array_column($user,'time'),array_column($user,'register_num')); //file_put_contents(dirname(__FILE__) . '/usersql2.txt',json_encode(M('user','tab_')->getLastSql())); //统计每日注册数 $data = M('date_list') ->field("time") ->where($maps) ->select(); foreach ($data as &$val){ $val['register_num'] = $user[$val['time']]?$user[$val['time']]:0; $val['register'] = $user2[$val['time']]?$user2[$val['time']]:''; } return $data; } /** * [get_time 通过日期获得时间戳] * @param [type] $date [description] * @return [type] [int] */ private function get_time($date,$d){ $date= explode("-",$date); $year=$date[0]; $month=$date[1]; $day=$date[2]; $start=mktime(0,0,0,$month,$day,$year)-$d*24*60*60; return $start; } /* * 根据时间计算注册人数 */ public function getcount($day, $n = null) { if (null !== $n) { $map['register_time'] = get_start_end_time($day, $n); } else { $map = get_last_day_time($day, "register_time"); } if (isset($_REQUEST['promote_name'])) { if ($_REQUEST['promote_name'] == '全部') { unset($_REQUEST['promote_name']); } else if ($_REQUEST['promote_name'] == '自然注册') { $map['tab_user.promote_id'] = array("elt", 0); } else { $map['tab_user.promote_id'] = get_promote_id($_REQUEST['promote_name']); } } if (isset($_REQUEST['game_name'])) { if ($_REQUEST['game_name'] == '全部') { unset($_REQUEST['game_name']); } else { $map['tab_user.fgame_id'] = get_game_id($_REQUEST['game_name']); } $r_user_id = D('User') ->where($map) ->select(); for ($i = 0; $i < count($r_user_id); $i++) { $sd[] = $r_user_id[$i]['user_id']; } $pid = implode(",", $sd); $count = D("User") ->where($map) ->count(); } else { $r_user_id = D("User")->where($map)->select(); for ($i = 0; $i < count($r_user_id); $i++) { $sd[] = $r_user_id[$i]['id']; } $pid = implode(",", $sd); $count = D("User")->where($map)->count(); } $r_count = array($pid, $count); return $r_count; } /* * 计算留存率 * */ public function onelogincount($day, $count, $n = null) { if (null !== $n) { $onetime['login_time'] = get_start_end_time($day, $n); } else { $onetime = get_last_day_time($day, "login_time"); } if (isset($_REQUEST['promote_name'])) { if ($_REQUEST['promote_name'] == '全部') { unset($_REQUEST['promote_name']); } else if ($_REQUEST['promote_name'] == '自然注册') { $onetime['promote_id'] = array("elt", 0); } else { $onetime['promote_id'] = get_promote_id($_REQUEST['promote_name']); } } else { $onetime['promote_id'] = array('egt', 0); } if (isset($_REQUEST['game_name'])) { if ($_REQUEST['game_name'] == '全部') { unset($_REQUEST['game_name']); } else { $onetime['game_id'] = get_game_id($_REQUEST['game_name']); } } else { $onetime['game_id'] = array('gt', 0); } $onetime['user_id'] = array('in', (string)$count[0]); $onelogincount = M("user_login_record", "tab_")->where($onetime)->count('distinct user_id'); if ($onelogincount != 0) { if ($count[1] == 0) { $baifen = ""; } else { $lu = $onelogincount / $count[1]; $baifen = $lu * 100; $baifen = $baifen > 100 ? '100%' : $baifen . '%'; } } else { if ($count[1] == 0) { $baifen = ""; } elseif ($count[1] != 0) { $baifen = "0%"; } } return round($baifen) . '%'; } public function userarpu($p=0) { $request=$_REQUEST; $page = intval($p); $page = $page ? $page : 1; //默认显示第一页数据arraypage $arraypage = $page ? $page : 1; //默认显示第一页数据 if(isset($_REQUEST['row'])) {$row = $_REQUEST['row'];}else{$row = 10;} $start = I('start'); $end = empty(I('end')) ? time_format(time(),'Y-m-d') : I('end'); $game_id = I('game_id'); $promote_id = I('promote_id'); $map_list = array(); if ($_REQUEST['hasbindcoins'] == 1) { unset($hasbindcoins['pay_way']); } else { $hasbindcoins['pay_way'] = array('gt',-1); } if(I('game_id') !=0){ $this->assign('game_name',get_game_name(I('game_id'))); } if(I('promote_id') !=0){ $this->assign('promote_name',get_promote_account(I('promote_id'))); } if(I('game_id') != '') $map_list['game_id'] = I('game_id'); if(I('promote_id') != '') $map_list['promote_id'] = I('promote_id'); if(!empty($start)) { //新增玩家 // $data = $this->count_register($start, $end, $game_id, $promote_id, $page); $data = $this->count_register($start, $end, $game_id, $promote_id); // var_dump($data);exit; foreach ($data as $key => $value) { $time = $value['time']; //活跃玩家 $data[$key]['act_user'] = $this->count_act_user($time,$game_id,$promote_id); //1日留存 $map = $map_list; if($map_list['promote_id']!=''){ $map['tab_user.promote_id']=$map_list['promote_id']; } unset($map['promote_id']); $map["FROM_UNIXTIME(register_time,'%Y-%m-%d')"] = $time; $login_time = strtotime("+1 day",strtotime($time)); $login_time_end = $login_time+86399; $num = M('user','tab_') ->field('count(DISTINCT tab_user.id) as num') ->join("right join tab_user_login_record as ur on ur.user_id = tab_user.id and ur.login_time between $login_time and $login_time_end") ->where($map) ->group('user_id') ->find(); $data[$key]['keep_num'] = round($num['num']/$data[$key]['register_num'],4)*100; //充值 $map = $map_list; empty($game_name ) || $map['game_name'] = array('like','%'.$game_name.'%'); empty($promote_id) || $map['promote_id'] = $promote_id; $map['pay_status'] = 1; $map["pay_time"] = ['between',[strtotime($time),strtotime($time)+86399]]; empty($hasbindcoins) || $map['pay_way'] = $hasbindcoins['pay_way']; $spend = M('spend','tab_')->field("IFNULL(sum(pay_amount),0) as money,IFNULL(count(distinct user_id),0) as people") ->where($map)->find(); $data[$key]['spend'] = $spend['money']; //付费玩家数 $data[$key]['spend_people'] = $spend['people']; //新付费玩家 $newmap = $map_list; empty($hasbindcoins) || $newmap['pay_way'] = $hasbindcoins['pay_way']; $newmap['pay_status'] = 1; $sql = M('spend','tab_') ->field("user_id,min(pay_time) as time") ->group('user_id') ->where(array_merge($newmap,['_string'=>'(small_id=0 or small_id=user_id)'])) ->select(false); //$sql = "select IFNULL(count(user_id),0) as num from ({$sql}) as t WHERE FROM_UNIXTIME(t.time,'%Y-%m-%d') = '{$time}'"; $sql = M('spend','tab_') ->table('('.$sql.') as t') ->field('IFNULL(count(user_id),0) as num') ->where(array('time'=>['between',[strtotime($time),strtotime($time)+86399]])) ->select(false); $query = M()->query($sql); $data[$key]['new_pop'] = $query[0]['num']; //付费率 $data[$key]['spend_rate'] = round($data[$key]['spend_people']/$data[$key]['act_user'],4)*100; //ARPU $data[$key]['ARPU'] = round($data[$key]['spend']/$data[$key]['act_user'],2); //ARPPU $data[$key]['ARPPU'] = round($data[$key]['spend']/$data[$key]['spend_people'],2); //累计付费玩家 $map = $map_list; empty($hasbindcoins) || $map['pay_way'] = $hasbindcoins['pay_way']; $map['pay_status'] = 1; $map["pay_time"] = array('elt',strtotime($time)+86399); $pop_num = M('spend','tab_')->field('count(distinct user_id) as num')->where($map)->select(); $data[$key]['pop_num'] = $pop_num[0]['num']; } //分页 $time_map['time'] = array('between',array($start,$end)); $count = M('date_list')->where($time_map)->count(); $page = set_pagination($count,$row); if($page) {$this->assign('_page', $page);} }else{ unset($_REQUEST['data_order']); if(count(I('get.'))!=0){ $this->error('时间选择错误,请重新选择!'); } } if($request['data_order']!=''){ $data_order=reset(explode(',',$request['data_order'])); $data_order_type=end(explode(',',$request['data_order'])); $this->assign('userarpu_order',$data_order); $this->assign('userarpu_order_type',$data_order_type); } $data=my_sort($data,$data_order_type,(int)$data_order,SORT_STRING); $size=$row;//每页显示的记录数 $pnum = ceil(count($data) / $size); //总页数,ceil()函数用于求大于数字的最小整数 //用array_slice(array,offset,length) 函数在数组中根据条件取出一段值;array(数组),offset(元素的开始位置),length(组的长度) $data = array_slice($data, ($arraypage-1)*$size, $size); $this->meta_title = 'ARPU统计'; $this->assign('data',$data); $this->display(); } /** * 获取活跃用户数 * @param $time */ public function count_act_user($time,$game_id="",$promote_id=""){ $map["login_time"] = ['between',[strtotime($time),strtotime($time)+86399]]; $map1["register_time"]=['between',[strtotime($time),strtotime($time)+86399]]; empty($game_id) || $map['game_id'] = $game_id; empty($game_id) || $map1['fgame_id'] = $game_id; if(!empty($promote_id)){ $user=M('User','tab_')->field('id')->where(array('promote_id'=>$promote_id))->select(); $user=implode(',',array_column($user,'id')); $map['user_id']=array('in',$user); $map1['id']=array('in',$user); }; $uudata=M('User','tab_') ->field('id as user_id') ->where($map1) ->select(false); $data = M('user_login_record','tab_') ->field('user_id') ->where($map) ->union($uudata) ->group('user_id') ->select(); $data=count($data); return $data; } //计算指定日期新用户数 public function getnewcount($time) { $map = array(); if (!empty($time)) { $map['register_time'] = get_start_end_time($_REQUEST['time-start']); } else { $map['register_time'] = -1; } if (isset($_REQUEST['promote_name'])) { if ($_REQUEST['promote_name'] == '全部') { unset($_REQUEST['promote_name']); } else if ($_REQUEST['promote_name'] == '自然注册') { $map['promote_id'] = array("elt", 0); } else { $map['promote_id'] = get_promote_id($_REQUEST['promote_name']); } } else { $map['promote_id'] = array('egt', 0); } if (isset($_REQUEST['game_name'])) { if ($_REQUEST['game_name'] == '全部') { unset($_REQUEST['game_name']); } else { $map['fgame_id'] = get_game_id($_REQUEST['game_name']); } } else { $map['fgame_id'] = array('gt', 0); } $r_user_id = M("User", "tab_") ->where($map) ->select(); for ($i = 0; $i < count($r_user_id); $i++) { $sd[] = $r_user_id[$i]['id']; } $pid = implode(",", $sd); $count = M("User", "tab_") ->where($map) ->count(); $count = array($pid, $count); return $count; } //计算留存数 public function getplaycount($day, $count, $n = null) { if (null !== $n) { $onetime['login_time'] = get_start_end_time($day, $n); } else { $onetime = get_last_day_time($day, "login_time"); } if (isset($_REQUEST['promote_name'])) { if ($_REQUEST['promote_name'] == '全部') { unset($_REQUEST['promote_name']); } else if ($_REQUEST['promote_name'] == '自然注册') { $onetime['promote_id'] = array("elt", 0); } else { $onetime['promote_id'] = get_promote_id($_REQUEST['promote_name']); } } else { $onetime['promote_id'] = array('egt', 0); } if (isset($_REQUEST['game_name'])) { if ($_REQUEST['game_name'] == '全部') { unset($_REQUEST['game_name']); } else { $onetime['game_id'] = get_game_id($_REQUEST['game_name']); } } else { $onetime['game_id'] = array('gt', 0); } $onetime['user_id'] = array('in', (string)$count[0]); $onelogincount = M("user_login_record", "tab_")->where($onetime)->count('distinct user_id'); return $onelogincount; } //计算次日留存率 function get_cilogin($newcount, $cicount) { if ($cicount == 0) { return sprintf("%.2f", 0) . '%'; } else { return round($cicount / $newcount * 100) . '%'; } } //计算指定游戏 用户总数 与时间无关 public function getallcount() { $map = array(); if (!isset($_REQUEST['time-start'])) { $map['a.register_time'] = -1; } if (isset($_REQUEST['game_name'])) { if ($_REQUEST['game_name'] == '全部') { unset($_REQUEST['game_name']); } else { $map['a.fgame_id'] = get_game_id($_REQUEST['game_name']); } } else { $map['a.fgame_id'] = array('gt', 0); } if (isset($_REQUEST['promote_name'])) { if ($_REQUEST['promote_name'] == '全部') { unset($_REQUEST['promote_name']); } else if ($_REQUEST['promote_name'] == '自然注册') { $map['a.promote_id'] = array("elt", 0); } else { $map['a.promote_id'] = get_promote_id($_REQUEST['promote_name']); } } else { $map['a.promote_id'] = array('egt', 0); } $count = M("User as a", "tab_") ->field("count(*) as count") ->where($map) ->count(); return $count; } //计算付费用户数 public function getpaycount() { $count = 0; if (isset($_REQUEST['time-start'])) { $map['pay_time'] = array("lt", strtotime($_REQUEST['time-start']) + (60 * 60 * 24)); } else { $map['pay_time'] = -1; } $map['pay_status'] = 1; if (isset($_REQUEST['game_name'])) { if ($_REQUEST['game_name'] == '全部') { unset($_REQUEST['game_name']); } else { $map['game_id'] = get_game_id($_REQUEST['game_name']); } } else { $map['game_id'] = array('gt', 0); } if (isset($_REQUEST['promote_name'])) { if ($_REQUEST['promote_name'] == '全部') { unset($_REQUEST['promote_name']); } else if ($_REQUEST['promote_name'] == '自然注册') { $map['promote_id'] = array("elt", 0); } else { $map['promote_id'] = get_promote_id($_REQUEST['promote_name']); } } else { $map['promote_id'] = array('egt', 0); } $count = M("spend", "tab_") ->where($map) ->count('distinct id'); return $count; } //计算新用户付费金额 public function getnewpaycount() { $count = 0; if (isset($_REQUEST['time-start'])) { $map['pay_time'] = array("lt", strtotime($_REQUEST['time-start']) + (60 * 60 * 24)); $newuser = $this->getnewcount($_REQUEST['time-start']); $map['user_id'] = array('in', (string)$newuser[0]); } else { $map['pay_time'] = -1; } $map['pay_status'] = 1; if (isset($_REQUEST['game_name'])) { if ($_REQUEST['game_name'] == '全部') { unset($_REQUEST['game_name']); } else { $map['a.fgame_id'] = get_game_id($_REQUEST['game_name']); } } else { $map['a.fgame_id'] = array('gt', 0); } if (isset($_REQUEST['promote_name'])) { if ($_REQUEST['promote_name'] == '全部') { unset($_REQUEST['promote_name']); } else if ($_REQUEST['promote_name'] == '自然注册') { $map['a.promote_id'] = array("elt", 0); } else { $map['a.promote_id'] = get_promote_id($_REQUEST['promote_name']); } } else { $map['a.promote_id'] = array('egt', 0); } $list = M("User as a", "tab_") ->field("sum(pay_amount) as sum") ->join("tab_spend as c on c.game_id=a.fgame_id") ->where($map) ->group('a.id') ->find(); if (!empty($list['sum'])) { $count = $list['sum']; } return sprintf("%.2f", $count); } //计算总付费金额 public function getallpaycount() { $count = 0; $map = array(); if (!isset($_REQUEST['time-start'])) { $map['pay_time'] = -1; } $map['pay_status'] = 1; if (isset($_REQUEST['game_name'])) { if ($_REQUEST['game_name'] == '全部') { unset($_REQUEST['game_name']); } else { $map['game_id'] = get_game_id($_REQUEST['game_name']); } } else { $map['game_id'] = array('gt', 0); } if (isset($_REQUEST['promote_name'])) { if ($_REQUEST['promote_name'] == '全部') { unset($_REQUEST['promote_name']); } else if ($_REQUEST['promote_name'] == '自然注册') { $map['promote_id'] = array("elt", 0); } else { $map['promote_id'] = get_promote_id($_REQUEST['promote_name']); } } else { $map['promote_id'] = array('egt', 0); } $list = M("spend", "tab_") ->field("sum(pay_amount) as sum") ->where($map) ->find(); if (!empty($list['sum'])) { $count = $list['sum']; } return sprintf("%.2f", $count); } //计算总付费率 public function getrate() { $pr = $this->getpaycount();//总付费人数 $all = $this->getallcount(); if ($all == 0) { $count = 0; } else { $count = $pr / $all; $count = $count > 1 ? 100 : $count * 100; } return sprintf("%.2f", $count) . '%'; } // 计算活跃用户数(当前日期所在一周的时间) public function gethuocount() { $count = 0; if (isset($_REQUEST['game_name']) || isset($_REQUEST['time-start'])) { if (isset($_REQUEST['game_name'])) { if ($_REQUEST['game_name'] == '全部') { unset($_REQUEST['game_name']); } else { $map['game_id'] = $_REQUEST['game_id']; $time = date("Y-m-d", time()); $start = strtotime("$time - 6 days"); //周末 $end = strtotime("$time"); $map['login_time'] = array("between", array($start, $end)); } } if (isset($_REQUEST['time-start'])) { $time2 = $_REQUEST['time-start']; $start2 = strtotime("$time2 - 6 days"); //周末 $end2 = strtotime("$time2"); $map['login_time'] = array("between", array($start2, $end2)); } $data = M("user_login_record", "tab_") ->group('user_id') ->having('count(user_id) > 2') ->where($map) ->select(); $count = count($data); } return sprintf("%.2f", $count); } //获取用户ARPU public function getuserarpu() { $new = $this->getnewpaycount(); if (isset($_REQUEST['time-start'])) { $newcount = end($this->getnewcount($_REQUEST['time-start'])); if ($newcount == 0) { $count = 0; } else { $count = $new / $newcount; } } else { $count = 0; } return sprintf("%.2f", $count); } // 获取活跃ARPU public function gethuoarpu() { if (isset($_REQUEST['game_name']) || isset($_REQUEST['time-start'])) { if (isset($_REQUEST['game_name'])) { if ($_REQUEST['game_name'] == '全部') { unset($_REQUEST['game_name']); } else { $map['tab_user_login_record.game_id'] = get_game_id($_REQUEST['game_name']); $time = date("Y-m-d", time()); $start = strtotime("$time - 6 days"); //周末 $end = strtotime("$time"); $map['login_time'] = array("between", array($start, $end)); } } if (isset($_REQUEST['time-start'])) { $time2 = $_REQUEST['time-start']; $start2 = strtotime("$time2 - 6 days"); //周末 $end2 = strtotime("$time2"); $map['login_time'] = array("between", array($start2, $end2)); } $data = M("user_login_record", "tab_") ->group('user_id') ->having('count(user_id) > 2') ->where($map) ->select(); foreach ($data as $key => $value) { $data1[] = $value['user_id']; } foreach ($data1 as $value) { $user_account[] = get_user_account($value); } $pid = implode(',', $user_account); } $map['user_account'] = array('in', $pid); if ($pid != '') { $huosum = M("spend ", "tab_") ->distinct(true) ->field("pay_amount") ->join("tab_user_login_record on tab_spend.game_id = tab_user_login_record.game_id") ->where($map) ->select(); foreach ($huosum as $value) { $huosum2[] = $value['pay_amount']; } $sum = array_sum($huosum2); $count = count($data); $return = $sum / $count; } else { $return = 0; } return $return; } //获取付费ARPU public function getpayarpu() { $paysum = $this->getallpaycount();//所有用户付费 $paycount = $this->getpaycount();//新用户付费 if ($paycount != 0) { $count = $paysum / $paycount; } else { $count = 0; } return sprintf("%.2f", $count); } public function cha_userarpu($p=0){ $page = intval($p); $page = $page ? $page : 1; //默认显示第一页数据arraypage $arraypage = $page ? $page : 1; //默认显示第一页数据 $row = 10; $time = $_REQUEST['time']; $promote_id = $_REQUEST['promote_id']; $join = "left join tab_user u on u.fgame_id = tab_game.id"; if($time==''){ $this->error('参数错误,缺少时间'); }else{ $map['register_time']=array('between',array(strtotime($time),strtotime($time)+24*60*60-1)); } if($promote_id!=''){ $map_list['promote_id']=$promote_id; $map['promote_id']=$promote_id; $join .= " AND u.promote_id = {$promote_id}"; } if ($_REQUEST['hasbindcoins'] == 1) { unset($hasbindcoins['pay_way']); } else { $hasbindcoins['pay_way'] = array('gt',-1); } $map['puid']=0; $data=M('Game','tab_')->field('id as game_id, game_name')->order('id desc')->select(); foreach ($data as $key => $value) { $game_id = $value['game_id']; $map_list['game_id']=$game_id; $user=M('User','tab_'); $spend=M('spend','tab_'); //新增人数 $rdata=$user ->field('count(id) as register_num') ->where(array('fgame_id'=>$game_id)) ->where($map) ->find(); $data[$key]['register_num']=$rdata['register_num']; //活跃玩家 $data[$key]['act_user'] = $this->count_act_user($time,$game_id,$promote_id); //1日留存 $mapl=$map_list; $mapl["register_time"] = ['between',[strtotime($time),strtotime($time)+86399]]; if ($promote_id!='') $mapl['tab_user.promote_id']=$mapl['promote_id']; unset($mapl['promote_id']); $login_time = date('Y-m-d', strtotime("+1 day",strtotime($time))); $num = $user ->field('count(DISTINCT tab_user.id) as num') ->join("right join tab_user_login_record as ur on ur.user_id = tab_user.id and FROM_UNIXTIME(ur.login_time,'%Y-%m-%d') = '{$login_time}'") ->where($mapl) ->find(); $data[$key]['keep_num'] = round($num['num']/$data[$key]['register_num'],4)*100; //充值 $mapl = $map_list; empty($game_name ) || $mapl['game_name'] = array('like','%'.$game_name.'%'); empty($promote_id) || $mapl['promote_id'] = $promote_id; empty($hasbindcoins) || $mapl['pay_way'] = $hasbindcoins['pay_way']; $mapl['pay_status'] = 1; $mapl["pay_time"] = ['between',[strtotime($time),strtotime($time)+86399]]; $spend = $spend->field("IFNULL(sum(pay_amount),0) as money,IFNULL(count(distinct user_id),0) as people")->where($mapl)->find(); $data[$key]['spend'] = $spend['money']; //付费玩家数 $data[$key]['spend_people'] = $spend['people']; //付费率 $data[$key]['spend_rate'] = round($data[$key]['spend_people']/$data[$key]['act_user'],4)*100; //ARPU $data[$key]['ARPU'] = round($data[$key]['spend']/$data[$key]['act_user'],2); //ARPPU $data[$key]['ARPPU'] = round($data[$key]['spend']/$data[$key]['spend_people'],2); if($data[$key]['register_num']==0&&$data[$key]['act_user']==0&&$data[$key]['keep_num']==0&&$data[$key]['spend']==0&&$data[$key]['spend_people']==0){ unset($data[$key]); } } $count=count($data); if($count > $row){ $page = new \Think\Page($count, $row); $page->setConfig('theme','%FIRST% %UP_PAGE% %LINK_PAGE% %DOWN_PAGE% %END% %HEADER%'); $this->assign('_page', $page->show()); } $size=$row;//每页显示的记录数 $pnum = ceil(count($data) / $size); //总页数,ceil()函数用于求大于数字的最小整数 //用array_slice(array,offset,length) 函数在数组中根据条件取出一段值;array(数组),offset(元素的开始位置),length(组的长度) $data = array_slice($data, ($arraypage-1)*$size, $size); $this->assign('list_data',$data); $this->display(); } function game_analysis(){ if($_REQUEST['time-start']!=''&&$_REQUEST['time-end']!=''){ $start=$_REQUEST['time-start']; $end=$_REQUEST['time-end']; }else{ $start=get_lastweek_name(6); $end=date('Y-m-d'); } $umap['register_time']=array('BETWEEN',array(strtotime($start),strtotime($end)+24*60*60-1)); $smap['pay_time']=array('BETWEEN',array(strtotime($start),strtotime($end)+24*60*60-1)); if($_REQUEST['promote_id']!=''){ $umap['promote_id']=$_REQUEST['promote_id']; $smap['promote_id']=$_REQUEST['promote_id']; } $data=M('Game','tab_')->field('id as game_id, game_name')->order('id desc')->select(); foreach ($data as $key => $value) { $umap['fgame_id']=$value['game_id']; $smap['game_id']=$value['game_id']; $udata=M('User','tab_') ->field('count(id) as register_num') ->where($umap) ->find(); $data[$key]['count']=$udata['register_num']; $smap['pay_status']=1; $sdata=M('Spend','tab_') ->field('ifnull(sum(pay_amount),0) as sum') ->where($smap) ->find(); $data[$key]['sum']=$sdata['sum']; } if($_REQUEST['data_order']==2){ $data_order_type='sum'; $data_order=3;//倒序 }else{ $data_order_type='count'; $data_order=3; } $data=my_sort($data,$data_order_type,(int)$data_order); $data = array_slice($data, 0, 12); // 前台显示 // X轴游戏 $xAxis="["; foreach ($data as $tk => $tv) { $xAxis.="'".$tv['game_name']."',"; } $xAxis.="]"; //x轴注册数据 $xzdate="["; foreach ($data as $key => $value) { $xzdate.="'".$value['count']."',"; } $xzdate.="]"; //x轴充值数据 $xsdate="["; foreach ($data as $key => $value) { $xsdate.="'".$value['sum']."',"; } $xsdate.="]"; $this->meta_title = '游戏分析'; $this->assign('xzdate',$xzdate); $this->assign('xsdate',$xsdate); $this->assign('xAxis',$xAxis); $this->assign('start',$start); $this->assign('end',$end); $this->assign('data',$data); $this->display(); } function promote_analysis(){ if($_REQUEST['time-start']!=''&&$_REQUEST['time-end']!=''){ $start=$_REQUEST['time-start']; $end=$_REQUEST['time-end']; }else{ $start=get_lastweek_name(6); $end=date('Y-m-d'); } $umap['register_time']=array('BETWEEN',array(strtotime($start),strtotime($end)+24*60*60-1)); $smap['pay_time']=array('BETWEEN',array(strtotime($start),strtotime($end)+24*60*60-1)); $hStart = strtotime($start); $hEnd = strtotime($end)+24*60*60-1; if($_REQUEST['game_id']!=''){ $umap['fgame_id']=$_REQUEST['game_id']; $smap['game_id']=$_REQUEST['game_id']; } $data=M('Promote','tab_')->field('id as promote_id,account as promote_name')->order('id desc')->select(); foreach ($data as $key => $value) { $umap['promote_id']=$value['promote_id']; $smap['promote_id']=$value['promote_id']; $echohavingUser = $havingUser.' and promote_id = '.$value['promote_id']; $udata=M('User','tab_') ->field('count(id) as register_num,register_time,fgame_id,promote_id') ->where($umap) ->find(); $data[$key]['count']=$udata['register_num']; $smap['pay_status']=1; $sdata=M('Spend','tab_') ->field('ifnull(sum(pay_amount),0) as sum') ->where($smap) ->find(); $data[$key]['sum']=$sdata['sum']; } $data_order_type = ''; if($_REQUEST['data_order']==2){ $data_order_type='sum'; $data_order=3;//倒序 }else{ $data_order_type='count'; $data_order=3; } $data=my_sort($data,$data_order_type,(int)$data_order); $data = array_slice($data, 0, 12); // 前台显示 // X轴游戏 $xAxis="["; foreach ($data as $tk => $tv) { $xAxis.="'".$tv['promote_name']."',"; } $xAxis.="]"; //x轴注册数据 $xzdate="["; foreach ($data as $key => $value) { $xzdate.="'".$value['count']."',"; } $xzdate.="]"; //x轴充值数据 $xsdate="["; foreach ($data as $key => $value) { $xsdate.="'".$value['sum']."',"; } $xsdate.="]"; $this->meta_title = '推广员分析'; $this->assign('xzdate',$xzdate); $this->assign('xsdate',$xsdate); $this->assign('xAxis',$xAxis); $this->assign('start',$start); $this->assign('end',$end); $this->assign('data',$data); $this->display(); } /* * 应用概况 * @author 鹿文学 */ public function device_survey() { $device = D('DeviceRecord'); // 统计 $total = $device->all_device(); $todaystart = mktime(0,0,0,date('m'),date('d'),date('Y')); $today = $device->total_device(['create_time'=>array('between',[$todaystart,$todaystart+86399])]); $yesterday = $device->total_device(['create_time'=>array('between',[$todaystart-86400,$todaystart-1])]); $day7 = $device->total_device(['create_time'=>array('between',[$todaystart-86400*7,$todaystart-1])],1); $day30 = $device->total_device(['create_time'=>array('between',[$todaystart-86400*30,$todaystart-1])],1); $duration = $device->single_duration(['create_time'=>array('between',[$todaystart-86400*7,$todaystart-1])]); $this->assign('total',$total); $this->assign('today',$today); $this->assign('yesterday',$yesterday); $this->assign('day7',$day7); $this->assign('day30',$day30); $this->assign('duration7',second_to_duration($duration/7)); // 日历 R('Index/calendar'); // 折线图 $this->foldLineDiagram($_REQUEST['start'],$_REQUEST['end'],$_REQUEST['num']); $this->display(); } /* * 折线图 * @param integer $start 开始时间 * @param integer $end 结束时间 * @param boolean $flag 是否ajax返回 * @author 鹿文学 */ public function foldLineDiagram($start='',$end='',$num='',$flag=false) { $starttime = $start?strtotime($start):mktime(0,0,0,date('m'),date('d')-1,date('Y')); $endtime = $end?strtotime($end)+86399:$starttime+86399; $start = date('Y-m-d',$starttime); $end = date('Y-m-d',$endtime); $device = D('DeviceRecord'); if ($start == $end) { $day_count = 1; if ($start == date('Y-m-d',strtotime('-1 day'))) {$num = 2;} $hours = ['00','01','02','03','04','05','06','07','08','09','10','11','12','13','14','15','16','17','18','19','20','21','22','23']; $data['date'] = [$start]; $data['hours'] = 1; foreach($hours as $v) { $data['news']['ios'][$v] = 0; $data['news']['and'][$v] = 0; $data['active']['ios'][$v] = 0; $data['active']['and'][$v] = 0; } // 新增设备 $hoursnews = $device->news_on_time(['create_time'=>['between',[$starttime,$endtime]]],'news',5,'time,version'); // 活跃设备 $hoursactive = $device->active_on_time(['create_time'=>['between',[$starttime,$endtime]]],'active',5,'time,version'); // 启动机型 $hoursmodel = $device->model(['create_time'=>['between',[$starttime,$endtime]]]); foreach($hours as $v) { foreach($hoursnews as $h) { $time = explode(' ',$h['time']); if ($time[1] == $v){ $data['news'][$h['version']==1?'and':'ios'][$v]+= (integer)$h['news']; } } foreach($hoursactive as $h) { $time = explode(' ',$h['time']); if ($time[1] == $v){ $data['active'][$h['version']==1?'and':'ios'][$v] += (integer)$h['active']; } } } foreach($hoursmodel as $k=>$h) { $data['xmodel'][$h['version']==1?'and':'ios'][] = "'".$h['model']."'"; $data['model'][$h['version']==1?'and':'ios'][$h['model']] = (integer)$h['count']; } } else { $datelist = get_date_list($starttime,$endtime,$num==7?4:1); $day_count = count($datelist); $data['date'] = $datelist; $data['hours'] = 0; foreach($datelist as $k => $v) { $data['news']['ios'][$v] = 0; $data['news']['and'][$v] = 0; $data['active']['ios'][$v] = 0; $data['active']['and'][$v] = 0; } // 新增设备 $news = $device->news_on_time(['create_time'=>['between',[$starttime,$endtime]]],'news',$num==7?2:1,'time,version'); // 活跃设备 $active = $device->active_on_time(['create_time'=>['between',[$starttime,$endtime]]],'active',$num==7?2:1,'time,version'); // 启动机型 $model = $device->model(['create_time'=>['between',[$starttime,$endtime]]]); foreach($datelist as $v) { foreach($news as $h) { if ($v == $h['time']) { $data['news'][$h['version']==1?'and':'ios'][$v] += (integer)$h['news']; } } foreach($active as $h) { if ($v == $h['time']) { $data['active'][$h['version']==1?'and':'ios'][$v] += (integer)$h['active']; } } } foreach($model as $k=>$h) { $data['xmodel'][$h['version']==1?'and':'ios'][] = "'".$h['model']."'"; $data['model'][$h['version']==1?'and':'ios'][$h['model']] = (integer)$h['count']; } } foreach($data as $k => $v) { if (is_array($v)) { if ($k == 'date'){ $data[$k] = '"'.implode('","',$v).'"'; $table[$k] = $v; }elseif($k == 'xmodel'){ $table[$k]['ios'] = $v['ios']; $table[$k]['and'] = $v['and']; $data[$k]['ios'] = implode(',',$v['ios']); $data[$k]['and'] = implode(',',$v['and']); }elseif($k == 'model'){ $table[$k]['ios'] = $v['ios']; $table[$k]['and'] = $v['and']; $tempexport=[]; foreach($v['ios'] as $t => $s) { $tempexport[]=['model'=>$t,'count'=>$s,'version'=>'ios']; } foreach($v['and'] as $t => $s) { $tempexport[]=['model'=>$t,'count'=>$s,'version'=>'android']; } $export[$k]=$tempexport; $data[$k]['ios'] = implode(',',$v['ios']); $data[$k]['and'] = implode(',',$v['and']); }else{ $sum = 0;$x='';$y=0;$tempexport=[];$count=0; foreach($v['ios'] as $t => $s){ $sum += $s;$count++; if($data['hours']==1){ if ($t%2==1) {$tab['ios'][$x.'~'.$t] = $y+$s;$x='';$y=0;}else{$x .= $t;$y += $s;} $tempexport[]=['time'=>$start.' '.(substr($t,0,2)).':00','count'=>$s,'version'=>'ios']; }else{ $tempexport[]=['time'=>$t,'count'=>$s,'version'=>'ios']; } } foreach($v['and'] as $t => $s){ $sum += $s;$count++; if($data['hours']==1){ if ($t%2==1) {$tab['and'][$x.'~'.$t] = $y+$s;$x='';$y=0;}else{$x .= $t;$y += $s;} $tempexport[]=['time'=>$start.' '.(substr($t,0,2)).':00','count'=>$s,'version'=>'android']; }else{ $tempexport[]=['time'=>$t,'count'=>$s,'version'=>'android']; } } if($data['hours']==1){ $table[$k]=$tab; $export['average'][$k]=$table['average'][$k]=$sum; }else{ $table[$k] = $v; $export['average'][$k]=$table['average'][$k]=round($sum/$day_count,2); } $export['sum'][$k] = $table['sum'][$k]=$sum; $export[$k]=$tempexport; $data[$k]['ios'] = implode(',',$v['ios']); $data[$k]['and'] = implode(',',$v['and']); } } } @file_put_contents(dirname(__FILE__).'/device_data_foldline.txt',json_encode($export)); if ($flag) { $data['table'] = $table; echo json_encode($data); } else { $this->assign('foldline',$data); $this->assign('table',$table); $this->assign('num',$num); } } }