wss-pool/cmd/servicemanager/shareWss.go

package servicemanager

import (
	"fmt"
	"github.com/gin-gonic/gin"
	"wss-pool/cmd/common"
	"wss-pool/cmd/marketwsscliert"
	"wss-pool/config"
	"wss-pool/internal/data"
	red "wss-pool/internal/redis"
	"wss-pool/logging/applogger"
)

// GatherUS
//
//	@Description: 美股采集
//	@param checkStr
//	@param ipServer
//	@param addrServer
func GatherUS(checkStr, ipServer, addrServer string) {
	// 初始化相同项目mongodb和redis的ip对应关系
	//data.MgoDbToRedisMap = common.GetMgoDbToRedisMap(config.Config.Mongodb.RedisToMongodb)
	// 初始化所有项目MongoDB
	//data.Mgo_initMap(config.Config.Mongodb, common.GetMongodbAddrList(config.Config.Mongodb.AddrList))
	// 初始化所有项目Redis
	red.RedisInitMapList(common.GetRedisAddrList(config.Config.Redis.AddrList))

	// Enable collaborative data collection
	go marketwsscliert.ShareMarketBak(checkStr)

	// Register Route
	router := gin.Default()
	addr := fmt.Sprintf("%v%v", ipServer, addrServer)
	applogger.Info("intService---addr:%v", addr)

	// Start Service
	if err := router.Run(addr); err != nil {
		applogger.Error("Failed to start Gin data collection service：%v", err)
	}
}

// GatherForex
//
//	@Description: 外汇采集
//	@param checkStr
//	@param ipServer
//	@param addrServer
func GatherForex(checkStr, ipServer, addrServer string) {
	data.Mgo_init(config.Config.Mongodb)
	// init Redis
	red.RedisInitMapList(common.GetRedisAddrList(config.Config.Redis.AddrList))

	// 外汇插针配置加载
	go marketwsscliert.GetModifyForex()
	// 外汇实时报价
	go marketwsscliert.ForexMarketBak(checkStr)
	// 外汇实时天报价
	go marketwsscliert.ForexMarketDayBak(checkStr)
	// 外汇买一卖一报价
	go marketwsscliert.ForexMarketQuoteBak(checkStr)
	// 外汇成交报价
	go marketwsscliert.ForexMarketTradeBak(checkStr)
	// 外汇成交报价存储
	go marketwsscliert.ForexMarketTradeBak2(checkStr)
	// 外汇成交报价清理
	go marketwsscliert.ForexMarketClearTradeBak2(checkStr)
	// 外汇交易对每天0点0分0秒更新数据
	go marketwsscliert.ForexUpdateClosePrice()

	// Register Route
	router := gin.Default()
	addr := fmt.Sprintf("%v%v", ipServer, addrServer)
	applogger.Info("intService---addr:%v", addr)

	// Start Service
	if err := router.Run(addr); err != nil {
		applogger.Error("Failed to start Gin data collection service：%v", err)
	}
}