Update app.py

app.py

@@ -639,18 +639,23 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     logging.debug(f"Processing user with email: {email}")
     
     # Проверка существования пользователя в базе данных по email
-    cursor.execute("SELECT web_st FROM contacts WHERE email = ?", (email,))
+    cursor.execute("SELECT web_st, b_mess FROM contacts WHERE email = ?", (email,))
     user = cursor.fetchone()
     logging.debug(f"User found: {user}")
 
     # Вынесение увеличения значения web_st в отдельный блок
     web_st_value = 1  # Инициализация значения web_st
+    current_messages = ""  # Инициализация текущих сообщений
     if user:
         # Проверка текущего значения web_st и его инкрементация
         current_web_st = user[0] if user[0] is not None and user[0] != "" else 0
         web_st_value = int(current_web_st) + 1
         logging.debug(f"Calculated web_st_value: {web_st_value}")
 
+        # Получение текущих сообщений
+        current_messages = user[1] if user[1] is not None else ""
+        logging.debug(f"Current messages: {current_messages}")
+
         # Обновление значения web_st
         cursor.execute("UPDATE contacts SET web_st = ? WHERE email = ?", (web_st_value, email))
         conn.commit()
@@ -703,6 +708,14 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     # Добавление значения web_st в данные для вставки
     transformed_data['web_st'] = web_st_value
 
+    # Обработка сообщений
+    new_messages = transformed_data.get('b_mess', "")
+    if current_messages:
+        transformed_data['b_mess'] = current_messages + "; " + new_messages
+    else:
+        transformed_data['b_mess'] = new_messages
+    logging.debug(f"Transformed data after message processing: {transformed_data}")
+
     # Обновление данных пользователя в базе данных
     if user:
         update_query = "UPDATE contacts SET "