# Изменены параметры и добавлена логика для удаления событий
This commit is contained in:
23
main.py
23
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]
|
||||
|
||||
# 🔴 Отмена всех задач, связанных с ивентом
|
||||
|
||||
Reference in New Issue
Block a user