123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101 |
- <?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();
- }
- }
- }
|