Add files via upload

app/services/payment/stars.py

@@ -383,6 +383,22 @@ class TelegramStarsMixin:
                     exc_info=True,
                 )
 
+        # Начисляем реферальную комиссию за прямую покупку подписки
+        try:
+            from app.services.referral_service import process_referral_topup
+
+            await process_referral_topup(
+                db,
+                user.id,
+                amount_kopeks,
+                getattr(self, 'bot', None),
+            )
+        except Exception as ref_error:
+            logger.error(
+                'Ошибка реферального начисления при покупке подписки через Stars: %s',
+                ref_error,
+            )
+
         logger.info(
             '✅ Обработан Stars платеж как покупка подписки: пользователь %s, %s звезд → %s',
             user.id,

app/services/payment/yookassa.py

@@ -687,6 +687,22 @@ class YooKassaPaymentMixin:
                         payment.yookassa_payment_id,
                         user.id,
                     )
+
+                    # Начисляем реферальную комиссию за прямую покупку подписки
+                    try:
+                        from app.services.referral_service import process_referral_topup
+
+                        await process_referral_topup(
+                            db,
+                            user.id,
+                            payment.amount_kopeks,
+                            getattr(self, 'bot', None),
+                        )
+                    except Exception as ref_error:
+                        logger.error(
+                            'Ошибка реферального начисления при покупке подписки YooKassa: %s',
+                            ref_error,
+                        )
                 else:
                     old_balance = getattr(user, 'balance_kopeks', 0)
                     was_first_topup = not getattr(user, 'has_made_first_topup', False)