Не отправляется рассылка в боте telegram?

Question

[Dezzly]

import asyncio
import logging

from aiogram import Bot, Dispatcher, types, F
from aiogram.filters import CommandStart, Command
from aiogram.types import Message
from aiogram import Router
from aiogram.fsm.context import FSMContext
from aiogram.fsm.state import State, StatesGroup

from config import TOKEN

# Логирование
logging.basicConfig(level=logging.INFO)

# ID администратора
ADMIN_ID = **********

# Файл для хранения ID пользователей
USERS_FILE = "users.txt"

# Инициализация бота
bot = Bot(token=TOKEN)
dp = Dispatcher()
router = Router()

# Состояния FSM
class States(StatesGroup):
    broadcast = State()

def save_user_id(user_id):
    """Сохраняет ID пользователя в файл."""
    with open(USERS_FILE, "a+", encoding="utf-8") as f:
        f.seek(0)
        if str(user_id) not in f.read():
            f.write(f"{user_id}\n")

def get_user_ids():
    """Возвращает список ID пользователей из файла."""
    try:
        with open(USERS_FILE, "r", encoding="utf-8") as f:
            return [int(line.strip()) for line in f]
    except FileNotFoundError:
        return []

# Обработчик команды /start
@router.message(CommandStart())
async def cmd_start(message: Message, state: FSMContext):
    user_id = message.from_user.id
    save_user_id(user_id)
    await message.answer("Привет! Ты зарегистрирован для получения рассылки.")

# Обработчик команды /admin
@router.message(Command("admin"))
async def cmd_admin(message: Message, state: FSMContext):
    user_id = message.from_user.id
    if user_id == ADMIN_ID:
        await state.set_state(States.broadcast)
        await message.answer("Введите текст для рассылки:")
    else:
        await message.answer("У вас нет прав доступа.")

# Обработчик текста для рассылки
@router.message(F.state == States.broadcast)
async def process_broadcast(message: Message, state: FSMContext):
    text = message.text
    await state.finish()

    print(f"Получен текст для рассылки: {text}")

    for user_id in get_user_ids():
        try:
            await bot.send_message(chat_id=user_id, text=text)
            print(f"Сообщение отправлено пользователю {user_id}")
        except Exception as e:
            print(f"Ошибка при отправке сообщения пользователю {user_id}: {e}")

    await message.answer(f"Рассылка отправлена!")

# Регистрация роутера
dp.include_router(router)

# Запуск бота
async def main():
    await dp.start_polling(bot)

if __name__ == '__main__':
    asyncio.run(main())

Comments

[Константин Нагибович]

Проблема в отступах.

[Dezzly]

Константин Нагибович, IDE ни на один отступ не ругается. Если ты имеешь ввиду что здесь все слитно, то это сайт так отобразил в коде у меня все отступы соблюдены

[Михаил Кростелев]

ну а в консоли что выводится? Ошибка может какая? нужно больше информации

[Михаил Кростелев]

а @ у router в оригинале стоит? Это же декоратор все-таки

[Dezzly]

Михаил Кростелев, "F.state == States.broadcast" удалил в обработчики рассылки и все заработало, но проблема в том что теперь отправляется при вводе любого текста в чат

Answer 1

[Михаил Кростелев]

в роутере попробуйте внести изменения

@router.message(States.broadcast)
async def process_broadcast(message: Message, state: FSMContext):
    text = message.text
    await state.finish()
    ...