cf-platform/Application/Admin/Controller/StatisticsCountSetController.class.php

<?php

namespace Admin\Controller;
use Think\Controller;

/**
 * 后台总览聚合
 * @author cz
 * 与group_concat最大字符数102400。后期考虑放弃
 */
class StatisticsCountSetController extends Controller {
	public $beginTime;
	public $endTime;
	public $date;
	public $nowdata;
	public $UserModel;
	public $ChartModel;
	public $LoginModel;
	public $SpendModel;
	public $PromoteModel;

	public $addid;
	public $adddata;
	public $reset=false;

	public function _initialize(){
        //初始化
        $this->UserModel =M("User","tab_");
        $this->LoginModel =M("user_login_record","tab_");
        $this->SpendModel =M("spend","tab_");
		$this->PromoteModel =M("promote","tab_");
		
        $this->PromoteCountModel =M("PromoteCount","tab_");
        $this->GameCountModel =M("GameCount","tab_");
		$this->nowdata =time();
		if(I("reset"))  $this->reset = true;

    }
   public function setDateCount($date)
	{
		$this->date =  $date;
		$tarry = explode('-',$date);
        $this->beginTime=mktime(0,0,0,$tarry[1],$tarry[2],$tarry[0]);
		$this->endTime=mktime(0,0,0,$tarry[1],$tarry[2]-0+1,$tarry[0])-1;

        set_time_limit(0);
		$t1 = microtime(true);
		//判断是否存在
		// $res = $this->ChartModel->where("date = '{$this->beginTime}'")->find();
		// $reset='';
		// if(!empty($res)){
		// 	if($this->reset){
		// 		$this->ChartModel->where("date = '{$this->beginTime}'")->delete();
		// 		$reset = "reset and creat ";
		// 	}else{
		// 		echo ("{$this->date} 已统计，请勿重复提交".PHP_EOL);
		// 		return;
		// 	}
			
		// }
		$group_concat_max_len = M()->query("show variables like 'group_concat_max_len'")[0]['value'];
		if($group_concat_max_len < 102400){
			echo ("请".PHP_EOL);	
		}
		dump($res);

		// $this->promoteNew();
		// $this->promotePayMoeny();
		// $this->promoteActive();
		// $this->promoteCreateDb();

		// $this->addid = [];
		// $this->adddata = [];

        // $this->gameNew();
		// $this->gamePayMoeny();
		// $this->gameActive();
		// $this->gameCreateDb();
		

		$t2 = microtime(true);
		echo ("{$this->date} {$reset}success runtime:".round($t2-$t1,3).'s'.PHP_EOL);
		# code...
	}

   //=======================聚合推广员========================
   //1聚合新增
   public function promoteNew()
   {
	$map = ['register_time'=>['between',[$this->beginTime,$this->endTime]],"puid"=>0,"promote_id"=>["gt",0]];//0不是小号
	$promoteNew = $this->UserModel->field('COUNT(1) AS new_user_count,promote_id,promote_account')
				->where($map)
				->group("promote_id")
				->select();
	$count = count($promoteNew);
	for ($i=0; $i < $count; $i++) { 
		$this->addid[] = $promoteNew[$i]["promote_id"];
		$this->adddata[$promoteNew[$i]["promote_id"]] = $promoteNew[$i];
	}
	unset($promoteNew);
   }
   //2聚合付费
   public function promotePayMoeny()
   {
	$map = ['pay_time'=>['between',[$this->beginTime,$this->endTime]],"pay_status"=>1,"promote_id"=>["gt",0]];//1支付成功
	$promotePayMoeny = $this->SpendModel->field('sum(pay_amount) AS pay_money_count,promote_id,promote_account')
				->where($map)
				->group("promote_id")
				->select();
	$count = count($promotePayMoeny);
	for ($i=0; $i < $count; $i++) { 
		if (in_array($promotePayMoeny[$i]["promote_id"],$this->addid)) {
			//存在
			$this->adddata[$promotePayMoeny[$i]["promote_id"]]["pay_money_count"] = $promotePayMoeny[$i]["pay_money_count"];
		}else{
			$this->addid[] = $promotePayMoeny[$i]["promote_id"];
			$this->adddata[$promotePayMoeny[$i]["promote_id"]] = $promotePayMoeny[$i];
		}
	}	
	unset($promotePayMoeny);
   }
   //3聚合活跃
   public function promoteActive()
   {
	$map = ['login_time'=>['between',[$this->beginTime,$this->endTime]],"promote_id"=>["gt",0]];//0不是小号
	$promoteActive = $this->LoginModel->field('COUNT(DISTINCT user_id) AS active_user_count,GROUP_CONCAT(DISTINCT user_id) active_user_list,promote_id')
				->where($map)
				->group("promote_id")
				->select();
	$count = count($promoteActive);
	for ($i=0; $i < $count; $i++) { 
		if (in_array($promoteActive[$i]["promote_id"],$this->addid)) {
			//存在
			$this->adddata[$promoteActive[$i]["promote_id"]]["active_user_count"] = $promoteActive[$i]["active_user_count"];
			$this->adddata[$promoteActive[$i]["promote_id"]]["active_user_list"] = $promoteActive[$i]["active_user_list"];
		}else{
			$this->addid[] = $promoteActive[$i]["promote_id"];
			$this->adddata[$promoteActive[$i]["promote_id"]] = $promoteActive[$i];
		}
	}
	unset($promoteActive);
   }
   //4加入数据库
   public function promoteCreateDb()
	{	
		$count = count($this->addid);
		if ($count > 0) {
			foreach ($this->adddata as $key => $value) {
				$value['date']=$this->beginTime;
				$value['create_time']=$this->nowdata;
				$value['active_user_list'] = @serialize(explode(",",$value['active_user_list']));
				if(empty($value['promote_account'])){
					$value['promote_account'] =  $this->PromoteModel->field("account")->where("id = {$value['promote_id']}")->find()['account'];
				}
				$this->PromoteCountModel->add($value);
			}
		}
	}
	//=======================聚合游戏========================
	//1聚合新增
	public function gameNew()
	{
		$map = ['register_time'=>['between',[$this->beginTime,$this->endTime]],"puid"=>0,"fgame_id"=>["gt",0]];//0不是小号
		$gameNew = $this->UserModel->field('COUNT(1) AS new_user_count,fgame_id game_id,fgame_name game_name')
					->where($map)
					->group("fgame_id")
					->select();
		$count = count($gameNew);
		for ($i=0; $i < $count; $i++) { 
			$this->addid[] = $gameNew[$i]["game_id"];
			$this->adddata[$gameNew[$i]["game_id"]] = $gameNew[$i];
		}
		unset($gameNew);
	}
	//2聚合付费
	public function gamePayMoeny()
	{
		$map = ['pay_time'=>['between',[$this->beginTime,$this->endTime]],"pay_status"=>1,"game_id"=>["gt",0]];//1支付成功
		$gamePayMoeny = $this->SpendModel->field('sum(pay_amount) AS pay_money_count,game_id,game_name')
					->where($map)
					->group("game_id")
					->select();
		$count = count($gamePayMoeny);
		for ($i=0; $i < $count; $i++) { 
			if (in_array($gamePayMoeny[$i]["game_id"],$this->addid)) {
				//存在
				$this->adddata[$gamePayMoeny[$i]["game_id"]]["pay_money_count"] = $gamePayMoeny[$i]["pay_money_count"];
			}else{
				$this->addid[] = $gamePayMoeny[$i]["game_id"];
				$this->adddata[$gamePayMoeny[$i]["game_id"]] = $gamePayMoeny[$i];
			}
		}	
		unset($gamePayMoeny);
	}
	//3聚合活跃
	public function gameActive()
	{
	 $map = ['login_time'=>['between',[$this->beginTime,$this->endTime]],"game_id"=>["gt",0]];//0不是小号
	 $gameActive = $this->LoginModel->field('COUNT(DISTINCT user_id) AS active_user_count,GROUP_CONCAT(DISTINCT user_id) active_user_list,game_id,game_name')
				 ->where($map)
				 ->group("game_id")
				 ->select();
	 $count = count($gameActive);
	 for ($i=0; $i < $count; $i++) { 
		 if (in_array($gameActive[$i]["game_id"],$this->addid)) {
			 //存在
			 $this->adddata[$gameActive[$i]["game_id"]]["active_user_count"] = $gameActive[$i]["active_user_count"];
			 $this->adddata[$gameActive[$i]["game_id"]]["active_user_list"] = $gameActive[$i]["active_user_list"];
		 }else{
			 $this->addid[] = $gameActive[$i]["game_id"];
			 $this->adddata[$gameActive[$i]["game_id"]] = $gameActive[$i];
		 }
	 }
	 unset($gameActive);
	}
	//4加入数据库
	public function gameCreateDb()
	{	
		$count = count($this->addid);
		if ($count > 0) {
			foreach ($this->adddata as $key => $value) {
				$value['date']=$this->beginTime;
				$value['create_time']=$this->nowdata;
				$value['active_user_list'] = @serialize(explode(",",$value['active_user_list']));
				$this->GameCountModel->add($value);
			}
		}
	}
	
}