new_sdk_wu/www/new_sdk/application/crontab/ComplexSummaryGame.php

<?php

namespace app\crontab;

use app\service\ComplexSummaryService;
use app\service\RetaineService;
use think\console\Command;
use think\console\Input;
use think\console\Output;
use think\console\Input\Argument;
use think\Db;
use think\Exception;

/**
 * 聚合-游戏数据汇总-统计脚本
 * 统计游戏数据汇总
 */
class ComplexSummaryGame extends Command
{
    protected function configure()
    {
        $this->setName('ComplexSummaryGame')
            ->setDescription('聚合-游戏数据汇总-统计脚本')
            ->addArgument('day', Argument::OPTIONAL, '统计日期，格式：Y-m-d，默认为昨天');
    }

    protected function execute(Input $input, Output $output)
    {
        $service = new ComplexSummaryService();

        // 获取统计日期（默认昨天）
        $day = $input->getArgument('day') ?: date('Y-m-d', strtotime('-1 day'));

        $output->writeln(date('Y-m-d H:i:s') . " 开始统计日期: {$day}");

        $gameIds = $service->getOnlineGameIds();
        try {
            // 1. 获取新增玩家数据
            $regNumList = $service->getRegNum($day, $gameIds, 0);
            $output->writeln("新增玩家统计完成: " . count($regNumList) . " 条");

            // 2. 获取新增角色数据
            $regRoleNumList = $service->getRegRoleNum($day, $gameIds, 0, 0);
            $output->writeln("新增角色统计完成: " . count($regRoleNumList) . " 条");

            // 3. 获取 充值金额、实付金额 和 付费人数
            $payMoneyList = $service->getPayMoney($day, $gameIds, 0, 0);
            $output->writeln("充值金额统计完成: " . count($payMoneyList) . " 条");

            // 4. 获取活跃玩家（使用玩家活跃日志表）
            $activeUserList = $service->getActiveUserByActiveLog($day, $gameIds, 0, 0);
            $output->writeln("活跃玩家统计完成: " . count($activeUserList) . " 条");
            
            // // 5. 获取付费人数
            // $payUserNumList = $service->getPayUserNum($day, $gameIds, 0);
            // $output->writeln("付费人数统计完成: " . count($payUserNumList) . " 条");

            // 6. 合并所有统计数据
            $allStats = $service->mergeStatsData([
                $regNumList,
                $regRoleNumList,
                $payMoneyList,
                $activeUserList
                // ,
                // $payUserNumList
            ]);

            // 7. 计算ARPU和ARPPU，并保存数据
            // 先清空当天日期的数据，避免重新抓取时数据错乱（在事务外执行，确保清空操作生效）
            Db::table('cy_complex_summary_game')
                ->where('day', $day)
                ->delete();
            
            // Db::startTrans();
            try {
                foreach ($allStats as $stat) {
                    $gameId = $stat['game_id'] ?? 0;
                    // $complexId = $stat['channel_id'] ?? 0;
                    // 渠道数量
                    $complexNum = model('common/PolychannelGame')->where('game_id', $gameId)->count();

                    // 计算ARPU和ARPPU
                    $payMoney = floatval($stat['pay_money'] ?? 0);
                    $pay_amount = floatval($stat['pay_amount_total'] ?? 0);
                    $activeUserNum = intval($stat['active_user_num'] ?? 0);
                    $payUserNum = intval($stat['pay_user_num'] ?? 0);

                    $arpu = $activeUserNum > 0 ? round($pay_amount / $activeUserNum, 2)*100 : 0;
                    $arppu = $payUserNum > 0 ? round($pay_amount / $payUserNum, 2)*100 : 0;
                    
                    // 准备保存的数据
                    $saveData = [
                        'day' => $day,
                        'game_id' => $gameId,
                        'complex_num' => $complexNum,
                        'reg_num' => intval($stat['reg_num'] ?? 0),
                        'reg_role_num' => intval($stat['reg_role_num'] ?? 0),
                        'pay_money' => $payMoney,
                        'pay_amount' => $pay_amount,
                        'active_user_num' => $activeUserNum,
                        'pay_user_num' => $payUserNum,
                        'arpu' => $arpu,
                        'arppu' => $arppu,
                    ];
                    // dump($saveData);

                    // 直接插入（已清空当天数据，无需检查是否存在）
                    Db::table('cy_complex_summary_game')->insert($saveData);
                    
                    // 以下代码已注释，防止以后需要时可以恢复
                    // // 检查记录是否存在
                    // $exists = Db::table('cy_complex_summary_game')
                    //     ->where([
                    //         'day' => $day,
                    //         'game_id' => $gameId,
                    //     ])
                    //     ->find();
                    // 
                    // if ($exists) {
                    //     // 更新
                    //     Db::table('cy_complex_summary_game')
                    //         ->where(['id' => $exists['id']])
                    //         ->update($saveData);
                    // } else {
                    //     // 插入
                    //     Db::table('cy_complex_summary_game')->insert($saveData);
                    // }
                }
                
                Db::commit();
                $output->writeln("数据保存成功，共处理 " . count($allStats) . " 条记录");
                
            } catch (Exception $e) {
                Db::rollback();
                $output->writeln("保存数据失败: " . $e->getMessage());
                throw $e;
            }
            
        } catch (Exception $e) {
            $output->writeln("统计失败: " . $e->getMessage() . ' - ' . $e->getFile() . ":" . $e->getLine());
            throw $e;
        }
        
        $output->writeln(date('Y-m-d H:i:s') . " 统计完成");
    }
}