async def get_raydium_price() -> float:
    """从 DexScreener 获取 MCC 市场价格"""
    url = "https://api.dexscreener.com/latest/dex/pairs/solana/HgK6MkCSiuEk7kpDLhdfpKm8i7STuxxwQVBxAo4oshLa"
    response = await http.get(url)
    return float(response["pair"]["priceUsd"])

async def get_price_from_pool() -> float:
    """从 Raydium Pool 账户直接计算价格"""
    # 读取池子的 MCC 和 USDT 储备量
    pool_data = await rpc.get_account_info(POOL_ADDRESS)
    mcc_reserve = parse_mcc_reserve(pool_data)
    usdt_reserve = parse_usdt_reserve(pool_data)

    # 价格 = USDT 储备 / MCC 储备
    return usdt_reserve / mcc_reserve

def calculate_30day_average(prices: List[float]) -> float:
    """计算 30 天均价"""
    if len(prices) < 180:
        # 数据不足时使用已有数据
        pass
    return sum(prices) / len(prices)

-- 价格历史记录表
CREATE TABLE mcc_price_history (
    id SERIAL PRIMARY KEY,
    date DATE NOT NULL,
    hour_slot INTEGER NOT NULL,      -- 0-23 (每小时)
    close_price DECIMAL(20, 8) NOT NULL,
    source VARCHAR(50) NOT NULL,     -- 'raydium', 'admin', 'default'
    created_at TIMESTAMP DEFAULT NOW(),
    UNIQUE (date, hour_slot, source)
);

schedule: "0 * * * *"  # UTC 每小时整点