|
@@ -1,97 +0,0 @@
|
|
|
-<?php
|
|
|
-
|
|
|
-namespace App\Console\Commands;
|
|
|
-
|
|
|
-use App\Models\NodeDailyDataFlow;
|
|
|
-use App\Models\UserDailyDataFlow;
|
|
|
-use App\Models\UserDataFlowLog;
|
|
|
-use Illuminate\Console\Command;
|
|
|
-use Log;
|
|
|
-
|
|
|
-class fixDailyTrafficLogError extends Command
|
|
|
-{
|
|
|
- protected $signature = 'fixDailyTrafficLogError';
|
|
|
- protected $description = '修复原版本的每日流量计算错误';
|
|
|
-
|
|
|
- private $end;
|
|
|
-
|
|
|
- public function handle(): void
|
|
|
- {
|
|
|
- // set value
|
|
|
- $this->end = date('Y-m-d 23:59:59', strtotime('-1 days'));
|
|
|
- $nodeArray = UserDataFlowLog::distinct()->pluck('node_id')->toArray();
|
|
|
-
|
|
|
- Log::info('----------------------------【修复原版本的每日流量计算错误】开始----------------------------');
|
|
|
- Log::info('----------------------------【节点流量日志修正】开始----------------------------');
|
|
|
- foreach (NodeDailyDataFlow::all() as $log) {
|
|
|
- NodeDailyDataFlow::whereId($log->id)->update([
|
|
|
- 'created_at' => date('Y-m-d H:i:s', strtotime("$log->created_at -1 days")),
|
|
|
- ]);
|
|
|
- }
|
|
|
-
|
|
|
- Log::info('----------------------------【添加节点流量日志】开始----------------------------');
|
|
|
- foreach ($nodeArray as $nodeId) {
|
|
|
- $query = UserDataFlowLog::whereNodeId($nodeId)
|
|
|
- ->whereBetween('log_time', [strtotime(date('Y-m-d', strtotime('-1 days'))), strtotime($this->end)]);
|
|
|
-
|
|
|
- $u = $query->sum('u');
|
|
|
- $d = $query->sum('d');
|
|
|
- $total = $u + $d;
|
|
|
-
|
|
|
- if ($total) { // 有数据才记录
|
|
|
- $obj = new NodeDailyDataFlow();
|
|
|
- $obj->node_id = $nodeId;
|
|
|
- $obj->u = $u;
|
|
|
- $obj->d = $d;
|
|
|
- $obj->total = $total;
|
|
|
- $obj->traffic = flowAutoShow($total);
|
|
|
- $obj->created_at = $this->end;
|
|
|
- $obj->save();
|
|
|
- }
|
|
|
- }
|
|
|
- Log::info('----------------------------【添加节点流量日志】结束----------------------------');
|
|
|
- Log::info('----------------------------【节点流量日志修正】结束----------------------------');
|
|
|
- Log::info('----------------------------【用户流量日志修正】开始----------------------------');
|
|
|
- foreach (UserDailyDataFlow::all() as $log) {
|
|
|
- UserDailyDataFlow::whereId($log->id)->update(['created_at' => date('Y-m-d H:i:s', strtotime("$log->created_at -1 days"))]);
|
|
|
- }
|
|
|
- Log::info('----------------------------【用户个人流量日志修正】开始----------------------------');
|
|
|
- foreach (UserDataFlowLog::distinct()->pluck('user_id')->toArray() as $userId) {
|
|
|
- // 统计一次所有节点的总和
|
|
|
- $this->statisticsByUser($userId);
|
|
|
- // 统计每个节点产生的流量
|
|
|
- foreach ($nodeArray as $nodeId) {
|
|
|
- $this->statisticsByUser($userId, $nodeId);
|
|
|
- }
|
|
|
- }
|
|
|
- Log::info('----------------------------【用户个人流量日志修正】结束----------------------------');
|
|
|
- Log::info('----------------------------【用户流量日志修正】结束----------------------------');
|
|
|
- Log::info('----------------------------【修复原版本的每日流量计算错误】结束----------------------------');
|
|
|
- }
|
|
|
-
|
|
|
- private function statisticsByUser($user_id, $node_id = 0): void
|
|
|
- {
|
|
|
- $query = UserDataFlowLog::whereUserId($user_id)
|
|
|
- ->whereBetween('log_time', [strtotime(date('Y-m-d', strtotime('-1 days'))), strtotime($this->end)]);
|
|
|
-
|
|
|
- if ($node_id) {
|
|
|
- $query->whereNodeId($node_id);
|
|
|
- }
|
|
|
-
|
|
|
- $u = $query->sum('u');
|
|
|
- $d = $query->sum('d');
|
|
|
- $total = $u + $d;
|
|
|
-
|
|
|
- if ($total) { // 有数据才记录
|
|
|
- $obj = new UserDailyDataFlow();
|
|
|
- $obj->user_id = $user_id;
|
|
|
- $obj->node_id = $node_id;
|
|
|
- $obj->u = $u;
|
|
|
- $obj->d = $d;
|
|
|
- $obj->total = $total;
|
|
|
- $obj->traffic = flowAutoShow($total);
|
|
|
- $obj->created_at = $this->end;
|
|
|
- $obj->save();
|
|
|
- }
|
|
|
- }
|
|
|
-}
|