dms-api/app/v1/logic/tool/BasicActiveDayLogic.php

<?php

namespace app\v1\logic\tool;


use support\think\Db;

class BasicActiveDayLogic extends BaseLogic
{
    protected string $table = "basic_active_day";

    protected string $group = 'game_id, agent_id, site_id, tdate, active';

    protected array $data;

    protected string $date;
    public function run($params=[])
    {
        if(!empty($params['date'])){
            $sDate = is_array($params['date']) ? $params['date'][0] : $params['date'];
            $eDate = is_array($params['date']) ? $params['date'][1] : $params['date'];
        }else{
            $sDate = date('Y-m-d');
            $eDate = date('Y-m-d');
        }

        for ($date = $sDate; $date <= $eDate; $date = date('Y-m-d', strtotime($date . '+1 day'))){
            $this->date = $date;
            $this->table = $this->table . "_" . date('Y', strtotime($this->date));

            try {
                $this->initStart();
            }catch (\Exception $e){
                return json_encode(["status"=>"error", "msg"=>$e->getMessage()], 256);
            }
        }

        $this->reRun();

        return json_encode(["status"=>"success", "msg"=>""], 256);
    }

    // 重跑
    protected function reRun(): void
    {
        $day = date('d');
        $hour = date('H');
        $i = date('i');
        $t = date('t');

        // 月末，重跑整月
        if($day==$t){
            if($hour==1 && $i<10){
                for ($d=1; $d<=$t; $d++){
                    $this->date = date('Y-m-d', strtotime("-{$d} day"));
                    $this->initStart();
                }
            }
        }else{
            // 重跑前3天
            if($hour==8 && $i<10){
                for ($d=1; $d<=3; $d++){
                    $this->date = date('Y-m-d', strtotime("-{$d} day"));
                    $this->initStart();
                }
            }
        }
    }

    protected function initStart(): void
    {
        // 重置数据
        $this->data = [];

        $this->loginTotalByGame();

        $this->replaceData(['tdate'=>$this->date]);
    }

    protected function loginTotalByGame()
    {
        $table = "sdk_active_log_" . date('Ym', strtotime($this->date));
        $filed = "game_id, agent_id, site_id, {$this->date} as tdate, active, count(distinct uid) as login_count";

        $where = [
            'tdate' => $this->date,
        ];
        $result = Db::connect('db_game_log')->table($table)->field($filed)->where($where)->group($this->group)->select()->toArray();

        if($result) foreach ($result as &$vv){
            $vv['reg_date'] = date('Y-m-d', strtotime("{$this->date} -{$vv['days']}days"));
        }

        $this->pushData($result);
    }
}