Update app.py

app.py

@@ -806,6 +806,41 @@ curator_on_off = "1"  # Глобальная переменная для упр
 
 current_curator_index = 0
 
+import sqlite3
+import requests
+import json
+import logging
+from flask import Flask, request, jsonify
+
+app = Flask(__name__)
+
+DATABASE_NAME = 'data_gc.db'
+
+verifikation_start = "1"  # Глобальная переменная для управления верификацией
+curator_on_off = "1"  # Глобальная переменная для управления назначением куратора
+current_curator_index = 0
+curators = ["Curator1", "Curator2", "Curator3"]  # Список кураторов
+
+wa_url = 'https://api.whatsapp.com/send?phone='  # URL для верификации номера
+wa_ak = ''  # Некоторая часть URL
+ws_url_ver = ''  # Часть URL
+wa_api_key = 'YOUR_WHATSAPP_API_KEY'  # API-ключ для верификации номера
+api_key_sys = 'YOUR_API_KEY'  # API-ключ для системного доступа
+
+mapping_template = {
+    "name": "name",
+    "phone": "phone",
+    "email": "email",
+    "b_city": "b_city",
+    "b_fin": "b_fin",
+    "b_ban": "b_ban",
+    "b_ign": "b_ign",
+    "b_baners": "b_baners",
+    "b_butt": "b_butt",
+    "b_mess": "b_mess"
+    # Добавьте все необходимые поля для маппинга
+}
+
 def verify_phone_number_biz(phone_number):
     full_url_ver = f"{wa_url}{wa_ak}{ws_url_ver}{wa_api_key}"
     payload = {"phoneNumber": phone_number}
@@ -968,53 +1003,6 @@ def send_get_request_biz():
     except requests.exceptions.RequestException as e:
         return jsonify({'error': f'API request failed: {str(e)}'}), 500
 
-@app.route('/webhookbz', methods=['POST'])
-def webhookbz_biz():
-    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_biz(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'}), 500