Update app.py

app.py

@@ -782,6 +782,8 @@ def send_request():
 
 DATABASE_NAME = 'data_gc.db'
 
+
+
 def update_or_insert_user(db_name, user_data, mapping_template):
     conn = sqlite3.connect(db_name)
     cursor = conn.cursor()
@@ -821,10 +823,8 @@ def update_or_insert_user(db_name, user_data, mapping_template):
         transformed_data['phone'] = phone
     logging.debug(f"Transformed data after phone processing: {transformed_data}")
 
-    web_st_value = 0
-    if user:
-        web_st_value = 1 if user[0] is None or user[0] == "" or user[0] == 0 else int(user[0])
-        web_st_value += 1
+    # Увеличиваем значение web_st на единицу
+    web_st_value = 1
     logging.debug(f"Calculated web_st_value: {web_st_value}")
 
     update_query = "UPDATE contacts SET "
@@ -832,8 +832,8 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     for column, value in transformed_data.items():
         update_query += f"{column} = ?, "
         update_values.append(value)
-    update_query += "web_st = ? WHERE email = ?"
-    update_values.extend([web_st_value, email])
+    update_query += "web_st = web_st + 1 WHERE email = ?"
+    update_values.append(email)
     logging.debug(f"Update query: {update_query} with values: {update_values}")
     cursor.execute(update_query, update_values)
 
@@ -849,42 +849,24 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     conn.close()
     logging.debug(f"User with email {email} processed successfully")
 
-@app.route('/send_get_request', methods=['GET'])
-def send_get_request():
-    token = request.args.get('token')
-    webinarId = request.args.get('webinarId')
-    url = f'https://online.bizon365.ru/api/v1/webinars/reports/get?webinarId={webinarId}'
 
-    response = requests.get(url, headers={'X-Token': token})
 
-    if response.status_code == 200:
-        data = response.json()
 
-        report = data.get('report', {})
-        messages = data.get('messages', {})
 
-        report_json_str = report.get('report', '{}')
-        try:
-            report_json = json.loads(report_json_str)
-        except json.JSONDecodeError:
-            report_json = {}
 
-        messages_json_str = report.get('messages', '{}')
-        try:
-            messages_json = json.loads(messages_json_str)
-        except json.JSONDecodeError:
-            messages_json = {}
 
-        users_meta = report_json.get('usersMeta', {})
 
-        # Обновление или добавление каждого пользователя в базу данных data_gc.db
-        for user_id, user_data in users_meta.items():
-            user_data['messages'] = messages_json
-            update_or_insert_user(DATABASE_NAME, user_data, mapping_template)
 
-        return jsonify({'status': 'User data saved successfully'})
-    else:
-        return jsonify({'error': 'Failed to fetch data from the API'}), response.status_code
+
+
+
+
+
+
+
+
+
+