ProxyPanel/app/Console/Commands/UserHourlyTrafficMonitoring.php

<?php

namespace App\Console\Commands;

use App\Models\User;
use App\Notifications\DataAnomaly;
use Illuminate\Console\Command;
use Log;
use Notification;

class UserHourlyTrafficMonitoring extends Command
{
    protected $signature = 'userHourlyTrafficMonitoring';
    protected $description = '用户每小时流量监控';
    private $data_anomaly_notification;
    private $traffic_ban_value;

    public function handle()
    {
        $jobTime = microtime(true);
        $this->data_anomaly_notification = sysConfig('data_anomaly_notification');
        $this->traffic_ban_value = sysConfig('traffic_ban_value') * GB;

        User::activeUser()->with('dataFlowLogs')->WhereHas('dataFlowLogs')->chunk(config('tasks.chunk'), function ($users) {
            foreach ($users as $user) {
                $this->statisticsByUser($user);
            }
        });

        $jobTime = round((microtime(true) - $jobTime), 4);

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

    private function statisticsByUser(User $user)
    {
        $created_at = date('Y-m-d H:59:59', strtotime('-1 hour'));
        $time = strtotime($created_at);
        $logs = $user->dataFlowLogs()
            ->whereBetween('log_time', [$time - 3599, $time])
            ->groupBy('node_id')
            ->selectRaw('node_id, sum(`u`) as u, sum(`d`) as d')
            ->get();

        if ($logs->isNotEmpty()) { // 有数据才记录
            $data = $logs->each(function ($log) use ($created_at) {
                $log->total = $log->u + $log->d;
                $log->traffic = flowAutoShow($log->total);
                $log->created_at = $created_at;
            })->flatten()->toArray();

            $data[] = [ // 每小时节点流量合计
                'u'          => $logs->sum('u'),
                'd'          => $logs->sum('d'),
                'total'      => $logs->sum('total'),
                'traffic'    => flowAutoShow($logs->sum('total')),
                'created_at' => $created_at,
            ];

            $user->hourlyDataFlows()->createMany($data);

            if ($this->data_anomaly_notification) { // 用户流量异常警告
                $traffic = $user->hourlyDataFlows()->whereNodeId(null)->latest()->first();
                if ($traffic->total >= $this->traffic_ban_value) {
                    Notification::send(User::find(1), new DataAnomaly($user->username, flowAutoShow($traffic->u), flowAutoShow($traffic->d), flowAutoShow($traffic->traffic)));
                }
            }
        }
    }
}