mirror of
https://github.com/ProxyPanel/ProxyPanel.git
synced 2026-04-11 23:19:05 +00:00
49 lines
1.3 KiB
PHP
49 lines
1.3 KiB
PHP
<?php
|
|
|
|
namespace App\Console\Commands;
|
|
|
|
use App\Models\Node;
|
|
use App\Models\NodeHourlyDataFlow;
|
|
use App\Models\UserDataFlowLog;
|
|
use Illuminate\Console\Command;
|
|
use Log;
|
|
|
|
class AutoStatisticsNodeHourlyTraffic extends Command
|
|
{
|
|
protected $signature = 'autoStatisticsNodeHourlyTraffic';
|
|
protected $description = '自动统计节点每小时流量';
|
|
|
|
public function handle(): void
|
|
{
|
|
$jobStartTime = microtime(true);
|
|
|
|
foreach (Node::whereStatus(1)->orderBy('id')->get() as $node) {
|
|
$this->statisticsByNode($node->id);
|
|
}
|
|
|
|
$jobEndTime = microtime(true);
|
|
$jobUsedTime = round(($jobEndTime - $jobStartTime), 4);
|
|
|
|
Log::info('---【'.$this->description.'】完成---,耗时'.$jobUsedTime.'秒');
|
|
}
|
|
|
|
private function statisticsByNode($node_id): void
|
|
{
|
|
$query = UserDataFlowLog::whereNodeId($node_id)->whereBetween('log_time', [strtotime('-1 hour'), time()]);
|
|
|
|
$u = $query->sum('u');
|
|
$d = $query->sum('d');
|
|
$total = $u + $d;
|
|
|
|
if ($total) { // 有数据才记录
|
|
$obj = new NodeHourlyDataFlow();
|
|
$obj->node_id = $node_id;
|
|
$obj->u = $u;
|
|
$obj->d = $d;
|
|
$obj->total = $total;
|
|
$obj->traffic = flowAutoShow($total);
|
|
$obj->save();
|
|
}
|
|
}
|
|
}
|