Update app.py

app.py

@@ -1483,6 +1483,7 @@ def add_user_senler_full():
 
 
 
+# Проверка групп СЕНДЛЕРА на рассылку
 # Проверка групп СЕНДЛЕРА на рассылку
 @app.route('/get_Lo_Mess_senler', methods=['POST'])
 def get_Lo_Mess_senler():
@@ -1496,7 +1497,6 @@ def get_Lo_Mess_senler():
         if not vk_user_id or not vk_group_id or not subscription_id:
             return jsonify({"status": "error", "message": "Missing required parameters"}), 400
 
-
         payload = {
             "vk_user_id": [vk_user_id],
             'vk_group_id': vk_group_id,
@@ -1521,8 +1521,23 @@ def get_Lo_Mess_senler():
         # Выводим полный ответ от сервера Senler в консоль
         logging.debug(f"Senler API response: {data}")
 
-        # Возвращаем успешный ответ
-        return jsonify({"status": "success", "message": "Request completed", "data": data}), 200
+        # Проверяем, что ответ содержит данные
+        if not data.get('success'):
+            return jsonify({"status": "error", "message": "Failed to fetch data from Senler API"}), 500
+
+        # Проверяем, что пользователь подписан на указанную группу
+        user_subscriptions = data.get('items', [])
+        if not user_subscriptions:
+            return jsonify({"status": "not"}), 200
+
+        for user in user_subscriptions:
+            subscriptions = user.get('subscriptions', [])
+            for sub in subscriptions:
+                if sub.get('subscription_id') == int(subscription_id):
+                    return jsonify({"status": "1"}), 200
+
+        # Если группа не найдена
+        return jsonify({"status": "not"}), 200
 
     except Exception as e:
         logging.error(f"An error occurred: {str(e)}")