数据库同步首购优惠

import mysql.connector
from mysql.connector import Error

def sync_databases(source_config, target_config):
    try:
        source_conn = mysql.connector.connect(**source_config)
        target_conn = mysql.connector.connect(**target_config)
        
        if source_conn.is_connected() and target_conn.is_connected():
            source_cursor = source_conn.cursor()
            target_cursor = target_conn.cursor()
            
            # Fetch latest data from source
            source_cursor.execute("SELECT * FROM products WHERE updated_at > %s", (last_sync_time,))
            records = source_cursor.fetchall()
            
            for record in records:
                # Insert or update in target database
                target_cursor.execute("REPLACE INTO products VALUES (%s, %s, %s)", record)
            
            target_conn.commit()
            print("Sync completed successfully.")
    
    except Error as e:
        print(f"Error: {e}")
    
    finally:
        if source_conn.is_connected():
            source_cursor.close()
            source_conn.close()
        if target_conn.is_connected():
            target_cursor.close()
            target_conn.close()

# Configuration for source and target databases
source_db_config = {
    'host': 'source_host',
    'database': 'source_db',
    'user': 'source_user',
    'password': 'source_password'
}

target_db_config = {
    'host': 'target_host',
    'database': 'target_db',
    'user': 'target_user',
    'password': 'target_password'
}

sync_databases(source_db_config, target_db_config)

def apply_first_purchase_discount(user_id):
    # Check if the user is eligible for first purchase discount
    if is_first_purchase(user_id):
        discount_code = generate_discount_code()
        apply_discount_to_user(user_id, discount_code)
        return discount_code
    else:
        return None

def is_first_purchase(user_id):
    # Logic to check if it's the user's first purchase
    # This could involve querying a database or checking a cache
    pass

def generate_discount_code():
    # Generate a unique discount code
    import uuid
    return str(uuid.uuid4())

def apply_discount_to_user(user_id, discount_code):
    # Apply the discount code to the user's account
    pass

# Example usage
user_id = 12345
discount_code = apply_first_purchase_discount(user_id)
if discount_code:
    print(f"Discount code {discount_code} applied successfully.")
else:
    print("User is not eligible for first purchase discount.")