Update app.py

app.py

@@ -1180,6 +1180,15 @@ DATABASE2 = 'data_gc.db'
 
 
 
+def parse_csv_data(data):
+    parsed_data = []
+    for item in data:
+        for key, value in item.items():
+            headers = key.split(';')
+            row = value.split(';')
+            parsed_data.append(dict(zip(headers, row)))
+    return parsed_data
+
 def insert_data(data):
     conn = sqlite3.connect(DATABASE2)
     cursor = conn.cursor()
@@ -1191,9 +1200,9 @@ def insert_data(data):
         data_t = msk_now.strftime('%Y-%m-%d %H:%M:%S')
 
         # Проверка наличия ключей перед их использованием и предоставление значений по умолчанию
-        name = row.get('name', '')
-        phone = row.get('phone', '')
-        email = row.get('email', '')
+        name = row.get('Name', '')
+        phone = row.get('Phone', '')
+        email = row.get('Email', '')
         vk_id = row.get('vk_id', '')
         chat_id = row.get('chat_id', '')
         ws_st = row.get('ws_st', '')
@@ -1219,16 +1228,19 @@ def insert_data(data):
         n_con = row.get('n_con', '')
         canal = row.get('canal', '')
 
-        # Создание динамического SQL-запроса
+        # Создание динамического SQL-запроса с использованием INSERT ... ON CONFLICT ... DO UPDATE
         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]
 
         placeholders = ', '.join(['?' for _ in columns])
         columns_str = ', '.join(columns)
+        update_str = ', '.join([f'{col} = excluded.{col}' for col in columns])
 
         query = f'''
             INSERT INTO contacts ({columns_str})
             VALUES ({placeholders})
+            ON CONFLICT(email) DO UPDATE SET
+            {update_str}
         '''
 
         try:
@@ -1253,7 +1265,8 @@ def upload_csv():
         stream = io.StringIO(file.stream.read().decode("UTF8"), newline=None)
         csv_input = csv.DictReader(stream)
         data = [row for row in csv_input]
-        insert_data(data)
+        parsed_data = parse_csv_data(data)
+        insert_data(parsed_data)
         return jsonify({"message": "Data uploaded and inserted successfully"})
     return jsonify({"error": "Invalid file format"}), 400