Update app.py

app.py

@@ -860,39 +860,38 @@ def update_or_insert_user(db_name, user_data, mapping_template):
 
 @app.route('/send_get_request', methods=['GET'])
 def send_get_request():
-    # Получение параметров из запроса
     token = request.args.get('token')
     webinarId = request.args.get('webinarId')
     url = f'https://online.bizon365.ru/api/v1/webinars/reports/get?webinarId={webinarId}'
 
-    # Отправка GET-запроса к API
+    # Выполнение GET-запроса к API для получения отчета и сообщений
     response = requests.get(url, headers={'X-Token': token})
 
-    if response.status_code == 200:  # Если статус ответа равен 200 (OK)
+    # Проверка, успешно ли выполнен запрос
+    if response.status_code == 200:
         data = response.json()  # Получение данных в формате JSON
 
-        report = data.get('report', {})  # Получение раздела 'report' из данных
-        messages = data.get('messages', {})  # Получение раздела 'messages' из данных
+        # Получение разделов 'report' и 'messages' из данных
+        report = data.get('report', {})
+        messages_str = data.get('messages', '{}')  # Получение строки JSON для сообщений
 
-        report_json_str = report.get('report', '{}')  # Получение строки JSON для отчета
+        # Преобразование строки JSON в объект Python
         try:
-            report_json = json.loads(report_json_str)  # Преобразование строки JSON в объект
+            messages_json = json.loads(messages_str)  # Преобразование строки JSON в объект
         except json.JSONDecodeError:
-            report_json = {}  # Установка пустого объекта при ошибке преобразования
+            messages_json = {}  # Установка пустого объекта при ошибке преобразования
 
-        messages_json_str = report.get('messages', '[]')  # Получение строки JSON для сообщений
-        try:
-            messages_json = json.loads(messages_json_str)  # Преобразование строки JSON в объект
-        except json.JSONDecodeError:
-            messages_json = []  # Установка пустого списка при ошибке преобразования
+        # Получение метаинформации пользователей из отчета
+        users_meta = report.get('usersMeta', {})
 
-        users_meta = report_json.get('usersMeta', {})  # Получение метаинформации пользователей из отчета
+        # Создание множества для хранения обработанных email-ов
+        processed_emails = set()
 
-        processed_emails = set()  # Создание множества для хранения обработанных email-ов
-        for user_id, user_data in users_meta.items():  # Проход по всем пользователям
-            # Извлечение сообщений текущего пользователя
-            messages_user = [msg for msg in messages_json if msg.get('user_id') == user_id]  # Фильтрация сообщений по user_id
-            user_data['messages'] = messages_user  # Добавление сообщений пользователя в данные пользователя
+        # Проход по всем пользователям
+        for user_id, user_data in users_meta.items():
+            # Извлечение сообщений конкретного пользователя
+            messages_user = messages_json.get(user_id, [])  # Получение сообщений пользователя
+            user_data['messages'] = messages_user  # Добавление сообщений в данные пользователя
 
             email = user_data.get('email')
             if email and email not in processed_emails:
@@ -910,6 +909,7 @@ def send_get_request():
 
 
 
+
 @app.route('/biz_v', methods=['GET'])
 def biz_v():
     api_sys_control = request.args.get('api_sys')