diff --git a/main.py b/main.py index 201327e..493babc 100644 --- a/main.py +++ b/main.py @@ -1732,33 +1732,38 @@ async def schedule_reminders(event_id): # Отправляем embed в канал по ID await bot.get_channel(REMINDER_CHANNEL_ID).send(embed=embed) - - # 🧹 Удаление события через 13 часов после начала + # 🧹 Удаление события через 6 часов после начала async def delete_expired_event(): - now = datetime.datetime.now(MOSCOW_TZ) - await asyncio.sleep((start_time - datetime.datetime.now(MOSCOW_TZ)).total_seconds() + 4 * 3600) + now_local = datetime.datetime.now(MOSCOW_TZ) + delay = (start_time - now_local).total_seconds() + 1 * 10 + await asyncio.sleep(max(0, round(delay))) # Удаление сообщения try: - poll_msg_id = event_tasks[event_id].get("poll_msg_id") + poll_msg_id = event_tasks.get(event_id, {}).get("poll_msg_id") channel = bot.get_channel(POLL_CHANNEL_ID) + + if not poll_msg_id or channel is None: + raise RuntimeError( + f"Нет poll_msg_id или не найден канал (poll_msg_id={poll_msg_id}, channel={channel})") + msg = await channel.fetch_message(poll_msg_id) await msg.delete() + except Exception as e: logging.exception("Ошибка при удалении сообщения:") print(f"⚠️ Ошибка при удалении сообщения: {e}") - # Удаление из памяти + # Удаление из памяти + файла event_tasks.pop(event_id, None) save_event_tasks() - print(f"🗑️ Событие '{name}' автоматически удалено через 13ч после начала.") - + print(f"🗑️ Событие '{name}' автоматически удалено через 6ч после начала.") # 🧠 Планируем все задачи task1 = asyncio.create_task(send_embed_reminder(120, start_time, name, votes)) # За 2 часа task2 = asyncio.create_task(send_embed_reminder(30, start_time, name, votes)) # За 30 минут - task3 = asyncio.create_task(delete_expired_event()) # Через 4 часов удаление + task3 = asyncio.create_task(delete_expired_event()) # Через 6 часов удаление scheduled_tasks[event_id] = [task1, task2, task3] # 🔴 Отмена всех задач, связанных с ивентом