实时推送

package main

import (
	"fmt"
	"log"
	"time"

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

func main() {
	cfg, err := config.NewClientConfig(
		config.WithPropertiesFile("tiger_openapi_config.properties"),
	)
	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 *push.QuoteData) {
			fmt.Printf("[行情] %s 最新价: %.2f 涨跌幅: %.2f%%\n",
				data.Symbol, data.LatestPrice, data.ChangePercentage)
		},
		OnTick: func(data *push.TickData) {
			fmt.Printf("[逐笔] %s 成交价: %.2f 数量: %d\n",
				data.Symbol, data.Price, data.Volume)
		},
		OnDepth: func(data *push.DepthData) {
			fmt.Printf("[深度] %s 更新\n", data.Symbol)
		},
		OnOrder: func(data *push.OrderData) {
			fmt.Printf("[订单] %s 状态变更: %s\n", data.Symbol, data.Status)
		},
		OnAsset: func(data *push.AssetData) {
			fmt.Println("[资产] 账户资产变动")
		},
		OnPosition: func(data *push.PositionData) {
			fmt.Printf("[持仓] %s 数量变更\n", data.Symbol)
		},
		OnTransaction: func(data *push.TransactionData) {
			fmt.Printf("[成交] %s 成交价: %.2f\n", data.Symbol, data.FilledPrice)
		},
	})

	// 连接推送服务
	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)

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

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 *push.TickData) {
//     fmt.Printf("成交: %.2f x %d\n", data.Price, data.Volume)
// }

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

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

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

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

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

pc.SubscribePosition("")

pc.SubscribeOrder("")
// 回调示例：
// OnOrder: func(data *push.OrderData) {
//     fmt.Printf("订单 %d 状态: %s\n", data.OrderId, data.Status)
// }

pc.SubscribeTransaction("")

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

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