AutoBanUserJob.php 1.9 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061
  1. <?php
  2. namespace App\Console\Commands;
  3. use Illuminate\Console\Command;
  4. use App\Http\Models\Config;
  5. use App\Http\Models\UserBanLog;
  6. use App\Http\Models\User;
  7. use App\Http\Models\UserTrafficHourly;
  8. use Log;
  9. class AutoBanUserJob extends Command
  10. {
  11. protected $signature = 'command:autoBanUserJob';
  12. protected $description = '自动封禁用户';
  13. protected static $config;
  14. public function __construct()
  15. {
  16. parent::__construct();
  17. $config = Config::query()->get();
  18. $data = [];
  19. foreach ($config as $vo) {
  20. $data[$vo->name] = $vo->value;
  21. }
  22. self::$config = $data;
  23. }
  24. public function handle()
  25. {
  26. // 封禁24小时内流量异常账号
  27. if (self::$config['is_traffic_ban']) {
  28. $userList = User::query()->where('status', '>=', 0)->where('enable', 1)->get();
  29. foreach ($userList as $user) {
  30. $time = date('Y-m-d H:i:s', time() - 24 * 60 * 60);
  31. $totalTraffic = UserTrafficHourly::query()->where('user_id', $user->id)->where('node_id', 0)->where('created_at', '>=', $time)->sum('total');
  32. if ($totalTraffic >= (self::$config['traffic_ban_value'] * 1024 * 1024 * 1024)) {
  33. $ban_time = date('Y-m-d H:i:s', strtotime("+" . self::$config['traffic_ban_time'] . " minutes"));
  34. User::query()->where('id', $user->id)->update(['enable' => 0, 'ban_time' => $ban_time]);
  35. // 写入日志
  36. $this->log($user->id, self::$config['traffic_ban_time'], '【自动封禁】-流量异常');
  37. }
  38. }
  39. }
  40. Log::info('定时任务:' . $this->description);
  41. }
  42. private function log($user_id, $minutes, $desc)
  43. {
  44. $log = new UserBanLog();
  45. $log->user_id = $user_id;
  46. $log->minutes = $minutes;
  47. $log->desc = $desc;
  48. $log->save();
  49. }
  50. }