main.py

"""Телеграм бот с примеров установки времени рассылки 
и алгоритмом рассылки сообщений без лишний зхапросов к БД"""
import random
import asyncio
from datetime import time, timedelta, datetime
from aiogram import Bot, Dispatcher
from bot.handlers import include_routers
from bot.models import User, UserImageTag, Image
from bot.singleton import GlobalVars
from tok import TOKEN
from parse import parse_image

bot = Bot(token=TOKEN)
dp = Dispatcher()

async def get_time_notify():
    """Получить время ближайшего уведомления"""
    now = datetime.now()
    users = User.filter(User.time > now).order_by(User.time.asc())
    if users.count() > 0:
        return (users.first()).time

async def sending_messages():
    """Рассылка сообщений"""
    GlobalVars.SEND_TIME = await get_time_notify()
    while True:
        now_time = datetime.now().time()
        now_time = time(now_time.hour, now_time.minute)
        if GlobalVars.SEND_TIME and GlobalVars.SEND_TIME == now_time:
            for user in User.filter(time=GlobalVars.SEND_TIME):
                not_sent_images = Image.select().where(~(Image.url << UserImageTag.select(UserImageTag.image).where(UserImageTag.tg_user_id == user.tg_user)))
                if not_sent_images:
                    random_images = random.choice(not_sent_images)
                    await bot.send_photo(user.tg_user, random_images.url)

            # Сохраняем информацию о том, что изображение было отправлено этому пользователю
            UserImageTag.create(tg_user_id=user.tg_user, image=random_images.url, tag='')


            GlobalVars.SEND_TIME = await get_time_notify()

        now_time = (datetime.now() + timedelta(minutes=1))
        now_time = datetime(now_time.year, now_time.month, now_time.day,
                            now_time.hour, now_time.minute)
        seconds = (now_time - datetime.now()).seconds + 1
        await asyncio.sleep(seconds)

async def update_image():
    ''' паралельный процесс'''
    while True:
        await parse_image('https://pikabu.ru/community/mem/search')
        await asyncio.sleep(3600)

async def on_startup():
    """Обертка что бы запустить параллельный процесс"""
    asyncio.create_task(update_image())
    asyncio.create_task(sending_messages())

async def main():
    '''Старт бота'''
    dp.startup.register(on_startup)
    include_routers(dp)
    await dp.start_polling(bot)

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