package business

import (
	"wss-pool/logging/applogger"
)

func RunHBData(checkData string) {
	HbMarketSpots(checkData)
	HbContract(checkData)
	ShareMarket(checkData)
}

// 现货行情数据
func HbMarketSpots(checkData string) {
	switch checkData {
	case "subscribeDepth": // 市场深度行情数据	8863
		MgoSubscribeDepth()
	case "subscribeLevelMbp": // 市场深度MBP行情数据(增量推送)（150挡）	8864
		MgoSubscribeLevelMbp()
	case "subscribeFullMbp": // 市场深度MBP行情数据(全量推送)	8865
		MgoSubscribeFullMbp()
	case "subscribeSubMbp": // 市场深度MBP行情数据(增量推送) 8866
		MgoSubscribeSubMbp()
	case "subscribeBbo": // 买一卖一逐笔行情	8867
		MgoSubscribeBbo()
	case "subscribeKLine": // K线数据	8868
		MgoSubscribeKLine()
	case "subscribeTrade": // 成交明细	8869
		MgoSubscribeTrade()
	case "subscribeLast24h": // 市场概要	8847
		MgoSubscribeLast24h()
	case "subscribeTicker": // 聚合行情(Ticker)	8848
		MgoSubscribeTicker()
	default:
		applogger.Info("Please select the data source that needs to be connected......")
	}
}

// 合约行情数据
func HbContract(checkData string) {
	switch checkData {
	case "subscribeCtKline": // k线数据	8841
		MgoSubscribeCtKline()
	case "subscribeCtDepth": // 深度信息 8842
		MgoSubscribeCtDepth()
	case "subscribeCtAddDepth": // 新增深度信息	8843
		MgoSubscribeCtAddDepth()
	case "subscribeCtBbo": // 买一卖一行情数据	8844
		MgoSubscribeCtBbo()
	case "subscribeCtDetail": // 合约详情数据	8845
		MgoSubscribeCtDetail()
	case "subscribeCtTradeDetail": // 合约贸易详情数据	8846
		MgoSubscribeCtTradeDetail()
	default:
		applogger.Info("Please select the data source that needs to be connected......")
	}
}

// 股票行情数据
func ShareMarket(checkData string) {
	switch checkData {
	case "usShare": // US 8849
		ShareUsData()
	default:
		applogger.Info("Please select the data source that needs to be connected......")
	}
}