From e0857168f8f2ac8f677d6eca5b07ecc17cd8f63c Mon Sep 17 00:00:00 2001 From: chenzhi <“chenzhi063@qq.com> Date: Wed, 30 Oct 2019 10:26:10 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E6=8E=A5=E5=8F=A3=E7=BB=88?= =?UTF-8?q?=E7=BB=93?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../SpendCountSetController.class.php | 77 +++++++++++++------ 1 file changed, 55 insertions(+), 22 deletions(-) diff --git a/Application/Admin/Controller/SpendCountSetController.class.php b/Application/Admin/Controller/SpendCountSetController.class.php index 3cc425559..bff90c5fe 100644 --- a/Application/Admin/Controller/SpendCountSetController.class.php +++ b/Application/Admin/Controller/SpendCountSetController.class.php @@ -12,6 +12,7 @@ class SpendCountSetController extends \Think\Controller public $date; public $nowdata; public $model; + public $usermodel; public $continue=false;//单元测试，开启后可访问独立函数测试 public function _initialize(){ //初始化 @@ -20,6 +21,7 @@ class SpendCountSetController extends \Think\Controller $this->date = date('Y')."-".((date('m')-1) > 9 ? (date('m')-1) : "0".(date('m')-1)); $this->nowdata =time(); $this->model =M("spend_count",'tab_'); + $this->usermodel =M("spend_user_count",'tab_'); } /** * 初始化统计/用于之前数据的聚合 @@ -31,7 +33,7 @@ class SpendCountSetController extends \Think\Controller die("init error"); } $nowdate = date('Y')."-".(date('m') > 9 ? date('m') : "0".date('m')); - $nowdate = "2017-10"; + // $nowdate = "2017-10"; //获取所有的月份 pay_time $res = M("spend",'tab_')->field("FROM_UNIXTIME(pay_time,'%Y-%m') AS pay_time")->buildSql(); $res = M()->table($res.' a')->group('pay_time')->select(); @@ -39,23 +41,23 @@ class SpendCountSetController extends \Think\Controller for ($i=0; $i < count($res); $i++) { # code... if($res[$i]['pay_time'] != $nowdate){ + //设定初始时间 $month = $res[$i]['pay_time']; $this->date = $month; $tarry = explode('-',$month); $this->beginThismonth=mktime(0,0,0,$tarry[1],1,$tarry[0]); $this->endThismonth=mktime(0,0,0,$tarry[1]-0+1,1,$tarry[0])-1; - //执行 + //执行聚合 $this->model->startTrans(); + $this->usermodel->startTrans(); $this->continue =true; - $this->getCashData(); - $this->getBalanceData(); - $this->getBingData(); - $this->getInsideData(); - $this->setRoot(); + //执行游戏表统计 + $this->setGameCount(); //执行用户表统计 $this->setUserCount(); - + $this->model->commit(); + $this->usermodel->commit(); } } die("success"); @@ -68,22 +70,34 @@ class SpendCountSetController extends \Think\Controller { //判断是否已经聚合 $countRes = M("spend_count","tab_")->field("count(*) date_count")->where("count_date = '{$this->date}'")->find()['date_count']; - if($countRes > 0){ - die("Repeated statistics"); + $countUserRes = M("spend_user_count","tab_")->field("count(*) date_count")->where("count_date = '{$this->date}'")->find()['date_count']; + if($countRes > 0 || $countUserRes >0){ + die("error:Repeated statistics"); } $this->model->startTrans(); + $this->usermodel->startTrans(); $this->continue =true; - $this->getCashData(); - $this->getBalanceData(); - $this->getBingData(); - $this->getInsideData(); - $this->setRoot(); + //执行游戏表统计 + $this->setGameCount(); //执行用户表统计 $this->setUserCount(); - + //执行 $this->model->commit(); + $this->usermodel->commit(); die("success"); } + /** + * 获取游戏聚合 + */ + public function setGameCount() + { + $this->getCashData(); + $this->getBalanceData(); + $this->getBingData(); + $this->getInsideData(); + $this->getRoot(); + # code... + } //获取游戏现金流水 public function getCashData() { @@ -265,7 +279,7 @@ class SpendCountSetController extends \Think\Controller } // return true; } - public function setRoot() + public function getRoot() { if(!$this->continue){ die("api error"); @@ -312,6 +326,7 @@ class SpendCountSetController extends \Think\Controller //获取会长信息 public function getRootUser() { + if(!$this->continue) die("api error"); //获取所有数据 $month = $this->date; $from = " @@ -342,13 +357,18 @@ class SpendCountSetController extends \Think\Controller "count_date"=>$this->date, "create_time"=>$this->nowdata ); - M("spend_user_count","tab_")->add($adddata); + $tempdbres = $this->usermodel->add($adddata); + if(!$tempdbres){ + $this->usermodel->rollback(); + die("getRootUser error"); + } } } //获取组长信息 public function getParentUser() { + if(!$this->continue) die("api error"); $month =$this->date; //获取数据 $from = " @@ -377,13 +397,18 @@ class SpendCountSetController extends \Think\Controller "count_date"=>$this->date, "create_time"=>$this->nowdata ); - M("spend_user_count","tab_")->add($adddata); + $tempdbres = $this->usermodel->add($adddata); + if(!$tempdbres){ + $this->usermodel->rollback(); + die("getParentUser error"); + } } } //获取组员 public function getPromoteUser() { + if(!$this->continue) die("api error"); $month = $this->date;; //获取数据 $from = " @@ -410,14 +435,18 @@ class SpendCountSetController extends \Think\Controller "count_date"=>$this->date, "create_time"=>$this->nowdata ); - M("spend_user_count","tab_")->add($adddata); + $tempdbres = $this->usermodel->add($adddata); + if(!$tempdbres){ + $this->usermodel->rollback(); + die("getPromoteUser error"); + } } # code... } //处理inside_cash_count public function getInsideData2() { - + if(!$this->continue) die("api error"); $insideRes = M() ->table("tab_deposit deposit") ->field("promote_id,promote_account,IFNULL(promote.parent_id,0) parent_id,parent_name,sum(pay_amount) inside_cash_count,'{$this->date}' as count_date,'{$this->nowdata}' as create_time") @@ -469,7 +498,11 @@ class SpendCountSetController extends \Think\Controller ); $dbres = M("spend_user_count","tab_")->where($tempmap)->find(); $savedata = array("inside_cash_count"=>$inside_cash_count-0+$dbres['inside_cash_count'],"all_count"=>$inside_cash_count-0+$dbres['all_count']); - M("spend_user_count","tab_")->where($tempmap)->save($savedata); + $tempdbres = $this->usermodel->where($tempmap)->save($savedata); + if(!$tempdbres){ + $this->usermodel->rollback(); + die("setInsideCount error"); + } # code... }