Update app.py

app.py

@@ -747,12 +747,13 @@ def update_or_insert_user(db_name, user_data, mapping_template, gog_url):
 
     logging.debug(f"Processing user with email: {email}")
 
-    cursor.execute("SELECT web_st, b_mess 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}")
 
     current_web_st = user[0] if user else None
-    current_messages = user[1] if user else ""
+    current_ws_st = user[1] if user else None
+    current_messages = user[2] if user else ""
 
     transformed_data = {}
     for json_key, db_column in mapping_template.items():
@@ -786,11 +787,17 @@ def update_or_insert_user(db_name, user_data, mapping_template, gog_url):
     logging.debug(f"Transformed data after phone processing: {transformed_data}")
 
     # Проверяем наличие ws_st в базе данных и не перезаписываем его, если оно уже существует
-    if current_web_st is not None and current_web_st != "":
-        transformed_data['ws_st'] = current_web_st
+    if current_ws_st is not None and current_ws_st != "":
+        transformed_data['ws_st'] = current_ws_st
     else:
         transformed_data['ws_st'] = user_data.get('ws_st', "")
 
+    # Увеличиваем значение web_st на 1, если пользователь уже существует в базе данных
+    if current_web_st is not None:
+        transformed_data['web_st'] = int(current_web_st) + 1
+    else:
+        transformed_data['web_st'] = 1
+
     new_messages = transformed_data.get('b_mess', "")
     if current_messages:
         transformed_data['b_mess'] = current_messages + "; " + new_messages