data_engine

type DataStatistics struct {
	DataCount        int    `json:"dataCount"`
	DataSuccessCount int    `json:"dataSuccessCount"`
	DataErrorCount   int    `json:"dataErrorCount"`
	UseTime          int64  `json:"useTime"`
	DataAverage      string `json:"dataAverage"`

	StartTime time.Time `json:"startTime,omitempty"`
	EndTime   time.Time `json:"endTime,omitempty"`
	// contains filtered or unexported fields
}

type ExcelSheet struct {
	Name     int      `json:"name,omitempty"`
	SkipRow  int      `json:"skipRow,omitempty"`
	NameList []string `json:"nameList,omitempty"`
}

type ExcelTask struct {
	Path           string        `json:"path,omitempty"`
	SheetList      []*ExcelSheet `json:"sheetList,omitempty"`
	DataCount      int           `json:"dataCount"`
	ReadyDataCount int           `json:"readyDataCount"`
	IsEnd          bool          `json:"isEnd,omitempty"`
	StartTime      time.Time     `json:"startTime,omitempty"`
	EndTime        time.Time     `json:"endTime,omitempty"`
	Error          string        `json:"error,omitempty"`
	UseTime        int64         `json:"useTime"`
	IsStop         bool          `json:"isStop"`
	IsError        bool          `json:"isError"`
	OnData         func(data map[string]interface{}) (err error)
	OnError        func(err error)
	OnEnd          func()
}

type StrategyData struct {
	DataNumber  int                  `json:"dataNumber,omitempty"`
	StartIndex  int                  `json:"startIndex,omitempty"`
	BatchNumber int                  `json:"batchNumber,omitempty"`
	IndexName   string               `json:"indexName,omitempty"`
	DataName    string               `json:"dataName,omitempty"`
	FieldList   []*StrategyDataField `json:"fieldList,omitempty"`
	*DataStatistics
}

type StrategyDataField struct {
	Name        string               `json:"name,omitempty"`
	IndexName   string               `json:"indexName,omitempty"`
	DataName    string               `json:"dataName,omitempty"`
	Value       string               `json:"value,omitempty"`
	ReuseNumber int                  `json:"reuseNumber,omitempty"`
	ValueIsList bool                 `json:"valueIsList,omitempty"`
	ValueCount  int                  `json:"valueCount,omitempty"`
	FieldList   []*StrategyDataField `json:"fieldList,omitempty"`
	// contains filtered or unexported fields
}

type StrategyTask struct {
	*StrategyData
	ErrorContinue bool   `json:"errorContinue"`
	IsEnd         bool   `json:"isEnd,omitempty"`
	Error         string `json:"error,omitempty"`
	IsStop        bool   `json:"isStop"`
	IsError       bool   `json:"isError"`
	OnDataList    func(dataList []map[string]interface{}) (err error)
	OnError       func(err error)
	OnEnd         func()
}

type TextTask struct {
	Path           string    `json:"path,omitempty"`
	CellSeparator  string    `json:"cellSeparator,omitempty"`
	SkipRow        int       `json:"skipRow,omitempty"`
	NameList       []string  `json:"nameList,omitempty"`
	DataCount      int       `json:"dataCount"`
	ReadyDataCount int       `json:"readyDataCount"`
	IsEnd          bool      `json:"isEnd,omitempty"`
	StartTime      time.Time `json:"startTime,omitempty"`
	EndTime        time.Time `json:"endTime,omitempty"`
	Error          string    `json:"error,omitempty"`
	UseTime        int64     `json:"useTime"`
	IsStop         bool      `json:"isStop"`
	IsError        bool      `json:"isError"`
	OnData         func(data map[string]interface{}) (err error)
	OnError        func(err error)
	OnEnd          func()
}