service

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Feb 26, 2023 License: MIT Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CalRoutinePoolSize = 30
View Source 
var DaylineHeader = []string{"id", "trade_date", "open", "high", "low", "close", "amount", "vol", "turnover",
	"main_net_inflow", "small_net_inflow", "middle_net_inflow", "large_net_inflow", "super_net_inflow",
	"pct_chg_open", "pct_chg_high", "pct_chg_low", "pct_chg_close", "pct_chg_amount", "pct_chg_vol",
	"pct_main_net_inflow", "pct_small_net_inflow", "pct_middle_net_inflow", "pct_large_net_inflow", "pct_super_net_inflow"}
View Source 
var NetRoutinePoolSize = 20
View Source 
var WmqylineHeader = []string{"ts_code", "security_name", "qdate", "share_number", "ep", "high", "close", "pct_chg_high",
	"pct_chg_close", "weight_avg_roe", "gross_profit_margin", "parent_net_profit", "basic_eps",
	"or_last_month", "np_last_month", "yoy_sales", "yoy_dedu_np", "cfps", "dividend_yield_ratio"}

Functions

func ForecastFastGet 

func ForecastFastGet(requestParam ForecastRequestParam) ([]byte, error)

func GetCacheFilterCond 

func GetCacheFilterCond() map[string]*entity.FilterCond

func GetCachePinYin 

func GetCachePinYin() map[string]*entity.PinYin

func RefreshCacheFilterCond 

func RefreshCacheFilterCond()

func RefreshCachePinYin 

func RefreshCachePinYin()

Types

type AccValue 

type AccValue struct {
	PctChgMarketValue float64
	YoyDeduNp         float64
	YoySales          float64
	OrLastMonth       float64
	NpLastMonth       float64
	Pe                float64
	Peg               float64
}

type BalanceSheetService 

type BalanceSheetService struct {
	service.OrmBaseService
}

* 同步表结构，服务继承基本服务的方法

func GetBalanceSheetService 

func GetBalanceSheetService() *BalanceSheetService

func (*BalanceSheetService) GetSeqName 

func (this *BalanceSheetService) GetSeqName() string

func (*BalanceSheetService) NewEntities 

func (this *BalanceSheetService) NewEntities(data []byte) (interface{}, error)

func (*BalanceSheetService) NewEntity 

func (this *BalanceSheetService) NewEntity(data []byte) (interface{}, error)

type CashFlowService 

type CashFlowService struct {
	service.OrmBaseService
}

* 同步表结构，服务继承基本服务的方法

func GetCashFlowService 

func GetCashFlowService() *CashFlowService

func (*CashFlowService) GetSeqName 

func (this *CashFlowService) GetSeqName() string

func (*CashFlowService) NewEntities 

func (this *CashFlowService) NewEntities(data []byte) (interface{}, error)

func (*CashFlowService) NewEntity 

func (this *CashFlowService) NewEntity(data []byte) (interface{}, error)

type DayLineService 

type DayLineService struct {
	service.OrmBaseService
}

* 同步表结构，服务继承基本服务的方法

func GetDayLineService 

func GetDayLineService() *DayLineService

func (*DayLineService) Aggregation 

func (this *DayLineService) Aggregation(dayLines []*entity.DayLine) (map[stock.AggregationType]*entity.DayLine, []interface{}, []interface{})

func (*DayLineService) AsyncParseFile 

func (this *DayLineService) AsyncParseFile(para interface{})

func (*DayLineService) AsyncStdFile 

func (this *DayLineService) AsyncStdFile(para interface{})

func (*DayLineService) AsyncUpdateBeforeMa 

func (this *DayLineService) AsyncUpdateBeforeMa(para interface{})

func (*DayLineService) AsyncUpdateDayLine 

func (this *DayLineService) AsyncUpdateDayLine(para interface{})

func (*DayLineService) AsyncUpdateStat 

func (this *DayLineService) AsyncUpdateStat(para interface{})

func (*DayLineService) AsyncWriteFile 

func (this *DayLineService) AsyncWriteFile(para interface{})

func (*DayLineService) FindAllInOutEvent 

func (this *DayLineService) FindAllInOutEvent(ts_code string, eventCode string, startDate int64, endDate int64, compareValue float64, condNum int) map[string][]*entity.DayLine

func (*DayLineService) FindCorr 

func (this *DayLineService) FindCorr(ts_code string, startDate int64, from int, limit int, orderby string, count int64) ([]*entity.PortfolioStat, int64, error)

* 查找收盘价相关性的股票

func (*DayLineService) FindFlexPoint 

func (this *DayLineService) FindFlexPoint(ts_code string, tradedate int64, fields []string, eventContent string, filterParas []interface{}, startDate int64, endDate int64, from int, limit int, count int64) (*InOutPoint, error)

func (*DayLineService) FindFollowing 

func (this *DayLineService) FindFollowing(ts_code string, startDate int64, endDate int64, from int, limit int, count int64) ([]*entity.DayLine, int64, error)

获取某时间点后limit条数据，如果没有日期范围的指定，就是返回最早limit条数据

func (*DayLineService) FindHighest 

func (this *DayLineService) FindHighest(ts_code string, dayCount string, startDate int64, from int, limit int, count int64) ([]*entity.DayLine, int64, error)

获取某时间点后，前后dayCount内的是最高点的，limit条数据

func (*DayLineService) FindInOutEvent 

func (this *DayLineService) FindInOutEvent(ts_code string, tradedate int64, eventCode string, filterParas []interface{}, startDate int64, endDate int64, compareValue float64, condNum int, from int, limit int, count int64) (*InOutPoint, error)

func (*DayLineService) FindLowest 

func (this *DayLineService) FindLowest(ts_code string, dayCount string, startDate int64, from int, limit int, count int64) ([]*entity.DayLine, int64, error)

获取某时间点后，前后dayCount内的是最高点的，limit条数据

func (*DayLineService) FindMaCross 

func (this *DayLineService) FindMaCross(ts_code string, srcDayCount string, targetDayCount string, startDate int64, cross string, from int, limit int, count int64) ([]*entity.DayLine, int64, error)

获取某时间点后，两dayCount均线交叉的，limit条数据

func (*DayLineService) FindModelData 

func (this *DayLineService) FindModelData(ts_code string, industry string, startDate int64) ([]*entity.DayLine, error)

* 获取某只股票最新的日期

func (*DayLineService) FindPreceding 

func (this *DayLineService) FindPreceding(ts_code string, endDate int64, from int, limit int, count int64) ([]*entity.DayLine, int64, error)

* 获取某时间点前limit条数据，如果没有日期范围的指定，就是返回最新的回溯limit条数据

func (*DayLineService) FindRange 

func (this *DayLineService) FindRange(ts_code string, startDate int64, endDate int64, limit int) ([]*entity.DayLine, error)

获取某时间点前后limit条数据

func (*DayLineService) GetDayLine 

func (this *DayLineService) GetDayLine(secId string, beg int, end int, limit int, previous *entity.DayLine) ([]*entity.DayLine, error)

* 获取某只股票的日线数据

func (*DayLineService) GetFinanceFlow 

func (this *DayLineService) GetFinanceFlow(secId string, beg int, limit int) ([]*entity.DayLine, error)

* 获取某只股票的日线资金流动数据，最多6个月的数据

func (*DayLineService) GetKLine 

func (this *DayLineService) GetKLine(secId string, beg int, end int, limit int, klt int) ([]string, error)

* 获取某只股票的分钟线到年线的数据

func (*DayLineService) GetSeqName 

func (this *DayLineService) GetSeqName() string

func (*DayLineService) GetUpdateDayline 

func (this *DayLineService) GetUpdateDayline(secId string, beg int64, limit int) ([]*entity.DayLine, error)

* 当天15点之前缺当天资金流数据

func (*DayLineService) LoadFile 

func (this *DayLineService) LoadFile(src string, startDate int64, endDate int64, filename string) ([]*entity.DayLine, error)

func (*DayLineService) NewEntities 

func (this *DayLineService) NewEntities(data []byte) (interface{}, error)

func (*DayLineService) NewEntity 

func (this *DayLineService) NewEntity(data []byte) (interface{}, error)

func (*DayLineService) ParseByte 

func (this *DayLineService) ParseByte(shareId string, content []byte) []interface{}

func (*DayLineService) ParseFile 

func (this *DayLineService) ParseFile(src string, target string, filename string, flag int) error

func (*DayLineService) ParsePath 

func (this *DayLineService) ParsePath(src string, target string) error

* 读目录下的数据

func (*DayLineService) RefreshBeforeMa 

func (this *DayLineService) RefreshBeforeMa(startDate int64) error

* 刷新所有股票的日线统计数据，包括移动平均，累计增长，均值，相对标准差

func (*DayLineService) RefreshDayLine 

func (this *DayLineService) RefreshDayLine(beg int64) error

* 刷新所有股票的日线数据，beg为负数的时候从已有的最新数据开始更新

func (*DayLineService) RefreshStat 

func (this *DayLineService) RefreshStat(startDate int64) error

* 刷新所有股票的日线统计数据，包括移动平均，累计增长，均值，相对标准差

func (*DayLineService) Search 

func (this *DayLineService) Search(ts_code string, industry string, sector string, startDate int64, endDate int64, orderby string, from int, limit int, count int64) ([]*entity.DayLine, int64, error)

func (*DayLineService) StdFile 

func (this *DayLineService) StdFile(startDate int64, endDate int64, filename string, minmax string, standard string) (map[stock.AggregationType]*entity.DayLine, error)

func (*DayLineService) StdPath 

func (this *DayLineService) StdPath(src string, minmax string, standard string, startDate int64, endDate int64) error

* src: "C:\stock\data\origin\lday" minmax: "C:\stock\data\minmax\lday" standard: "C:\stock\data\standard\lday"

func (*DayLineService) UpdateBeforeMa 

func (this *DayLineService) UpdateBeforeMa(tscode string, startDate int64) (int64, error)

* 填充过去1，3，5天的各移动平均值

func (*DayLineService) UpdateDayline 

func (this *DayLineService) UpdateDayline(secId string, beg int64, limit int) ([]*entity.DayLine, error)

func (*DayLineService) UpdateFinanceFlow 

func (this *DayLineService) UpdateFinanceFlow(dayLines []*entity.DayLine, secId string, beg int, limit int) ([]*entity.DayLine, error)

func (*DayLineService) UpdateStat 

func (this *DayLineService) UpdateStat(tscode string, startDate int64) (int64, error)

func (*DayLineService) WriteAllFile 

func (this *DayLineService) WriteAllFile(startDate int64) error

func (*DayLineService) WriteFile 

func (this *DayLineService) WriteFile(src string, ts_code string, startDate int64) error

type EventCondService 

type EventCondService struct {
	service.OrmBaseService
}

* 同步表结构，服务继承基本服务的方法

func GetEventCondService 

func GetEventCondService() *EventCondService

func (*EventCondService) AsyncUpdateEventCond 

func (this *EventCondService) AsyncUpdateEventCond(para interface{})

func (*EventCondService) FindGroupby 

func (this *EventCondService) FindGroupby(tscode string, startDate int64, endDate int64, eventCode string, eventType string, orderby string, from int, limit int, count int64) ([]*entity.EventCond, int64, error)

func (*EventCondService) GetSeqName 

func (this *EventCondService) GetSeqName() string

func (*EventCondService) GetUpdateEventCond 

func (this *EventCondService) GetUpdateEventCond(tscode string) []interface{}

func (*EventCondService) NewEntities 

func (this *EventCondService) NewEntities(data []byte) (interface{}, error)

func (*EventCondService) NewEntity 

func (this *EventCondService) NewEntity(data []byte) (interface{}, error)

func (*EventCondService) RefreshEventCond 

func (this *EventCondService) RefreshEventCond() error

func (*EventCondService) Search 

func (this *EventCondService) Search(tscode string, startDate int64, endDate int64, eventCode string, eventType string, orderby string, from int, limit int, count int64) ([]*entity.EventCond, int64, error)

type EventFilterService 

type EventFilterService struct {
	service.OrmBaseService
}

* 同步表结构，服务继承基本服务的方法

func GetEventFilterService 

func GetEventFilterService() *EventFilterService

func (*EventFilterService) GetCacheEventFilter 

func (this *EventFilterService) GetCacheEventFilter() map[string][]*entity.EventFilter

func (*EventFilterService) GetSeqName 

func (this *EventFilterService) GetSeqName() string

func (*EventFilterService) NewEntities 

func (this *EventFilterService) NewEntities(data []byte) (interface{}, error)

func (*EventFilterService) NewEntity 

func (this *EventFilterService) NewEntity(data []byte) (interface{}, error)

func (*EventFilterService) RefreshCacheEventFilter 

func (this *EventFilterService) RefreshCacheEventFilter()

type EventService 

type EventService struct {
	service.OrmBaseService
}

* 同步表结构，服务继承基本服务的方法

func GetEventService 

func GetEventService() *EventService

func (*EventService) GetCacheEvent 

func (this *EventService) GetCacheEvent() map[string]*entity.Event

func (*EventService) GetSeqName 

func (this *EventService) GetSeqName() string

func (*EventService) NewEntities 

func (this *EventService) NewEntities(data []byte) (interface{}, error)

func (*EventService) NewEntity 

func (this *EventService) NewEntity(data []byte) (interface{}, error)

func (*EventService) RefreshCacheEvent 

func (this *EventService) RefreshCacheEvent()

type ExpressResponse 

type ExpressResponse struct {
	SecurityCode         string  `json:"SECURITY_CODE"`
	SecurityNameAbbr     string  `json:"SECURITY_NAME_ABBR"`
	TradeMarketCode      string  `json:"TRADE_MARKET_CODE"`
	TradeMarket          string  `json:"TRADE_MARKET"`
	SecurityTypeCode     string  `json:"SECURITY_TYPE_CODE"`
	SecurityType         string  `json:"SECURITY_TYPE"`
	NewestDate           string  `json:"UPDATE_DATE"`
	ReportDate           string  `json:"REPORT_DATE"`
	BasicEps             float64 `json:"BASIC_EPS"`               //每股收益
	DeductBasicEps       float64 `json:"DEDUCT_BASIC_EPS"`        //每股扣非收益
	TotalOperateIncome   float64 `json:"TOTAL_OPERATE_INCOME"`    //营收
	TotalOperateIncomeSq float64 `json:"TOTAL_OPERATE_INCOME_SQ"` //去年同期(元)
	ParentNetProfit      float64 `json:"PARENT_NETPROFIT"`        //归母净利润
	ParentNetProfitSq    float64 `json:"PARENT_NETPROFIT_SQ"`     //去年同期(元)
	ParentBvps           float64 `json:"PARENT_BVPS"`             //每股净资产
	WeightAvgRoe         float64 `json:"WEIGHTAVG_ROE"`           //净资产收益率
	YoySales             float64 `json:"YSTZ"`                    //收入同比增长
	YoyNetProfit         float64 `json:"JLRTBZCL"`                //净利润同比增长
	OrLastMonth          float64 `json:"DJDYSHZ"`                 //收入季度环比增长
	NpLastMonth          float64 `json:"DJDJLHZ"`                 //利润季度环比增长
	PublishName          string  `json:"PUBLISHNAME"`
	NoticeDate           string  `json:"NOTICE_DATE"`
	OrgCode              string  `json:"ORG_CODE"`
	Market               string  `json:"MARKET"`
	IsNew                string  `json:"ISNEW"`
	QDate                string  `json:"QDATE"`
	NDate                string  `json:"NDATE"`
	DataType             string  `json:"DATATYPE"`
	DataYear             string  `json:"DATAYEAR"`
	DateMmDd             string  `json:"DATEMMDD"`
	EITime               string  `json:"EITIME"`
	SecuCode             string  `json:"SECUCODE"`
}

type ExpressResponseData 

type ExpressResponseData struct {
	eastmoney.ReportResponseData
	Data []*ExpressResponse `json:"data,omitempty"`
}

type ExpressResponseResult 

type ExpressResponseResult struct {
	eastmoney.ReportResponseResult
	Result *ExpressResponseData `json:"result,omitempty"`
}

type ExpressService 

type ExpressService struct {
	service.OrmBaseService
}

* 同步表结构，服务继承基本服务的方法

func GetExpressService 

func GetExpressService() *ExpressService

func (*ExpressService) AsyncUpdateExpress 

func (this *ExpressService) AsyncUpdateExpress(para interface{})

func (*ExpressService) FindByQDate 

func (this *ExpressService) FindByQDate(securityCode string, startDate string, endDate string, orderby string) (map[string][]*entity.Express, error)

func (*ExpressService) FindLatest 

func (this *ExpressService) FindLatest(securityCode string, latestDate string, orderby string, from int, limit int, count int64) ([]*entity.Express, int64, error)

func (*ExpressService) GetSeqName 

func (this *ExpressService) GetSeqName() string

func (*ExpressService) GetUpdateExpress 

func (this *ExpressService) GetUpdateExpress(securityCode string) ([]interface{}, error)

func (*ExpressService) NewEntities 

func (this *ExpressService) NewEntities(data []byte) (interface{}, error)

func (*ExpressService) NewEntity 

func (this *ExpressService) NewEntity(data []byte) (interface{}, error)

func (*ExpressService) RefreshExpress 

func (this *ExpressService) RefreshExpress() error

func (*ExpressService) Search 

func (this *ExpressService) Search(securityCode string, startDate string, endDate string, orderby string, from int, limit int, count int64) ([]*entity.Express, int64, error)

func (*ExpressService) UpdateExpress 

func (this *ExpressService) UpdateExpress(securityCode string) ([]interface{}, error)

type FilterCondService 

type FilterCondService struct {
	service.OrmBaseService
}

* 同步表结构，服务继承基本服务的方法

func GetFilterCondService 

func GetFilterCondService() *FilterCondService

func (*FilterCondService) GetSeqName 

func (this *FilterCondService) GetSeqName() string

func (*FilterCondService) NewEntities 

func (this *FilterCondService) NewEntities(data []byte) (interface{}, error)

func (*FilterCondService) NewEntity 

func (this *FilterCondService) NewEntity(data []byte) (interface{}, error)

type FminLineService 

type FminLineService struct {
	service.OrmBaseService
}

* 同步表结构，服务继承基本服务的方法

func GetFminLineService 

func GetFminLineService() *FminLineService

func (*FminLineService) AsyncParseFile 

func (this *FminLineService) AsyncParseFile(para interface{})

func (*FminLineService) GetSeqName 

func (this *FminLineService) GetSeqName() string

func (*FminLineService) NewEntities 

func (this *FminLineService) NewEntities(data []byte) (interface{}, error)

func (*FminLineService) NewEntity 

func (this *FminLineService) NewEntity(data []byte) (interface{}, error)

func (*FminLineService) ParseByte 

func (this *FminLineService) ParseByte(shareId string, content []byte) []*entity.FminLine

func (*FminLineService) ParseFile 

func (this *FminLineService) ParseFile(src string, target string, filename string, flag int) error

func (*FminLineService) ParsePath 

func (this *FminLineService) ParsePath(src string, target string) error

* 读目录下的数据

func (*FminLineService) ToCsv 

func (this *FminLineService) ToCsv(fminLines []*entity.FminLine) string

type ForecastRequestParam 

type ForecastRequestParam struct {
	Callback    string `json:"callback"`
	SortColumns string `json:"sortColumns"` //排序的字段，逗号分隔
	SortTypes   string `json:"sortTypes"`   //-1降序，1升序，逗号分隔
	PageSize    string `json:"pageSize"`    //每页的记录数
	PageNumber  int    `json:"pageNumber"`  //页数
	ReportName  string `json:"reportName"`  //获取的数据类型
	Columns     string `json:"columns"`     //获取的字段，ALL
	Token       string `json:"token"`
	Filter      string `json:"filter,omitempty"` //条件
}

type ForecastResponse 

type ForecastResponse struct {
	SecuCode            string  `json:"SECUCODE"`
	SecurityCode        string  `json:"SECURITY_CODE"`
	SecurityNameAbbr    string  `json:"SECURITY_NAME_ABBR"`
	TradeMarketCode     string  `json:"TRADE_MARKET_CODE"`
	TradeMarket         string  `json:"TRADE_MARKET"`
	SecurityTypeCode    string  `json:"SECURITY_TYPE_CODE"`
	SecurityType        string  `json:"SECURITY_TYPE"`
	NoticeDate          string  `json:"NOTICE_DATE"`
	OrgCode             string  `json:"ORG_CODE"`
	ReportDate          string  `json:"REPORT_DATE"`
	QDate               string  `json:"QDATE"`
	NDate               string  `json:"NDATE"`
	PredictFinanceCode  string  `json:"PREDICT_FINANCE_CODE"`
	PredictFinance      string  `xorm:"varchar(1024)" json:"PREDICT_FINANCE"`
	PredictAmtLower     float64 `json:"PREDICT_AMT_LOWER"`
	PredictAmtUpper     float64 `json:"PREDICT_AMT_UPPER"`
	AddAmpLower         float64 `json:"ADD_AMP_LOWER"`
	AddAmpUpper         float64 `json:"ADD_AMP_UPPER"`
	PredictContent      string  `xorm:"varchar(32000)" json:"PREDICT_CONTENT"`
	ChangeReasonExplain string  `xorm:"varchar(32000)" json:"CHANGE_REASON_EXPLAIN"`
	PredictType         string  `json:"PREDICT_TYPE"`
	PreYearSamePeriod   float64 `json:"PREYEAR_SAME_PERIOD"`
	IncreaseAvg         float64 `json:"INCREASE_JZ"`
	ForecastAvg         float64 `json:"FORECAST_JZ"`
	ForecastState       string  `json:"FORECAST_STATE"`
	IsLatest            string  `json:"IS_LATEST"`
}

type ForecastResponseData 

type ForecastResponseData struct {
	eastmoney.ReportResponseData
	Data []*ForecastResponse `json:"data,omitempty"`
}

type ForecastResponseResult 

type ForecastResponseResult struct {
	eastmoney.ReportResponseResult
	Result *ForecastResponseData `json:"result,omitempty"`
}

type ForecastService 

type ForecastService struct {
	service.OrmBaseService
}

* 同步表结构，服务继承基本服务的方法

func GetForecastService 

func GetForecastService() *ForecastService

func (*ForecastService) AsyncUpdateForecast 

func (this *ForecastService) AsyncUpdateForecast(para interface{})

func (*ForecastService) FindByQDate 

func (this *ForecastService) FindByQDate(securityCode string, startDate string, endDate string, orderby string) (map[string][]*entity.Forecast, error)

func (*ForecastService) FindLatest 

func (this *ForecastService) FindLatest(securityCode string, latestDate string, orderby string, from int, limit int, count int64) ([]*entity.Forecast, int64, error)

func (*ForecastService) GetSeqName 

func (this *ForecastService) GetSeqName() string

func (*ForecastService) GetUpdateForecast 

func (this *ForecastService) GetUpdateForecast(securityCode string) ([]interface{}, error)

func (*ForecastService) NewEntities 

func (this *ForecastService) NewEntities(data []byte) (interface{}, error)

func (*ForecastService) NewEntity 

func (this *ForecastService) NewEntity(data []byte) (interface{}, error)

func (*ForecastService) RefreshForecast 

func (this *ForecastService) RefreshForecast() error

func (*ForecastService) Search 

func (this *ForecastService) Search(securityCode string, startDate string, endDate string, orderby string, from int, limit int, count int64) ([]*entity.Forecast, int64, error)

func (*ForecastService) UpdateForecast 

func (this *ForecastService) UpdateForecast(securityCode string) ([]interface{}, error)

type InOutPoint 

type InOutPoint struct {
	Data      []*entity.DayLine        `json:"data,omitempty"`
	CondValue []map[string]interface{} `json:"cond_value,omitempty"`
	Count     int64                    `json:"count,omitempty"`
}

type IncomeService 

type IncomeService struct {
	service.OrmBaseService
}

* 同步表结构，服务继承基本服务的方法

func GetIncomeService 

func GetIncomeService() *IncomeService

func (*IncomeService) GetSeqName 

func (this *IncomeService) GetSeqName() string

func (*IncomeService) NewEntities 

func (this *IncomeService) NewEntities(data []byte) (interface{}, error)

func (*IncomeService) NewEntity 

func (this *IncomeService) NewEntity(data []byte) (interface{}, error)

type LineType 

type LineType int64
const (
	LineType_Day LineType = iota + 1
	LineType_Wmqy
)

type MinLineService 

type MinLineService struct {
	service.OrmBaseService
}

* 同步表结构，服务继承基本服务的方法

func GetMinLineService 

func GetMinLineService() *MinLineService

func (*MinLineService) AsyncParseFile 

func (this *MinLineService) AsyncParseFile(para interface{})

func (*MinLineService) AsyncUpdateMinLine 

func (this *MinLineService) AsyncUpdateMinLine(para interface{})

func (*MinLineService) AsyncUpdateTodayMinLine 

func (this *MinLineService) AsyncUpdateTodayMinLine(para interface{})

func (*MinLineService) Cron 

func (this *MinLineService) Cron() *cron.Cron

func (*MinLineService) FindMinLines 

func (this *MinLineService) FindMinLines(tscode string, tradeDate int64, tradeMinute int64) ([]*entity.MinLine, error)

* 除非当天的分钟数据全部获取，每次访问都要重新获取网络的分钟数据

func (*MinLineService) GetMinLine 

func (this *MinLineService) GetMinLine(secId string, beg int, limit int, klt int) ([]*entity.MinLine, error)

* 获取过去的分钟数据

func (*MinLineService) GetSeqName 

func (this *MinLineService) GetSeqName() string

func (*MinLineService) GetTodayFinanceFlow 

func (this *MinLineService) GetTodayFinanceFlow(secId string) ([]*entity.MinLine, error)

* 获取当日的资金流向分钟数据

func (*MinLineService) GetTodayMinLine 

func (this *MinLineService) GetTodayMinLine(secId string) ([]*entity.MinLine, error)

* 获取当日的分钟数据

func (*MinLineService) GetUpdateMinLine 

func (this *MinLineService) GetUpdateMinLine(secId string, beg int64, limit int) ([]*entity.MinLine, error)

func (*MinLineService) GetUpdateTodayMinLine 

func (this *MinLineService) GetUpdateTodayMinLine(secId string) ([]*entity.MinLine, error)

func (*MinLineService) NewEntities 

func (this *MinLineService) NewEntities(data []byte) (interface{}, error)

func (*MinLineService) NewEntity 

func (this *MinLineService) NewEntity(data []byte) (interface{}, error)

func (*MinLineService) ParseByte 

func (this *MinLineService) ParseByte(shareId string, content []byte) []*entity.MinLine

func (*MinLineService) ParseFile 

func (this *MinLineService) ParseFile(src string, target string, filename string, flag int) error

func (*MinLineService) ParsePath 

func (this *MinLineService) ParsePath(src string, target string) error

* 读目录下的数据

func (*MinLineService) RefreshMinLine 

func (this *MinLineService) RefreshMinLine(beg int64) error

func (*MinLineService) RefreshToday 

func (this *MinLineService) RefreshToday()

func (*MinLineService) RefreshTodayMinLine 

func (this *MinLineService) RefreshTodayMinLine() error

func (*MinLineService) ToCsv 

func (this *MinLineService) ToCsv(minLines []*entity.MinLine) string

func (*MinLineService) UpdateMinLine 

func (this *MinLineService) UpdateMinLine(secId string, beg int64, limit int) ([]*entity.MinLine, error)

func (*MinLineService) UpdateTodayFinanceFlow 

func (this *MinLineService) UpdateTodayFinanceFlow(minLines []*entity.MinLine, secId string) ([]*entity.MinLine, error)

func (*MinLineService) UpdateTodayMinLine 

func (this *MinLineService) UpdateTodayMinLine(secId string) ([]*entity.MinLine, error)

* 获取今天的分钟数据，并更新数据库

type PerformanceResponse 

type PerformanceResponse struct {
	SecurityCode       string  `json:"SECURITY_CODE"`
	SecurityNameAbbr   string  `json:"SECURITY_NAME_ABBR"`
	TradeMarketCode    string  `json:"TRADE_MARKET_CODE"`
	TradeMarket        string  `json:"TRADE_MARKET"`
	SecurityTypeCode   string  `json:"SECURITY_TYPE_CODE"`
	SecurityType       string  `json:"SECURITY_TYPE"`
	NewestDate         string  `json:"UPDATE_DATE"`
	ReportDate         string  `json:"REPORTDATE"`
	BasicEps           float64 `json:"BASIC_EPS"`            //每股收益
	DeductBasicEps     float64 `json:"DEDUCT_BASIC_EPS"`     //每股扣非收益
	TotalOperateIncome float64 `json:"TOTAL_OPERATE_INCOME"` //营收
	ParentNetProfit    float64 `json:"PARENT_NETPROFIT"`     //归母净利润
	WeightAvgRoe       float64 `json:"WEIGHTAVG_ROE"`        //净资产收益率
	YoySales           float64 `json:"YSTZ"`                 //应收同比增长
	YoyDeduNp          float64 `json:"SJLTZ"`                //扣非净利润同比增长
	Bps                float64 `json:"BPS"`                  //每股净资产
	Cfps               float64 `json:"MGJYXJJE"`             //每股经营现金流量(元)
	GrossprofitMargin  float64 `json:"XSMLL"`                //销售毛利率(%)
	OrLastMonth        float64 `json:"YSHZ"`                 //营业收入季度环比增长(%)
	NpLastMonth        float64 `json:"SJLHZ"`                //净利润季度环比增长(%)
	AssignDscrpt       string  `json:"ASSIGNDSCRPT"`
	PayYear            string  `json:"PAYYEAR"`
	PublishName        string  `json:"PUBLISHNAME"`
	DividendYieldRatio float64 `json:"ZXGXL"` //股息率
	NoticeDate         string  `json:"NOTICE_DATE"`
	OrgCode            string  `json:"ORG_CODE"`
	TradeMarketZJG     string  `json:"TRADE_MARKET_ZJG"`
	IsNew              string  `json:"ISNEW"`
	QDate              string  `json:"QDATE"`
	NDate              string  `json:"NDATE"`
	DataType           string  `json:"DATATYPE"`
	DataYear           string  `json:"DATAYEAR"`
	DateMmDd           string  `json:"DATEMMDD"`
	EITime             string  `json:"EITIME"`
	SecuCode           string  `json:"SECUCODE"`
}

type PerformanceResponseData 

type PerformanceResponseData struct {
	eastmoney.ReportResponseData
	Data []*PerformanceResponse `json:"data,omitempty"`
}

type PerformanceResponseResult 

type PerformanceResponseResult struct {
	eastmoney.ReportResponseResult
	Result *PerformanceResponseData `json:"result,omitempty"`
}

type PerformanceService 

type PerformanceService struct {
	service.OrmBaseService
}

* 同步表结构，服务继承基本服务的方法

func GetPerformanceService 

func GetPerformanceService() *PerformanceService

func (*PerformanceService) AsyncUpdatePerformance 

func (this *PerformanceService) AsyncUpdatePerformance(para interface{})

func (*PerformanceService) FindByQDate 

func (this *PerformanceService) FindByQDate(securityCode string, startDate string, endDate string, orderby string) (map[string][]*entity.Performance, error)

func (*PerformanceService) FindLatest 

func (this *PerformanceService) FindLatest(securityCode string, latestDate string, orderby string, from int, limit int, count int64) ([]*entity.Performance, int64, error)

func (*PerformanceService) GetSeqName 

func (this *PerformanceService) GetSeqName() string

func (*PerformanceService) GetUpdatePerformance 

func (this *PerformanceService) GetUpdatePerformance(securityCode string) ([]interface{}, error)

func (*PerformanceService) NewEntities 

func (this *PerformanceService) NewEntities(data []byte) (interface{}, error)

func (*PerformanceService) NewEntity 

func (this *PerformanceService) NewEntity(data []byte) (interface{}, error)

func (*PerformanceService) RefreshPerformance 

func (this *PerformanceService) RefreshPerformance() error

func (*PerformanceService) Search 

func (this *PerformanceService) Search(securityCode string, startDate string, endDate string, orderby string, from int, limit int, count int64) ([]*entity.Performance, int64, error)

func (*PerformanceService) UpdatePerformance 

func (this *PerformanceService) UpdatePerformance(securityCode string) ([]interface{}, error)

type PerformanceType 

type PerformanceType int64
const (
	PerformanceType_Performance PerformanceType = iota + 1
	PerformanceType_Express
	PerformanceType_Forecast
)

type PinYinService 

type PinYinService struct {
	service.OrmBaseService
}

* 同步表结构，服务继承基本服务的方法

func GetPinYinService 

func GetPinYinService() *PinYinService

func (*PinYinService) GetSeqName 

func (this *PinYinService) GetSeqName() string

func (*PinYinService) NewEntities 

func (this *PinYinService) NewEntities(data []byte) (interface{}, error)

func (*PinYinService) NewEntity 

func (this *PinYinService) NewEntity(data []byte) (interface{}, error)

type PortfolioStatService 

type PortfolioStatService struct {
	service.OrmBaseService
}

func GetPortfolioStatService 

func GetPortfolioStatService() *PortfolioStatService

func (*PortfolioStatService) AsyncUpdatePortfolioStat 

func (this *PortfolioStatService) AsyncUpdatePortfolioStat(para interface{})

func (*PortfolioStatService) FindPortfolioStat 

func (this *PortfolioStatService) FindPortfolioStat(ts_code string, term int64, from int, limit int, orderby string, count int64) ([]*entity.PortfolioStat, int64, error)

func (*PortfolioStatService) GetSeqName 

func (this *PortfolioStatService) GetSeqName() string

func (*PortfolioStatService) GetUpdatePortfolioStat 

func (this *PortfolioStatService) GetUpdatePortfolioStat(tscode string) ([]interface{}, error)

* 更新股票季度业绩统计数据，并返回结果

func (*PortfolioStatService) NewEntities 

func (this *PortfolioStatService) NewEntities(data []byte) (interface{}, error)

func (*PortfolioStatService) NewEntity 

func (this *PortfolioStatService) NewEntity(data []byte) (interface{}, error)

func (*PortfolioStatService) RefreshPortfolioStat 

func (this *PortfolioStatService) RefreshPortfolioStat() error

* 刷新所有股票的季度业绩统计数据

func (*PortfolioStatService) UpdatePortfolioStat 

func (this *PortfolioStatService) UpdatePortfolioStat(tscode string) error

* 通过内存更新股票季度业绩统计数据，并返回结果

type ProcessLogService 

type ProcessLogService struct {
	service.OrmBaseService
}

func GetProcessLogService 

func GetProcessLogService() *ProcessLogService

func (*ProcessLogService) Cron 

func (this *ProcessLogService) Cron() *cron.Cron

func (*ProcessLogService) EndLog 

func (this *ProcessLogService) EndLog(processLog *entity.ProcessLog, errorCode string, errorMsg string)

func (*ProcessLogService) GetSeqName 

func (this *ProcessLogService) GetSeqName() string

func (*ProcessLogService) NewEntities 

func (this *ProcessLogService) NewEntities(data []byte) (interface{}, error)

func (*ProcessLogService) NewEntity 

func (this *ProcessLogService) NewEntity(data []byte) (interface{}, error)

func (*ProcessLogService) Schedule 

func (this *ProcessLogService) Schedule()

func (*ProcessLogService) StartLog 

func (this *ProcessLogService) StartLog(name string, methodName string, bizCode string) *entity.ProcessLog

type QPerformanceService 

type QPerformanceService struct {
	service.OrmBaseService
}

func GetQPerformanceService 

func GetQPerformanceService() *QPerformanceService

func (*QPerformanceService) AsyncUpdateDayQPerformance 

func (this *QPerformanceService) AsyncUpdateDayQPerformance(para interface{})

func (*QPerformanceService) AsyncUpdateWmqyQPerformance 

func (this *QPerformanceService) AsyncUpdateWmqyQPerformance(para interface{})

func (*QPerformanceService) Compute 

func (this *QPerformanceService) Compute(qpMap map[string][]interface{}, previousMap map[string]*entity.QPerformance)

* 计算并推导缺失的当前价格和股票季度业绩数据项

func (*QPerformanceService) FindAccBySql 

func (this *QPerformanceService) FindAccBySql(ts_code string, startDate string) (map[string][]interface{}, error)

* 通过数据库sql计算累计涨幅

func (*QPerformanceService) FindAllQStatBySql 

func (this *QPerformanceService) FindAllQStatBySql(ts_code string, startDate string, endDate string) map[string][]interface{}

* 通过数据库sql计算股票季度业绩全部统计数据，并返回结果

func (*QPerformanceService) FindPercentRank 

func (this *QPerformanceService) FindPercentRank(rankType string, ts_code string, tradeDate int64, startDate string, endDate string, from int, limit int, count int64) ([]*entity.QPerformance, error)

* 计算股票的在本股票历史上以及在同行业历史上的位置,不支持tscode多只股票

func (*QPerformanceService) FindQExpress 

func (this *QPerformanceService) FindQExpress(lineType LineType, ts_code string, startDate string, endDate string) (map[string][]interface{}, error)

* 组合当前价格和股票季度业绩快报数据

func (*QPerformanceService) FindQForecast 

func (this *QPerformanceService) FindQForecast(lineType LineType, ts_code string, startDate string, endDate string) (map[string][]interface{}, error)

* 组合当前价格和股票季度业绩预测数据

func (*QPerformanceService) FindQPerformance 

func (this *QPerformanceService) FindQPerformance(lineType LineType, ts_code string, startDate string, endDate string) (map[string][]interface{}, error)

* 组合当前价格和股票季度正式业绩数据

func (*QPerformanceService) FindQStatBySql 

func (this *QPerformanceService) FindQStatBySql(aggregationType string, ts_code string, startDate string, endDate string, sourceName string) (map[string][]interface{}, error)

* 通过数据库sql计算股票季度业绩某种统计数据，并返回结果

func (*QPerformanceService) FindStdQPerformance 

func (this *QPerformanceService) FindStdQPerformance(ts_code string, terms []int, startDate string, endDate string, stdType StdType, isWinsorize bool) (map[string][]*entity.QPerformance, error)

* 查询股票季度业绩数据，并进行标准化处理

func (*QPerformanceService) GetQTerm 

func (this *QPerformanceService) GetQTerm(qpMap map[string][]*entity.QPerformance, terms []int) (map[string]map[int]*QTerm, error)

* 在所有的数据中分选出各种不同的term对应的数据集，原始数据降序排列

func (*QPerformanceService) GetQTermBySql 

func (this *QPerformanceService) GetQTermBySql(tscode string, term int) (*QTerm, error)

func (*QPerformanceService) GetSeqName 

func (this *QPerformanceService) GetSeqName() string

func (*QPerformanceService) GetUpdateDayQPerformance 

func (this *QPerformanceService) GetUpdateDayQPerformance(tscode string) ([]interface{}, error)

func (*QPerformanceService) GetUpdateWmqyQPerformance 

func (this *QPerformanceService) GetUpdateWmqyQPerformance(tscode string, startDate string) ([]interface{}, error)

* 更新股票季度业绩数据，并返回结果

func (*QPerformanceService) NewEntities 

func (this *QPerformanceService) NewEntities(data []byte) (interface{}, error)

func (*QPerformanceService) NewEntity 

func (this *QPerformanceService) NewEntity(data []byte) (interface{}, error)

func (*QPerformanceService) RefreshDayQPerformance 

func (this *QPerformanceService) RefreshDayQPerformance() error

func (*QPerformanceService) RefreshWmqyQPerformance 

func (this *QPerformanceService) RefreshWmqyQPerformance(startDate string) error

* 刷新所有股票的季度业绩数据

func (*QPerformanceService) Search 

func (this *QPerformanceService) Search(keyword string, tscode string, terms []int, sourceOptions []string, startDate string, endDate string, orderby string, from int, limit int, count int64) ([]*entity.QPerformance, int64, error)

func (*QPerformanceService) Std 

func (this *QPerformanceService) Std(ps []interface{}, stdType StdType, isWinsorize bool) []*entity.QPerformance

* 对股票季度业绩数据进行异常值处理和标准化操作

func (*QPerformanceService) StdMap 

func (this *QPerformanceService) StdMap(psMap map[string][]interface{}, stdType StdType, isWinsorize bool) map[string][]*entity.QPerformance

* 批量标准化股票季度业绩数据

type QStatService 

type QStatService struct {
	service.OrmBaseService
	Terms     []int
	MedianMap map[string]*entity.QStat
	Locker    sync.Mutex
}

func GetQStatService 

func GetQStatService() *QStatService

func (*QStatService) AsyncUpdateQStat 

func (this *QStatService) AsyncUpdateQStat(para interface{})

func (*QStatService) FindAcc 

func (this *QStatService) FindAcc(ps []interface{}, qterm *QTerm, pre *entity.QPerformance) *entity.QStat

原始数据降序排列

func (*QStatService) FindAllQStat 

func (this *QStatService) FindAllQStat(qpMap map[string][]*entity.QPerformance, qtermMap map[string]map[int]*QTerm) map[string][]interface{}

* 通过内存计算股票季度业绩全部统计数据，并返回结果，原始数据降序排列

func (*QStatService) FindPercentRank 

func (this *QStatService) FindPercentRank(tscode string, qterm *QTerm) ([]*entity.QStat, error)

func (*QStatService) FindQStat 

func (this *QStatService) FindQStat(ts_code string, terms []int, source string, sourceName string) (map[string]map[int][]interface{}, error)

* 查询股票季度业绩统计数据

func (*QStatService) FindQStatMedian 

func (this *QStatService) FindQStatMedian() (map[string]*entity.QStat, error)

* 计算股票季度业绩统计数据中位数，最大值和最小值，并返回结果，方便进行去极值和标准化

func (*QStatService) GetQStatMedian 

func (this *QStatService) GetQStatMedian() error

* 计算股票所有统计数据的Min，Max，并保存

func (*QStatService) GetSeqName 

func (this *QStatService) GetSeqName() string

func (*QStatService) GetUpdateQStat 

func (this *QStatService) GetUpdateQStat(tscode string) ([]interface{}, error)

* 更新股票季度业绩统计数据，并返回结果

func (*QStatService) MinmaxStd 

func (this *QStatService) MinmaxStd(q *entity.QStat, fieldname string) float64

* 对某个统计指标计算minmax标准化

func (*QStatService) NewEntities 

func (this *QStatService) NewEntities(data []byte) (interface{}, error)

func (*QStatService) NewEntity 

func (this *QStatService) NewEntity(data []byte) (interface{}, error)

func (*QStatService) RefreshQStat 

func (this *QStatService) RefreshQStat() error

* 刷新所有股票的季度业绩统计数据

func (*QStatService) Search 

func (this *QStatService) Search(keyword string, terms []int, sourceOptions []string, from int, limit int, count int64) ([]*entity.QStat, int64, error)

func (*QStatService) UpdatePercentRank 

func (this *QStatService) UpdatePercentRank(tscode string, qtermMap map[string]map[int]*QTerm) ([]interface{}, error)

func (*QStatService) UpdateQStat 

func (this *QStatService) UpdateQStat(tscode string, terms []int) ([]interface{}, error)

* 通过内存更新股票季度业绩统计数据，并返回结果

func (*QStatService) UpdateQStatBySql 

func (this *QStatService) UpdateQStatBySql(tscode string, term int) ([]interface{}, error)

* 通过数据库sql更新股票季度业绩统计数据，并返回结果

type QTerm 

type QTerm struct {
	ActualStartDate string
	StartDate       string
	EndDate         string
	Term            int
	TradeDate       int64
}

type ShareEventService 

type ShareEventService struct {
	service.OrmBaseService
}

* 同步表结构，服务继承基本服务的方法

func GetShareEventService 

func GetShareEventService() *ShareEventService

func (*ShareEventService) GetMine 

func (this *ShareEventService) GetMine(userName string, ts_code string) ([]interface{}, error)

func (*ShareEventService) GetSeqName 

func (this *ShareEventService) GetSeqName() string

func (*ShareEventService) NewEntities 

func (this *ShareEventService) NewEntities(data []byte) (interface{}, error)

func (*ShareEventService) NewEntity 

func (this *ShareEventService) NewEntity(data []byte) (interface{}, error)

type ShareRequest 

type ShareRequest struct {
	TsCode     string `json:"ts_code,omitempty"`     // N	股票代码
	ListStatus string `json:"list_status,omitempty"` // N	上市状态: L上市 D退市 P暂停上市,默认L
	Exchange   string `json:"exchange,omitempty"`    // N	交易所 SSE上交所 SZSE深交所 HKEX港交所(未上线)
	IsHs       string `json:"is_hs,omitempty"`       // N  是否沪深港通标的,N否 H沪股通 S深股通
}

type ShareService 

type ShareService struct {
	service.OrmBaseService
}

* 同步表结构，服务继承基本服务的方法

func GetShareService 

func GetShareService() *ShareService

func (*ShareService) GetCacheShare 

func (this *ShareService) GetCacheShare() ([]string, map[string]*entity.Share)

func (*ShareService) GetSeqName 

func (this *ShareService) GetSeqName() string

func (*ShareService) GetShares 

func (this *ShareService) GetShares(ts_code string) ([]interface{}, error)

func (*ShareService) NewEntities 

func (this *ShareService) NewEntities(data []byte) (interface{}, error)

func (*ShareService) NewEntity 

func (this *ShareService) NewEntity(data []byte) (interface{}, error)

func (*ShareService) RefreshCacheShare 

func (this *ShareService) RefreshCacheShare()

func (*ShareService) Search 

func (this *ShareService) Search(keyword string, from int, limit int) ([]*entity.Share, error)

func (*ShareService) UpdatePinYin 

func (this *ShareService) UpdatePinYin()

func (*ShareService) UpdateSector 

func (this *ShareService) UpdateSector(tscode string, sector string)

func (*ShareService) UpdateShares 

func (this *ShareService) UpdateShares()

type StatScoreService 

type StatScoreService struct {
	service.OrmBaseService
}

func GetStatScoreService 

func GetStatScoreService() *StatScoreService

func (*StatScoreService) AsyncUpdateStatScore 

func (this *StatScoreService) AsyncUpdateStatScore(para interface{})

func (*StatScoreService) CreateScorePercentile 

func (this *StatScoreService) CreateScorePercentile() (int64, error)

* 计算股票季度业绩统计评分数据中位数，最大值和最小值，并返回结果，方便进行去极值和标准化

func (*StatScoreService) FindStatScoreMedian 

func (this *StatScoreService) FindStatScoreMedian() (map[string]*entity.StatScore, error)

* 计算股票季度业绩统计数据中位数，最大值和最小值，并返回结果，方便进行去极值和标准化

func (*StatScoreService) GetSeqName 

func (this *StatScoreService) GetSeqName() string

func (*StatScoreService) GetUpdateStatScore 

func (this *StatScoreService) GetUpdateStatScore(ts_code string) (map[string]map[int]*entity.StatScore, error)

func (*StatScoreService) NewEntities 

func (this *StatScoreService) NewEntities(data []byte) (interface{}, error)

func (*StatScoreService) NewEntity 

func (this *StatScoreService) NewEntity(data []byte) (interface{}, error)

func (*StatScoreService) RefreshStatScore 

func (this *StatScoreService) RefreshStatScore() error

* 刷新所有股票的季度业绩统计评分数据

func (*StatScoreService) Search 

func (this *StatScoreService) Search(keyword string, tscode string, terms []int, scoreOptions []string, orderby string, from int, limit int, count int64) ([]*entity.StatScore, int64, error)

type StdType 

type StdType int64
const (
	StdType_None StdType = iota + 1
	StdType_Std
	StdType_MinMax
)

type TodayMinLineResponseData 

type TodayMinLineResponseData struct {
	Code        string   `json:"code,omitempty"`
	Market      string   `json:"code,omitempty"`
	Name        string   `json:"code,omitempty"`
	Decimal     int      `json:"code,omitempty"`        //小数位
	TrendsTotal int      `json:"trendsTotal,omitempty"` //总记录数
	PrePrice    float64  `json:"prePrice,omitempty"`
	PreClose    float64  `json:"preClose,omitempty"`
	Trends      []string `json:"trends,omitempty"` //数据
}

type TodayMinLineResponseResult 

type TodayMinLineResponseResult struct {
	Rc   int                       `json:"rc,omitempty"`
	Rt   int                       `json:"rt,omitempty"`
	Svr  int                       `json:"svr,omitempty"`
	Lt   int                       `json:"lt,omitempty"`
	Full int                       `json:"full,omitempty"`
	Data *TodayMinLineResponseData `json:"data,omitempty"`
}

type UserShare 

type UserShare struct {
	Id                 int64   `json:"id,omitempty"`
	TsCode             string  `json:"ts_code,omitempty"`
	Name               string  `json:"name,omitempty"`
	Industry           string  `json:"industry,omitempty"`
	Sector             string  `json:"sector,omitempty"`
	TradeDate          int64   `json:"trade_date"`
	QDate              string  `json:"qdate"`
	Source             string  `json:"source"`
	Close              float64 `json:"close"`
	PctChgClose        float64 `json:"pct_chg_close"`
	PctChgVol          float64 `json:"pct_chg_vol"`
	Turnover           float64 `json:"turnover"`
	Pe                 float64 `json:"pe"`
	Peg                float64 `json:"peg"`
	Percent3Close      float64 `json:"percent3_close"`
	Percent5Close      float64 `json:"percent5_close"`
	Percent10Close     float64 `json:"percent10_close"`
	Percent13Close     float64 `json:"percent13_close"`
	Percent20Close     float64 `json:"percent20_close"`
	Percent21Close     float64 `json:"percent21_close"`
	Percent30Close     float64 `json:"percent30_close"`
	Percent34Close     float64 `json:"percent34_close"`
	Percent55Close     float64 `json:"percent55_close"`
	Percent60Close     float64 `json:"percent60_close"`
	Percent90Close     float64 `json:"percent90_close"`
	Percent120Close    float64 `json:"percent120_close"`
	Percent144Close    float64 `json:"percent144_close"`
	Percent233Close    float64 `json:"percent233_close"`
	Percent240Close    float64 `json:"percent240_close"`
	PercentPe          float64 `json:"percent_pe"`
	PercentPeg         float64 `json:"percent_peg"`
	IndustryPercentPe  float64 `json:"industry_percent_pe"`
	IndustryPercentPeg float64 `json:"industry_percent_peg"`
}

type WmqyLineBuf 

type WmqyLineBuf struct {
	Buf  []interface{}
	Lock sync.Mutex
}

type WmqyLineService 

type WmqyLineService struct {
	service.OrmBaseService
}

* 同步表结构，服务继承基本服务的方法

func GetWmqyLineService 

func GetWmqyLineService() *WmqyLineService

func (*WmqyLineService) AsyncStdFile 

func (this *WmqyLineService) AsyncStdFile(para interface{})

func (*WmqyLineService) AsyncUpdateWmqyLine 

func (this *WmqyLineService) AsyncUpdateWmqyLine(para interface{})

func (*WmqyLineService) FindFollowing 

func (this *WmqyLineService) FindFollowing(ts_code string, lineType int, startDate string, endDate string, from int, limit int, count int64) ([]*entity.WmqyLine, int64, error)

获取某时间点后limit条数据，如果没有日期范围的指定，就是返回最早limit条数据

func (*WmqyLineService) FindPreceding 

func (this *WmqyLineService) FindPreceding(ts_code string, lineType int, endDate string, from int, limit int, count int64) ([]*entity.WmqyLine, int64, error)

* 获取某时间点前limit条数据，如果没有日期范围的指定，就是返回最新的回溯limit条数据

func (*WmqyLineService) GetSeqName 

func (this *WmqyLineService) GetSeqName() string

func (*WmqyLineService) GetUpdateWmqyLine 

func (this *WmqyLineService) GetUpdateWmqyLine(secId string, beg int64, limit int, wmqy *WmqyLineBuf) ([]interface{}, error)

func (*WmqyLineService) GetWmqyLine 

func (this *WmqyLineService) GetWmqyLine(secId string, beg int64, end int, limit int, klt int, previous *entity.WmqyLine) ([]*entity.WmqyLine, error)

* 获取某只股票的日线数据

func (*WmqyLineService) NewEntities 

func (this *WmqyLineService) NewEntities(data []byte) (interface{}, error)

func (*WmqyLineService) NewEntity 

func (this *WmqyLineService) NewEntity(data []byte) (interface{}, error)

func (*WmqyLineService) RefreshWmqyLine 

func (this *WmqyLineService) RefreshWmqyLine(beg int64) error

* 刷新所有股票的日线数据，beg为负数的时候从已有的最新数据开始更新

func (*WmqyLineService) StdFile 

func (this *WmqyLineService) StdFile(minmax string, standard string, _startDate int64, _endDate int64, filename string) (map[stock.AggregationType]*entity.QPerformance, error)

func (*WmqyLineService) StdPath 

func (this *WmqyLineService) StdPath(minmax string, standard string, startDate int64, endDate int64) error

* minmax: "C:\stock\data\minmax\lday" standard: "C:\stock\data\standard\lday"

func (*WmqyLineService) UpdateWmqyLine 

func (this *WmqyLineService) UpdateWmqyLine(secId string, beg int64, limit int, wmqy *WmqyLineBuf) ([]interface{}, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.