MTP20_IF/controllers/quote/quote.go

package quote

import (
	"fmt"
	"mtp2_if/global/app"
	"mtp2_if/global/e"
	"mtp2_if/logger"
	"mtp2_if/models"
	"mtp2_if/mtpcache"
	"mtp2_if/utils"
	"net/http"
	"strings"
	"time"

	"github.com/gin-gonic/gin"
)

// QueryQuoteDayReq 获取商品盘面信息请求参数
type QueryQuoteDayReq struct {
	GoodsCodes string `form:"goodsCodes" binding:"required"`
}

// QueryQuoteDayRsp 获取商品盘面信息返回模型
type QueryQuoteDayRsp struct {
	Exchangedate         int64     `json:"exchangedate"`         // 交易日
	Goodscode            string    `json:"goodscode"`            // 商品代码
	Exchangecode         int       `json:"exchangecode"`         // 交易所代码
	Preclose             float64   `json:"preclose"`             // 昨收
	Opentime             time.Time `json:"opentime"`             // 开盘时间
	Opened               float64   `json:"opened"`               // 开盘价
	Highest              float64   `json:"highest"`              // 最高价
	Lowest               float64   `json:"lowest"`               // 最低价
	Lasttime             string    `json:"lasttime"`             // 行情时间（只有现价变化行情时间才变化）
	Utclasttime          time.Time `json:"utclasttime"`          // utc的行情时间
	Last                 float64   `json:"last"`                 // 最新价
	Lastvolume           int64     `json:"lastvolume"`           // 最新成交量
	Lastturnover         float64   `json:"lastturnover`          // 最新成交金额
	Totalbidvolume       int64     `json:"totalbidvolume"`       // 外盘
	Totalaskvolume       int64     `json:"totalaskvolume"`       // 内盘
	Totalvolume          int64     `json:"totalvolume"`          // 总量
	Totalturnover        float64   `json:"totalturnover"`        // 总金额
	Bid                  float64   `json:"bid"`                  // 买1
	Bid2                 float64   `json:"bid2"`                 // 买2
	Bid3                 float64   `json:"bid3"`                 // 买3
	Bid4                 float64   `json:"bid4"`                 // 买4
	Bid5                 float64   `json:"bid5"`                 // 买5
	Bidvolume            int64     `json:"bidvolume"`            // 买量1
	Bidvolume2           int64     `json:"bidvolume2"`           // 买量2
	Bidvolume3           int64     `json:"bidvolume3"`           // 买量3
	Bidvolume4           int64     `json:"bidvolume4"`           // 买量4
	Bidvolume5           int64     `json:"bidvolume5"`           // 买量5
	Ask                  float64   `json:"ask"`                  // 卖1
	Ask2                 float64   `json:"ask2"`                 // 卖2
	Ask3                 float64   `json:"ask3"`                 // 卖3
	Ask4                 float64   `json:"ask4"`                 // 卖4
	Ask5                 float64   `json:"ask5"`                 // 卖5
	Askvolume            int64     `json:"askvolume"`            // 卖量1
	Askvolume2           int64     `json:"askvolume2"`           // 卖量2
	Askvolume3           int64     `json:"askvolume3"`           // 卖量3
	Askvolume4           int64     `json:"askvolume4"`           // 卖量4
	Askvolume5           int64     `json:"askvolume5"`           // 卖量5
	Presettle            float64   `json:"presettle"`            // 昨结价
	Settle               float64   `json:"settle"`               // 结算价
	Preholdvolume        int64     `json:"preholdvolume"`        // 昨持仓
	Holdvolume           int64     `json:"holdvolume"`           // 持仓
	Averageprice         float64   `json:"averageprice"`         // 均价
	Orderid              int64     `json:"orderid"`              // 序号
	Limitup              float64   `json:"limitup"`              // 涨停价
	Limitdown            float64   `json:"limitdown"`            // 跌停价
	Inventory            int64     `json:"inventory"`            // 库存
	Holdincrement        int64     `json:"holdincrement"`        // 单笔持仓
	Iscleared            int       `json:"iscleared"`            // 是否清盘标志
	Issettled            int       `json:"issettled"`            // 是否结算标志
	Bidqueueinfo         string    `json:"bidqueueinfo"`         // 大利市买港股用
	Askqueueinfo         string    `json:"askqueueinfo"`         // 大利市卖港股用
	Bidorderid           int64     `json:"bidorderid"`           // 买单号1
	Bidorderid2          int64     `json:"bidorderid2"`          // 买单号2
	Bidorderid3          int64     `json:"bidorderid3"`          // 买单号3
	Bidorderid4          int64     `json:"bidorderid4"`          // 买单号4
	Bidorderid5          int64     `json:"bidorderid5"`          // 买单号5
	Askorderid           int64     `json:"askorderid"`           // 卖单号1
	Askorderid2          int64     `json:"askorderid2"`          // 卖单号2
	Askorderid3          int64     `json:"askorderid3"`          // 卖单号3
	Askorderid4          int64     `json:"askorderid4"`          // 卖单号4
	Askorderid5          int64     `json:"askorderid5"`          // 卖单号5
	Lastlot              int64     `json:"lastlot"`              // 最新成交手数
	Totallot             int64     `json:"totallot"`             // 总手数
	Strikeprice          float64   `json:"strikeprice"`          // 发行价
	Cleartime            int64     `json:"cleartime"`            // 清盘时间
	Calloptionpremiums   int64     `json:"calloptionpremiums"`   // 认购期权1
	Calloptionpremiums2  int64     `json:"calloptionpremiums2"`  // 认购期权2
	Calloptionpremiums3  int64     `json:"calloptionpremiums3"`  // 认购期权3
	Calloptionpremiums4  int64     `json:"calloptionpremiums4"`  // 认购期权4
	Calloptionpremiums5  int64     `json:"calloptionpremiums5"`  // 认购期权5
	Putoptionpremiums    int64     `json:"putoptionpremiums"`    // 认沽期权1
	Putoptionpremiums2   int64     `json:"putoptionpremiums2"`   // 认沽期权2
	Putoptionpremiums3   int64     `json:"putoptionpremiums3"`   // 认沽期权3
	Putoptionpremiums4   int64     `json:"putoptionpremiums4"`   // 认沽期权4
	Putoptionpremiums5   int64     `json:"putoptionpremiums5"`   // 认沽期权5
	Nontotalvolume       int64     `json:"nontotalvolume"`       // 非交易总量
	Nontotalholdervolume int64     `json:"nontotalholdervolume"` // 非交易持仓量
	Nontotalturnover     int64     `json:"nontotalturnover"`     // 非交易总金额
	Nontotallot          int64     `json:"nontotallot"`          // 非交易总手数
	Publictradetype      string    `json:"publictradetype"`      // 公共交易标志类型 港股专用
	Iep                  float64   `json:"iep"`                  // 平衡价 港股专用
	Iev                  float64   `json:"iev"`                  // 平衡量 港股专用
	Grepmarketprice      float64   `json:"grepmarketprice"`      // 暗盘价 港股专用
	Bid6                 float64   `json:"bid6"`                 // 买6
	Bid7                 float64   `json:"bid7"`                 // 买7
	Bid8                 float64   `json:"bid8"`                 // 买8
	Bid9                 float64   `json:"bid9"`                 // 买9
	Bid10                float64   `json:"bid10"`                // 买10
	Bidvolume6           int64     `json:"bidvolume6"`           // 买量6
	Bidvolume7           int64     `json:"bidvolume7"`           // 买量7
	Bidvolume8           int64     `json:"bidvolume8"`           // 买量8
	Bidvolume9           int64     `json:"bidvolume9"`           // 买量9
	Bidvolume10          int64     `json:"bidvolume10"`          // 买量10
	Ask6                 float64   `json:"ask6"`                 // 卖6
	Ask7                 float64   `json:"ask7"`                 // 卖7
	Ask8                 float64   `json:"ask8"`                 // 卖8
	Ask9                 float64   `json:"ask9"`                 // 卖9
	Ask10                float64   `json:"ask10"`                // 卖10
	Askvolume6           int64     `json:"askvolume6"`           // 卖量6
	Askvolume7           int64     `json:"askvolume7"`           // 卖量7
	Askvolume8           int64     `json:"askvolume8"`           // 卖量8
	Askvolume9           int64     `json:"askvolume9"`           // 卖量9
	Askvolume10          int64     `json:"askvolume10"`          // 卖量10
	Bidordervolume       int64     `json:"bidordervolume"`       // 买单量1
	Bidordervolume2      int64     `json:"bidordervolume2"`      // 买单量2
	Bidordervolume3      int64     `json:"bidordervolume3"`      // 买单量3
	Bidordervolume4      int64     `json:"bidordervolume4"`      // 买单量4
	Bidordervolume5      int64     `json:"bidordervolume5"`      // 买单量5
	Bidordervolume6      int64     `json:"bidordervolume6"`      // 买单量6
	Bidordervolume7      int64     `json:"bidordervolume7"`      // 买单量7
	Bidordervolume8      int64     `json:"bidordervolume8"`      // 买单量8
	Bidordervolume9      int64     `json:"bidordervolume9"`      // 买单量9
	Bidordervolume10     int64     `json:"bidordervolume10"`     // 买单量10
	Askordervolume       int64     `json:"askordervolume"`       // 卖单量1
	Askordervolume2      int64     `json:"askordervolume2"`      // 卖单量2
	Askordervolume3      int64     `json:"askordervolume3"`      // 卖单量3
	Askordervolume4      int64     `json:"askordervolume4"`      // 卖单量4
	Askordervolume5      int64     `json:"askordervolume5"`      // 卖单量5
	Askordervolume6      int64     `json:"askordervolume6"`      // 卖单量6
	Askordervolume7      int64     `json:"askordervolume7"`      // 卖单量7
	Askordervolume8      int64     `json:"askordervolume8"`      // 卖单量8
	Askordervolume9      int64     `json:"askordervolume9"`      // 卖单量9
	Askordervolume10     int64     `json:"askordervolume10"`     // 卖单量10
}

// QueryQuoteDay 获取商品盘面信息
// @Summary 获取商品盘面信息
// @Produce json
// @Security ApiKeyAuth
// @Param goodsCodes query string true "商品代码列表，格式：CU2102,CU2103,AL2107"
// @Success 200 {object} QueryQuoteDayRsp
// @Failure 500 {object} app.Response
// @Router /Quote/QueryQuoteDay [get]
// @Tags 行情服务
func QueryQuoteDay(c *gin.Context) {
	appG := app.Gin{C: c}

	// 获取请求参数
	var req QueryQuoteDayReq
	if err := appG.C.ShouldBindQuery(&req); err != nil {
		logger.GetLogger().Errorf("QueryQuoteDay failed: %s", err.Error())
		appG.Response(http.StatusBadRequest, e.INVALID_PARAMS, nil)
		return
	}

	rsp := make([]QueryQuoteDayRsp, 0)
	// 构建查询GoodsCodes
	goodsCodes := fmt.Sprintf("'%s'", req.GoodsCodes)
	goodsCodes = strings.Replace(goodsCodes, ",", "','", -1)
	quoteDays, err := models.GetQuoteDays(goodsCodes)
	if err != nil {
		logger.GetLogger().Errorf("QueryQuoteDay failed: %s", err.Error())
		appG.Response(http.StatusBadRequest, e.ERROR_QUERY_FAIL, nil)
		return
	}
	for _, v := range quoteDays {
		// 获取对应的商品信息
		goods, bFind := mtpcache.GetGoods(v.Goodscode)
		if bFind {
			rsp = append(rsp, QueryQuoteDayRsp{
				Exchangedate:         v.Exchangedate,
				Goodscode:            v.Goodscode,
				Exchangecode:         v.Exchangecode,
				Preclose:             utils.IntToFloat64(int(v.Preclose), int(goods.DECIMALPLACE)),
				Opentime:             time.Unix(int64(v.Opentime), 0),
				Opened:               utils.IntToFloat64(int(v.Opened), int(goods.DECIMALPLACE)),
				Highest:              utils.IntToFloat64(int(v.Highest), int(goods.DECIMALPLACE)),
				Lowest:               utils.IntToFloat64(int(v.Lowest), int(goods.DECIMALPLACE)),
				Lasttime:             v.Lasttime,
				Utclasttime:          time.Unix(int64(v.Utclasttime), 0),
				Last:                 utils.IntToFloat64(int(v.Last), int(goods.DECIMALPLACE)),
				Lastvolume:           v.Lastvolume,
				Lastturnover:         float64(v.Lastturnover),
				Totalbidvolume:       v.Totalbidvolume,
				Totalaskvolume:       v.Totalaskvolume,
				Totalvolume:          v.Totalvolume,
				Totalturnover:        float64(v.Totalturnover),
				Bid:                  utils.IntToFloat64(int(v.Bid), int(goods.DECIMALPLACE)),
				Bid2:                 utils.IntToFloat64(int(v.Bid2), int(goods.DECIMALPLACE)),
				Bid3:                 utils.IntToFloat64(int(v.Bid3), int(goods.DECIMALPLACE)),
				Bid4:                 utils.IntToFloat64(int(v.Bid4), int(goods.DECIMALPLACE)),
				Bid5:                 utils.IntToFloat64(int(v.Bid5), int(goods.DECIMALPLACE)),
				Bidvolume:            v.Bidvolume,
				Bidvolume2:           v.Bidvolume2,
				Bidvolume3:           v.Bidvolume3,
				Bidvolume4:           v.Bidvolume4,
				Bidvolume5:           v.Bidvolume5,
				Ask:                  utils.IntToFloat64(int(v.Ask), int(goods.DECIMALPLACE)),
				Ask2:                 utils.IntToFloat64(int(v.Ask2), int(goods.DECIMALPLACE)),
				Ask3:                 utils.IntToFloat64(int(v.Ask3), int(goods.DECIMALPLACE)),
				Ask4:                 utils.IntToFloat64(int(v.Ask4), int(goods.DECIMALPLACE)),
				Ask5:                 utils.IntToFloat64(int(v.Ask5), int(goods.DECIMALPLACE)),
				Askvolume:            v.Askvolume,
				Askvolume2:           v.Askvolume2,
				Askvolume3:           v.Askvolume3,
				Askvolume4:           v.Askvolume4,
				Askvolume5:           v.Askvolume5,
				Presettle:            utils.IntToFloat64(int(v.Presettle), int(goods.DECIMALPLACE)),
				Settle:               utils.IntToFloat64(int(v.Settle), int(goods.DECIMALPLACE)),
				Preholdvolume:        v.Preholdvolume,
				Holdvolume:           v.Holdvolume,
				Averageprice:         utils.IntToFloat64(int(v.Averageprice), int(goods.DECIMALPLACE)),
				Orderid:              v.Orderid,
				Limitup:              utils.IntToFloat64(int(v.Limitup), int(goods.DECIMALPLACE)),
				Limitdown:            utils.IntToFloat64(int(v.Limitdown), int(goods.DECIMALPLACE)),
				Inventory:            v.Inventory,
				Holdincrement:        v.Holdincrement,
				Iscleared:            v.Iscleared,
				Issettled:            v.Issettled,
				Bidqueueinfo:         v.Bidqueueinfo,
				Askqueueinfo:         v.Askqueueinfo,
				Bidorderid:           v.Bidorderid,
				Bidorderid2:          v.Bidorderid2,
				Bidorderid3:          v.Bidorderid3,
				Bidorderid4:          v.Bidorderid4,
				Bidorderid5:          v.Bidorderid5,
				Askorderid:           v.Askorderid,
				Askorderid2:          v.Askorderid2,
				Askorderid3:          v.Askorderid3,
				Askorderid4:          v.Askorderid4,
				Askorderid5:          v.Askorderid5,
				Lastlot:              v.Lastlot,
				Totallot:             v.Totallot,
				Strikeprice:          utils.IntToFloat64(int(v.Strikeprice), int(goods.DECIMALPLACE)),
				Cleartime:            v.Cleartime,
				Calloptionpremiums:   v.Calloptionpremiums,
				Calloptionpremiums2:  v.Calloptionpremiums2,
				Calloptionpremiums3:  v.Calloptionpremiums3,
				Calloptionpremiums4:  v.Calloptionpremiums4,
				Calloptionpremiums5:  v.Calloptionpremiums5,
				Putoptionpremiums:    v.Putoptionpremiums,
				Putoptionpremiums2:   v.Putoptionpremiums2,
				Putoptionpremiums3:   v.Putoptionpremiums3,
				Putoptionpremiums4:   v.Putoptionpremiums4,
				Putoptionpremiums5:   v.Putoptionpremiums5,
				Nontotalvolume:       v.Nontotalvolume,
				Nontotalholdervolume: v.Nontotalholdervolume,
				Nontotalturnover:     v.Nontotalturnover,
				Nontotallot:          v.Nontotallot,
				Publictradetype:      v.Publictradetype,
				Iep:                  utils.IntToFloat64(int(v.Iep), int(goods.DECIMALPLACE)),
				Iev:                  utils.IntToFloat64(int(v.Iev), int(goods.DECIMALPLACE)),
				Grepmarketprice:      utils.IntToFloat64(int(v.Grepmarketprice), int(goods.DECIMALPLACE)),
				Bid6:                 utils.IntToFloat64(int(v.Bid6), int(goods.DECIMALPLACE)),
				Bid7:                 utils.IntToFloat64(int(v.Bid7), int(goods.DECIMALPLACE)),
				Bid8:                 utils.IntToFloat64(int(v.Bid8), int(goods.DECIMALPLACE)),
				Bid9:                 utils.IntToFloat64(int(v.Bid9), int(goods.DECIMALPLACE)),
				Bid10:                utils.IntToFloat64(int(v.Bid10), int(goods.DECIMALPLACE)),
				Bidvolume6:           v.Bidvolume6,
				Bidvolume7:           v.Bidvolume7,
				Bidvolume8:           v.Bidvolume8,
				Bidvolume9:           v.Bidvolume9,
				Bidvolume10:          v.Bidvolume10,
				Ask6:                 utils.IntToFloat64(int(v.Ask6), int(goods.DECIMALPLACE)),
				Ask7:                 utils.IntToFloat64(int(v.Ask7), int(goods.DECIMALPLACE)),
				Ask8:                 utils.IntToFloat64(int(v.Ask8), int(goods.DECIMALPLACE)),
				Ask9:                 utils.IntToFloat64(int(v.Ask9), int(goods.DECIMALPLACE)),
				Ask10:                utils.IntToFloat64(int(v.Ask10), int(goods.DECIMALPLACE)),
				Askvolume6:           v.Askvolume6,
				Askvolume7:           v.Askvolume7,
				Askvolume8:           v.Askvolume8,
				Askvolume9:           v.Askvolume9,
				Askvolume10:          v.Askvolume10,
				Bidordervolume:       v.Bidordervolume,
				Bidordervolume2:      v.Bidordervolume2,
				Bidordervolume3:      v.Bidordervolume3,
				Bidordervolume4:      v.Bidordervolume4,
				Bidordervolume5:      v.Bidordervolume5,
				Bidordervolume6:      v.Bidordervolume6,
				Bidordervolume7:      v.Bidordervolume7,
				Bidordervolume8:      v.Bidordervolume8,
				Bidordervolume9:      v.Bidordervolume9,
				Bidordervolume10:     v.Bidordervolume10,
				Askordervolume:       v.Askordervolume,
				Askordervolume2:      v.Askordervolume2,
				Askordervolume3:      v.Askordervolume3,
				Askordervolume4:      v.Askordervolume4,
				Askordervolume5:      v.Askordervolume5,
				Askordervolume6:      v.Askordervolume6,
				Askordervolume7:      v.Askordervolume7,
				Askordervolume8:      v.Askordervolume8,
				Askordervolume9:      v.Askordervolume9,
				Askordervolume10:     v.Askordervolume10,
			})
		}
	}

	// 查询成功
	logger.GetLogger().Debugln("QueryQuoteDay successed, rows: %v", len(rsp))
	appG.Response(http.StatusOK, e.SUCCESS, rsp)
}