web

type AIChatReq struct {
	SessionID string `json:"sessionID" binding:"required"`
	Text      string `json:"text" binding:"required"`
	// Action 任务类型：generate（默认）/ explain / fix / optimize / continue
	Action string `json:"action"`
	// MsgID 本次发起的唯一流水号（前端按会话递增），后端据此幂等去重：
	// 同一流水号已处理时重放结果、悬空时复用继续，杜绝重复消息污染上下文。
	MsgID string `json:"msgId"`
	// ConnID / DB / TabID：会话失效时后端据此透明重建（保留多轮上下文，按 tab 隔离）。
	ConnID string `json:"connId"`
	DB     string `json:"db"`
	TabID  string `json:"tabId"`
	// History 可选：当前对话历史（会话重建时回放，保留多轮上下文）。
	History []HistoryItem `json:"history"`
}

type AISessionIDReq struct {
	ID string `uri:"id" binding:"required"`
}

type AISessionReq struct {
	ConnID string `json:"connId" binding:"required"`
	DB     string `json:"db"`
	// TabID 可选：所属 query tab（按 tab 隔离对话；空 = 不隔离）。
	TabID string `json:"tabId"`
	// History 可选：会话重建时回放的历史消息（role/content/msgId），保留多轮上下文。
	History []HistoryItem `json:"history"`
}

type BrowseDirsReq struct {
	Path string `query:"path"`
}

type CellValueReq struct {
	ConnID    string   `json:"connId" binding:"required"`
	DB        string   `json:"db"`                           // 目标库名
	Table     string   `json:"table" binding:"required"`     // 表名
	Column    string   `json:"column" binding:"required"`    // 目标列名
	PKColumns []string `json:"pkColumns" binding:"required"` // 主键列名
	PKValues  []any    `json:"pkValues" binding:"required"`  // 主键值
}

type CompareReq struct {
	Options      service.CompareOptions `json:"options"`
	TaskConfigID string                 `json:"taskConfigId"`
}

type CompareResultReq struct {
	TaskID string `query:"taskID" binding:"required"`
}

type CreateSnapshotReq struct {
	ConnID         string   `json:"connId" binding:"required"`
	DBNames        []string `json:"dbNames" binding:"required"`
	Name           string   `json:"name" binding:"required"`
	Description    string   `json:"description"`
	IncludeSamples bool     `json:"includeSamples"`
	SampleLimit    int      `json:"sampleLimit"` // 每表采样行数；<=0 走默认 10
}

type DeleteConnReq struct {
	ID string `uri:"id" binding:"required"`
}

type DeleteRowsReq struct {
	ConnID    string   `json:"connId" binding:"required"`
	DB        string   `json:"db"`                           // 目标库名
	Table     string   `json:"table" binding:"required"`     // 表名
	PKColumns []string `json:"pkColumns" binding:"required"` // 主键列名
	Rows      [][]any  `json:"rows" binding:"required"`      // 每行主键值数组（与 PKColumns 顺序一致）
}

type DictionaryReq struct {
	Options      service.DictionaryOptions `json:"options"`
	Compress     *bool                     `json:"compress"` // 未指定时默认 true
	TaskConfigID string                    `json:"taskConfigId"`
}

type ExportReq struct {
	Options      service.ExportOptions `json:"options"`
	Compress     *bool                 `json:"compress"` // 未指定时默认 true
	TaskConfigID string                `json:"taskConfigId"`
}

type FavoriteAddReq struct {
	ConnID string `json:"connId" binding:"required"`
	Title  string `json:"title"`
	DB     string `json:"db"`
	Mode   string `json:"mode"`
	SQL    string `json:"sql" binding:"required"`
}

type FavoriteRenameReq struct {
	ID    string `json:"id" binding:"required"`
	Title string `json:"title" binding:"required"`
}

type FavoriteReq struct {
	ConnID string `query:"connId"`
}

type GetDatabaseListReq struct {
	ID    string `uri:"id" binding:"required"`
	Force bool   `query:"force"`
}

type GetDbObjectsReq struct {
	ID    string `uri:"id" binding:"required"`
	DB    string `query:"db" binding:"required"`
	Force bool   `query:"force"`
}

type GetDbSchemasReq struct {
	ID    string `uri:"id" binding:"required"`
	DB    string `query:"db" binding:"required"`
	Force bool   `query:"force"`
}

type GetHistoryReq struct {
	TaskID string `uri:"taskID" binding:"required"`
}

type GetLastTaskReq struct {
	Type string `uri:"type" binding:"required"`
}

type GetSchemaObjectsReq struct {
	ID     string `uri:"id" binding:"required"`
	DB     string `query:"db" binding:"required"`
	Schema string `query:"schema" binding:"required"`
	Force  bool   `query:"force"`
}

type GetSnapshotReq struct {
	ID string `uri:"id" binding:"required"`
}

type GetTableColumnsReq struct {
	ID    string `uri:"id" binding:"required"`
	DB    string `query:"db"`
	Table string `query:"table" binding:"required"`
}

type GetTablesReq struct {
	ID string `uri:"id" binding:"required"`
	DB string `query:"db"`
}

type GetTaskReq struct {
	ID string `query:"id" binding:"required"`
}

type HistoryItem struct {
	Role    string `json:"role"`
	Content string `json:"content"`
	MsgID   string `json:"msgId"`
}

type ImportReq struct {
	Options      service.ImportOptions `json:"options"`
	Backup       *bool                 `json:"backup"` // 未指定时默认 true
	TaskConfigID string                `json:"taskConfigId"`
}

type InsertRowReq struct {
	ConnID  string   `json:"connId" binding:"required"`
	DB      string   `json:"db"`                         // 目标库名
	Table   string   `json:"table" binding:"required"`   // 表名
	Columns []string `json:"columns" binding:"required"` // 写入列名（与 Values 顺序一致）
	Values  []any    `json:"values" binding:"required"`  // 对应列值（null 表示 NULL）
}

type InspectReq struct {
	Path string `json:"path" binding:"required"`
}

type ListHistoryReq struct {
	Type         string `query:"type"`
	TaskConfigID string `query:"taskConfigId"`
}

type ListTasksReq struct {
	Type string `query:"type"`
}

type MigrateReq struct {
	Options      service.MigrateOptions `json:"options"`
	Backup       *bool                  `json:"backup"` // 未指定时默认 true
	TaskConfigID string                 `json:"taskConfigId"`
}

type MountOptions struct {
	// Prefix 页面 + API 挂载前缀，默认 "/dqex"：API 挂 Prefix+"/api"，前端页面挂 Prefix+"/"。
	// 传 "" 时 API="/api"、页面="/"（与 RunWeb 独立部署路径一致）。
	Prefix string
	// FrameAncestors 允许 iframe 嵌入本服务的宿主 origin 白名单（CSP frame-ancestors，
	// 对本挂载子树全部响应生效）；生产环境建议显式配置，防止任意站点嵌入。
	FrameAncestors []string
	// Fallback 前端静态资源未命中时的回退（如宿主自己的 SPA/404 页面 handler，可为 nil）。
	// dqex UI 与宿主 SPA 共存时：先经 dqex 静态资源匹配，未命中交回宿主处理。
	Fallback gin.HandlerFunc
}

type PingResult struct {
	OK        bool   `json:"ok"`
	ElapsedMS int64  `json:"elapsedMs"`
	Error     string `json:"error,omitempty"`
}

type ProcInfo struct {
	PID  int
	Name string
}

type RunTaskReq struct {
	ID string `json:"id" binding:"required"`
}

type SQLAuditReq struct {
	ConnID string `query:"connId"` // 空 = 全部连接
	Limit  int    `query:"limit"`  // <=0 默认 100，上限 500
	Offset int    `query:"offset"`
}

type SQLDDLReq struct {
	ConnID string `query:"connId" binding:"required"`
	DB     string `query:"db"`                      // 库名（Oracle 下为 schema）
	Type   string `query:"type" binding:"required"` // table / view / function / procedure
	Name   string `query:"name" binding:"required"`
}

type SQLGenReq struct {
	ConnID string `json:"connId" binding:"required"`
	DB     string `json:"db"` // 目标库名（点对象树查表时传入，覆盖连接默认库）
	engine.GenSQLParams
}

type SQLHistoryReq struct {
	ConnID string `query:"connId" binding:"required"`
}

type SQLPingReq struct {
	ConnID string `json:"connId" binding:"required"`
}

type SQLRunReq struct {
	ConnID string `json:"connId" binding:"required"`
	DB     string `json:"db"` // 目标库名（点对象树查表时传入，覆盖连接默认库）
	SQL    string `json:"sql" binding:"required"`
	Limit  int    `json:"limit"`  // 返回行数上限，<=0 走默认（1000），最大 1000
	Offset int    `json:"offset"` // 分页偏移
	Mask   bool   `json:"mask"`   // 结果集脱敏：敏感列（password/token/secret 等）统一打码
	Mode   string `json:"mode"`   // 执行模式：transform（默认，转换+限制）| raw（原始直传）
}

type SaveConnReq struct {
	ID        string             `json:"id"`
	Name      string             `json:"name" binding:"required"`
	ShortName string             `json:"shortName"` // 命令行简写
	Env       string             `json:"env"`       // dev/test/staging/prod
	Conn      service.DBConnInfo `json:"conn"`
}

type SnapshotCompareReq struct {
	Options      service.SnapshotCompareOptions `json:"options"`
	TaskConfigID string                         `json:"taskConfigId"`
}

type SnapshotCompareResultReq struct {
	TaskID string `query:"taskID" binding:"required"`
}

type StartResp struct {
	TaskID string `json:"taskID"`
}

type TablePageReq struct {
	ConnID         string                `json:"connId" binding:"required"`
	DB             string                `json:"db"` // 目标库名（点对象树查表时传入，覆盖连接默认库）
	Table          string                `json:"table" binding:"required"`
	Page           int                   `json:"page"`
	PageSize       int                   `json:"pageSize"`
	SortSpecs      []engine.SortSpec     `json:"sortSpecs"`      // 多列排序（按顺序叠加 ORDER BY）
	ExcludeColumns []string              `json:"excludeColumns"` // 省略的大字段列名（二进制/超长文本，列表不取真实值）
	Filters        []engine.ColumnFilter `json:"filters"`        // 列过滤条件（AND 叠加）
	MaxRows        int                   `json:"maxRows"`        // 导出时行数上限（仅 /table-export 使用，默认 100000）
}

type TestConnReq struct {
	ID   string             `json:"id"`
	Conn service.DBConnInfo `json:"conn"`
}

type UpdateCellReq struct {
	ConnID    string   `json:"connId" binding:"required"`
	DB        string   `json:"db"`                           // 目标库名
	Table     string   `json:"table" binding:"required"`     // 表名
	Column    string   `json:"column" binding:"required"`    // 目标列名
	Value     any      `json:"value"`                        // 新值（null 表示 SET NULL）
	PKColumns []string `json:"pkColumns" binding:"required"` // 主键列名
	PKValues  []any    `json:"pkValues" binding:"required"`  // 主键值
}

type UploadReq struct {
	File *multipart.FileHeader `file:"file" binding:"required"`
}

type VersionInfo struct {
	Version   string   `json:"version"`
	CommitID  string   `json:"commitId"`
	BuildTime string   `json:"buildTime"`
	DBTypes   []string `json:"dbTypes"`
	// ShowLinks 是否展示开源项目链接（opensource 构建时为 true）
	ShowLinks bool `json:"showLinks"`
}

type WorkspaceGetReq struct {
	ConnID string `query:"connId" binding:"required"`
}

type WorkspaceSaveReq struct {
	ConnID      string                 `json:"connId" binding:"required"`
	Tabs        []service.WorkspaceTab `json:"tabs" binding:"required"`
	ActiveID    string                 `json:"activeId"`
	TabSettings *service.TabSettings   `json:"tabSettings,omitempty"`
}