Update app.py

app.py

@@ -792,7 +792,7 @@ def update_or_insert_user(db_name, user_data, mapping_template):
         return
 
     logging.debug(f"Processing user with email: {email}")
-
+    
     # Проверка существования пользователя в базе данных по email
     cursor.execute("SELECT web_st FROM contacts WHERE email = ?", (email,))
     user = cursor.fetchone()
@@ -809,16 +809,22 @@ def update_or_insert_user(db_name, user_data, mapping_template):
         # Обновление значения web_st
         cursor.execute("UPDATE contacts SET web_st = ? WHERE email = ?", (web_st_value, email))
         conn.commit()
+        conn.close()
         logging.debug(f"User {email} web_st updated to {web_st_value}")
     else:
+        conn.close()
         logging.debug(f"User {email} not found, proceeding with insert")
 
+    # Открываем соединение снова для остальных операций
+    conn = sqlite3.connect(db_name)
+    cursor = conn.cursor()
+
     # Преобразование данных пользователя на основе шаблона сопоставления
     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"
+            transformed_data[db_column] = "; ".join(value)  # Сохраняем сообщения в строку
         else:
             transformed_data[db_column] = str(value)
     logging.debug(f"Transformed data: {transformed_data}")
@@ -897,12 +903,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.get(user_id, [])  # Извлечение сообщений конкретного пользователя
+            # Получаем только сообщения для текущего пользователя
+            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)