package servicemanager

import (
	"wss-pool/config"
	"wss-pool/internal/data"
	"wss-pool/internal/data/business"
	red "wss-pool/internal/redis"
)

// TickDB
func TickDB(checkStr, ipServer, addrServer, contractCode string) {
	data.Mgo_init(config.Config.Mongodb)
	switch checkStr {
	case "spotKline": // 现货历史数据
		business.TickUpdateSpotKline()
	case "all": // 合约全部历史数据
		business.TickUpdateContractKline(true)
	case "allUs": // 美股全部历史数据
		business.TickUpdateStockUs(true)
	case "Us": // 实时数据
		business.TickUpdateStockUs(false)
	case "previousClose": // TODO: 更新美股上次比盘价
		business.UpdateStockUS()
	case "UsNewPrice":
		business.UsNewPrice(contractCode)
	case "usOpenPrice":
		business.UpdateOpenPrice()
	case "southAsiaStock": // TODO: 自动聚合东南亚国家数据
		red.RedisClient = red.RedisInit(config.Config.Redis.DbTen)
		business.TickSouthAsiaSpotKline(contractCode)
	case "stockIndex": // TODO: 自动聚合指数
		business.TickSpotIndexKline()
	case "deleteSpot": // TODO: 自动数据清理：contractCode(true:清理数据,false:清理并优化多余数据)
		business.DeleteSpot(contractCode)
	case "stockCloseData": // TODO: 自动检测并推送插针数据
		business.StockClosedData()
	case "checkStock": // TODO: 自动机器人行情检查
		business.CheckStock()
	case "updateStockCode": // 更新股票code和交易所
		business.UpdateStockCode()
	case "updateStockUsCode": // 更新美股股票code和交易所
		business.UpdateStockUsCode()
	case "updateStockExchange": // 更新印度股票(Exchange字段)
		business.UpdateStockExchange()
	case "forexClosePrice": // TODO: 更新外汇闭盘价
		business.ForexUpdateCode()
	case "deleteForexTrade": // TODO: 清理外汇成交报价
		business.DeleteForexTrade()
	default:
		//抓取美股
		//business.InitStockList()
		//查询美股交易所
		//business.UpdateStockUSTape()
	}
}