Update app.py

app.py

@@ -100,7 +100,18 @@ for db in DATABASES:
 
 
 
-
+template = {
+    "username": "name",
+    "phone": "phone",
+    "email": "email",
+    "city": "b_city",
+    "finished": "b_fin",
+    "ban": "b_ban",
+    "ignore": "b_ign",
+    "banners": "b_baners",  # Если массив заполнен пишем -1, если пустой пишем - 0
+    "buttons": "b_butt",    # Если массив заполнен пишем -1, если пустой пишем - 0
+    "messages": "b_mess"
+}
 
 
 
@@ -764,7 +775,7 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     email = user_data.get('email')
     
     # Проверка существования пользователя
-    cursor.execute("SELECT * FROM contacts WHERE email = ?", (email,))
+    cursor.execute("SELECT web_st FROM contacts WHERE email = ?", (email,))
     user = cursor.fetchone()
 
     # Преобразование данных пользователя на основе шаблона
@@ -778,40 +789,28 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     
     if user:
         # Обновление существующего пользователя
+        web_st_value = user[0] + 1
         update_query = "UPDATE contacts SET "
         update_values = []
         for column, value in transformed_data.items():
             update_query += f"{column} = ?, "
             update_values.append(value)
-        update_query = update_query.rstrip(", ") + " WHERE email = ?"
-        update_values.append(email)
+        update_query += "web_st = ? WHERE email = ?"
+        update_values.extend([web_st_value, email])
         cursor.execute(update_query, update_values)
     else:
         # Добавление нового пользователя
-        columns = ', '.join(transformed_data.keys())
-        placeholders = ', '.join('?' for _ in transformed_data)
+        columns = ', '.join(transformed_data.keys()) + ", web_st"
+        placeholders = ', '.join('?' for _ in transformed_data) + ", ?"
         insert_query = f"INSERT INTO contacts ({columns}) VALUES ({placeholders})"
-        cursor.execute(insert_query, list(transformed_data.values()))
+        insert_values = list(transformed_data.values()) + [1]
+        cursor.execute(insert_query, insert_values)
 
     conn.commit()
     conn.close()
 
 @app.route('/send_get_request', methods=['GET'])
 def send_get_request():
-    template = {
-        "username": "name",
-        "phone": "phone",
-        "email": "email",
-        "city": "b_city", 
-        "finished": "b_fin",
-        "ban": "b_ban",
-        "ignore": "b_ign",
-        "banners": "b_baners", # Если массив заполнен пишем -1, если пустой пишем - 0
-        "buttons": "b_butt",   # Если массив заполнен пишем -1, если пустой пишем - 0
-        "messages": "b_mess",
-        "0": "web_st",  # С первого раза и с каждым обновлением пользователя, увеличиваем на 1
-    }
-
     token = request.args.get('token')
     webinarId = request.args.get('webinarId')
     url = f'https://online.bizon365.ru/api/v1/webinars/reports/get?webinarId={webinarId}'
@@ -871,7 +870,6 @@ def send_get_request():
 
 
 
-
 
 
 @app.route('/biz_v', methods=['GET'])