matchmaking-system/internal/data/control_share.go

package data

import (
	"context"
)

// InitStockUs
//
//	@Description: 美股交易
//	@param data
func InitStockUs(data *Data) {
	go InitCacheSymbolShareUs(context.Background(), data) // 初始化-美股股票代码
	go InitSubscribeShareUs(shareUs, false)               // 检查交易订单订阅标识状态机
	go ShareUsTransactionEntrust(context.Background())    // 监控美股挂单信息缓存队列
	go ShareUsTransactionPosition(context.Background())   // 监控美股持仓信息缓存队列
	go InitShareUsCloseCachePrice(false)                  // 同步闭盘价
	go InitShareUsCloseNewPrice(false)                    // 同步实时行情
	go InitShareUsPriceSetUp(false)                       // 同步插针行情
}

// InitStockMys
//
//	@Description: 马股交易
//	@param data
func InitStockMys(data *Data) {
	go InitCacheSymbolShareMys(context.Background(), data) // 初始化-马股股票代码
	go InitSubscribeShareMys(shareMys, false)              // 检查交易订单订阅标识状态机
	go ShareMysTransactionEntrust(context.Background())    // 监控马股挂单信息缓存队列
	go ShareMysTransactionPosition(context.Background())   // 监控马股持仓信息缓存队列
	go InitShareMysCloseCachePrice(false)                  // 同步闭盘价
	go InitShareMysCloseNewPrice(false)                    // 同步实时行情
	go InitShareMysPriceSetUp(false)                       // 同步插针行情
}

// InitStockTha
//
//	@Description: 泰股交易
//	@param data
func InitStockTha(data *Data) {
	go InitCacheSymbolShareTha(context.Background(), data) // 初始化-泰股股票代码
	go InitSubscribeShareTha(shareTha, false)              // 检查交易订单订阅标识状态机
	go ShareThaTransactionEntrust(context.Background())    // 监控泰股挂单信息缓存队列
	go ShareThaTransactionPosition(context.Background())   // 监控泰股持仓信息缓存队列
	go InitShareThaCloseCachePrice(false)                  // 同步闭盘价
	go InitShareThaCloseNewPrice(false)                    // 同步实时行情
	go InitShareThaPriceSetUp(false)                       // 同步插针行情
}

// InitStockIdn
//
//	@Description: 印尼股交易
//	@param data
func InitStockIdn(data *Data) {
	go InitCacheSymbolShareIdn(context.Background(), data) // 初始化-印尼股票代码
	go InitSubscribeShareIdn(shareIdn, false)              // 检查交易订单订阅标识状态机
	go ShareIdnTransactionEntrust(context.Background())    // 监控印尼股挂单信息缓存队列
	go ShareIdnTransactionPosition(context.Background())   // 监控印尼股持仓信息缓存队列
	go InitShareIdnCloseCachePrice(false)                  // 同步闭盘价
	go InitShareIdnCloseNewPrice(false)                    // 同步实时行情
	go InitShareIdnPriceSetUp(false)                       // 同步插针行情
}

// InitStockInr
//
//	@Description: 印度股交易
//	@param data
func InitStockInr(data *Data) {
	go InitCacheSymbolShareInr(context.Background(), data) // 初始化-印度股票代码
	go InitSubscribeShareInr(shareInr, false)              // 检查交易订单订阅标识状态机
	go ShareInrTransactionEntrust(context.Background())    // 监控印股挂单信息缓存队列
	go ShareInrTransactionPosition(context.Background())   // 监控印度股持仓信息缓存队列
	go InitShareInrCloseCachePrice(false)                  // 同步闭盘价
	go InitShareInrCloseNewPrice(false)                    // 同步实时行情
	go InitShareInrPriceSetUp(false)                       // 同步插针行情
}

// InitStockSgd
//
//	@Description: 新加坡股交易
//	@param data
func InitStockSgd(data *Data) {
	go InitCacheSymbolShareSgd(context.Background(), data) // 初始化-新加坡股票代码
	go InitSubscribeShareSgd(shareSgd, false)              // 检查交易订单订阅标识状态机
	go ShareSgdTransactionEntrust(context.Background())    // 监控新加坡股挂单信息缓存队列
	go ShareSgdTransactionPosition(context.Background())   // 监控新加坡股持仓信息缓存队列
	go InitShareSgdCloseCachePrice(false)                  // 同步闭盘价
	go InitShareSgdCloseNewPrice(false)                    // 同步实时行情
	go InitShareSgdPriceSetUp(false)                       // 同步插针行情
}

// InitStockEur
//
//	@Description: 德股交易
//	@param data
func InitStockEur(data *Data) {
	go InitCacheSymbolShareEur(context.Background(), data) // 初始化-德股票代码
	go InitSubscribeShareEur(shareEur, false)              // 检查交易订单订阅标识状态机
	go ShareEurTransactionEntrust(context.Background())    // 监控德股挂单信息缓存队列
	go ShareEurTransactionPosition(context.Background())   // 监控德股持仓信息缓存队列
	go InitShareEurCloseCachePrice(false)                  // 同步闭盘价
	go InitShareEurCloseNewPrice(false)                    // 同步实时行情
	go InitShareEurPriceSetUp(false)                       // 同步插针行情
}

// InitStockFur
//
//	@Description: 法股交易
//	@param data
func InitStockFur(data *Data) {
	go InitCacheSymbolShareFur(context.Background(), data) // 初始化-法股票代码
	go InitSubscribeShareFur(shareFur, false)              // 检查交易订单订阅标识状态机
	go ShareFurTransactionEntrust(context.Background())    // 监控法股挂单信息缓存队列
	go ShareFurTransactionPosition(context.Background())   // 监控法股持仓信息缓存队列
	go InitShareFurCloseCachePrice(false)                  // 同步闭盘价
	go InitShareFurCloseNewPrice(false)                    // 同步实时行情
	go InitShareFurPriceSetUp(false)                       // 同步插针行情
}

// InitStockJpy
//
//	@Description: 日股交易
//	@param data
func InitStockJpy(data *Data) {
	go InitCacheSymbolShareJpy(context.Background(), data) // 初始化-日股票代码
	go InitSubscribeShareJpy(shareJpy, false)              // 检查交易订单订阅标识状态机
	go ShareJpyTransactionEntrust(context.Background())    // 监控日股挂单信息缓存队列
	go ShareJpyTransactionPosition(context.Background())   // 监控日股持仓信息缓存队列
	go InitShareJpyCloseCachePrice(false)                  // 同步闭盘价
	go InitShareJpyCloseNewPrice(false)                    // 同步实时行情
	go InitShareJpyPriceSetUp(false)                       // 同步插针行情
}

// InitStockBrl
//
//	@Description: 巴西股交易
//	@param data
func InitStockBrl(data *Data) {
	go InitCacheSymbolShareBrl(context.Background(), data) // 初始化-巴西股票代码
	go InitSubscribeShareBrl(shareBrl, false)              // 检查交易订单订阅标识状态机
	go ShareBrlTransactionEntrust(context.Background())    // 监控巴西股挂单信息缓存队列
	go ShareBrlTransactionPosition(context.Background())   // 监控巴西股持仓信息缓存队列
	go InitShareBrlCloseCachePrice(false)                  // 同步闭盘价
	go InitShareBrlCloseNewPrice(false)                    // 同步实时行情
	go InitShareBrlPriceSetUp(false)                       // 同步插针行情
}

// InitStockHkd
//
//	@Description: 港股交易
//	@param data
func InitStockHkd(data *Data) {
	go InitCacheSymbolShareHkd(context.Background(), data) // 初始化-港股股票代码
	go InitSubscribeShareHkd(shareHkd, false)              // 检查交易订单订阅标识状态机
	go ShareHkdTransactionEntrust(context.Background())    // 监控港股挂单信息缓存队列
	go ShareHkdTransactionPosition(context.Background())   // 监控港度股持仓信息缓存队列
	go InitShareHkdCloseCachePrice(false)                  // 同步闭盘价
	go InitShareHkdCloseNewPrice(false)                    // 同步实时行情
	go InitShareHkdPriceSetUp(false)                       // 同步插针行情
}

// InitStockGbx
//
//	@Description: 英股交易
//	@param data
func InitStockGbx(data *Data) {
	go InitCacheSymbolShareGbx(context.Background(), data) // 初始化-英股票代码
	go InitSubscribeShareGbx(shareGbx, false)              // 检查交易订单订阅标识状态机
	go ShareGbxTransactionEntrust(context.Background())    // 监控英股挂单信息缓存队列
	go ShareGbxTransactionPosition(context.Background())   // 监控英度股持仓信息缓存队列
	go InitShareGbxCloseCachePrice(false)                  // 同步闭盘价
	go InitShareGbxCloseNewPrice(false)                    // 同步实时行情
	go InitShareGbxPriceSetUp(false)                       // 同步插针行情
}

// InitStockBlk
//
//	@Description: 大宗股交易
//	@param data
func InitStockBlk(data *Data) {
	go InitCacheSymbolShareBlk(context.Background(), data)                                                                                       // 初始化-大宗交易股票代码
	SubscribeShareBlk()                                                                                                                          // 大宗(美股|泰股|马股|印尼股|印度股|新加坡股|港股|英股)下单交易对行情订阅
	InitSubscribeShareBlk(shareUs, shareTha, shareMys, shareIdn, shareInr, shareSgd, shareHkd, shareGbx, shareEur, shareFur, shareBrl, shareJpy) // 检查交易订单订阅标识状态机
	ShareBlkTransactionEntrust(context.Background())                                                                                             // 监控大宗(美股|泰股|马股|印尼股|印度股|新加坡股|港股|英股)交易股挂单信息缓存队列
	InitShareBlkCloseCachePrice()                                                                                                                // 监控大宗(美股|泰股|马股|印尼股|印度股|新加坡股|港股|英股)股票代码闭盘价格
	InitShareBlkSetUpPrice()                                                                                                                     // 插针价
}