dms-api/app/v1/logic/dataReport/UserLogLogic.php

<?php

// 玩家日志逻

namespace app\v1\logic\dataReport;

use plugin\saiadmin\exception\ApiException;
use plugin\saiadmin\basic\BaseLogic;
use plugin\saiadmin\service\OpenSpoutWriter;
use support\think\Db;

class UserLogLogic extends BaseLogic
{

    // 注册日志
    public function getRegLogList($params): mixed
    {
        $orderBy = request()->input('orderBy', 'reg_time');
        $orderType = request()->input('orderType', 'desc');
        $params = $this->searchByAuth($params);
        $limit = request()->input('limit', 10);

        // 检查注册时间只能查询3个月内
        if (empty($params['reg_time']) || count($params['reg_time']) != 2) {
            throw new ApiException('请选择注册时间范围');
        }
        $startTime = strtotime($params['reg_time'][0]);
        $endTime = strtotime($params['reg_time'][1]);
        if ($endTime < $startTime) {
            throw new ApiException('注册时间范围不正确');
        }
        // 计算时间差，限制为3个月（90天）内
        $maxDays = 90;
        if (($endTime - $startTime) > ($maxDays * 86400)) {
            throw new ApiException('注册时间只能查询3个月内');
        }


        // 公共处理完的where， 自然量ID, auth_id=0为自然量
        $whereRaw = $this->getCommonWhereRaw($params);
        $monthRange = getMonthRange($params['reg_time'][0], $params['reg_time'][1]);

        $db = Db::connect('db_game_log');
        $unionQuery = [];
        foreach ($monthRange as $month){
            $tableName = 'sdk_reg_log_' . $month;
            $unionQuery[] = $db->table($tableName)->whereRaw(where: $whereRaw)->buildSql();
        }
        $fullSql = "(" . implode(' UNION ALL ', $unionQuery) . ") as unTable";

        return $db->table($fullSql)->order($orderBy, $orderType)->paginate($limit)->toArray();
    }

    // 登录日志
    public function getLoginLogList($params): 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($params);


         // 检查注册时间只能查询3个月内
        if (empty($params['login_time']) || count($params['login_time']) != 2) {
            throw new ApiException('请选择登录时间范围');
        }
        $startTime = strtotime($params['login_time'][0]);
        $endTime = strtotime($params['login_time'][1]);
        if ($endTime < $startTime) {
            throw new ApiException('登录时间范围不正确');
        }
        // 计算时间差，限制为3个月（90天）内
        $maxDays = 90;
        if (($endTime - $startTime) > ($maxDays * 86400)) {
            throw new ApiException('登录时间只能查询3个月内');
        }

        // 检查登录时间只能查询3个月内
        if(!empty($params['reg_time'])){
            $startTime = strtotime($params['reg_time'][0]);
            $endTime = strtotime($params['reg_time'][1]);
            if ($endTime < $startTime) {
                throw new ApiException('注册时间范围不正确');
            }
            // 计算时间差，限制为3个月（90天）内
            $maxDays = 90;
            if (($endTime - $startTime) > ($maxDays * 86400)) {
                throw new ApiException('注册时间只能查询3个月内');
            }
        }

         // 公共处理完的where， 自然量ID, auth_id=0为自然量
        $whereRaw = $this->getCommonWhereRaw($params);
        $monthRange = getMonthRange($params['login_time'][0], $params['login_time'][1]);

        $db = Db::connect('db_game_log');
        $unionQuery = [];
        foreach ($monthRange as $month){
            $tableName = 'sdk_login_log_' . $month;
            $unionQuery[] = $db->table($tableName)->whereRaw(where: $whereRaw)->buildSql();
        }
        $fullSql = "(" . implode(' UNION ALL ', $unionQuery) . ") as unTable";

        return $db->table($fullSql)->order($orderBy, $orderType)->paginate($limit)->toArray();
    }

    // 充值明细
    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， 自然量ID, auth_id=0为自然量
        $whereRaw = $this->getCommonWhereRaw($params);

        $rechargeDetailQuery = $rechargeDetailQuery->whereRaw($whereRaw);

        $rechargeDetailQuery->order($orderBy, $orderType);

        if ($type == 'all') {
            $data = $rechargeDetailQuery->select()->toArray();
        } else {
            $data = $rechargeDetailQuery->paginate($limit)->toArray();
        }

        return $data;
    }

    // 充值明细导出
    public function exportRechargeDetailList($where): mixed
    {
        $data = $this->getRechargeDetailList($where, 'all');

        $data = $this->trandformListColumn($data, ['game', 'ip', 'agent', 'auth', 'pay_channel']);
        $data = array_map(function ($item) {
            return [
                'order_id' => $item['order_id'],
                '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, $filter);
        $file_path = $writer->returnFile();
        return response()->download($file_path, urlencode($file_name));
    }

    // 充值排行
    public function getRechargeRankList($params): mixed
    {
        $orderBy = request()->input('orderBy', 'searchTotalMoney');
        $orderType = request()->input('orderType', 'desc');
        $page = request()->input('page', 1);
        $limit = request()->input('limit', 10);

        $params = $this->searchByAuth($params);

        $tableName = 'sdk_order_success';

        $rechargeRankQuery = Db::connect('db_game_log')->table($tableName);

        // 公共处理完的where， 自然量ID, auth_id=0为自然量
        $whereRaw = $this->getCommonWhereRaw($params);

        $rechargeRankQuery = $rechargeRankQuery->whereRaw($whereRaw);

        // 先选择字段，包括计算字段
        $rechargeRankQuery->field('user_name,sum(money) as searchTotalMoney,
            order_id,
            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)->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 * 86400) {
                $item['login_alert'] = 1;
            } else {
                $item['login_alert'] = 0;
            }
            // 最近充值时间与现在时间对比，如果超过3天，则告警，并提示
            if ($item['pay_time'] < $item['now_time'] - 3 * 86400) {
                $item['pay_alert'] = 1;
            } else {
                $item['pay_alert'] = 0;
            }
        }

        $totalList = Db::connect('db_game_log')->table('sdk_order_success')
            ->whereRaw($whereRaw)
            ->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($params): mixed
    {
        $page = request()->input('page', 1);
        $limit = request()->input('limit', 10);
        $orderBy = request()->input('orderBy', 'create_time');
        $orderType = request()->input('orderType', 'desc');

        $params = $this->searchByAuth($params);

        // 公共处理完的where， 自然量ID, auth_id=0为自然量
        $whereRaw = $this->getCommonWhereRaw($params);
        $tables = ['role_data_and', 'role_data_ios'];

        $db = Db::connect('db_game_log');
        $unionQuery = [];
        foreach ($tables as $tableName){
            $unionQuery[] = $db->table($tableName)->whereRaw(where: $whereRaw)->buildSql();
        }
        $fullSql = "(" . implode(' UNION ALL ', $unionQuery) . ") as unTable";

        return $db->table($fullSql)->order($orderBy, $orderType)->paginate($limit)->toArray();
    }
}