diff --git a/app/handlers/balance/main.py b/app/handlers/balance/main.py index 42982fbc..e0b8abb9 100644 --- a/app/handlers/balance/main.py +++ b/app/handlers/balance/main.py @@ -395,6 +395,10 @@ async def handle_successful_topup_with_cart( success_text = ( f"✅ Баланс пополнен на {texts.format_price(amount_kopeks)}!\n\n" f"💰 Текущий баланс: {texts.format_price(user.balance_kopeks)}\n\n" + f"⚠️ Важно: Пополнение баланса не активирует подписку автоматически. " + f"Обязательно активируйте подписку отдельно!\n\n" + f"🔄 При наличии сохранённой корзины подписки и включенной автопокупке, " + f"подписка будет приобретена автоматически после пополнения баланса.\n\n" f"🛒 У вас есть сохраненная корзина подписки\n" f"Стоимость: {texts.format_price(total_price)}\n\n" f"Хотите продолжить оформление?" @@ -770,6 +774,13 @@ async def handle_topup_amount_callback( await process_heleket_payment_amount( callback.message, db_user, db, amount_kopeks, state ) + elif method == "wata": + from app.database.database import AsyncSessionLocal + from .wata import process_wata_payment_amount + async with AsyncSessionLocal() as db: + await process_wata_payment_amount( + callback.message, db_user, db, amount_kopeks, state + ) elif method == "stars": from .stars import process_stars_payment_amount await process_stars_payment_amount( diff --git a/app/handlers/stars_payments.py b/app/handlers/stars_payments.py index 3186ca6c..4b49f51f 100644 --- a/app/handlers/stars_payments.py +++ b/app/handlers/stars_payments.py @@ -130,6 +130,10 @@ async def handle_successful_payment( "⭐ Потрачено звезд: {stars_spent}\n" "💰 Зачислено на баланс: {amount} ₽\n" "🆔 ID транзакции: {transaction_id}...\n\n" + "⚠️ Важно: Пополнение баланса не активирует подписку автоматически. " + "Обязательно активируйте подписку отдельно!\n\n" + "🔄 При наличии сохранённой корзины подписки и включенной автопокупке, " + "подписка будет приобретена автоматически после пополнения баланса.\n\n" "Спасибо за пополнение! 🚀", ).format( stars_spent=payment.total_amount, diff --git a/app/handlers/webhooks.py b/app/handlers/webhooks.py index 50a279ef..c6cd8ee7 100644 --- a/app/handlers/webhooks.py +++ b/app/handlers/webhooks.py @@ -114,7 +114,11 @@ async def handle_successful_payment(message: types.Message): ) await message.answer( - f"✅ Баланс успешно пополнен на {settings.format_price(amount_kopeks)}!" + f"✅ Баланс успешно пополнен на {settings.format_price(amount_kopeks)}!\n\n" + "⚠️ Важно: Пополнение баланса не активирует подписку автоматически. " + "Обязательно активируйте подписку отдельно!\n\n" + f"🔄 При наличии сохранённой корзины подписки и включенной автопокупке, " + f"подписка будет приобретена автоматически после пополнения баланса." ) logger.info(f"✅ Обработан Stars платеж: {payment.telegram_payment_charge_id}") diff --git a/app/localization/locales/en.json b/app/localization/locales/en.json index bdc2258e..7e6655ac 100644 --- a/app/localization/locales/en.json +++ b/app/localization/locales/en.json @@ -1242,7 +1242,7 @@ "SKIP_BUTTON": "Skip ➡️", "STARS_PAYMENT_ENROLLMENT_ERROR": "❌ Failed to credit funds. Please contact support; the payment will be verified manually.", "STARS_PAYMENT_PROCESSING_ERROR": "❌ Technical error processing the payment. Please contact support for assistance.", - "STARS_PAYMENT_SUCCESS": "🎉 Payment processed successfully!\n\n⭐ Stars spent: {stars_spent}\n💰 Added to balance: {amount} ₽\n🆔 Transaction ID: {transaction_id}...\n\nThank you for topping up! 🚀", + "STARS_PAYMENT_SUCCESS": "🎉 Payment processed successfully!\n\n⭐ Stars spent: {stars_spent}\n💰 Added to balance: {amount} ₽\n🆔 Transaction ID: {transaction_id}...\n\n⚠️ Important: Balance top-up does not automatically activate your subscription. Please activate your subscription separately!\n\n🔄 If you have a saved subscription cart and auto-purchase is enabled, your subscription will be automatically purchased after balance top-up.\n\nThank you for topping up! 🚀", "STARS_PAYMENT_USER_NOT_FOUND": "❌ Error: user not found. Please contact support.", "STARS_PRECHECK_INVALID_PAYLOAD": "Payment validation error. Please try again.", "STARS_PRECHECK_TECHNICAL_ERROR": "Technical error. Please try again later.", diff --git a/app/localization/locales/ru.json b/app/localization/locales/ru.json index 140353b3..cee78825 100644 --- a/app/localization/locales/ru.json +++ b/app/localization/locales/ru.json @@ -1262,7 +1262,7 @@ "SKIP_BUTTON": "⏭️ Пропустить", "STARS_PAYMENT_ENROLLMENT_ERROR": "❌ Произошла ошибка при зачислении средств. Обратитесь в поддержку, платеж будет проверен вручную.", "STARS_PAYMENT_PROCESSING_ERROR": "❌ Техническая ошибка при обработке платежа. Обратитесь в поддержку для решения проблемы.", - "STARS_PAYMENT_SUCCESS": "🎉 Платеж успешно обработан!\n\n⭐ Потрачено звезд: {stars_spent}\n💰 Зачислено на баланс: {amount} ₽\n🆔 ID транзакции: {transaction_id}...\n\nСпасибо за пополнение! 🚀", + "STARS_PAYMENT_SUCCESS": "🎉 Платеж успешно обработан!\n\n⭐ Потрачено звезд: {stars_spent}\n💰 Зачислено на баланс: {amount} ₽\n\n🆔 ID транзакции: {transaction_id}...\n\n⚠️ Важно: Пополнение баланса не активирует подписку автоматически. Обязательно активируйте подписку отдельно!\n\n🔄 При наличии сохранённой корзины подписки и включенной автопокупке, подписка будет приобретена автоматически после пополнения баланса.\n\nСпасибо за пополнение! 🚀", "STARS_PAYMENT_USER_NOT_FOUND": "❌ Ошибка: пользователь не найден. Обратитесь в поддержку.", "STARS_PRECHECK_INVALID_PAYLOAD": "Ошибка валидации платежа. Попробуйте еще раз.", "STARS_PRECHECK_TECHNICAL_ERROR": "Техническая ошибка. Попробуйте позже.", diff --git a/app/services/payment/common.py b/app/services/payment/common.py index 3fe7f99c..e1cf28b0 100644 --- a/app/services/payment/common.py +++ b/app/services/payment/common.py @@ -42,6 +42,7 @@ class PaymentCommonMixin: user and user.subscription and not user.subscription.is_trial and user.subscription.is_active ) + # Создаем основную кнопку: если есть активная подписка - продлить, иначе купить first_button = build_miniapp_or_callback_button( text=( texts.MENU_EXTEND_SUBSCRIPTION @@ -53,7 +54,16 @@ class PaymentCommonMixin: ), ) - keyboard_rows: list[list[InlineKeyboardButton]] = [[first_button]] + # Кнопка активации подписки (всегда отображается) + activate_subscription_button = build_miniapp_or_callback_button( + text="🚀 Активировать подписку", + callback_data="menu_buy" # Используем ту же callback_data что и "Купить подписку" + ) + + keyboard_rows: list[list[InlineKeyboardButton]] = [ + [first_button], + [activate_subscription_button] + ] # Если для пользователя есть незавершённый checkout, предлагаем вернуться к нему. if user: @@ -128,7 +138,11 @@ class PaymentCommonMixin: "✅ Платеж успешно завершен!\n\n" f"💰 Сумма: {settings.format_price(amount_kopeks)}\n" f"💳 Способ: {payment_method}\n\n" - "Средства зачислены на ваш баланс!" + "Средства зачислены на ваш баланс!\n\n" + "⚠️ Важно: Пополнение баланса не активирует подписку автоматически. " + "Обязательно активируйте подписку отдельно!\n\n" + f"🔄 При наличии сохранённой корзины подписки и включенной автопокупке, " + f"подписка будет приобретена автоматически после пополнения баланса." ) await self.bot.send_message( diff --git a/app/services/payment/cryptobot.py b/app/services/payment/cryptobot.py index e4d3d5e5..0195eb2f 100644 --- a/app/services/payment/cryptobot.py +++ b/app/services/payment/cryptobot.py @@ -346,7 +346,11 @@ class CryptoBotPaymentMixin: await self.bot.send_message( chat_id=user.telegram_id, - text=f"✅ Баланс пополнен на {settings.format_price(payment.amount_kopeks)}!\n\n{cart_message}", + text=f"✅ Баланс пополнен на {settings.format_price(payment.amount_kopeks)}!\n\n" + f"⚠️ Важно: Пополнение баланса не активирует подписку автоматически. " + f"Обязательно активируйте подписку отдельно!\n\n" + f"🔄 При наличии сохранённой корзины подписки и включенной автопокупке, " + f"подписка будет приобретена автоматически после пополнения баланса.\n\n{cart_message}", reply_markup=keyboard ) logger.info( diff --git a/app/services/payment/mulenpay.py b/app/services/payment/mulenpay.py index 69f672a9..7b4ffcf3 100644 --- a/app/services/payment/mulenpay.py +++ b/app/services/payment/mulenpay.py @@ -389,7 +389,11 @@ class MulenPayPaymentMixin: await self.bot.send_message( chat_id=user.telegram_id, - text=f"✅ Баланс пополнен на {settings.format_price(payment.amount_kopeks)}!\n\n{cart_message}", + text=f"✅ Баланс пополнен на {settings.format_price(payment.amount_kopeks)}!\n\n" + f"⚠️ Важно: Пополнение баланса не активирует подписку автоматически. " + f"Обязательно активируйте подписку отдельно!\n\n" + f"🔄 При наличии сохранённой корзины подписки и включенной автопокупке, " + f"подписка будет приобретена автоматически после пополнения баланса.\n\n{cart_message}", reply_markup=keyboard ) logger.info( diff --git a/app/services/payment/pal24.py b/app/services/payment/pal24.py index 501dbe2c..cb928e1e 100644 --- a/app/services/payment/pal24.py +++ b/app/services/payment/pal24.py @@ -489,7 +489,11 @@ class Pal24PaymentMixin: chat_id=user.telegram_id, text=( "✅ Баланс пополнен на " - f"{settings.format_price(payment.amount_kopeks)}!\n\n{cart_message}" + f"{settings.format_price(payment.amount_kopeks)}!\n\n" + f"⚠️ Важно: Пополнение баланса не активирует подписку автоматически. " + f"Обязательно активируйте подписку отдельно!\n\n" + f"🔄 При наличии сохранённой корзины подписки и включенной автопокупке, " + f"подписка будет приобретена автоматически после пополнения баланса.\n\n{cart_message}" ), reply_markup=keyboard, ) diff --git a/app/services/payment/platega.py b/app/services/payment/platega.py index bfe331cb..fc7fe4d8 100644 --- a/app/services/payment/platega.py +++ b/app/services/payment/platega.py @@ -498,6 +498,10 @@ class PlategaPaymentMixin: chat_id=user.telegram_id, text=( f"✅ Баланс пополнен на {settings.format_price(payment.amount_kopeks)}!\n\n" + f"⚠️ Важно: Пополнение баланса не активирует подписку автоматически. " + f"Обязательно активируйте подписку отдельно!\n\n" + f"🔄 При наличии сохранённой корзины подписки и включенной автопокупке, " + f"подписка будет приобретена автоматически после пополнения баланса.\n\n" f"{cart_message}" ), reply_markup=keyboard, diff --git a/app/services/payment/stars.py b/app/services/payment/stars.py index 9d7e4e33..b7fd5942 100644 --- a/app/services/payment/stars.py +++ b/app/services/payment/stars.py @@ -604,7 +604,11 @@ class TelegramStarsMixin: await self.bot.send_message( chat_id=user.telegram_id, - text=f"✅ Баланс пополнен на {settings.format_price(amount_kopeks)}!\n\n{cart_message}", + text=f"✅ Баланс пополнен на {settings.format_price(amount_kopeks)}!\n\n" + f"⚠️ Важно: Пополнение баланса не активирует подписку автоматически. " + f"Обязательно активируйте подписку отдельно!\n\n" + f"🔄 При наличии сохранённой корзины подписки и включенной автопокупке, " + f"подписка будет приобретена автоматически после пополнения баланса.\n\n{cart_message}", reply_markup=keyboard, ) logger.info( diff --git a/app/services/payment/wata.py b/app/services/payment/wata.py index 5bff005b..d8bc789a 100644 --- a/app/services/payment/wata.py +++ b/app/services/payment/wata.py @@ -514,6 +514,10 @@ class WataPaymentMixin: f"💰 Сумма: {settings.format_price(payment.amount_kopeks)}\n" "🦊 Способ: WATA\n" f"🆔 Транзакция: {transaction.id}\n\n" + "⚠️ Важно: Пополнение баланса не активирует подписку автоматически. " + "Обязательно активируйте подписку отдельно!\n\n" + "🔄 При наличии сохранённой корзины подписки и включенной автопокупке, " + "подписка будет приобретена автоматически после пополнения баланса.\n\n" "Баланс пополнен автоматически!" ), parse_mode="HTML", diff --git a/app/services/payment/yookassa.py b/app/services/payment/yookassa.py index 171a6bf0..53542d53 100644 --- a/app/services/payment/yookassa.py +++ b/app/services/payment/yookassa.py @@ -554,7 +554,11 @@ class YooKassaPaymentMixin: await self.bot.send_message( chat_id=user.telegram_id, - text=f"✅ Баланс пополнен на {settings.format_price(payment.amount_kopeks)}!\n\n{cart_message}", + text=f"✅ Баланс пополнен на {settings.format_price(payment.amount_kopeks)}!\n\n" + f"⚠️ Важно: Пополнение баланса не активирует подписку автоматически. " + f"Обязательно активируйте подписку отдельно!\n\n" + f"🔄 При наличии сохранённой корзины подписки и включенной автопокупке, " + f"подписка будет приобретена автоматически после пополнения баланса.\n\n{cart_message}", reply_markup=keyboard, ) logger.info( diff --git a/app/services/tribute_service.py b/app/services/tribute_service.py index c21906d7..bef09a91 100644 --- a/app/services/tribute_service.py +++ b/app/services/tribute_service.py @@ -257,6 +257,10 @@ class TributeService: f"💰 Сумма: {int(amount_rubles)} ₽\n" f"💳 Способ оплаты: Tribute\n" f"🎉 Средства зачислены на баланс!\n\n" + f"⚠️ Важно: Пополнение баланса не активирует подписку автоматически. " + f"Обязательно активируйте подписку отдельно!\n\n" + f"🔄 При наличии сохранённой корзины подписки и включенной автопокупке, " + f"подписка будет приобретена автоматически после пополнения баланса.\n\n" f"Спасибо за оплату! 🙏" ) @@ -318,7 +322,9 @@ class TributeService: await self.bot.send_message( chat_id=user_id, - text=f"✅ Баланс пополнен на {settings.format_price(amount_kopeks)}!\n\n{cart_message}", + text=f"✅ Баланс пополнен на {settings.format_price(amount_kopeks)}!\n\n" + f"⚠️ Важно: Пополнение баланса не активирует подписку автоматически. " + f"Обязательно активируйте подписку отдельно!\n\n{cart_message}", reply_markup=keyboard ) logger.info( diff --git a/app/webapi/routes/users.py b/app/webapi/routes/users.py index c2031719..c10c938d 100644 --- a/app/webapi/routes/users.py +++ b/app/webapi/routes/users.py @@ -158,6 +158,12 @@ async def get_user( _: Any = Security(require_api_token), db: AsyncSession = Depends(get_db_session), ) -> UserResponse: + # First check if the provided ID is a telegram_id + user = await get_user_by_telegram_id(db, user_id) + if user: + return _serialize_user(user) + + # If not found as telegram_id, check as internal user ID user = await get_user_by_id(db, user_id) if not user: raise HTTPException(status.HTTP_404_NOT_FOUND, "User not found") @@ -202,8 +208,15 @@ async def update_user_endpoint( _: Any = Security(require_api_token), db: AsyncSession = Depends(get_db_session), ) -> UserResponse: - user = await get_user_by_id(db, user_id) - if not user: + # First check if the provided ID is a telegram_id + user = await get_user_by_telegram_id(db, user_id) + if user: + found_user = user + else: + # If not found as telegram_id, check as internal user ID + found_user = await get_user_by_id(db, user_id) + + if not found_user: raise HTTPException(status.HTTP_404_NOT_FOUND, "User not found") updates: dict[str, Any] = {} @@ -234,18 +247,23 @@ async def update_user_endpoint( raise HTTPException(status.HTTP_400_BAD_REQUEST, "Promo group not found") updates["promo_group_id"] = promo_group.id - if payload.referral_code is not None and payload.referral_code != user.referral_code: + if payload.referral_code is not None and payload.referral_code != found_user.referral_code: existing_code_owner = await get_user_by_referral_code(db, payload.referral_code) - if existing_code_owner and existing_code_owner.id != user.id: + if existing_code_owner and existing_code_owner.id != found_user.id: raise HTTPException(status.HTTP_400_BAD_REQUEST, "Referral code already in use") updates["referral_code"] = payload.referral_code if not updates: - return _serialize_user(user) + return _serialize_user(found_user) - user = await update_user(db, user, **updates) - user = await get_user_by_id(db, user.id) - return _serialize_user(user) + found_user = await update_user(db, found_user, **updates) + # Reload the user to ensure we have the latest data + if found_user.telegram_id == user_id: + found_user = await get_user_by_telegram_id(db, user_id) + else: + found_user = await get_user_by_id(db, found_user.id) + + return _serialize_user(found_user) @router.post("/{user_id}/balance", response_model=UserResponse) @@ -258,13 +276,20 @@ async def update_balance( if payload.amount_kopeks == 0: raise HTTPException(status.HTTP_400_BAD_REQUEST, "Amount must be non-zero") - user = await get_user_by_id(db, user_id) - if not user: + # First check if the provided ID is a telegram_id + user = await get_user_by_telegram_id(db, user_id) + if user: + found_user = user + else: + # If not found as telegram_id, check as internal user ID + found_user = await get_user_by_id(db, user_id) + + if not found_user: raise HTTPException(status.HTTP_404_NOT_FOUND, "User not found") success = await add_user_balance( db, - user, + found_user, amount_kopeks=payload.amount_kopeks, description=payload.description or "Корректировка через веб-API", create_transaction=payload.create_transaction, @@ -273,5 +298,10 @@ async def update_balance( if not success: raise HTTPException(status.HTTP_500_INTERNAL_SERVER_ERROR, "Failed to update balance") - user = await get_user_by_id(db, user_id) - return _serialize_user(user) + # Reload the user to ensure we have the latest data + if found_user.telegram_id == user_id: + found_user = await get_user_by_telegram_id(db, user_id) + else: + found_user = await get_user_by_id(db, found_user.id) + + return _serialize_user(found_user) diff --git a/docs/web-admin-integration.md b/docs/web-admin-integration.md index 01e2b84d..4f31ed9e 100644 --- a/docs/web-admin-integration.md +++ b/docs/web-admin-integration.md @@ -105,10 +105,10 @@ curl -X POST "http://127.0.0.1:8080/tokens" \ | `PUT` | `/settings/{key}` | Обновить значение настройки. | `DELETE` | `/settings/{key}` | Сбросить настройку к значению по умолчанию. | `GET` | `/users` | Список пользователей с фильтрами и пагинацией. -| `GET` | `/users/{id}` | Детали пользователя. +| `GET` | `/users/{id}` | Детали пользователя. ID может быть как внутренним (user.id), так и Telegram ID (user.telegram_id). | `POST` | `/users` | Создать пользователя (например, для ручной выдачи доступа). -| `PATCH` | `/users/{id}` | Обновить профиль пользователя или статус. -| `POST` | `/users/{id}/balance` | Корректировка баланса с созданием транзакции. +| `PATCH` | `/users/{id}` | Обновить профиль пользователя или статус. ID может быть как внутренним (user.id), так и Telegram ID (user.telegram_id). +| `POST` | `/users/{id}/balance` | Корректировка баланса с созданием транзакции. ID может быть как внутренним (user.id), так и Telegram ID (user.telegram_id). | `GET` | `/subscriptions` | Список подписок с фильтрами. | `POST` | `/subscriptions` | Создать триальную или платную подписку. | `POST` | `/subscriptions/{id}/extend` | Продлить подписку на N дней. @@ -260,7 +260,7 @@ curl -X POST "http://127.0.0.1:8080/tokens" \ 1. **Health-check** — перед авторизацией UI вызывает `GET /health`, чтобы отобразить статус и версию бота. 2. **Настройки UI** — подгружает категории через `GET /settings/categories`, далее выводит форму со значениями из `GET /settings`. 3. **Статистика дашборда** — `GET /stats/overview` для карточек с показателями. -4. **Раздел пользователи** — `GET /users` с поиском (`search`), фильтрами по статусу или промо-группе. Для детальной карточки использовать `GET /users/{id}`. +4. **Раздел пользователи** — `GET /users` с поиском (`search`), фильтрами по статусу или промо-группе. Для детальной карточки использовать `GET /users/{id}` (в качестве ID можно использовать как внутренний user.id, так и telegram_id пользователя). 5. **Операции с подпиской** — использовать `POST /subscriptions/{id}/...` эндпоинты для продления, выдачи трафика и устройств. 6. **Поддержка** — список тикетов (`GET /tickets`), изменение статуса (`POST /tickets/{id}/status`), блокировка ответов (`POST /tickets/{id}/reply-block`). 7. **История операций** — `GET /transactions` с фильтрами по пользователю, типу и периоду.