Update app.py

app.py

@@ -858,13 +858,15 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     conn.close()  # Закрытие соединения с базой данных
     logging.debug(f"User with email {email} processed successfully")  # Логирование успешной обработки пользователя
 
-@app.route('/send_get_request', methods=['GET'])  # Определение маршрута для обработки GET-запросов
+@app.route('/send_get_request', methods=['GET'])
 def send_get_request():
-    token = request.args.get('token')  # Получение значения параметра token из запроса
-    webinarId = request.args.get('webinarId')  # Получение значения параметра webinarId из запроса
-    url = f'https://online.bizon365.ru/api/v1/webinars/reports/get?webinarId={webinarId}'  # Формирование URL для запроса
+    # Получение параметров из запроса
+    token = request.args.get('token')
+    webinarId = request.args.get('webinarId')
+    url = f'https://online.bizon365.ru/api/v1/webinars/reports/get?webinarId={webinarId}'
 
-    response = requests.get(url, headers={'X-Token': token})  # Выполнение GET-запроса с заголовком авторизации
+    # Отправка GET-запроса к API
+    response = requests.get(url, headers={'X-Token': token})
 
     if response.status_code == 200:  # Если статус ответа равен 200 (OK)
         data = response.json()  # Получение данных в формате JSON
@@ -878,7 +880,7 @@ def send_get_request():
         except json.JSONDecodeError:
             report_json = {}  # Установка пустого объекта при ошибке преобразования
 
-        messages_json_str = report.get('messages', '{}')  # Получение строки JSON для сообщений
+        messages_json_str = report.get('messages', '[]')  # Получение строки JSON для сообщений
         try:
             messages_json = json.loads(messages_json_str)  # Преобразование строки JSON в объект
         except json.JSONDecodeError:
@@ -888,19 +890,18 @@ def send_get_request():
 
         processed_emails = set()  # Создание множества для хранения обработанных email-ов
         for user_id, user_data in users_meta.items():  # Проход по всем пользователям
-            email = user_data.get('email')  # Получение email пользователя
-            if email not in processed_emails:  # Если email еще не был обработан
-                # Извлечение сообщений конкретного пользователя
-                messages_user = [msg for msg in messages_json if msg.get('user_id') == user_id]  # Фильтрация сообщений по user_id
-                user_data['messages'] = messages_user  # Добавление отфильтрованных сообщений в данные пользователя
-                update_or_insert_user(DATABASE_NAME, user_data, mapping_template)  # Обновление или вставка данных пользователя в базу данных
-                processed_emails.add(email)  # Добавление email в множество обработанных
-
-        return jsonify({'status': 'User data saved successfully'})  # Возвращение JSON-ответа с подтверждением успешного сохранения данных
-    else:
-        return jsonify({'error': 'Failed to fetch data from the API'}), response.status_code  # Возвращение JSON-ответа с ошибкой и кодом состояния при неудачном запросе
+            # Извлечение сообщений текущего пользователя
+            messages_user = [msg for msg in messages_json if msg.get('user_id') == user_id]  # Фильтрация сообщений по user_id
+            user_data['messages'] = messages_user  # Добавление сообщений пользователя в данные пользователя
 
+            email = user_data.get('email')
+            if email and email not in processed_emails:
+                update_or_insert_user(DATABASE_NAME, user_data, mapping_template)
+                processed_emails.add(email)
 
+        return jsonify({'status': 'User data saved successfully'})
+    else:
+        return jsonify({'error': 'Failed to fetch data from the API'}), response.status_code