Update app.py

app.py

@@ -681,7 +681,7 @@ 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, ws_st, b_mess FROM contacts WHERE email = ?", (email,))
     user = cursor.fetchone()
     logging.debug(f"User found: {user}")
 
@@ -723,7 +723,6 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     logging.debug(f"Transformed data: {transformed_data}")
 
     # Заполнение обязательных полей значениями по умолчанию
-
     required_fields = [
         "vk_id", "chat_id", "ws_st", "ws_stop", "web_st", "fin_prog",
         "b_city", "b_fin", "b_ban", "b_ign", "b_baners", "b_butt", "b_mess",
@@ -749,11 +748,16 @@ def update_or_insert_user(db_name, user_data, mapping_template):
 
     # Обновление данных пользователя в базе данных
     if user:
+        # Объединение новых сообщений с существующими
+        if 'b_mess' in transformed_data and user[2]:
+            transformed_data['b_mess'] = user[2] + "; " + transformed_data['b_mess']
+
         update_query = "UPDATE contacts SET "
         update_values = []
         for column, value in transformed_data.items():
-            update_query += f"{column} = ?, "
-            update_values.append(value)
+            if column != 'ws_st' or not user[1]:  # Проверка на наличие существующего ws_st
+                update_query += f"{column} = ?, "
+                update_values.append(value)
         update_query = update_query.rstrip(", ") + " WHERE email = ?"
         update_values.append(email)
         logging.debug(f"Update query: {update_query} with values: {update_values}")