You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
70 lines
2.4 KiB
70 lines
2.4 KiB
package data
|
|
|
|
import (
|
|
"context"
|
|
)
|
|
|
|
// InitSymbol
|
|
//
|
|
// @Description: 初始化数字币交易对(现货|合约|秒合约|外汇)
|
|
// @param data
|
|
func InitSymbol(data *Data) {
|
|
InitCacheSymbolSpots(context.Background(), data) // 初始化-现货交易对
|
|
InitCacheSymbolContract(context.Background(), data) // 初始化-合约(秒合约)交易对
|
|
InitCacheSymbolForex(context.Background(), data) // 初始化-外汇交易对
|
|
}
|
|
|
|
// InitCode
|
|
//
|
|
// @Description: 初始化股票代码(美股|泰股|印尼股|印度股|马股|新加坡|期权-印度|港股)
|
|
// @param data
|
|
func InitCode(data *Data) {
|
|
InitCacheSymbolShareUs(context.Background(), data) // 初始化-美股股票代码
|
|
InitCacheSymbolShareTha(context.Background(), data) // 初始化-泰股股票代码
|
|
InitCacheSymbolShareIdn(context.Background(), data) // 初始化-印尼股票代码
|
|
InitCacheSymbolShareInr(context.Background(), data) // 初始化-印度股票代码
|
|
InitCacheSymbolShareMys(context.Background(), data) // 初始化-马股股票代码
|
|
InitCacheSymbolShareSgd(context.Background(), data) // 初始化-新加坡股票代码
|
|
InitCacheSymbolShareHkd(context.Background(), data) // 初始化-港股股票代码
|
|
InitCacheSymbolOptionInr(context.Background(), data) // 初始化-期权(印度)股票代码
|
|
InitCacheSymbolShareBlk(context.Background(), data) // 初始化-大宗交易股票代码
|
|
}
|
|
|
|
// InitCache
|
|
//
|
|
// @Description: 恢复美股|泰股|马股|印尼股|印度股|新加坡股|港股|期权|大宗交易|订单缓存数据
|
|
// @param data
|
|
func InitCache(data *Data) {
|
|
RestoreCacheShareUs(data)
|
|
RestoreCacheShareEur(data)
|
|
RestoreCacheShareFur(data)
|
|
RestoreCacheShareGbx(data)
|
|
RestoreCacheShareTha(data)
|
|
RestoreCacheShareMys(data)
|
|
RestoreCacheShareIdn(data)
|
|
RestoreCacheShareInr(data)
|
|
RestoreCacheShareSgd(data)
|
|
RestoreCacheShareHkd(data)
|
|
}
|
|
|
|
// InitClearCacheOrder
|
|
//
|
|
// @Description: 通过市场订单表清理订单垃圾缓存数据
|
|
// @param data
|
|
func InitClearCacheOrder(data *Data) {
|
|
RestoreClearCacheShareUs(data)
|
|
RestoreClearCacheShareTha(data)
|
|
RestoreClearCacheShareMys(data)
|
|
RestoreClearCacheShareIdn(data)
|
|
RestoreClearCacheShareInr(data)
|
|
RestoreClearCacheShareSgd(data)
|
|
RestoreClearCacheShareHkd(data)
|
|
}
|
|
|
|
// InitIpoRedisCacheOrder
|
|
//
|
|
// @Description: 恢复IPO-OrderNo匹配OrderId
|
|
// @param data
|
|
func InitIpoRedisCacheOrder(data *Data) {
|
|
TradeIPoInrByOrderNo(data)
|
|
}
|
|
|