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.
79 lines
2.3 KiB
79 lines
2.3 KiB
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)
|
|
}
|
|
}
|
|
|