Update app.py

app.py

@@ -1190,8 +1190,7 @@ def parse_csv_data(data):
 def insert_data(data):
     conn = sqlite3.connect(DATABASE2)
     cursor = conn.cursor()
-    # Инвертируем порядок данных
-    data = reversed(data)
+
     for row in data:
         # Получение текущего времени в московском часовом поясе
         utc_now = datetime.utcnow()
@@ -1228,7 +1227,16 @@ def insert_data(data):
         n_con = row.get('n_con', '')
         canal = row.get('canal', '')
 
-        # Создание динамического SQL-запроса с использованием INSERT OR REPLACE
+        # Проверка существования пользователя в базе данных по email
+        cursor.execute("SELECT 1 FROM contacts WHERE email = ?", (email,))
+        user_exists = cursor.fetchone()
+
+        # Если пользователь существует, пропускаем вставку
+        if user_exists:
+            print(f"User with email {email} already exists. Skipping insert.")
+            continue
+
+        # Создание динамического SQL-запроса для вставки данных
         columns = ['name', 'phone', 'email', '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', 'shop_st', 'curator', 'pr1', 'pr2', 'pr3', 'pr4', 'pr5', 'ad_url', 'key_pr', 'n_con', 'canal', 'data_t']
         values = [name, phone, email, 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, shop_st, curator, pr1, pr2, pr3, pr4, pr5, ad_url, key_pr, n_con, canal, data_t]
 
@@ -1236,7 +1244,7 @@ def insert_data(data):
         columns_str = ', '.join(columns)
 
         query = f'''
-            INSERT OR REPLACE INTO contacts ({columns_str})
+            INSERT INTO contacts ({columns_str})
             VALUES ({placeholders})
         '''
 
@@ -1250,7 +1258,6 @@ def insert_data(data):
 
     conn.commit()
     conn.close()
-
 @app.route('/upload_csv', methods=['POST'])
 def upload_csv():
     if 'file' not in request.files: