userTrafficAbnormalWarning(); $jobEndTime = microtime(true); $jobUsedTime = round(($jobEndTime - $jobStartTime), 4); Log::info('执行定时任务【' . $this->description . '】,耗时' . $jobUsedTime . '秒'); } // 用户流量异常警告 private function userTrafficAbnormalWarning() { // 1小时内流量异常用户(多往前取5分钟,防止数据统计任务执行时间过长导致没有数据) $userTotalTrafficList = UserTrafficHourly::query()->where('node_id', 0)->where('total', '>', 104857600)->where('created_at', '>=', date('Y-m-d H:i:s', time() - 3900))->groupBy('user_id')->selectRaw("user_id, sum(total) as totalTraffic")->get(); // 只统计100M以上的记录,加快查询速度 if (!$userTotalTrafficList->isEmpty()) { $title = "流量异常用户提醒"; foreach ($userTotalTrafficList as $vo) { $user = User::query()->where('id', $vo->user_id)->first(); // 通过ServerChan发微信消息提醒管理员 if ($vo->totalTraffic > (self::$systemConfig['traffic_ban_value'] * 1073741824)) { $traffic = UserTrafficHourly::query()->where('node_id', 0)->where('user_id', $vo->user_id)->where('created_at', '>=', date('Y-m-d H:i:s', time() - 3900))->selectRaw("user_id, sum(`u`) as totalU, sum(`d`) as totalD, sum(total) as totalTraffic")->first(); $content = "用户**{$user->username}(ID:{$user->id})**,最近1小时**上行流量:" . flowAutoShow($traffic->totalU) . ",下行流量:" . flowAutoShow($traffic->totalD) . ",共计:" . flowAutoShow($traffic->totalTraffic) . "**。"; ServerChan::send($title, $content); } } } } }