query("
SELECT
n.*,
ca.name AS cf_account_name,
ca.api_token AS cf_api_token,
p.name AS panel_name,
p.panel_type,
COALESCE(g.name, 'عمومی') AS resolved_group_name
FROM nodes n
JOIN cloudflare_accounts ca ON n.cf_account_id = ca.id
JOIN panels p ON n.panel_id = p.id
LEFT JOIN panel_groups g ON n.group_id = g.id
");
$nodes = $stmt->fetchAll();
if (empty($nodes)) {
exit;
}
foreach ($nodes as $node) {
$port = !empty($node['check_port']) ? (int)$node['check_port'] : 443;
$country = !empty($node['country']) ? $node['country'] : 'نامشخص';
$isOnline = isNodeAlive($node['main_ip'], $port);
if ($node['status'] === 'manual_override') {
continue;
}
// =======================================================
// ۱. نود قطع است -> انتخاب زاپاس به صورت چرخشی (Round-Robin)
// =======================================================
if (!$isOnline && empty($node['assigned_backup_id'])) {
// دریافت لیست تمام زاپاس‌های متعلق به این پنل
$bStmt = $pdo->prepare("SELECT * FROM backup_nodes WHERE panel_id = ? ORDER BY id ASC");
$bStmt->execute([$node['panel_id']]);
$allBackups = $bStmt->fetchAll();
if (!empty($allBackups)) {
$totalBackups = count($allBackups);
// محاسبه تعداد نودهای آفلاین فعلی این پنل برای چرخش عادلانه
$cStmt = $pdo->prepare("SELECT COUNT(*) FROM nodes WHERE panel_id = ? AND assigned_backup_id IS NOT NULL");
$cStmt->execute([$node['panel_id']]);
$assignedCount = (int)$cStmt->fetchColumn();
// انتخاب اندیس زاپاس با استفاده از باقیمانده تقسیم (Modulo)
$backupIndex = $assignedCount % $totalBackups;
$backup = $allBackups[$backupIndex];
$cfError = '';
$cfUpdated = Cloudflare::updateRecord(
$node['cf_api_token'],
$node['zone_id'],
$node['record_id'],
$node['domain_name'],
$backup['ip'],
(bool)$node['proxied'],
$cfError
);
if ($cfUpdated) {
$pdo->prepare("
UPDATE nodes
SET current_ip = ?, status = 'offline', assigned_backup_id = ?
WHERE id = ?
")->execute([$backup['ip'], $backup['id'], $node['id']]);
$pType = strtoupper($node['panel_type']);
$msg = "🔴 هشدار: قطعی نود و سوییچ چرخشی به زاپاس\n\n"
. "🏷 نود: {$node['name']}\n"
. "🌍 کشور: {$country}\n"
. "👥 گروه: {$node['resolved_group_name']}\n"
. "🏢 پنل: {$node['panel_name']} ({$pType})\n"
. "🌐 ساب‌دامین: {$node['domain_name']}\n"
. "❌ آی‌پی قطع شده: {$node['main_ip']}\n"
. "🔄 آی‌پی زاپاس اختصاص داده شده: {$backup['ip']} ({$backup['name']})\n"
. "⏱ زمان: " . date('Y-m-d H:i:s');
Telegram::sendMessage($msg);
}
} else {
$pType = strtoupper($node['panel_type']);
$msg = "⚠️ هشدار بحرانی: نود قطع است ولی هیچ زاپاسی برای این پنل ثبت نشده!\n\n"
. "🏷 نود: {$node['name']}\n"
. "👥 گروه: {$node['resolved_group_name']}\n"
. "🏢 پنل: {$node['panel_name']} ({$pType})\n"
. "❌ آی‌پی: {$node['main_ip']}";
Telegram::sendMessage($msg);
}
}
// =======================================================
// ۲. نود وصل شد -> بازگردانی به آی‌پی اصلی
// =======================================================
if ($isOnline && !empty($node['assigned_backup_id'])) {
$cfError = '';
$cfUpdated = Cloudflare::updateRecord(
$node['cf_api_token'],
$node['zone_id'],
$node['record_id'],
$node['domain_name'],
$node['main_ip'],
(bool)$node['proxied'],
$cfError
);
if ($cfUpdated) {
$bStmt = $pdo->prepare("SELECT name, ip FROM backup_nodes WHERE id = ?");
$bStmt->execute([$node['assigned_backup_id']]);
$released = $bStmt->fetch();
$pdo->prepare("
UPDATE nodes
SET current_ip = main_ip, status = 'online', assigned_backup_id = NULL
WHERE id = ?
")->execute([$node['id']]);
$pType = strtoupper($node['panel_type']);
$bText = $released ? "{$released['ip']} ({$released['name']})" : "زاپاس";
$msg = "🟢 گزارش: بازگشت نود به مدار\n\n"
. "🏷 نود: {$node['name']}\n"
. "🌍 کشور: {$country}\n"
. "👥 گروه: {$node['resolved_group_name']}\n"
. "🏢 پنل: {$node['panel_name']} ({$pType})\n"
. "🌐 ساب‌دامین: {$node['domain_name']}\n"
. "✅ آی‌پی اصلی وصل شد: {$node['main_ip']}\n"
. "🔄 نود از روی زاپاس ({$bText}) برداشته شد.\n"
. "⏱ زمان: " . date('Y-m-d H:i:s');
Telegram::sendMessage($msg);
}
}
}