401 lines
13 KiB
PHP
401 lines
13 KiB
PHP
<?php
|
|
|
|
/**
|
|
* PHP Mikrotik Billing (https://github.com/hotspotbilling/phpnuxbill/)
|
|
* by https://t.me/ibnux
|
|
**/
|
|
|
|
_admin();
|
|
$ui->assign('_title', Lang::T('Network'));
|
|
$ui->assign('_system_menu', 'network');
|
|
|
|
$action = $routes['1'];
|
|
$ui->assign('_admin', $admin);
|
|
|
|
use PEAR2\Net\RouterOS;
|
|
|
|
require_once 'system/autoload/PEAR2/Autoload.php';
|
|
|
|
if (!in_array($admin['user_type'], ['SuperAdmin', 'Admin'])) {
|
|
_alert(Lang::T('You do not have permission to access this page'), 'danger', "dashboard");
|
|
}
|
|
|
|
use RouterOS\Exceptions\Socket\TimeoutException;
|
|
use RouterOS\Exceptions\Socket\ConnectionException;
|
|
|
|
function mikrotik_get_resources($routerId)
|
|
{
|
|
$mikrotik = ORM::for_table('tbl_routers')->where('enabled', '1')->find_one($routerId);
|
|
|
|
if (!$mikrotik) {
|
|
return [
|
|
'status' => 'Offline',
|
|
'error' => 'Router not found or disabled'
|
|
];
|
|
}
|
|
|
|
// Check cache first (30 second cache for successful connections)
|
|
$cacheKey = 'router_resources_' . $routerId;
|
|
$cachedData = null;
|
|
if (function_exists('apcu_fetch')) {
|
|
$cachedData = apcu_fetch($cacheKey);
|
|
if ($cachedData && (time() - $cachedData['timestamp']) < 30) {
|
|
return array_merge($cachedData, ['cached' => true]);
|
|
}
|
|
}
|
|
|
|
// Check if router is in circuit breaker state (too many recent failures)
|
|
$circuitBreakerKey = 'router_failures_' . $routerId;
|
|
$failureCount = 0;
|
|
$lastFailure = 0;
|
|
if (function_exists('apcu_fetch')) {
|
|
$failureCount = apcu_fetch($circuitBreakerKey) ?: 0;
|
|
$lastFailure = apcu_fetch($circuitBreakerKey . '_time') ?: 0;
|
|
}
|
|
|
|
// If more than 3 failures in the last 5 minutes, skip connection attempt
|
|
if ($failureCount >= 3 && (time() - $lastFailure) < 300) {
|
|
return [
|
|
'status' => 'Offline',
|
|
'error' => 'Router temporarily unavailable (circuit breaker)',
|
|
'cached' => true
|
|
];
|
|
}
|
|
|
|
try {
|
|
// Set a shorter timeout for the connection
|
|
$client = Mikrotik::getClient($mikrotik['ip_address'], $mikrotik['username'], $mikrotik['password']);
|
|
|
|
if (!$client) {
|
|
throw new Exception('Failed to create RouterOS client');
|
|
}
|
|
|
|
// Set timeout for individual requests (5 seconds each)
|
|
$health = $client->sendSync(new RouterOS\Request('/system health print'), 5);
|
|
$res = $client->sendSync(new RouterOS\Request('/system resource print'), 5);
|
|
|
|
$resourceData = $res->getAllOfType(RouterOS\Response::TYPE_DATA)[0];
|
|
$uptime = $resourceData->getProperty('uptime');
|
|
$freeMemory = $resourceData->getProperty('free-memory');
|
|
$totalMemory = $resourceData->getProperty('total-memory');
|
|
$cpuLoad = $resourceData->getProperty('cpu-load');
|
|
|
|
$status = ($uptime !== null && $freeMemory !== null && $totalMemory !== null && $cpuLoad !== null) ? 'Online' : 'Offline';
|
|
|
|
$result = [
|
|
'status' => $status,
|
|
'uptime' => $uptime,
|
|
'freeMemory' => mikrotik_formatSize($freeMemory),
|
|
'totalMemory' => mikrotik_formatSize($totalMemory),
|
|
'cpuLoad' => $cpuLoad . '%',
|
|
'timestamp' => time()
|
|
];
|
|
|
|
// Cache successful results
|
|
if (function_exists('apcu_store') && $status === 'Online') {
|
|
apcu_store($cacheKey, $result, 30);
|
|
}
|
|
|
|
return $result;
|
|
} catch (TimeoutException $e) {
|
|
// Increment failure count for circuit breaker
|
|
if (function_exists('apcu_store')) {
|
|
apcu_store($circuitBreakerKey, $failureCount + 1, 300);
|
|
apcu_store($circuitBreakerKey . '_time', time(), 300);
|
|
}
|
|
|
|
return [
|
|
'status' => 'Offline',
|
|
'error' => 'Connection timeout',
|
|
'timeout' => true
|
|
];
|
|
} catch (ConnectionException $e) {
|
|
// Increment failure count for circuit breaker
|
|
if (function_exists('apcu_store')) {
|
|
apcu_store($circuitBreakerKey, $failureCount + 1, 300);
|
|
apcu_store($circuitBreakerKey . '_time', time(), 300);
|
|
}
|
|
|
|
return [
|
|
'status' => 'Offline',
|
|
'error' => 'Connection failed',
|
|
'connection_error' => true
|
|
];
|
|
} catch (Exception $e) {
|
|
// Increment failure count for circuit breaker
|
|
if (function_exists('apcu_store')) {
|
|
apcu_store($circuitBreakerKey, $failureCount + 1, 300);
|
|
apcu_store($circuitBreakerKey . '_time', time(), 300);
|
|
}
|
|
|
|
return [
|
|
'status' => 'Offline',
|
|
'error' => 'Unknown error: ' . $e->getMessage()
|
|
];
|
|
}
|
|
}
|
|
|
|
function mikrotik_formatSize($size)
|
|
{
|
|
$units = ['B', 'KB', 'MB', 'GB'];
|
|
$unitIndex = 0;
|
|
while ($size >= 1024 && $unitIndex < count($units) - 1) {
|
|
$size /= 1024;
|
|
$unitIndex++;
|
|
}
|
|
return round($size, 2) . ' ' . $units[$unitIndex];
|
|
}
|
|
|
|
// Function to reboot MikroTik router
|
|
function mikrotik_reboot($routerId)
|
|
{
|
|
$mikrotik = ORM::for_table('tbl_routers')->where('enabled', '1')->find_one($routerId);
|
|
|
|
if (!$mikrotik) {
|
|
return [
|
|
'status' => 'Offline',
|
|
'message' => 'Router not found'
|
|
];
|
|
}
|
|
|
|
try {
|
|
$client = Mikrotik::getClient($mikrotik['ip_address'], $mikrotik['username'], $mikrotik['password']);
|
|
|
|
// Send the reboot command
|
|
$client->sendSync(new RouterOS\Request('/system reboot'));
|
|
|
|
return [
|
|
'status' => 'Rebooting',
|
|
'message' => 'Router is rebooting'
|
|
];
|
|
} catch (TimeoutException | ConnectionException $e) {
|
|
return [
|
|
'status' => 'Error',
|
|
'message' => 'Failed to connect to the router'
|
|
];
|
|
}
|
|
}
|
|
|
|
switch ($action) {
|
|
case 'list':
|
|
$ui->assign('xfooter', '<script type="text/javascript" src="ui/lib/c/routers.js"></script>');
|
|
|
|
$name = _post('name');
|
|
if ($name != '') {
|
|
$query = ORM::for_table('tbl_routers')->where_like('name', '%' . $name . '%')->order_by_desc('id');
|
|
$d = Paginator::findMany($query, ['name' => $name]);
|
|
} else {
|
|
$query = ORM::for_table('tbl_routers')->order_by_desc('id');
|
|
$d = Paginator::findMany($query);
|
|
}
|
|
|
|
$ui->assign('d', $d);
|
|
run_hook('view_list_routers'); #HOOK
|
|
$ui->display('routers.tpl');
|
|
break;
|
|
|
|
case 'get_resources':
|
|
if (isset($_GET['router_id'])) {
|
|
$routerId = $_GET['router_id'];
|
|
$resources = mikrotik_get_resources($routerId);
|
|
echo json_encode($resources);
|
|
exit;
|
|
}
|
|
break;
|
|
|
|
case 'get_all_resources':
|
|
// Get all enabled routers
|
|
$routers = ORM::for_table('tbl_routers')->where('enabled', '1')->find_many();
|
|
$results = [];
|
|
|
|
foreach ($routers as $router) {
|
|
$resources = mikrotik_get_resources($router['id']);
|
|
$results[$router['id']] = $resources;
|
|
}
|
|
|
|
echo json_encode($results);
|
|
exit;
|
|
break;
|
|
|
|
case 'reboot':
|
|
if (isset($_GET['router_id'])) {
|
|
$routerId = $_GET['router_id'];
|
|
$result = mikrotik_reboot($routerId);
|
|
echo json_encode($result);
|
|
exit;
|
|
}
|
|
break;
|
|
|
|
case 'add':
|
|
run_hook('view_add_routers'); #HOOK
|
|
$ui->display('routers-add.tpl');
|
|
break;
|
|
|
|
case 'edit':
|
|
$id = $routes['2'];
|
|
$d = ORM::for_table('tbl_routers')->find_one($id);
|
|
if (!$d) {
|
|
$d = ORM::for_table('tbl_routers')->where_equal('name', _get('name'))->find_one();
|
|
}
|
|
if ($d) {
|
|
$ui->assign('d', $d);
|
|
run_hook('view_router_edit'); #HOOK
|
|
$ui->display('routers-edit.tpl');
|
|
} else {
|
|
r2(U . 'routers/list', 'e', Lang::T('Account Not Found'));
|
|
}
|
|
break;
|
|
|
|
case 'delete':
|
|
$id = $routes['2'];
|
|
run_hook('router_delete'); #HOOK
|
|
$d = ORM::for_table('tbl_routers')->find_one($id);
|
|
if ($d) {
|
|
$d->delete();
|
|
r2(U . 'routers/list', 's', Lang::T('Data Deleted Successfully'));
|
|
}
|
|
break;
|
|
|
|
case 'add-post':
|
|
$name = _post('name');
|
|
$ip_address = _post('ip_address');
|
|
$username = _post('username');
|
|
$password = _post('password');
|
|
$description = _post('description');
|
|
$enabled = _post('enabled');
|
|
|
|
$msg = '';
|
|
if (Validator::Length($name, 30, 4) == false) {
|
|
$msg .= 'Name should be between 5 to 30 characters' . '<br>';
|
|
}
|
|
if ($ip_address == '' or $username == '') {
|
|
$msg .= Lang::T('All field is required') . '<br>';
|
|
}
|
|
|
|
$d = ORM::for_table('tbl_routers')->where('ip_address', $ip_address)->find_one();
|
|
if ($d) {
|
|
$msg .= Lang::T('IP Router Already Exist') . '<br>';
|
|
}
|
|
if (strtolower($name) == 'radius') {
|
|
$msg .= '<b>Radius</b> name is reserved<br>';
|
|
}
|
|
|
|
if ($msg == '') {
|
|
Mikrotik::getClient($ip_address, $username, $password);
|
|
run_hook('add_router'); #HOOK
|
|
$d = ORM::for_table('tbl_routers')->create();
|
|
$d->name = $name;
|
|
$d->ip_address = $ip_address;
|
|
$d->username = $username;
|
|
$d->password = $password;
|
|
$d->description = $description;
|
|
$d->enabled = $enabled;
|
|
$d->save();
|
|
|
|
r2(U . 'routers/list', 's', Lang::T('Data Created Successfully'));
|
|
} else {
|
|
r2(U . 'routers/add', 'e', $msg);
|
|
}
|
|
break;
|
|
|
|
case 'download':
|
|
$routerId = _post('router_id');
|
|
$routerName = _post('router_name');
|
|
|
|
if ($routerId && $routerName) {
|
|
$updateRouterIdStmt = $conn->prepare("UPDATE tbl_appconfig SET value = :router_id WHERE setting = 'router_id'");
|
|
$updateRouterIdStmt->execute(['router_id' => $routerId]);
|
|
|
|
$updateRouterNameStmt = $conn->prepare("UPDATE tbl_appconfig SET value = :router_name WHERE setting = 'router_name'");
|
|
$updateRouterNameStmt->execute(['router_name' => $routerName]);
|
|
|
|
header("Location: {$app_url}/system/plugin/download.php?download=1");
|
|
exit;
|
|
} else {
|
|
r2(U . 'routers/list', 'e', Lang::T('Invalid router ID or name'));
|
|
}
|
|
break;
|
|
|
|
case 'edit-post':
|
|
$name = _post('name');
|
|
$ip_address = _post('ip_address');
|
|
$username = _post('username');
|
|
$password = _post('password');
|
|
$description = _post('description');
|
|
$enabled = $_POST['enabled'];
|
|
$msg = '';
|
|
if (Validator::Length($name, 30, 4) == false) {
|
|
$msg .= 'Name should be between 5 to 30 characters' . '<br>';
|
|
}
|
|
if ($ip_address == '' or $username == '') {
|
|
$msg .= Lang::T('All field is required') . '<br>';
|
|
}
|
|
|
|
$id = _post('id');
|
|
$d = ORM::for_table('tbl_routers')->find_one($id);
|
|
if ($d) {
|
|
} else {
|
|
$msg .= Lang::T('Data Not Found') . '<br>';
|
|
}
|
|
|
|
if ($d['name'] != $name) {
|
|
$c = ORM::for_table('tbl_routers')->where('name', $name)->where_not_equal('id', $id)->find_one();
|
|
if ($c) {
|
|
$msg .= 'Name Already Exists<br>';
|
|
}
|
|
}
|
|
$oldname = $d['name'];
|
|
|
|
if ($d['ip_address'] != $ip_address) {
|
|
$c = ORM::for_table('tbl_routers')->where('ip_address', $ip_address)->where_not_equal('id', $id)->find_one();
|
|
if ($c) {
|
|
$msg .= 'IP Already Exists<br>';
|
|
}
|
|
}
|
|
|
|
if (strtolower($name) == 'radius') {
|
|
$msg .= '<b>Radius</b> name is reserved<br>';
|
|
}
|
|
|
|
if ($msg == '') {
|
|
Mikrotik::getClient($ip_address, $username, $password);
|
|
run_hook('router_edit'); #HOOK
|
|
$d->name = $name;
|
|
$d->ip_address = $ip_address;
|
|
$d->username = $username;
|
|
$d->password = $password;
|
|
$d->description = $description;
|
|
$d->enabled = $enabled;
|
|
$d->save();
|
|
if ($name != $oldname) {
|
|
$p = ORM::for_table('tbl_plans')->where('routers', $oldname)->find_result_set();
|
|
$p->set('routers', $name);
|
|
$p->save();
|
|
$p = ORM::for_table('tbl_payment_gateway')->where('routers', $oldname)->find_result_set();
|
|
$p->set('routers', $name);
|
|
$p->save();
|
|
$p = ORM::for_table('tbl_pool')->where('routers', $oldname)->find_result_set();
|
|
$p->set('routers', $name);
|
|
$p->save();
|
|
$p = ORM::for_table('tbl_transactions')->where('routers', $oldname)->find_result_set();
|
|
$p->set('routers', $name);
|
|
$p->save();
|
|
$p = ORM::for_table('tbl_user_recharges')->where('routers', $oldname)->find_result_set();
|
|
$p->set('routers', $name);
|
|
$p->save();
|
|
$p = ORM::for_table('tbl_voucher')->where('routers', $oldname)->find_result_set();
|
|
$p->set('routers', $name);
|
|
$p->save();
|
|
}
|
|
r2(U . 'routers/list', 's', Lang::T('Data Updated Successfully'));
|
|
} else {
|
|
r2(U . 'routers/edit/' . $id, 'e', $msg);
|
|
}
|
|
break;
|
|
|
|
default:
|
|
r2(U . 'routers/list/', 's', '');
|
|
}
|
|
|
|
?>
|