mirror of
https://github.com/ProxyPanel/ProxyPanel.git
synced 2026-04-11 23:19:05 +00:00
101 lines
3.7 KiB
PHP
101 lines
3.7 KiB
PHP
<?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::query()->distinct()->pluck('node_id')->toArray();
|
|
|
|
Log::info('----------------------------【修复原版本的每日流量计算错误】开始----------------------------');
|
|
Log::info('----------------------------【节点流量日志修正】开始----------------------------');
|
|
foreach(NodeDailyDataFlow::all() as $log){
|
|
NodeDailyDataFlow::query()->whereId($log->id)->update([
|
|
'created_at' => date('Y-m-d H:i:s', strtotime("-1 days", strtotime($log->created_at)))
|
|
]);
|
|
}
|
|
|
|
Log::info('----------------------------【添加节点流量日志】开始----------------------------');
|
|
foreach($nodeArray as $nodeId){
|
|
$query = UserDataFlowLog::query()
|
|
->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::query()->whereId($log->id)->update([
|
|
'created_at' => date('Y-m-d H:i:s', strtotime("-1 days", strtotime($log->created_at)))
|
|
]);
|
|
}
|
|
Log::info('----------------------------【用户个人流量日志修正】开始----------------------------');
|
|
foreach(UserDataFlowLog::query()->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::query()
|
|
->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();
|
|
}
|
|
}
|
|
|
|
} |