Update app.py

app.py

@@ -809,16 +809,10 @@ 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():
@@ -852,9 +846,6 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     # Добавление значения web_st в данные для вставки
     transformed_data['web_st'] = web_st_value
 
-    # Добавление сообщений в данные для вставки
-    transformed_data['messages'] = json.dumps(user_data.get('messages', []))
-
     # Обновление данных пользователя в базе данных
     if user:
         update_query = "UPDATE contacts SET "
@@ -878,7 +869,6 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     conn.commit()
     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')
@@ -893,17 +883,26 @@ def send_get_request():
         report = data.get('report', {})
         messages = data.get('messages', {})
 
-        users_meta = report.get('usersMeta', {})
+        report_json_str = report.get('report', '{}')
+        try:
+            report_json = json.loads(report_json_str)
+        except json.JSONDecodeError:
+            report_json = {}
+
+        messages_json_str = report.get('messages', '{}')
+        try:
+            messages_json = json.loads(messages_json_str)
+        except json.JSONDecodeError:
+            messages_json = {}
+
+        users_meta = report_json.get('usersMeta', {})
 
-        # Обновление или добавление каждого пользователя в базу данных
+        # Обновление или добавление каждого пользователя в базу данных data_gc.db
         processed_emails = set()
         for user_id, user_data in users_meta.items():
-            # Извлечение сообщений для текущего пользователя
-            user_messages = messages.get(user_id, [])
-            user_data['messages'] = user_messages
-            
+            user_data['messages'] = messages_json.get(user_id, [])  # Извлечение сообщений конкретного пользователя
             email = user_data.get('email')
-            if email and email not in processed_emails:
+            if email not in processed_emails:
                 update_or_insert_user(DATABASE_NAME, user_data, mapping_template)
                 processed_emails.add(email)
 
@@ -914,6 +913,22 @@ def send_get_request():
 
 
 
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+