#!/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