Update app.py

app.py

@@ -882,20 +882,17 @@ def send_get_request():
         try:
             messages_json = json.loads(messages_json_str)  # Преобразование строки JSON в объект
         except json.JSONDecodeError:
-            messages_json = {}  # Установка пустого объекта при ошибке преобразования
+            messages_json = []  # Установка пустого списка при ошибке преобразования
 
         users_meta = report_json.get('usersMeta', {})  # Получение метаинформации пользователей из отчета
 
         processed_emails = set()  # Создание множества для хранения обработанных email-ов
         for user_id, user_data in users_meta.items():  # Проход по всем пользователям
-            # Получение сообщений для текущего пользователя
-            messages_user = {key: msg for key, msg in messages_json.items() if msg.get('user_id') == user_id}
-            logging.debug(f"Messages for user {user_id}: {messages_user}")  # Логирование сообщений для текущего пользователя
-            
-            user_data['messages'] = messages_user  # Добавление сообщений текущего пользователя в данные
-
             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 в множество обработанных
 
@@ -912,7 +909,6 @@ def send_get_request():
 
 
 
-
 @app.route('/biz_v', methods=['GET'])
 def biz_v():
     api_sys_control = request.args.get('api_sys')