Update app.py

app.py

@@ -782,6 +782,11 @@ def send_request():
 
 DATABASE_NAME = 'data_gc.db'
 
+
+
+
+
+
 def update_or_insert_user(db_name, user_data, mapping_template):
     conn = sqlite3.connect(db_name)
     cursor = conn.cursor()
@@ -824,8 +829,14 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     transformed_data = {}
     for json_key, db_column in mapping_template.items():
         value = user_data.get(json_key, "")
+        
         if isinstance(value, list):
-            transformed_data[db_column] = "1" if value else "0"
+            # Проверяем тип элементов списка
+            if all(isinstance(item, str) for item in value):
+                transformed_data[db_column] = "; ".join(value)  # Сохраняем сообщения в строку
+            else:
+                logging.error(f"Expected list of strings for key {json_key}, but got: {value}")
+                transformed_data[db_column] = ""
         else:
             transformed_data[db_column] = str(value)
     logging.debug(f"Transformed data: {transformed_data}")
@@ -877,6 +888,8 @@ 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'])
 def send_get_request():
     token = request.args.get('token')
@@ -905,12 +918,14 @@ def send_get_request():
 
         users_meta = report_json.get('usersMeta', {})
 
-        # Обновление или добавление каждого пользователя в базу данных data_gc.db
+        # Обновление или добавление каждого пользователя в базу данных
         processed_emails = set()
         for user_id, user_data in users_meta.items():
-            user_data['messages'] = messages_json
+            # Получаем только сообщения для текущего пользователя
+            user_messages = messages_json.get(user_id, [])
+            user_data['messages'] = user_messages
             email = user_data.get('email')
-            if email not in processed_emails:
+            if email and email not in processed_emails:
                 update_or_insert_user(DATABASE_NAME, user_data, mapping_template)
                 processed_emails.add(email)
 
@@ -930,6 +945,13 @@ def send_get_request():
 
 
 
+
+
+
+
+
+
+