Update app.py

app.py

@@ -1192,7 +1192,7 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     cursor = conn.cursor()
 
     # Получение email пользователя из данных
-    email = user_data.get('Email')
+    email = user_data.get('email')
     if not email:
         logging.error(f"User data missing email: {user_data}")
         return
@@ -1200,30 +1200,15 @@ 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 1 FROM contacts WHERE email = ?", (email,))
     user = cursor.fetchone()
     logging.debug(f"User found: {user}")
 
-    # Вынесение увеличения значения web_st в отдельный блок
-    web_st_value = 1  # Инициализация значения web_st
+    # Если пользователь существует, закрываем соединение и возвращаемся
     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}")
-
-        # Обновление значения web_st
-        cursor.execute("UPDATE contacts SET web_st = ? WHERE email = ?", (web_st_value, email))
-        conn.commit()
         conn.close()
-        logging.debug(f"User {email} web_st updated to {web_st_value}")
-    else:
-        conn.close()
-        logging.debug(f"User {email} not found, proceeding with insert")
-
-    # Открываем соединение снова для остальных операций
-    conn = sqlite3.connect(db_name)
-    cursor = conn.cursor()
+        logging.debug(f"User with email {email} already exists. Skipping insert.")
+        return
 
     # Преобразование данных пользователя на основе шаблона сопоставления
     transformed_data = {}
@@ -1254,39 +1239,26 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     logging.debug(f"Transformed data after adding required fields: {transformed_data}")
 
     # Обработка номера телефона, если он есть
-    if 'Phone' in user_data:
-        phone = user_data['Phone']
+    if 'phone' in user_data:
+        phone = user_data['phone']
         if phone.startswith('+'):
             phone = phone[1:]
         transformed_data['phone'] = phone
     logging.debug(f"Transformed data after phone processing: {transformed_data}")
 
-    # Добавление значения web_st в данные для вставки
-    transformed_data['web_st'] = web_st_value
-
-    # Обновление данных пользователя в базе данных
-    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 = update_query.rstrip(", ") + " WHERE email = ?"
-        update_values.append(email)
-        logging.debug(f"Update query: {update_query} with values: {update_values}")
-        cursor.execute(update_query, update_values)
-    else:
-        columns = ', '.join(transformed_data.keys())
-        placeholders = ', '.join('?' for _ in transformed_data)
-        insert_query = f"INSERT INTO contacts ({columns}) VALUES ({placeholders})"
-        insert_values = list(transformed_data.values())
-        logging.debug(f"Insert query: {insert_query} with values: {insert_values}")
-        cursor.execute(insert_query, insert_values)
+    # Добавление нового пользователя в базу данных
+    columns = ', '.join(transformed_data.keys())
+    placeholders = ', '.join('?' for _ in transformed_data)
+    insert_query = f"INSERT INTO contacts ({columns}) VALUES ({placeholders})"
+    insert_values = list(transformed_data.values())
+    logging.debug(f"Insert query: {insert_query} with values: {insert_values}")
+    cursor.execute(insert_query, insert_values)
 
     # Подтверждение изменений и закрытие соединения
     conn.commit()
     conn.close()
-    logging.debug(f"User with email {email} processed successfully")
+    logging.debug(f"User with email {email} inserted successfully")
+
 
 @app.route('/upload_csv', methods=['POST'])
 def upload_csv():