AutoStatisticsNodeDailyTraffic.php 1.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455
  1. <?php
  2. namespace App\Console\Commands;
  3. use App\Models\Node;
  4. use App\Models\NodeDailyDataFlow;
  5. use App\Models\UserDataFlowLog;
  6. use Illuminate\Console\Command;
  7. use Log;
  8. class AutoStatisticsNodeDailyTraffic extends Command
  9. {
  10. protected $signature = 'autoStatisticsNodeDailyTraffic';
  11. protected $description = '自动统计节点每日流量';
  12. public function handle(): void
  13. {
  14. $jobStartTime = microtime(true);
  15. foreach (Node::whereStatus(1)->orderBy('id')->get() as $node) {
  16. $this->statisticsByNode($node->id);
  17. }
  18. $jobEndTime = microtime(true);
  19. $jobUsedTime = round(($jobEndTime - $jobStartTime), 4);
  20. Log::info(
  21. '---【' . $this->description . '】完成---,耗时' . $jobUsedTime . '秒'
  22. );
  23. }
  24. private function statisticsByNode($node_id): void
  25. {
  26. $query = UserDataFlowLog::whereNodeId($node_id)->whereBetween(
  27. 'log_time',
  28. [strtotime(date('Y-m-d')), time()]
  29. );
  30. $u = $query->sum('u');
  31. $d = $query->sum('d');
  32. $total = $u + $d;
  33. if ($total) { // 有数据才记录
  34. $obj = new NodeDailyDataFlow();
  35. $obj->node_id = $node_id;
  36. $obj->u = $u;
  37. $obj->d = $d;
  38. $obj->total = $total;
  39. $obj->traffic = flowAutoShow($total);
  40. $obj->save();
  41. }
  42. }
  43. }