Fringg
033d0da5e0
Platega API defines: 2=СБП, 11=Карточный эквайринг, 12=Международная, 13=Крипто. Code 10 does not exist in their API but was defined in our config as "Банковские карты (RUB)", while real code 11 was mislabeled as "Банковские карты". This caused two card options to appear in the admin panel, one of which didn't work. - Removed code 10 from definitions, defaults, allowed set, .env.example - Renamed code 11: "Банковские карты" → "Карты (RUB)" - Removed redundant filter in handlers/balance/platega.py - Updated tests to match
470 lines
18 KiB
Python
470 lines
18 KiB
Python
"""Handlers for Platega balance interactions."""
|
|
|
|
import html
|
|
|
|
import structlog
|
|
from aiogram import types
|
|
from aiogram.fsm.context import FSMContext
|
|
from sqlalchemy.ext.asyncio import AsyncSession
|
|
|
|
from app.config import settings
|
|
from app.database.models import User
|
|
from app.keyboards.inline import get_back_keyboard
|
|
from app.localization.texts import get_texts
|
|
from app.services.payment_service import PaymentService
|
|
from app.states import BalanceStates
|
|
from app.utils.decorators import error_handler
|
|
|
|
|
|
logger = structlog.get_logger(__name__)
|
|
|
|
|
|
def _get_active_methods() -> list[int]:
|
|
return settings.get_platega_active_methods()
|
|
|
|
|
|
async def _prompt_amount(
|
|
message: types.Message,
|
|
db_user: User,
|
|
state: FSMContext,
|
|
method_code: int,
|
|
) -> None:
|
|
texts = get_texts(db_user.language)
|
|
method_name = settings.get_platega_method_display_title(method_code)
|
|
|
|
# Всегда фиксируем выбранный метод для последующей обработки
|
|
await state.update_data(payment_method='platega', platega_method=method_code)
|
|
|
|
data = await state.get_data()
|
|
pending_amount = int(data.get('platega_pending_amount') or 0)
|
|
|
|
if pending_amount > 0:
|
|
# Если сумма уже известна (например, после быстрого выбора),
|
|
# сразу создаём платеж и сбрасываем временное значение.
|
|
await state.update_data(platega_pending_amount=None)
|
|
|
|
from app.database.database import AsyncSessionLocal
|
|
|
|
async with AsyncSessionLocal() as db:
|
|
await process_platega_payment_amount(
|
|
message,
|
|
db_user,
|
|
db,
|
|
pending_amount,
|
|
state,
|
|
)
|
|
return
|
|
|
|
min_amount_label = settings.format_price(settings.PLATEGA_MIN_AMOUNT_KOPEKS)
|
|
max_amount_kopeks = settings.PLATEGA_MAX_AMOUNT_KOPEKS
|
|
max_amount_label = settings.format_price(max_amount_kopeks) if max_amount_kopeks and max_amount_kopeks > 0 else ''
|
|
|
|
default_prompt_body = (
|
|
'Введите сумму для пополнения от {min_amount} до {max_amount}.\n'
|
|
if max_amount_kopeks and max_amount_kopeks > 0
|
|
else 'Введите сумму для пополнения от {min_amount}.\n'
|
|
)
|
|
|
|
prompt_template = texts.t(
|
|
'PLATEGA_TOPUP_PROMPT',
|
|
(f'💳 <b>Оплата через Platega ({{method_name}})</b>\n\n{default_prompt_body}Оплата происходит через Platega.'),
|
|
)
|
|
|
|
keyboard = get_back_keyboard(db_user.language)
|
|
|
|
await message.edit_text(
|
|
prompt_template.format(
|
|
method_name=method_name,
|
|
min_amount=min_amount_label,
|
|
max_amount=max_amount_label,
|
|
),
|
|
reply_markup=keyboard,
|
|
parse_mode='HTML',
|
|
)
|
|
|
|
await state.set_state(BalanceStates.waiting_for_amount)
|
|
await state.update_data(
|
|
platega_prompt_message_id=message.message_id,
|
|
platega_prompt_chat_id=message.chat.id,
|
|
)
|
|
|
|
|
|
@error_handler
|
|
async def start_platega_payment(
|
|
callback: types.CallbackQuery,
|
|
db_user: User,
|
|
state: FSMContext,
|
|
):
|
|
texts = get_texts(db_user.language)
|
|
|
|
# Проверка ограничения на пополнение
|
|
if getattr(db_user, 'restriction_topup', False):
|
|
reason = html.escape(getattr(db_user, 'restriction_reason', None) or 'Действие ограничено администратором')
|
|
support_url = settings.get_support_contact_url()
|
|
keyboard = []
|
|
if support_url:
|
|
keyboard.append([types.InlineKeyboardButton(text='🆘 Обжаловать', url=support_url)])
|
|
keyboard.append([types.InlineKeyboardButton(text=texts.BACK, callback_data='menu_balance')])
|
|
|
|
await callback.message.edit_text(
|
|
f'🚫 <b>Пополнение ограничено</b>\n\n{reason}\n\n'
|
|
'Если вы считаете это ошибкой, вы можете обжаловать решение.',
|
|
reply_markup=types.InlineKeyboardMarkup(inline_keyboard=keyboard),
|
|
)
|
|
await callback.answer()
|
|
return
|
|
|
|
if not settings.is_platega_enabled():
|
|
await callback.answer(
|
|
texts.t(
|
|
'PLATEGA_TEMPORARILY_UNAVAILABLE',
|
|
'❌ Оплата через Platega временно недоступна',
|
|
),
|
|
show_alert=True,
|
|
)
|
|
return
|
|
|
|
active_methods = _get_active_methods()
|
|
if not active_methods:
|
|
await callback.answer(
|
|
texts.t(
|
|
'PLATEGA_METHODS_NOT_CONFIGURED',
|
|
'⚠️ На стороне Platega нет доступных методов оплаты',
|
|
),
|
|
show_alert=True,
|
|
)
|
|
return
|
|
|
|
await state.update_data(payment_method='platega')
|
|
data = await state.get_data()
|
|
has_pending_amount = bool(int(data.get('platega_pending_amount') or 0))
|
|
|
|
if len(active_methods) == 1:
|
|
await _prompt_amount(callback.message, db_user, state, active_methods[0])
|
|
await callback.answer()
|
|
return
|
|
|
|
method_buttons: list[list[types.InlineKeyboardButton]] = []
|
|
for method_code in active_methods:
|
|
label = settings.get_platega_method_display_title(method_code)
|
|
method_buttons.append(
|
|
[
|
|
types.InlineKeyboardButton(
|
|
text=label,
|
|
callback_data=f'platega_method_{method_code}',
|
|
)
|
|
]
|
|
)
|
|
|
|
method_buttons.append([types.InlineKeyboardButton(text=texts.BACK, callback_data='balance_topup')])
|
|
|
|
await callback.message.edit_text(
|
|
texts.t(
|
|
'PLATEGA_SELECT_PAYMENT_METHOD',
|
|
'Выберите способ оплаты Platega:',
|
|
),
|
|
reply_markup=types.InlineKeyboardMarkup(inline_keyboard=method_buttons),
|
|
)
|
|
if not has_pending_amount:
|
|
await state.set_state(BalanceStates.waiting_for_platega_method)
|
|
await callback.answer()
|
|
|
|
|
|
@error_handler
|
|
async def handle_platega_method_selection(
|
|
callback: types.CallbackQuery,
|
|
db_user: User,
|
|
state: FSMContext,
|
|
):
|
|
try:
|
|
method_code = int(callback.data.rsplit('_', 1)[-1])
|
|
except ValueError:
|
|
await callback.answer('❌ Некорректный способ оплаты', show_alert=True)
|
|
return
|
|
|
|
if method_code not in _get_active_methods():
|
|
await callback.answer('⚠️ Этот способ сейчас недоступен', show_alert=True)
|
|
return
|
|
|
|
await _prompt_amount(callback.message, db_user, state, method_code)
|
|
await callback.answer()
|
|
|
|
|
|
@error_handler
|
|
async def start_platega_direct_method(
|
|
callback: types.CallbackQuery,
|
|
db_user: User,
|
|
state: FSMContext,
|
|
):
|
|
"""Handle direct Platega method selection from the main payment screen (inline mode)."""
|
|
texts = get_texts(db_user.language)
|
|
|
|
try:
|
|
method_code = int(callback.data.removeprefix('topup_platega_m'))
|
|
except (ValueError, IndexError):
|
|
await callback.answer('❌ Некорректный способ оплаты', show_alert=True)
|
|
return
|
|
|
|
if getattr(db_user, 'restriction_topup', False):
|
|
reason = html.escape(getattr(db_user, 'restriction_reason', None) or 'Действие ограничено администратором')
|
|
support_url = settings.get_support_contact_url()
|
|
keyboard = []
|
|
if support_url:
|
|
keyboard.append([types.InlineKeyboardButton(text='🆘 Обжаловать', url=support_url)])
|
|
keyboard.append([types.InlineKeyboardButton(text=texts.BACK, callback_data='menu_balance')])
|
|
|
|
await callback.message.edit_text(
|
|
f'🚫 <b>Пополнение ограничено</b>\n\n{reason}\n\n'
|
|
'Если вы считаете это ошибкой, вы можете обжаловать решение.',
|
|
reply_markup=types.InlineKeyboardMarkup(inline_keyboard=keyboard),
|
|
)
|
|
await callback.answer()
|
|
return
|
|
|
|
if not settings.is_platega_enabled():
|
|
await callback.answer(
|
|
texts.t(
|
|
'PLATEGA_TEMPORARILY_UNAVAILABLE',
|
|
'❌ Оплата через Platega временно недоступна',
|
|
),
|
|
show_alert=True,
|
|
)
|
|
return
|
|
|
|
if method_code not in _get_active_methods():
|
|
await callback.answer('⚠️ Этот способ сейчас недоступен', show_alert=True)
|
|
return
|
|
|
|
await _prompt_amount(callback.message, db_user, state, method_code)
|
|
await callback.answer()
|
|
|
|
|
|
@error_handler
|
|
async def process_platega_payment_amount(
|
|
message: types.Message,
|
|
db_user: User,
|
|
db: AsyncSession,
|
|
amount_kopeks: int,
|
|
state: FSMContext,
|
|
):
|
|
texts = get_texts(db_user.language)
|
|
|
|
# Проверка ограничения на пополнение
|
|
if getattr(db_user, 'restriction_topup', False):
|
|
reason = html.escape(getattr(db_user, 'restriction_reason', None) or 'Действие ограничено администратором')
|
|
support_url = settings.get_support_contact_url()
|
|
keyboard = []
|
|
if support_url:
|
|
keyboard.append([types.InlineKeyboardButton(text='🆘 Обжаловать', url=support_url)])
|
|
keyboard.append([types.InlineKeyboardButton(text=texts.BACK, callback_data='menu_balance')])
|
|
|
|
await message.answer(
|
|
f'🚫 <b>Пополнение ограничено</b>\n\n{reason}\n\n'
|
|
'Если вы считаете это ошибкой, вы можете обжаловать решение.',
|
|
reply_markup=types.InlineKeyboardMarkup(inline_keyboard=keyboard),
|
|
parse_mode='HTML',
|
|
)
|
|
await state.clear()
|
|
return
|
|
|
|
if not settings.is_platega_enabled():
|
|
await message.answer(
|
|
texts.t(
|
|
'PLATEGA_TEMPORARILY_UNAVAILABLE',
|
|
'❌ Оплата через Platega временно недоступна',
|
|
)
|
|
)
|
|
return
|
|
|
|
data = await state.get_data()
|
|
method_code = int(data.get('platega_method', 0))
|
|
if method_code not in _get_active_methods():
|
|
await message.answer(
|
|
texts.t(
|
|
'PLATEGA_METHOD_SELECTION_REQUIRED',
|
|
'⚠️ Выберите способ оплаты Platega перед вводом суммы',
|
|
)
|
|
)
|
|
await state.set_state(BalanceStates.waiting_for_platega_method)
|
|
return
|
|
|
|
if amount_kopeks < settings.PLATEGA_MIN_AMOUNT_KOPEKS:
|
|
await message.answer(
|
|
texts.t(
|
|
'PLATEGA_AMOUNT_TOO_LOW',
|
|
'Минимальная сумма для оплаты через Platega: {amount}',
|
|
).format(amount=settings.format_price(settings.PLATEGA_MIN_AMOUNT_KOPEKS)),
|
|
reply_markup=get_back_keyboard(db_user.language),
|
|
)
|
|
return
|
|
|
|
if amount_kopeks > settings.PLATEGA_MAX_AMOUNT_KOPEKS:
|
|
await message.answer(
|
|
texts.t(
|
|
'PLATEGA_AMOUNT_TOO_HIGH',
|
|
'Максимальная сумма для оплаты через Platega: {amount}',
|
|
).format(amount=settings.format_price(settings.PLATEGA_MAX_AMOUNT_KOPEKS)),
|
|
reply_markup=get_back_keyboard(db_user.language),
|
|
)
|
|
return
|
|
|
|
try:
|
|
payment_service = PaymentService(message.bot)
|
|
payment_result = await payment_service.create_platega_payment(
|
|
db=db,
|
|
user_id=db_user.id,
|
|
amount_kopeks=amount_kopeks,
|
|
description=settings.get_balance_payment_description(amount_kopeks, telegram_user_id=db_user.telegram_id),
|
|
language=db_user.language,
|
|
payment_method_code=method_code,
|
|
)
|
|
except Exception as error:
|
|
logger.exception('Ошибка создания платежа Platega', error=error)
|
|
payment_result = None
|
|
|
|
if not payment_result or not payment_result.get('redirect_url'):
|
|
await message.answer(
|
|
texts.t(
|
|
'PLATEGA_PAYMENT_ERROR',
|
|
'❌ Ошибка создания платежа Platega. Попробуйте позже или обратитесь в поддержку.',
|
|
)
|
|
)
|
|
await state.clear()
|
|
return
|
|
|
|
redirect_url = payment_result.get('redirect_url')
|
|
local_payment_id = payment_result.get('local_payment_id')
|
|
transaction_id = payment_result.get('transaction_id')
|
|
method_title = settings.get_platega_method_display_title(method_code)
|
|
|
|
keyboard = types.InlineKeyboardMarkup(
|
|
inline_keyboard=[
|
|
[
|
|
types.InlineKeyboardButton(
|
|
text=texts.t(
|
|
'PLATEGA_PAY_BUTTON',
|
|
'💳 Оплатить через {method}',
|
|
).format(method=method_title),
|
|
url=redirect_url,
|
|
)
|
|
],
|
|
[
|
|
types.InlineKeyboardButton(
|
|
text=texts.t('CHECK_STATUS_BUTTON', '📊 Проверить статус'),
|
|
callback_data=f'check_platega_{local_payment_id}',
|
|
)
|
|
],
|
|
[types.InlineKeyboardButton(text=texts.BACK, callback_data='balance_topup')],
|
|
]
|
|
)
|
|
|
|
instructions_template = texts.t(
|
|
'PLATEGA_PAYMENT_INSTRUCTIONS',
|
|
(
|
|
'💳 <b>Оплата через Platega ({method})</b>\n\n'
|
|
'💰 Сумма: {amount}\n'
|
|
'🆔 ID транзакции: {transaction}\n\n'
|
|
'📱 <b>Инструкция:</b>\n'
|
|
'1. Нажмите кнопку «Оплатить»\n'
|
|
'2. Следуйте подсказкам платёжной системы\n'
|
|
'3. Подтвердите перевод\n'
|
|
'4. Средства зачислятся автоматически\n\n'
|
|
'❓ Если возникнут проблемы, обратитесь в {support}'
|
|
),
|
|
)
|
|
|
|
state_data = await state.get_data()
|
|
prompt_message_id = state_data.get('platega_prompt_message_id')
|
|
prompt_chat_id = state_data.get('platega_prompt_chat_id', message.chat.id)
|
|
|
|
try:
|
|
await message.delete()
|
|
except Exception as delete_error: # pragma: no cover - зависит от прав бота
|
|
logger.warning('Не удалось удалить сообщение с суммой Platega', delete_error=delete_error)
|
|
|
|
if prompt_message_id:
|
|
try:
|
|
await message.bot.delete_message(prompt_chat_id, prompt_message_id)
|
|
except Exception as delete_error: # pragma: no cover - диагностический лог
|
|
logger.warning('Не удалось удалить сообщение с запросом суммы Platega', delete_error=delete_error)
|
|
|
|
invoice_message = await message.answer(
|
|
instructions_template.format(
|
|
method=method_title,
|
|
amount=settings.format_price(amount_kopeks),
|
|
transaction=transaction_id or local_payment_id,
|
|
support=settings.get_support_contact_display_html(),
|
|
),
|
|
reply_markup=keyboard,
|
|
parse_mode='HTML',
|
|
)
|
|
|
|
try:
|
|
from app.services import payment_service as payment_module
|
|
|
|
payment = await payment_module.get_platega_payment_by_id(db, local_payment_id)
|
|
if payment:
|
|
payment_metadata = dict(getattr(payment, 'metadata_json', {}) or {})
|
|
payment_metadata['invoice_message'] = {
|
|
'chat_id': invoice_message.chat.id,
|
|
'message_id': invoice_message.message_id,
|
|
}
|
|
await payment_module.update_platega_payment(
|
|
db,
|
|
payment=payment,
|
|
metadata=payment_metadata,
|
|
)
|
|
except Exception as error: # pragma: no cover - диагностический лог
|
|
logger.warning('Не удалось сохранить данные сообщения Platega', error=error)
|
|
|
|
await state.update_data(
|
|
platega_invoice_message_id=invoice_message.message_id,
|
|
platega_invoice_chat_id=invoice_message.chat.id,
|
|
)
|
|
|
|
await state.clear()
|
|
|
|
|
|
@error_handler
|
|
async def check_platega_payment_status(
|
|
callback: types.CallbackQuery,
|
|
db: AsyncSession,
|
|
):
|
|
try:
|
|
local_payment_id = int(callback.data.split('_')[-1])
|
|
except ValueError:
|
|
await callback.answer('❌ Некорректный идентификатор платежа', show_alert=True)
|
|
return
|
|
|
|
payment_service = PaymentService(callback.bot)
|
|
|
|
try:
|
|
status_info = await payment_service.get_platega_payment_status(db, local_payment_id)
|
|
except Exception as error:
|
|
logger.exception('Ошибка проверки статуса Platega', error=error)
|
|
await callback.answer('⚠️ Ошибка проверки статуса', show_alert=True)
|
|
return
|
|
|
|
if not status_info:
|
|
await callback.answer('⚠️ Платёж не найден', show_alert=True)
|
|
return
|
|
|
|
payment = status_info.get('payment')
|
|
status = status_info.get('status')
|
|
is_paid = status_info.get('is_paid')
|
|
|
|
language = 'ru'
|
|
user = getattr(payment, 'user', None)
|
|
if user and getattr(user, 'language', None):
|
|
language = user.language
|
|
|
|
texts = get_texts(language)
|
|
|
|
if is_paid:
|
|
await callback.answer(texts.t('PLATEGA_PAYMENT_ALREADY_CONFIRMED', '✅ Платёж уже зачислен'), show_alert=True)
|
|
else:
|
|
await callback.answer(
|
|
texts.t('PLATEGA_PAYMENT_STATUS', 'Текущий статус платежа: {status}').format(status=status),
|
|
show_alert=True,
|
|
)
|