Added basic support for distributing billing (#15156)

This commit is contained in:
Neil Lathwood
2023-07-25 18:09:34 +01:00
committed by GitHub
parent a2f906c3f4
commit a69d50e962
2 changed files with 21 additions and 4 deletions

View File

@@ -41,7 +41,11 @@ foreach ($query->get(['bill_id', 'bill_name']) as $bill) {
echo 'Bill : ' . $bill->bill_name . "\n";
$bill_id = $bill->bill_id;
$port_list = dbFetchRows('SELECT * FROM `bill_ports` as P, `ports` as I, `devices` as D WHERE P.bill_id=? AND I.port_id = P.port_id AND D.device_id = I.device_id', [$bill_id]);
if ($config['distributed_poller'] && $config['distributed_billing']) {
$port_list = dbFetchRows('SELECT * FROM `bill_ports` as P, `ports` as I, `devices` as D WHERE P.bill_id=? AND I.port_id = P.port_id AND D.device_id = I.device_id AND D.poller_group IN (?)', [$bill_id, $config['distributed_poller_group']]);
} else {
$port_list = dbFetchRows('SELECT * FROM `bill_ports` as P, `ports` as I, `devices` as D WHERE P.bill_id=? AND I.port_id = P.port_id AND D.device_id = I.device_id', [$bill_id]);
}
$now = dbFetchCell('SELECT NOW()');
$delta = 0;