extend

type CodesHTTP struct {
	*tdx.CodesBase
	// contains filtered or unexported fields
}

type Income struct {
	Offset  int        //偏移量
	Time    time.Time  //时间
	Source  protocol.K //源
	Current protocol.K //当前
}

type Incomes []*Income

type Kline struct {
	Code   string         `json:"code"`                  //代码
	Date   int64          `json:"date"`                  //时间节点 2006-01-02 15:00
	Open   protocol.Price `json:"open"`                  //开盘价
	High   protocol.Price `json:"high"`                  //最高价
	Low    protocol.Price `json:"low"`                   //最低价
	Close  protocol.Price `json:"close"`                 //收盘价
	Volume int64          `json:"volume"`                //成交量
	Amount protocol.Price `json:"amount"`                //成交额
	InDate int64          `json:"inDate" xorm:"created"` //创建时间
}

type KlineHandler func(code string, f func(k *protocol.Kline) bool) (*protocol.KlineResp, error)

type KlineTable struct {
	Kline `xorm:"extends"`

	Handler func(c *tdx.Client) KlineHandler `xorm:"-"`
	// contains filtered or unexported fields
}

type Klines []*Kline

type PullKline struct {
	Config PullKlineConfig
	// contains filtered or unexported fields
}

type PullKlineConfig struct {
	Codes   []string  //操作代码
	Tables  []string  //数据类型
	Dir     string    //数据位置
	Limit   int       //协程数量
	StartAt time.Time //数据开始时间
}

type PullKlineMysql struct {
	Config PullKlineConfig
	DB     *xorms.Engine
	// contains filtered or unexported fields
}

type PullTrade struct {
	Dir string
}

type THSFactor struct {
	Date    int64   `json:"date"`     //时间
	QFactor float64 `json:"q_factor"` //前复权因子
	HFactor float64 `json:"h_factor"` //后复权因子
}