neiyou_user_web/app/Console/Commands/UserTrafficAbnormalAutoWarning.php

<?php

namespace App\Console\Commands;

use App\Components\PushNotification;
use App\Models\UserHourlyDataFlow;
use Illuminate\Console\Command;
use Log;

class UserTrafficAbnormalAutoWarning extends Command
{

    protected $signature = 'userTrafficAbnormalAutoWarning';
    protected $description = '用户流量异常警告';

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

        // 用户流量异常警告
        $this->userTrafficAbnormalWarning();

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

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

    // 用户流量异常警告
    private function userTrafficAbnormalWarning(): void
    {
        // 1小时内流量异常用户(多往前取5分钟，防止数据统计任务执行时间过长导致没有数据)
        $userTotalTrafficLogs = UserHourlyDataFlow::whereNodeId(0)
                                                  ->where('total', '>', MB * 50)
                                                  ->where(
                                                      'created_at',
                                                      '>=',
                                                      date(
                                                          'Y-m-d H:i:s',
                                                          time() - 3900
                                                      )
                                                  )
                                                  ->groupBy('user_id')
                                                  ->selectRaw(
                                                      "user_id, sum(total) as totalTraffic"
                                                  )
                                                  ->get(
                                                  ); // 只统计100M以上的记录，加快查询速度
        $trafficBanValue      = sysConfig('traffic_ban_value');

        foreach ($userTotalTrafficLogs->load('user') as $log) {
            // 推送通知管理员
            if ($log->totalTraffic > $trafficBanValue * GB) {
                $user    = $log->user;
                $traffic = UserHourlyDataFlow::userRecentUsed($user->id)
                                             ->selectRaw(
                                                 "user_id, sum(`u`) as totalU, sum(`d`) as totalD, sum(total) as totalTraffic"
                                             )
                                             ->first();

                PushNotification::send(
                    "流量异常用户提醒",
                    "用户**{$user->email}(ID:{$user->id})**，最近1小时**上行流量：" . flowAutoShow(
                        $traffic->totalU
                    ) . "，下行流量：" . flowAutoShow(
                        $traffic->totalD
                    ) . "，共计：" . flowAutoShow($traffic->totalTraffic) . "**。"
                );
            }
        }
    }

}