Update app.py

app.py

@@ -935,6 +935,53 @@ def send_get_request():
 
 
 
+@app.route('/webhookbz', methods=['POST'])
+def data_gc_tab():
+    api_sys_control = request.args.get('api_sys')
+    if api_sys_control != api_key_sys:
+        return "EUR 22", 200
+
+    data = request.json
+    webinar_id = data.get('webinarId')
+
+    if not webinar_id:
+        return jsonify({'error': 'webinarId is required'}), 400
+
+    url = f'https://online.bizon365.ru/api/v1/webinars/reports/get?webinarId={webinar_id}'
+    response = requests.get(url, headers={'X-Token': api_key_sys})
+
+    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', {})
+
+        processed_emails = set()
+        for user_id, user_data in users_meta.items():
+            user_messages = messages_json.get(user_id, [])
+            user_data['messages'] = user_messages
+            email = user_data.get('email')
+            if email and email not in processed_emails:
+                update_or_insert_user(DATABASE_NAME, user_data, mapping_template)
+                processed_emails.add(email)
+
+        return jsonify({'status': 'User data saved successfully'})
+    else:
+        return jsonify({'error': 'Failed to fetch data from the API'}), response.status_code