146 lines
6.2 KiB
PHP
Executable File
146 lines
6.2 KiB
PHP
Executable File
#!/usr/bin/env php
|
|
<?php
|
|
|
|
/**
|
|
* LibreNMS
|
|
*
|
|
* This file is part of LibreNMS.
|
|
*
|
|
* @copyright (C) 2006 - 2012 Adam Armstrong
|
|
*/
|
|
|
|
use LibreNMS\Billing;
|
|
use LibreNMS\Util\Number;
|
|
|
|
$init_modules = [];
|
|
require __DIR__ . '/includes/init.php';
|
|
|
|
$options = getopt('r');
|
|
|
|
if (isset($options['r'])) {
|
|
echo "Clearing history table.\n";
|
|
DB::table('bill_history')->truncate();
|
|
}
|
|
|
|
foreach (dbFetchRows('SELECT * FROM `bills` ORDER BY `bill_id`') as $bill) {
|
|
echo str_pad($bill['bill_id'] . ' ' . $bill['bill_name'], 30) . " \n";
|
|
|
|
$i = 0;
|
|
while ($i <= 24) {
|
|
unset($class);
|
|
unset($rate_data);
|
|
$day_data = Billing::getDates($bill['bill_day'], $i);
|
|
|
|
$datefrom = $day_data['0'];
|
|
$dateto = $day_data['1'];
|
|
|
|
$check = dbFetchRow('SELECT * FROM `bill_history` WHERE bill_id = ? AND bill_datefrom = ? AND bill_dateto = ? LIMIT 1', [$bill['bill_id'], $datefrom, $dateto]);
|
|
|
|
$period = Billing::getPeriod($bill['bill_id'], $datefrom, $dateto);
|
|
|
|
$date_updated = $check ? str_replace(['-', ':', ' '], '', $check['updated']) : 0;
|
|
|
|
// Send the current dir_95th to the getRates function so it knows to aggregate or return the max in/out value and highest direction
|
|
$dir_95th = $bill['dir_95th'];
|
|
|
|
if ($period['period'] > 0 && $dateto > $date_updated) {
|
|
$rate_data = Billing::getRates($bill['bill_id'], $datefrom, $dateto, $dir_95th);
|
|
$rate_95th = $rate_data['rate_95th'];
|
|
$dir_95th = $rate_data['dir_95th'];
|
|
$total_data = $rate_data['total_data'];
|
|
$rate_average = $rate_data['rate_average'];
|
|
|
|
if ($bill['bill_type'] == 'cdr') {
|
|
$type = 'CDR';
|
|
$allowed = $bill['bill_cdr'];
|
|
$used = $rate_data['rate_95th'];
|
|
$allowed_text = Number::formatSi($allowed, 2, 3, 'bps');
|
|
$used_text = Number::formatSi($used, 2, 3, 'bps');
|
|
$overuse = ($used - $allowed);
|
|
$overuse = (($overuse <= 0) ? '0' : $overuse);
|
|
$percent = Number::calculatePercent($rate_data['rate_95th'], $bill['bill_cdr']);
|
|
} elseif ($bill['bill_type'] == 'quota') {
|
|
$type = 'Quota';
|
|
$allowed = $bill['bill_quota'];
|
|
$used = $rate_data['total_data'];
|
|
$allowed_text = Billing::formatBytes($allowed);
|
|
$used_text = Billing::formatBytes($used);
|
|
$overuse = ($used - $allowed);
|
|
$overuse = (($overuse <= 0) ? '0' : $overuse);
|
|
$percent = Number::calculatePercent($rate_data['total_data'], $bill['bill_quota']);
|
|
}
|
|
|
|
echo \Carbon\Carbon::parse($datefrom)->toDateTimeString() . ' to ' . \Carbon\Carbon::parse($dateto)->toDateTimeString() . ' ' . str_pad($type, 8) . ' ' . str_pad($allowed_text, 10) . ' ' . str_pad($used_text, 10) . ' ' . $percent . '%';
|
|
|
|
if ($i == '0') {
|
|
$update = [
|
|
'rate_95th' => $rate_data['rate_95th'],
|
|
'rate_95th_in' => $rate_data['rate_95th_in'],
|
|
'rate_95th_out' => $rate_data['rate_95th_out'],
|
|
'dir_95th' => $rate_data['dir_95th'],
|
|
'total_data' => $rate_data['total_data'],
|
|
'total_data_in' => $rate_data['total_data_in'],
|
|
'total_data_out' => $rate_data['total_data_out'],
|
|
'rate_average' => $rate_data['rate_average'],
|
|
'rate_average_in' => $rate_data['rate_average_in'],
|
|
'rate_average_out' => $rate_data['rate_average_out'],
|
|
'bill_last_calc' => ['NOW()'],
|
|
];
|
|
|
|
dbUpdate($update, 'bills', '`bill_id` = ?', [$bill['bill_id']]);
|
|
echo ' Updated! ';
|
|
}
|
|
|
|
if (isset($check['bill_id']) && $check['bill_id'] == $bill['bill_id']) {
|
|
$update = [
|
|
'rate_95th' => $rate_data['rate_95th'],
|
|
'rate_95th_in' => $rate_data['rate_95th_in'],
|
|
'rate_95th_out' => $rate_data['rate_95th_out'],
|
|
'dir_95th' => $rate_data['dir_95th'],
|
|
'rate_average' => $rate_data['rate_average'],
|
|
'rate_average_in' => $rate_data['rate_average_in'],
|
|
'rate_average_out' => $rate_data['rate_average_out'],
|
|
'traf_total' => $rate_data['total_data'],
|
|
'traf_in' => $rate_data['total_data_in'],
|
|
'traf_out' => $rate_data['total_data_out'],
|
|
'bill_peak_out' => $period['peak_out'],
|
|
'bill_peak_in' => $period['peak_in'],
|
|
'bill_used' => $used,
|
|
'bill_overuse' => $overuse,
|
|
'bill_percent' => $percent,
|
|
'updated' => ['NOW()'],
|
|
];
|
|
|
|
dbUpdate($update, 'bill_history', '`bill_hist_id` = ?', [$check['bill_hist_id']]);
|
|
echo ' Updated history! ';
|
|
} else {
|
|
$update = [
|
|
'rate_95th' => $rate_data['rate_95th'],
|
|
'rate_95th_in' => $rate_data['rate_95th_in'],
|
|
'rate_95th_out' => $rate_data['rate_95th_out'],
|
|
'dir_95th' => $rate_data['dir_95th'],
|
|
'rate_average' => $rate_data['rate_average'],
|
|
'rate_average_in' => $rate_data['rate_average_in'],
|
|
'rate_average_out' => $rate_data['rate_average_out'],
|
|
'traf_total' => $rate_data['total_data'],
|
|
'traf_in' => $rate_data['total_data_in'],
|
|
'traf_out' => $rate_data['total_data_out'],
|
|
'bill_datefrom' => $datefrom,
|
|
'bill_dateto' => $dateto,
|
|
'bill_type' => $type,
|
|
'bill_allowed' => $allowed,
|
|
'bill_used' => $used,
|
|
'bill_overuse' => $overuse,
|
|
'bill_percent' => $percent,
|
|
'bill_id' => $bill['bill_id'],
|
|
];
|
|
dbInsert($update, 'bill_history');
|
|
echo ' Generated history! ';
|
|
} //end if
|
|
echo "\n\n";
|
|
} //end if
|
|
|
|
$i++;
|
|
} //end while
|
|
}//end foreach
|