Update app.py

app.py

@@ -1703,7 +1703,6 @@ def verify_phone_number2(phone_number):
     else:
         return "false"
 
-# Функция для обработки CSV данных
 def parse_csv_data(data):
     parsed_data = []
     for item in data:
@@ -1713,7 +1712,6 @@ def parse_csv_data(data):
             parsed_data.append(dict(zip(headers, row)))
     return parsed_data
 
-# Функция для вставки данных в базу данных
 def insert_data(data, template_key):
     global current_curator_index
     conn = sqlite3.connect(DATABASE2)
@@ -1722,7 +1720,6 @@ def insert_data(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)
@@ -1738,21 +1735,17 @@ def insert_data(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)
 
@@ -1774,16 +1767,22 @@ def insert_data(data, template_key):
 
         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)}")
             conn.rollback()
             raise
 
-    conn.commit()
-    conn.close()
+    try:
+        conn.commit()
+        print("Transaction committed successfully.")
+    except Exception as e:
+        print(f"Error committing transaction: {str(e)}")
+        conn.rollback()
+    finally:
+        conn.close()
 
-# Проверка ключа API
 def verify_api_key():
     api_key = request.args.get('api_sys')
     if api_key != "fasSd345D":
@@ -1836,7 +1835,6 @@ def upload_csv():
 
 
 
-
 
 
 @app.route('/gc_in', methods=['GET'])