neiyou_user_web/app/Console/Commands/AutoStatisticsUserHourlyTraffic.php

<?php

namespace App\Console\Commands;

use App\Models\Node;
use App\Models\User;
use App\Models\UserDataFlowLog;
use App\Models\UserHourlyDataFlow;
use Illuminate\Console\Command;
use Log;

class AutoStatisticsUserHourlyTraffic extends Command
{
    protected $signature = 'autoStatisticsUserHourlyTraffic';
    protected $description = '自动统计用户每小时流量';

    public function handle(): void
    {
        $jobStartTime = microtime(true);

        foreach (User::activeUser()->get() as $user) {
            // 统计一次所有节点的总和
            $this->statisticsByNode($user->id);

            // 统计每个节点产生的流量
            foreach (Node::whereStatus(1)->orderBy('id')->get() as $node) {
                $this->statisticsByNode($user->id, $node->id);
            }
        }

        $jobEndTime = microtime(true);
        $jobUsedTime = round(($jobEndTime - $jobStartTime), 4);

        Log::info('---【'.$this->description.'】完成---，耗时'.$jobUsedTime.'秒');
    }

    private function statisticsByNode($user_id, $node_id = 0): void
    {
        $query = UserDataFlowLog::whereUserId($user_id)->whereBetween('log_time', [strtotime("-1 hour"), time()]);

        if ($node_id) {
            $query->whereNodeId($node_id);
        }

        $u = $query->sum('u');
        $d = $query->sum('d');
        $total = $u + $d;

        if ($total) { // 有数据才记录
            $obj = new UserHourlyDataFlow();
            $obj->user_id = $user_id;
            $obj->node_id = $node_id;
            $obj->u = $u;
            $obj->d = $d;
            $obj->total = $total;
            $obj->traffic = flowAutoShow($total);
            $obj->save();
        }
    }
}