5 Commits

View File

@@ -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()