model

package
v0.0.0-...-d2b7790 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 25, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Day  = "day"
	Week = "week"
)
View Source
const (
	FieldQuoteID              = "id"
	FieldQuoteCode            = "code"
	FieldQuoteOpen            = "open"
	FieldQuoteClose           = "close"
	FieldQuoteHigh            = "high"
	FieldQuoteLow             = "low"
	FieldQuoteYesterdayClosed = "yesterday_closed"
	FieldQuoteVolume          = "volume"
	FieldQuoteAccount         = "account"
	FieldQuoteDate            = "date"
	FieldQuoteNumOfYear       = "num_of_year"
	FieldQuoteXd              = "xd"
	FieldQuoteCreateTimestamp = "create_timestamp"
	FieldQuoteModifyTimestamp = "modify_timestamp"
)
View Source
const (
	FieldStockCode            = "code"
	FieldStockName            = "name"
	FieldStockSuspend         = "suspend"
	FieldStockCreateTimestamp = "create_timestamp"
	FieldStockModifyTimestamp = "modify_timestamp"
)

Variables

This section is empty.

Functions

func QuoteWithDeleteManyByCodesAndDate

func QuoteWithDeleteManyByCodesAndDate(exec mysql.Exec, model string, codes []string, date string, timeout time.Duration) (int64, error)

func QuoteWithInsertMany

func QuoteWithInsertMany(exec mysql.Exec, model string, data []*Quote, timeout time.Duration) (int64, error)

func StockWithInsertMany

func StockWithInsertMany(exec mysql.Exec, stocks []*Stock, timeout time.Duration) (int64, error)

func StockWithInsertOrUpdateMany

func StockWithInsertOrUpdateMany(exec mysql.Exec, stocks []*Stock, timeout time.Duration) (int64, error)

func StockWithSelectMany

func StockWithSelectMany(exec mysql.Exec, codes []string, timeout time.Duration) (map[string]*Stock, error)

func StockWithUpdateOne

func StockWithUpdateOne(exec mysql.Exec, code string, stock *Stock, timeout time.Duration) (int64, error)

Types

type Metadata

type Metadata struct {
	ObjectID        string  `json:"_id" bson:"_id"`
	Source          string  `json:"source" bson:"source"`
	Code            string  `json:"code" bson:"code"`
	Name            string  `json:"name" bson:"name"`                         // 0 股票简称
	Open            float64 `json:"open" bson:"open"`                         // 1 今日开盘价格
	YesterdayClosed float64 `json:"yesterday_closed" bson:"yesterday_closed"` // 2 昨日收盘价格
	Latest          float64 `json:"latest" bson:"latest"`                     // 3 最近成交价格
	High            float64 `json:"high" bson:"high"`                         // 4 最高成交价
	Low             float64 `json:"low" bson:"low"`                           // 5 最低成交价
	Volume          uint64  `json:"volume" bson:"volume"`                     // 8 成交数量(股)
	Account         float64 `json:"account" bson:"account"`                   // 9 成交金额(元)
	Date            string  `json:"date" bson:"date"`                         // 30 日期
	Time            string  `json:"time" bson:"time"`                         // 31 时间
	Suspend         string  `json:"suspend" bson:"suspend"`                   // 32 停牌状态
}

Metadata trade data

func SelectMetadataRange

func SelectMetadataRange(db *mongo.Client, offset, limit int64, date string, lastID string, timeout time.Duration) ([]*Metadata, error)

func (*Metadata) String

func (m *Metadata) String() string

type Quote

type Quote struct {
	Id              int64        `json:"id"`
	Code            string       `json:"code"`
	Open            float64      `json:"open"`
	Close           float64      `json:"close"`
	High            float64      `json:"high"`
	Low             float64      `json:"low"`
	YesterdayClosed float64      `json:"yesterday_closed"`
	Volume          uint64       `json:"volume"`
	Account         float64      `json:"account"`
	Date            time.Time    `json:"date"`
	NumOfYear       int          `json:"num_of_year"`
	Xd              float64      `json:"xd"`
	CreateTimestamp time.Time    `json:"create_timestamp"`
	ModifyTimestamp sql.NullTime `json:"modify_timestamp"`
}

func QuoteWithSelectBetweenByCodeAndDate

func QuoteWithSelectBetweenByCodeAndDate(exec mysql.Exec, model string, code string, begin, end string, timeout time.Duration) ([]*Quote, error)

func QuoteWithSelectManyLatest

func QuoteWithSelectManyLatest(exec mysql.Exec, model string, code string, date string, limit int64, timeout time.Duration) ([]*Quote, error)

func QuoteWithSelectOneByCodeAndDate

func QuoteWithSelectOneByCodeAndDate(exec mysql.Exec, model string, code string, date string, timeout time.Duration) (*Quote, error)

func QuoteWithSelectRangeByDate

func QuoteWithSelectRangeByDate(exec mysql.Exec, model string, date string, offset, limit int64, timeout time.Duration) ([]*Quote, error)

func (*Quote) String

func (q *Quote) String() string

type Stock

type Stock struct {
	Code            string       `json:"code"`
	Name            string       `json:"name"`
	Suspend         string       `json:"suspend"`
	CreateTimestamp time.Time    `json:"create_timestamp"`
	ModifyTimestamp sql.NullTime `json:"modify_timestamp"`
}

Stock

func StockWithSelectRange

func StockWithSelectRange(exec mysql.Exec, offset, limit int64, timeout time.Duration) ([]*Stock, error)

func (*Stock) String

func (s *Stock) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL