Update app.py

app.py

@@ -788,6 +788,10 @@ def update_or_insert_user(db_name, user_data, mapping_template):
 
     # Получение email пользователя из данных
     email = user_data.get('email')
+    if not email:
+        logging.error(f"User data missing email: {user_data}")
+        return
+
     logging.debug(f"Processing user with email: {email}")
     
     # Проверка существования пользователя в базе данных по email
@@ -826,26 +830,25 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     logging.debug(f"Transformed data after phone processing: {transformed_data}")
 
     # Вынесение увеличения значения web_st в отдельный блок
-    web_st_value = 0
+    web_st_value = 1
     if user:
         # Проверка текущего значения web_st и его инкрементация
-        web_st_value = 1 if user[0] is None or user[0] == "" or user[0] == 0 else int(user[0])
-        web_st_value += 1
+        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}")
 
     # Обновление данных пользователя в базе данных
-    update_query = "UPDATE contacts SET "
-    update_values = []
-    for column, value in transformed_data.items():
-        update_query += f"{column} = ?, "
-        update_values.append(value)
-    update_query += "web_st = ? WHERE email = ?"
-    update_values.extend([web_st_value, email])
-    logging.debug(f"Update query: {update_query} with values: {update_values}")
-    cursor.execute(update_query, update_values)
-
-    # Если пользователь не найден, вставка нового пользователя
-    if cursor.rowcount == 0:
+    if user:
+        update_query = "UPDATE contacts SET "
+        update_values = []
+        for column, value in transformed_data.items():
+            update_query += f"{column} = ?, "
+            update_values.append(value)
+        update_query += "web_st = ? WHERE email = ?"
+        update_values.extend([web_st_value, email])
+        logging.debug(f"Update query: {update_query} with values: {update_values}")
+        cursor.execute(update_query, update_values)
+    else:
         columns = ', '.join(transformed_data.keys()) + ", web_st"
         placeholders = ', '.join('?' for _ in transformed_data) + ", ?"
         insert_query = f"INSERT INTO contacts ({columns}) VALUES ({placeholders})"
@@ -858,9 +861,6 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     conn.close()
     logging.debug(f"User with email {email} processed successfully")
 
-
-
-
 @app.route('/send_get_request', methods=['GET'])
 def send_get_request():
     token = request.args.get('token')
@@ -920,6 +920,7 @@ def send_get_request():
 
 
 
+
 
 
 @app.route('/biz_v', methods=['GET'])