diff --git a/app/services/payment/cryptobot.py b/app/services/payment/cryptobot.py index 9633cfbf..638570d5 100644 --- a/app/services/payment/cryptobot.py +++ b/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 diff --git a/app/services/payment/freekassa.py b/app/services/payment/freekassa.py index 6a25aa66..d5a59297 100644 --- a/app/services/payment/freekassa.py +++ b/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 # Создаем транзакцию diff --git a/app/services/payment/heleket.py b/app/services/payment/heleket.py index cc0a9865..37f9ab63 100644 --- a/app/services/payment/heleket.py +++ b/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 diff --git a/app/services/payment/kassa_ai.py b/app/services/payment/kassa_ai.py index 9c0bf707..14cb7329 100644 --- a/app/services/payment/kassa_ai.py +++ b/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 # Создаем транзакцию diff --git a/app/services/payment/mulenpay.py b/app/services/payment/mulenpay.py index 68fc225f..a4d16cd3 100644 --- a/app/services/payment/mulenpay.py +++ b/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 diff --git a/app/services/payment/pal24.py b/app/services/payment/pal24.py index e9cb6626..84d59412 100644 --- a/app/services/payment/pal24.py +++ b/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( diff --git a/app/services/payment/platega.py b/app/services/payment/platega.py index 36be7c0c..bb401adf 100644 --- a/app/services/payment/platega.py +++ b/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 # Убеждаемся, что промогруппы загружены в асинхронном контексте, diff --git a/app/services/payment/wata.py b/app/services/payment/wata.py index 14446089..be902fb7 100644 --- a/app/services/payment/wata.py +++ b/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 '') diff --git a/app/services/payment/yookassa.py b/app/services/payment/yookassa.py index 08e46fc2..4b137c2c 100644 --- a/app/services/payment/yookassa.py +++ b/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(