diff --git a/app/handlers/subscription/devices.py b/app/handlers/subscription/devices.py index 3dbc94ff..4d0bdddd 100644 --- a/app/handlers/subscription/devices.py +++ b/app/handlers/subscription/devices.py @@ -1190,6 +1190,18 @@ async def confirm_add_devices(callback: types.CallbackQuery, db_user: User, db: await db.refresh(db_user) await db.refresh(subscription) + # Отправляем уведомление админам о докупке устройств + try: + from app.services.admin_notification_service import AdminNotificationService + + notification_service = AdminNotificationService(callback.bot) + old_device_limit = subscription.device_limit - devices_count + await notification_service.send_subscription_update_notification( + db, db_user, subscription, 'devices', old_device_limit, subscription.device_limit, price + ) + except Exception as e: + logger.error(f'Ошибка отправки уведомления о докупке устройств: {e}') + success_text = ( '✅ Устройства успешно добавлены!\n\n' f'📱 Добавлено: {devices_count} устройств\n' diff --git a/app/handlers/subscription/traffic.py b/app/handlers/subscription/traffic.py index bbae7895..2e2c09ad 100644 --- a/app/handlers/subscription/traffic.py +++ b/app/handlers/subscription/traffic.py @@ -540,6 +540,9 @@ async def add_traffic(callback: types.CallbackQuery, db_user: User, db: AsyncSes await callback.answer() return + # Сохраняем старое значение трафика для уведомления + old_traffic_limit = subscription.traffic_limit_gb + try: success = await subtract_user_balance( db, @@ -580,6 +583,17 @@ async def add_traffic(callback: types.CallbackQuery, db_user: User, db: AsyncSes await db.refresh(db_user) await db.refresh(subscription) + # Отправляем уведомление админам о докупке трафика + try: + from app.services.admin_notification_service import AdminNotificationService + + notification_service = AdminNotificationService(callback.bot) + await notification_service.send_subscription_update_notification( + db, db_user, subscription, 'traffic', old_traffic_limit, subscription.traffic_limit_gb, price + ) + except Exception as e: + logger.error(f'Ошибка отправки уведомления о докупке трафика: {e}') + success_text = '✅ Трафик успешно добавлен!\n\n' if traffic_gb == 0: success_text += '🎉 Теперь у вас безлимитный трафик!'