dto

type AddAliasesReq struct {
	EsConnectData     EsConnectData     `json:"es_connect_data"`
	AddAliasesReqData AddAliasesReqData `json:"add_aliases_req_data"`
}

type AddAliasesReqData struct {
	IndexName []string
	AliasName string
}

type AggregateMongoDocumentsReq struct {
	EsConnectData  EsConnectData `json:"es_connect_data"`
	DbName         string        `json:"db_name"`
	CollectionName string        `json:"collection_name"`
	Pipeline       bson.Pipeline `json:"pipeline"`
}

type AnalysisFilter struct {
	FilterType string `json:"filterType"`
	Filts      []struct {
		FilterType string `json:"filterType"`
		Filts      []struct {
			ColumnName string      `json:"columnName"`
			Comparator string      `json:"comparator"`
			FilterType string      `json:"filterType"`
			Ftv        interface{} `json:"ftv"`
		} `json:"filts,omitempty"`
		Relation   string      `json:"relation,omitempty"`
		ColumnName string      `json:"columnName,omitempty"`
		Comparator string      `json:"comparator,omitempty"`
		Ftv        interface{} `json:"ftv,omitempty"`
	} `json:"filts"`
	Relation string `json:"relation"`
}

type BatchInsertDataReq struct {
	EsConnectData EsConnectData   `json:"es_connect_data"`
	DbName        string          `json:"db_name"`
	TableName     string          `json:"table_name"`
	Cols          []string        `json:"cols"`
	Data          [][]interface{} `json:"data"`
}

type BatchLiveBroadcast struct {
	Channel string        `json:"channel"`
	List    []interface{} `json:"list"`
}

type CancelTask struct {
	EsConnect int    `json:"es_connect"`
	TaskID    string `json:"task_id"`
}

type CatAliasesReq struct {
	EsConnectData     EsConnectData     `json:"es_connect_data"`
	CatAliasesReqData CatAliasesReqData `json:"cat_aliases_req_data"`
}

type CatAliasesReqData struct {
	CatRequest proto.CatAliasesRequest
}

type CatAllocationRequest struct {
	EsConnectData            EsConnectData            `json:"es_connect_data"`
	CatAllocationRequestData CatAllocationRequestData `json:"cat_allocation_request_data"`
}

type CatAllocationRequestData struct {
	CatRequest proto.CatAllocationRequest
}

type CatCountReq struct {
	EsConnectData   EsConnectData   `json:"es_connect_data"`
	CatCountReqData CatCountReqData `json:"cat_count_req_data"`
}

type CatCountReqData struct {
	CatRequest proto.CatCountRequest
}

type CatHealthReq struct {
	EsConnectData    EsConnectData    `json:"es_connect_data"`
	CatHealthReqData CatHealthReqData `json:"cat_health_req_data"`
}

type CatHealthReqData struct {
	CatRequest proto.CatHealthRequest
}

type CatNodeReqData struct {
	H []string `json:"h"`
}

type CatNodesReq struct {
	EsConnectData  EsConnectData  `json:"es_connect_data"`
	CatNodeReqData CatNodeReqData `json:"cat_node_req_data"`
}

type CatShardsReq struct {
	EsConnectData    EsConnectData    `json:"es_connect_data"`
	CatShardsReqData CatShardsReqData `json:"cat_shards_req_data"`
}

type CatShardsReqData struct {
	CatRequest proto.CatShardsRequest
}

type CleanupeRepository struct {
	EsConnect  int    `json:"es_connect"` //es连接id
	Repository string `json:"name"`       //存储库名
}

type ClusterStatsReq struct {
	EsConnectData       EsConnectData       `json:"es_connect_data"`
	ClusterStatsReqData ClusterStatsReqData `json:"cluster_stats_req_data"`
}

type ClusterStatsReqData struct {
	Human bool `json:"human"`
}

type CountMongoDocumentsReq struct {
	EsConnectData  EsConnectData `json:"es_connect_data"`
	DbName         string        `json:"db_name"`
	CollectionName string        `json:"collection_name"`
	Filter         bson.M        `json:"filter"`
}

type CreateIndexReq struct {
	EsConnectData      EsConnectData      `json:"es_connect_data"`
	CreateIndexReqData CreateIndexReqData `json:"create_index_req_data"`
}

type CreateIndexReqData struct {
	IndexCreateRequest proto.IndicesCreateRequest
	Body               interface{}
}

type CreateReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
	CreateReqData CreateReqData `json:"create_req_data"`
}

type CreateReqData struct {
	CreateRequest proto.CreateRequest
	Body          interface{}
}

type CreateSnapshot struct {
	SnapshotName       string   `json:"snapshotName"`
	RepositoryName     string   `json:"repositoryName"`
	IndexList          []string `json:"indexList"`
	IgnoreUnavailable  *bool    `json:"ignore_unavailable"`
	IncludeGlobalState *bool    `json:"include_global_state"`
	Partial            *bool    `json:"partial"`
	Wait               *bool    `json:"wait"`
	EsConnect          int      `json:"es_connect"`
}

type CrudFilter struct {
	Relation  AnalysisFilter `json:"relation"`
	SortList  []SortStruct   `json:"sort_list"`
	EsConnect int            `json:"es_connect"`
	IndexName string         `json:"index_name"`
	Page      int            `json:"page"`
	Limit     int            `json:"limit"`
}

type DataxInfoDelReq struct {
	ID int `json:"id"`
}

type DataxInfoInsertReq struct {
	IP       string `json:"ip"`
	Port     int    `json:"port"`
	DbName   string `json:"db_name"`
	Username string `json:"username"`
	Pwd      string `json:"pwd"`
	Remark   string `json:"remark"`
	Typ      string `json:"typ"`
}

type DataxInfoListReq struct {
	Remark string `json:"remark"`
	Typ    string `json:"typ"`
	Page   int    `json:"page"`
	Limit  int    `json:"limit"`
}

type DataxInfoTestLinkReq struct {
	IP       string `json:"ip"`
	Port     int    `json:"port"`
	DbName   string `json:"db_name"`
	Username string `json:"username"`
	Pwd      string `json:"pwd"`
	Remark   string `json:"remark"`
	Typ      string `json:"typ"`
}

type DeleteByQueryReq struct {
	EsConnectData        EsConnectData        `json:"es_connect_data"`
	DeleteByQueryReqData DeleteByQueryReqData `json:"delete_by_query_req_data"`
}

type DeleteByQueryReqData struct {
	IndexNames []string
	Documents  []string
	Body       interface{}
}

type DeleteDb struct {
	// 插件ID
	PluginId string `json:"plugin_id"`
	// 目标表名
	TableName string `json:"table"` // 目标表名
	// WHERE条件SQL
	WhereSql string `json:"where_sql"`
	// WHERE条件参数
	WhereArgs []interface{} `json:"where_args"`
}

type DeleteEsLink struct {
	Id int `json:"id"`
}

type DeleteEsLinkCfg struct {
	Id int `json:"id"`
}

type DeleteIndexReq struct {
	EsConnectData      EsConnectData      `json:"es_connect_data"`
	DeleteIndexReqData DeleteIndexReqData `json:"delete_index_req_data"`
}

type DeleteIndexReqData struct {
	IndicesDeleteRequest proto.IndicesDeleteRequest
}

type DeleteManyMongoDocumentsReq struct {
	EsConnectData  EsConnectData `json:"es_connect_data"`
	DocIds         []interface{} `json:"doc_ids"`
	DbName         string        `json:"db_name"`
	CollectionName string        `json:"collection_name"`
}

type DeleteMongoDocumentReq struct {
	EsConnectData  EsConnectData `json:"es_connect_data"`
	DbName         string        `json:"db_name"`
	CollectionName string        `json:"collection_name"`
	DocId          interface{}   `json:"doc_id"`
	Filter         bson.M        `json:"filter"`
}

type DeleteReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
	DeleteReqData DeleteReqData `json:"delete_req_data"`
}

type DeleteReqData struct {
	DeleteRequest proto.DeleteRequest
}

type DeleteSnapshot struct {
	SnapshotName   string `json:"snapshotName"`
	RepositoryName string `json:"repositoryName"`
	EsConnect      int    `json:"es_connect"`
}

type DsTypeReq struct {
	// ES连接数据
	EsConnectData EsConnectData `json:"es_connect_data"`
}

type DslHistoryListReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
	IndexName     string        `json:"indexName"` // 索引名
	Date          []string      `json:"date"`      //开始时间与结束时间（格式：”年-月-日 时:分:秒“ ）
	Page          int           `json:"page"`      //拉取数据当前页
	Limit         int           `json:"limit"`     //拉取条数
}

type DslHistoryListReq2 struct {
	// 索引名
	IndexName string `json:"indexName"`
	// 开始时间与结束时间（格式："年-月-日 时:分:秒"）
	Date []string `json:"date"`
	// 当前页码
	Page int `json:"page"`
	// 每页条数
	Limit int `json:"limit"`
}

type EsAliasInfo struct {
	EsConnect        int         `json:"es_connect"`
	Settings         common.Json `json:"settings"`
	IndexName        string      `json:"index_name"`
	AliasName        string      `json:"alias_name"`
	NewAliasNameList []string    `json:"new_alias_name_list"`
	NewIndexList     []string    `json:"new_index_list"`
	Types            int         `json:"types"`
}

type EsCat struct {
	EsConnect        int    `json:"es_connect"`
	Cat              string `json:"cat"`
	IndexBytesFormat string `json:"index_bytes_format"`
}

type EsConnectData struct {
	UserID    int `json:"user_id"`
	EsConnect int `json:"es_connect"`
}

type EsDocDeleteRowByID struct {
	EsConnect int    `json:"es_connect"`
	ID        string `json:"id"`
	IndexName string `json:"index_name"`
	Type      string `json:"type"`
}

type EsDocUpdateByID struct {
	EsConnect int         `json:"es_connect"`
	ID        string      `json:"id"`
	JSON      common.Json `json:"json"`
	Type      string      `json:"type_name"`
	Index     string      `json:"index"`
}

type EsIndexInfo struct {
	EsConnect int         `json:"es_connect"`
	Settings  common.Json `json:"settings"`
	IndexName string      `json:"index_name"`
	Types     string      `json:"types"`
}

type EsMapGetProperties struct {
	EsConnectID int    `json:"es_connect"`
	IndexName   string `json:"index_name"`
}

type EsMappingInfo struct {
	IndexNameList []string    `json:"index_name_list"`
	EsConnect     int         `json:"es_connect"`
	Mappings      common.Json `json:"mappings"`
	IndexName     string      `json:"index_name"`
}

type EsOptimize struct {
	EsConnect int    `json:"es_connect"`
	IndexName string `json:"index_name"`
}

type EsReIndexInfo struct {
	EsConnect int `json:"es_connect"`
	UrlValues struct {
		Timeout             int    `json:"timeout"`
		RequestsPerSecond   int    `json:"requests_per_second"`
		Slices              int    `json:"slices"`
		Scroll              string `json:"scroll"`
		WaitForActiveShards string `json:"wait_for_active_shards"`
		Refresh             *bool  `json:"refresh"`
		WaitForCompletion   *bool  `json:"wait_for_completion"`
	} `json:"url_values"`
	Body map[string]interface{} `json:"body"`
}

type EsRest struct {
	EsConnect int    `json:"es_connect"`
	Body      string `json:"body"`
	Path      string `json:"path"`
}

type EsSnapshotInfo struct {
	EsConnect        int      `json:"es_connect"`         //es连接id
	SnapshotInfoList []string `json:"snapshot_info_list"` //存储库
}

type EsTaskInfo struct {
	EsConnect    int      `json:"es_connect"`
	TaskId       []string `json:"task_id"`
	Actions      []string `json:"actions"`
	NodeId       []string `json:"node_id"`
	ParentTaskId string   `json:"parent_task_id"`
}

type ExecMoreReq struct {
	// 插件ID
	PluginId string `json:"plugin_id"`
	// SQL语句列表
	Sqls []ExecSql `json:"sqls"`
}

type ExecSql struct {
	// SQL语句
	Sql string `json:"sql"`
	// SQL参数
	Args []interface{} `json:"args"`
}

type ExecSqlReq struct {
	// 插件ID
	PluginId string `json:"plugin_id"`
	// SQL语句
	Sql string `json:"sql"`
	// SQL参数
	Args []interface{} `json:"args"`
}

type FindMongoDocumentsReq struct {
	EsConnectData  EsConnectData `json:"es_connect_data"`
	DbName         string        `json:"db_name"`
	CollectionName string        `json:"collection_name"`
	Filter         bson.M        `json:"filter"`
	Projection     bson.M        `json:"projection"`
	Sort           bson.D        `json:"sort"`
	Skip           int64         `json:"skip"`
	Limit          int64         `json:"limit"`
}

type FlushReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
	FlushReqData  FlushReqData  `json:"flush_req"`
}

type FlushReqData struct {
	IndexNames []string `json:"index_names"`
}

type GetAliasesReq struct {
	EsConnectData     EsConnectData     `json:"es_connect_data"`
	GetAliasesReqData GetAliasesReqData `json:"get_aliases_req_data"`
}

type GetAliasesReqData struct {
	IndexNames []string
}

type GetEsCfgRelation struct {
	ID int `json:"id"`
}

type GetIndicesReq struct {
	EsConnectData     EsConnectData     `json:"es_connect_data"`
	GetIndicesReqData GetIndicesReqData `json:"get_indices_req_data"`
}

type GetIndicesReqData struct {
	CatIndicesRequest proto.CatIndicesRequest
}

type GetMappingReq struct {
	EsConnectData     EsConnectData     `json:"es_connect_data"`
	GetMappingReqData GetMappingReqData `json:"get_mapping_req_data"`
}

type GetMappingReqData struct {
	IndexNames []string
}

type GetMongoCollectionsReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
	DbName        string        `json:"db_name"`
}

type GetRoles4UserIdReq struct {
	UserId int `json:"user_id"`
}

type IndicesClearCacheReq struct {
	EsConnectData            EsConnectData            `json:"es_connect_data"`
	IndicesClearCacheReqData IndicesClearCacheReqData `json:"indices_clear_cache_req_data"`
}

type IndicesClearCacheReqData struct {
	IndexNames []string `json:"index_names"`
}

type IndicesCloseReq struct {
	EsConnectData       EsConnectData       `json:"es_connect_data"`
	IndicesCloseReqData IndicesCloseReqData `json:"indices_close_req_data"`
}

type IndicesCloseReqData struct {
	IndexNames []string `json:"index_names"`
}

type IndicesForcemergeReq struct {
	EsConnectData            EsConnectData            `json:"es_connect_data"`
	IndicesForcemergeReqData IndicesForcemergeReqData `json:"indices_forcemerge_req_data"`
}

type IndicesForcemergeReqData struct {
	IndexNames     []string `json:"index_names"`
	MaxNumSegments *int     `json:"max_num_segments"`
}

type IndicesGetSettingsRequestReq struct {
	EsConnectData                    EsConnectData                    `json:"es_connect_data"`
	IndicesGetSettingsRequestReqData IndicesGetSettingsRequestReqData `json:"indices_get_settings_request_req_data"`
}

type IndicesGetSettingsRequestReqData struct {
	IndicesGetSettingsRequest proto.IndicesGetSettingsRequest
}

type IndicesPutSettingsRequest struct {
	EsConnectData                 EsConnectData                 `json:"es_connect_data"`
	IndicesPutSettingsRequestData IndicesPutSettingsRequestData `json:"indices_put_settings_request_data"`
}

type IndicesPutSettingsRequestData struct {
	IndexSettingsRequest proto.IndicesPutSettingsRequest
	Body                 interface{}
}

type IndicesSegmentsRequest struct {
	EsConnectData              EsConnectData              `json:"es_connect_data"`
	IndicesSegmentsRequestData IndicesSegmentsRequestData `json:"indices_segments_request_data"`
}

type IndicesSegmentsRequestData struct {
	Human bool `json:"human"`
}

type InsertEsLink struct {
	Ip      string `json:"ip"`
	Remark  string `json:"remark"`
	Version int    `json:"version"`
	CfgIds  []int  `json:"cfgIds"`
}

type InsertEsLinkCfg struct {
	User       string   `json:"user"`
	Pwd        string   `json:"pwd"`
	Remark     string   `json:"remark"`
	RootPEM    string   ` json:"rootpem" `
	CertPEM    string   ` json:"certpem" `
	KeyPEM     string   `json:"keypem" `
	ShareRoles []string `json:"share_roles"`
}

type InsertManyMongoDocumentsReq struct {
	EsConnectData  EsConnectData `json:"es_connect_data"`
	DbName         string        `json:"db_name"`
	CollectionName string        `json:"collection_name"`
	Docs           []bson.M      `json:"docs"`
}

type InsertMongoDocumentReq struct {
	EsConnectData  EsConnectData `json:"es_connect_data"`
	DbName         string        `json:"db_name"`
	CollectionName string        `json:"collection_name"`
	Doc            bson.M        `json:"doc"`
}

type InsertOrUpdateDb struct {
	// 插件ID
	PluginId string `json:"plugin_id"`
	// 目标表名
	TableName string `json:"table"` // 目标表名
	// 没有则新增，有则更新的数据
	UpsertData map[string]interface{} // 没有则新增，有则更新
	// 冲突检查的唯一键
	UniqueKeys []string // 冲突检查的唯一键
}

type LiveBroadcast struct {
	Channel string      `json:"channel"`
	Data    interface{} `json:"data"`
}

type LiveBroadcastEvMsg2AllReq struct {
	NoticeData *NoticeData `json:"notice_data"`
}

type LiveBroadcastEvMsg2RolesReq struct {
	NoticeData *NoticeData `json:"notice_data"`
	RoleIds    []int       `json:"role_ids"`
}

type LiveBroadcastEvMsg2UsersReq struct {
	NoticeData *NoticeData `json:"notice_data"`
	UserIds    []int       `json:"user_ids"`
}

type LoadDebugPlugin struct {
	ID      string `json:"id"`
	Addr    string `json:"addr"`
	Pid     int    `json:"pid"`
	NetType string `json:"net_type"`
}

type MongoExecReq struct {
	// ES连接数据
	EsConnectData EsConnectData `json:"es_connect_data"`
	// 数据库名称
	DbName string `json:"db_name"`
	// MongoDB命令
	Command bson.D `json:"command"`
	// 超时时间
	Timeout time.Duration `json:"timeout"`
}

type MoveToAnotherIndexAliasesReq struct {
	EsConnectData                    EsConnectData                    `json:"es_connect_data"`
	MoveToAnotherIndexAliasesReqData MoveToAnotherIndexAliasesReqData `json:"move_to_another_index_aliases_req_data"`
}

type MoveToAnotherIndexAliasesReqData struct {
	Body proto.AliasAction
}

type MysqlDbsReq struct {
	// ES连接数据
	EsConnectData EsConnectData `json:"es_connect_data"`
}

type MysqlExecReq struct {
	// ES连接数据
	EsConnectData EsConnectData `json:"es_connect_data"`
	// SQL语句
	Sql string `json:"sql"`
	// SQL参数
	Args []interface{} `json:"args"`
	// 数据库名称
	DbName string `json:"dbName"`
}

type MysqlSelectReq struct {
	// ES连接数据
	EsConnectData EsConnectData `json:"es_connect_data"`
	// SQL语句
	Sql string `json:"sql"`
	// SQL参数
	Args []interface{} `json:"args"`
	// 数据库名称
	DbName string `json:"dbName"`
}

type MysqlTablesReq struct {
	// ES连接数据
	EsConnectData EsConnectData `json:"es_connect_data"`
	// 数据库名称
	DbName string `json:"dbName"`
}

type NoticeBtnJumpType = string

type NoticeData struct {
	Title         string         `json:"title"`                     //标题
	Content       string         `json:"content"`                   //内容
	Type          string         `json:"type"`                      //通知类型（如 system, alert, announcement）
	Level         NoticeLevel    `json:"level"`                     //消息严重程度 info, warn, danger,success,primary
	IsTask        bool           `json:"is_task"`                   //是否定时任务
	FromUid       int            `json:"from_uid"`                  //用户id
	PluginAlias   string         `json:"plugin_alias"`              //插件id
	Source        string         `json:"source"`                    //来源
	NoticeJumpBtn *NoticeJumpBtn `json:"notice_jump_btn,omitempty"` //跳转按钮
	PublishTime   time.Time      `json:"publish_time"`              //发布时间
}

type NoticeJumpBtn struct {
	Text     string            `json:"text"`      //按钮文案
	JumpUrl  string            `json:"jump_url"`  //跳转链接
	JumpType NoticeBtnJumpType `json:"jump_type"` // 跳转类型: "internal" 或 "external"
}

type NoticeLevel = string

type OpenReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
	OpenReqData   OpenReqData   `json:"open_req_data"`
}

type OpenReqData struct {
	IndexNames []string `json:"index_names"`
}

type PerformRequest struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
	Request       *Request      `json:"request"`
}

type PingReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
}

type PluginRunDsl struct {
	EsConnectData *EsConnectData `json:"es_connect_data"`
	Params        url.Values     `json:"-"`
	HttpMethod    string         `json:"http_method"`
	Path          string         `json:"path"`
	Dsl           string         `json:"dsl"`
}

type PluginRunDsl2 struct {
	Params     url.Values `json:"-"`
	HttpMethod string     `json:"http_method"`
	Path       string     `json:"path"`
	Dsl        string     `json:"dsl"`
}

type PutMappingReq struct {
	EsConnectData     EsConnectData     `json:"es_connect_data"`
	PutMappingReqData PutMappingReqData `json:"put_mapping_req_data"`
}

type PutMappingReqData struct {
	IndicesPutMappingRequest proto.IndicesPutMappingRequest
	Body                     interface{}
}

type RedisBatchExecReq struct {
	// ES连接数据
	EsConnectData EsConnectData `json:"es_connect_data"`
	// 命令参数
	Args [][]interface{} `json:"args"`
	// 数据库索引
	DbName int `json:"dbName"`
}

type RedisExecReq struct {
	// ES连接数据
	EsConnectData EsConnectData `json:"es_connect_data"`
	// 命令参数
	Args []interface{} `json:"args"`
	// 数据库索引
	DbName int `json:"dbName"`
}

type RefreshReq struct {
	EsConnectData  EsConnectData  `json:"es_connect_data"`
	RefreshReqData RefreshReqData `json:"refresh_req_data"`
}

type RefreshReqData struct {
	IndexNames []string `json:"index_names"`
}

type ReindexReq struct {
	EsConnectData  EsConnectData  `json:"es_connect_data"`
	ReindexReqData ReindexReqData `json:"reindex_req_data"`
}

type ReindexReqData struct {
	ReindexRequest proto.ReindexRequest
	Body           interface{}
}

type RemoveAliasesReq struct {
	EsConnectData        EsConnectData        `json:"es_connect_data"`
	RemoveAliasesReqData RemoveAliasesReqData `json:"remove_aliases_req_data"`
}

type RemoveAliasesReqData struct {
	IndexName []string
	AliasName []string
}

type Request struct {
	Method        string
	URL           *url.URL
	Header        http.Header
	Form          url.Values
	PostForm      url.Values
	MultipartForm *multipart.Form
	JsonBody      string
}

type RestoreSnapshotReq struct {
	EsConnectData          EsConnectData          `json:"es_connect_data"`
	RestoreSnapshotReqData RestoreSnapshotReqData `json:"restore_snapshot_req_data"`
}

type RestoreSnapshotReqData struct {
	Repository        string
	Snapshot          string
	WaitForCompletion *bool
	ReqJson           proto.Json
}

type SaveDb struct {
	// 插件ID
	PluginId string `json:"plugin_id"`
	// 目标表名
	TableName string `json:"table"` // 目标表名
	// 要插入或更新的数据
	Data interface{} `json:"data"` // 要插入或更新的数据
}

type SearchReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
	SearchReqData SearchReqData `json:"search_req_data"`
}

type SearchReqData struct {
	SearchRequest proto.SearchRequest
	Query         interface{}
}

type SelectReq struct {
	// 插件ID
	PluginId string `json:"plugin_id"`
	// SQL语句
	Sql string `json:"sql"`
	// SQL参数
	Args []interface{} `json:"args"`
}

type SelectType struct {
	ID     int    `json:"id"`
	Remark string `json:"remark"`
	Typ    string `json:"typ"`
}

type ShowMongoDbsReq struct {
	// ES连接数据
	EsConnectData EsConnectData `json:"es_connect_data"`
}

type SnapshotCreateRepository struct {
	EsConnect              int    `json:"es_connect"`                 //es连接id
	Repository             string `json:"name"`                       //存储库名
	Type                   string `json:"type"`                       //类型 fs/url
	Location               string `json:"location"`                   //存储位置
	Compress               string `json:"compress"`                   //是否压缩 true/false
	MaxRestoreBytesPerSec  string `json:"max_restore_bytes_per_sec"`  //节点恢复速率
	MaxSnapshotBytesPerSec string `json:"max_snapshot_bytes_per_sec"` //每个节点快照速率
	ChunkSize              string `json:"chunk_size"`                 //大文件分解块大小
	Readonly               string `json:"readonly"`                   //是否只读
}

type SnapshotCreateRepositoryReq struct {
	EsConnectData                   EsConnectData                   `json:"es_connect_data"`
	SnapshotCreateRepositoryReqData SnapshotCreateRepositoryReqData `json:"snapshot_create_repository_req_data"`
}

type SnapshotCreateRepositoryReqData struct {
	Repository string
	ReqJson    proto.Json
}

type SnapshotCreateReq struct {
	EsConnectData         EsConnectData         `json:"es_connect_data"`
	SnapshotCreateReqData SnapshotCreateReqData `json:"snapshot_create_req_data"`
}

type SnapshotCreateReqData struct {
	Repository        string
	Snapshot          string
	WaitForCompletion *bool
	ReqJson           proto.Json
}

type SnapshotDelete struct {
	EsConnect  int    `json:"es_connect"`
	Repository string `json:"repository"`
	Snapshot   string `json:"snapshot"`
}

type SnapshotDeleteRepository struct {
	EsConnect  int    `json:"es_connect"` //es连接id
	Repository string `json:"name"`       //存储库名
}

type SnapshotDeleteRepositoryReq struct {
	EsConnectData                   EsConnectData                   `json:"es_connect_data"`
	SnapshotDeleteRepositoryReqData SnapshotDeleteRepositoryReqData `json:"snapshot_delete_repository_req_data"`
}

type SnapshotDeleteRepositoryReqData struct {
	Repository []string
}

type SnapshotDeleteReq struct {
	EsConnectData         EsConnectData         `json:"es_connect_data"`
	SnapshotDeleteReqData SnapshotDeleteReqData `json:"snapshot_delete_req_data"`
}

type SnapshotDeleteReqData struct {
	Repository string
	Snapshot   string
}

type SnapshotDetail struct {
	EsConnect  int    `json:"es_connect"`
	Repository string `json:"repository"`
	Snapshot   string `json:"snapshot"`
}

type SnapshotGetRepositoryReq struct {
	EsConnectData                EsConnectData                `json:"es_connect_data"`
	SnapshotGetRepositoryReqData SnapshotGetRepositoryReqData `json:"snapshot_get_repository_req_data"`
}

type SnapshotGetRepositoryReqData struct {
	Repository []string
}

type SnapshotList struct {
	EsConnect  int    `json:"es_connect"`
	Repository string `json:"repository"`
}

type SnapshotRestore struct {
	SnapshotName       string   `json:"snapshotName"`
	RepositoryName     string   `json:"repositoryName"`
	IndexList          []string `json:"indexList"`
	IgnoreUnavailable  *bool    `json:"ignore_unavailable"`
	IncludeGlobalState *bool    `json:"include_global_state"`
	Partial            *bool    `json:"partial"`
	Wait               *bool    `json:"wait"`
	EsConnect          int      `json:"es_connect"`
	RenamePattern      string   `json:"rename_pattern"`
	RenameReplacement  string   `json:"rename_replacement"`
}

type SnapshotStatus struct {
	SnapshotName   string `json:"snapshot"`
	RepositoryName string `json:"repository"`
	EsConnect      int    `json:"es_connect"`
}

type SnapshotStatusReq struct {
	EsConnectData         EsConnectData         `json:"es_connect_data"`
	SnapshotStatusReqData SnapshotStatusReqData `json:"snapshot_status_req_data"`
}

type SnapshotStatusReqData struct {
	Repository        string
	Snapshot          []string
	IgnoreUnavailable *bool
}

type SortStruct struct {
	Col      string `json:"col"`
	SortRule string `json:"sortRule"`
}

type SqlToDsl struct {
	Sql string `json:"sql"`
}

type StopDebugPlugin struct {
	ID string `json:"id"`
}

type TaskList struct {
	EsConnect int `json:"es_connect"`
}

type TaskListReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
}

type TasksCancelReq struct {
	EsConnectData      EsConnectData      `json:"es_connect_data"`
	TasksCancelReqData TasksCancelReqData `json:"tasks_cancel_req_data"`
}

type TasksCancelReqData struct {
	TaskId string
}

type TransferLogReq struct {
	EsConnect int `json:"es_connect"`
}

type TransferReq struct {
	AutoIncrementId string `json:"autoIncrementId"`
	EsConnect       int    `json:"es_connect"`
	SelectType      string `json:"selectType"`
	Remark          string `json:"remark"`
	SelectTable     string `json:"selectTable"`
	TypeName        string `json:"type_name"`
	Cols            struct {
		TableCols []string `json:"tableCols"`
		EsCols    []struct {
			Col   string `json:"col"`
			TbCol string `json:"tbCol"`
		} `json:"esCols"`
	} `json:"cols"`
	IndexName       string `json:"indexName"`
	Reset           bool   `json:"reset"`
	GoNum           int    `json:"goNum"`
	EsFlushInterval int    `json:"esFlushInterval"`
	EsBufferSize    int    `json:"esBufferSize"`
	EsDocID         string `json:"esDocId"`
	BufferSize      int    `json:"bufferSize"`
	MaxIdleConns    int    `json:"maxIdleConns"`
	MaxOpenConns    int    `json:"maxOpenConns"`
	CrontabSpec     string `json:"crontab_spec"`
}

type UpdateDb struct {
	// 插件ID
	PluginId string `json:"plugin_id"`
	// 目标表名
	TableName string `json:"table"` // 目标表名
	// 更新SQL语句
	UpdateSql string `json:"update_sql"`
	// 更新SQL参数
	UpdateArgs []interface{} `json:"update_args"`
	// 要插入或更新的数据
	Data map[string]interface{} `json:"data"` // 要插入或更新的数据
}

type UpdateEsLink struct {
	Id      int    `json:"id"`
	Ip      string `json:"ip"`
	Remark  string `json:"remark" `
	Version int    `json:"version"`
	CfgIds  []int  `json:"cfgIds"`
}

type UpdateEsLinkCfg struct {
	Id         int      `json:"id"`
	User       string   `json:"user"`
	Pwd        string   `json:"pwd"`
	Remark     string   `json:"remark"`
	RootPEM    string   ` json:"rootpem" `
	CertPEM    string   ` json:"certpem" `
	KeyPEM     string   `json:"keypem" `
	ShareRoles []string `json:"share_roles"`
	LinkId     int      `json:"linkId"`
}

type UpdateMapping struct {
	EsConnect  int         `json:"es_connect"`
	IndexName  string      `json:"index_name"`
	TypeName   string      `json:"type_name"`
	Properties common.Json `json:"properties"`
}

type UpdateMongoDocumentReq struct {
	EsConnectData  EsConnectData `json:"es_connect_data"`
	DbName         string        `json:"db_name"`
	CollectionName string        `json:"collection_name"`
	DocId          interface{}   `json:"doc_id"`
	Update         bson.M        `json:"update"`
	Filter         bson.M        `json:"filter"`
}

type UpdateReq struct {
	EsConnectData EsConnectData `json:"es_connect_data"`
	UpdateReqData UpdateReqData `json:"update_req_data"`
}

type UpdateReqData struct {
	UpdateRequest proto.UpdateRequest
	Body          interface{}
}