Update app.py

app.py

@@ -397,7 +397,7 @@ def upload_csv():
 
 
 
-# ОБНОВЛЯЕМ CSV JSON-файла
+# ОБНОВЛЯЕМ JSON-файла
 DATABASE = 'data_gc.db'
 
 # Функция для очистки номера телефона
@@ -470,6 +470,239 @@ def upload_json():
 
 
 
+# ОБНОВЛЯЕМ Бизон 365
+DATABASE_NAME = 'data_gc.db'
+
+def update_or_insert_user(db_name, user_data, mapping_template):
+    conn = sqlite3.connect(db_name)
+    cursor = conn.cursor()
+
+    # Получение email пользователя из данных
+    email = user_data.get('email')
+    if not email:
+        logging.error(f"User data missing email: {user_data}")
+        return
+
+    logging.debug(f"Processing user with email: {email}")
+    
+    # Проверка существования пользователя в базе данных по email
+    cursor.execute("SELECT web_st, ws_st, b_mess FROM contacts WHERE email = ?", (email,))
+    user = cursor.fetchone()
+    logging.debug(f"User found: {user}")
+
+    # Вынесение увеличения значения web_st в отдельный блок
+    web_st_value = 1  # Инициализация значения web_st
+    if user:
+        # Проверка текущего значения web_st и его инкрементация
+        current_web_st = user[0] if user[0] is not None and user[0] != "" else 0
+        web_st_value = int(current_web_st) + 1
+        logging.debug(f"Calculated web_st_value: {web_st_value}")
+
+        # Обновление значения web_st
+        cursor.execute("UPDATE contacts SET web_st = ? WHERE email = ?", (web_st_value, email))
+        conn.commit()
+        conn.close()
+        logging.debug(f"User {email} web_st updated to {web_st_value}")
+    else:
+        conn.close()
+        logging.debug(f"User {email} not found, proceeding with insert")
+
+    # Открываем соединение снова для остальных операций
+    conn = sqlite3.connect(db_name)
+    cursor = conn.cursor()
+
+    # Преобразование данных пользователя на основе шаблона сопоставления
+    transformed_data = {}
+    for json_key, db_column in mapping_template.items():
+        value = user_data.get(json_key, "")
+        
+        if isinstance(value, list):
+            # Проверяем тип элементов списка
+            if all(isinstance(item, str) for item in value):
+                transformed_data[db_column] = "; ".join(value)  # Сохраняем сообщения в строку
+            else:
+                logging.error(f"Expected list of strings for key {json_key}, but got: {value}")
+                transformed_data[db_column] = ""
+        else:
+            transformed_data[db_column] = str(value)
+    logging.debug(f"Transformed data: {transformed_data}")
+
+    # Заполнение обязательных полей значениями по умолчанию
+    required_fields = [
+        "vk_id", "chat_id", "ws_st", "ws_stop", "web_st", "fin_prog",
+        "b_city", "b_fin", "b_ban", "b_ign", "b_baners", "b_butt", "b_mess",
+        "shop_st", "curator", "pr1", "pr2", "pr3", "pr4", "pr5", "gc_url",
+        "key_pr", "n_con", "canal", "data_on", "data_t", 'utm_source', 'utm_medium', 'utm_campaign', 'utm_term', 'utm_content', 'gcpc'
+    ]
+
+    for field in required_fields:
+        if field not in transformed_data:
+            transformed_data[field] = ""
+    logging.debug(f"Transformed data after adding required fields: {transformed_data}")
+
+    # Обработка номера телефона, если он есть
+    if 'phone' in user_data:
+        phone = user_data['phone']
+        if phone.startswith('+'):
+            phone = phone[1:]
+        transformed_data['phone'] = phone
+    logging.debug(f"Transformed data after phone processing: {transformed_data}")
+
+    # Добавление значения web_st в данные для вставки
+    transformed_data['web_st'] = web_st_value
+
+    # Обновление данных пользователя в базе данных
+    if user:
+        # Объединение новых сообщений с существующими
+        if 'b_mess' in transformed_data and user[2]:
+            transformed_data['b_mess'] = user[2] + "; " + transformed_data['b_mess']
+
+        update_query = "UPDATE contacts SET "
+        update_values = []
+        for column, value in transformed_data.items():
+            if column != 'ws_st' or not user[1]:  # Проверка на наличие существующего ws_st
+                update_query += f"{column} = ?, "
+                update_values.append(value)
+        update_query = update_query.rstrip(", ") + " WHERE email = ?"
+        update_values.append(email)
+        logging.debug(f"Update query: {update_query} with values: {update_values}")
+        cursor.execute(update_query, update_values)
+    else:
+        columns = ', '.join(transformed_data.keys())
+        placeholders = ', '.join('?' for _ in transformed_data)
+        insert_query = f"INSERT INTO contacts ({columns}) VALUES ({placeholders})"
+        insert_values = list(transformed_data.values())
+        logging.debug(f"Insert query: {insert_query} with values: {insert_values}")
+        cursor.execute(insert_query, insert_values)
+
+    # Подтверждение изменений и закрытие соединения
+    conn.commit()
+    conn.close()
+    logging.debug(f"User with email {email} processed successfully")
+
+
+@app.route('/send_request', methods=['POST'])
+def send_request():
+    token = request.form.get('token')
+    min_date = request.form.get('minDate')
+    type = request.form.get('type')
+    url = f'https://online.bizon365.ru/api/v1/webinars/reports/getlist?minDate={min_date}&limit=100&type={type}'
+    
+    response = requests.get(url, headers={'X-Token': token})
+    
+    if response.status_code == 200:
+        data = response.json()
+        webinar_ids = [item['webinarId'] for item in data['list']]
+        return jsonify(webinar_ids)
+    else:
+        return jsonify({'error': 'Failed to fetch data from the API'}), response.status_code
+
+
+
+
+@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}'
+
+    try:
+        response = requests.get(url, headers={'X-Token': token})
+        response.raise_for_status()  # Проверка на ошибки HTTP
+        data = response.json()
+
+        # Убедитесь, что report существует в данных
+        if data is None or 'report' not in data:
+            return jsonify({'error': 'No report data found'}), 500
+
+        report = data.get('report', {})
+        messages = data.get('messages', {})
+
+        # Проверка на None перед использованием
+        if report is None:
+            return jsonify({'error': 'No report data found in the response'}), 500
+
+        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'})
+    
+    except requests.exceptions.RequestException as e:
+        return jsonify({'error': f'API request failed: {str(e)}'}), 500
+
+api_bz = "SkrIONpr3ByeSIuEaBhr1bB8u4aBhSJfH8uEpB2rk7rI_ETrn"
+
+
+@app.route('/webhookbz', methods=['POST'])
+def webhookbz():
+    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
+
+
+