Browse Source

签到 救济 统计

laowu 4 days ago
parent
commit
81bd4da705

+ 26 - 26
app/Console/Commands/RecordPlatformData.php

@@ -137,9 +137,9 @@ class RecordPlatformData extends Command
         // 低保
         //$Dibao = $dao->dibao($dateID);
         // 付费低保
-        //$payDibao = $dao->payDibao($dateID);
+        $payDibao = $dao->payDibao($dateID);
         // 签到人数、金额
-        //$signIn = $dao->signIn($dateID);
+        $signIn = $dao->signIn($dateID);
 
 
         $list = $RecordPlatformDataModel->where('DateID', $dateID)->where('Channel', '>=', 0)->get();
@@ -230,25 +230,25 @@ class RecordPlatformData extends Command
 //                }
 //            }
 
-//            if ($payDibao->isNotEmpty()) {
-//                // 付费低保人数
-//                foreach ($payDibao as $item) {
-//
-//                    $data = ['DateID' => $dateID, 'PayDibao' => $item->PayDibao];
-//
-//                    $dao->Update($data, $value->Channel, $item->Channel, $dateID);
-//                }
-//            }
+            if ($payDibao->isNotEmpty()) {
+                // 付费低保人数
+                foreach ($payDibao as $item) {
 
-//            if ($signIn->isNotEmpty()) {
-//                // 付费低保人数
-//                foreach ($signIn as $item) {
-//
-//                    $data = ['DateID' => $dateID, 'SignInSum' => $item->SignInSum,'SignInCount'=>$item->SignInCount];
-//
-//                    $dao->Update($data, $value->Channel, $item->Channel, $dateID);
-//                }
-//            }
+                    $data = ['DateID' => $dateID, 'PayDibao' => $item->PayDibao];
+
+                    $dao->Update($data, $value->Channel, $item->Channel, $dateID);
+                }
+            }
+
+            if ($signIn->isNotEmpty()) {
+                // 付费低保人数
+                foreach ($signIn as $item) {
+
+                    $data = ['DateID' => $dateID, 'SignInSum' => $item->SignInSum,'SignInCount'=>$item->SignInCount];
+
+                    $dao->Update($data, $value->Channel, $item->Channel, $dateID);
+                }
+            }
 
 
             $ARPU = $value->ActivePeple > 0 ? number_format(($value->PayTotal / $value->ActivePeple) / NumConfig::NUM_VALUE,2,'.','') : 0;
@@ -272,18 +272,18 @@ class RecordPlatformData extends Command
 //            $ShareWinningsScore = $ShareWinnings->sum('Score');
 //            $DibaoScore = $Dibao->sum('Score');
 //            $TotalDibaoCount = $Dibao->sum('TotalDibaoCount');
-//            $PayDibaoCont = $payDibao->sum('PayDibao');
-//            $SignInSum = $signIn->sum('SignInSum');
-//            $SignInCount = $signIn->sum('SignInCount');
+            $PayDibaoCont = $payDibao->sum('PayDibao');
+            $SignInSum = $signIn->sum('SignInSum');
+            $SignInCount = $signIn->sum('SignInCount');
 
             $GiveGold = 0;
             $RechargeWinningsScore = 0;
             $ShareWinningsScore = 0;
             $DibaoScore = 0;
             $TotalDibaoCount = 0;
-            $PayDibaoCont = 0;
-            $SignInSum = 0;
-            $SignInCount = 0;
+//            $PayDibaoCont = 0;
+//            $SignInSum = 0;
+//            $SignInCount = 0;
 
             $data = compact('ARPPU', 'ARPU', 'ApplyWithdraw', 'WithdrawFree', 'GameUserCount', 'NewGameUserCount', 'GiveGold', 'ApplyWithdrawBi',
                 'ApplyWithdrawCount','TotalDibaoCount','SignInSum','SignInCount','NewWinTop');

+ 2 - 0
app/dao/RecordPlatformData/RecordPlatformData.php

@@ -151,7 +151,9 @@ class RecordPlatformData
         return DB::connection('sqlsrv')->table(TableName::QPRecordDB() . 'RecordUserScoreChangeStatistics as rc')
             ->where('DateID', $dateID)
             ->where('ScoreType', 44)
+            ->where('ruts.Recharge', '>', 0)
             ->join(TableName::QPAccountsDB() . 'AccountsInfo as ai', 'rc.UserID', 'ai.UserID')
+            ->join(DB::raw('QPRecordDB.dbo.RecordUserTotalStatistics as ruts'), 'ruts.UserID', 'rc.UserID')
             ->selectRaw('sum(Score) as SignInSum,count(rc.UserID) SignInCount,Channel')
             ->groupBy('Channel')
             ->get();