UI: карточки подписок и выбор тарифов
This commit is contained in:
@@ -1,102 +1,376 @@
|
|||||||
from aiogram import Router, types
|
from aiogram import Router, types
|
||||||
import logging
|
|
||||||
from instences.config import BASE_URL_FASTAPI
|
|
||||||
import aiohttp
|
|
||||||
from aiogram.enums.parse_mode import ParseMode
|
from aiogram.enums.parse_mode import ParseMode
|
||||||
from aiogram.filters import Command
|
from aiogram.filters import Command
|
||||||
|
import logging
|
||||||
|
from datetime import datetime
|
||||||
|
import aiohttp
|
||||||
|
|
||||||
|
from instences.config import BASE_URL_FASTAPI
|
||||||
from keyboard.keyboards import (
|
from keyboard.keyboards import (
|
||||||
tarif_Lark_pro_keyboard,
|
buy_keyboard,
|
||||||
tarif_Lark_keyboard,
|
tarif_Lark_keyboard,
|
||||||
|
tarif_Lark_pro_keyboard,
|
||||||
tarif_Lark_family_keyboard,
|
tarif_Lark_family_keyboard,
|
||||||
tarif_confirm_keyboard,
|
tarif_confirm_keyboard,
|
||||||
buy_keyboard,
|
subscriptions_card_keyboard,
|
||||||
)
|
)
|
||||||
|
|
||||||
router = Router()
|
router = Router()
|
||||||
logger = logging.getLogger(__name__)
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
|
|
||||||
async def call_api(method, endpoint, data=None):
|
async def call_api(method: str, endpoint: str, data: dict | None = None):
|
||||||
"""
|
"""
|
||||||
Выполняет HTTP-запрос к FastAPI.
|
Унифицированный вызов backend API.
|
||||||
"""
|
"""
|
||||||
url = f"{BASE_URL_FASTAPI}{endpoint}"
|
url = f"{BASE_URL_FASTAPI}{endpoint}"
|
||||||
logger.info(f"Инициализация запроса: {method} {url} с данными {data}")
|
logger.info(f"API {method} {url} data={data}")
|
||||||
|
|
||||||
try:
|
try:
|
||||||
async with aiohttp.ClientSession() as session:
|
async with aiohttp.ClientSession() as session:
|
||||||
async with session.request(method, url, json=data) as response:
|
async with session.request(method, url, json=data) as resp:
|
||||||
logger.info(
|
logger.info(f"API response {resp.status} {resp.reason}")
|
||||||
f"Получен ответ от {url}: статус {response.status}")
|
if resp.status in {200, 201}:
|
||||||
|
return await resp.json()
|
||||||
if response.status in {200, 201}:
|
if resp.status in {400, 404}:
|
||||||
result = await response.json()
|
# Возвращаем JSON с detail, чтобы разобрать ошибку
|
||||||
logger.debug(f"Ответ JSON: {result}")
|
try:
|
||||||
return result
|
return await resp.json()
|
||||||
if response.status in {404, 400}:
|
except Exception:
|
||||||
result = await response.json()
|
return None
|
||||||
logger.debug(f"Код {response.status}, возвращаю {result}")
|
logger.error(f"Unexpected status {resp.status}: {await resp.text()}")
|
||||||
return result
|
|
||||||
logger.error(
|
|
||||||
f"Ошибка в запросе: статус {response.status}, причина {response.reason}")
|
|
||||||
return "ERROR"
|
return "ERROR"
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.exception(f"Исключение при выполнении запроса к {url}: {e}")
|
logger.exception(f"API exception {url}: {e}")
|
||||||
return "ERROR"
|
return "ERROR"
|
||||||
|
|
||||||
|
|
||||||
def escape_markdown_v2(text: str) -> str:
|
def escape_markdown_v2(text: str) -> str:
|
||||||
"""
|
"""
|
||||||
Экранирует специальные символы для Markdown_V2.
|
Экранирует спецсимволы для Markdown_V2.
|
||||||
"""
|
"""
|
||||||
special_chars = r"_*[]()~`>#+-=|{}.!"
|
special_chars = r"_*[]()~`>#+-=|{}.!\\"
|
||||||
for char in special_chars:
|
for ch in special_chars:
|
||||||
text = text.replace(char, f"\\{char}")
|
text = text.replace(ch, f"\\{ch}")
|
||||||
return text
|
return text
|
||||||
|
|
||||||
|
|
||||||
@router.message(Command("subscriptions"))
|
def _plan_human_title(plan: str) -> str:
|
||||||
async def supp(message: types.Message):
|
|
||||||
"""
|
"""
|
||||||
Меню системы подписок
|
Красивое имя тарифа по plan-строке из БД.
|
||||||
"""
|
"""
|
||||||
text = ""
|
if not plan:
|
||||||
uri = None # Инициализация переменной
|
return "—"
|
||||||
try:
|
if plan.startswith("Lark_Standart"):
|
||||||
# Вызов API для получения URI
|
return "Lark Basic"
|
||||||
result = await call_api("GET", f"/uri?telegram_id={message.from_user.id}")
|
if plan.startswith("Lark_Pro"):
|
||||||
# Получаем URI из ответа или "Error", если ключ отсутствует
|
return "Lark Pro"
|
||||||
uri = result.get('detail', "Error")
|
if plan.startswith("Lark_Family"):
|
||||||
|
return "Lark Family"
|
||||||
|
return plan
|
||||||
|
|
||||||
# Проверка результата
|
|
||||||
if uri == "Error":
|
async def _fetch_user_and_subs(telegram_id: int):
|
||||||
text = escape_markdown_v2("Произошла ошибка при получении URI")
|
"""
|
||||||
elif uri == "SUB_ERROR":
|
Берём пользователя и список его подписок с backend.
|
||||||
text = escape_markdown_v2("Вы ещё не приобрели подписки!!")
|
"""
|
||||||
elif "vless" in uri:
|
user = await call_api("GET", f"/user/{telegram_id}")
|
||||||
escaped_uri = escape_markdown_v2(uri) # Экранирование URI
|
if not user or not isinstance(user, dict):
|
||||||
text = f"Ваша подписка: ```{escaped_uri}```"
|
return None, []
|
||||||
|
|
||||||
|
user_id = user["id"]
|
||||||
|
subs = await call_api("GET", f"/subscriptions/{user_id}")
|
||||||
|
|
||||||
|
if subs == "ERROR" or not isinstance(subs, list):
|
||||||
|
subs = []
|
||||||
|
|
||||||
|
return user, subs
|
||||||
|
|
||||||
|
|
||||||
|
async def _show_subscriptions_view(
|
||||||
|
msg: types.Message,
|
||||||
|
telegram_id: int,
|
||||||
|
index: int = 0,
|
||||||
|
edit: bool = False,
|
||||||
|
):
|
||||||
|
"""
|
||||||
|
Рендер карточки подписки: навигация + конфиг + продление.
|
||||||
|
"""
|
||||||
|
user, subs = await _fetch_user_and_subs(telegram_id)
|
||||||
|
|
||||||
|
if not user:
|
||||||
|
text = "Не удалось получить данные пользователя. Попробуй чуть позже."
|
||||||
|
if edit:
|
||||||
|
await msg.edit_text(text)
|
||||||
else:
|
else:
|
||||||
text = escape_markdown_v2("Произошла ошибка при обработке URI")
|
await msg.answer(text)
|
||||||
except Exception as e:
|
return
|
||||||
# Логирование ошибок
|
|
||||||
logger.error(f"Ошибка при вызове API для подписки: {e}")
|
|
||||||
text = escape_markdown_v2(
|
|
||||||
"Произошла неожиданная ошибка при получении подписки.")
|
|
||||||
|
|
||||||
# Ответ пользователю
|
if not subs:
|
||||||
await message.answer(
|
text = (
|
||||||
text,
|
"⚪ У тебя пока нет активных подписок.\n\n"
|
||||||
parse_mode=ParseMode.MARKDOWN_V2
|
"Можешь подключить тариф через меню подписок."
|
||||||
|
)
|
||||||
|
if edit:
|
||||||
|
await msg.edit_text(
|
||||||
|
text,
|
||||||
|
parse_mode=ParseMode.HTML,
|
||||||
|
reply_markup=buy_keyboard(),
|
||||||
|
)
|
||||||
|
else:
|
||||||
|
await msg.answer(
|
||||||
|
text,
|
||||||
|
parse_mode=ParseMode.HTML,
|
||||||
|
reply_markup=buy_keyboard(),
|
||||||
|
)
|
||||||
|
return
|
||||||
|
|
||||||
|
# Нормализуем индекс
|
||||||
|
index = max(0, min(index, len(subs) - 1))
|
||||||
|
sub = subs[index]
|
||||||
|
|
||||||
|
plan_title = _plan_human_title(sub.get("plan"))
|
||||||
|
expiry_raw = sub.get("expiry_date")
|
||||||
|
date_str = "—"
|
||||||
|
days_left = None
|
||||||
|
status_emoji = "🟢"
|
||||||
|
|
||||||
|
if expiry_raw:
|
||||||
|
try:
|
||||||
|
dt = datetime.fromisoformat(expiry_raw)
|
||||||
|
date_str = dt.strftime("%d.%m.%Y")
|
||||||
|
now = datetime.now(dt.tzinfo) if dt.tzinfo else datetime.now()
|
||||||
|
days_left = (dt.date() - now.date()).days
|
||||||
|
if days_left < 0:
|
||||||
|
status_emoji = "⚫"
|
||||||
|
else:
|
||||||
|
status_emoji = "🟢"
|
||||||
|
except ValueError:
|
||||||
|
status_emoji = "⚪"
|
||||||
|
|
||||||
|
lines = [
|
||||||
|
f"{status_emoji} <b>Подписка</b>",
|
||||||
|
f"Тариф: {plan_title}",
|
||||||
|
]
|
||||||
|
|
||||||
|
if days_left is None:
|
||||||
|
lines.append(f"Действует до {date_str}")
|
||||||
|
else:
|
||||||
|
if days_left >= 0:
|
||||||
|
lines.append(f"Действует до {date_str} (ещё {days_left} дн.)")
|
||||||
|
else:
|
||||||
|
lines.append(f"Истекла {date_str}")
|
||||||
|
|
||||||
|
lines.append("")
|
||||||
|
lines.append(f"{index + 1} из {len(subs)}")
|
||||||
|
|
||||||
|
text = "\n".join(lines)
|
||||||
|
|
||||||
|
kb = subscriptions_card_keyboard(
|
||||||
|
sub_id=sub["id"],
|
||||||
|
index=index,
|
||||||
|
total=len(subs),
|
||||||
)
|
)
|
||||||
|
|
||||||
|
if edit:
|
||||||
|
await msg.edit_text(text, parse_mode=ParseMode.HTML, reply_markup=kb)
|
||||||
|
else:
|
||||||
|
await msg.answer(text, parse_mode=ParseMode.HTML, reply_markup=kb)
|
||||||
|
|
||||||
|
|
||||||
|
# ===== Мои подписки / карточка =====
|
||||||
|
|
||||||
|
@router.message(Command("subscriptions"))
|
||||||
|
async def cmd_subscriptions(message: types.Message):
|
||||||
|
"""
|
||||||
|
/subscriptions — открыть карточку подписок.
|
||||||
|
"""
|
||||||
|
await _show_subscriptions_view(
|
||||||
|
msg=message,
|
||||||
|
telegram_id=message.from_user.id,
|
||||||
|
index=0,
|
||||||
|
edit=False,
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
@router.callback_query(lambda c: c.data == "go_subscriptions")
|
||||||
|
async def cb_go_subscriptions(callback: types.CallbackQuery):
|
||||||
|
"""
|
||||||
|
Кнопка из других экранов — перейти в 'Мои подписки'.
|
||||||
|
"""
|
||||||
|
await _show_subscriptions_view(
|
||||||
|
msg=callback.message,
|
||||||
|
telegram_id=callback.from_user.id,
|
||||||
|
index=0,
|
||||||
|
edit=True,
|
||||||
|
)
|
||||||
|
await callback.answer()
|
||||||
|
|
||||||
|
|
||||||
|
@router.callback_query(lambda c: c.data.startswith("sub_prev:"))
|
||||||
|
async def cb_sub_prev(callback: types.CallbackQuery):
|
||||||
|
"""
|
||||||
|
Навигация: предыдущая подписка.
|
||||||
|
"""
|
||||||
|
try:
|
||||||
|
index = int(callback.data.split(":")[1])
|
||||||
|
except (IndexError, ValueError):
|
||||||
|
index = 0
|
||||||
|
|
||||||
|
await _show_subscriptions_view(
|
||||||
|
msg=callback.message,
|
||||||
|
telegram_id=callback.from_user.id,
|
||||||
|
index=index,
|
||||||
|
edit=True,
|
||||||
|
)
|
||||||
|
await callback.answer()
|
||||||
|
|
||||||
|
|
||||||
|
@router.callback_query(lambda c: c.data.startswith("sub_next:"))
|
||||||
|
async def cb_sub_next(callback: types.CallbackQuery):
|
||||||
|
"""
|
||||||
|
Навигация: следующая подписка.
|
||||||
|
"""
|
||||||
|
try:
|
||||||
|
index = int(callback.data.split(":")[1])
|
||||||
|
except (IndexError, ValueError):
|
||||||
|
index = 0
|
||||||
|
|
||||||
|
await _show_subscriptions_view(
|
||||||
|
msg=callback.message,
|
||||||
|
telegram_id=callback.from_user.id,
|
||||||
|
index=index,
|
||||||
|
edit=True,
|
||||||
|
)
|
||||||
|
await callback.answer()
|
||||||
|
|
||||||
|
|
||||||
|
@router.callback_query(lambda c: c.data.startswith("sub_cfg:"))
|
||||||
|
async def cb_sub_cfg(callback: types.CallbackQuery):
|
||||||
|
"""
|
||||||
|
Кнопка 'Конфиг' в карточке подписки.
|
||||||
|
Тянем URI через /uri?telegram_id=...
|
||||||
|
"""
|
||||||
|
result = await call_api(
|
||||||
|
"GET",
|
||||||
|
f"/uri?telegram_id={callback.from_user.id}",
|
||||||
|
)
|
||||||
|
|
||||||
|
if result == "ERROR" or not isinstance(result, dict):
|
||||||
|
await callback.message.answer(
|
||||||
|
"Не удалось получить конфиг. Попробуй позже."
|
||||||
|
)
|
||||||
|
await callback.answer()
|
||||||
|
return
|
||||||
|
|
||||||
|
detail = result.get("detail")
|
||||||
|
|
||||||
|
if detail == "SUB_ERROR":
|
||||||
|
await callback.message.answer(
|
||||||
|
"У тебя нет активной подписки для генерации конфига."
|
||||||
|
)
|
||||||
|
await callback.answer()
|
||||||
|
return
|
||||||
|
|
||||||
|
if not isinstance(detail, str) or not detail:
|
||||||
|
await callback.message.answer(
|
||||||
|
"Что-то пошло не так при выдаче конфига."
|
||||||
|
)
|
||||||
|
await callback.answer()
|
||||||
|
return
|
||||||
|
|
||||||
|
escaped = escape_markdown_v2(detail)
|
||||||
|
text = f"Твой конфиг:\n```{escaped}```"
|
||||||
|
|
||||||
|
await callback.message.answer(
|
||||||
|
text,
|
||||||
|
parse_mode=ParseMode.MARKDOWN_V2,
|
||||||
|
)
|
||||||
|
await callback.answer()
|
||||||
|
|
||||||
|
|
||||||
|
@router.callback_query(lambda c: c.data.startswith("sub_renew:"))
|
||||||
|
async def cb_sub_renew(callback: types.CallbackQuery):
|
||||||
|
"""
|
||||||
|
Кнопка 'Продлить' в карточке подписки.
|
||||||
|
По факту — повторный /subscription/buy с тем же планом.
|
||||||
|
"""
|
||||||
|
sub_id = callback.data.split(":", maxsplit=1)[
|
||||||
|
1] if ":" in callback.data else None
|
||||||
|
user, subs = await _fetch_user_and_subs(callback.from_user.id)
|
||||||
|
|
||||||
|
if not user or not subs:
|
||||||
|
await callback.message.answer("Подписка не найдена.")
|
||||||
|
await callback.answer()
|
||||||
|
return
|
||||||
|
|
||||||
|
target = next((s for s in subs if s.get("id") == sub_id), None)
|
||||||
|
if not target:
|
||||||
|
await callback.message.answer("Подписка не найдена.")
|
||||||
|
await callback.answer()
|
||||||
|
return
|
||||||
|
|
||||||
|
plan_id = target.get("plan")
|
||||||
|
if not plan_id:
|
||||||
|
await callback.message.answer("Не удалось определить тариф для продления.")
|
||||||
|
await callback.answer()
|
||||||
|
return
|
||||||
|
|
||||||
|
result = await call_api(
|
||||||
|
"POST",
|
||||||
|
"/subscription/buy",
|
||||||
|
{"telegram_id": str(callback.from_user.id), "plan_id": plan_id},
|
||||||
|
)
|
||||||
|
|
||||||
|
# Ошибки backend (detail)
|
||||||
|
if result == "ERROR" or not isinstance(result, dict):
|
||||||
|
await callback.message.answer("Ошибка при продлении. Попробуй позже.")
|
||||||
|
await callback.answer()
|
||||||
|
return
|
||||||
|
|
||||||
|
detail = result.get("detail")
|
||||||
|
if detail == "INSUFFICIENT_FUNDS":
|
||||||
|
await callback.message.answer("Недостаточно средств на балансе.")
|
||||||
|
await callback.answer()
|
||||||
|
return
|
||||||
|
if detail == "TARIFF_NOT_FOUND":
|
||||||
|
await callback.message.answer("Тариф не найден.")
|
||||||
|
await callback.answer()
|
||||||
|
return
|
||||||
|
if detail == "ACTIVE_SUBSCRIPTION_EXISTS":
|
||||||
|
await callback.message.answer("У тебя уже есть активная подписка этого типа.")
|
||||||
|
await callback.answer()
|
||||||
|
return
|
||||||
|
|
||||||
|
# Успех — backend вернёт message с URI
|
||||||
|
uri = result.get("message")
|
||||||
|
if isinstance(uri, str) and uri:
|
||||||
|
escaped_uri = escape_markdown_v2(uri)
|
||||||
|
await callback.message.answer(
|
||||||
|
"Подписка успешно продлена.\n"
|
||||||
|
f"Твой конфиг:\n```{escaped_uri}```",
|
||||||
|
parse_mode=ParseMode.MARKDOWN_V2,
|
||||||
|
)
|
||||||
|
else:
|
||||||
|
await callback.message.answer("Подписка успешно продлена.")
|
||||||
|
|
||||||
|
# Перерисовать карточку (обновлённый список)
|
||||||
|
await _show_subscriptions_view(
|
||||||
|
msg=callback.message,
|
||||||
|
telegram_id=callback.from_user.id,
|
||||||
|
index=0,
|
||||||
|
edit=True,
|
||||||
|
)
|
||||||
|
await callback.answer()
|
||||||
|
|
||||||
|
|
||||||
|
# ===== Меню покупки подписки (Basic / Pro / Family) =====
|
||||||
|
|
||||||
@router.callback_query(lambda callback: callback.data == "buy_subscription")
|
@router.callback_query(lambda callback: callback.data == "buy_subscription")
|
||||||
async def buy_subscription_callback_handler(callback: types.CallbackQuery):
|
async def buy_subscription_callback_handler(callback: types.CallbackQuery):
|
||||||
"""
|
"""
|
||||||
Меню выбора тарифа: Basic / Pro / Family + показ баланса.
|
Меню выбора тарифа: Basic / Pro / Family + показ баланса.
|
||||||
"""
|
"""
|
||||||
# Тянем пользователя, чтобы показать баланс
|
|
||||||
user_data = await call_api("GET", f"/user/{callback.from_user.id}")
|
user_data = await call_api("GET", f"/user/{callback.from_user.id}")
|
||||||
balance = user_data.get("balance", 0) if user_data else "?"
|
balance = user_data.get("balance", 0) if user_data else "?"
|
||||||
|
|
||||||
@@ -120,32 +394,34 @@ async def buy_subscription_callback_handler(callback: types.CallbackQuery):
|
|||||||
@router.callback_query(lambda callback: callback.data == "subs")
|
@router.callback_query(lambda callback: callback.data == "subs")
|
||||||
async def subs_callback_handler(callback: types.CallbackQuery):
|
async def subs_callback_handler(callback: types.CallbackQuery):
|
||||||
"""
|
"""
|
||||||
Обработчик callback_query с data="subs".
|
Кнопка 'Lark Basic' — раскрываем варианты сроков.
|
||||||
"""
|
"""
|
||||||
await callback.message.edit_text(
|
await callback.message.edit_text(
|
||||||
"Подписки птенчик",
|
"Тариф Lark Basic — выбери срок:",
|
||||||
reply_markup=tarif_Lark_keyboard()
|
reply_markup=tarif_Lark_keyboard(),
|
||||||
)
|
)
|
||||||
|
await callback.answer()
|
||||||
|
|
||||||
|
|
||||||
@router.callback_query(lambda callback: callback.data == "subs_pro")
|
@router.callback_query(lambda callback: callback.data == "subs_pro")
|
||||||
async def subs_pro_callback_handler(callback: types.CallbackQuery):
|
async def subs_pro_callback_handler(callback: types.CallbackQuery):
|
||||||
"""
|
"""
|
||||||
Обработчик callback_query с data="subs_pro".
|
Кнопка 'Lark Pro'.
|
||||||
"""
|
"""
|
||||||
await callback.message.edit_text(
|
await callback.message.edit_text(
|
||||||
"Подписки птенчик ПРО",
|
"Тариф Lark Pro — выбери срок:",
|
||||||
reply_markup=tarif_Lark_pro_keyboard()
|
reply_markup=tarif_Lark_pro_keyboard(),
|
||||||
)
|
)
|
||||||
|
await callback.answer()
|
||||||
|
|
||||||
|
|
||||||
@router.callback_query(lambda callback: callback.data == "subs_family")
|
@router.callback_query(lambda callback: callback.data == "subs_family")
|
||||||
async def subs_family_callback_handler(callback: types.CallbackQuery):
|
async def subs_family_callback_handler(callback: types.CallbackQuery):
|
||||||
"""
|
"""
|
||||||
Обработчик callback_query с data="subs_family".
|
Кнопка 'Lark Family'.
|
||||||
"""
|
"""
|
||||||
await callback.message.edit_text(
|
await callback.message.edit_text(
|
||||||
"Подписки Lark Family",
|
"Тариф Lark Family — выбери срок:",
|
||||||
reply_markup=tarif_Lark_family_keyboard(),
|
reply_markup=tarif_Lark_family_keyboard(),
|
||||||
)
|
)
|
||||||
await callback.answer()
|
await callback.answer()
|
||||||
@@ -154,56 +430,83 @@ async def subs_family_callback_handler(callback: types.CallbackQuery):
|
|||||||
@router.callback_query(lambda callback: callback.data.startswith("Lark:"))
|
@router.callback_query(lambda callback: callback.data.startswith("Lark:"))
|
||||||
async def lark_tariff_callback_handler(callback: types.CallbackQuery):
|
async def lark_tariff_callback_handler(callback: types.CallbackQuery):
|
||||||
"""
|
"""
|
||||||
Обработчик для выбора тарифа Lark.
|
Обработчик выбора конкретного тарифа Lark.
|
||||||
|
callback_data: Lark:<Class>:<months>
|
||||||
"""
|
"""
|
||||||
data = callback.data.split(":")
|
try:
|
||||||
tariff_name = data[0]
|
_, tariff_class, months_str = callback.data.split(":")
|
||||||
tariff_class = data[1]
|
months = int(months_str)
|
||||||
tariff_time = int(data[2])
|
except Exception:
|
||||||
|
await callback.message.answer("Некорректные данные тарифа.")
|
||||||
|
await callback.answer()
|
||||||
|
return
|
||||||
|
|
||||||
# Определение окончания для месяцев
|
if months == 1:
|
||||||
if tariff_time == 1:
|
months_label = "1 месяц"
|
||||||
months = f"{tariff_time} месяц"
|
elif 2 <= months <= 4:
|
||||||
elif 2 <= tariff_time <= 4:
|
months_label = f"{months} месяца"
|
||||||
months = f"{tariff_time} месяца"
|
|
||||||
else:
|
else:
|
||||||
months = f"{tariff_time} месяцев"
|
months_label = f"{months} месяцев"
|
||||||
|
|
||||||
text = f"Тариф {tariff_name} на {months}. Продолжите покупку..."
|
text = f"Тариф Lark {tariff_class} на {months_label}. Продолжить покупку?"
|
||||||
|
|
||||||
# Рендеринг клавиатуры
|
keyboard = tarif_confirm_keyboard("Lark", months, tariff_class)
|
||||||
keyboard = tarif_confirm_keyboard(tariff_name, tariff_time, tariff_class)
|
|
||||||
await callback.message.edit_text(text=text, reply_markup=keyboard)
|
await callback.message.edit_text(text=text, reply_markup=keyboard)
|
||||||
|
await callback.answer()
|
||||||
|
|
||||||
|
|
||||||
@router.callback_query(lambda callback: callback.data.startswith("confirm:"))
|
@router.callback_query(lambda callback: callback.data.startswith("confirm:"))
|
||||||
async def confirm_callback_handler(callback: types.CallbackQuery):
|
async def confirm_callback_handler(callback: types.CallbackQuery):
|
||||||
"""
|
"""
|
||||||
Обработчик подтверждения подписки.
|
Подтверждение покупки тарифа.
|
||||||
"""
|
"""
|
||||||
try:
|
try:
|
||||||
data = callback.data.split(":")[1]
|
data = callback.data.split(":", maxsplit=1)[1]
|
||||||
tariff_info = data.split("_")
|
name, classif, amount_str = data.split("_")
|
||||||
plan_id = f"{tariff_info[0]}_{tariff_info[1]}_{tariff_info[2]}"
|
plan_id = f"{name}_{classif}_{amount_str}"
|
||||||
result = await call_api("POST", "/subscription/buy", {"telegram_id": callback.from_user.id, "plan_id": plan_id})
|
except Exception:
|
||||||
detail = result.get("detail", {})
|
await callback.message.edit_text("Некорректные данные тарифа.")
|
||||||
|
|
||||||
if detail == "ERROR":
|
|
||||||
await callback.message.edit_text("Произошла ошибка при оформлении подписки.")
|
|
||||||
elif detail == "INSUFFICIENT_FUNDS":
|
|
||||||
await callback.message.edit_text("Денег на вашем балансе не достаточно.")
|
|
||||||
elif detail == "TARIFF_NOT_FOUND":
|
|
||||||
await callback.message.edit_text("Ваш тариф не найден.")
|
|
||||||
elif detail == "ACTIVE_SUBSCRIPTION_EXISTS":
|
|
||||||
await callback.message.edit_text("Вы уже имеете активную подписку.")
|
|
||||||
else:
|
|
||||||
uri = result.get("message", {})
|
|
||||||
escaped_text = escape_markdown_v2(f"Подписка успешно оформлена!")
|
|
||||||
answer_text = f"Ваш конфиг для подключения: ```{uri}```"
|
|
||||||
await callback.message.edit_text(escaped_text)
|
|
||||||
await callback.message.answer(answer_text, parse_mode=ParseMode.MARKDOWN_V2)
|
|
||||||
except Exception as e:
|
|
||||||
logger.exception(f"Ошибка при обработке подтверждения подписки: {e}")
|
|
||||||
await callback.message.edit_text("Произошла ошибка при оформлении подписки.")
|
|
||||||
finally:
|
|
||||||
await callback.answer()
|
await callback.answer()
|
||||||
|
return
|
||||||
|
|
||||||
|
result = await call_api(
|
||||||
|
"POST",
|
||||||
|
"/subscription/buy",
|
||||||
|
{"telegram_id": str(callback.from_user.id), "plan_id": plan_id},
|
||||||
|
)
|
||||||
|
|
||||||
|
if result == "ERROR" or not isinstance(result, dict):
|
||||||
|
await callback.message.edit_text("Ошибка при оформлении подписки.")
|
||||||
|
await callback.answer()
|
||||||
|
return
|
||||||
|
|
||||||
|
detail = result.get("detail")
|
||||||
|
|
||||||
|
if detail == "INSUFFICIENT_FUNDS":
|
||||||
|
await callback.message.edit_text(
|
||||||
|
"Недостаточно средств. Попробуй пополнить баланс."
|
||||||
|
)
|
||||||
|
await callback.answer()
|
||||||
|
return
|
||||||
|
if detail == "TARIFF_NOT_FOUND":
|
||||||
|
await callback.message.edit_text("Тариф не найден.")
|
||||||
|
await callback.answer()
|
||||||
|
return
|
||||||
|
if detail == "ACTIVE_SUBSCRIPTION_EXISTS":
|
||||||
|
await callback.message.edit_text("У тебя уже есть активная подписка.")
|
||||||
|
await callback.answer()
|
||||||
|
return
|
||||||
|
|
||||||
|
uri = result.get("message", "")
|
||||||
|
if uri:
|
||||||
|
escaped_uri = escape_markdown_v2(uri)
|
||||||
|
answer_text = f"Подписка успешно оформлена!\n\nТвой конфиг:\n```{escaped_uri}```"
|
||||||
|
await callback.message.edit_text("Подписка успешно оформлена.")
|
||||||
|
await callback.message.answer(
|
||||||
|
answer_text,
|
||||||
|
parse_mode=ParseMode.MARKDOWN_V2,
|
||||||
|
)
|
||||||
|
else:
|
||||||
|
await callback.message.edit_text("Подписка успешно оформлена.")
|
||||||
|
|
||||||
|
await callback.answer()
|
||||||
|
|||||||
@@ -1,3 +1,5 @@
|
|||||||
|
from aiogram.types import InlineKeyboardButton
|
||||||
|
from aiogram.utils.keyboard import InlineKeyboardBuilder
|
||||||
from aiogram.utils.keyboard import InlineKeyboardBuilder, ReplyKeyboardBuilder
|
from aiogram.utils.keyboard import InlineKeyboardBuilder, ReplyKeyboardBuilder
|
||||||
from aiogram.types import InlineKeyboardButton, KeyboardButton
|
from aiogram.types import InlineKeyboardButton, KeyboardButton
|
||||||
|
|
||||||
@@ -121,11 +123,136 @@ def buy_keyboard():
|
|||||||
return builder.as_markup()
|
return builder.as_markup()
|
||||||
|
|
||||||
|
|
||||||
def subhist_keyboard():
|
def tarif_Lark_keyboard():
|
||||||
|
builder = InlineKeyboardBuilder()
|
||||||
|
builder.row(
|
||||||
|
InlineKeyboardButton(
|
||||||
|
text="🐣 Lark 1 месяц",
|
||||||
|
callback_data="Lark:Standart:1",
|
||||||
|
)
|
||||||
|
)
|
||||||
|
builder.row(
|
||||||
|
InlineKeyboardButton(
|
||||||
|
text="🐣 Lark 6 месяцев",
|
||||||
|
callback_data="Lark:Standart:6",
|
||||||
|
)
|
||||||
|
)
|
||||||
|
builder.row(
|
||||||
|
InlineKeyboardButton(
|
||||||
|
text="🐣 Lark 12 месяцев",
|
||||||
|
callback_data="Lark:Standart:12",
|
||||||
|
)
|
||||||
|
)
|
||||||
|
builder.row(
|
||||||
|
InlineKeyboardButton(
|
||||||
|
text="🔙 Назад",
|
||||||
|
callback_data="buy_subscription",
|
||||||
|
)
|
||||||
|
)
|
||||||
|
return builder.as_markup()
|
||||||
|
|
||||||
|
|
||||||
|
def tarif_Lark_pro_keyboard():
|
||||||
|
builder = InlineKeyboardBuilder()
|
||||||
|
builder.row(
|
||||||
|
InlineKeyboardButton(
|
||||||
|
text="🦅 Lark Pro 1 месяц",
|
||||||
|
callback_data="Lark:Pro:1",
|
||||||
|
)
|
||||||
|
)
|
||||||
|
builder.row(
|
||||||
|
InlineKeyboardButton(
|
||||||
|
text="🦅 Lark Pro 6 месяцев",
|
||||||
|
callback_data="Lark:Pro:6",
|
||||||
|
)
|
||||||
|
)
|
||||||
|
builder.row(
|
||||||
|
InlineKeyboardButton(
|
||||||
|
text="🦅 Lark Pro 12 месяцев",
|
||||||
|
callback_data="Lark:Pro:12",
|
||||||
|
)
|
||||||
|
)
|
||||||
|
builder.row(
|
||||||
|
InlineKeyboardButton(
|
||||||
|
text="🔙 Назад",
|
||||||
|
callback_data="buy_subscription",
|
||||||
|
)
|
||||||
|
)
|
||||||
|
return builder.as_markup()
|
||||||
|
|
||||||
|
|
||||||
|
def tarif_Lark_family_keyboard():
|
||||||
|
builder = InlineKeyboardBuilder()
|
||||||
|
builder.row(
|
||||||
|
InlineKeyboardButton(
|
||||||
|
text="👨👩👧 Lark Family 1 месяц",
|
||||||
|
callback_data="Lark:Family:1",
|
||||||
|
)
|
||||||
|
)
|
||||||
|
builder.row(
|
||||||
|
InlineKeyboardButton(
|
||||||
|
text="👨👩👧 Lark Family 6 месяцев",
|
||||||
|
callback_data="Lark:Family:6",
|
||||||
|
)
|
||||||
|
)
|
||||||
|
builder.row(
|
||||||
|
InlineKeyboardButton(
|
||||||
|
text="👨👩👧 Lark Family 12 месяцев",
|
||||||
|
callback_data="Lark:Family:12",
|
||||||
|
)
|
||||||
|
)
|
||||||
|
builder.row(
|
||||||
|
InlineKeyboardButton(
|
||||||
|
text="🔙 Назад",
|
||||||
|
callback_data="buy_subscription",
|
||||||
|
)
|
||||||
|
)
|
||||||
|
return builder.as_markup()
|
||||||
|
|
||||||
|
|
||||||
|
def subscriptions_card_keyboard(sub_id: str, index: int, total: int):
|
||||||
"""
|
"""
|
||||||
Подписки — история/список
|
Карточка подписки:
|
||||||
|
- навигация ⬅️/➡️
|
||||||
|
- 'Конфиг' / 'Продлить'
|
||||||
|
- 'Новая' / 'Назад'
|
||||||
"""
|
"""
|
||||||
builder = InlineKeyboardBuilder()
|
builder = InlineKeyboardBuilder()
|
||||||
|
|
||||||
|
nav = []
|
||||||
|
if index > 0:
|
||||||
|
nav.append(
|
||||||
|
InlineKeyboardButton(
|
||||||
|
text="⬅️",
|
||||||
|
callback_data=f"sub_prev:{index-1}",
|
||||||
|
)
|
||||||
|
)
|
||||||
|
if index < total - 1:
|
||||||
|
nav.append(
|
||||||
|
InlineKeyboardButton(
|
||||||
|
text="➡️",
|
||||||
|
callback_data=f"sub_next:{index+1}",
|
||||||
|
)
|
||||||
|
)
|
||||||
|
if nav:
|
||||||
|
builder.row(*nav)
|
||||||
|
|
||||||
|
builder.row(
|
||||||
|
InlineKeyboardButton(
|
||||||
|
text="🔑 Конфиг",
|
||||||
|
callback_data=f"sub_cfg:{sub_id}",
|
||||||
|
),
|
||||||
|
InlineKeyboardButton(
|
||||||
|
text="🔁 Продлить",
|
||||||
|
callback_data=f"sub_renew:{sub_id}",
|
||||||
|
),
|
||||||
|
)
|
||||||
|
builder.row(
|
||||||
|
InlineKeyboardButton(
|
||||||
|
text="➕ Новая",
|
||||||
|
callback_data="buy_subscription",
|
||||||
|
)
|
||||||
|
)
|
||||||
builder.row(
|
builder.row(
|
||||||
InlineKeyboardButton(
|
InlineKeyboardButton(
|
||||||
text="🔙 Назад",
|
text="🔙 Назад",
|
||||||
@@ -135,34 +262,18 @@ def subhist_keyboard():
|
|||||||
return builder.as_markup()
|
return builder.as_markup()
|
||||||
|
|
||||||
|
|
||||||
def payment_methods_keyboard(amount: int):
|
def tarif_confirm_keyboard(name: str, amount: int, classif: str):
|
||||||
"""
|
|
||||||
Способы оплаты для выбранной суммы.
|
|
||||||
ЛаркинсКоины убрал нахер
|
|
||||||
"""
|
|
||||||
builder = InlineKeyboardBuilder()
|
builder = InlineKeyboardBuilder()
|
||||||
builder.row(
|
builder.row(
|
||||||
InlineKeyboardButton(
|
InlineKeyboardButton(
|
||||||
text="⭐ Telegram Stars",
|
text="✅ Подтвердить",
|
||||||
callback_data=f"method_stars_{amount}",
|
callback_data=f"confirm:{name}_{classif}_{amount}",
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
builder.row(
|
builder.row(
|
||||||
InlineKeyboardButton(
|
InlineKeyboardButton(
|
||||||
text="💵 YooKassa",
|
text="🔙 Отменить",
|
||||||
callback_data=f"method_ykassa_{amount}",
|
callback_data="buy_subscription",
|
||||||
)
|
|
||||||
)
|
|
||||||
builder.row(
|
|
||||||
InlineKeyboardButton(
|
|
||||||
text="🪙 CryptoBot",
|
|
||||||
callback_data=f"method_crypto_{amount}",
|
|
||||||
)
|
|
||||||
)
|
|
||||||
builder.row(
|
|
||||||
InlineKeyboardButton(
|
|
||||||
text="🔙 Назад",
|
|
||||||
callback_data="popup",
|
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
return builder.as_markup()
|
return builder.as_markup()
|
||||||
@@ -340,7 +451,8 @@ def tarif_confirm_keyboard(name, amount, classif):
|
|||||||
|
|
||||||
def confirm_popup_keyboard():
|
def confirm_popup_keyboard():
|
||||||
"""
|
"""
|
||||||
Подтверждение пополнения — без «иди нахуй», мы же под босса господина ларк это красим....
|
аааааааааааааааааааааа
|
||||||
|
|
||||||
"""
|
"""
|
||||||
builder = InlineKeyboardBuilder()
|
builder = InlineKeyboardBuilder()
|
||||||
builder.row(
|
builder.row(
|
||||||
|
|||||||
Reference in New Issue
Block a user