Add files via upload

app/services/payment/cryptobot.py

@@ -92,7 +92,9 @@ class CryptoBotPaymentMixin:
             if not invoice_data:
                 logger.error('Ошибка создания CryptoBot invoice')
                 error = ValueError('CryptoBot invoice creation returned empty result')
-                self._schedule_error_notification(error, f'CryptoBot invoice creation error: user_id={user_id}, amount={amount_usd}')
+                self._schedule_error_notification(
+                    error, f'CryptoBot invoice creation error: user_id={user_id}, amount={amount_usd}'
+                )
                 return None
 
             cryptobot_crud = import_module('app.database.crud.cryptobot')
@@ -164,7 +166,9 @@ class CryptoBotPaymentMixin:
             if not payment:
                 logger.error('CryptoBot платеж не найден в БД: %s', invoice_id)
                 error = ValueError(f'CryptoBot payment not found: {invoice_id}')
-                self._schedule_error_notification(error, f'CryptoBot webhook error: payment not found for invoice_id={invoice_id}')
+                self._schedule_error_notification(
+                    error, f'CryptoBot webhook error: payment not found for invoice_id={invoice_id}'
+                )
                 return False
 
             if payment.status == 'paid':
@@ -245,7 +249,9 @@ class CryptoBotPaymentMixin:
                         invoice_id,
                     )
                     error = ValueError(f'Invalid amount after conversion: {amount_kopeks} kopeks')
-                    self._schedule_error_notification(error, f'CryptoBot webhook error: invalid amount for invoice_id={invoice_id}')
+                    self._schedule_error_notification(
+                        error, f'CryptoBot webhook error: invalid amount for invoice_id={invoice_id}'
+                    )
                     return False
 
                 payment_service_module = import_module('app.services.payment_service')
@@ -273,7 +279,9 @@ class CryptoBotPaymentMixin:
                         updated_payment.user_id,
                     )
                     error = ValueError(f'User not found: {updated_payment.user_id}')
-                    self._schedule_error_notification(error, f'CryptoBot webhook error: user not found for invoice_id={invoice_id}')
+                    self._schedule_error_notification(
+                        error, f'CryptoBot webhook error: user not found for invoice_id={invoice_id}'
+                    )
                     return False
 
                 old_balance = user.balance_kopeks

app/services/payment/freekassa.py

@@ -269,7 +269,9 @@ class FreekassaPaymentMixin:
                 trigger,
             )
             error = ValueError(f'User not found: {payment.user_id}')
-            self._schedule_error_notification(error, f'Freekassa finalize error: user not found for order_id={payment.order_id}')
+            self._schedule_error_notification(
+                error, f'Freekassa finalize error: user not found for order_id={payment.order_id}'
+            )
             return False
 
         # Создаем транзакцию

app/services/payment/heleket.py

@@ -320,7 +320,9 @@ class HeleketPaymentMixin:
         if amount_kopeks <= 0:
             logger.error('Heleket платеж %s имеет некорректную сумму: %s', updated_payment.uuid, updated_payment.amount)
             error = ValueError(f'Heleket payment has invalid amount: {updated_payment.amount}')
-            self._schedule_error_notification(error, f'Heleket webhook error: invalid amount for uuid={updated_payment.uuid}')
+            self._schedule_error_notification(
+                error, f'Heleket webhook error: invalid amount for uuid={updated_payment.uuid}'
+            )
             return None
 
         transaction = await payment_module.create_transaction(
@@ -351,7 +353,9 @@ class HeleketPaymentMixin:
         if not user:
             logger.error('Пользователь %s не найден для Heleket платежа', updated_payment.user_id)
             error = ValueError(f'User not found: {updated_payment.user_id}')
-            self._schedule_error_notification(error, f'Heleket webhook error: user not found for uuid={updated_payment.uuid}')
+            self._schedule_error_notification(
+                error, f'Heleket webhook error: user not found for uuid={updated_payment.uuid}'
+            )
             return None
 
         old_balance = user.balance_kopeks

app/services/payment/kassa_ai.py

@@ -264,7 +264,9 @@ class KassaAiPaymentMixin:
                 trigger,
             )
             error = ValueError(f'User not found: {payment.user_id}')
-            self._schedule_error_notification(error, f'KassaAI finalize error: user not found for order_id={payment.order_id}')
+            self._schedule_error_notification(
+                error, f'KassaAI finalize error: user not found for order_id={payment.order_id}'
+            )
             return False
 
         # Создаем транзакцию

app/services/payment/mulenpay.py

@@ -277,7 +277,9 @@ class MulenPayPaymentMixin:
                         display_name,
                     )
                     error = ValueError(f'User not found: {payment.user_id}')
-                    self._schedule_error_notification(error, f'{display_name} webhook error: user not found for uuid={payment.uuid}')
+                    self._schedule_error_notification(
+                        error, f'{display_name} webhook error: user not found for uuid={payment.uuid}'
+                    )
                     return False
 
                 old_balance = user.balance_kopeks

app/services/payment/pal24.py

@@ -386,7 +386,9 @@ class Pal24PaymentMixin:
                 trigger,
             )
             error = ValueError(f'User not found: {payment.user_id}')
-            self._schedule_error_notification(error, f'Pal24 finalize error: user not found for bill_id={payment.bill_id}')
+            self._schedule_error_notification(
+                error, f'Pal24 finalize error: user not found for bill_id={payment.bill_id}'
+            )
             return False
 
         transaction = await payment_module.create_transaction(

app/services/payment/platega.py

@@ -324,7 +324,9 @@ class PlategaPaymentMixin:
         if not user:
             logger.error('Пользователь %s не найден для Platega', payment.user_id)
             error = ValueError(f'User not found: {payment.user_id}')
-            self._schedule_error_notification(error, f'Platega finalize error: user not found for correlation_id={payment.correlation_id}')
+            self._schedule_error_notification(
+                error, f'Platega finalize error: user not found for correlation_id={payment.correlation_id}'
+            )
             return payment
 
         # Убеждаемся, что промогруппы загружены в асинхронном контексте,

app/services/payment/wata.py

@@ -461,7 +461,9 @@ class WataPaymentMixin:
         if not user:
             logger.error('Пользователь %s не найден при обработке WATA', payment.user_id)
             error = ValueError(f'User not found: {payment.user_id}')
-            self._schedule_error_notification(error, f'WATA finalize error: user not found for payment_link_id={payment.payment_link_id}')
+            self._schedule_error_notification(
+                error, f'WATA finalize error: user not found for payment_link_id={payment.payment_link_id}'
+            )
             return payment
 
         transaction_external_id = str(transaction_payload.get('id') or transaction_payload.get('transactionId') or '')

app/services/payment/yookassa.py

@@ -146,7 +146,9 @@ class YooKassaPaymentMixin:
             if not yookassa_response or yookassa_response.get('error'):
                 logger.error('Ошибка создания платежа YooKassa: %s', yookassa_response)
                 error = ValueError(f'YooKassa payment creation failed: {yookassa_response}')
-                self._schedule_error_notification(error, f'YooKassa payment creation error: user_id={user_id}, amount={amount_kopeks}')
+                self._schedule_error_notification(
+                    error, f'YooKassa payment creation error: user_id={user_id}, amount={amount_kopeks}'
+                )
                 return None
 
             yookassa_created_at: datetime | None = None
@@ -1114,7 +1116,9 @@ class YooKassaPaymentMixin:
                 payment.yookassa_payment_id,
                 error,
             )
-            self._schedule_error_notification(error, f'YooKassa successful payment processing error: payment_id={payment.yookassa_payment_id}')
+            self._schedule_error_notification(
+                error, f'YooKassa successful payment processing error: payment_id={payment.yookassa_payment_id}'
+            )
             return False
 
     async def _mark_yookassa_payment_processing_completed(