Update app.py

app.py

@@ -1703,7 +1703,18 @@ def verify_phone_number2(phone_number):
     else:
         return "false"
 
-def insert_data2(data, template_key):
+# Функция для обработки CSV данных
+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, template_key):
     global current_curator_index
     conn = sqlite3.connect(DATABASE2)
     cursor = conn.cursor()
@@ -1711,6 +1722,7 @@ def insert_data2(data, template_key):
     mapping_template_cur = mapp_templates.get(template_key, mt_avp)
 
     for row in data:
+        # Получение текущего времени в московском часовом поясе
         utc_now = datetime.utcnow()
         msk_tz = pytz.timezone('Europe/Moscow')
         msk_now = utc_now.replace(tzinfo=pytz.utc).astimezone(msk_tz)
@@ -1726,10 +1738,21 @@ def insert_data2(data, template_key):
             print(f"Missing required fields in row: {row}. Skipping insert.")
             continue
 
+        # Проверка существования пользователя в базе данных по email или телефону
+        cursor.execute("SELECT 1 FROM contacts WHERE email = ? OR phone = ?", (email, phone))
+        user_exists = cursor.fetchone()
+
+        # Если пользователь существует, пропускаем вставку
+        if user_exists:
+            print(f"User with email {email} or phone {phone} already exists. Skipping insert.")
+            continue
+
+        # Назначение куратора
         if curator_on_off == "1":
             user_data['curator'] = curators[current_curator_index]
             current_curator_index = (current_curator_index + 1) % len(curators)
 
+        # Верификация номера телефона
         if verifikation_start == "1":
             user_data['ws_st'] = verify_phone_number2(phone)
 
@@ -1749,13 +1772,8 @@ def insert_data2(data, template_key):
             VALUES ({placeholders})
         '''
 
-        # Вывод информации о строке перед записью в базу данных
-        print(f"Inserting row: {user_data}")
-
         try:
             cursor.execute(query, [user_data.get(field, '') for field in fields])
-            # Вывод информации о том, что запись была успешно выполнена
-            print(f"Row inserted successfully: {user_data}")
         except Exception as e:
             print(f"Error inserting row: {row}")
             print(f"Error message: {str(e)}")
@@ -1765,12 +1783,15 @@ def insert_data2(data, template_key):
     conn.commit()
     conn.close()
 
+# Проверка ключа API
+@app.before_request
+def verify_api_key():
+    api_key = request.args.get('api_key')
+    if api_key != "fasSd345D":
+        return jsonify({"error": "Invalid API key"}), 403
+
 @app.route('/upload_csv', methods=['POST'])
 def upload_csv():
-    global verifikation_start, curator_on_off
-
-    template_key = 'avp'  # Исправлено на существующий ключ
-
     if 'file' not in request.files:
         return jsonify({"error": "No file part"}), 400
     file = request.files['file']
@@ -1780,7 +1801,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_data2(data, template_key)
+        parsed_data = parse_csv_data(data)
+        insert_data(parsed_data, 'avp')
         return jsonify({"message": "Data uploaded and inserted successfully"})
     return jsonify({"error": "Invalid file format"}), 400