Compare commits
18 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
1db24ace53 | ||
| d3e47a662f | |||
|
|
51645096d3 | ||
|
|
00edfdbd19 | ||
|
|
94df5ee9a5 | ||
|
|
0d9a86ee54 | ||
|
|
12c60b884a | ||
|
|
6276490ee1 | ||
|
|
3e976d9960 | ||
|
|
77ca27a09c | ||
|
|
d1417653c3 | ||
|
|
cbf113f7bb | ||
|
|
a572c90194 | ||
|
|
f042cc2f9e | ||
|
|
779f13b98e | ||
|
|
c7ded9e499 | ||
|
|
cda94583ed | ||
|
|
79307b9791 |
@@ -1,7 +1,16 @@
|
||||
from .start import router as start_router
|
||||
from .profile import router as profile_router
|
||||
from .subscriptions import router as subscriptions_router
|
||||
from .support import router as support_router
|
||||
|
||||
# Экспортируем все маршрутизаторы
|
||||
routers = [start_router,profile_router,subscriptions_router,support_router]
|
||||
from .start import router as start_router
|
||||
from .profile import router as profile_router
|
||||
from .subscriptions import router as subscriptions_router
|
||||
from .support import router as support_router
|
||||
from .referrals import router as referrals_router
|
||||
|
||||
# Список всех роутеров бота
|
||||
routers = [
|
||||
start_router,
|
||||
profile_router,
|
||||
subscriptions_router,
|
||||
support_router,
|
||||
referrals_router,
|
||||
]
|
||||
|
||||
__all__ = ["routers"]
|
||||
|
||||
@@ -1,242 +1,534 @@
|
||||
from aiogram import Router, types
|
||||
from aiogram.types import CallbackQuery
|
||||
import logging
|
||||
from datetime import datetime
|
||||
from aiogram.enums.parse_mode import ParseMode
|
||||
import locale
|
||||
from instences.config import BASE_URL_FASTAPI
|
||||
import aiohttp
|
||||
from keyboard.keyboards import (
|
||||
account_keyboard,
|
||||
popup_keyboard,
|
||||
tranhist_keyboard,
|
||||
confirm_popup_keyboard,
|
||||
guide_keyboard,
|
||||
balance_keyboard,
|
||||
)
|
||||
|
||||
locale.setlocale(locale.LC_TIME, "ru_RU.UTF-8")
|
||||
|
||||
router = Router()
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
async def call_api(method, endpoint, data=None):
|
||||
"""
|
||||
Выполняет HTTP-запрос к FastAPI.
|
||||
"""
|
||||
url = f"{BASE_URL_FASTAPI}{endpoint}"
|
||||
logger.info(f"Инициализация запроса: {method} {url} с данными {data}")
|
||||
|
||||
try:
|
||||
async with aiohttp.ClientSession() as session:
|
||||
async with session.request(method, url, json=data) as response:
|
||||
logger.info(
|
||||
f"Получен ответ от {url}: статус {response.status}")
|
||||
|
||||
if response.status in {200, 201}:
|
||||
result = await response.json()
|
||||
logger.debug(f"Ответ JSON: {result}")
|
||||
return result
|
||||
if response.status == 404:
|
||||
logger.debug(f"Код {response.status}, возвращаю ничего")
|
||||
return None
|
||||
logger.error(
|
||||
f"Ошибка в запросе: статус {response.status}, причина {response.reason}"
|
||||
)
|
||||
return "ERROR"
|
||||
except Exception as e:
|
||||
logger.exception(f"Исключение при выполнении запроса к {url}: {e}")
|
||||
return "ERROR"
|
||||
|
||||
|
||||
@router.callback_query(lambda callback: callback.data == "profile")
|
||||
async def profile_callback_handler(callback: CallbackQuery):
|
||||
"""
|
||||
Профиль пользователя.
|
||||
Логика работы с API сохранена, переписан только текст/визуал.
|
||||
"""
|
||||
try:
|
||||
user_data = await call_api("GET", f"/user/{callback.from_user.id}")
|
||||
if not user_data:
|
||||
await callback.message.answer(
|
||||
"Произошла ошибка, попробуйте позже или свяжитесь с администрацией."
|
||||
)
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
sub_data = await call_api("GET", f"/subscription/{user_data['telegram_id']}/last")
|
||||
if sub_data == "ERROR" or not isinstance(sub_data, dict):
|
||||
sub_data = None
|
||||
|
||||
balance_text = f"💰 Баланс: {user_data['balance']} ₽"
|
||||
|
||||
username = callback.from_user.username or "пользователь"
|
||||
|
||||
# Нет подписки
|
||||
if not sub_data:
|
||||
text = (
|
||||
f"📜 Профиль {username}\n\n"
|
||||
f"{balance_text}\n\n"
|
||||
"У тебя пока нет активной подписки.\n"
|
||||
"Пополняй баланс и подключай тариф Lark, чтобы получить статус 🐣 или 🦅."
|
||||
)
|
||||
else:
|
||||
expiry_date = sub_data.get("end_date")
|
||||
formatted_date = (
|
||||
datetime.fromisoformat(expiry_date).strftime("%d %B %Y г.")
|
||||
if expiry_date
|
||||
else None
|
||||
)
|
||||
is_expired = (
|
||||
datetime.fromisoformat(expiry_date) < datetime.now()
|
||||
if expiry_date
|
||||
else True
|
||||
)
|
||||
status_icon = "✖️" if is_expired else "☑️"
|
||||
profile_status = "🦅" if "Pro" in sub_data.get("plan", "") else "🐣"
|
||||
|
||||
if not is_expired and formatted_date:
|
||||
sub_text = (
|
||||
f"Подписка активна до {formatted_date} {status_icon}\n"
|
||||
f"Текущий статус: {profile_status}"
|
||||
)
|
||||
else:
|
||||
sub_text = (
|
||||
f"Подписка неактивна {status_icon}\n"
|
||||
"Ты можешь продлить её в разделе подписок."
|
||||
)
|
||||
|
||||
text = (
|
||||
f"📜 Профиль {username} {profile_status}\n\n"
|
||||
f"{sub_text}\n\n"
|
||||
f"{balance_text}"
|
||||
)
|
||||
|
||||
await callback.message.edit_text(text, reply_markup=account_keyboard())
|
||||
except Exception as e:
|
||||
logger.exception(f"Ошибка в обработчике профиля: {e}")
|
||||
await callback.message.answer("Произошла ошибка. Попробуйте позже.")
|
||||
finally:
|
||||
await callback.answer()
|
||||
|
||||
|
||||
@router.callback_query(lambda callback: callback.data == "balance")
|
||||
async def balance_callback_handler(callback: CallbackQuery):
|
||||
"""
|
||||
Обработчик callback_query для баланса.
|
||||
"""
|
||||
user_data = await call_api("GET", f"/user/{callback.from_user.id}")
|
||||
if not user_data:
|
||||
await callback.message.answer(
|
||||
"Произошла ошибка, попробуйте позже или свяжитесь с администрацией."
|
||||
)
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
await callback.message.edit_text(
|
||||
f"💰 Текущий баланс: {user_data['balance']} ₽\n\n"
|
||||
"Выбери сумму, на которую хочешь пополнить счёт.",
|
||||
reply_markup=balance_keyboard(),
|
||||
)
|
||||
await callback.answer()
|
||||
|
||||
|
||||
@router.callback_query(lambda callback: callback.data == "popup")
|
||||
async def popup_callback_handler(callback: CallbackQuery):
|
||||
"""
|
||||
Обработчик callback_query для выбора суммы пополнения.
|
||||
"""
|
||||
user = await call_api("GET", f"/user/{callback.from_user.id}")
|
||||
if not user:
|
||||
await callback.message.answer(
|
||||
"Произошла ошибка, попробуйте позже или свяжитесь с администрацией."
|
||||
)
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
await callback.message.edit_text(
|
||||
"Выбери сумму для пополнения баланса.",
|
||||
reply_markup=popup_keyboard(),
|
||||
)
|
||||
await callback.answer()
|
||||
|
||||
|
||||
@router.callback_query(lambda callback: callback.data == "tranhist")
|
||||
async def tranhist_callback_handler(callback: CallbackQuery):
|
||||
"""
|
||||
Обработчик callback_query для истории транзакций.
|
||||
(Логику и формат Markdown_V2 не трогаем, чтобы не поймать новые баги)
|
||||
"""
|
||||
user_data = await call_api("GET", f"/user/{callback.from_user.id}")
|
||||
if not user_data:
|
||||
await callback.message.edit_text("Вы еще не зарегистрированы.")
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
try:
|
||||
transactions = await call_api("GET", f"/user/{user_data['telegram_id']}/transactions")
|
||||
if not transactions:
|
||||
await callback.message.edit_text(
|
||||
"У вас нет транзакций.", reply_markup=tranhist_keyboard()
|
||||
)
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
result = "Ваши транзакции:```\n"
|
||||
for count, tran in enumerate(transactions, start=1):
|
||||
dt = datetime.fromisoformat(tran["created_at"]).strftime(
|
||||
"%d.%m.%Y %H:%M:%S"
|
||||
)
|
||||
result += f"{count}. Сумма: {tran['amount']}, Дата: {dt}\n"
|
||||
if len(result) > 4000:
|
||||
result += "...\nСлишком много транзакций для отображения."
|
||||
break
|
||||
result += "```"
|
||||
await callback.message.edit_text(
|
||||
result,
|
||||
parse_mode=ParseMode.MARKDOWN_V2,
|
||||
reply_markup=tranhist_keyboard(),
|
||||
)
|
||||
except Exception as e:
|
||||
logger.error(f"Ошибка обработки транзакций: {e}")
|
||||
await callback.message.edit_text("Произошла ошибка. Попробуйте позже.")
|
||||
finally:
|
||||
await callback.answer()
|
||||
|
||||
|
||||
@router.callback_query(lambda callback: callback.data.startswith("popup:"))
|
||||
async def popup_confirm_callback_handler(callback: CallbackQuery):
|
||||
"""
|
||||
Обработчик подтверждения пополнения баланса.
|
||||
"""
|
||||
data = callback.data.split(":")
|
||||
popup_info = data[1]
|
||||
result = await call_api(
|
||||
"POST",
|
||||
f"/user/{callback.from_user.id}/balance/{float(popup_info)}",
|
||||
)
|
||||
if result == "ERROR":
|
||||
await callback.message.answer(
|
||||
"Произошла ошибка, попробуйте позже или свяжитесь с администрацией."
|
||||
)
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
text = f"✅ Баланс пополнен на {popup_info} ₽. Спасибо, что остаёшься с Lark."
|
||||
await callback.message.edit_text(
|
||||
text=text, reply_markup=confirm_popup_keyboard()
|
||||
)
|
||||
await callback.answer()
|
||||
|
||||
|
||||
@router.callback_query(lambda callback: callback.data == "guide")
|
||||
async def guide_callback_handler(callback: CallbackQuery):
|
||||
"""
|
||||
Обработчик callback_query для руководства.
|
||||
"""
|
||||
await callback.message.edit_text(
|
||||
"Выбери платформу, для которой нужно руководство по подключению:",
|
||||
reply_markup=guide_keyboard(),
|
||||
)
|
||||
await callback.answer()
|
||||
# Профиль. последнее изменениеы
|
||||
|
||||
from aiogram import Router, types, F
|
||||
from aiogram.types import (
|
||||
CallbackQuery,
|
||||
LabeledPrice,
|
||||
Message,
|
||||
PreCheckoutQuery,
|
||||
)
|
||||
import logging
|
||||
from datetime import datetime
|
||||
from aiogram.enums.parse_mode import ParseMode
|
||||
import locale
|
||||
from instences.config import BASE_URL_FASTAPI
|
||||
import aiohttp
|
||||
from keyboard.keyboards import (
|
||||
account_keyboard,
|
||||
popup_keyboard,
|
||||
tranhist_keyboard,
|
||||
confirm_popup_keyboard,
|
||||
guide_keyboard,
|
||||
balance_keyboard,
|
||||
payment_methods_keyboard,
|
||||
)
|
||||
|
||||
locale.setlocale(locale.LC_TIME, "ru_RU.UTF-8")
|
||||
|
||||
router = Router()
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
async def call_api(method, endpoint, data=None, base_url=BASE_URL_FASTAPI):
|
||||
"""
|
||||
Выполняет HTTP-запрос к FastAPI.
|
||||
"""
|
||||
url = f"{base_url}{endpoint}"
|
||||
logger.info(f"Инициализация запроса: {method} {url} с данными {data}")
|
||||
|
||||
try:
|
||||
async with aiohttp.ClientSession() as session:
|
||||
async with session.request(
|
||||
method,
|
||||
url,
|
||||
json=data,
|
||||
headers={"Content-Type": "application/json"}
|
||||
) as response:
|
||||
logger.info(
|
||||
f"Получен ответ от {url}: статус {response.status}"
|
||||
)
|
||||
|
||||
if response.status in {200, 201}:
|
||||
result = await response.json()
|
||||
logger.debug(f"Ответ JSON: {result}")
|
||||
return result
|
||||
if response.status == 404:
|
||||
logger.debug(f"Код {response.status}, возвращаю ничего")
|
||||
return None
|
||||
logger.error(
|
||||
f"Ошибка в запросе: статус {response.status}, причина {response.reason}"
|
||||
)
|
||||
return "ERROR"
|
||||
except Exception as e:
|
||||
logger.exception(f"Исключение при выполнении запроса к {url}: {e}")
|
||||
return "ERROR"
|
||||
|
||||
|
||||
@router.callback_query(lambda callback: callback.data == "profile")
|
||||
async def profile_callback_handler(callback: CallbackQuery):
|
||||
"""
|
||||
Профиль пользователя.
|
||||
Логика работы с API сохранена, изменён только текст/визуал.
|
||||
"""
|
||||
try:
|
||||
user_data = await call_api("GET", f"/user/{callback.from_user.id}")
|
||||
if not user_data:
|
||||
await callback.message.answer(
|
||||
"Произошла ошибка, попробуйте позже или свяжитесь с администрацией."
|
||||
)
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
sub_data = await call_api(
|
||||
"GET", f"/subscription/{user_data['telegram_id']}/last"
|
||||
)
|
||||
if sub_data == "ERROR" or not isinstance(sub_data, dict):
|
||||
sub_data = None
|
||||
|
||||
username = callback.from_user.username or "-"
|
||||
balance = user_data.get("balance", 0)
|
||||
|
||||
# Статус подписки: Активна / Нет активных
|
||||
sub_status = "⚫ Нет активных"
|
||||
|
||||
if sub_data:
|
||||
expiry_date = sub_data.get("end_date")
|
||||
if expiry_date:
|
||||
try:
|
||||
is_expired = datetime.fromisoformat(
|
||||
expiry_date) < datetime.now()
|
||||
except ValueError:
|
||||
is_expired = True
|
||||
else:
|
||||
is_expired = True
|
||||
|
||||
if not is_expired:
|
||||
sub_status = "🟢 Активна"
|
||||
|
||||
text = (
|
||||
"🥚 <b>Профиль</b>\n\n"
|
||||
f"Пользователь: @{username}\n"
|
||||
f"Баланс: {balance} ₽\n"
|
||||
f"Статус подписки: {sub_status}\n\n"
|
||||
"Выберите действие:"
|
||||
)
|
||||
|
||||
await callback.message.edit_text(
|
||||
text,
|
||||
parse_mode=ParseMode.HTML,
|
||||
reply_markup=account_keyboard(),
|
||||
)
|
||||
except Exception as e:
|
||||
logger.exception(f"Ошибка в обработчике профиля: {e}")
|
||||
await callback.message.answer("Произошла ошибка. Попробуйте позже.")
|
||||
finally:
|
||||
await callback.answer()
|
||||
|
||||
|
||||
@router.callback_query(lambda callback: callback.data == "balance")
|
||||
async def balance_callback_handler(callback: CallbackQuery):
|
||||
"""
|
||||
При нажатии «Пополнить баланс» показываем выбор суммы пополнения.
|
||||
"""
|
||||
await callback.message.edit_text(
|
||||
"💳 Выберите сумму пополнения:",
|
||||
reply_markup=popup_keyboard(),
|
||||
)
|
||||
await callback.answer()
|
||||
|
||||
|
||||
@router.callback_query(lambda callback: callback.data == "popup")
|
||||
async def popup_callback_handler(callback: CallbackQuery):
|
||||
"""
|
||||
Обработчик callback_query для выбора суммы пополнения.
|
||||
"""
|
||||
user = await call_api("GET", f"/user/{callback.from_user.id}")
|
||||
if not user:
|
||||
await callback.message.answer(
|
||||
"Произошла ошибка, попробуйте позже или свяжитесь с администрацией."
|
||||
)
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
await callback.message.edit_text(
|
||||
"Выбери сумму для пополнения баланса.",
|
||||
reply_markup=popup_keyboard(),
|
||||
)
|
||||
await callback.answer()
|
||||
|
||||
|
||||
@router.callback_query(lambda callback: callback.data == "tranhist")
|
||||
async def tranhist_callback_handler(callback: CallbackQuery):
|
||||
"""
|
||||
Обработчик callback_query для истории транзакций.
|
||||
(Логику и формат Markdown_V2 не трогаем, чтобы не поймать новые баги)
|
||||
"""
|
||||
user_data = await call_api("GET", f"/user/{callback.from_user.id}")
|
||||
if not user_data:
|
||||
await callback.message.edit_text("Вы еще не зарегистрированы.")
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
try:
|
||||
transactions = await call_api(
|
||||
"GET", f"/user/{user_data['telegram_id']}/transactions"
|
||||
)
|
||||
if not transactions:
|
||||
await callback.message.edit_text(
|
||||
"У вас нет транзакций.", reply_markup=tranhist_keyboard()
|
||||
)
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
result = "Ваши транзакции:```\n"
|
||||
for count, tran in enumerate(transactions, start=1):
|
||||
dt = datetime.fromisoformat(tran["created_at"]).strftime(
|
||||
"%d.%m.%Y %H:%M:%S"
|
||||
)
|
||||
result += f"{count}. Сумма: {tran['amount']}, Дата: {dt}\n"
|
||||
if len(result) > 4000:
|
||||
result += "...\nСлишком много транзакций для отображения."
|
||||
break
|
||||
result += "```"
|
||||
await callback.message.edit_text(
|
||||
result,
|
||||
parse_mode=ParseMode.MARKDOWN_V2,
|
||||
reply_markup=tranhist_keyboard(),
|
||||
)
|
||||
except Exception as e:
|
||||
logger.error(f"Ошибка обработки транзакций: {e}")
|
||||
await callback.message.edit_text(
|
||||
"Произошла ошибка. Попробуйте позже."
|
||||
)
|
||||
finally:
|
||||
await callback.answer()
|
||||
|
||||
|
||||
@router.callback_query(lambda callback: callback.data.startswith("popup:"))
|
||||
async def popup_confirm_callback_handler(callback: CallbackQuery):
|
||||
"""
|
||||
После выбора суммы показываем варианты оплаты.
|
||||
Разрешены только суммы 200, 300, 600, 1000 ₽.
|
||||
"""
|
||||
try:
|
||||
_, amount_raw = callback.data.split(":", maxsplit=1)
|
||||
amount = int(float(amount_raw))
|
||||
except Exception:
|
||||
await callback.message.answer("Некорректная сумма пополнения.")
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
if amount not in {200, 300, 600, 1000}:
|
||||
await callback.message.answer(
|
||||
"Эта сумма пополнения недоступна. Выбери вариант от 200 до 1000 ₽."
|
||||
)
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
text = (
|
||||
f"💰 Сумма пополнения: {amount} ₽\n\n"
|
||||
"Выбери способ оплаты:"
|
||||
)
|
||||
|
||||
await callback.message.edit_text(
|
||||
text=text,
|
||||
reply_markup=payment_methods_keyboard(amount),
|
||||
)
|
||||
await callback.answer()
|
||||
|
||||
|
||||
# ===== Telegram Stars =====
|
||||
|
||||
@router.callback_query(lambda callback: callback.data.startswith("method_stars_"))
|
||||
async def method_stars_handler(callback: CallbackQuery):
|
||||
"""
|
||||
Оплата через Telegram Stars.
|
||||
Формируем invoice прямо из бота, без отдельного биллинга.
|
||||
"""
|
||||
try:
|
||||
amount_str = callback.data.split("_")[-1]
|
||||
amount_rub = int(float(amount_str))
|
||||
except Exception:
|
||||
await callback.message.answer("Некорректная сумма для оплаты.")
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
payload = f"stars_topup:{callback.from_user.id}:{amount_rub}"
|
||||
|
||||
stars_amount = amount_rub
|
||||
|
||||
prices = [
|
||||
LabeledPrice(
|
||||
label=f"Пополнение баланса на {amount_rub} ₽",
|
||||
amount=stars_amount,
|
||||
)
|
||||
]
|
||||
|
||||
try:
|
||||
await callback.message.answer_invoice(
|
||||
title="Пополнение баланса Lark VPN",
|
||||
description=(
|
||||
f"Пополнение баланса на {amount_rub} ₽ через Telegram Stars.\n\n"
|
||||
"После успешной оплаты баланс будет зачислен автоматически."
|
||||
),
|
||||
payload=payload,
|
||||
provider_token="", # для Stars провайдер пустой
|
||||
currency="XTR",
|
||||
prices=prices,
|
||||
)
|
||||
await callback.answer()
|
||||
except Exception as e:
|
||||
logger.exception(f"Ошибка при отправке invoice Telegram Stars: {e}")
|
||||
await callback.message.answer(
|
||||
"Не удалось создать счёт в Telegram Stars. Попробуй позже или выбери другой способ оплаты."
|
||||
)
|
||||
await callback.answer()
|
||||
|
||||
|
||||
@router.callback_query(lambda callback: callback.data.startswith("method_ykassa_"))
|
||||
async def method_ykassa_handler(callback: CallbackQuery):
|
||||
"""
|
||||
Обработчик оплаты через YooKassa.
|
||||
"""
|
||||
amount = callback.data.split("_")[-1]
|
||||
|
||||
try:
|
||||
await callback.answer()
|
||||
except Exception:
|
||||
pass
|
||||
|
||||
endpoint = (
|
||||
f"/billing/payments/init?"
|
||||
f"user_id={callback.from_user.id}&amount={float(amount)}&provider=yookassa"
|
||||
)
|
||||
|
||||
logger.info(f"Отправка запроса на инициализацию платежа: {endpoint}")
|
||||
|
||||
result = await call_api("POST", endpoint, None, "http://billing:8000")
|
||||
|
||||
if result == "ERROR" or not isinstance(result, dict):
|
||||
await callback.message.edit_text(
|
||||
"❌ Произошла ошибка при создании платежа. Попробуйте позже."
|
||||
)
|
||||
return
|
||||
|
||||
if not result.get("success", False):
|
||||
error_msg = (
|
||||
result.get("error")
|
||||
or result.get("detail")
|
||||
or "Неизвестная ошибка"
|
||||
)
|
||||
await callback.message.edit_text(f"❌ Ошибка: {error_msg}")
|
||||
return
|
||||
|
||||
payment_url = result.get("confirmation_url", "#")
|
||||
payment_id = result.get("payment_id", "")
|
||||
|
||||
await callback.message.edit_text(
|
||||
f"💵 <b>Оплата через YooKassa</b>\n\n"
|
||||
f"💰 Сумма: <code>{amount}</code> руб\n"
|
||||
f"📋 ID платежа: <code>{payment_id}</code>\n\n"
|
||||
f"➡️ <a href='{payment_url}'>Перейти к оплате</a>\n\n"
|
||||
f"<i>После оплаты нажмите кнопку 'Проверить оплату'</i>",
|
||||
parse_mode=ParseMode.HTML,
|
||||
disable_web_page_preview=True,
|
||||
reply_markup=types.InlineKeyboardMarkup(
|
||||
inline_keyboard=[[
|
||||
types.InlineKeyboardButton(
|
||||
text="🔄 Проверить оплату",
|
||||
callback_data=f"check_payment:{payment_id}",
|
||||
)
|
||||
]]
|
||||
),
|
||||
)
|
||||
|
||||
await callback.answer()
|
||||
|
||||
|
||||
@router.callback_query(lambda callback: callback.data.startswith("method_crypto_"))
|
||||
async def method_crypto_handler(callback: CallbackQuery):
|
||||
"""
|
||||
Оплата через CryptoBot.
|
||||
"""
|
||||
amount = callback.data.split("_")[-1]
|
||||
|
||||
try:
|
||||
await callback.answer()
|
||||
except Exception:
|
||||
pass
|
||||
|
||||
endpoint = (
|
||||
f"/billing/payments/init?"
|
||||
f"user_id={callback.from_user.id}&amount={float(amount)}&provider=cryptobot"
|
||||
)
|
||||
|
||||
logger.info(f"Отправка запроса на инициализацию платежа: {endpoint}")
|
||||
|
||||
result = await call_api("POST", endpoint, None, "http://billing:8000")
|
||||
|
||||
if result == "ERROR" or not isinstance(result, dict):
|
||||
await callback.message.edit_text(
|
||||
"❌ Произошла ошибка при создании платежа. Попробуйте позже."
|
||||
)
|
||||
return
|
||||
|
||||
if not result.get("success", False):
|
||||
error_msg = (
|
||||
result.get("error")
|
||||
or result.get("detail")
|
||||
or "Неизвестная ошибка"
|
||||
)
|
||||
await callback.message.edit_text(f"❌ Ошибка: {error_msg}")
|
||||
return
|
||||
|
||||
payment_url = result.get("confirmation_url", "#")
|
||||
payment_id = result.get("payment_id", "")
|
||||
|
||||
await callback.message.edit_text(
|
||||
f"💵 <b>Оплата через Сryptobot</b>\n\n"
|
||||
f"💰 Сумма: <code>{amount}</code> руб\n"
|
||||
f"📋 ID платежа: <code>{payment_id}</code>\n\n"
|
||||
f"➡️ <a href='{payment_url}'>Перейти к оплате</a>\n\n"
|
||||
f"<i>После оплаты нажмите кнопку 'Проверить оплату'</i>",
|
||||
parse_mode=ParseMode.HTML,
|
||||
disable_web_page_preview=True,
|
||||
reply_markup=types.InlineKeyboardMarkup(
|
||||
inline_keyboard=[[
|
||||
types.InlineKeyboardButton(
|
||||
text="🔄 Проверить оплату",
|
||||
callback_data=f"check_payment:{payment_id}",
|
||||
)
|
||||
]]
|
||||
),
|
||||
)
|
||||
|
||||
await callback.answer()
|
||||
|
||||
|
||||
@router.callback_query(lambda callback: callback.data.startswith("method_sbp_"))
|
||||
async def method_sbp_handler(callback: types.CallbackQuery):
|
||||
try:
|
||||
amount = int(callback.data.split("_")[2])
|
||||
except Exception:
|
||||
await callback.message.answer("Ошибка суммы платежа.")
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
endpoint = (
|
||||
f"/billing/payments/init?"
|
||||
f"user_id={callback.from_user.id}&amount={float(amount)}&provider=sbp"
|
||||
)
|
||||
|
||||
result = await call_api("POST", endpoint,None ,"http://billing:8000")
|
||||
|
||||
if result == "ERROR" or not isinstance(result, dict):
|
||||
await callback.message.answer("Ошибка при инициализации платежа.")
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
url = result.get("confirmation_url")
|
||||
if not url:
|
||||
await callback.message.answer("СБП временно недоступно.")
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
await callback.message.answer(
|
||||
f"🏦 Платёж через СБП:\nПерейди по ссылке для оплаты:\n{url}"
|
||||
)
|
||||
await callback.answer()
|
||||
|
||||
|
||||
@router.callback_query(lambda callback: callback.data == "guide")
|
||||
async def guide_callback_handler(callback: CallbackQuery):
|
||||
"""
|
||||
Обработчик callback_query для руководства.
|
||||
"""
|
||||
await callback.message.edit_text(
|
||||
"Выбери платформу, для которой нужно руководство по подключению:",
|
||||
reply_markup=guide_keyboard(),
|
||||
)
|
||||
await callback.answer()
|
||||
|
||||
|
||||
# ===== Служебные хендлеры для платежей Telegram Stars =====
|
||||
|
||||
@router.pre_checkout_query()
|
||||
async def pre_checkout_query_handler(pre_checkout_query: PreCheckoutQuery):
|
||||
"""
|
||||
Обязательный шаг для Telegram Payments:
|
||||
подтверждаем pre_checkout_query, иначе платёж не пройдёт.
|
||||
"""
|
||||
try:
|
||||
await pre_checkout_query.bot.answer_pre_checkout_query(
|
||||
pre_checkout_query.id,
|
||||
ok=True,
|
||||
)
|
||||
except Exception as e:
|
||||
logger.exception(f"Ошибка при answer_pre_checkout_query: {e}")
|
||||
|
||||
|
||||
async def _process_stars_topup(message: Message):
|
||||
"""
|
||||
Логика зачисления средств после успешной оплаты Stars.
|
||||
"""
|
||||
sp = message.successful_payment
|
||||
if not sp:
|
||||
return
|
||||
|
||||
payload = sp.invoice_payload or ""
|
||||
parts = payload.split(":")
|
||||
if len(parts) != 3 or parts[0] != "stars_topup":
|
||||
logger.info(
|
||||
"successful_payment не относится к пополнению баланса Stars.")
|
||||
return
|
||||
|
||||
_, telegram_id_str, amount_str = parts
|
||||
|
||||
try:
|
||||
amount_rub = int(amount_str)
|
||||
except ValueError:
|
||||
# На всякий случай fallback к total_amount
|
||||
amount_rub = sp.total_amount
|
||||
|
||||
data = {
|
||||
"telegram_id": telegram_id_str,
|
||||
"amount": amount_rub,
|
||||
"currency": sp.currency,
|
||||
"provider": "telegram_stars",
|
||||
"telegram_payment_charge_id": sp.telegram_payment_charge_id,
|
||||
}
|
||||
|
||||
logger.info(
|
||||
f"Обработка успешного платежа Telegram Stars: "
|
||||
f"user={telegram_id_str}, amount={amount_rub}, currency={sp.currency}"
|
||||
)
|
||||
|
||||
result = await call_api("POST", "/user/deposit", data)
|
||||
|
||||
if result == "ERROR" or result is None:
|
||||
await message.answer(
|
||||
"⭐ Оплата через Telegram Stars прошла, но не удалось автоматически обновить баланс.\n"
|
||||
"Если баланс не изменился — напиши, пожалуйста, в поддержку и укажи время платежа."
|
||||
)
|
||||
return
|
||||
|
||||
await message.answer(
|
||||
f"⭐ Оплата через Telegram Stars успешно проведена.\n"
|
||||
f"На твой баланс зачислено {amount_rub} ₽."
|
||||
)
|
||||
|
||||
|
||||
@router.message(F.successful_payment)
|
||||
async def successful_payment_handler(message: Message):
|
||||
"""
|
||||
Глобальный хендлер успешных платежей.
|
||||
Сейчас используем только для пополнения баланса через Stars.
|
||||
"""
|
||||
try:
|
||||
await _process_stars_topup(message)
|
||||
except Exception as e:
|
||||
logger.exception(f"Ошибка при обработке successful_payment: {e}")
|
||||
await message.answer(
|
||||
"Оплата прошла, но произошла ошибка при обработке. "
|
||||
"Если баланс не изменился — напиши, пожалуйста, в поддержку."
|
||||
)
|
||||
|
||||
123
handlers/referrals.py
Normal file
123
handlers/referrals.py
Normal file
@@ -0,0 +1,123 @@
|
||||
from aiogram import Router, types
|
||||
from aiogram.filters import Command
|
||||
from aiogram.enums.parse_mode import ParseMode
|
||||
import logging
|
||||
import aiohttp
|
||||
|
||||
from instences.config import BASE_URL_FASTAPI
|
||||
|
||||
router = Router()
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
async def call_api(method: str, endpoint: str, data=None, base_url: str = BASE_URL_FASTAPI):
|
||||
"""
|
||||
Универсальный HTTP-запрос к FastAPI для рефералок.
|
||||
|
||||
Ожидаем:
|
||||
GET /user/{telegram_id}/referrals -> {
|
||||
"invited_count": int
|
||||
}
|
||||
"""
|
||||
url = f"{base_url}{endpoint}"
|
||||
logger.info(f"[referrals] Запрос: {method} {url} с данными {data}")
|
||||
|
||||
try:
|
||||
async with aiohttp.ClientSession() as session:
|
||||
async with session.request(
|
||||
method,
|
||||
url,
|
||||
json=data,
|
||||
headers={"Content-Type": "application/json"},
|
||||
) as response:
|
||||
logger.info(
|
||||
f"[referrals] Ответ от {url}: статус {response.status}"
|
||||
)
|
||||
|
||||
if response.status in {200, 201}:
|
||||
result = await response.json()
|
||||
logger.debug(f"[referrals] Ответ JSON: {result}")
|
||||
return result
|
||||
if response.status == 404:
|
||||
logger.debug("[referrals] 404, возвращаю None")
|
||||
return None
|
||||
|
||||
logger.error(
|
||||
f"[referrals] Ошибка в запросе: статус {response.status}, "
|
||||
f"причина {response.reason}"
|
||||
)
|
||||
return "ERROR"
|
||||
except Exception as e:
|
||||
logger.exception(f"[referrals] Исключение при запросе к {url}: {e}")
|
||||
return "ERROR"
|
||||
|
||||
|
||||
async def _build_referral_text(bot, user_id: int) -> str:
|
||||
"""
|
||||
Текст реферальной программы + количество приглашённых.
|
||||
"""
|
||||
me = await bot.get_me()
|
||||
bot_username = me.username or "LarkVPN_bot"
|
||||
|
||||
link = f"https://t.me/{bot_username}?start=ref_{user_id}"
|
||||
|
||||
text = (
|
||||
"👥 <b>Реферальная программа</b>\n\n"
|
||||
"Зови друзей в Lark VPN и получай бонусы на баланс.\n\n"
|
||||
f"🔗 Твоя ссылка:\n<code>{link}</code>\n\n"
|
||||
)
|
||||
|
||||
invited_count = 0
|
||||
|
||||
stats = await call_api("GET", f"/user/{user_id}/referrals")
|
||||
if isinstance(stats, dict):
|
||||
raw = stats.get("invited_count")
|
||||
try:
|
||||
invited_count = int(raw)
|
||||
except (TypeError, ValueError):
|
||||
invited_count = 0
|
||||
elif stats == "ERROR":
|
||||
logger.warning(
|
||||
f"[referrals] Ошибка при получении статистики для user_id={user_id}"
|
||||
)
|
||||
|
||||
text += f"👤 Приглашено: {invited_count}\n\n"
|
||||
text += "Бонусы начисляются, когда приглашённые пополняют баланс."
|
||||
|
||||
return text
|
||||
|
||||
|
||||
@router.message(Command("referrals"))
|
||||
async def referrals_command(message: types.Message):
|
||||
"""
|
||||
Команда /referrals — показывает текст реферальной программы.
|
||||
"""
|
||||
logger.info(f"[referrals] Команда /referrals от {message.from_user.id}")
|
||||
try:
|
||||
text = await _build_referral_text(message.bot, message.from_user.id)
|
||||
await message.answer(text, parse_mode=ParseMode.HTML)
|
||||
except Exception as e:
|
||||
logger.exception(f"[referrals] Ошибка в обработчике /referrals: {e}")
|
||||
await message.answer("Произошла ошибка. Попробуй позже.")
|
||||
|
||||
|
||||
@router.callback_query(lambda callback: callback.data == "referral")
|
||||
async def referrals_callback(callback: types.CallbackQuery):
|
||||
"""
|
||||
Кнопка «Реферальная программа» (если где-то есть).
|
||||
"""
|
||||
try:
|
||||
text = await _build_referral_text(
|
||||
callback.message.bot,
|
||||
callback.from_user.id,
|
||||
)
|
||||
await callback.message.edit_text(
|
||||
text,
|
||||
parse_mode=ParseMode.HTML,
|
||||
)
|
||||
except Exception as e:
|
||||
logger.exception(
|
||||
f"[referrals] Ошибка в обработчике callback 'referral': {e}")
|
||||
await callback.message.answer("Произошла ошибка. Попробуй позже.")
|
||||
finally:
|
||||
await callback.answer()
|
||||
@@ -1,89 +1,195 @@
|
||||
from aiogram import Router, types
|
||||
from aiogram.filters import Command
|
||||
from aiogram.types import Message, CallbackQuery
|
||||
from aiogram.enums.parse_mode import ParseMode
|
||||
import logging
|
||||
from instences.config import BASE_URL_FASTAPI
|
||||
import aiohttp
|
||||
|
||||
from instences.config import BASE_URL_FASTAPI
|
||||
from keyboard.keyboards import main_keyboard
|
||||
from .referrals import _build_referral_text
|
||||
|
||||
router = Router()
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
async def call_api(method, endpoint, data=None):
|
||||
async def call_api(method: str, endpoint: str, data=None):
|
||||
"""
|
||||
Выполняет HTTP-запрос к FastAPI.
|
||||
:param method: HTTP метод (GET, POST, и т.д.)
|
||||
:param endpoint: конечная точка API
|
||||
:param data: тело запроса (если необходимо)
|
||||
:return: JSON-ответ или "ERROR" при неуспехе
|
||||
Возвращает:
|
||||
- dict при 200/201
|
||||
- None при 404
|
||||
- "ERROR" при остальных ошибках
|
||||
"""
|
||||
url = f"{BASE_URL_FASTAPI}{endpoint}"
|
||||
logger.info(f"Инициализация запроса: {method} {url} с данными {data}")
|
||||
logger.info(f"[start] Запрос: {method} {url} с данными {data}")
|
||||
|
||||
try:
|
||||
async with aiohttp.ClientSession() as session:
|
||||
async with session.request(method, url, json=data) as response:
|
||||
logger.info(
|
||||
f"Получен ответ от {url}: статус {response.status}")
|
||||
f"[start] Ответ от {url}: статус {response.status}"
|
||||
)
|
||||
|
||||
if response.status in {200, 201}:
|
||||
result = await response.json()
|
||||
logger.debug(f"Ответ JSON: {result}")
|
||||
logger.debug(f"[start] Ответ JSON: {result}")
|
||||
return result
|
||||
if response.status == 404:
|
||||
logger.debug(f"Код {response.status}, возвращаю ничего")
|
||||
logger.debug("[start] Получен 404, возвращаю None")
|
||||
return None
|
||||
|
||||
logger.error(
|
||||
f"Ошибка в запросе: статус {response.status}, причина {response.reason}")
|
||||
f"[start] Ошибка в запросе: статус {response.status}, "
|
||||
f"причина {response.reason}"
|
||||
)
|
||||
return "ERROR"
|
||||
except Exception as e:
|
||||
logger.exception(f"Исключение при выполнении запроса к {url}: {e}")
|
||||
logger.exception(f"[start] Исключение при запросе к {url}: {e}")
|
||||
return "ERROR"
|
||||
|
||||
|
||||
def _welcome_text(username: str | None) -> str:
|
||||
uname = username or "птенец"
|
||||
return (
|
||||
f"🪽 Добро пожаловать в Lark VPN, {uname}!\n\n"
|
||||
"Здесь ты получаешь стабильный доступ к TikTok, YouTube, Discord, Instagram "
|
||||
"и другим сервисам без ограничений.\n\n"
|
||||
"1️⃣ Пополни баланс\n"
|
||||
"2️⃣ Выбери подходящий тариф\n"
|
||||
"3️⃣ Подключай конфиг на своих устройствах и забудь про блокировки.\n\n"
|
||||
"Следи за акциями и розыгрышами в канале:\n"
|
||||
"https://t.me/+0z5xqn3F1m02OTJi\n\n"
|
||||
"Lark держит связь. 🐣🦅"
|
||||
)
|
||||
"""
|
||||
Текст приветствия в /start и в главном меню.
|
||||
"""
|
||||
return "🥚 Lark Security\n\nВыберите действие из меню ниже."
|
||||
|
||||
|
||||
def _parse_referrer_id(message: Message) -> int | None:
|
||||
"""
|
||||
Достаём ref_<telegram_id> из /start.
|
||||
Примеры:
|
||||
/start
|
||||
/start ref_123456789
|
||||
"""
|
||||
text = message.text or ""
|
||||
parts = text.split(maxsplit=1)
|
||||
if len(parts) < 2:
|
||||
return None
|
||||
|
||||
arg = parts[1].strip()
|
||||
if not arg.startswith("ref_"):
|
||||
return None
|
||||
|
||||
raw_id = arg[4:]
|
||||
if not raw_id.isdigit():
|
||||
return None
|
||||
|
||||
try:
|
||||
return int(raw_id)
|
||||
except ValueError:
|
||||
return None
|
||||
|
||||
|
||||
@router.message(Command("start"))
|
||||
async def start_command(message: Message):
|
||||
"""
|
||||
Обработчик команды /start.
|
||||
Визуал и текст — обновлены, логика работы с API не тронута.
|
||||
/start c обработкой реферального параметра.
|
||||
"""
|
||||
user_id = message.from_user.id
|
||||
username = message.from_user.username
|
||||
referrer_id = _parse_referrer_id(message)
|
||||
|
||||
logger.info(
|
||||
f"Получена команда /start от пользователя: "
|
||||
f"{message.from_user.id} ({message.from_user.username})"
|
||||
f"[start] Команда /start от {user_id} (@{username}), "
|
||||
f"text={message.text!r}, referrer_id={referrer_id}"
|
||||
)
|
||||
|
||||
try:
|
||||
user_data = await call_api("GET", f"/user/{message.from_user.id}")
|
||||
if not user_data:
|
||||
logger.debug(
|
||||
"Пользователь не найден в базе, создаем новую запись.")
|
||||
await call_api("POST", "/user/create", {"telegram_id": message.from_user.id})
|
||||
# 1. Проверяем, есть ли пользователь в БД
|
||||
existing = await call_api("GET", f"/user/{user_id}")
|
||||
user_exists = existing not in (None, "ERROR")
|
||||
|
||||
logger.debug("Отправка приветственного сообщения пользователю.")
|
||||
# 2. Если пользователя нет — создаём
|
||||
if not user_exists:
|
||||
logger.debug(f"[start] Пользователь {user_id} не найден, создаю.")
|
||||
create_result = await call_api(
|
||||
"POST",
|
||||
"/user/create",
|
||||
{"telegram_id": user_id},
|
||||
)
|
||||
if create_result == "ERROR":
|
||||
logger.error(
|
||||
f"[start] Не удалось создать пользователя {user_id} в БД"
|
||||
)
|
||||
|
||||
# 3. Обработка рефералки, если параметр есть
|
||||
if referrer_id is not None:
|
||||
# 3.1. Самореферал
|
||||
if referrer_id == user_id:
|
||||
logger.info(
|
||||
f"[start] Пользователь {user_id} попытался зайти "
|
||||
f"по своей реферальной ссылке."
|
||||
)
|
||||
await message.answer(
|
||||
"Нельзя переходить по своей же реферальной ссылке."
|
||||
)
|
||||
|
||||
# 3.2. Пользователь уже зарегистрирован в боте
|
||||
elif user_exists:
|
||||
logger.info(
|
||||
f"[start] Пользователь {user_id} уже есть в БД, "
|
||||
f"реферальная ссылка {referrer_id} не сработает."
|
||||
)
|
||||
await message.answer(
|
||||
"Вы уже зарегистрированы в боте, "
|
||||
"реферальная ссылка не сработает."
|
||||
)
|
||||
|
||||
# 3.3. Новый пользователь + чужая рефералка → регистрируем реферал
|
||||
else:
|
||||
payload = {
|
||||
"referrer_id": referrer_id,
|
||||
"telegram_id": user_id,
|
||||
}
|
||||
logger.info(
|
||||
f"[start] Фиксирую реферала в бекенде: {payload}"
|
||||
)
|
||||
result = await call_api(
|
||||
"POST",
|
||||
"/user/referrals/track",
|
||||
payload,
|
||||
)
|
||||
if result == "ERROR":
|
||||
logger.error(
|
||||
f"[start] Ошибка при фиксации реферала: {payload}"
|
||||
)
|
||||
await message.answer(
|
||||
"Вы вошли по реферальной ссылке."
|
||||
)
|
||||
|
||||
# 4. В любом случае показываем главное меню
|
||||
await message.answer(
|
||||
_welcome_text(message.from_user.username),
|
||||
_welcome_text(username),
|
||||
reply_markup=main_keyboard(),
|
||||
)
|
||||
logger.info("Приветственное сообщение отправлено.")
|
||||
logger.info(f"[start] Главное меню отправлено пользователю {user_id}.")
|
||||
|
||||
except Exception as e:
|
||||
logger.exception(
|
||||
f"Ошибка при обработке команды /start для пользователя "
|
||||
f"[start] Ошибка при обработке /start для пользователя {user_id}: {e}"
|
||||
)
|
||||
await message.answer("Произошла ошибка. Попробуйте позже.")
|
||||
|
||||
|
||||
@router.message(Command("referrals"))
|
||||
async def referrals_menu_command(message: Message):
|
||||
"""
|
||||
Команда /referrals из бокового меню Telegram.
|
||||
Показывает текст реферальной программы.
|
||||
"""
|
||||
logger.info(
|
||||
f"[start] Команда /referrals от {message.from_user.id} "
|
||||
f"(@{message.from_user.username})"
|
||||
)
|
||||
try:
|
||||
text = await _build_referral_text(message.bot, message.from_user.id)
|
||||
await message.answer(text, parse_mode=ParseMode.HTML)
|
||||
logger.info("[start] Реферальная программа отправлена пользователю.")
|
||||
except Exception as e:
|
||||
logger.exception(
|
||||
f"[start] Ошибка при обработке /referrals для пользователя "
|
||||
f"{message.from_user.id}: {e}"
|
||||
)
|
||||
await message.answer("Произошла ошибка. Попробуйте позже.")
|
||||
@@ -92,24 +198,27 @@ async def start_command(message: Message):
|
||||
@router.callback_query(lambda callback: callback.data == "base")
|
||||
async def start_callback_handler(callback: CallbackQuery):
|
||||
"""
|
||||
Обработчик callback_query с data="base".
|
||||
Возвращает пользователя в главное меню.
|
||||
Callback с data="base" — возврат в главное меню.
|
||||
"""
|
||||
try:
|
||||
user_data = await call_api("GET", f"/user/{callback.from_user.id}")
|
||||
if not user_data:
|
||||
user_id = callback.from_user.id
|
||||
username = callback.from_user.username
|
||||
logger.info(f"[start] callback 'base' от {user_id} (@{username})")
|
||||
|
||||
user_data = await call_api("GET", f"/user/{user_id}")
|
||||
if user_data in (None, "ERROR"):
|
||||
await call_api(
|
||||
"POST",
|
||||
"/user/create",
|
||||
{"telegram_id": callback.from_user.id},
|
||||
{"telegram_id": user_id},
|
||||
)
|
||||
|
||||
await callback.message.edit_text(
|
||||
_welcome_text(callback.from_user.username),
|
||||
_welcome_text(username),
|
||||
reply_markup=main_keyboard(),
|
||||
)
|
||||
except Exception as e:
|
||||
logger.exception(f"Ошибка при обработке callback с data='base': {e}")
|
||||
logger.exception(f"[start] Ошибка при обработке callback 'base': {e}")
|
||||
await callback.message.answer("Произошла ошибка. Попробуйте позже.")
|
||||
finally:
|
||||
await callback.answer()
|
||||
|
||||
@@ -1,168 +1,512 @@
|
||||
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.filters import Command
|
||||
from keyboard.keyboards import tarif_Lark_pro_keyboard, tarif_Lark_keyboard, tarif_confirm_keyboard,buy_keyboard
|
||||
import logging
|
||||
from datetime import datetime
|
||||
import aiohttp
|
||||
|
||||
from instences.config import BASE_URL_FASTAPI
|
||||
from keyboard.keyboards import (
|
||||
buy_keyboard,
|
||||
tarif_Lark_keyboard,
|
||||
tarif_Lark_pro_keyboard,
|
||||
tarif_Lark_family_keyboard,
|
||||
tarif_confirm_keyboard,
|
||||
subscriptions_card_keyboard,
|
||||
)
|
||||
|
||||
router = Router()
|
||||
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}"
|
||||
logger.info(f"Инициализация запроса: {method} {url} с данными {data}")
|
||||
logger.info(f"API {method} {url} data={data}")
|
||||
|
||||
try:
|
||||
async with aiohttp.ClientSession() as session:
|
||||
async with session.request(method, url, json=data) as response:
|
||||
logger.info(f"Получен ответ от {url}: статус {response.status}")
|
||||
|
||||
if response.status in {200, 201}:
|
||||
result = await response.json()
|
||||
logger.debug(f"Ответ JSON: {result}")
|
||||
return result
|
||||
if response.status in {404,400}:
|
||||
result = await response.json()
|
||||
logger.debug(f"Код {response.status}, возвращаю {result}")
|
||||
return result
|
||||
logger.error(f"Ошибка в запросе: статус {response.status}, причина {response.reason}")
|
||||
async with session.request(method, url, json=data) as resp:
|
||||
logger.info(f"API response {resp.status} {resp.reason}")
|
||||
if resp.status in {200, 201}:
|
||||
return await resp.json()
|
||||
if resp.status in {400, 404}:
|
||||
# Возвращаем JSON с detail, чтобы разобрать ошибку
|
||||
try:
|
||||
return await resp.json()
|
||||
except Exception:
|
||||
return None
|
||||
logger.error(f"Unexpected status {resp.status}: {await resp.text()}")
|
||||
return "ERROR"
|
||||
except Exception as e:
|
||||
logger.exception(f"Исключение при выполнении запроса к {url}: {e}")
|
||||
logger.exception(f"API exception {url}: {e}")
|
||||
return "ERROR"
|
||||
|
||||
|
||||
def escape_markdown_v2(text: str) -> str:
|
||||
"""
|
||||
Экранирует специальные символы для Markdown_V2.
|
||||
Экранирует спецсимволы для Markdown_V2.
|
||||
"""
|
||||
special_chars = r"_*[]()~`>#+-=|{}.!"
|
||||
for char in special_chars:
|
||||
text = text.replace(char, f"\\{char}")
|
||||
special_chars = r"_*[]()~`>#+-=|{}.!\\"
|
||||
for ch in special_chars:
|
||||
text = text.replace(ch, f"\\{ch}")
|
||||
return text
|
||||
|
||||
|
||||
def _plan_human_title(plan: str) -> str:
|
||||
"""
|
||||
Красивое имя тарифа по plan-строке из БД.
|
||||
"""
|
||||
if not plan:
|
||||
return "—"
|
||||
if plan.startswith("Lark_Standart"):
|
||||
return "Lark Basic"
|
||||
if plan.startswith("Lark_Pro"):
|
||||
return "Lark Pro"
|
||||
if plan.startswith("Lark_Family"):
|
||||
return "Lark Family"
|
||||
return plan
|
||||
|
||||
|
||||
async def _fetch_user_and_subs(telegram_id: int):
|
||||
"""
|
||||
Берём пользователя и список его подписок с backend.
|
||||
"""
|
||||
user = await call_api("GET", f"/user/{telegram_id}")
|
||||
if not user or not isinstance(user, dict):
|
||||
return None, []
|
||||
|
||||
user_id = user["telegram_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:
|
||||
await msg.answer(text)
|
||||
return
|
||||
|
||||
if not subs:
|
||||
text = (
|
||||
"⚪ У тебя пока нет активных подписок.\n\n"
|
||||
"Можешь подключить тариф через меню подписок."
|
||||
)
|
||||
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 supp(message: types.Message):
|
||||
async def cmd_subscriptions(message: types.Message):
|
||||
"""
|
||||
Меню системы подписок
|
||||
/subscriptions — открыть карточку подписок.
|
||||
"""
|
||||
text = ""
|
||||
uri = None # Инициализация переменной
|
||||
try:
|
||||
# Вызов API для получения URI
|
||||
result = await call_api("GET", f"/uri?telegram_id={message.from_user.id}")
|
||||
uri = result.get('detail', "Error") # Получаем URI из ответа или "Error", если ключ отсутствует
|
||||
|
||||
# Проверка результата
|
||||
if uri == "Error":
|
||||
text = escape_markdown_v2("Произошла ошибка при получении URI")
|
||||
elif uri == "SUB_ERROR":
|
||||
text = escape_markdown_v2("Вы ещё не приобрели подписки!!")
|
||||
elif "trojan" in uri:
|
||||
escaped_uri = escape_markdown_v2(uri) # Экранирование URI
|
||||
text = f"Ваша подписка: ```{escaped_uri}```"
|
||||
else:
|
||||
text = escape_markdown_v2("Произошла ошибка при обработке URI")
|
||||
except Exception as e:
|
||||
# Логирование ошибок
|
||||
logger.error(f"Ошибка при вызове API для подписки: {e}")
|
||||
text = escape_markdown_v2("Произошла неожиданная ошибка при получении подписки.")
|
||||
|
||||
# Ответ пользователю
|
||||
await message.answer(
|
||||
text,
|
||||
parse_mode=ParseMode.MARKDOWN_V2
|
||||
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_name": 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")
|
||||
async def buy_subscription_callback_handler(callback: types.CallbackQuery):
|
||||
"""
|
||||
Обработчик callback_query с data="buy_subscription".
|
||||
Меню выбора тарифа: Basic / Pro / Family + показ баланса.
|
||||
"""
|
||||
await callback.message.edit_text(
|
||||
f"Ознакомься с условиями в вкладке \"О тарифах\" и выбери подходящий 🦅",
|
||||
reply_markup=buy_keyboard()
|
||||
user_data = await call_api("GET", f"/user/{callback.from_user.id}")
|
||||
balance = user_data.get("balance", 0) if user_data else "?"
|
||||
|
||||
text = (
|
||||
"➕ <b>Подключить новую подписку</b>\n\n"
|
||||
"🐣 Lark Basic - 200 ₽ / мес\n"
|
||||
"🦅 Lark Pro - 400 ₽ / мес\n"
|
||||
"👨👩👧 Lark Family - 700 ₽ / мес\n\n"
|
||||
f"💰 Баланс: {balance} ₽\n\n"
|
||||
"Выбери тариф:"
|
||||
)
|
||||
|
||||
await callback.message.edit_text(
|
||||
text,
|
||||
parse_mode=ParseMode.HTML,
|
||||
reply_markup=buy_keyboard(),
|
||||
)
|
||||
await callback.answer()
|
||||
|
||||
|
||||
@router.callback_query(lambda callback: callback.data == "subs")
|
||||
async def subs_callback_handler(callback: types.CallbackQuery):
|
||||
"""
|
||||
Обработчик callback_query с data="subs".
|
||||
"""
|
||||
Кнопка 'Lark Basic' — раскрываем варианты сроков.
|
||||
"""
|
||||
await callback.message.edit_text(
|
||||
"Подписки птенчик",
|
||||
reply_markup=tarif_Lark_keyboard()
|
||||
"Тариф Lark Basic — выбери срок:",
|
||||
reply_markup=tarif_Lark_keyboard(),
|
||||
)
|
||||
await callback.answer()
|
||||
|
||||
|
||||
@router.callback_query(lambda callback: callback.data == "subs_pro")
|
||||
async def subs_pro_callback_handler(callback: types.CallbackQuery):
|
||||
"""
|
||||
Обработчик callback_query с data="subs_pro".
|
||||
"""
|
||||
Кнопка 'Lark Pro'.
|
||||
"""
|
||||
await callback.message.edit_text(
|
||||
"Подписки птенчик ПРО",
|
||||
reply_markup=tarif_Lark_pro_keyboard()
|
||||
"Тариф Lark Pro — выбери срок:",
|
||||
reply_markup=tarif_Lark_pro_keyboard(),
|
||||
)
|
||||
await callback.answer()
|
||||
|
||||
|
||||
@router.callback_query(lambda callback: callback.data == "subs_family")
|
||||
async def subs_family_callback_handler(callback: types.CallbackQuery):
|
||||
"""
|
||||
Кнопка 'Lark Family'.
|
||||
"""
|
||||
await callback.message.edit_text(
|
||||
"Тариф Lark Family — выбери срок:",
|
||||
reply_markup=tarif_Lark_family_keyboard(),
|
||||
)
|
||||
await callback.answer()
|
||||
|
||||
|
||||
@router.callback_query(lambda callback: callback.data.startswith("Lark:"))
|
||||
async def lark_tariff_callback_handler(callback: types.CallbackQuery):
|
||||
"""
|
||||
Обработчик для выбора тарифа Lark.
|
||||
Обработчик выбора конкретного тарифа Lark.
|
||||
callback_data: Lark:<Class>:<months>
|
||||
"""
|
||||
data = callback.data.split(":")
|
||||
tariff_name = data[0]
|
||||
tariff_class = data[1]
|
||||
tariff_time = int(data[2])
|
||||
try:
|
||||
_, tariff_class, months_str = callback.data.split(":")
|
||||
months = int(months_str)
|
||||
except Exception:
|
||||
await callback.message.answer("Некорректные данные тарифа.")
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
# Определение окончания для месяцев
|
||||
if tariff_time == 1:
|
||||
months = f"{tariff_time} месяц"
|
||||
elif 2 <= tariff_time <= 4:
|
||||
months = f"{tariff_time} месяца"
|
||||
if months == 1:
|
||||
months_label = "1 месяц"
|
||||
elif 2 <= months <= 4:
|
||||
months_label = f"{months} месяца"
|
||||
else:
|
||||
months = f"{tariff_time} месяцев"
|
||||
months_label = f"{months} месяцев"
|
||||
|
||||
text = f"Тариф {tariff_name} на {months}. Продолжите покупку..."
|
||||
|
||||
# Рендеринг клавиатуры
|
||||
keyboard = tarif_confirm_keyboard(tariff_name, tariff_time, tariff_class)
|
||||
text = f"Тариф Lark {tariff_class} на {months_label}. Продолжить покупку?"
|
||||
|
||||
keyboard = tarif_confirm_keyboard("Lark", months, tariff_class)
|
||||
await callback.message.edit_text(text=text, reply_markup=keyboard)
|
||||
await callback.answer()
|
||||
|
||||
|
||||
@router.callback_query(lambda callback: callback.data.startswith("confirm:"))
|
||||
async def confirm_callback_handler(callback: types.CallbackQuery):
|
||||
"""
|
||||
Обработчик подтверждения подписки.
|
||||
Подтверждение покупки тарифа.
|
||||
"""
|
||||
try:
|
||||
data = callback.data.split(":")[1]
|
||||
tariff_info = data.split("_")
|
||||
plan_id = f"{tariff_info[0]}_{tariff_info[1]}_{tariff_info[2]}"
|
||||
result = await call_api("POST", "/subscription/buy", {"telegram_id": callback.from_user.id, "plan_name": "basic"})
|
||||
detail = result.get("detail", {})
|
||||
|
||||
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("uri", {})
|
||||
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:
|
||||
data = callback.data.split(":", maxsplit=1)[1]
|
||||
name, classif, amount_str = data.split("_")
|
||||
plan_id = f"{name}_{classif}_{amount_str}"
|
||||
except Exception:
|
||||
await callback.message.edit_text("Некорректные данные тарифа.")
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
result = await call_api(
|
||||
"POST",
|
||||
"/subscription/buy",
|
||||
{"telegram_id": str(callback.from_user.id), "plan_name": 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,356 +1,452 @@
|
||||
from aiogram.utils.keyboard import InlineKeyboardBuilder, ReplyKeyboardBuilder
|
||||
from aiogram.types import InlineKeyboardButton, KeyboardButton
|
||||
|
||||
|
||||
def main_keyboard():
|
||||
"""
|
||||
Главное меню (только визуал перетянут под твой стиль)
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(InlineKeyboardButton(
|
||||
text="📜 Профиль", callback_data="profile"))
|
||||
builder.row(InlineKeyboardButton(text="❔ FAQ ❔", callback_data="faq"))
|
||||
# Оставляем URL как у Вовы, меняем только текст
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="ℹ️ О нас",
|
||||
url="https://www.youtube.com/watch?v=Zirn-CKck-c"
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def account_keyboard():
|
||||
"""
|
||||
Аккаунт / профиль
|
||||
Визуал — твой, callback_data — как у Вовы.
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🪙 Пополнить баланс",
|
||||
callback_data="popup",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🦴 Мои подписки",
|
||||
callback_data="buy_subscription",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="📡 Руководство по подключению",
|
||||
callback_data="guide",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🧾 История транзакций",
|
||||
callback_data="tranhist",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Назад",
|
||||
callback_data="base",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def ticket_list_keyboard(tickets):
|
||||
builder = InlineKeyboardBuilder()
|
||||
for ticket in tickets:
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text=f"Тикет: {ticket['subject']}",
|
||||
callback_data=f"ticket_{ticket['id']}",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Назад",
|
||||
callback_data="main_sup",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def sup_keyboard():
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="📝 Создать запрос",
|
||||
callback_data="make_ticket",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="📂 Мои запросы",
|
||||
callback_data="my_tickets",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def ticket_keyboard():
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Отмена",
|
||||
callback_data="cancel",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def buy_keyboard():
|
||||
"""
|
||||
Меню выбора тарифа.
|
||||
Лейблы ближе к твоему стилю, но callback’и остаются старые.
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🐣 Lark (Basic)",
|
||||
callback_data="subs",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🦅 Lark Pro",
|
||||
callback_data="subs_pro",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="ℹ️ О тарифах",
|
||||
url="https://t.me/proxylark/19",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Назад",
|
||||
callback_data="profile",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def subhist_keyboard():
|
||||
"""
|
||||
Подписки — история/список
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Назад",
|
||||
callback_data="profile",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def popup_keyboard():
|
||||
"""
|
||||
Пополнение (суммы, стиль как в твоём topup_menu)
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(text="200 ₽", callback_data="popup:200"),
|
||||
InlineKeyboardButton(text="500 ₽", callback_data="popup:500"),
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(text="1000 ₽", callback_data="popup:1000"),
|
||||
InlineKeyboardButton(text="2000 ₽", callback_data="popup:2000"),
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(text="3000 ₽", callback_data="popup:3000"),
|
||||
InlineKeyboardButton(text="5000 ₽", callback_data="popup:5000"),
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Назад",
|
||||
callback_data="profile",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def balance_keyboard():
|
||||
"""
|
||||
Баланс
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🪙 Пополнить баланс",
|
||||
callback_data="popup",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🧾 История транзакций",
|
||||
callback_data="tranhist",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Назад",
|
||||
callback_data="profile",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def tarif_Lark_keyboard():
|
||||
"""
|
||||
Тариф Lark (Standart) — только подписи меняем.
|
||||
"""
|
||||
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():
|
||||
"""
|
||||
Тариф Lark Pro
|
||||
"""
|
||||
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 guide_keyboard():
|
||||
"""
|
||||
Руководство по подключению
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="📱 iOS / Android",
|
||||
callback_data="mob",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="💻 Windows / macOS",
|
||||
callback_data="pc",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Назад",
|
||||
callback_data="profile",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def faq_keyboard():
|
||||
"""
|
||||
FAQ
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Назад",
|
||||
callback_data="base",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def tranhist_keyboard():
|
||||
"""
|
||||
История транзакций
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Назад",
|
||||
callback_data="profile",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def tarif_confirm_keyboard(name, amount, classif):
|
||||
"""
|
||||
Подтверждение покупки тарифа
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="✅ Подтвердить",
|
||||
callback_data=f"confirm:{name}_{classif}_{amount}",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Отменить",
|
||||
callback_data="buy_subscription",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def confirm_popup_keyboard():
|
||||
"""
|
||||
Подтверждение пополнения — без «иди нахуй», мы же под босса господина ларк это красим....
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="✅ Готово, вернуться в профиль",
|
||||
callback_data="profile",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
from aiogram.utils.keyboard import InlineKeyboardBuilder, ReplyKeyboardBuilder
|
||||
from aiogram.types import InlineKeyboardButton, KeyboardButton
|
||||
|
||||
|
||||
def main_keyboard():
|
||||
"""
|
||||
Главное меню
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="📜 Профиль",
|
||||
callback_data="profile",
|
||||
)
|
||||
)
|
||||
# ------
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="❔ FAQ ❔",
|
||||
callback_data="faq",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="ℹ️ О нас",
|
||||
url="https://www.youtube.com/watch?v=Zirn-CKck-c",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def account_keyboard():
|
||||
"""
|
||||
Клавиатура профиля:
|
||||
пополнить баланс, история транзакций, назад в главное меню.
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🪙 Пополнить баланс",
|
||||
callback_data="balance",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🧾 История транзакций",
|
||||
callback_data="tranhist",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Назад",
|
||||
callback_data="base",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def balance_keyboard():
|
||||
"""
|
||||
Экран баланса
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🪙 Пополнить баланс",
|
||||
callback_data="popup",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🧾 История транзакций",
|
||||
callback_data="tranhist",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Назад",
|
||||
callback_data="profile",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def popup_keyboard():
|
||||
"""
|
||||
Суммы пополнения: 200, 300, 600, 1000 ₽.
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(text="200 ₽", callback_data="popup:200"),
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(text="300 ₽", callback_data="popup:300"),
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(text="600 ₽", callback_data="popup:600"),
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(text="1000 ₽", callback_data="popup:1000"),
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Назад",
|
||||
callback_data="profile", # назад в профиль
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def payment_methods_keyboard(amount: int):
|
||||
"""
|
||||
Способы оплаты для выбранной суммы.
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="⭐ Telegram Stars",
|
||||
callback_data=f"method_stars_{amount}",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="💵 YooKassa",
|
||||
callback_data=f"method_ykassa_{amount}",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🪙 CryptoBot",
|
||||
callback_data=f"method_crypto_{amount}",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Назад",
|
||||
callback_data="popup",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def ticket_list_keyboard(tickets):
|
||||
builder = InlineKeyboardBuilder()
|
||||
for ticket in tickets:
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text=f"Тикет: {ticket['subject']}",
|
||||
callback_data=f"ticket_{ticket['id']}",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Назад",
|
||||
callback_data="main_sup",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def sup_keyboard():
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="📝 Создать запрос",
|
||||
callback_data="make_ticket",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="📂 Мои запросы",
|
||||
callback_data="my_tickets",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def ticket_keyboard():
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Отмена",
|
||||
callback_data="cancel",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def buy_keyboard():
|
||||
"""
|
||||
Меню выбора тарифа.
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🐣 Lark Basic",
|
||||
callback_data="subs",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🦅 Lark Pro",
|
||||
callback_data="subs_pro",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="👨👩👧 Lark Family",
|
||||
callback_data="subs_family",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Назад",
|
||||
callback_data="profile",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def tarif_Lark_keyboard():
|
||||
"""
|
||||
Тариф Lark Basic (Standart)
|
||||
"""
|
||||
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():
|
||||
"""
|
||||
Тариф Lark Pro
|
||||
"""
|
||||
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():
|
||||
"""
|
||||
Тариф Lark Family.
|
||||
"""
|
||||
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()
|
||||
|
||||
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(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Назад",
|
||||
callback_data="profile",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def guide_keyboard():
|
||||
"""
|
||||
Руководство по подключению
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="📱 iOS / Android",
|
||||
callback_data="mob",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="💻 Windows / macOS",
|
||||
callback_data="pc",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Назад",
|
||||
callback_data="profile",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def faq_keyboard():
|
||||
"""
|
||||
FAQ
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Назад",
|
||||
callback_data="base",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def tranhist_keyboard():
|
||||
"""
|
||||
История транзакций
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Назад",
|
||||
callback_data="profile",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def tarif_confirm_keyboard(name: str, amount: int, classif: str):
|
||||
"""
|
||||
Подтверждение покупки тарифа
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="✅ Подтвердить",
|
||||
callback_data=f"confirm:{name}_{classif}_{amount}",
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔙 Отменить",
|
||||
callback_data="buy_subscription",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
|
||||
def confirm_popup_keyboard():
|
||||
"""
|
||||
Подтверждение пополнения.
|
||||
"""
|
||||
builder = InlineKeyboardBuilder()
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="✅ Готово, вернуться в профиль",
|
||||
callback_data="profile",
|
||||
)
|
||||
)
|
||||
return builder.as_markup()
|
||||
|
||||
10
main.py
10
main.py
@@ -11,7 +11,8 @@ import logging
|
||||
BOT_TOKEN = os.getenv("TOKEN")
|
||||
|
||||
if not BOT_TOKEN:
|
||||
raise ValueError("Не задан токен бота. Убедитесь, что переменная окружения 'TOKEN' установлена.")
|
||||
raise ValueError(
|
||||
"Не задан токен бота. Убедитесь, что переменная окружения 'TOKEN' установлена.")
|
||||
|
||||
bot = Bot(token=BOT_TOKEN)
|
||||
dp = Dispatcher()
|
||||
@@ -23,9 +24,10 @@ dp.message.middleware(AntiSpamMiddleware(rate_limit=1))
|
||||
async def set_commands():
|
||||
"""Устанавливает команды для бота."""
|
||||
commands = [
|
||||
BotCommand(command="/start", description="🥚Главное меню"),
|
||||
BotCommand(command="/subscriptions", description="🦴Мои подписки"),
|
||||
BotCommand(command="/support", description="❕Поддержка❕"),
|
||||
BotCommand(command="start", description="Запуск бота"),
|
||||
BotCommand(command="subscriptions", description="Мои подписки"),
|
||||
BotCommand(command="support", description="Техподдержка"),
|
||||
BotCommand(command="referrals", description="Реферальная программа"),
|
||||
]
|
||||
await bot.set_my_commands(commands)
|
||||
|
||||
|
||||
Reference in New Issue
Block a user