UserTrafficAbnormalAutoWarning.php 2.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950
  1. <?php
  2. namespace App\Console\Commands;
  3. use App\Components\PushNotification;
  4. use App\Models\UserHourlyDataFlow;
  5. use Illuminate\Console\Command;
  6. use Log;
  7. class UserTrafficAbnormalAutoWarning extends Command {
  8. protected $signature = 'userTrafficAbnormalAutoWarning';
  9. protected $description = '用户流量异常警告';
  10. public function handle(): void {
  11. $jobStartTime = microtime(true);
  12. // 用户流量异常警告
  13. $this->userTrafficAbnormalWarning();
  14. $jobEndTime = microtime(true);
  15. $jobUsedTime = round(($jobEndTime - $jobStartTime), 4);
  16. Log::info('---【'.$this->description.'】完成---,耗时'.$jobUsedTime.'秒');
  17. }
  18. // 用户流量异常警告
  19. private function userTrafficAbnormalWarning(): void {
  20. // 1小时内流量异常用户(多往前取5分钟,防止数据统计任务执行时间过长导致没有数据)
  21. $userTotalTrafficLogs = UserHourlyDataFlow::whereNodeId(0)
  22. ->where('total', '>', MB * 50)
  23. ->where('created_at', '>=', date('Y-m-d H:i:s', time() - 3900))
  24. ->groupBy('user_id')
  25. ->selectRaw("user_id, sum(total) as totalTraffic")
  26. ->get(); // 只统计100M以上的记录,加快查询速度
  27. $trafficBanValue = sysConfig('traffic_ban_value');
  28. foreach($userTotalTrafficLogs->load('user') as $log){
  29. // 推送通知管理员
  30. if($log->totalTraffic > $trafficBanValue * GB){
  31. $user = $log->user;
  32. $traffic = UserHourlyDataFlow::userRecentUsed($user->id)
  33. ->selectRaw("user_id, sum(`u`) as totalU, sum(`d`) as totalD, sum(total) as totalTraffic")
  34. ->first();
  35. PushNotification::send("流量异常用户提醒",
  36. "用户**{$user->email}(ID:{$user->id})**,最近1小时**上行流量:".flowAutoShow($traffic->totalU).",下行流量:".flowAutoShow($traffic->totalD).",共计:".flowAutoShow($traffic->totalTraffic)."**。");
  37. }
  38. }
  39. }
  40. }