MTP20_IF/models/quote.go

package models

import (
	"context"
	"encoding/json"
	"errors"
	"fmt"
	"mtp2_if/config"
	"mtp2_if/db"
	"mtp2_if/logger"
	"mtp2_if/rediscli"
	"mtp2_if/utils"
	"strings"
	"time"

	"github.com/go-viper/mapstructure/v2"
	"go.mongodb.org/mongo-driver/bson"
	"go.mongodb.org/mongo-driver/bson/primitive"
)

// CycleType 周期类型
type CycleType int

const (
	// CycleTypeSecond 周期类型 - 秒
	CycleTypeSecond CycleType = 0
	// CycleTypeMinutes1 周期类型 - 1分钟
	CycleTypeMinutes1 CycleType = 1
	// CycleTypeMinutes5 周期类型 - 5分钟
	CycleTypeMinutes5 CycleType = 2
	// CycleTypeMinutes30 周期类型 - 30分钟
	CycleTypeMinutes30 CycleType = 3
	// CycleTypeMinutes60 周期类型 - 60分钟
	CycleTypeMinutes60 CycleType = 4
	// CycleTypeMinutes120 周期类型 - 2小时
	CycleTypeMinutes120 CycleType = 120
	// CycleTypeMinutes240 周期类型 - 4小时
	CycleTypeMinutes240 CycleType = 240
	// CycleTypeMinutesDay 周期类型 - 日线
	CycleTypeMinutesDay CycleType = 11
	// CycleTypeWeek 周期类型 - 周线
	CycleTypeWeek CycleType = 12
	// CycleTypeMonth 周期类型 - 月线
	CycleTypeMonth CycleType = 13
	// CycleTypeYear 周期类型 - 年线
	CycleTypeYear CycleType = 14
	// CycleTypeTik 周期类型 - Tik
	CycleTypeTik CycleType = 10
)

// CycleData MongoDB中历史数据模型
type CycleData struct {
	ID    primitive.ObjectID `json:"-" bson:"_id"` // id
	GC    string             `bson:"GC"`           // 商品代码
	ST    int                `json:"-" bson:"ST"`  // 时间戳
	SST   string             `bson:"SST"`          // 时间文本
	Open  int                `bson:"Open"`         // 开盘价
	High  int                `bson:"High"`         // 最高价
	Low   int                `bson:"Low"`          // 最低价
	Close int                `bson:"Close"`        // 收盘价
	TV    int                `bson:"TV"`           // 总量
	TT    int                `bson:"TT"`           // 总金额
	HV    int                `bson:"HV"`           // 持仓量
	SP    int                `bson:"SP"`           // 结算价，日线周期（包括）以上才有
	FI    bool               `json:"FI"`           // 是否补充数据
}

// TikData MongoDB中Tik数据模型
type TikData struct {
	ID  primitive.ObjectID `json:"-" bson:"_id"` // id
	GC  string             `bson:"GC"`           // 商品代码
	TD  int                `bson:"TD"`           // 交易日时间戳
	AT  int                `bson:"AT"`           // 行情时间戳
	SAT string             `bson:"SAT"`          // 行情时间文本
	PE  int                `bson:"PE"`           // 现价
	Vol int                `bson:"Vol"`          // 现量
	TT  int                `bson:"TT"`           // 现金额
	Bid int                `bson:"Bid"`          // 买价
	BV  int                `bson:"BV"`           // 买量
	Ask int                `bson:"Ask"`          // 卖价
	AV  int                `bson:"AV"`           // 卖量
	HV  int                `bson:"HV"`           // 持仓量
	HI  int                `bson:"HI"`           // 单笔持仓
	TDR int                `bson:"TDR"`          // 交易方向
	TK  int                `bson:"TK"`           // 交易类型
	OId int                `bson:"OId"`          // 行情序号
}

// Quoteday 行情盘面
type Quoteday struct {
	Id                   int64  `mapstructure:"" xorm:"pk autoincr BIGINT(20)"`
	Exchangedate         int64  `mapstructure:"ExchangeDate" xorm:"not null BIGINT(20)"`          // 交易日
	Goodscode            string `mapstructure:"GoodsCode" xorm:"not null unique CHAR(10)"`        // 商品代码
	Exchangecode         int    `mapstructure:"ExchangeCode" xorm:"INT(11)"`                      // 交易所代码
	Preclose             int64  `mapstructure:"Preclose" xorm:"default 0 BIGINT(20)"`             // 昨收
	Opentime             int64  `mapstructure:"Opentime" xorm:"BIGINT(20)"`                       // 开盘时间
	Opened               int64  `mapstructure:"Opened" xorm:"not null default 0 BIGINT(20)"`      // 开盘价
	Highest              int64  `mapstructure:"Highest" xorm:"not null default 0 BIGINT(20)"`     // 最高价
	Lowest               int64  `mapstructure:"Lowest" xorm:"not null default 0 BIGINT(20)"`      // 最低价
	Lasttime             string `mapstructure:"Lasttime" xorm:"VARCHAR(20)"`                      // 行情时间（只有现价变化行情时间才变化）
	Utclasttime          int64  `mapstructure:"Utclasttime" xorm:"not null BIGINT(20)"`           // utc的行情时间
	Last                 int64  `mapstructure:"Last" xorm:"not null BIGINT(20)"`                  // 最新价
	Lastvolume           int64  `mapstructure:"Lastvolume" xorm:"default 0 BIGINT(20)"`           // 最新成交量
	Lastturnover         int64  `mapstructure:"Lastturnover" xorm:"default 0 BIGINT(20)"`         // 最新成交金额
	Totalbidvolume       int64  `mapstructure:"Totalbidvolume" xorm:"default 0 BIGINT(20)"`       // 外盘
	Totalaskvolume       int64  `mapstructure:"Totalaskvolume" xorm:"default 0 BIGINT(20)"`       // 内盘
	Totalvolume          int64  `mapstructure:"Totalvolume" xorm:"default 0 BIGINT(20)"`          // 总量
	Totalturnover        int64  `mapstructure:"Totalturnover" xorm:"default 0 BIGINT(20)"`        // 总金额
	Bid                  int64  `mapstructure:"Bid" xorm:"default 0 BIGINT(20)"`                  // 买1
	Bid2                 int64  `mapstructure:"Bid2" xorm:"default 0 BIGINT(20)"`                 // 买2
	Bid3                 int64  `mapstructure:"Bid3" xorm:"default 0 BIGINT(20)"`                 // 买3
	Bid4                 int64  `mapstructure:"Bid4" xorm:"default 0 BIGINT(20)"`                 // 买4
	Bid5                 int64  `mapstructure:"Bid5" xorm:"default 0 BIGINT(20)"`                 // 买5
	Bidvolume            int64  `mapstructure:"Bidvolume" xorm:"default 0 BIGINT(20)"`            // 买量1
	Bidvolume2           int64  `mapstructure:"Bidvolume2" xorm:"default 0 BIGINT(20)"`           // 买量2
	Bidvolume3           int64  `mapstructure:"Bidvolume3" xorm:"default 0 BIGINT(20)"`           // 买量3
	Bidvolume4           int64  `mapstructure:"Bidvolume4" xorm:"default 0 BIGINT(20)"`           // 买量4
	Bidvolume5           int64  `mapstructure:"Bidvolume5" xorm:"default 0 BIGINT(20)"`           // 买量5
	Ask                  int64  `mapstructure:"Ask" xorm:"default 0 BIGINT(20)"`                  // 卖1
	Ask2                 int64  `mapstructure:"Ask2" xorm:"default 0 BIGINT(20)"`                 // 卖2
	Ask3                 int64  `mapstructure:"Ask3" xorm:"default 0 BIGINT(20)"`                 // 卖3
	Ask4                 int64  `mapstructure:"Ask4" xorm:"default 0 BIGINT(20)"`                 // 卖4
	Ask5                 int64  `mapstructure:"Ask5" xorm:"default 0 BIGINT(20)"`                 // 卖5
	Askvolume            int64  `mapstructure:"Askvolume" xorm:"default 0 BIGINT(20)"`            // 卖量1
	Askvolume2           int64  `mapstructure:"Askvolume2" xorm:"default 0 BIGINT(20)"`           // 卖量2
	Askvolume3           int64  `mapstructure:"Askvolume3" xorm:"default 0 BIGINT(20)"`           // 卖量3
	Askvolume4           int64  `mapstructure:"Askvolume4" xorm:"default 0 BIGINT(20)"`           // 卖量4
	Askvolume5           int64  `mapstructure:"Askvolume5" xorm:"default 0 BIGINT(20)"`           // 卖量5
	Presettle            int64  `mapstructure:"Presettle" xorm:"default 0 BIGINT(20)"`            // 昨结价
	Settle               int64  `mapstructure:"Settle" xorm:"default 0 BIGINT(20)"`               // 结算价
	Preholdvolume        int64  `mapstructure:"Preholdvolume" xorm:"default 0 BIGINT(20)"`        // 昨持仓
	Holdvolume           int64  `mapstructure:"Holdvolume" xorm:"default 0 BIGINT(20)"`           // 持仓
	Averageprice         int64  `mapstructure:"Averageprice" xorm:"default 0 BIGINT(20)"`         // 均价
	Orderid              int64  `mapstructure:"Orderid" xorm:"default 0 BIGINT(20)"`              // 序号
	Limitup              int64  `mapstructure:"Limitup" xorm:"default 0 BIGINT(20)"`              // 涨停价
	Limitdown            int64  `mapstructure:"Limitdown" xorm:"default 0 BIGINT(20)"`            // 跌停价
	Inventory            int64  `mapstructure:"Inventory" xorm:"default 0 BIGINT(20)"`            // 库存
	Holdincrement        int64  `mapstructure:"Holdincrement" xorm:"default 0 BIGINT(20)"`        // 单笔持仓
	Iscleared            int    `mapstructure:"Iscleared" xorm:"INT(11)"`                         // 是否清盘标志
	Issettled            int    `mapstructure:"Issettled" xorm:"INT(11)"`                         // 是否结算标志
	Bidqueueinfo         string `mapstructure:"Bidqueueinfo" xorm:"VARCHAR(2000)"`                // 大利市买港股用
	Askqueueinfo         string `mapstructure:"Askqueueinfo" xorm:"VARCHAR(2000)"`                // 大利市卖港股用
	Bidorderid           int64  `mapstructure:"Bidorderid" xorm:"BIGINT(20)"`                     // 买单号1
	Bidorderid2          int64  `mapstructure:"Bidorderid2" xorm:"BIGINT(20)"`                    // 买单号2
	Bidorderid3          int64  `mapstructure:"Bidorderid3" xorm:"BIGINT(20)"`                    // 买单号3
	Bidorderid4          int64  `mapstructure:"Bidorderid4" xorm:"BIGINT(20)"`                    // 买单号4
	Bidorderid5          int64  `mapstructure:"Bidorderid5" xorm:"BIGINT(20)"`                    // 买单号5
	Askorderid           int64  `mapstructure:"Askorderid" xorm:"BIGINT(20)"`                     // 卖单号1
	Askorderid2          int64  `mapstructure:"Askorderid2" xorm:"BIGINT(20)"`                    // 卖单号2
	Askorderid3          int64  `mapstructure:"Askorderid3" xorm:"BIGINT(20)"`                    // 卖单号3
	Askorderid4          int64  `mapstructure:"Askorderid4" xorm:"BIGINT(20)"`                    // 卖单号4
	Askorderid5          int64  `mapstructure:"Askorderid5" xorm:"BIGINT(20)"`                    // 卖单号5
	Lastlot              int64  `mapstructure:"Lastlot" xorm:"BIGINT(20)"`                        // 最新成交手数
	Totallot             int64  `mapstructure:"Totallot" xorm:"BIGINT(20)"`                       // 总手数
	Strikeprice          int64  `mapstructure:"Strikeprice" xorm:"BIGINT(20)"`                    // 发行价
	Cleartime            int64  `mapstructure:"Cleartime" xorm:"BIGINT(20)"`                      // 清盘时间
	Calloptionpremiums   int64  `mapstructure:"Calloptionpremiums" xorm:"default 0 BIGINT(20)"`   // 认购期权1
	Calloptionpremiums2  int64  `mapstructure:"Calloptionpremiums2" xorm:"default 0 BIGINT(20)"`  // 认购期权2
	Calloptionpremiums3  int64  `mapstructure:"Calloptionpremiums3" xorm:"default 0 BIGINT(20)"`  // 认购期权3
	Calloptionpremiums4  int64  `mapstructure:"Calloptionpremiums4" xorm:"default 0 BIGINT(20)"`  // 认购期权4
	Calloptionpremiums5  int64  `mapstructure:"Calloptionpremiums5" xorm:"default 0 BIGINT(20)"`  // 认购期权5
	Putoptionpremiums    int64  `mapstructure:"Putoptionpremiums" xorm:"default 0 BIGINT(20)"`    // 认沽期权1
	Putoptionpremiums2   int64  `mapstructure:"Putoptionpremiums2" xorm:"default 0 BIGINT(20)"`   // 认沽期权2
	Putoptionpremiums3   int64  `mapstructure:"Putoptionpremiums3" xorm:"default 0 BIGINT(20)"`   // 认沽期权3
	Putoptionpremiums4   int64  `mapstructure:"Putoptionpremiums4" xorm:"default 0 BIGINT(20)"`   // 认沽期权4
	Putoptionpremiums5   int64  `mapstructure:"Putoptionpremiums5" xorm:"default 0 BIGINT(20)"`   // 认沽期权5
	Nontotalvolume       int64  `mapstructure:"Nontotalvolume" xorm:"default 0 BIGINT(20)"`       // 非交易总量
	Nontotalholdervolume int64  `mapstructure:"Nontotalholdervolume" xorm:"default 0 BIGINT(20)"` // 非交易持仓量
	Nontotalturnover     int64  `mapstructure:"Nontotalturnover" xorm:"default 0 BIGINT(20)"`     // 非交易总金额
	Nontotallot          int64  `mapstructure:"Nontotallot" xorm:"default 0 BIGINT(20)"`          // 非交易总手数
	Publictradetype      string `mapstructure:"Publictradetype" xorm:"VARCHAR(2)"`                // 公共交易标志类型 港股专用
	Iep                  int64  `mapstructure:"Iep" xorm:"default 0 BIGINT(20)"`                  // 平衡价 港股专用
	Iev                  int64  `mapstructure:"Iev" xorm:"default 0 BIGINT(20)"`                  // 平衡量 港股专用
	Grepmarketprice      int64  `mapstructure:"Grepmarketprice" xorm:"default 0 BIGINT(20)"`      // 暗盘价 港股专用
	Bid6                 int64  `mapstructure:"Bid6" xorm:"default 0 BIGINT(20)"`                 // 买6
	Bid7                 int64  `mapstructure:"Bid7" xorm:"default 0 BIGINT(20)"`                 // 买7
	Bid8                 int64  `mapstructure:"Bid8" xorm:"default 0 BIGINT(20)"`                 // 买8
	Bid9                 int64  `mapstructure:"Bid9" xorm:"default 0 BIGINT(20)"`                 // 买9
	Bid10                int64  `mapstructure:"Bid10" xorm:"default 0 BIGINT(20)"`                // 买10
	Bidvolume6           int64  `mapstructure:"Bidvolume6" xorm:"default 0 BIGINT(20)"`           // 买量6
	Bidvolume7           int64  `mapstructure:"Bidvolume7" xorm:"default 0 BIGINT(20)"`           // 买量7
	Bidvolume8           int64  `mapstructure:"Bidvolume8" xorm:"default 0 BIGINT(20)"`           // 买量8
	Bidvolume9           int64  `mapstructure:"Bidvolume9" xorm:"default 0 BIGINT(20)"`           // 买量9
	Bidvolume10          int64  `mapstructure:"Bidvolume10" xorm:"default 0 BIGINT(20)"`          // 买量10
	Ask6                 int64  `mapstructure:"Ask6" xorm:"default 0 BIGINT(20)"`                 // 卖6
	Ask7                 int64  `mapstructure:"Ask7" xorm:"default 0 BIGINT(20)"`                 // 卖7
	Ask8                 int64  `mapstructure:"Ask8" xorm:"default 0 BIGINT(20)"`                 // 卖8
	Ask9                 int64  `mapstructure:"Ask9" xorm:"default 0 BIGINT(20)"`                 // 卖9
	Ask10                int64  `mapstructure:"Ask10" xorm:"default 0 BIGINT(20)"`                // 卖10
	Askvolume6           int64  `mapstructure:"Askvolume6" xorm:"default 0 BIGINT(20)"`           // 卖量6
	Askvolume7           int64  `mapstructure:"Askvolume7" xorm:"default 0 BIGINT(20)"`           // 卖量7
	Askvolume8           int64  `mapstructure:"Askvolume8" xorm:"default 0 BIGINT(20)"`           // 卖量8
	Askvolume9           int64  `mapstructure:"Askvolume9" xorm:"default 0 BIGINT(20)"`           // 卖量9
	Askvolume10          int64  `mapstructure:"Askvolume10" xorm:"default 0 BIGINT(20)"`          // 卖量10
	Bidordervolume       int64  `mapstructure:"Bidordervolume" xorm:"default 0 BIGINT(20)"`       // 买单量1
	Bidordervolume2      int64  `mapstructure:"Bidordervolume2" xorm:"default 0 BIGINT(20)"`      // 买单量2
	Bidordervolume3      int64  `mapstructure:"Bidordervolume3" xorm:"default 0 BIGINT(20)"`      // 买单量3
	Bidordervolume4      int64  `mapstructure:"Bidordervolume4" xorm:"default 0 BIGINT(20)"`      // 买单量4
	Bidordervolume5      int64  `mapstructure:"Bidordervolume5" xorm:"default 0 BIGINT(20)"`      // 买单量5
	Bidordervolume6      int64  `mapstructure:"Bidordervolume6" xorm:"default 0 BIGINT(20)"`      // 买单量6
	Bidordervolume7      int64  `mapstructure:"Bidordervolume7" xorm:"default 0 BIGINT(20)"`      // 买单量7
	Bidordervolume8      int64  `mapstructure:"Bidordervolume8" xorm:"default 0 BIGINT(20)"`      // 买单量8
	Bidordervolume9      int64  `mapstructure:"Bidordervolume9" xorm:"default 0 BIGINT(20)"`      // 买单量9
	Bidordervolume10     int64  `mapstructure:"Bidordervolume10" xorm:"default 0 BIGINT(20)"`     // 买单量10
	Askordervolume       int64  `mapstructure:"Askordervolume" xorm:"default 0 BIGINT(20)"`       // 卖单量1
	Askordervolume2      int64  `mapstructure:"Askordervolume2" xorm:"default 0 BIGINT(20)"`      // 卖单量2
	Askordervolume3      int64  `mapstructure:"Askordervolume3" xorm:"default 0 BIGINT(20)"`      // 卖单量3
	Askordervolume4      int64  `mapstructure:"Askordervolume4" xorm:"default 0 BIGINT(20)"`      // 卖单量4
	Askordervolume5      int64  `mapstructure:"Askordervolume5" xorm:"default 0 BIGINT(20)"`      // 卖单量5
	Askordervolume6      int64  `mapstructure:"Askordervolume6" xorm:"default 0 BIGINT(20)"`      // 卖单量6
	Askordervolume7      int64  `mapstructure:"Askordervolume7" xorm:"default 0 BIGINT(20)"`      // 卖单量7
	Askordervolume8      int64  `mapstructure:"Askordervolume8" xorm:"default 0 BIGINT(20)"`      // 卖单量8
	Askordervolume9      int64  `mapstructure:"Askordervolume9" xorm:"default 0 BIGINT(20)"`      // 卖单量9
	Askordervolume10     int64  `mapstructure:"Askordervolume10" xorm:"default 0 BIGINT(20)"`     // 卖单量10
}

// TableName is Quoteday
func (*Quoteday) TableName() string {
	return "quoteday"
}

// GetHistoryCycleDatas 获取历史数据
// 参数 cycleType CycleType 周期类型
// 参数 goodsCode string 商品代码
// 参数 startTime time.Time 开始时间（闭区间）
// 参数 endTime time.Time 结束时间（闭区间）
// 参数 count int 条数
// 参数 isAscForST bool 是否按时间顺序排序，默认为时间倒序排序
// 返回值 []CycleData 历史数据
// 返回值 error 错误
func GetHistoryCycleDatas(cycleType CycleType, goodsCode string, startTime, endTime *time.Time, count int, isAscForST bool) ([]CycleData, error) {
	db := db.GetMongoDB()

	// 获取目标Collection
	collection := "mincycle"
	switch cycleType {
	case CycleTypeTik:
		collection = "quotetik"
	case CycleTypeMinutes1:
		collection = "mincycle"
	case CycleTypeMinutes5:
		collection = "min5cycle"
	case CycleTypeMinutes30:
		collection = "min30cycle"
	case CycleTypeMinutes60:
		collection = "min60cycle"
	case CycleTypeMinutes240:
		collection = "min240cycle"
	case CycleTypeMinutesDay:
		collection = "daycycle"
	case CycleTypeWeek:
		collection = "weekcycle"
	case CycleTypeMonth:
		collection = "monthcycle"
	case CycleTypeYear:
		collection = "yearcycle"
	default:
		return nil, errors.New("不支持的周期类型")
	}
	c := db.Collection(collection)

	// 按时间排序
	sort := "-ST"
	if isAscForST {
		sort = "ST"
	}

	// 查询数据
	var cycleDatas []CycleData
	m := bson.M{"GC": goodsCode}
	if startTime != nil && endTime == nil {
		m["ST"] = bson.M{"$gte": startTime.Unix()}
	} else if startTime == nil && endTime != nil {
		m["ST"] = bson.M{"$lte": endTime.Unix()}
	} else if startTime != nil && endTime != nil {
		m["ST"] = bson.M{"$gte": startTime.Unix(), "$lte": endTime.Unix()}
	}
	query := c.Find(context.Background(), m)
	if count > 0 {
		query = query.Limit(int64(count))
	}
	if err := query.Sort(sort).All(&cycleDatas); err != nil {
		return nil, err
	}

	return cycleDatas, nil
}

// GetHistoryTikDatas 获取历史数据
// 参数 goodsCode string 商品代码
// 参数 startTime time.Time 开始时间（闭区间）
// 参数 endTime time.Time 结束时间（闭区间）
// 参数 count int 条数
// 参数 isAscForST bool 是否按时间顺序排序，默认为时间倒序排序
// 返回值 []TikData Tik数据
// 返回值 error 错误
func GetHistoryTikDatas(goodsCode string, startTime, endTime *time.Time, count int, isAscForST bool) ([]TikData, error) {
	db := db.GetMongoDB()

	// 获取目标Collection
	collection := "quotetik"
	c := db.Collection(collection)

	// 按时间排序
	sort := "-_id"
	if isAscForST {
		sort = "id"
	}

	// 查询数据
	var tikDatas []TikData
	m := bson.M{"GC": goodsCode}
	if startTime != nil && endTime == nil {
		m["AT"] = bson.M{"$gte": startTime.Unix()}
	} else if startTime == nil && endTime != nil {
		m["AT"] = bson.M{"$lte": endTime.Unix()}
	} else if startTime != nil && endTime != nil {
		m["AT"] = bson.M{"$gte": startTime.Unix(), "$lte": endTime.Unix()}
	}
	query := c.Find(context.Background(), m)
	if count > 0 {
		query = query.Limit(int64(count))
	}
	if err := query.Sort(sort).All(&tikDatas); err != nil {
		return nil, err
	}

	return tikDatas, nil
}

// GetQuoteDays 获取目标商品的盘面数据
// 参数 goodsCodes string 商品代码字串，以“,”分隔
// 返回 []Quoteday 盘面数据
// 返回 error error
func GetQuoteDays(goodsCodes string) ([]Quoteday, error) {
	if config.SerCfg.MySQLCfg.Enabled == 0 {
		// 使用 Redis 盘面
		return QueryRedisQuoteDays(goodsCodes)
	}

	engine := db.GetMySQLEngine()
	datas := make([]Quoteday, 0)

	if len(goodsCodes) > 0 {
		// 指定商品代码查询
		// 处理商品代码, 让其可作为sql的in条件内容。 例如, 原字符串 ru2201,CU2406, => 处理成 'ru2201','CU2406'
		goodsCodes = strings.Trim(goodsCodes, ",")
		sCode := strings.Split(goodsCodes, ",")
		for i := range sCode {
			// 如果没有单引号, 则加上单引号
			if !strings.Contains(sCode[i], "'") {
				sCode[i] = "'" + sCode[i] + "'"
			}
		}
		Instr := strings.Join(sCode, ",")
		if err := engine.Where(fmt.Sprintf("goodscode in (%s)", Instr)).Find(&datas); err != nil {
			return nil, err
		}
	} else {
		// 不指定则查所有
		if err := engine.Find(&datas); err != nil {
			return nil, err
		}
	}

	return datas, nil
}

// SetRedisQuoteDays 将盘面数据同步到Redis
func SetRedisQuoteDays() (err error) {
	engine := db.GetMySQLEngine()
	datas := make([]Quoteday, 0)
	if err = engine.Find(&datas); err != nil {
		return
	}
	b, err := json.Marshal(datas)
	if err != nil {
		return
	}

	redisCli := rediscli.GetRedisClient()
	err = redisCli.Set("Tourist:QuoteDay", b, 0).Err()

	return
}

// QueryRedisQuoteDays 从Redis读取盘面数据
func QueryRedisQuoteDays(goodsCodes string) (quoteDays []Quoteday, err error) {
	exchangeCode := "250"
	quoteDays = make([]Quoteday, 0)

	redisCli := rediscli.GetRedisClient()
	for _, goodsCode := range strings.Split(goodsCodes, ",") {
		var m map[string]string
		m, err = redisCli.HGetAll(fmt.Sprintf("QuoteDay:%s_%s", exchangeCode, goodsCode)).Result()
		if err != nil {
			return
		}

		if len(m) == 0 {
			return
		}

		var quoteDay Quoteday
		config := &mapstructure.DecoderConfig{
			WeaklyTypedInput: true, // 启用弱类型转换，允许字符串自动转换为数字
			Result:           &quoteDay,
		}
		decoder, err := mapstructure.NewDecoder(config)
		if err != nil {
			return quoteDays, err
		}
		err = decoder.Decode(m)
		if err != nil {
			return quoteDays, err
		}

		quoteDays = append(quoteDays, quoteDay)
	}

	return
}

// GetRedisQuoteDays 从Redis读取盘面数据(游客)
func GetRedisQuoteDays(goodsCodes []string) (quoteDays []Quoteday, err error) {
	redisCli := rediscli.GetRedisClient()
	b, err := redisCli.Get("Tourist:QuoteDay").Bytes()
	if err != nil {
		return
	}

	var datas []Quoteday
	if err = json.Unmarshal(b, &datas); err != nil {
		return
	}
	quoteDays = make([]Quoteday, 0)
	for _, item := range datas {
		if utils.InArray(len(goodsCodes), func(i int) bool { return goodsCodes[i] == item.Goodscode }) {
			quoteDays = append(quoteDays, item)
		}
	}

	return
}

var Done chan bool

func StartSyncRedisQuoteDay() {
	ticker := time.NewTicker(2 * time.Second)
	Done = make(chan bool)
	go func() {
		for {
			select {
			case <-Done:
				ticker.Stop()
				return
			case <-ticker.C:
				// 在这里执行定时任务的代码
				if err := SetRedisQuoteDays(); err != nil {
					logger.GetLogger().Errorf("Sync Redis failed: %s", err.Error())
				}
			}
		}
	}()
}