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() } }