diff --git a/app/services/user_service.py b/app/services/user_service.py index 878bf702..bce7ac74 100644 --- a/app/services/user_service.py +++ b/app/services/user_service.py @@ -49,6 +49,7 @@ from app.database.models import ( User, UserMessage, UserStatus, + WataPayment, WelcomeText, YooKassaPayment, ) @@ -989,6 +990,17 @@ class UserService: except Exception as e: logger.error(f'❌ Ошибка удаления подписки: {e}') + try: + wata_payments_result = await db.execute(select(WataPayment).where(WataPayment.user_id == user_id)) + wata_payments = wata_payments_result.scalars().all() + + if wata_payments: + logger.info(f'🔄 Удаляем {len(wata_payments)} Wata платежей') + await db.execute(delete(WataPayment).where(WataPayment.user_id == user_id)) + await db.flush() + except Exception as e: + logger.error(f'❌ Ошибка удаления Wata платежей: {e}') + try: await db.execute(delete(User).where(User.id == user_id)) await db.commit()