Новые ссылки Kinopub
// Получаем новые эпизоды из очереди
$newEpisodes = $db->query(
"SELECT * FROM kinopub_new_episodes
WHERE status = 'new'
ORDER BY serial_title, season_num, episode_num",
false,
"fetchall"
);
// Дополнительная проверка: если серия уже добавлена в бот после попадания в очередь
$filteredEpisodes = [];
foreach ($newEpisodes as $ep) {
$stillNew = $db->query(
"SELECT id FROM series
WHERE serial_id = ? AND num_season = ? AND num_series = ?",
[$ep['serial_id'], $ep['season_num'], $ep['episode_num']],
"fetch"
);
// Если серия уже есть в боте - автоматически помечаем как обработанную
if ($stillNew) {
$db->execute(
"UPDATE kinopub_new_episodes
SET status = 'processed', date_processed = NOW()
WHERE id = ?",
[$ep['id']]
);
continue; // Пропускаем этот эпизод
}
$filteredEpisodes[] = $ep;
}
// Группируем по сериалам
$grouped = [];
foreach ($filteredEpisodes as $ep) {
$key = $ep['serial_id'] . '_' . $ep['serial_title'];
if (!isset($grouped[$key])) {
$grouped[$key] = [
'serial_title' => $ep['serial_title'],
'episodes' => []
];
}
$grouped[$key]['episodes'][] = $ep;
}
if (empty($filteredEpisodes)) {
echo '
Новых эпизодов не найдено.
';
} else {
echo '
Найдено новых эпизодов: ' . count($filteredEpisodes) . '
';
}
?>