80 lines
4.2 KiB
PHP
Executable File
80 lines
4.2 KiB
PHP
Executable File
|
|
<?php
|
|
header('Content-Type: application/json');
|
|
$pdo = new PDO("pgsql:host=localhost;dbname=adx_system", "admin", "admin123", [PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION]);
|
|
|
|
$pdo->exec("CREATE TABLE IF NOT EXISTS admin.rotation_domains (id SERIAL PRIMARY KEY, domain VARCHAR(255) UNIQUE, pool VARCHAR(100) DEFAULT 'default', sends_today INTEGER DEFAULT 0, sends_total INTEGER DEFAULT 0, last_used TIMESTAMP, reputation INTEGER DEFAULT 100, status VARCHAR(50) DEFAULT 'active')");
|
|
$pdo->exec("CREATE TABLE IF NOT EXISTS admin.rotation_config (id SERIAL PRIMARY KEY, pool VARCHAR(100) UNIQUE, max_per_day INTEGER DEFAULT 1000, cooldown_hours INTEGER DEFAULT 24, min_reputation INTEGER DEFAULT 50)");
|
|
|
|
$action = $_POST['action'] ?? $_GET['action'] ?? '';
|
|
|
|
switch ($action) {
|
|
case 'add':
|
|
$stmt = $pdo->prepare("INSERT INTO admin.rotation_domains (domain, pool) VALUES (?, ?) ON CONFLICT (domain) DO NOTHING");
|
|
$stmt->execute([$_POST['domain'], $_POST['pool'] ?? 'default']);
|
|
echo json_encode(['success' => true]);
|
|
break;
|
|
|
|
case 'bulk_add':
|
|
$domains = explode("\n", $_POST['domains']);
|
|
$pool = $_POST['pool'] ?? 'default';
|
|
$count = 0;
|
|
foreach ($domains as $d) {
|
|
$d = trim($d);
|
|
if ($d) {
|
|
$pdo->prepare("INSERT INTO admin.rotation_domains (domain, pool) VALUES (?, ?) ON CONFLICT DO NOTHING")->execute([$d, $pool]);
|
|
$count++;
|
|
}
|
|
}
|
|
echo json_encode(['success' => true, 'added' => $count]);
|
|
break;
|
|
|
|
case 'list':
|
|
$pool = $_GET['pool'] ?? null;
|
|
$where = $pool ? "WHERE pool = " . $pdo->quote($pool) : "";
|
|
$domains = $pdo->query("SELECT * FROM admin.rotation_domains $where ORDER BY last_used NULLS FIRST, sends_today ASC")->fetchAll(PDO::FETCH_ASSOC);
|
|
echo json_encode(['domains' => $domains]);
|
|
break;
|
|
|
|
case 'get_next':
|
|
$pool = $_POST['pool'] ?? 'default';
|
|
$config = $pdo->query("SELECT * FROM admin.rotation_config WHERE pool = " . $pdo->quote($pool))->fetch(PDO::FETCH_ASSOC);
|
|
$maxPerDay = $config['max_per_day'] ?? 1000;
|
|
$minRep = $config['min_reputation'] ?? 50;
|
|
|
|
$domain = $pdo->query("SELECT * FROM admin.rotation_domains WHERE pool = " . $pdo->quote($pool) . " AND status = 'active' AND sends_today < $maxPerDay AND reputation >= $minRep ORDER BY last_used NULLS FIRST, sends_today ASC LIMIT 1")->fetch(PDO::FETCH_ASSOC);
|
|
|
|
if ($domain) {
|
|
$pdo->exec("UPDATE admin.rotation_domains SET sends_today = sends_today + 1, sends_total = sends_total + 1, last_used = NOW() WHERE id = {$domain['id']}");
|
|
echo json_encode(['success' => true, 'domain' => $domain['domain']]);
|
|
} else {
|
|
echo json_encode(['success' => false, 'error' => 'No available domains']);
|
|
}
|
|
break;
|
|
|
|
case 'update_reputation':
|
|
$pdo->prepare("UPDATE admin.rotation_domains SET reputation = ? WHERE domain = ?")->execute([$_POST['reputation'], $_POST['domain']]);
|
|
echo json_encode(['success' => true]);
|
|
break;
|
|
|
|
case 'reset_daily':
|
|
$pdo->exec("UPDATE admin.rotation_domains SET sends_today = 0");
|
|
echo json_encode(['success' => true]);
|
|
break;
|
|
|
|
case 'pools':
|
|
$pools = $pdo->query("SELECT pool, COUNT(*) as domains, SUM(sends_today) as sends_today, SUM(sends_total) as sends_total FROM admin.rotation_domains GROUP BY pool")->fetchAll(PDO::FETCH_ASSOC);
|
|
echo json_encode(['pools' => $pools]);
|
|
break;
|
|
|
|
case 'set_config':
|
|
$pdo->prepare("INSERT INTO admin.rotation_config (pool, max_per_day, cooldown_hours, min_reputation) VALUES (?, ?, ?, ?) ON CONFLICT (pool) DO UPDATE SET max_per_day = ?, cooldown_hours = ?, min_reputation = ?")
|
|
->execute([$_POST['pool'], $_POST['max_per_day'], $_POST['cooldown_hours'], $_POST['min_reputation'], $_POST['max_per_day'], $_POST['cooldown_hours'], $_POST['min_reputation']]);
|
|
echo json_encode(['success' => true]);
|
|
break;
|
|
|
|
default:
|
|
echo json_encode(['actions' => ['add','bulk_add','list','get_next','update_reputation','reset_daily','pools','set_config']]);
|
|
}
|
|
|