行情查询

use tigeropen::config::ClientConfig;
use tigeropen::model::quote_requests::BriefRequest;
use tigeropen::quote::QuoteClient;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = ClientConfig::builder().build()?;
    // v0.5.0 起：直接用 from_config() 创建，无需手动构造 HttpClient
    let qc = QuoteClient::from_config(config);

    // 获取市场状态
    let states = qc.get_market_state("US").await?;
    println!("美股市场状态: {:?}", states);

    // 获取实时报价
    let briefs = qc.get_real_time_quote(BriefRequest {
        symbols: Some(vec!["AAPL".to_string(), "TSLA".to_string()]),
        ..Default::default()
    }).await?;
    println!("实时报价: {:?}", briefs);

    // 获取 K 线数据（v0.5.0 起支持多 symbol）
    let klines = qc.get_kline(&["AAPL", "TSLA"], "day").await?;
    println!("K 线数据: {:?}", klines);

    Ok(())
}

let states = qc.get_market_state("US").await?;
if let Some(s) = states.first() {
    println!("market={} status={} openTime={}", s.market, s.market_status, s.open_time);
}

// 查询港股市场状态
let hk_states = qc.get_market_state("HK").await?;

{ "market": "US" }

[
  {
    "market": "US",
    "marketStatus": "TRADING",
    "status": "trading",
    "openTime": "2025-05-06 09:30:00"
  }
]

use tigeropen::model::quote_requests::TradingCalendarRequest;

let calendar = qc.get_trading_calendar(TradingCalendarRequest {
    market: Some("US".to_string()),
    begin_date: Some("2025-01-01".to_string()),
    end_date: Some("2025-12-31".to_string()),
    ..Default::default()
}).await?;

let perms = qc.grab_quote_permission().await?;
for p in &perms {
    println!("{} expire_at={}", p.name, p.expire_at);
}

[
  { "name": "US_BASIC", "expireAt": 1767225600000 },
  { "name": "HK_BASIC", "expireAt": 1767225600000 },
  { "name": "US_REALTIME", "expireAt": 1767225600000 }
]

let quota = qc.get_kline_quota().await?;
println!("used={} total={}", quota.used, quota.quota);

use tigeropen::model::quote_requests::SymbolsRequest;
let symbols = qc.get_symbols(SymbolsRequest { market: Some("US".to_string()), ..Default::default() }).await?;
println!("symbols={}", symbols.len());

use tigeropen::model::quote_requests::SymbolNamesRequest;
let names = qc.get_symbol_names(SymbolNamesRequest {
    symbols: Some(vec!["AAPL".to_string()]),
    ..Default::default()
}).await?;

use tigeropen::model::quote_requests::TradeMetasRequest;
let metas = qc.get_trade_metas(TradeMetasRequest {
    symbols: Some(vec!["AAPL".to_string()]),
    ..Default::default()
}).await?;

use tigeropen::model::quote_requests::BriefRequest;

let briefs = qc.get_real_time_quote(BriefRequest {
    symbols: Some(vec!["AAPL".to_string(), "TSLA".to_string(), "00700".to_string()]),
    ..Default::default()
}).await?;
for b in &briefs {
    println!("{} latest={:.2} change_rate={:.4}", b.symbol, b.latest_price, b.change_rate);
}

{ "symbols": ["AAPL", "TSLA"] }

[
  {
    "symbol": "AAPL",
    "latestPrice": 227.52,
    "preClose": 225.01,
    "change": 2.51,
    "changeRate": 0.01115,
    "volume": 62345678,
    "open": 225.50,
    "high": 228.10,
    "low": 224.80,
    "askPrice": 227.53,
    "askSize": 300,
    "bidPrice": 227.52,
    "bidSize": 400,
    "latestTime": 1735042800000
  },
  {
    "symbol": "TSLA",
    "latestPrice": 410.44,
    "preClose": 403.84,
    "change": 6.60,
    "changeRate": 0.01634,
    "volume": 98765432,
    "open": 405.00,
    "high": 415.20,
    "low": 402.30,
    "latestTime": 1735042800000
  }
]

use tigeropen::model::quote_requests::BriefRequest;
let delay = qc.get_delayed_quote(BriefRequest {
    symbols: Some(vec!["AAPL".to_string()]),
    ..Default::default()
}).await?;

// 单只股票日线
let klines = qc.get_kline(&["AAPL"], "day").await?;
if let Some(k) = klines.first() {
    println!("{} bars={}", k.symbol, k.items.len());
}

// 多只股票批量查询（v0.5.0+）
let klines = qc.get_kline(&["AAPL", "TSLA"], "day").await?;

// 获取 5 分钟 K 线
let klines_5min = qc.get_kline(&["AAPL"], "5min").await?;

{ "symbols": ["AAPL", "TSLA"], "period": "day" }

[
  {
    "symbol": "AAPL",
    "period": "day",
    "items": [
      {
        "time": 1734912000000,
        "open": 222.56,
        "high": 225.72,
        "low": 222.11,
        "close": 225.01,
        "volume": 55234100
      },
      {
        "time": 1734998400000,
        "open": 225.50,
        "high": 228.10,
        "low": 224.80,
        "close": 227.52,
        "volume": 62345678
      }
    ]
  }
]

let timeline = qc.get_timeline(&["AAPL", "TSLA"]).await?;
if let Some(t) = timeline.first() {
    let points = t.intraday.as_ref().map(|b| b.items.len()).unwrap_or(0);
    println!("{} intraday_points={} preClose={:.2}", t.symbol, points, t.pre_close);
}

{ "symbols": ["AAPL"] }

[
  {
    "symbol": "AAPL",
    "period": "day",
    "preClose": 225.01,
    "intraday": {
      "items": [
        { "time": 1735020600000, "price": 225.50, "volume": 3021456, "avgPrice": 225.48 },
        { "time": 1735020660000, "price": 225.80, "volume": 1234567, "avgPrice": 225.55 }
      ]
    }
  }
]

use tigeropen::model::quote_requests::TimelineHistoryRequest;
let tl = qc.get_timeline_history(TimelineHistoryRequest {
    symbols: Some(vec!["AAPL".to_string()]),
    date: Some("2025-05-01".to_string()),
    ..Default::default()
}).await?;

use tigeropen::model::quote_requests::TradeTickRequest;

let ticks = qc.get_trade_tick(TradeTickRequest {
    symbols: Some(vec!["AAPL".to_string()]),
    ..Default::default()
}).await?;
if let Some(t) = ticks.first() {
    println!("{} ticks={}", t.symbol, t.items.len());
}

{ "symbols": ["AAPL"] }

[
  {
    "symbol": "AAPL",
    "beginIndex": 0,
    "endIndex": 1,
    "items": [
      { "time": 1735042780000, "price": 227.52, "volume": 100, "type": "B" },
      { "time": 1735042781000, "price": 227.50, "volume": 200, "type": "S" }
    ]
  }
]

use tigeropen::model::quote_requests::DepthQuoteRequest;

let depth = qc.get_quote_depth(DepthQuoteRequest {
    symbols: Some(vec!["AAPL".to_string()]),
    market: Some("US".to_string()),
    ..Default::default()
}).await?;
if let Some(d) = depth.first() {
    println!("asks={} bids={}", d.asks.len(), d.bids.len());
}

{ "symbols": ["AAPL"], "market": "US" }

[
  {
    "symbol": "AAPL",
    "asks": [
      { "price": 227.53, "volume": 300, "count": 2 },
      { "price": 227.55, "volume": 500, "count": 4 }
    ],
    "bids": [
      { "price": 227.52, "volume": 400, "count": 3 },
      { "price": 227.50, "volume": 600, "count": 5 }
    ]
  }
]

use tigeropen::model::quote_requests::StockBrokerRequest;
let brokers = qc.get_stock_broker(StockBrokerRequest {
    symbol: Some("00700".to_string()),
    ..Default::default()
}).await?;

if let Some(cf) = qc.get_capital_flow("AAPL", "US", "day").await? {
    println!("{} period={} rows={}", cf.symbol, cf.period, cf.items.len());
}

{
  "symbol": "AAPL",
  "period": "day",
  "items": [
    { "time": "2025-05-05", "timestamp": 1746403200000, "netInflow": 111111101 },
    { "time": "2025-05-06", "timestamp": 1746489600000, "netInflow": -25430000 }
  ]
}

if let Some(cd) = qc.get_capital_distribution("AAPL", "US").await? {
    println!("{} netInflow={:.2}", cd.symbol, cd.net_inflow);
}

{
  "symbol": "AAPL",
  "netInflow": 1111111101,
  "inAll": 8234567890,
  "inBig": 5123456789,
  "inMid": 2012345678,
  "inSmall": 1098765432,
  "outAll": 7123456789,
  "outBig": 4012345678,
  "outMid": 1800000000,
  "outSmall": 1311111111
}

// 单只股票
let exps = qc.get_option_expiration(&["AAPL"]).await?;
if let Some(e) = exps.first() {
    println!("dates={} first={}", e.dates.len(), e.dates.first().unwrap_or(&"".into()));
}

// 批量查询（v0.5.0+）
let exps = qc.get_option_expiration(&["AAPL", "TSLA"]).await?;

{ "symbols": ["AAPL"] }

[
  {
    "symbol": "AAPL",
    "dates": ["2025-01-17", "2025-02-21", "2025-03-21", "2025-06-20", "2025-09-19"],
    "timestamps": [1737072000000, 1740096000000, 1742515200000, 1750377600000, 1758240000000]
  }
]

use tigeropen::model::quote_requests::{OptionChainItem, OptionChainRequest};

// 单个查询（日期字符串，自动推断时区）
let chain = qc.get_option_chain(OptionChainRequest::new(vec![
    OptionChainItem::from_date("AAPL", "2025-01-17")?,
])).await?;
if let Some(row) = chain.first().and_then(|c| c.items.first()) {
    let call_id = row.call.as_ref().map(|l| l.identifier.clone()).unwrap_or_default();
    println!("call={}", call_id);
}

// 批量查询
let chains = qc.get_option_chain(OptionChainRequest::new(vec![
    OptionChainItem::from_date("AAPL", "2025-01-17")?,
    OptionChainItem::from_date("TSLA", "2025-02-21")?,
])).await?;

[
  {
    "symbol": "AAPL",
    "expiry": 1737072000000,
    "items": [
      {
        "call": {
          "identifier": "AAPL  250117C00220000",
          "strike": "220",
          "right": "CALL",
          "latestPrice": 9.50,
          "impliedVol": 0.285,
          "delta": 0.612
        },
        "put": {
          "identifier": "AAPL  250117P00220000",
          "strike": "220",
          "right": "PUT",
          "latestPrice": 2.10,
          "impliedVol": 0.312
        }
      }
    ]
  }
]

use tigeropen::model::quote_requests::{OptionContractItem, OptionQuoteRequest};

let opt_briefs = qc.get_option_quote(OptionQuoteRequest::new(vec![
    OptionContractItem::from_occ("AAPL  250117C00150000")?,
])).await?;
if let Some(b) = opt_briefs.first() {
    println!("{} latest={:.4}", b.symbol, b.latest_price);
}

[
  {
    "symbol": "AAPL",
    "expiry": "2025-01-17",
    "strike": "150",
    "right": "CALL",
    "latestPrice": 9.50,
    "preClose": 9.10,
    "change": 0.40,
    "openInterest": 12540,
    "volume": 3820,
    "multiplier": 100
  }
]

let mut item = OptionKlineItem::from_occ("AAPL  250117C00150000", "day")?;
item.begin_time = Some(begin_ms);
item.limit = Some(60);

use tigeropen::model::quote_requests::{OptionKlineItem, OptionKlineRequest};

// 单个合约
let opt_kline = qc.get_option_kline(OptionKlineRequest {
    option_query: Some(vec![
        OptionKlineItem::from_occ("AAPL  250117C00150000", "day")?,
    ]),
    ..Default::default()
}).await?;
if let Some(k) = opt_kline.first() {
    println!("bars={}", k.items.len());
}

// 批量查询
let opt_klines = qc.get_option_kline(OptionKlineRequest {
    option_query: Some(vec![
        OptionKlineItem::from_occ("AAPL  250117C00150000", "day")?,
        OptionKlineItem::from_occ("AAPL  250117P00150000", "day")?,
    ]),
    ..Default::default()
}).await?;

[
  {
    "symbol": "AAPL  250117C00150000",
    "period": "day",
    "items": [
      { "time": 1734912000000, "open": 8.80, "high": 9.60, "low": 8.70, "close": 9.10, "volume": 2100 },
      { "time": 1734998400000, "open": 9.10, "high": 9.80, "low": 9.00, "close": 9.50, "volume": 3820 }
    ]
  }
]

use tigeropen::model::OptionAnalysisRequest;

let analyses = qc.get_option_analysis(OptionAnalysisRequest {
    symbols: Some(vec!["AAPL".to_string()]),
    market: Some("US".to_string()),
    period: Some("26week".to_string()),
    ..Default::default()
}).await?;

for a in &analyses {
    println!(
        "{}: iv30d={:.4} hv={:.4} iv/hv={:.4}",
        a.symbol, a.implied_vol_30_days, a.his_volatility, a.iv_his_v_ratio
    );
    if let Some(m) = &a.implied_vol_metric {
        println!("  percentile={:.2} rank={:.2}", m.percentile, m.rank);
    }
}

let exchanges = qc.get_future_exchange().await?;
for e in &exchanges {
    println!("{} {} ({})", e.code, e.name, e.zone_id);
}

[
  { "code": "CME", "name": "Chicago Mercantile Exchange", "zoneId": "America/Chicago" },
  { "code": "CBOT", "name": "Chicago Board of Trade", "zoneId": "America/Chicago" },
  { "code": "NYMEX", "name": "New York Mercantile Exchange", "zoneId": "America/New_York" },
  { "code": "HKEX", "name": "Hong Kong Exchanges and Clearing", "zoneId": "Asia/Hong_Kong" }
]

let contracts = qc.get_future_contracts("CME").await?;
if let Some(c) = contracts.first() {
    println!("first contract={}", c.contract_code);
}

{ "exchange_code": "CME" }

[
  {
    "contractCode": "ES2506",
    "name": "E-mini S&P 500",
    "type": "index",
    "contractMonth": "202506",
    "lastTradingDate": "2025-06-20",
    "currency": "USD",
    "multiplier": 50,
    "minTick": 0.25,
    "exchange": "CME"
  },
  {
    "contractCode": "NQ2506",
    "name": "E-mini NASDAQ-100",
    "type": "index",
    "contractMonth": "202506",
    "currency": "USD",
    "multiplier": 20,
    "minTick": 0.25,
    "exchange": "CME"
  }
]

use tigeropen::model::quote_requests::FutureContractRequest;
let main = qc.get_current_future_contract(FutureContractRequest {
    type_: Some("CL".to_string()),
    ..Default::default()
}).await?;
if let Some(c) = main {
    println!("current main: {}", c.contract_code);
}

use tigeropen::model::quote_requests::FutureBriefRequest;

let fut_quotes = qc.get_future_real_time_quote(FutureBriefRequest {
    contract_codes: Some(vec!["ES2506".to_string(), "NQ2506".to_string()]),
    ..Default::default()
}).await?;
for q in &fut_quotes {
    println!("{} latest={:.4}", q.contract_code, q.latest_price);
}

{ "contract_codes": ["ES2506", "NQ2506"] }

[
  {
    "contractCode": "ES2506",
    "latestPrice": 5920.50,
    "latestTime": 1735042800000,
    "bidPrice": 5920.25,
    "askPrice": 5920.75,
    "volume": 1234567,
    "openInterest": 2345678,
    "open": 5900.00,
    "high": 5935.00,
    "low": 5895.00,
    "settlement": 5895.25
  }
]

use tigeropen::model::quote::FutureKlineRequest;

let fut_kline = qc.get_future_kline(FutureKlineRequest {
    contract_codes: vec!["ES2506".into()],
    period: "day".into(),
    begin_time: -1,
    end_time: -1,
    limit: None,
    page_token: None,
}).await?;
if let Some(k) = fut_kline.first() {
    println!("bars={}", k.items.len());
}

[
  {
    "items": [
      {
        "time": 1734912000000,
        "open": 5870.00,
        "high": 5900.00,
        "low": 5860.00,
        "close": 5895.25,
        "volume": 1023456,
        "openInterest": 2340000,
        "settlement": 5895.25
      },
      {
        "time": 1734998400000,
        "open": 5900.00,
        "high": 5935.00,
        "low": 5895.00,
        "close": 5920.50,
        "volume": 1234567
      }
    ]
  }
]

use tigeropen::model::quote_requests::FundQuoteRequest;
let q = qc.get_fund_quote(FundQuoteRequest {
    symbols: Some(vec!["SPY".to_string()]),
    ..Default::default()
}).await?;

use tigeropen::model::quote_requests::IndustryListRequest;

let industries = qc.get_industry_list(IndustryListRequest {
    level: Some("GSECTOR".to_string()),
    ..Default::default()
}).await?;

use tigeropen::model::quote::MarketScannerRequest;

if let Some(r) = qc.market_scanner(MarketScannerRequest {
    market: "US".into(),
    page: Some(0),
    page_size: Some(10),
    ..Default::default()
}).await? {
    println!("page={}/{} items={}", r.page, r.total_page, r.items.len());
}

{
  "page": 0,
  "totalPage": 50,
  "totalCount": 500,
  "pageSize": 10,
  "items": [
    {
      "symbol": "AAPL",
      "market": "US",
      "baseDataList": [
        { "index": 0, "name": "latest_price", "data": 227.52 }
      ]
    },
    {
      "symbol": "NVDA",
      "market": "US",
      "baseDataList": [
        { "index": 0, "name": "latest_price", "data": 138.85 }
      ]
    }
  ]
}

use tigeropen::model::{MarketScannerTagsRequest, MarketScannerTagGroup};

let groups = qc.get_market_scanner_tags(MarketScannerTagsRequest {
    market: Some("US".to_string()),
    multi_tags_fields: Some(vec!["MultiTagField_Industry".to_string()]),
    ..Default::default()
}).await?;

for g in &groups {
    println!("market={} field={} tags={}", g.market, g.multi_tag_field, g.tag_list.len());
    for tag in &g.tag_list {
        println!("  {} ({}) values={:?}", tag.field, tag.name, tag.values);
    }
}