Compare commits
5 Commits
d1417653c3
...
0d9a86ee54
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
0d9a86ee54 | ||
|
|
12c60b884a | ||
|
|
6276490ee1 | ||
|
|
3e976d9960 | ||
|
|
77ca27a09c |
@@ -24,16 +24,21 @@ router = Router()
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
async def call_api(method, endpoint, data=None):
|
||||
async def call_api(method, endpoint, data=None,base_url = BASE_URL_FASTAPI):
|
||||
"""
|
||||
Выполняет HTTP-запрос к FastAPI.
|
||||
"""
|
||||
url = f"{BASE_URL_FASTAPI}{endpoint}"
|
||||
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) as response:
|
||||
async with session.request(
|
||||
method,
|
||||
url,
|
||||
json=data,
|
||||
headers={"Content-Type": "application/json"}
|
||||
) as response:
|
||||
logger.info(
|
||||
f"Получен ответ от {url}: статус {response.status}"
|
||||
)
|
||||
@@ -71,7 +76,7 @@ async def profile_callback_handler(callback: CallbackQuery):
|
||||
|
||||
# Последняя подписка пользователя
|
||||
sub_data = await call_api(
|
||||
"GET", f"/subscription/{user_data['id']}/last"
|
||||
"GET", f"/subscription/{user_data['telegram_id']}/last"
|
||||
)
|
||||
if sub_data == "ERROR" or not isinstance(sub_data, dict):
|
||||
sub_data = None
|
||||
@@ -171,7 +176,7 @@ async def tranhist_callback_handler(callback: CallbackQuery):
|
||||
|
||||
try:
|
||||
transactions = await call_api(
|
||||
"GET", f"/user/{user_data['id']}/transactions"
|
||||
"GET", f"/user/{user_data['telegram_id']}/transactions"
|
||||
)
|
||||
if not transactions:
|
||||
await callback.message.edit_text(
|
||||
@@ -247,13 +252,55 @@ async def method_stars_handler(callback: CallbackQuery):
|
||||
@router.callback_query(lambda callback: callback.data.startswith("method_ykassa_"))
|
||||
async def method_ykassa_handler(callback: CallbackQuery):
|
||||
"""
|
||||
Заглушка: оплата через YooKassa.
|
||||
Обработчик оплаты через YooKassa.
|
||||
"""
|
||||
amount = callback.data.split("_")[-1]
|
||||
|
||||
# Формируем URL с query parameters вместо JSON body
|
||||
endpoint = f"/billing/payments/init?user_id={callback.from_user.id}&amount={float(amount)}&provider=yookassa"
|
||||
|
||||
logger.info(f"Отправка запроса на инициализацию платежа: {endpoint}")
|
||||
|
||||
# Отправляем POST запрос с пустым телом (параметры в URL)
|
||||
result = await call_api("POST", endpoint, None, "http://billing:8000")
|
||||
|
||||
if result == "ERROR":
|
||||
await callback.message.edit_text(
|
||||
"❌ Произошла ошибка при создании платежа. Попробуйте позже."
|
||||
)
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
# Проверяем успешность операции
|
||||
if not result.get("success", False):
|
||||
error_msg = result.get("error", "Неизвестная ошибка")
|
||||
await callback.message.edit_text(
|
||||
f"❌ Ошибка: {error_msg}"
|
||||
)
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
payment_url = result.get("confirmation_url", "#")
|
||||
payment_id = result.get("payment_id", "")
|
||||
|
||||
await callback.message.edit_text(
|
||||
f"💵 Оплата через YooKassa на {amount} ₽ пока в разработке.\n\n"
|
||||
"Функционал появится после настройки биллинга.",
|
||||
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="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()
|
||||
|
||||
|
||||
@@ -263,10 +310,50 @@ async def method_crypto_handler(callback: CallbackQuery):
|
||||
Заглушка: оплата через CryptoBot.
|
||||
"""
|
||||
amount = callback.data.split("_")[-1]
|
||||
endpoint = f"/billing/payments/init?user_id={callback.from_user.id}&amount={float(amount)}&provider=cryptobot"
|
||||
|
||||
logger.info(f"Отправка запроса на инициализацию платежа: {endpoint}")
|
||||
|
||||
# Отправляем POST запрос с пустым телом (параметры в URL)
|
||||
result = await call_api("POST", endpoint, None, "http://billing:8000")
|
||||
|
||||
if result == "ERROR":
|
||||
await callback.message.edit_text(
|
||||
"❌ Произошла ошибка при создании платежа. Попробуйте позже."
|
||||
)
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
# Проверяем успешность операции
|
||||
if not result.get("success", False):
|
||||
error_msg = result.get("error", "Неизвестная ошибка")
|
||||
await callback.message.edit_text(
|
||||
f"❌ Ошибка: {error_msg}"
|
||||
)
|
||||
await callback.answer()
|
||||
return
|
||||
|
||||
payment_url = result.get("confirmation_url", "#")
|
||||
payment_id = result.get("payment_id", "")
|
||||
|
||||
await callback.message.edit_text(
|
||||
f"🪙 Оплата через CryptoBot на {amount} ₽ пока в разработке.\n\n"
|
||||
"Платёжный шлюз будет добавлен позже.",
|
||||
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="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()
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user