Update app.py

app.py

@@ -782,131 +782,6 @@ 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()
-
-    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}")
-
-    cursor.execute("SELECT web_st FROM contacts WHERE email = ?", (email,))
-    user = cursor.fetchone()
-    logging.debug(f"User found: {user}")
-
-    web_st_value = 1
-    if user:
-        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}")
-
-        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):
-            transformed_data[db_column] = json.dumps(value) if value else ""
-        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", "ad_url",
-        "key_pr", "n_con", "canal", "data_t"
-    ]
-    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}")
-
-    transformed_data['web_st'] = web_st_value
-
-    if user:
-        update_query = "UPDATE contacts SET "
-        update_values = []
-        for column, value in transformed_data.items():
-            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 = Flask(__name__)
-
-@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', {})
-
-        processed_emails = set()
-        for user_id, user_data in users_meta.items():
-            user_data['messages'] = messages.get(user_id, [])
-            email = user_data.get('email')
-            if 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
-