From fae423177b6669d92c81536e820edb06d7f5bcbf Mon Sep 17 00:00:00 2001 From: Egor Date: Tue, 9 Sep 2025 08:11:28 +0300 Subject: [PATCH] Update user_service.py --- app/services/user_service.py | 21 ++++++++++++++++++++- 1 file changed, 20 insertions(+), 1 deletion(-) diff --git a/app/services/user_service.py b/app/services/user_service.py index 4d185eb4..503ff65b 100644 --- a/app/services/user_service.py +++ b/app/services/user_service.py @@ -13,7 +13,7 @@ from app.database.crud.transaction import get_user_transactions_count from app.database.crud.subscription import get_subscription_by_user_id from app.database.models import ( User, UserStatus, Subscription, Transaction, PromoCodeUse, - ReferralEarning, SubscriptionServer, YooKassaPayment, BroadcastHistory + ReferralEarning, SubscriptionServer, YooKassaPayment, BroadcastHistory, CryptoBotPayment ) from app.config import settings @@ -294,6 +294,25 @@ class UserService: logger.info(f"✅ YooKassa платежи удалены") except Exception as e: logger.error(f"❌ Ошибка удаления YooKassa платежей: {e}") + + try: + from app.database.models import CryptoBotPayment + from sqlalchemy import select, delete + + cryptobot_result = await db.execute( + select(CryptoBotPayment).where(CryptoBotPayment.user_id == user_id) + ) + cryptobot_payments = cryptobot_result.scalars().all() + + if cryptobot_payments: + logger.info(f"🔄 Удаляем {len(cryptobot_payments)} CryptoBot платежей") + await db.execute( + delete(CryptoBotPayment).where(CryptoBotPayment.user_id == user_id) + ) + await db.flush() + logger.info(f"✅ CryptoBot платежи удалены") + except Exception as e: + logger.error(f"❌ Ошибка удаления CryptoBot платежей: {e}") try: transactions_result = await db.execute(