AutoClearLogs.php 3.8 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394
  1. <?php
  2. namespace App\Console\Commands;
  3. use App\Models\NodeDailyDataFlow;
  4. use App\Models\NodeHeartbeat;
  5. use App\Models\NodeHourlyDataFlow;
  6. use App\Models\NodeOnlineIp;
  7. use App\Models\NodeOnlineLog;
  8. use App\Models\NotificationLog;
  9. use App\Models\Payment;
  10. use App\Models\RuleLog;
  11. use App\Models\UserBanedLog;
  12. use App\Models\UserDailyDataFlow;
  13. use App\Models\UserDataFlowLog;
  14. use App\Models\UserHourlyDataFlow;
  15. use App\Models\UserLoginLog;
  16. use App\Models\UserSubscribeLog;
  17. use Exception;
  18. use Illuminate\Console\Command;
  19. use Log;
  20. class AutoClearLogs extends Command
  21. {
  22. protected $signature = 'autoClearLogs';
  23. protected $description = '自动清除日志';
  24. public function handle()
  25. {
  26. $jobTime = microtime(true);
  27. // 清除日志
  28. if (sysConfig('is_clear_log')) {
  29. $this->clearLog();
  30. }
  31. $jobTime = round((microtime(true) - $jobTime), 4);
  32. Log::info('---【'.$this->description.'】完成---,耗时'.$jobTime.'秒');
  33. }
  34. // 清除日志
  35. private function clearLog()
  36. {
  37. try {
  38. // 清除节点每天流量数据日志
  39. NodeDailyDataFlow::where('created_at', '<=', date('Y-m-d H:i:s', strtotime(config('tasks.clean.node_daily_logs'))))->delete();
  40. // 清除节点每小时流量数据日志
  41. NodeHourlyDataFlow::where('created_at', '<=', date('Y-m-d H:i:s', strtotime(config('tasks.clean.node_hourly_logs'))))->delete();
  42. // 清理通知日志
  43. NotificationLog::where('updated_at', '<=', date('Y-m-d H:i:s', strtotime(config('tasks.clean.notification_logs'))))->delete();
  44. // 清除节点负载信息日志
  45. NodeHeartbeat::where('log_time', '<=', strtotime(config('tasks.clean.node_heartbeats')))->delete();
  46. // 清除节点在线用户数日志
  47. NodeOnlineLog::where('log_time', '<=', strtotime(config('tasks.clean.node_online_logs')))->delete();
  48. // 清理在线支付日志
  49. Payment::where('created_at', '<=', date('Y-m-d H:i:s', strtotime(config('tasks.clean.payments'))))->delete();
  50. // 清理审计触发日志
  51. RuleLog::where('created_at', '<=', date('Y-m-d H:i:s', strtotime(config('tasks.clean.rule_logs'))))->delete();
  52. // 清除用户连接IP
  53. NodeOnlineIp::where('created_at', '<=', strtotime(config('tasks.clean.node_online_ips')))->delete();
  54. // 清除用户封禁日志
  55. UserBanedLog::where('created_at', '<=', date('Y-m-d H:i:s', strtotime(config('tasks.clean.user_baned_logs'))))->delete();
  56. // 清除用户各节点 / 节点总计的每天流量数据日志
  57. UserDailyDataFlow::where('node_id', '<>', null)
  58. ->where('created_at', '<=', date('Y-m-d H:i:s', strtotime(config('tasks.clean.user_daily_logs_nodes'))))
  59. ->orWhere('created_at', '<=', date('Y-m-d H:i:s', strtotime(config('tasks.clean.user_daily_logs_total'))))
  60. ->delete();
  61. // 清除用户每时各流量数据日志
  62. UserHourlyDataFlow::where('created_at', '<=', date('Y-m-d H:i:s', strtotime(config('tasks.clean.user_hourly_logs'))))->delete();
  63. // 清除用户登陆日志
  64. UserLoginLog::where('created_at', '<=', date('Y-m-d H:i:s', strtotime(config('tasks.clean.login_logs'))))->delete(); // 清除用户订阅记录
  65. // 清理用户订阅请求日志
  66. UserSubscribeLog::where('request_time', '<=', date('Y-m-d H:i:s', strtotime(config('tasks.clean.subscribe_logs'))))->delete();
  67. // 清除用户流量日志
  68. UserDataFlowLog::where('log_time', '<=', strtotime(config('tasks.clean.traffic_logs')))->delete();
  69. } catch (Exception $e) {
  70. Log::error('【清理日志】错误: '.$e->getMessage());
  71. }
  72. }
  73. }