worker

type DataSource interface {
	Stop()
	ReadStart() (err error)
	Read(columnList []*dialect.ColumnModel, onRead func(data *DataSourceData) (err error)) (err error)
	ReadEnd() (err error)
	WriteStart() (err error)
	Write(data *DataSourceData) (err error)
	WriteEnd() (err error)
	WriteHeader(columnList []*dialect.ColumnModel) (err error)
}

type DataSourceData struct {
	HasSql     bool
	Sql        string
	HasData    bool
	Data       map[string]interface{}
	ColumnList []*dialect.ColumnModel
}

type DataSourceParam struct {
	Path       string
	Separator  string
	SheetIndex int
	StartRow   int
	SheetName  string
	Linefeed   string
	TitleList  []string
	Dia        dialect.Dialect
}

type DataSourceType struct {
	Name       string `json:"name"`
	New        func(param *DataSourceParam) (dataSource DataSource)
	FileSuffix string `json:"fileSuffix"`
}

type Page struct {
	PageSize   int `json:"pageSize"`
	PageNo     int `json:"pageNo"`
	TotalCount int `json:"totalCount"`
	TotalPage  int `json:"totalPage"`
}

type Task struct {
	TaskId     string `json:"taskId"`
	StartTime  int64  `json:"startTime"`
	EndTime    int64  `json:"endTime"`
	UseTime    int64  `json:"useTime"`
	Error      string `json:"error"`
	PanicError string `json:"panicError"`
	IsEnd      bool   `json:"isEnd"`
	IsStop     bool   `json:"isStop"`

	OwnerCount        int `json:"ownerCount"`
	OwnerSuccessCount int `json:"ownerSuccessCount"`
	OwnerErrorCount   int `json:"ownerErrorCount"`

	TableCount        int `json:"tableCount"`
	TableSuccessCount int `json:"tableSuccessCount"`
	TableErrorCount   int `json:"tableErrorCount"`

	DataCount        int `json:"dataCount"`
	DataReadyCount   int `json:"dataReadyCount"`
	DataSuccessCount int `json:"dataSuccessCount"`
	DataErrorCount   int `json:"dataErrorCount"`

	Extend map[string]interface{} `json:"extend"`
	Errors []string               `json:"errors"`

	Param *dialect.ParamModel
	// contains filtered or unexported fields
}

type TaskExecOwner struct {
	Name   string           `json:"name,omitempty"`
	Tables []*TaskExecTable `json:"tables,omitempty"`
}

type TaskExecParam struct {
	Owners []*TaskExecOwner `json:"owners"`

	BatchNumber     int  `json:"batchNumber"`
	ContinueIsError bool `json:"continueIsError"`

	OnProgress func(progress *TaskProgress)
}

type TaskExecTable struct {
	Name            string                   `json:"name,omitempty"`
	ColumnList      []*dialect.ColumnModel   `json:"columnList,omitempty"`
	InsertList      []map[string]interface{} `json:"insertList"`
	UpdateList      []map[string]interface{} `json:"updateList"`
	UpdateWhereList []map[string]interface{} `json:"updateWhereList"`
	DeleteList      []map[string]interface{} `json:"deleteList"`
}

type TaskExportColumn struct {
	SourceName string `json:"sourceName"`
	TargetName string `json:"targetName"`
	Value      string `json:"value"`
}

type TaskExportOwner struct {
	SourceName     string             `json:"sourceName"`
	TargetName     string             `json:"targetName"`
	SkipTableNames []string           `json:"skipTableNames"`
	Tables         []*TaskExportTable `json:"tables"`
}

type TaskExportParam struct {
	Owners         []*TaskExportOwner `json:"owners"`
	SkipOwnerNames []string           `json:"skipOwnerNames"`

	DataSourceType  *DataSourceType `json:"dataSourceType"`
	BatchNumber     int             `json:"batchNumber"`
	ExportStruct    bool            `json:"exportStruct"`
	ExportData      bool            `json:"exportData"`
	ExportBatchSql  bool            `json:"exportBatchSql"`
	ErrorContinue   bool            `json:"errorContinue"`
	Dir             string          `json:"dir"`
	AppendOwnerName bool            `json:"appendOwnerName"`

	IsDataListExport bool                     `json:"isDataListExport"`
	DataList         []map[string]interface{} `json:"dataList"`

	MergeIntoOneFile bool `json:"mergeIntoOneFile"`

	FormatIndexName func(ownerName string, tableName string, index *dialect.IndexModel) string `json:"-"`
	OnProgress      func(progress *TaskProgress)                                               `json:"-"`
}

type TaskExportTable struct {
	SourceName string              `json:"sourceName"`
	TargetName string              `json:"targetName"`
	Columns    []*TaskExportColumn `json:"columns"`
}

type TaskImportColumn struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

type TaskImportOwner struct {
	Name           string             `json:"name"`
	Path           string             `json:"path"`
	SkipTableNames []string           `json:"skipTableNames"`
	Tables         []*TaskImportTable `json:"tables"`
	Username       string             `json:"username"`
	Password       string             `json:"password"`
}

type TaskImportParam struct {
	Owners []*TaskImportOwner `json:"owners"`

	DataSourceType        *DataSourceType `json:"dataSourceType"`
	BatchNumber           int             `json:"batchNumber"`
	OwnerCreateIfNotExist bool            `json:"ownerCreateIfNotExist"`
	ErrorContinue         bool            `json:"errorContinue"`

	FormatIndexName func(ownerName string, tableName string, index *dialect.IndexModel) string `json:"-"`
	OnProgress      func(progress *TaskProgress)
}

type TaskImportTable struct {
	Name    string              `json:"name"`
	Path    string              `json:"path"`
	Columns []*TaskImportColumn `json:"columns"`
}

type TaskProgress struct {
	Title   string          `json:"title"`
	Infos   []string        `json:"infos"`
	Error   string          `json:"error"`
	OnError func(err error) `json:"-"`
}

type TaskSyncColumn struct {
	SourceName string `json:"sourceName"`
	TargetName string `json:"targetName"`
}

type TaskSyncOwner struct {
	SourceName     string           `json:"sourceName"`
	TargetName     string           `json:"targetName"`
	SkipTableNames []string         `json:"skipTableNames"`
	Tables         []*TaskSyncTable `json:"tables"`
	Username       string           `json:"username"`
	Password       string           `json:"password"`
}

type TaskSyncParam struct {
	Owners []*TaskSyncOwner `json:"owners"`

	BatchNumber           int  `json:"batchNumber"`
	SyncStruct            bool `json:"syncStruct"`
	SyncData              bool `json:"syncData"`
	ErrorContinue         bool `json:"errorContinue"`
	OwnerCreateIfNotExist bool `json:"ownerCreateIfNotExist"`

	FormatIndexName func(ownerName string, tableName string, index *dialect.IndexModel) string `json:"-"`
	OnProgress      func(progress *TaskProgress)                                               `json:"-"`
}

type TaskSyncTable struct {
	SourceName string            `json:"sourceName"`
	TargetName string            `json:"targetName"`
	Columns    []*TaskSyncColumn `json:"columns"`
}