玩家日志

app/v1/controller/gameLog/UserLogController.php

@@ -0,0 +1,130 @@
+<?php
+
+// 玩家日志控制器
+
+namespace app\v1\controller\gameLog;
+
+use app\v1\logic\gameLog\UserLogLogic;
+use plugin\saiadmin\basic\BaseController;
+use support\Request;
+use support\Response;
+
+class UserLogController extends BaseController
+{
+    public function __construct()
+    {
+      $this->logic = new UserLogLogic();
+      parent::__construct();
+    }
+
+    // 注册日志
+    public function getRegLogList(Request $request)
+    {
+        $where = $request->more([
+            ['user_name', ''],
+            ['media_id', ''],
+            ['game_id', ''],
+            ['agent_id', ''],
+            ['site_id', ''],
+            ['reg_time', ''],
+            ['vt', ''],
+        ]);
+
+        $data = $this->logic->getRegLogList($where);
+        $data['data'] = $this->logic->trandformListColumn($data['data'], ['site', 'agent', 'game', 'auth', 'media', 'ip']);
+        return $this->success($data);
+    }
+
+    // 登录日志
+    public function getLoginLogList(Request $request)
+    {
+        $where = $request->more([
+            ['user_name', ''],
+            ['media_id', ''],
+            ['game_id', ''],
+            ['agent_id', ''],
+            ['site_id', ''],
+            ['auth_id', ''],
+            ['reg_time', ''],
+            ['login_time', ''],
+        ]);
+
+        $data = $this->logic->getLoginLogList($where);
+        $data['data'] = $this->logic->trandformListColumn($data['data'], ['site', 'agent', 'game', 'auth', 'media', 'ip']);
+        return $this->success($data);
+    }
+
+    // 充值明细
+    public function getRechargeDetailList(Request $request)
+    {
+        $where = $request->more([
+            ['game_id', ''],
+            ['media_id', ''],
+            ['auth_id', ''],
+            ['agent_id', ''],
+            ['site_id', ''],
+            ['user_name', ''],
+            ['server_id', ''],
+            ['server_name', ''],
+            ['reg_date', ''],
+            ['pay_date', ''],
+        ]);
+        $data = $this->logic->getRechargeDetailList($where);
+        $data['data'] = $this->logic->trandformListColumn($data['data'], ['game', 'ip', 'agent','auth', 'pay_channel']);
+        return $this->success($data);
+    }
+
+    // 充值排行
+    public function getRechargeRankList(Request $request)
+    {
+        $where = $request->more([
+            ['game_id', ''],
+            ['media_id', ''],
+            ['auth_id', ''],
+            ['agent_id', ''],
+            ['site_id', ''],
+            ['user_name', ''],
+            ['server_id', ''],
+            ['server_name', ''],
+            ['reg_date', ''],
+            ['pay_date', ''],
+        ]);
+        $data = $this->logic->getRechargeRankList($where);
+       
+        return $this->success($data);
+    }
+
+    // 充值明细导出
+    public function exportRechargeDetailList(Request $request)
+    {
+        $where = $request->more([
+           ['game_id', ''],
+            ['media_id', ''],
+            ['auth_id', ''],
+            ['agent_id', ''],
+            ['site_id', ''],
+            ['user_name', ''],
+            ['server_id', ''],
+            ['server_name', ''],
+            ['reg_date', ''],
+            ['pay_date', ''],
+        ]);
+        return $this->logic->exportRechargeDetailList($where);
+    }
+
+    // 角色数据
+    public function getRoleDataList(Request $request)
+    {
+       $where = $request->more([
+            ['game_id', ''],
+            ['media_id', ''],
+            ['site_id', ''],
+            ['auth_id', ''],
+            ['user_name', ''],
+            ['reg_time', ''],
+        ]);
+        $data = $this->logic->getRoleDataList($where);
+        return $this->success($data);
+    }
+
+}

app/v1/logic/gameLog/UserLogLogic.php

@@ -0,0 +1,480 @@
+<?php
+
+// 玩家日志逻
+
+namespace app\v1\logic\gameLog;
+
+use plugin\saiadmin\basic\BaseLogic;
+use plugin\saiadmin\service\OpenSpoutWriter;
+use support\think\Db;
+use support\Request;
+
+class UserLogLogic extends BaseLogic
+{
+
+  // 注册日志
+    public function getRegLogList($where): mixed
+    {
+      
+      $params = $this->searchByAuth($where);
+
+      $regTime = $params['reg_time'];
+      $tableName = 'sdk_reg_log_'.date('Ym',strtotime($regTime));
+      $params['reg_time'] =strtotime($regTime . " 00:00:00") . "<=" . strtotime($regTime . " 23:59:59");
+      $orderBy = request()->input('orderBy', 'reg_time');
+      $orderType = request()->input('orderType', 'desc');
+      $page = request()->input('page', 1);
+      $limit = request()->input('limit', 10);
+  
+
+      // 获取这一天的注册日志
+      $regLogQuery = Db::connect('db_game_log')
+          ->table($tableName)
+          ->where('reg_time', '>=', strtotime($regTime . ' 00:00:00'))
+          ->where('reg_time', '<=', strtotime($regTime . ' 23:59:59'));
+
+      // 添加其他查询条件
+      if (!empty($params['game_id'])) {
+          $regLogQuery = $regLogQuery->where('game_id', 'in', is_array($params['game_id']) ? implode(',', $params['game_id']) : $params['game_id']);
+      }
+      if(!empty($params['user_name'])){
+        $regLogQuery = $regLogQuery->where('user_name', $params['user_name']);
+      }
+      if(!empty($params['media_id'])){
+        $regLogQuery = $regLogQuery->where('media_id', $params['media_id']);
+      }
+      if(!empty($params['site_id'])){
+        $regLogQuery = $regLogQuery->where('site_id', $params['site_id']);
+      }
+      if(!empty($params['agent_id'])){
+        $regLogQuery = $regLogQuery->where('agent_id', $params['agent_id']);
+      }
+      if(!empty($params['vt'])){
+        $regLogQuery = $regLogQuery->where('vt', $params['vt']);
+      }
+
+      // 执行查询并排序
+      $data = $regLogQuery->order($orderBy, $orderType)->select()->toArray();
+
+      // 分页
+     
+      $data = $regLogQuery->paginate($limit, false, ['page' => $page])->toArray();
+
+      return $data;
+    }
+
+    // 登录日志
+    public function getLoginLogList($where): mixed
+    {
+    
+      $orderBy = request()->input('orderBy', 'login_time');
+      $orderType = request()->input('orderType', 'desc');
+      $page = request()->input('page', 1);
+      $limit = request()->input('limit', 10);
+
+      $params = $this->searchByAuth($where);
+      $loginTime = $params['login_time'];
+      $tableName = 'sdk_login_log_'.date('Ym',strtotime($loginTime));
+
+
+      $loginLogQuery = Db::connect('db_game_log')
+          ->table($tableName)
+          ->where('login_time', '>=', strtotime($params['login_time'] . ' 00:00:00'))
+          ->where('login_time', '<=', strtotime($params['login_time'] . ' 23:59:59'));
+
+      if(!empty($params['game_id'])){
+        $loginLogQuery = $loginLogQuery->where('game_id', 'in', is_array($params['game_id']) ? implode(',', $params['game_id']) : $params['game_id']);
+      }
+      if(!empty($params['user_name'])){
+        $loginLogQuery = $loginLogQuery->where('user_name', $params['user_name']);
+      }
+      if(!empty($params['media_id'])){
+        $loginLogQuery = $loginLogQuery->where('media_id', $params['media_id']);
+      }
+      if(!empty($params['site_id'])){
+        $loginLogQuery = $loginLogQuery->where('site_id', $params['site_id']);
+      }
+      if(!empty($params['auth_id'])){
+        $loginLogQuery = $loginLogQuery->where('auth_id', $params['auth_id']);
+      }
+      if(!empty($params['agent_id'])){
+        $loginLogQuery = $loginLogQuery->where('agent_id', $params['agent_id']);
+      }
+      if(!empty($params['reg_time'])){
+        $loginLogQuery = $loginLogQuery
+        ->where('reg_time', '>=', strtotime($params['reg_time'] . ' 00:00:00'))
+        ->where('reg_time', '<=', strtotime($params['reg_time'] . ' 23:59:59'));
+      }
+      if(!empty($params['login_time'])){
+        $loginLogQuery = $loginLogQuery
+        ->where('login_time', '>=', strtotime($params['login_time'] . ' 00:00:00'))
+        ->where('login_time', '<=', strtotime($params['login_time'] . ' 23:59:59'));
+      }
+       // 执行查询并排序
+     
+      $loginLogQuery->order($orderBy, $orderType);
+   
+      $data = $loginLogQuery->paginate($limit, false, ['page' => $page])->toArray();
+      return $data;
+    }
+
+    // 充值明细
+    public function getRechargeDetailList($where,$type="list"): mixed
+    {
+      $orderBy = request()->input('orderBy', 'pay_date');
+      $orderType = request()->input('orderType', 'desc');
+      $page = request()->input('page', 1);
+      $limit = request()->input('limit', 10);
+
+      $params = $this->searchByAuth($where);
+   
+      $tableName = 'sdk_order_success';
+
+      $rechargeDetailQuery = Db::connect('db_game_log')
+          ->table($tableName)
+          ->where('pay_date', '>=', $params['pay_date'][0] . ' 00:00:00')
+          ->where('pay_date', '<=', $params['pay_date'][1] . ' 23:59:59');
+
+
+      if(!empty($params['game_id'])){
+        $rechargeDetailQuery = $rechargeDetailQuery->where('game_id', 'in', is_array($params['game_id']) ? implode(',', $params['game_id']) : $params['game_id']);
+      }
+      if(!empty($params['user_name'])){
+        $rechargeDetailQuery = $rechargeDetailQuery->where('user_name', $params['user_name']);
+      }
+      if(!empty($params['media_id'])){
+        $rechargeDetailQuery = $rechargeDetailQuery->where('media_id', $params['media_id']);
+      }
+      if(!empty($params['auth_id'])){
+        $rechargeDetailQuery = $rechargeDetailQuery->where('auth_id', $params['auth_id']);
+      }
+      if(!empty($params['agent_id'])){
+        $rechargeDetailQuery = $rechargeDetailQuery->where('agent_id', $params['agent_id']);
+      }
+      if(!empty($params['site_id'])){
+        $rechargeDetailQuery = $rechargeDetailQuery->where('site_id', $params['site_id']);
+      }
+      if(!empty($params['server_id'])){
+        $rechargeDetailQuery = $rechargeDetailQuery->where('server_id', $params['server_id']);
+      }
+      if(!empty($params['server_name'])){
+        $rechargeDetailQuery = $rechargeDetailQuery->where('server_name', $params['server_name']);
+      }
+      if(!empty($params['reg_date'])){
+        $rechargeDetailQuery = $rechargeDetailQuery
+        ->where('reg_date', '>=', $params['reg_date'][0] . ' 00:00:00')
+        ->where('reg_date', '<=', $params['reg_date'][1] . ' 23:59:59');
+      }
+
+      $rechargeDetailQuery->order($orderBy, $orderType);
+
+      if($type == 'all'){
+        $data = $rechargeDetailQuery->select()->toArray();
+      }else{
+        $data = $rechargeDetailQuery->paginate($limit, false, ['page' => $page])->toArray();
+      }
+      
+      return $data;
+    }
+
+    // 充值明细导出
+    public function exportRechargeDetailList($where): mixed
+    {
+        $data = $this->getRechargeDetailList($where, 'all');
+
+        print_r('====>');
+        print_r($data);
+       
+        $data = $this->trandformListColumn($data, ['game', 'ip', 'agent','auth', 'pay_channel']);
+        $data = array_map(function($item){
+            return [
+                'orderid' => $item['orderid'],
+                'user_name' => $item['user_name'],
+                'agent_id' => $item['agent_id'],
+                'site_id' => $item['site_id'],
+                'game_name' => $item['game_name'],
+                'server_id' => $item['server_id'],
+                'server_name' => $item['server_name'],
+                'pay_channel_name' => $item['pay_channel_name'],
+                'money' => $item['money'],
+                'pay_date' => $item['pay_date'],
+                'reg_date' => $item['reg_date'],
+                
+                'first_payment' => $item['first_payment'],
+                'agent_name' => $item['agent_name'],
+                'auth_name' => $item['auth_name'],
+            ];
+        }, $data);
+      
+        // 是否首次付费
+        $filter = [
+            'first_payment' => [
+                ['value' => 1, 'label' => '是'],
+                ['value' => 0, 'label' => '否']
+            ]
+        ];
+        $file_name = '充值明细_'.date('YmdHis').'.xlsx';
+        $header = ['订单号', '用户名', '渠道ID', '广告位ID', '游戏名', '服务器ID', '服务器名', '支付方式', '充值金额', '充值时间', '注册时间', '是否首次付费',  '渠道名', '负责人'];
+       
+        $writer = new OpenSpoutWriter($file_name);
+        $writer->setWidth([15, 15, 15, 15, 15, 15, 15, 15, 15, 15, 15, 15, 15]);
+        $writer->setHeader($header);
+        // $writer->setData($data, null);
+        $writer->setData($data, null, $filter);
+        $file_path = $writer->returnFile();
+        return response()->download($file_path, urlencode($file_name));
+    }
+
+    // 充值排行
+    public function getRechargeRankList($where): mixed
+    {
+      $orderBy = request()->input('orderBy', 'searchTotalMoney');
+      $orderType = request()->input('orderType', 'desc');
+      $page = request()->input('page', 1);
+      $limit = request()->input('limit', 10);
+
+      $params = $this->searchByAuth($where);
+
+      $tableName = 'sdk_order_success';
+
+      $rechargeRankQuery = Db::connect('db_game_log')
+          ->table($tableName)
+          ->where('pay_date', '>=', $params['pay_date'][0] . ' 00:00:00')
+          ->where('pay_date', '<=', $params['pay_date'][1] . ' 23:59:59');
+
+      if(!empty($params['game_id'])){
+        $rechargeRankQuery = $rechargeRankQuery->where('game_id', 'in', is_array($params['game_id']) ? implode(',', $params['game_id']) : $params['game_id']);
+      }
+      if(!empty($params['user_name'])){
+        $rechargeRankQuery = $rechargeRankQuery->where('user_name', $params['user_name']);
+      }
+      if(!empty($params['media_id'])){
+        $rechargeRankQuery = $rechargeRankQuery->where('media_id', $params['media_id']);
+      }
+      if(!empty($params['auth_id'])){
+        $rechargeRankQuery = $rechargeRankQuery->where('auth_id', $params['auth_id']);
+      }
+      if(!empty($params['agent_id'])){
+        $rechargeRankQuery = $rechargeRankQuery->where('agent_id', $params['agent_id']);
+      }
+      if(!empty($params['site_id'])){
+        $rechargeRankQuery = $rechargeRankQuery->where('site_id', $params['site_id']);
+      }
+      if(!empty($params['server_id'])){
+        $rechargeRankQuery = $rechargeRankQuery->where('server_id', $params['server_id']);
+      }
+      if(!empty($params['server_name'])){
+        $rechargeRankQuery = $rechargeRankQuery->where('server_name', $params['server_name']);
+      }
+      if(!empty($params['reg_date'])){
+        $rechargeRankQuery = $rechargeRankQuery
+        ->where('reg_date', '>=', $params['reg_date'][0] . ' 00:00:00')
+        ->where('reg_date', '<=', $params['reg_date'][1] . ' 23:59:59');
+      }
+
+      // 先选择字段，包括计算字段
+      $rechargeRankQuery->field('user_name,sum(money) as searchTotalMoney,
+            orderid,
+            game_id,
+            media_id,
+            agent_id,
+            site_id,
+            uid,
+            pay_channel_id,
+            auth_id,
+            server_id,
+            server_name,
+            pay_date,
+            reg_date,
+            role_name,
+            role_id');
+
+      $rechargeRankQuery->group('uid, game_id,site_id,server_id,media_id,auth_id,agent_id,server_id,auth_id,role_id');
+
+      $rechargeRankQuery->order($orderBy, $orderType);
+
+
+      $data = $rechargeRankQuery->paginate($limit, false, ['page' => $page])->toArray();
+
+
+      $data['data'] = $this->trandformListColumn($data['data'], ['game','auth', 'agent', 'pay_channel']);
+
+
+       // // 告警提示，查询最近登录时间，查询最近充值时间，和现在时间对比，如果超过3天，则告警，并提示
+
+      foreach($data['data'] as &$item){
+          // 最后登录时间
+          $item['login_time'] = Db::connect('db_origin')->table('user_'.$item['uid']%10)->where('uid', $item['uid'])->value('login_time');
+          // 最近注册时间
+          $item['pay_time'] = Db::connect('db_origin')->table('user_'.$item['uid']%10)->where('uid', $item['uid'])->value('pay_time');
+          // 现在时间
+          $item['now_time'] = time();
+
+          // 最近登录时间与现在时间对比，如果超过3天，则告警，并提示
+          if($item['login_time'] < $item['now_time'] - 3 * 24 * 60 * 60){
+          $item['login_alert'] = 1;
+          }else{
+          $item['login_alert'] = 0;
+          }
+          // 最近充值时间与现在时间对比，如果超过3天，则告警，并提示
+          if($item['pay_time'] < $item['now_time'] - 3 * 24 * 60 * 60){
+          $item['pay_alert'] = 1;
+          }else{
+          $item['pay_alert'] = 0;
+          }
+      }
+
+
+      $totalWhere = [];
+      if(!empty($params['game_id'])){
+            $totalWhere[] = ['game_id', 'in', is_array($params['game_id']) ? implode(',', $params['game_id']) : $params['game_id']];
+       }
+       if(!empty($where['auth_id'])){
+            $totalWhere[] = ['auth_id', 'in', is_array($params['auth_id']) ? implode(',', $params['auth_id']) : $params['auth_id']];
+       }
+       if(!empty($where['agent_id'])){
+            $totalWhere['agent_id'] = $params['agent_id'];
+       }
+       if(!empty($where['site_id'])){
+            $totalWhere['site_id'] = $params['site_id'];
+       }
+       if(!empty($where['server_id'])){
+            $totalWhere['server_id'] = $params['server_id'];
+       }
+       if(!empty($where['user_name'])){
+            $totalWhere['user_name'] = $params['user_name'];
+       }
+       if(!empty($where['server_name'])){
+            $totalWhere['server_name'] = $params['server_name'];
+       }
+       if(!empty($where['reg_date'])){
+            $totalWhere['reg_date'] = $params['reg_date'];
+       }
+
+      $totalList = Db::connect('db_game_log')->table('sdk_order_success')
+                  ->where($totalWhere)
+                  ->field('game_id,uid,sum(money) as totalMoney')
+                  ->group('uid,game_id,site_id,server_id,media_id,auth_id,agent_id,server_id,auth_id,role_id')
+                  ->select()->toArray();
+
+      
+      // 查询累计充值金额（对每一行数据单独查询历史充值金额）
+      $totalMoneyMap = [];
+      if (!empty($data['data']) && !empty($totalList)) {
+          foreach ($totalList as $totalItem) {
+              $key = $totalItem['uid'] . '_' . $totalItem['game_id'];
+              $totalMoneyMap[$key] = $totalItem['totalMoney'] ?? 0;
+          }
+      }
+      
+      // 为搜索结果添加累计充值金额
+      foreach($data['data'] as &$item){
+          $key = $item['uid'] . '_' . $item['game_id'];
+          $item['totalMoney'] = $totalMoneyMap[$key] ?? 0;
+      }
+
+      return $data;
+    }
+
+    // 角色数据
+
+
+    public function getRoleDataList($where): mixed
+    {
+      $orderBy = request()->input('orderBy', 'reg_time');
+      $orderType = request()->input('orderType', 'desc');
+      $page = request()->input('page', 1);
+      $limit = request()->input('limit', 10);
+
+      $params = $this->searchByAuth($where);
+      $regTime = $params['reg_time'];
+
+
+      $egTableName = 'sdk_reg_log_' . date('Ym', strtotime($regTime));
+
+
+      $userData = Db::connect('db_game_log')->table($egTableName)->where('reg_time', '>=', strtotime($regTime . ' 00:00:00'))->where('reg_time', '<=', strtotime($regTime . ' 23:59:59'))->select()->toArray();
+
+      $where_sql = "";
+      if(!empty($params['game_id'])){
+          $where_sql .= is_array($params['game_id']) ? " AND game_id in (".implode(',', $params['game_id']).")" : " AND game_id = {$params['game_id']}";
+      }
+
+      if(!empty($params['media_id'])){
+          $where_sql .= " AND media_id = {$params['media_id']}";
+      }
+
+      if(!empty($params['site_id'])){
+          $where_sql .= " AND site_id = {$params['site_id']}";
+      }
+
+      if(!empty($params['auth_id'])){
+          $where_sql .= " AND auth_id = {$params['auth_id']}";
+      }
+
+      if(!empty($params['user_name'])){
+          $where_sql .= " AND user_name = {$params['user_name']}";
+      }
+
+
+
+      $uids = array_column($userData, 'uid');
+
+  
+      if(empty($userData)){
+          return [];
+      }
+      
+      $where_sql = " AND uid in (".implode(',', $uids).") {$where_sql}";
+      
+
+      $sql_parts = [];
+      $sql_parts[] = "SELECT * FROM role_data_and WHERE 1=1 {$where_sql}";
+      $sql_parts[] = "SELECT * FROM role_data_ios WHERE 1=1 {$where_sql}";
+
+
+
+      $unionSql = implode(" UNION ALL ", $sql_parts);
+
+      // 分页
+       
+        $offset = ($page - 1) * $limit;
+        $unionSql .= " LIMIT {$offset}, {$limit}";
+        $roleData = Db::connect('db_game_log')->query($unionSql);
+
+        // 合并相同uid的数据，将角色信息放到数组中
+        $mergedData = [];
+        foreach ($roleData as $item) {
+            $uid = $item['uid'];
+            
+            if (!isset($mergedData[$uid])) {
+                // 创建用户基础信息，排除角色相关字段
+                $baseInfo = array_diff_key($item, array_flip(['role_id', 'role_name', 'role_level']));
+                $mergedData[$uid] = $baseInfo + ['roles' => []];
+            }
+            
+            // 添加角色信息到数组
+            $mergedData[$uid]['roles'][] = [
+                'server_name' => $item['server_name'],
+                'role_name' => $item['role_name'],
+                'role_level' => $item['role_level'],
+            ];
+        }
+        
+        // 转换回数组格式
+        $roleData = array_values($mergedData);
+        $roleData = $this->trandformListColumn($roleData, ['game', 'ip', 'auth', 'agent']);
+        $count = count($roleData);
+
+        return [
+            'data'          => $roleData,
+            'current_page'  => $page,
+            'per_page'      => $limit,
+            'last_page'     => ceil($count / $limit),
+            'has_more'      => $page < ceil($count / $limit),
+            'total'         =>  $count
+        ];
+
+    }
+
+}

plugin/saiadmin/basic/BaseLogic.php

@@ -232,8 +232,9 @@ class BaseLogic
         }
   
         // return $data;
-        print_r($data);
-         return $this->model->withSearch($withSearch, $data);
+        // print_r($data);
+        //  return $this->model->withSearch($withSearch, $data);
+        return $data;
     }