From 50eba2d0937672475b41ee50bc3ab226be667d9c Mon Sep 17 00:00:00 2001
From: Capybara-z <stas89091000@yandex.ru>
Date: Thu, 3 Apr 2025 02:06:28 +0300
Subject: [PATCH] =?UTF-8?q?=D0=9F=D0=B5=D1=80=D0=B5=D0=BD=D0=B5=D1=81?=
 =?UTF-8?q?=D0=B0=D0=BD=D0=B0=20=D0=BB=D0=BE=D0=B3=D0=B8=D0=BA=D0=B0=20?=
 =?UTF-8?q?=D0=BA=D1=83=D0=BF=D0=BE=D0=BD=D0=BE=D0=B2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- Логика купонов перенесена в свое место.
---
 handlers/start.py | 44 +++-----------------------------------------
 1 file changed, 3 insertions(+), 41 deletions(-)

diff --git a/handlers/start.py b/handlers/start.py
index c68c2f7c..e355bd55 100644
--- a/handlers/start.py
+++ b/handlers/start.py
@@ -31,6 +31,7 @@ from database import (
     get_trial,
     update_balance,
 )
+from handlers.admin.coupons.coupons_handler import handle_coupon_activation
 from handlers.buttons import ABOUT_VPN, BACK, CHANNEL, MAIN_MENU, SUPPORT
 from handlers.captcha import generate_captcha
 from handlers.keys.key_management import create_key
@@ -119,47 +120,8 @@ async def process_start_logic(
         try:
             if "coupons_" in text:
                 logger.info(f"Обнаружена ссылка на купон: {text}")
-                coupon_code = text.split("coupons_")[1].strip()
-
-                coupon = await session.fetchrow(
-                    "SELECT id, code, amount, usage_limit, usage_count, is_used FROM coupons WHERE code = $1",
-                    coupon_code,
-                )
-                if not coupon:
-                    await message.answer("❌ Купон не найден!")
-                    return await process_callback_view_profile(message, state, admin)
-
-                usage_exists = await session.fetchval(
-                    "SELECT 1 FROM coupon_usages WHERE coupon_id = $1 AND user_id = $2",
-                    coupon["id"],
-                    message.chat.id,
-                )
-                if usage_exists:
-                    await message.answer("❌ Вы уже использовали этот купон!")
-                    return await process_callback_view_profile(message, state, admin)
-
-                if coupon["is_used"] or coupon["usage_count"] >= coupon["usage_limit"]:
-                    await message.answer("❌ Этот купон уже использован!")
-                    return await process_callback_view_profile(message, state, admin)
-
-                connection_exists = await check_connection_exists(message.chat.id)
-                if not connection_exists:
-                    await add_connection(tg_id=message.chat.id, session=session)
-
-                await update_balance(message.chat.id, coupon["amount"])
-                await session.execute(
-                    "UPDATE coupons SET usage_count = $1, is_used = $2 WHERE code = $3",
-                    coupon["usage_count"] + 1,
-                    coupon["usage_count"] + 1 >= coupon["usage_limit"],
-                    coupon_code,
-                )
-                await session.execute(
-                    "INSERT INTO coupon_usages (coupon_id, user_id, used_at) VALUES ($1, $2, NOW())",
-                    coupon["id"],
-                    message.chat.id,
-                )
-                await message.answer(COUPON_SUCCESS_MSG.format(amount=coupon["amount"]))
-                return await process_callback_view_profile(message, state, admin)
+                await handle_coupon_activation(message, state, session)
+                return
 
             if "gift_" in text:
                 parts = text.split("gift_")[1].split("_")