fixDailyTrafficLogError.php 4.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101
  1. <?php
  2. namespace App\Console\Commands;
  3. use App\Models\NodeDailyDataFlow;
  4. use App\Models\UserDailyDataFlow;
  5. use App\Models\UserDataFlowLog;
  6. use Illuminate\Console\Command;
  7. use Log;
  8. class fixDailyTrafficLogError extends Command
  9. {
  10. protected $signature = 'fixDailyTrafficLogError';
  11. protected $description = '修复原版本的每日流量计算错误';
  12. private $end;
  13. public function handle(): void
  14. {
  15. // set value
  16. $this->end = date('Y-m-d 23:59:59', strtotime("-1 days"));
  17. $nodeArray = UserDataFlowLog::distinct()->pluck('node_id')->toArray();
  18. Log::info('----------------------------【修复原版本的每日流量计算错误】开始----------------------------');
  19. Log::info('----------------------------【节点流量日志修正】开始----------------------------');
  20. foreach (NodeDailyDataFlow::all() as $log) {
  21. NodeDailyDataFlow::whereId($log->id)->update([
  22. 'created_at' => date('Y-m-d H:i:s', strtotime("$log->created_at -1 days")),
  23. ]);
  24. }
  25. Log::info('----------------------------【添加节点流量日志】开始----------------------------');
  26. foreach ($nodeArray as $nodeId) {
  27. $query = UserDataFlowLog::whereNodeId($nodeId)
  28. ->whereBetween('log_time',
  29. [strtotime(date('Y-m-d', strtotime("-1 days"))), strtotime($this->end)]);
  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 = $nodeId;
  36. $obj->u = $u;
  37. $obj->d = $d;
  38. $obj->total = $total;
  39. $obj->traffic = flowAutoShow($total);
  40. $obj->created_at = $this->end;
  41. $obj->save();
  42. }
  43. }
  44. Log::info('----------------------------【添加节点流量日志】结束----------------------------');
  45. Log::info('----------------------------【节点流量日志修正】结束----------------------------');
  46. Log::info('----------------------------【用户流量日志修正】开始----------------------------');
  47. foreach (UserDailyDataFlow::all() as $log) {
  48. UserDailyDataFlow::whereId($log->id)->update([
  49. 'created_at' => date('Y-m-d H:i:s', strtotime("$log->created_at -1 days")),
  50. ]);
  51. }
  52. Log::info('----------------------------【用户个人流量日志修正】开始----------------------------');
  53. foreach (UserDataFlowLog::distinct()->pluck('user_id')->toArray() as $userId) {
  54. // 统计一次所有节点的总和
  55. $this->statisticsByUser($userId);
  56. // 统计每个节点产生的流量
  57. foreach ($nodeArray as $nodeId) {
  58. $this->statisticsByUser($userId, $nodeId);
  59. }
  60. }
  61. Log::info('----------------------------【用户个人流量日志修正】结束----------------------------');
  62. Log::info('----------------------------【用户流量日志修正】结束----------------------------');
  63. Log::info('----------------------------【修复原版本的每日流量计算错误】结束----------------------------');
  64. }
  65. private function statisticsByUser($user_id, $node_id = 0): void
  66. {
  67. $query = UserDataFlowLog::whereUserId($user_id)
  68. ->whereBetween('log_time',
  69. [strtotime(date('Y-m-d', strtotime("-1 days"))), strtotime($this->end)]);
  70. if ($node_id) {
  71. $query->whereNodeId($node_id);
  72. }
  73. $u = $query->sum('u');
  74. $d = $query->sum('d');
  75. $total = $u + $d;
  76. if ($total) { // 有数据才记录
  77. $obj = new UserDailyDataFlow();
  78. $obj->user_id = $user_id;
  79. $obj->node_id = $node_id;
  80. $obj->u = $u;
  81. $obj->d = $d;
  82. $obj->total = $total;
  83. $obj->traffic = flowAutoShow($total);
  84. $obj->created_at = $this->end;
  85. $obj->save();
  86. }
  87. }
  88. }