update

Documentation

Index

• Constants
• func DaemonService()
• func IsSubNewStock(securityCode, date string) bool
• func IsSubNewStockByIpoDate(securityCode, ipoDate, date string) bool
• func RealtimeUpdateSnapshot(pbarIndex *int, modName string)
• func RepairExchange(pbarIndex *int, start, end string)
• func RepairF10(pbarIndex *int, start, end string)
• func StockUpdateBasicKLine(pbarIndex *int)
• func StockUpdateKLineWithQfq(pbarIndex *int)
• func StockUpdateRealtimeBasicKLine(pbarIndex *int)
• func StockUpdateRealtimeKLine(pbarIndex *int)
• func StockUpdateWideKLine(pbarIndex *int)
• func StockUpdateXdxr(pbarIndex *int)
• func UpdateAllData(pbarIndex *int)
• func UpdateExchange(pbarIndex *int)
• func UpdateExchangeFundFlow(pbarIndex *int)
• func UpdateExchangeKLineExtend(pbarIndex *int)
• func UpdateF10(pbarIndex *int)
• func UpdateF10Notices(pbarIndex *int)
• func UpdateFinanceReports(pbarIndex *int)
• func UpdateHistoryTransaction(isToday bool, pbarIndex *int)
• func UpdateKLine(pbarIndex *int)
• func UpdateStockSnapshot(pbarIndex *int)
• type RiskAssessmentInfo
• type Scheduler
  • func NewScheduler(interval int, service func()) *Scheduler
  • func (this *Scheduler) Run() error

Constants

const (
	SubNewStockYears = 1 // 次新股几年内
)

Functions

func DaemonService

func DaemonService()

DaemonService 执行守护进程服务

func IsSubNewStock

func IsSubNewStock(securityCode, date string) bool

IsSubNewStock 检查是否次新股

func IsSubNewStockByIpoDate

func IsSubNewStockByIpoDate(securityCode, ipoDate, date string) bool

IsSubNewStockByIpoDate 检查是否次新股

func RealtimeUpdateSnapshot

func RealtimeUpdateSnapshot(pbarIndex *int, modName string)

RealtimeUpdateSnapshot 更新快照缓存

func RepairExchange

func RepairExchange(pbarIndex *int, start, end string)

RepairExchange 修补扩展交易数据

func RepairF10

func RepairF10(pbarIndex *int, start, end string)

RepairF10 修补F10基础数据

func StockUpdateBasicKLine

func StockUpdateBasicKLine(pbarIndex *int)

StockUpdateBasicKLine 更新日线

func StockUpdateKLineWithQfq

func StockUpdateKLineWithQfq(pbarIndex *int)

StockUpdateKLineWithQfq 更新日线-前复权

func StockUpdateRealtimeBasicKLine

func StockUpdateRealtimeBasicKLine(pbarIndex *int)

StockUpdateRealtimeBasicKLine 更新K线数据

func StockUpdateRealtimeKLine

func StockUpdateRealtimeKLine(pbarIndex *int)

StockUpdateRealtimeKLine 更新K线数据

func StockUpdateWideKLine

func StockUpdateWideKLine(pbarIndex *int)

StockUpdateWideKLine 更新日线

func StockUpdateXdxr

func StockUpdateXdxr(pbarIndex *int)

StockUpdateXdxr 除权除息

func UpdateAllData

func UpdateAllData(pbarIndex *int)

UpdateAllData 更新全部数据

func UpdateExchange

func UpdateExchange(pbarIndex *int)

UpdateExchange 更新快照扩展数据

func UpdateExchangeFundFlow

func UpdateExchangeFundFlow(pbarIndex *int)

UpdateExchangeFundFlow 资金流向

func UpdateExchangeKLineExtend

func UpdateExchangeKLineExtend(pbarIndex *int)

UpdateExchangeKLineExtend 更新扩展数据

只能当天更新给下一个交易日使用

func UpdateF10

func UpdateF10(pbarIndex *int)

UpdateF10 更新基础数据

func UpdateF10Notices

func UpdateF10Notices(pbarIndex *int)

UpdateF10Notices 评估上市公司公告的风险等级

func UpdateFinanceReports

func UpdateFinanceReports(pbarIndex *int)

UpdateFinanceReports 更新财务报告

func UpdateHistoryTransaction

func UpdateHistoryTransaction(isToday bool, pbarIndex *int)

UpdateHistoryTransaction 成交数据

func UpdateKLine

func UpdateKLine(pbarIndex *int)

UpdateKLine 更新K线

func UpdateStockSnapshot

func UpdateStockSnapshot(pbarIndex *int)

UpdateStockSnapshot 更新快照数据

Types

type RiskAssessmentInfo

type RiskAssessmentInfo struct {
	Code  string // 股票代码
	Score int    // 测评分
}

RiskAssessmentInfo 风险评估 - 安全分

type Scheduler

type Scheduler struct {
	// contains filtered or unexported fields
}

func NewScheduler

func NewScheduler(interval int, service func()) *Scheduler

NewScheduler 创建一个业务定时器

func (*Scheduler) Run

func (this *Scheduler) Run() error