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.
658 lines
22 KiB
658 lines
22 KiB
2 months ago
|
package processor
|
||
|
|
|
||
|
|
import (
|
||
|
|
"encoding/json"
|
||
|
|
"fmt"
|
||
|
|
"github.com/gin-gonic/gin"
|
||
|
|
"github.com/gorilla/websocket"
|
||
|
|
"go.mongodb.org/mongo-driver/bson"
|
||
|
|
"net/http"
|
||
|
|
"reflect"
|
||
|
|
"strings"
|
||
|
|
"time"
|
||
|
|
"wss-pool/cmd/common"
|
||
|
|
"wss-pool/cmd/websocketservice"
|
||
|
|
"wss-pool/internal"
|
||
|
|
"wss-pool/internal/data"
|
||
|
|
red "wss-pool/internal/redis"
|
||
|
|
"wss-pool/pkg/model/stock"
|
||
|
|
)
|
||
|
|
|
||
|
|
const (
|
||
|
|
KlinePageSize = 100
|
||
|
|
SpotsStatus int = 1
|
||
|
|
ContractStatus int = 2
|
||
|
|
)
|
||
|
|
|
||
|
|
// 现货历史记录
|
||
|
|
// contract_code 合约代码 或 合约标识
|
||
|
|
// period K线类型 "1min", "5min", "15min", "30min", "60min", "4hour", "1day", "1mon", "1week", "1year"
|
||
|
|
// size 获取数量，默认150 [1,2000]
|
||
|
|
// from 开始时间戳 10位 单位S
|
||
|
|
// to 结束时间戳 10位 单位S
|
||
|
|
func SpotKLineList(c *gin.Context) {
|
||
|
|
symbol := internal.ReplaceStr(c.Query("symbol")) // 币种
|
||
|
|
period := internal.ReplaceStr(c.Query("period")) // 时间颗粒度
|
||
|
|
size := internal.IntegerInit(internal.ReplaceStr(c.Query("size")))
|
||
|
|
from := internal.IntegerInit(internal.ReplaceStr(c.Query("from"))) // 开始时间
|
||
|
|
to := internal.IntegerInit(internal.ReplaceStr(c.Query("to"))) // 结束时间
|
||
|
|
if symbol == "" {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, "symbol error", internal.QueryError))
|
||
|
|
return
|
||
|
|
} else if period == "" {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, "period error", internal.QueryError))
|
||
|
|
return
|
||
|
|
}
|
||
|
|
filter := bson.M{"channel": fmt.Sprintf("market.%susdt.kline.%s", symbol, period), "code": bson.M{"$gte": from, "$lte": to}}
|
||
|
|
if size > 0 {
|
||
|
|
filter = bson.M{"channel": fmt.Sprintf("market.%susdt.kline.%s", symbol, period)}
|
||
|
|
}
|
||
|
|
tableName := data.GetStockKLineTableName(period)
|
||
|
|
//applogger.Debug("查询数据总数: %v", total)
|
||
|
|
pagedData, err := data.MgoLimitFind(tableName, filter, int64(size))
|
||
|
|
if err != nil {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, err, internal.QueryError))
|
||
|
|
return
|
||
|
|
}
|
||
|
|
var md stock.MgoPageSize
|
||
|
|
md.Data = removeDuplicates(pagedData)
|
||
|
|
md.Data = common.MarshalToJsonWithGzip(md.Data)
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusOK, md, internal.QuerySuccess))
|
||
|
|
}
|
||
|
|
|
||
|
|
func removeDuplicates(pagedData []data.MongoTick) []data.MongoTick {
|
||
|
|
result := make([]data.MongoTick, 0)
|
||
|
|
keys := make([]int64, 0)
|
||
|
|
resMap := make(map[int64]data.MongoTick)
|
||
|
|
for _, doc := range pagedData {
|
||
|
|
resMap[doc.Code] = doc
|
||
|
|
keys = append(keys, doc.Code)
|
||
|
|
}
|
||
|
|
for _, v := range keys {
|
||
|
|
result = append(result, resMap[v])
|
||
|
|
}
|
||
|
|
return result
|
||
|
|
}
|
||
|
|
|
||
|
|
// 合约价格历史记录
|
||
|
|
func ContractPriceKLineList(c *gin.Context) {
|
||
|
|
contractCode := strings.ToUpper(internal.ReplaceStr(c.Query("symbol"))) // 合约
|
||
|
|
from := internal.IntegerInit(internal.ReplaceStr(c.Query("from"))) // 开始时间
|
||
|
|
to := internal.IntegerInit(internal.ReplaceStr(c.Query("to"))) // 结束时间
|
||
|
|
period := internal.ReplaceStr(c.Query("period")) // 时间颗粒度
|
||
|
|
size := internal.IntegerInit(internal.ReplaceStr(c.Query("size"))) // 结束时间
|
||
|
|
if contractCode == "" {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, "symbol error", internal.QueryError))
|
||
|
|
return
|
||
|
|
} else if period == "" {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, "period error", internal.QueryError))
|
||
|
|
return
|
||
|
|
}
|
||
|
|
//bodyStr, err := internal.HttpGet(fmt.Sprintf("https://api.hbdm.com/index/market/history/linear_swap_mark_price_kline?contract_code=%s&period=%s", contractCode, period))
|
||
|
|
//if err != nil {
|
||
|
|
// c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, err, internal.QueryError))
|
||
|
|
// return
|
||
|
|
//}
|
||
|
|
//result := business.SpotKlineRes{}
|
||
|
|
//if err = json.Unmarshal([]byte(bodyStr), &result); err != nil {
|
||
|
|
// applogger.Error("Unmarshal err: %v---%v", err)
|
||
|
|
//}
|
||
|
|
//var md stock.MgoPageSize
|
||
|
|
//md.Data = result
|
||
|
|
//c.JSON(http.StatusOK, internal.GinResult(http.StatusOK, md, internal.QuerySuccess))
|
||
|
|
|
||
|
|
//else if from == 0 {
|
||
|
|
// c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, "from error", internal.QueryError))
|
||
|
|
// return
|
||
|
|
//} else if to == 0 {
|
||
|
|
// c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, "to error", internal.QueryError))
|
||
|
|
// return
|
||
|
|
//}
|
||
|
|
|
||
|
|
filter := bson.M{"channel": fmt.Sprintf("market.%s-USDT.mark_price.%s", contractCode, period), "code": bson.M{"$gte": from, "$lte": to}}
|
||
|
|
if size > 0 {
|
||
|
|
filter = bson.M{"channel": fmt.Sprintf("market.%s-USDT.mark_price.%s", contractCode, period)}
|
||
|
|
}
|
||
|
|
tableName := data.GetContractPriceKLineTableName(period)
|
||
|
|
//applogger.Debug("查询数据总数: %v", total)
|
||
|
|
pagedData, err := data.MgoLimitFind(tableName, filter, int64(size))
|
||
|
|
if err != nil {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, err, internal.QueryError))
|
||
|
|
return
|
||
|
|
}
|
||
|
|
var md stock.MgoPageSize
|
||
|
|
md.Data = removeDuplicates(pagedData)
|
||
|
|
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusOK, md, internal.QuerySuccess))
|
||
|
|
}
|
||
|
|
|
||
|
|
// 合约历史记录
|
||
|
|
func ContractKLineList(c *gin.Context) {
|
||
|
|
contractCode := strings.ToUpper(internal.ReplaceStr(c.Query("symbol"))) // 合约
|
||
|
|
from := internal.IntegerInit(internal.ReplaceStr(c.Query("from"))) // 开始时间
|
||
|
|
to := internal.IntegerInit(internal.ReplaceStr(c.Query("to"))) // 结束时间
|
||
|
|
period := internal.ReplaceStr(c.Query("period")) // 时间颗粒度
|
||
|
|
size := internal.IntegerInit(internal.ReplaceStr(c.Query("size"))) // 结束时间
|
||
|
|
if contractCode == "" {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, "symbol error", internal.QueryError))
|
||
|
|
return
|
||
|
|
} else if period == "" {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, "period error", internal.QueryError))
|
||
|
|
return
|
||
|
|
}
|
||
|
|
//url := fmt.Sprintf("https://api.hbdm.com/linear-swap-ex/market/history/kline?contract_code=%s&period=%s&from=%d&to=%d", contractCode, period, from, to)
|
||
|
|
//if size > 0 {
|
||
|
|
// url = fmt.Sprintf("https://api.hbdm.com/linear-swap-ex/market/history/kline?contract_code=%s&period=%s&size=%d", contractCode, period, size)
|
||
|
|
//}
|
||
|
|
//bodyStr, err := internal.HttpGet(url)
|
||
|
|
//if err != nil {
|
||
|
|
// c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, err, internal.QueryError))
|
||
|
|
// return
|
||
|
|
//}
|
||
|
|
//result := business.ContractKlineRes{}
|
||
|
|
//if err = json.Unmarshal([]byte(bodyStr), &result); err != nil {
|
||
|
|
// applogger.Error("Unmarshal err: %v---%v", err)
|
||
|
|
//}
|
||
|
|
//var md stock.MgoPageSize
|
||
|
|
//md.Data = result
|
||
|
|
//c.JSON(http.StatusOK, internal.GinResult(http.StatusOK, md, internal.QuerySuccess))
|
||
|
|
filter := bson.M{"channel": fmt.Sprintf("market.%s-USDT.kline.%s", contractCode, period), "code": bson.M{"$gte": from, "$lte": to}}
|
||
|
|
if size > 0 {
|
||
|
|
filter = bson.M{"channel": fmt.Sprintf("market.%s-USDT.kline.%s", contractCode, period)}
|
||
|
|
}
|
||
|
|
tableName := data.GetContractKLineTableName(period)
|
||
|
|
|
||
|
|
pagedData, err := data.MgoLimitFind(tableName, filter, int64(size))
|
||
|
|
if err != nil {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, err, internal.QueryError))
|
||
|
|
return
|
||
|
|
}
|
||
|
|
var md stock.MgoPageSize
|
||
|
|
md.Data = removeDuplicates(pagedData)
|
||
|
|
md.Data = common.MarshalToJsonWithGzip(md.Data)
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusOK, md, internal.QuerySuccess))
|
||
|
|
}
|
||
|
|
|
||
|
|
// 查询价格
|
||
|
|
func InquiryPrice(c *gin.Context) {
|
||
|
|
contractCode := internal.ReplaceStr(c.Query("symbol"))
|
||
|
|
timeStr := c.Query("time") // 结束时间
|
||
|
|
if contractCode == "" {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, "symbol error", internal.QueryError))
|
||
|
|
return
|
||
|
|
} else if timeStr == "" {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, "timeStr error", internal.QueryError))
|
||
|
|
return
|
||
|
|
}
|
||
|
|
timestamp, err := common.TimeStrToTimestamp(timeStr)
|
||
|
|
fmt.Println(timestamp)
|
||
|
|
if err != nil {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, err.Error(), internal.QueryError))
|
||
|
|
return
|
||
|
|
}
|
||
|
|
ok := strings.Contains(contractCode, "-USDT")
|
||
|
|
filter := bson.M{"channel": fmt.Sprintf("market.%s.kline.1min", contractCode), "code": timestamp}
|
||
|
|
tableName := data.GetContractKLineTableName("1min")
|
||
|
|
if !ok {
|
||
|
|
tableName = data.GetStockKLineTableName("1min")
|
||
|
|
}
|
||
|
|
pagedData, err := data.MgoLimitFind(tableName, filter, int64(0))
|
||
|
|
if err != nil {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, err, internal.QueryError))
|
||
|
|
return
|
||
|
|
}
|
||
|
|
var md stock.MgoPageSize
|
||
|
|
md.Data = removeDuplicates(pagedData)
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusOK, md, internal.QuerySuccess))
|
||
|
|
}
|
||
|
|
|
||
|
|
// 美股查询记录
|
||
|
|
func HistoryUsList(c *gin.Context) {
|
||
|
|
code := strings.ToUpper(internal.ReplaceStr(c.Query("code"))) // 股票代码
|
||
|
|
pageSize := internal.IntegerInit(internal.ReplaceStr(c.Query("pageSize"))) // 每页显示多少条数据
|
||
|
|
pageNumber := internal.IntegerInit(internal.ReplaceStr(c.Query("pageNumber"))) // 第几页
|
||
|
|
period := internal.ReplaceStr(c.Query("period")) // 时间颗粒度
|
||
|
|
from := internal.IntegerInit(internal.ReplaceStr(c.Query("from"))) // 开始时间
|
||
|
|
if pageNumber <= 0 {
|
||
|
|
pageNumber = 1
|
||
|
|
}
|
||
|
|
if pageSize <= 0 {
|
||
|
|
pageSize = KlinePageSize
|
||
|
|
}
|
||
|
|
if code == "" {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, "code error", internal.QueryError))
|
||
|
|
return
|
||
|
|
} else if period == "" {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, "period error", internal.QueryError))
|
||
|
|
return
|
||
|
|
}
|
||
|
|
if from == 0 {
|
||
|
|
from = int(time.Now().Unix())
|
||
|
|
}
|
||
|
|
filter := bson.M{"code": code, "timestamp": bson.M{"$lte": from}}
|
||
|
|
tableName := data.GetStockUsTableName(period)
|
||
|
|
total, err := data.MgoFindTotal(tableName, filter)
|
||
|
|
if err != nil {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, err, internal.QueryError))
|
||
|
|
return
|
||
|
|
}
|
||
|
|
//applogger.Debug("查询数据总数: %v", total)
|
||
|
|
pagedData, err := data.MgoPagingFind(tableName, filter, int64(pageSize), int64(pageNumber), -1)
|
||
|
|
if err != nil {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, err, internal.QueryError))
|
||
|
|
return
|
||
|
|
}
|
||
|
|
var md stock.MgoPageSize
|
||
|
|
md.Data = pagedData
|
||
|
|
md.PageSize = pageSize
|
||
|
|
md.PageNumber = pageNumber
|
||
|
|
md.Total = total
|
||
|
|
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusOK, md, internal.QuerySuccess))
|
||
|
|
}
|
||
|
|
|
||
|
|
func removeWsconn(conn interface{}, userConn *websocket.Conn, symbol string) error {
|
||
|
|
connRes := make([]*websocket.Conn, 0)
|
||
|
|
value := reflect.ValueOf(conn)
|
||
|
|
if value.Kind() != reflect.Slice && value.Kind() != reflect.Array {
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
for i := 0; i < value.Len(); i++ {
|
||
|
|
val := value.Index(i).Interface().(*websocket.Conn)
|
||
|
|
if val != userConn {
|
||
|
|
connRes = append(connRes, val)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
// 现货|合约|秒合约列表查询
|
||
|
|
func MainSpotList(c *gin.Context) {
|
||
|
|
market_type := internal.IntegerInit(internal.ReplaceStr(c.Query("marketType")))
|
||
|
|
if market_type == 0 {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, "marketType error", internal.QueryError))
|
||
|
|
return
|
||
|
|
}
|
||
|
|
result := make([]interface{}, 0)
|
||
|
|
var md stock.MgoPageSize
|
||
|
|
resMap := make(map[string]interface{})
|
||
|
|
if market_type == SpotsStatus {
|
||
|
|
// spot := websocketservice.HashValue(websocketservice.RedisDIGITAL)
|
||
|
|
websocketservice.SpotMarketCache.Range(
|
||
|
|
func(key, value any) bool {
|
||
|
|
//for _, val := range spot {
|
||
|
|
//if strings.Contains(key.(string), fmt.Sprintf("%susdt", strings.ToLower(val.Name))) && value != nil {
|
||
|
|
resMap[key.(string)] = value
|
||
|
|
//}
|
||
|
|
return true
|
||
|
|
})
|
||
|
|
if _, ok := resMap["btc"]; ok {
|
||
|
|
result = append(result, resMap["btc"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["eth"]; ok {
|
||
|
|
result = append(result, resMap["eth"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["bnb"]; ok {
|
||
|
|
result = append(result, resMap["bnb"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["usdc"]; ok {
|
||
|
|
result = append(result, resMap["usdc"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["xrp"]; ok {
|
||
|
|
result = append(result, resMap["xrp"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["ada"]; ok {
|
||
|
|
result = append(result, resMap["ada"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["doge"]; ok {
|
||
|
|
result = append(result, resMap["doge"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["sol"]; ok {
|
||
|
|
result = append(result, resMap["sol"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["trx"]; ok {
|
||
|
|
result = append(result, resMap["trx"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["ltc"]; ok {
|
||
|
|
result = append(result, resMap["ltc"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["dot"]; ok {
|
||
|
|
result = append(result, resMap["dot"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["matic"]; ok {
|
||
|
|
result = append(result, resMap["matic"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["bch"]; ok {
|
||
|
|
result = append(result, resMap["bch"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["eos"]; ok {
|
||
|
|
result = append(result, resMap["eos"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["ton"]; ok {
|
||
|
|
result = append(result, resMap["ton"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["avax"]; ok {
|
||
|
|
result = append(result, resMap["avax"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["shib"]; ok {
|
||
|
|
result = append(result, resMap["shib"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["invu"]; ok {
|
||
|
|
result = append(result, resMap["invu"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["osel"]; ok {
|
||
|
|
result = append(result, resMap["osel"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["fmd"]; ok {
|
||
|
|
result = append(result, resMap["fmd"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["dten"]; ok {
|
||
|
|
result = append(result, resMap["dten"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["xnsl"]; ok {
|
||
|
|
result = append(result, resMap["xnsl"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["kools"]; ok {
|
||
|
|
result = append(result, resMap["kools"])
|
||
|
|
}
|
||
|
|
md.Data = result
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusOK, md, internal.QuerySuccess))
|
||
|
|
return
|
||
|
|
}
|
||
|
|
// contract := websocketservice.HashValue(websocketservice.RedisCONTRACT)
|
||
|
|
websocketservice.ContractCache.Range(
|
||
|
|
func(key, value any) bool {
|
||
|
|
//for _, val := range contract {
|
||
|
|
// if strings.Contains(key.(string), val.Name) && value != nil {
|
||
|
|
resMap[key.(string)] = value
|
||
|
|
// }
|
||
|
|
// }
|
||
|
|
return true
|
||
|
|
})
|
||
|
|
|
||
|
|
if _, ok := resMap["BTC-USDT"]; ok {
|
||
|
|
result = append(result, resMap["BTC-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["ETH-USDT"]; ok {
|
||
|
|
result = append(result, resMap["ETH-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["BCH-USDT"]; ok {
|
||
|
|
result = append(result, resMap["BCH-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["XRP-USDT"]; ok {
|
||
|
|
result = append(result, resMap["XRP-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["EOS-USDT"]; ok {
|
||
|
|
result = append(result, resMap["EOS-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["LTC-USDT"]; ok {
|
||
|
|
result = append(result, resMap["LTC-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["TRX-USDT"]; ok {
|
||
|
|
result = append(result, resMap["TRX-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["ETC-USDT"]; ok {
|
||
|
|
result = append(result, resMap["ETC-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["LINK-USDT"]; ok {
|
||
|
|
result = append(result, resMap["LINK-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["BNB-USDT"]; ok {
|
||
|
|
result = append(result, resMap["BNB-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["ADA-USDT"]; ok {
|
||
|
|
result = append(result, resMap["ADA-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["DOGE-USDT"]; ok {
|
||
|
|
result = append(result, resMap["DOGE-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["SOL-USDT"]; ok {
|
||
|
|
result = append(result, resMap["SOL-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["DOT-USDT"]; ok {
|
||
|
|
result = append(result, resMap["DOT-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["MATIC-USDT"]; ok {
|
||
|
|
result = append(result, resMap["MATIC-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["AVAX-USDT"]; ok {
|
||
|
|
result = append(result, resMap["AVAX-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["SHIB-USDT"]; ok {
|
||
|
|
result = append(result, resMap["SHIB-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["BNBS-USDT"]; ok {
|
||
|
|
result = append(result, resMap["BNBS-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["INVU-USDT"]; ok {
|
||
|
|
result = append(result, resMap["INVU-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["OSEL-USDT"]; ok {
|
||
|
|
result = append(result, resMap["OSEL-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["FMD-USDT"]; ok {
|
||
|
|
result = append(result, resMap["FMD-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["DTEN-USDT"]; ok {
|
||
|
|
result = append(result, resMap["DTEN-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["XNSL-USDT"]; ok {
|
||
|
|
result = append(result, resMap["XNSL-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["KOOLS-USDT"]; ok {
|
||
|
|
result = append(result, resMap["KOOLS-USDT"])
|
||
|
|
}
|
||
|
|
md.Data = result
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusOK, md, internal.QuerySuccess))
|
||
|
|
}
|
||
|
|
|
||
|
|
// 现货|合约|秒合约|自选列表查询
|
||
|
|
func MainFreeSpotList(c *gin.Context) {
|
||
|
|
id := internal.ReplaceStr(c.Query("id"))
|
||
|
|
market_type := internal.IntegerInit(internal.ReplaceStr(c.Query("marketType")))
|
||
|
|
if market_type == 0 || len(id) == 0 {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, "marketType or userId error", internal.QueryError))
|
||
|
|
return
|
||
|
|
}
|
||
|
|
var md stock.MgoPageSize
|
||
|
|
result := make([]interface{}, 0)
|
||
|
|
md.Data = result
|
||
|
|
userIdKey := fmt.Sprintf("%v%v", FreeSymbolKey, id)
|
||
|
|
resultStr, err := red.Get_Cache_Byte(userIdKey)
|
||
|
|
if err != nil {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusOK, md, internal.QueryError))
|
||
|
|
return
|
||
|
|
}
|
||
|
|
var freeList []StockSymbol
|
||
|
|
if err = json.Unmarshal(resultStr, &freeList); err != nil {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusOK, md, internal.QueryError))
|
||
|
|
return
|
||
|
|
}
|
||
|
|
// 组合需要查询自选缓存股票code
|
||
|
|
var symbolList []string
|
||
|
|
for _, value := range freeList {
|
||
|
|
if market_type == value.MarketType {
|
||
|
|
symbolList = append(symbolList, value.Code)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
resMap := make(map[string]interface{})
|
||
|
|
switch market_type {
|
||
|
|
case SpotsStatus:
|
||
|
|
websocketservice.SpotMarketCache.Range(func(key, value any) bool {
|
||
|
|
for _, vue := range symbolList {
|
||
|
|
if vue == key.(string) {
|
||
|
|
resMap[vue] = value
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return true
|
||
|
|
})
|
||
|
|
if _, ok := resMap["btc"]; ok {
|
||
|
|
result = append(result, resMap["btc"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["eth"]; ok {
|
||
|
|
result = append(result, resMap["eth"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["bnb"]; ok {
|
||
|
|
result = append(result, resMap["bnb"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["usdc"]; ok {
|
||
|
|
result = append(result, resMap["usdc"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["xrp"]; ok {
|
||
|
|
result = append(result, resMap["xrp"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["ada"]; ok {
|
||
|
|
result = append(result, resMap["ada"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["doge"]; ok {
|
||
|
|
result = append(result, resMap["doge"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["sol"]; ok {
|
||
|
|
result = append(result, resMap["sol"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["trx"]; ok {
|
||
|
|
result = append(result, resMap["trx"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["ltc"]; ok {
|
||
|
|
result = append(result, resMap["ltc"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["dot"]; ok {
|
||
|
|
result = append(result, resMap["dot"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["matic"]; ok {
|
||
|
|
result = append(result, resMap["matic"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["bch"]; ok {
|
||
|
|
result = append(result, resMap["bch"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["eos"]; ok {
|
||
|
|
result = append(result, resMap["eos"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["ton"]; ok {
|
||
|
|
result = append(result, resMap["ton"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["avax"]; ok {
|
||
|
|
result = append(result, resMap["avax"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["shib"]; ok {
|
||
|
|
result = append(result, resMap["shib"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["invu"]; ok {
|
||
|
|
result = append(result, resMap["invu"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["osel"]; ok {
|
||
|
|
result = append(result, resMap["osel"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["fmd"]; ok {
|
||
|
|
result = append(result, resMap["fmd"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["dten"]; ok {
|
||
|
|
result = append(result, resMap["dten"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["xnsl"]; ok {
|
||
|
|
result = append(result, resMap["xnsl"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["kools"]; ok {
|
||
|
|
result = append(result, resMap["kools"])
|
||
|
|
}
|
||
|
|
md.Data = result
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusOK, md, internal.QuerySuccess))
|
||
|
|
default:
|
||
|
|
websocketservice.ContractCache.Range(
|
||
|
|
func(key, value any) bool {
|
||
|
|
for _, vue := range symbolList {
|
||
|
|
if vue == key.(string) {
|
||
|
|
resMap[vue] = value
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return true
|
||
|
|
})
|
||
|
|
if _, ok := resMap["BTC-USDT"]; ok {
|
||
|
|
result = append(result, resMap["BTC-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["ETH-USDT"]; ok {
|
||
|
|
result = append(result, resMap["ETH-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["BCH-USDT"]; ok {
|
||
|
|
result = append(result, resMap["BCH-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["XRP-USDT"]; ok {
|
||
|
|
result = append(result, resMap["XRP-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["EOS-USDT"]; ok {
|
||
|
|
result = append(result, resMap["EOS-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["LTC-USDT"]; ok {
|
||
|
|
result = append(result, resMap["LTC-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["TRX-USDT"]; ok {
|
||
|
|
result = append(result, resMap["TRX-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["ETC-USDT"]; ok {
|
||
|
|
result = append(result, resMap["ETC-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["LINK-USDT"]; ok {
|
||
|
|
result = append(result, resMap["LINK-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["BNB-USDT"]; ok {
|
||
|
|
result = append(result, resMap["BNB-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["ADA-USDT"]; ok {
|
||
|
|
result = append(result, resMap["ADA-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["DOGE-USDT"]; ok {
|
||
|
|
result = append(result, resMap["DOGE-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["SOL-USDT"]; ok {
|
||
|
|
result = append(result, resMap["SOL-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["DOT-USDT"]; ok {
|
||
|
|
result = append(result, resMap["DOT-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["MATIC-USDT"]; ok {
|
||
|
|
result = append(result, resMap["MATIC-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["AVAX-USDT"]; ok {
|
||
|
|
result = append(result, resMap["AVAX-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["SHIB-USDT"]; ok {
|
||
|
|
result = append(result, resMap["SHIB-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["BNBS-USDT"]; ok {
|
||
|
|
result = append(result, resMap["BNBS-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["INVU-USDT"]; ok {
|
||
|
|
result = append(result, resMap["INVU-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["OSEL-USDT"]; ok {
|
||
|
|
result = append(result, resMap["OSEL-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["FMD-USDT"]; ok {
|
||
|
|
result = append(result, resMap["FMD-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["DTEN-USDT"]; ok {
|
||
|
|
result = append(result, resMap["DTEN-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["XNSL-USDT"]; ok {
|
||
|
|
result = append(result, resMap["XNSL-USDT"])
|
||
|
|
}
|
||
|
|
if _, ok := resMap["KOOLS-USDT"]; ok {
|
||
|
|
result = append(result, resMap["KOOLS-USDT"])
|
||
|
|
}
|
||
|
|
md.Data = result
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusOK, md, internal.QuerySuccess))
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
func IntroList(c *gin.Context) {
|
||
|
|
symbol := strings.ToUpper(internal.ReplaceStr(c.Query("symbol"))) // 交易对
|
||
|
|
if symbol == "" {
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusBadRequest, "symbol error", internal.QueryError))
|
||
|
|
return
|
||
|
|
}
|
||
|
|
var md stock.MgoPageSize
|
||
|
|
md.Data = Intro[symbol]
|
||
|
|
c.JSON(http.StatusOK, internal.GinResult(http.StatusOK, md, internal.QuerySuccess))
|
||
|
|
}
|