<?php
namespace Admin\Event;
use Think\Controller;
/**
 * 后台事件控制器
 * @author 王贺 
 */
class SpendEvent extends ThinkEvent {
    public function list_($model = null,$p,$extend=array()){
        $model || $this->error('模型名标识必须！');
        $page = intval($p);
        $page = $page ? $page : 1; //默认显示第一页数据
        $arraypage = $page; //默认显示第一页数据
        //解析列表规则
        $fields = $model['fields'];
        // 关键字搜索
        $map    =   empty($model['map'])?array():$model['map'];
        $map['tab_spend.pay_status'] = 1;

				if(isset($_REQUEST['row'])) {$row = $_REQUEST['row'];}else{$row = 10;}
				
        //读取模型数据列表
        $name = $model['m_name'];

        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);
            $sort = $data_order==3?'desc':'asc'; 
            $model['order'] = $data_order_type.' '.$sort;
        }
        
        $new_model = D($name);
        $data = D($name)
        // 查询条件
        ->where($map)
        /* 默认通过id逆序排列 */
        ->order($model['order'])
        //根据字段分组
        ->group($model['group'])
        /* 数据分页 */
        ->page($page, $row)
        /* 执行查询 */
        ->select();
        /* 查询记录总数 */
        $count = D($name)
            // 查询条件
            ->where($map)
            /* 默认通过id逆序排列 */
            ->order($model['order'])
            //根据字段分组
            ->group($model['group'])
            /* 执行查询 */
            ->count();
        //分页
				
				$page = set_pagination($count,$row);
				if($page) {$this->assign('_page', $page);}
				
				
        $this->assign('model', $model);
        $this->assign('list_data', $data);
        $this->meta_title = $model['title'].'列表';
        $this->display($model['template_list']);
    }
    
    public function group_list($model = null,$p,$extend=array()){
        $model || $this->error('模型名标识必须！');
        $page = intval($p);
        $page = $page ? $page : 1; //默认显示第一页数据

        //解析列表规则
        $fields = $model['fields'];
        // 关键字搜索
        $map    =   empty($extend)?array():$extend;
        $map['tab_spend.pay_status'] = 1;
        // 条件搜索
        foreach($_REQUEST as $name=>$val){
            switch ($name) {
                case 'account':
                    $map['tab_spend.user_account']  =   array('like','%'.$val.'%');
                    break;
                case 'game_id':
                    $map['tab_game.id']  =  $val;
                    break;
                case 'promote_id':
                    $map['tab_spend.promote_id']  =  $val;
                    break;
            }
        }


				if(isset($_REQUEST['row'])) {$row = $_REQUEST['row'];}else{$row = 10;}

        //读取模型数据列表
        $name = $model['m_name'];
        $new_model = D($name);
        $data = D($name)
            ->field('tab_spend.*,case parent_id  when 0 then promote_id else parent_id end AS parent_id,sum(pay_amount) AS total_amount,DATE_FORMAT( FROM_UNIXTIME(pay_time),"%Y-%m-%d") AS period')
            ->join('left join tab_promote ON tab_spend.promote_id = tab_promote.id') 
            // 查询条件
            ->where($map)
            /* 默认通过id逆序排列 */
            ->order($model['order'])
            //根据字段分组
            ->group($model['group'])
            /* 数据分页 */
            ->page($page, $row)
            /* 执行查询 */
            ->select();
        /* 查询记录总数 */
        $count = count($data);
         //分页

				
				$page = set_pagination($count,$row);
				if($page) {$this->assign('_page', $page);}
				
				
        $this->assign('model', $model);
        $this->assign('list_data', $data);
        $this->meta_title = $model['title'].'列表';
        $this->display($model['template_list']);
    }
    public function spend_list($model = null,$p,$extend=array()){
        $model || $this->error('模型名标识必须！');
        $page = intval($p);
        $page = $page ? $page : 1; //默认显示第一页数据
        $arraypage = $page; //默认显示第一页数据
        //解析列表规则
        $fields = $model['fields'];
        // 关键字搜索
        $map    =   empty($model['map'])?array():$model['map'];
        $map['tab_spend.pay_status'] = 1;

				
				if(isset($_REQUEST['row'])) {$row = $_REQUEST['row'];}else{$row = 10;}
				
        //读取模型数据列表
        $name = $model['m_name'];
        $new_model = D($name);
        $data = D($name) 
            // 查询条件
            ->where($map)
            /* 默认通过id逆序排列 */
            ->order($model['order'])
            //根据字段分组
            ->group($model['group'])
            /* 数据分页 */
            // ->page($page, $row)
            /* 执行查询 */
            ->select();
        $count=count($data);
         //分页
				
				$page = set_pagination($count,$row);
				if($page) {$this->assign('_page', $page);}
				
				
        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);
        $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('model', $model);
        $this->assign('list_data', $data);
        $this->meta_title = $model['title'].'列表';
        $this->display($model['template_list']);
    }

 public function check_bill111($model = null,$p,$extend=array()){
     global $countpage;

        $model || $this->error('模型名标识必须！');
        $page = intval($p);
        $page = $page ? $page : 1; //默认显示第一页数据

        //解析列表规则
        $fields = $model['fields'];
        // 关键字搜索
        $user_map    =   empty($extend['user_map'])?array():$extend['user_map'];
        $spend_map    =   empty($extend['spend_map'])?array():$extend['spend_map'];
        $user = D("User");
        $spend = D("Spend");
        
        //读取模型数据列表
        $data = array();
        
		
				if(isset($_REQUEST['row'])) {$row = $_REQUEST['row'];}else{$row = 10;}
        
        $user_map['is_check'] = $spend_map['is_check'] = 1;
        $spend_map['pay_status']=1;
        $user_map['fgame_id'] = array('neq',0);
        $user_map1=$user_map;
        $user_map1['parent_id']=0;
        $user1=M("user","tab_")
             ->field('id,account,promote_id,promote_account,parent_id,fgame_id,fgame_name,count(*) as count')
             ->group("fgame_id,promote_id")
             ->where($user_map1)
             ->select();
        $user_map['parent_id']=array("neq","0");

        $user=M("user","tab_")
             ->field('id,account,promote_id,promote_account,parent_id,fgame_id,fgame_name,count(*) as count')
             ->group("fgame_id,promote_id")
             ->where($user_map)
             ->select();

             // $user1  注册人数
             foreach ($user1 as $k1 => $v1) {
                foreach ($user as $k2 => $v2) {
                    if($v1['promote_id']==$v2['parent_id']&&$v1['fgame_id']==$v2['fgame_id']){
                       $user1[$k1]['count']+=$v2['count'];
                    }
                }
             }
             unset($user_map['parent_id']);
             //查出 二级推广的父类id
             $p1=M("promote","tab_")
                ->field("id,account,parent_id")
               ->where("parent_id <> 0 ")
               ->select();
             
             $spend=M("spend","tab_")
                ->field('promote_id,promote_account,game_id,game_name,sum(pay_amount) as total_money')
                ->group('promote_id,game_id')
                ->where($spend_map)
                ->select();
    
                        //选出二级推广充值记录
                foreach ($p1 as $k1 => $v1) {
                    foreach ($spend as $k2 => $v2) {
                        if($v1['id']==$v2['promote_id']){
                            $sd[$k2]=$v2;
                          $sd[$k2]['parent_id']=$v1['parent_id'];
                        }
                    }
                }

                //二级推广充值记录合并到一级
                foreach ($sd as $k => $v) {
                    foreach ($spend as $k2 => $v2) {
                        if($v['parent_id']==$v2['promote_id']&&$v['game_id']==$v2['game_id']){
                            $spend[$k2]['total_money']=$v2['total_money']+$v['total_money'];
                           unset($spend[$k2=$k]);
                        } 
                    }
                }


                // //讲二级的推广游戏且一级没有推广的游戏充值记录 合并到一级
                foreach ($spend as $key => $value) {
                    foreach ($p1 as $k => $v) {
                        if($value['promote_id']==$v['id']){
                            $spend[$key]['promote_id']=$v['parent_id'];
                            $spend[$key]['promote_account']=get_promote_name($v['parent_id']);
                            $spend[$key]['pp']=$value['promote_id'];
                        }
                    }
                }
                //如一级用户没有该游戏注册人数 将二级注册人数加到一级 
                foreach ($spend as $key => $value) {
                    foreach ($user as $k => $v) {
                        if($v['fgame_id']==$value['game_id']&&$v['parent_id']==$value['promote_id']){
                            $spend[$key]['total_number']=$v['count'];
                            // continue;
                        }
                    }
                }
                //将注册人数加入数组
                foreach ($spend as $key => $value) {
                    foreach ($user1 as $k => $v) {
                        if($v['fgame_id']==$value['game_id']&&$v['promote_id']==$value['promote_id']){
                            $spend[$key]['total_number']=$v['count'];

                        }
                    }
                   }
                   
        $timestart=$_GET['timestart'];
        $timeend=$_GET['timeend'];
        $this->assign('model', $model);
       if(strlen($_GET['timeend'])>10){
            $page=substr($_GET['timeend'],-1);
            
           }
        $this->assign('list_data', $this->page_array(10,$page,$spend));
        $this->assign('_page',$this->show_array($countpage,U("Query/bill/group/1&timestart=$timestart&timeend=$timeend"),$page));
        $this->meta_title = $model['title'].'列表';
        $this->display($model['template_list']);
    }


    public function check_bill($model = null,$p,$extend=array()){
        $model || $this->error('模型名标识必须！');
        $page = intval($p);
        $page = $page ? $page : 1; //默认显示第一页数据

        //解析列表规则
        $fields = $model['fields'];
        // 关键字搜索
        $map0    =   empty($extend[0])?array():$extend[0];
        $map1    =   empty($extend[1])?array():$extend[1];
        
        $user = D("User");
        $spend = D("Spend");
        
        //读取模型数据列表
        $data = array();
        
        $row    = 10;
				if(isset($_REQUEST['row'])) {$row = $_REQUEST['row'];}else{$row = 10;}
        
        $map1['is_check'] = $map0['is_check'] = 1;
        $map0['fgame_id'] = array('neq',0);
        
        $map1['pay_status'] = 1;

        $offset = ($page-1)*$row;
        
        $sql0 = $user->table("__USER__ as u ")
            ->field('u.id,u.promote_id,u.fgame_id as game_id,if(p.parent_id=0,u.promote_id,p.parent_id) as parent_id,u.fgame_name as game_name')
            ->join('__PROMOTE__ as p on(p.id=u.promote_id)','left')
            ->where($map0)
            ->order("u.id")
            ->group("u.id")       
            ->select(false);
        $sql0 = "select parent_id as promote_id,group_concat(promote_id) as chpids,game_id,game_name,count(id) as total_number from ("
            .$sql0
            ." ) as a group by a.game_id,a.parent_id order by parent_id " ;
            
        $data0 = $user->query($sql0." limit $offset,$row");  
        
        $count0 = count($user->query($sql0));              
        
        $sql1 = $spend->table("__SPEND__ as s")
            ->field("s.id,s.promote_id,s.game_id,if(p.parent_id=0,s.promote_id,p.parent_id) as parent_id,s.game_name,s.pay_amount ")
            ->join('__PROMOTE__ as p on(p.id=s.promote_id)','left')
            ->where($map1)
            ->group("id")
            ->select(false);
        $sql1 = "select parent_id as promote_id,group_concat(promote_id) as chpids,game_id,game_name,sum(pay_amount) as total_money from ( "
            .$sql1
            ." ) as a group by game_id,parent_id order by parent_id ";
        
        $data1 = $spend->query($sql1." limit $offset,$row");
        
        $count1 = count($spend->query($sql1));
        if (!empty($data1) && !empty($data0)) {
            foreach ($data1 as $j => $u) {
                foreach ($data0 as $k => $v) {
                    if (($u['promote_id'] == $v['promote_id']) && ($u['game_id'] == $v['game_id'])) {
                        if ($u['chpids'] !== $v['chpids']) {
                            $uchpids = (explode(',',$u['chpids']));
                            $schpids = (explode(',',$v['chpids']));
                            $chpids = array_unique(array_merge($uchpids,$schpids));
                            sort($chpids);
                            $u['chpids'] = $v['chpids'] = implode(',',$chpids);
                        }
                        $data[] = array_merge($u,$v);unset($data1[$j]);unset($data0[$k]);
                    }
                }       
            }             
            $data = array_merge($data,$data0,$data1); 
        } elseif (!empty($data0)) {$data = $data0;}
          elseif (!empty($data1)) {$data = $data1;}
        
        $count = $count0>$count1?$count0:$count1;
        
        //分页
         
        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->assign('model', $model);
        $this->assign('list_data', $data);
        $this->meta_title = $model['title'].'列表';
        $this->display($model['template_list']);
    }

        public function page_array($count,$page,$array,$order=0){
          global $countpage; #定全局变量
          $page=(empty($page))?'1':$page; #判断当前页面是否为空 如果为空就表示为第一页面 
            $start=($page-1)*$count; #计算每次分页的开始位置
          if($order==1){
           $array=array_reverse($array);
          }  
          $totals=count($array); 
          $countpage=ceil($totals/$count); #计算总页面数
          $pagedata=array();
         $pagedata=array_slice($array,$start,$count);
          return $pagedata; #返回查询数据
        }

        /**
         * 分页及显示函数
         * $countpage 全局变量，照写
         * $url 当前url
         */
        public function show_array($countpage,$url,$page){
           $page=empty($page)?1:$page;
         if($page > 1){
           $uppage=$page-1;
         }else{
          $uppage=1;
         }
         if($page < $countpage){
           $nextpage=$page+1;
         
         }else{
           $nextpage=$countpage;
         }
           $str='<div style="border:1px; height:30px; color:#9999CC">';
         $str.="<p>共 {$countpage} 页 / 第 {$page} 页</p>";
         $str.="<span class='current'><a href='$url/page/1'>  首页 </a></span>";
         $str.="<span><a href='$url/page/{$uppage}'> 上一页 </a></span>";
         $str.="<span><a href='$url/page/{$nextpage}'>下一页 </a></span>";
         $str.="<span><a href='$url/page/{$countpage}'>尾页 </a></span>";
         $str.='</div>';
         return $str;
        }

        
    public function cpsettl_list($model = null,$p,$extend=array()){
        $model || $this->error('模型名标识必须！');
        $page = intval($p);
        $page = $page ? $page : 1; //默认显示第一页数据
        //解析列表规则
        $fields = $model['fields'];
        // 关键字搜索
        $map    =   empty($extend)?array():$extend;

				 
				if(isset($_REQUEST['row'])) {$row = $_REQUEST['row'];}else{$row = 10;} 
        //读取模型数据列表
        $name = $model['m_name'];
        // var_dump($fields);exit;
        $new_model = M($name,'tab_');
        $data = $new_model 
            ->field($fields.",g.developers")
            // 查询条件
            ->where($map)
            /* 默认通过id逆序排列 */
            ->order($model['order'])
            ->join('tab_game as g on g.id=s.game_id','LEFT')
            //根据字段分组
            ->group($model['group'])
            /* 数据分页 */
            ->page($page,$row)
            ->order($model['order'])
            /* 执行查询 */
            ->select();
        /* 查询记录总数 */
        $count = $new_model 
            ->field($fields)
            // 查询条件
            ->where($map)
            /* 默认通过id逆序排列 */
            ->order($model['order'])
            ->join('tab_game as g on g.id=s.game_id','LEFT')
            //根据字段分组
            ->group($model['group'])
            /* 执行查询 */
            ->select();
            $count=count($count);
        static $alltotal=0;
        // var_dump($data);exit;
        foreach ($data as $key => $value) {
            $alltotal=$alltotal+$value['total']*$value['selle_ratio']/100;
        }
         //分页
				
				$page = set_pagination($count,$row);
				if($page) {$this->assign('_page', $page);}
				
        $this->assign('model', $model);
        $this->assign('data', $data);
        $this->assign('alltotal', $alltotal);
        
        $this->display($model['template_list']);

    }
}