Update app.py

app.py

@@ -735,7 +735,7 @@ def send_to_google_forms(user_data, gog_url):
         logging.error(f"Failed to send data to Google Forms for user: {user_data.get('email')}. Response: {response.text}")
 
         
-def update_or_insert_user(db_name, user_data, mapping_template):
+def update_or_insert_user(db_name, user_data, mapping_template, gog_url):
     conn = sqlite3.connect(db_name)
     cursor = conn.cursor()
 
@@ -746,12 +746,13 @@ def update_or_insert_user(db_name, user_data, mapping_template):
 
     logging.debug(f"Processing user with email: {email}")
 
-    cursor.execute("SELECT web_st, ws_st FROM contacts WHERE email = ?", (email,))
+    cursor.execute("SELECT web_st, ws_st, b_mess FROM contacts WHERE email = ?", (email,))
     user = cursor.fetchone()
     logging.debug(f"User found: {user}")
 
     current_web_st = user[0] if user else None
     current_ws_st = user[1] if user else None
+    current_messages = user[2] if user else ""
 
     transformed_data = {}
     for json_key, db_column in mapping_template.items():
@@ -796,6 +797,13 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     else:
         transformed_data['web_st'] = 1
 
+    new_messages = transformed_data.get('b_mess', "")
+    if current_messages:
+        transformed_data['b_mess'] = current_messages + "; " + new_messages
+    else:
+        transformed_data['b_mess'] = new_messages
+    logging.debug(f"Transformed data after message processing: {transformed_data}")
+
     if user:
         update_query = "UPDATE contacts SET "
         update_values = []
@@ -818,6 +826,10 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     conn.close()
     logging.debug(f"User with email {email} processed successfully")
 
+    # Отправка данных в Google Forms
+    send_to_google_forms(transformed_data, gog_url)
+
+
 
 @app.route('/send_request', methods=['POST'])
 def send_request():