global

type Action = string

type ApiKey = string

type AssetsData struct {
	ID int64 // 时间(K线棒id)
}

type AssetsService struct {
}

type AssignUpdateInfo struct {
	StartTime    Timestamp    // 开始更新的时间戳,默认为0时,从最开始的时间更新
	EndTime      Timestamp    // 结束更新的时间戳,默认为0时,更新到最新时间
	DataSourceID DataSourceID // 数据源ID号(数据源唯一ID),更新时使用该数据源进行更新数据
}

type Config struct {
	DataServiceName string                         // 给数据服务起一个独立的名字
	LogLevel        string                         // 日志级别
	DataStoragePath string                         // 文件缓存的保存路径,如:"./"即为当前项目执行目录
	DataSource      map[DataSourceID]DataSource    // 数据源信息,TAG字段必须按照标准常量输出赋值,否则出错
	UserSecret      UserSecret                     // 托管账户和秘钥
	AssignUpdate    map[DataIndex]AssignUpdateInfo // 指定更新的币种信息,如果为空就是不指定,如果指定了系统只更新指定的币种信息
}

type DataIndex struct {
	Action   string // 类型,Kline,Trade,Depth,Assets,Order
	Platform string // 交易所,数据源
	Symbol   string // 交易对
}

type DataSource struct {
	// 数据源的唯一标识,对应数据源的名称,
	Tag string

	// 方便人类查看的数据源名称
	Name string

	// 当前数据源是否开启状态
	EnableSource bool

	// 数据源的基础连接地址
	Urls Urls

	// 连接该数据源所需要的密码,例如连接master需要密码验证登录
	Password string

	// 数据源公共接口方法
	DSAction DataSourceAction
}

type DataSourceAction interface {
	// 设置每个数据源的配置信息
	SetConfig(conf Config)

	// 获取数据源提供的所有交易对列表
	GetSymbolList(dsID DataSourceID) (ss []Symbol, err error)

	// UpdataKlineFileCache 更新K线数据的文件缓存 (Kline,Trade,Depth)
	/*
		参数: di 数据索引
		参数: sTime 更新的开始时间
		参数: eTime 更新的截止时间
		返回值: kbs 返回KlineBar指针的Slice
	*/
	UpdataKlineFileCache(uParam UpdataFileCacheParam, sTime, eTime Timestamp, upStatus chan bool)

	// UpdataKlineFileCache 更新K线数据的文件缓存 (Kline,Trade,Depth)
	/*
		参数: di 数据索引
		参数: sTime 更新的开始时间
		参数: eTime 更新的截止时间
		返回值: kbs 返回KlineBar指针的Slice
	*/
	UpdataTradeFileCache(uParam UpdataFileCacheParam, sTime, eTime Timestamp) (err error)

	// GetKlineBarSlice 获取K线数据列表 (Kline,Trade,Depth)
	/*
		参数: di 数据索引
		参数: sTime 更新的开始时间
		参数: eTime 更新的截止时间
		返回值: kbs 返回KlineBar指针的Slice
	*/
	GetKlineBarSlice(di DataIndex, sTime, eTime Timestamp) (kbs KlineBarSlice, err error)

	// GetTradeSlice 获取K线数据列表 (Kline,Trade,Depth)
	/*
		参数: di 数据索引
		参数: sTime 更新的开始时间
		参数: eTime 更新的截止时间
		返回值: kbs 返回KlineBar指针的Slice
	*/
	GetTradeSlice(di DataIndex, sTime, eTime Timestamp) (kbs KlineBarSlice, err error)

	// KlineRealTimeLine 创建长链接持续提供Kline数据(数据类型为:Kline,Trade,Depth)
	/*
		参数: kp 只能传入一个数据源(当前的数据源),多个币种可同时返回数据
		参数: rsDataChan 返回数据的接收管道,当有数据返回时会给该管道输出数据
	*/
	KlineRealTimeLine(kp RealTimeDataParam, rsData chan KlineRealTimeData)

	// TradeRealTimeLink 创建长链接持续提供Trade数据(数据类型为:Kline,Trade,Depth)
	/*
		参数: kp 只能传入一个数据源(当前的数据源),多个币种可同时返回数据
		参数: rsDataChan 返回数据的接收管道,当有数据返回时会给该管道输出数据
	*/
	TradeRealTimeLink(kp RealTimeDataParam, rsData chan TradeRealTimeData)

	// DepthRealTimeLink 创建长链接持续提供Depth数据(数据类型为:Kline,Trade,Depth)
	/*
		参数: kp 只能传入一个数据源(当前的数据源),多个币种可同时返回数据
		参数: rsDataChan 返回数据的接收管道,当有数据返回时会给该管道输出数据
	*/
	DepthRealTimeLink(kp RealTimeDataParam, rsData chan DepthRealTimeData)
}

type DataSourceID = uint64

type DateTimeDay = string // 日的日期格式,如: "20060102"

type DateTimeHour = string // 小时的日期格式,如: "2006010215"

type DateTimeMinute = string // 分钟的日期格式,如: "200601021504"

type DateTimeMonth = string // 月的日期格式,如: "200601"

type DateTimeSecond = string // 秒钟的日期格式,如: "20060102150405"

type DateTimeYear = string // 年的日期格式,如: "2006"

type DepthData struct {
	Asks []*DepthInfo // 卖方深度列表
	Bids []*DepthInfo // 买方深度列表
}

type DepthInfo struct {
	Price  float64 // 价格
	Amount float64 // 数量
}

type DepthRealTimeData struct {
	Ts    Timestamp
	Items map[Platform]map[Symbol]DepthData
}

type DepthRealTimeDataParam struct {
	Platforms Platform
	Symbols   []Symbol
}

type KlineBar struct {
	Ts    Timestamp // 时间戳(单位:秒)
	Open  float64   // 开盘价
	High  float64   // 最高价
	Low   float64   // 最低价
	Close float64   // 收盘价,当K线为最晚的一根时，是最新成交价
	Vol   float64   // 以基础币种计量的交易量
}

type KlineBarList struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type KlineBarSlice []*KlineBar

type KlineData struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type KlineRealTimeData struct {
	Ts    Timestamp
	Items map[Platform]map[Symbol]KlineBar
}

type KlineToFileCache struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type OrderData struct {
	ID int64 // 时间(K线棒id)
}

type OrderService struct {
}

type Platform = string

type RealTimeDataParam struct {
	Platforms Platform
	Symbols   []Symbol
}

type SecretKey = string

type SupplySymbol map[Platform][]SymbolInfo

type Symbol = string

type SymbolInfo struct {
	Symbol        string // 交易对名称
	BaseCurrency  string // 交易基础币名称
	QuoteCurrency string // 计价币名称

	MinSize float64 // 最小交易数量
	MaxSize float64 // 最大交易数量

	PricePrecision  uint // 基础币种报价精度
	AmountPrecision uint // 计价币种报价精度

	MinOrderValue float64 // 最小订单金额=最小交易额*最小交易量
	MaxOrderValue float64 // 最大下单金额=最大交易额*最大交易量

	TickSize uint // 交易价格精度(小数点后位数，默认为10位)
}

type Timestamp = int64

type TradeData struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type TradeInfo struct {
	ID     int64   // 成交id(唯一)
	Ts     int64   // 成交时间(毫秒)
	Side   string  // 交易方向 buy,shell
	Price  float64 // 成交价格
	Amount float64 // 成交数量
}

type TradeRealTimeData struct {
	Ts    Timestamp
	Items map[Platform]map[Symbol]TradeInfo
}

type TradeRealTimeDataParam struct {
	Platforms Platform
	Symbols   []Symbol
}

type UpdataFileCacheParam struct {
	Platform Platform
	Symbol   Symbol
}

type Urls struct {
	Http string // RestAPI 访问地址
	WS   string // WebSocket 访问地址
}

type UserSecret map[Platform]map[ApiKey]struct {

	// 人类能看懂的名字
	Name string

	// 私有接口的ApiKey
	ApiKey ApiKey

	// 私有接口的ApiKey
	SecretKey SecretKey

	// 是否启用
	Enable bool
}