实时推送

package main

import (
	"fmt"
	"log"
	"time"

	"github.com/tigerfintech/openapi-go-sdk/config"
	"github.com/tigerfintech/openapi-go-sdk/push"
	"github.com/tigerfintech/openapi-go-sdk/push/pb"
)

func main() {
	cfg, err := config.NewClientConfig()
	if err != nil {
		log.Fatal(err)
	}

	pc := push.NewPushClient(cfg)

	// 设置所有回调
	pc.SetCallbacks(push.Callbacks{
		OnConnect: func() {
			fmt.Println("[推送] 连接成功")
		},
		OnDisconnect: func() {
			fmt.Println("[推送] 连接断开，等待自动重连...")
		},
		OnError: func(err error) {
			fmt.Printf("[推送] 发生错误: %v\n", err)
		},
		OnKickout: func(reason string) {
			fmt.Printf("[推送] 账户被踢出: %s\n", reason)
		},
		OnQuote: func(data *pb.QuoteData) {
			fmt.Printf("[行情] %s latest=%.2f\n", data.GetSymbol(), data.GetLatestPrice())
		},
		OnTick: func(data *pb.TradeTickData) {
			fmt.Printf("[逐笔] %s\n", data.GetSymbol())
		},
		OnDepth: func(data *pb.QuoteDepthData) {
			fmt.Printf("[深度] %s\n", data.GetSymbol())
		},
		OnOrder: func(data *pb.OrderStatusData) {
			fmt.Printf("[订单] id=%d status=%s\n", data.GetId(), data.GetStatus())
		},
		OnAsset: func(data *pb.AssetData) {
			fmt.Println("[资产] 账户资产变动")
		},
		OnPosition: func(data *pb.PositionData) {
			fmt.Printf("[持仓] %s\n", data.GetSymbol())
		},
		OnTransaction: func(data *pb.OrderTransactionData) {
			fmt.Printf("[成交] orderId=%d\n", data.GetOrderId())
		},
	})

	if err := pc.Connect(); err != nil {
		log.Fatal(err)
	}
	defer pc.Disconnect()

	// 订阅行情推送
	if err := pc.SubscribeQuote([]string{"AAPL", "TSLA"}); err != nil {
		log.Printf("订阅行情失败: %v", err)
	}

	// 订阅账户推送（传空字符串使用配置中的账户）
	pc.SubscribeAsset("")
	pc.SubscribeOrder("")
	pc.SubscribePosition("")
	pc.SubscribeTransaction("")

	fmt.Println("推送已启动，按 Ctrl+C 退出...")
	time.Sleep(60 * time.Second)
}

cfg, _ := config.NewClientConfig(
    config.WithPropertiesFile("tiger_openapi_config.properties"),
)
pc := push.NewPushClient(cfg)

import "github.com/tigerfintech/openapi-go-sdk/push/pb"

pc.SetCallbacks(push.Callbacks{
    OnConnect: func() {
        fmt.Println("连接成功")
    },
    OnQuote: func(data *pb.QuoteData) {
        fmt.Printf("%s: %.2f\n", data.GetSymbol(), data.GetLatestPrice())
    },
})

if err := pc.Connect(); err != nil {
    log.Fatal("连接失败:", err)
}
defer pc.Disconnect()

state := pc.State()
fmt.Println("当前状态:", state)

// 订阅行情
if err := pc.SubscribeQuote([]string{"AAPL", "TSLA"}); err != nil {
    log.Println("订阅失败:", err)
}

// 退订某只股票
pc.UnsubscribeQuote([]string{"TSLA"})

pc.SubscribeTick([]string{"AAPL"})
// 回调中处理：
// OnTick: func(data *pb.TradeTickData) {
//     fmt.Printf("%s ticks=%d\n", data.GetSymbol(), len(data.GetTicks()))
// }

pc.SubscribeDepth([]string{"AAPL"})

pc.SubscribeOption([]string{"AAPL  250117C00150000"})

pc.SubscribeFuture([]string{"ES2506", "NQ2506"})

pc.SubscribeKline([]string{"AAPL"})

pc.SetCallbacks(push.Callbacks{
    OnStockTop: func(data *pb.StockTopData) {
        fmt.Printf("[StockTop] market=%s items=%d\n", data.GetMarket(), len(data.GetTopData()))
    },
})
// 订阅
pc.SubscribeStockTop("US", []string{"LATEST_PRICE", "HIGHER", "LOWER"})
// 退订
pc.UnsubscribeStockTop("US", []string{"LATEST_PRICE", "HIGHER", "LOWER"})

pc.SetCallbacks(push.Callbacks{
    OnOptionTop: func(data *pb.OptionTopData) {
        fmt.Printf("[OptionTop] market=%s items=%d\n", data.GetMarket(), len(data.GetTopData()))
    },
})
// 订阅
pc.SubscribeOptionTop("US", []string{"VOLUME", "AMOUNT"})
// 退订
pc.UnsubscribeOptionTop("US", []string{"VOLUME", "AMOUNT"})

pc.SetCallbacks(push.Callbacks{
    OnQuote: func(data *pb.QuoteData) {
        // Cc 推送也会进入这里
        fmt.Printf("[Quote/Cc] %s latest=%.2f\n", data.GetSymbol(), data.GetLatestPrice())
    },
})
// 订阅
pc.SubscribeCc([]string{"BTCUSD", "ETHUSD"})
// 退订
pc.UnsubscribeCc([]string{"BTCUSD", "ETHUSD"})

pc.SetCallbacks(push.Callbacks{
    OnQuote: func(data *pb.QuoteData) {
        // 市场状态变化也会进入这里
        fmt.Printf("[Market/Quote] symbol=%s\n", data.GetSymbol())
    },
})
// 订阅美股市场状态
pc.SubscribeMarket("US")
// 退订
pc.UnsubscribeMarket("US")

pc.SubscribeAsset("")         // 使用默认账户
pc.SubscribeAsset("DU123456") // 指定账户

pc.SubscribePosition("")

pc.SubscribeOrder("")
// 回调示例：
// OnOrder: func(data *pb.OrderStatusData) {
//     fmt.Printf("订单 %d 状态: %s\n", data.GetId(), data.GetStatus())
// }

pc.SubscribeTransaction("")

subs := pc.GetSubscriptions()
for subType, symbols := range subs {
    fmt.Printf("订阅类型: %v, 标的: %v\n", subType, symbols)
}

accountSubs := pc.GetAccountSubscriptions()
fmt.Println("已订阅账户推送:", accountSubs)