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()
@@ -852,6 +852,9 @@ 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 "
@@ -890,26 +893,17 @@ def send_get_request():
         report = data.get('report', {})
         messages = data.get('messages', {})
 
-        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', {})
+        users_meta = report.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.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)
 
@@ -924,7 +918,6 @@ def send_get_request():
 
 
 
-
 @app.route('/biz_v', methods=['GET'])
 def biz_v():
     api_sys_control = request.args.get('api_sys')