mirror of
https://github.com/ada-dmitry/vol_bot.git
synced 2026-09-24 00:30:19 +00:00
Добавление логгирования
This commit is contained in:
+8
-2
@@ -5,24 +5,30 @@ from models import User
|
||||
from database import async_session
|
||||
import os
|
||||
|
||||
|
||||
router = Router()
|
||||
admin_ids = list(map(int, os.getenv("ADMINS").split(",")))
|
||||
|
||||
|
||||
@router.message(F.text == "/admin")
|
||||
async def admin_panel(message: Message):
|
||||
if message.from_user.id not in admin_ids:
|
||||
return await message.answer("Доступ запрещён.")
|
||||
await message.answer("Команды:\n/stat — статистика\n/broadcast <текст> — рассылка")
|
||||
|
||||
|
||||
@router.message(F.text.startswith("/stat"))
|
||||
async def stat_handler(message: Message):
|
||||
if message.from_user.id not in admin_ids:
|
||||
return
|
||||
async with async_session() as session:
|
||||
total = await session.scalar(select(User).count())
|
||||
subscribed = await session.scalar(select(User).where(User.is_subscribed).count())
|
||||
subscribed = await session.scalar(
|
||||
select(User).where(User.is_subscribed).count()
|
||||
)
|
||||
await message.answer(f"Всего пользователей: {total}\nПодписаны: {subscribed}")
|
||||
|
||||
|
||||
@router.message(F.text.startswith("/broadcast "))
|
||||
async def broadcast_handler(message: Message, bot: Bot):
|
||||
if message.from_user.id not in admin_ids:
|
||||
@@ -48,4 +54,4 @@ async def broadcast_handler(message: Message, bot: Bot):
|
||||
except Exception:
|
||||
failed += 1
|
||||
|
||||
await message.answer(f"📬 Рассылка завершена:\nУспешно: {sent}\nОшибок: {failed}")
|
||||
await message.answer(f"📬 Рассылка завершена:\nУспешно: {sent}\nОшибок: {failed}")
|
||||
|
||||
Reference in New Issue
Block a user