聚合财务1
chenzhi
5 years ago
parent
744cbcf7ea
commit
95cd9993e2
@ -0,0 +1,320 @@
|
||||
<?php
|
||||
|
||||
namespace Admin\Controller;
|
||||
use Think\Controller;
|
||||
|
||||
/**
|
||||
* 后台总览聚合
|
||||
* @author cz
|
||||
*/
|
||||
class AggregateFinanceSetController extends Controller {
|
||||
// public $beginTime;
|
||||
// public $endTime;
|
||||
// public $date;
|
||||
// public $nowdata;
|
||||
// public $UserModel;
|
||||
// public $ChartModel;
|
||||
// public $LoginModel;
|
||||
// public $SpendModel;
|
||||
// public $PromoteModel;
|
||||
// public $GameCountModel;
|
||||
// public $addid;
|
||||
// public $adddata;
|
||||
// public $gameid;
|
||||
// public $gamedata;
|
||||
// public $reset=false;
|
||||
public $apihost;
|
||||
|
||||
public function _initialize(){
|
||||
$apihost = M("Kv")->field("value")->where("`key` = 'aggregate_finance_api'")->find();
|
||||
if(empty($apihost)){
|
||||
echo "请先设置请求接口aggregate_finance_api的值".PHP_EOL;die;
|
||||
}
|
||||
$this->apihost = $apihost['value'];
|
||||
//初始化
|
||||
// $this->UserModel =M("User","tab_");
|
||||
// $this->LoginModel =M("user_login_record","tab_");
|
||||
// $this->SpendModel =M("spend","tab_");
|
||||
// $this->PromoteModel =M("promote","tab_");
|
||||
// $this->model =M();
|
||||
// $this->PromoteCountModel =M("PromoteCount","tab_");
|
||||
// $this->GameCountModel =M("GameCount","tab_");
|
||||
// $this->nowdata =time();
|
||||
|
||||
// $group_concat_max_len = M()->execute("SET SESSION group_concat_max_len = 4294967295");
|
||||
// echo "set group_concat_max_len ok,beging count".PHP_EOL;
|
||||
// if(I("reset")) $this->reset = true;
|
||||
|
||||
|
||||
}
|
||||
public function setDaliyCount()
|
||||
{
|
||||
$w = (int)date("w");
|
||||
$d = (int)date("d");
|
||||
|
||||
|
||||
$this->setDateCount($begin);
|
||||
}
|
||||
public function setWeekCount()//进行周结
|
||||
{
|
||||
echo $this->apihost;
|
||||
# code...
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
public function setFreeDateCount($begin,$end='')
|
||||
{
|
||||
if($end == '') $end = $begin;
|
||||
//判断日期格式
|
||||
$patten = "/^\d{4}[\-](0?[1-9]|1[012])[\-](0?[1-9]|[12][0-9]|3[01])$/";
|
||||
if (!preg_match($patten, $begin)) {
|
||||
die("开始时间格式错误");
|
||||
}
|
||||
if (!preg_match($patten, $end)) {
|
||||
die("结束时间格式错误");
|
||||
}
|
||||
if(strtotime($end) < strtotime($begin)){
|
||||
die("结束时间不能比开始时间小");
|
||||
}
|
||||
if(strtotime($end)+86399 > time()){
|
||||
die("结束时间不能包含今日");
|
||||
}
|
||||
if($begin == $end){
|
||||
$this->setDateCount($begin);
|
||||
}else{
|
||||
$starttime = $begin?strtotime($begin):mktime(0,0,0,date('m'),date('d')-1,date('Y'));
|
||||
$endtime = $end?strtotime($end)+86399:$starttime+86399;
|
||||
$datelist = get_date_list($starttime,$endtime,1);
|
||||
$countdate = count($datelist);
|
||||
for($i=0;$i<$countdate;$i++){
|
||||
$this->setDateCount($datelist[$i]);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
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);
|
||||
//判断是否存在
|
||||
$PromoteRes = $this->PromoteCountModel->where("date = '{$this->beginTime}'")->find();
|
||||
$GameRes = $this->GameCountModel->where("date = '{$this->beginTime}'")->find();
|
||||
$reset='';
|
||||
if(!empty($PromoteRes) || !empty($GameRes) ){
|
||||
if($this->reset){
|
||||
$this->PromoteCountModel->where("date = '{$this->beginTime}'")->delete();
|
||||
$this->GameCountModel->where("date = '{$this->beginTime}'")->delete();
|
||||
$reset = "reset and creat ";
|
||||
}else{
|
||||
echo ("{$this->date} 已统计，请勿重复提交".PHP_EOL);
|
||||
return;
|
||||
}
|
||||
}
|
||||
$this->model->startTrans();
|
||||
$this->addid = [];
|
||||
$this->adddata = [];
|
||||
$this->promoteNew();
|
||||
$this->promotePayMoeny();
|
||||
$this->promoteActive();
|
||||
$this->promoteCreateDb();
|
||||
// unset($this->addid);
|
||||
// unset($this->adddata);
|
||||
$this->gameid = [];
|
||||
$this->gamedata = [];
|
||||
$this->gameNew();
|
||||
$this->gamePayMoeny();
|
||||
$this->gameActive();
|
||||
$this->gameCreateDb();
|
||||
$this->model->commit();
|
||||
$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]];
|
||||
$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'] = @json_encode(array_map("intFun",explode(",",$value['active_user_list'])));
|
||||
if(empty($value['promote_account']) && $value['promote_id']){
|
||||
if($value['promote_id'] == 0){
|
||||
$value['promote_account'] = "官方渠道";
|
||||
}else{
|
||||
$value['promote_account'] = $this->PromoteModel->field("account")->where("id = {$value['promote_id']}")->find()['account'];
|
||||
if(!$value['promote_account']){
|
||||
$value['promote_account']="未知推广员";
|
||||
}
|
||||
}
|
||||
}
|
||||
$tempdbres = $this->PromoteCountModel->add($value);
|
||||
if($tempdbres === false){
|
||||
$this->model->rollback();
|
||||
die("error");
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
//=======================聚合游戏========================
|
||||
//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->gameid[] = $gameNew[$i]["game_id"];
|
||||
$this->gamedata[$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->gameid)) {
|
||||
//存在
|
||||
$this->gamedata[$gamePayMoeny[$i]["game_id"]]["pay_money_count"] = $gamePayMoeny[$i]["pay_money_count"];
|
||||
}else{
|
||||
$this->gameid[] = $gamePayMoeny[$i]["game_id"];
|
||||
$this->gamedata[$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->gameid)) {
|
||||
//存在
|
||||
$this->gamedata[$gameActive[$i]["game_id"]]["active_user_count"] = $gameActive[$i]["active_user_count"];
|
||||
$this->gamedata[$gameActive[$i]["game_id"]]["active_user_list"] = $gameActive[$i]["active_user_list"];
|
||||
}else{
|
||||
$this->gameid[] = $gameActive[$i]["game_id"];
|
||||
$this->gamedata[$gameActive[$i]["game_id"]] = $gameActive[$i];
|
||||
}
|
||||
}
|
||||
unset($gameActive);
|
||||
}
|
||||
//4加入数据库
|
||||
public function gameCreateDb()
|
||||
{
|
||||
$count = count($this->gameid);
|
||||
if ($count > 0) {
|
||||
foreach ($this->gamedata as $key => $value) {
|
||||
$value['date']=$this->beginTime;
|
||||
$value['create_time']=$this->nowdata;
|
||||
$value['active_user_list'] = @json_encode(array_map("intFun",explode(",",$value['active_user_list'])));
|
||||
$tempdbres = $this->GameCountModel->add($value);
|
||||
if($tempdbres === false){
|
||||
$this->model->rollback();
|
||||
die("error");
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
Loading…
Reference in New Issue