Update app.py

app.py

@@ -824,24 +824,14 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     logging.debug(f"Transformed data after phone processing: {transformed_data}")
 
     # Увеличиваем значение web_st на единицу
-    web_st_value = 1
-    logging.debug(f"Calculated web_st_value: {web_st_value}")
-
-    update_query = "UPDATE contacts SET "
-    update_values = []
-    for column, value in transformed_data.items():
-        update_query += f"{column} = ?, "
-        update_values.append(value)
-    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)
+    update_query = "UPDATE contacts SET web_st = web_st + 1 WHERE email = ?"
+    cursor.execute(update_query, (email,))
 
     if cursor.rowcount == 0:
         columns = ', '.join(transformed_data.keys()) + ", web_st"
         placeholders = ', '.join('?' for _ in transformed_data) + ", ?"
         insert_query = f"INSERT INTO contacts ({columns}) VALUES ({placeholders})"
-        insert_values = list(transformed_data.values()) + [web_st_value]
+        insert_values = list(transformed_data.values()) + [1]
         logging.debug(f"Insert query: {insert_query} with values: {insert_values}")
         cursor.execute(insert_query, insert_values)
 
@@ -849,6 +839,42 @@ 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