Update app.py

app.py

@@ -1556,34 +1556,32 @@ def add_or_update_contact_v2(contact_data):
     msk_now = utc_now.replace(tzinfo=pytz.utc).astimezone(msk_tz)
     contact_data['data_t'] = msk_now.strftime('%Y-%m-%d %H:%M:%S')
 
-    cursor.execute("SELECT id FROM contacts WHERE email = ?", (email,))
-    contact = cursor.fetchone()
-
+    # Список всех возможных полей
     fields = [
         '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', 'gc_url', 'key_pr', 'n_con', 'canal', 'data_t', 'utm_source', 'utm_medium', 'utm_campaign', 'utm_term', 'utm_content'
     ]
 
+    # Устанавливаем значения по умолчанию для отсутствующих полей
+    for field in fields:
+        if field not in contact_data:
+            contact_data[field] = ''
+
     placeholders = ", ".join([f"{field} = ?" for field in fields])
 
+    cursor.execute("SELECT id FROM contacts WHERE email = ?", (email,))
+    contact = cursor.fetchone()
+
     if contact:
         update_query = f"UPDATE contacts SET {placeholders} WHERE id = ?"
-        cursor.execute(update_query, (*[contact_data.get(field, '') for field in fields], contact[0]))
+        cursor.execute(update_query, (*[contact_data[field] for field in fields], contact[0]))
     else:
         insert_query = f"INSERT INTO contacts ({', '.join(fields)}) VALUES ({', '.join(['?' for _ in fields])})"
-        cursor.execute(insert_query, tuple(contact_data.get(field, '') for field in fields))
+        cursor.execute(insert_query, tuple(contact_data[field] for field in fields))
 
     conn.commit()
     conn.close()
-def send_to_google_forms_v2(user_data, gog_url):
-    logging.debug(f"Sending data to Google Forms: {user_data}")
-    url = gog_url.format(**user_data)
-    response = requests.post(url)
-    if response.status_code == 200:
-        logging.debug(f"Data sent to Google Forms successfully for user: {user_data.get('email')}")
-    else:
-        logging.error(f"Failed to send data to Google Forms for user: {user_data.get('email')}. Response: {response.text}")
 
 @app.route('/add_data_ver_cur', methods=['GET'])
 def add_data_ver_cur():