Update app.py

app.py

@@ -811,7 +811,13 @@ def update_or_insert_user(db_name, user_data, mapping_template):
         cursor.execute("UPDATE contacts SET web_st = ? WHERE email = ?", (web_st_value, email))
         conn.commit()
         logging.debug(f"User {email} web_st updated to {web_st_value}")
+
+        # Извлечение старых сообщений
+        old_messages = json.loads(user[1]) if user[1] else []
+        logging.debug(f"Old messages: {old_messages}")
+
     else:
+        old_messages = []
         logging.debug(f"User {email} not found, proceeding with insert")
 
     # Преобразование данных пользователя на основе шаблона сопоставления
@@ -847,7 +853,6 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     # Добавление значения web_st в данные для вставки
     transformed_data['web_st'] = web_st_value
 
-    # Выполнение двух пунктов:
     # Баннеры: Проверяется наличие ключа banners в user_data и устанавливается b_baners в 1 или 0.
     if 'banners' in user_data and isinstance(user_data['banners'], list) and user_data['banners']:
         transformed_data['b_baners'] = '1'
@@ -862,14 +867,14 @@ def update_or_insert_user(db_name, user_data, mapping_template):
         transformed_data['b_butt'] = '0'
     logging.debug(f"Transformed data after buttons processing: {transformed_data}")
 
+    # Обработка новых сообщений
+    new_messages = user_data.get('messages', [])
+    all_messages = old_messages + new_messages
+    transformed_data['b_mess'] = json.dumps(all_messages)
+    logging.debug(f"Transformed data after adding messages: {transformed_data}")
+
     # Обновление данных пользователя в базе данных
     if user:
-        # Объединение новых и старых сообщений
-        new_messages = user_data.get('messages', [])
-        old_messages = json.loads(user[1]) if user[1] else []
-        all_messages = old_messages + new_messages
-        transformed_data['b_mess'] = json.dumps(all_messages)
-
         update_query = "UPDATE contacts SET "
         update_values = []
         for column, value in transformed_data.items():
@@ -880,9 +885,6 @@ def update_or_insert_user(db_name, user_data, mapping_template):
         logging.debug(f"Update query: {update_query} with values: {update_values}")
         cursor.execute(update_query, update_values)
     else:
-        # Преобразование сообщений в JSON
-        transformed_data['b_mess'] = json.dumps(user_data.get('messages', []))
-
         columns = ', '.join(transformed_data.keys())
         placeholders = ', '.join('?' for _ in transformed_data)
         insert_query = f"INSERT INTO contacts ({columns}) VALUES ({placeholders})"