Как я написал AI-бота на aiogram 3 с помощью нейросетей, выжил при 2500+ пользователей и почему SQLite "всё ещё торт"

			processing_users = set()

def is_user_locked(user_id):
    return user_id in processing_users

def lock_user(user_id):
    processing_users.add(user_id)

def unlock_user(user_id):
    processing_users.discard(user_id)

		

			WAIT_FOR_COMPLETION = [
    "Подожди, я ещё думаю над твоим предыдущим запросом! 😅",
    "Воу-воу, не так быстро! 🏎️\nЯ еще перевариваю твою прошлую задачу. Дай мне пару секунд.",
    "Секундочку... ⏳\nЯ ещё пишу ответ на твой предыдущий запрос. Сейчас всё будет!",
    "Эй, не спамь! ✋\nЯ еще решаю твою прошлую задачу. Дай пару секунд! 😉"
]
		

			@common_router.message(CommandStart())
async def start(message: Message, state: FSMContext, bot: Bot = None, **kwargs):
    try:
        await state.clear()
        user_id = message.from_user.id
        username = message.from_user.username

        referrer_id = None
        partner_code = None
        web_source = None
        from_adv = 0

        args = message.text.split()

        if len(args) > 1:
            potential_arg = args[1]
            if potential_arg == "adv":
                from_adv = 1

            elif potential_arg.startswith("fromweb"):
                web_source = potential_arg

            elif potential_arg.isdigit() and int(potential_arg) != user_id:
                ref_check = await db.get_user(int(potential_arg))
                if ref_check:
                    referrer_id = int(potential_arg)
            else:
                valid_partner = await db.check_partner_code(potential_arg)
                if valid_partner:
                    partner_code = valid_partner
		

			"[СИСТЕМНОЕ ПРИМЕЧАНИЕ: Часть старых фото скрыта для экономии памяти. Ты БОЛЬШЕ НЕ ВИДИШЬ их содержимое. Если пользователь просит уточнить что-то из этих фото — ТЕБЕ КАТЕГОРИЧЕСКИ ЗАПРЕЩЕНО выдумывать задания. Вежливо объясни, что ты помнишь только 10 последних фото, и попроси прислать фото заново.]".
		

			                except TelegramRetryAfter as e:
                    sleep_time = e.retry_after + 1
                    logger.info(f"user_id={user_id} event=FLOOD_WAIT. Спим {sleep_time} сек. Генерация не прервана.")
                    await asyncio.sleep(sleep_time)

		

			                try:
                    logger.error(f"user_id={user_id} event=!!! ОШИБКА в process_gdz_text : {e}. ВОЗВРАЩАЮ ЗАПРОС.", exc_info=True)
                    await db.add_requests(user_id, 1)
                except Exception as db_err:
                    logger.critical(f"Не удалось вернуть запрос пользователю {user_id}: {db_err}")
		

			async def update_daily_bonus_cron():
    global db_writer
    logger.info("⏳ CRON: Запуск ночного обновления и сбор аналитики...")

    expired_users_ids = []
    stats = {}

    now_msk = datetime.utcnow() + timedelta(hours=3)
    target_date_msk = now_msk - timedelta(days=1)
    target_date_str = target_date_msk.strftime('%Y-%m-%d')
    stats['today'] = target_date_str

    start_of_day_utc = (target_date_msk.replace(hour=0, minute=0, second=0) - timedelta(hours=3)).strftime('%Y-%m-%d %H:%M:%S')
    end_of_day_utc = (target_date_msk.replace(hour=23, minute=59, second=59) - timedelta(hours=3)).strftime('%Y-%m-%d %H:%M:%S')

    async with db_lock:
        try:
            # === 1. АУДИТОРИЯ ===

            # Всего пользователей
            async with db_writer.execute("SELECT COUNT(*) FROM users") as cursor:
                stats['total_users'] = (await cursor.fetchone())[0]

            stats['new_organic'] = 0
            stats['new_site'] = 0
            stats['new_ads'] = 0
            stats['new_referrals'] = 0
            stats['new_partners'] = 0

            start_msk = f"{target_date_str} 00:00:00"
            end_msk = f"{target_date_str} 23:59:59"

            async with db_writer.execute("SELECT from_adv, web_source, referred_by, partner_source FROM users WHERE reg_date >= ? AND reg_date <= ?",(start_msk, end_msk)) as cursor:
                rows = await cursor.fetchall()
                stats['new_users'] = len(rows)
                for r in rows:
                    if r['from_adv']:
                        stats['new_ads'] += 1
                    elif r['web_source']:
                        stats['new_site'] += 1
                    elif r['partner_source']:
                        stats['new_partners'] += 1
                    elif r['referred_by']:
                        stats['new_referrals'] += 1
                    else:
                        stats['new_organic'] += 1

            # Активность (1 - фри, 2 - прем)
            stats['active_free'] = 0
            stats['active_prem'] = 0
            async with db_writer.execute("SELECT was_active_today, COUNT(*) FROM users WHERE was_active_today >= 1 GROUP BY was_active_today") as cursor:
                active_rows = await cursor.fetchall()
                for r in active_rows:
                    if r[0] == 1:
                        stats['active_free'] = r[1]
                    elif r[0] == 2:
                        stats['active_prem'] = r[1]
                stats['active_today'] = stats['active_free'] + stats['active_prem']

            async with db_writer.execute("SELECT COUNT(*) FROM users WHERE requests_left <= 0") as cursor:
                stats['limit_hitters'] = (await cursor.fetchone())[0]

            async with db_writer.execute("SELECT COUNT(*) FROM users WHERE subscription_status = 'active'") as cursor:
                stats['active_subs'] = (await cursor.fetchone())[0]

            # === 2. ДЕНЬГИ ===
            stats['success_count'] = 0
            stats['revenue'] = 0
            stats['new_clients'] = 0
            stats['regular_clients'] = 0
            stats['abandoned_carts'] = 0
            stats['lost_money'] = 0

            async with db_writer.execute("""SELECT user_id, amount, status FROM payments WHERE created_at >= ? AND created_at <= ?""", (start_of_day_utc, end_of_day_utc)) as cursor:
                payments_today = await cursor.fetchall()

            # Ищем, кто из сегодняшних "успешных" платил раньше, чтобы определить постоянников
            success_user_ids = [p['user_id'] for p in payments_today if p['status'] in ('success', 'succeeded')]
            regular_users_set = set()

            if success_user_ids:
                placeholders = ','.join('?' for _ in success_user_ids)
                query = f"""SELECT DISTINCT user_id FROM payments WHERE status IN ('success', 'succeeded') AND created_at < ? AND user_id IN ({placeholders})"""
                async with db_writer.execute(query, [start_of_day_utc] + success_user_ids) as cursor:
                    prev_users = await cursor.fetchall()
                    regular_users_set = {r['user_id'] for r in prev_users}

            # Распределяем платежи
            for p in payments_today:
                if p['status'] in ('success', 'succeeded'):
                    stats['success_count'] += 1
                    stats['revenue'] += p['amount']
                    if p['user_id'] in regular_users_set:
                        stats['regular_clients'] += 1
                    else:
                        stats['new_clients'] += 1
                        # Если этот же юзер купит сегодня еще раз, второй платеж пойдет как от постоянника
                        regular_users_set.add(p['user_id'])
                elif p['status'] in ('pending', 'canceled'):
                    stats['abandoned_carts'] += 1
                    stats['lost_money'] += p['amount']

            # === 3. ЕЖЕДНЕВНЫЙ СБРОС И ВЫДАЧА БОНУСА ===
            async with db_writer.execute("UPDATE users SET requests_left = requests_left + 1 WHERE was_active_today = 1 OR requests_left <= 0"): pass
            async with db_writer.execute("UPDATE users SET was_active_today = 0"): pass

            # === 4. ПРОВЕРКА ИСТЕКШИХ ПОДПИСОК ===
            check_time = (datetime.utcnow() + timedelta(hours=3)).strftime('%Y-%m-%d %H:%M:%S')

            async with db_writer.execute("""
                    SELECT user_id FROM users 
                    WHERE subscription_status = 'active' AND subscription_expiry_date < ?
                """, (check_time,)) as cursor:
                rows = await cursor.fetchall()
                expired_users_ids = [row['user_id'] for row in rows]

            async with db_writer.execute("""
                    UPDATE users SET subscription_status = 'expired' 
                    WHERE subscription_status = 'active' AND subscription_expiry_date < ?
                """, (check_time,)) as cursor:
                expired_count = cursor.rowcount

            await db_writer.commit()
            logger.info(f"✅ CRON: Обновление завершено. Истекло подписок: {expired_count}")
            return expired_users_ids, stats

        except Exception as e:
            await db_writer.rollback()
            logger.error(f"Ошибка при ночном обновлении CRON: {e}")
            raise e
		

			    run_time_5m = datetime.now(ZoneInfo("Europe/Moscow")) + timedelta(minutes=5)
    scheduler.add_job(
        auto_check_payment,
        trigger='date',
        run_date=run_time_5m,
        jobstore='memory',
        args=[bot, str(inv_id), user_id, username, False, None, None]
    )

    run_time_30m = datetime.now(ZoneInfo("Europe/Moscow")) + timedelta(minutes=30)
    scheduler.add_job(
        auto_check_payment,
        trigger='date',
        run_date=run_time_30m,
        jobstore='memory',
        args=[bot, str(inv_id), user_id, username, True, payment_url, desc],
        misfire_grace_time=3600
    )