dao

type DepsTree struct {
	*Task
	Children []*DepsTree
}

type JobResult struct {
	Id           uint   `gorm:"primary_key"`
	JobName      string `json:"job_name"`
	DispatchID   string `json:"dispatch_id"`
	JobCompleted bool
	GroupID      float64   `json:"group_id"`
	AgentNode    string    `json:"agent_node"`
	StartedAt    time.Time `json:"started_at"`
	FinishedAt   time.Time `json:"finished_at"`
	Status       int       `json:"status"`
	Output       string    `json:"output,omitempty" gorm:"column:output_data"`
}

type LogResult struct {
	Log   []*jobLog `json:"log"`
	Count int       `json:"count"`
}

type Machine struct {
	ginp.Model
	System string `binding:"required" json:"system" gorm:"unique_index:idx_ip_system"`
	IP     string `json:"ip" gorm:"unique_index:idx_ip_system"`
	Status int    `json:"status"`

	// operator
	Comment  string `binding:"required" json:"comment"`
	Operator string `json:"author"`

	// only for request form
	Cron bool   `json:"cron" gorm:"-"`
	IPs  string `binding:"required" json:"ips" gorm:"-"`
}

type Node struct {
	Name  string
	Tasks []*Task
}

type Query struct {
	Keyword  string   `form:"keyword" json:"keyword"`
	System   string   `form:"system" json:"system"`
	Topic    string   `form:"topic" json:"topic"`
	Queue    string   `form:"queue" json:"queue"`
	Count    int      `form:"count" json:"count"`
	Machines []string `form:"machines" json:"machines"`
}

type Queue struct {
	ginp.Model
	Name       string `binding:"required" json:"name" gorm:"unique_index"`
	Describe   string `binding:"required" json:"desc" gorm:"column:description"`
	Password   string `binding:"required" json:"password"`
	TopicCount int    `json:"topics"`

	// operator
	Comment  string `binding:"required" json:"comment"`
	Operator string `json:"author"`
}

type QueueHistory struct {
	ginp.Model
	Queue        string  `json:"queue" gorm:"index:idx_queue"`
	SuccessCount int64   `json:"success_count"`
	FailCount    int64   `json:"fail_count"`
	AddQps       float64 `json:"add_qps"`

	//
	DataType int `binding:"required" json:"type" form:"type" gorm:"-"`
}

type RunType struct {
	Value string
	Type  int
	Unit  string
}

type Storage struct {
	ginp.Model
	System         string        `json:"system" gorm:"unique_index:idx_system_host_port"`
	Type           string        `json:"type" gorm:"default:'redis'"`
	Host           string        `json:"host" gorm:"unique_index:idx_system_host_port"`
	Port           int           `json:"port" gorm:"unique_index:idx_system_host_port"`
	Password       string        `json:"password"`
	MaxConnNum     int           `json:"max_conn_num" gorm:"default:'100'"`
	MaxIdleNum     int           `json:"max_idle_num" gorm:"default:'100'"`
	MaxIdleSeconds time.Duration `json:"max_idle_seconds" gorm:"default:'3000000000'"`
	Status         int           `json:"status"`
	Describe       string        `json:"desc" gorm:"column:description"`

	// operator
	Comment  string `form:"comment"`
	Operator string `form:"author"`
}

type System struct {
	ginp.Model
	Name             string `binding:"required" form:"name" json:"name" gorm:"unique_index"`
	Describe         string `binding:"required" form:"desc" json:"desc" gorm:"column:description"`
	MachineCount     int    `json:"machines"`
	StorageCount     int    `json:"storages"`
	TopicCount       int    `json:"topics"`
	CronMachineCount int    `json:"cron_machines"`
	JobCount         int    `json:"jobs"`

	// operator
	Comment  string `form:"comment"`
	Operator string `form:"author"`

	// cron job count
	JobSuccessCount uint64 `json:"job_success_count" gorm:"-"`
	JobFailCount    uint64 `json:"job_fail_count" gorm:"-"`
}

type Task struct {
	ginp.Model
	System      string `binding:"required" json:"system"`
	Name        string `binding:"required" json:"name" gorm:"unique_index:task_name"`
	Describe    string `binding:"required" json:"desc" gorm:"column:description"`
	TimeOut     int    `json:"timeout" gorm:"default:500"`
	Concurrency int    `json:"concurrency" gorm:"default:'1'"`
	Executor    int    `json:"executor" gorm:"default:0"`
	GRPCHost    string `json:"grpc_host" gorm:"column:grpc_host"`
	Exec        string `json:"command"`
	RunType     string `json:"scheduler"`
	Status      int    `json:"status" gorm:"default:0"`                        // 0表示开启
	NodeStatus  int    `json:"nodeStatus" gorm:"column:node_status;default:0"` // 0表示正常，1表示无可用节点
	DependOn    string `json:"dependents"`
	Children    string `json:"children"`
	Operator    string `json:"author"`
	EnvVar      string `json:"envs"`
}

type TaskDetail struct {
	*Task
	Nodes map[string]interface{}
}

type TaskTest struct {
	ginp.Model
	TaskId     uint64
	TaskJobId  string
	Status     int `gorm:"default:1"`
	Result     string
	TaskDetail string `gorm:"type:text"`
	OpUser     string
}

type Topic struct {
	ginp.Model

	System         string `binding:"required" json:"system"`
	Queue          string `binding:"required" json:"queue" gorm:"unique_index:uix_name_queue_name"`
	Name           string `binding:"required" json:"name" gorm:"unique_index:uix_name_queue_name"`
	Describe       string `binding:"required" json:"desc" gorm:"column:description"`
	ConsumeFile    string `binding:"required" json:"consume"`
	RetryTimes     int    `json:"retry_times" gorm:"default:'3'"`
	MaxQueueLength int    `json:"max_queue_length" gorm:"default:'1000'"`
	RunType        int    `json:"run_type" gorm:"default:'0'"`
	Password       string `json:"password"`
	NumOfWorkers   int    `json:"num_of_workers" gorm:"default:'10'"`
	CgiConfig      string `json:"cgi_config" gorm:"default:'local'"`
	Storage        uint64 `binding:"required" json:"storage"`
	Status         uint8  `json:"status" gorm:"default:0"`
	Alarm          int    `json:"alarm" gorm:"default:200"`
	AlarmRetry     int    `json:"alarm_retry" gorm:"default:100"`
	HttpConfig     string `json:"http_config" gorm:"default:''"`
	TopicConfig    string `json:"topic_config" gorm:"default:''"`

	// operator
	Comment  string `binding:"required" json:"comment"`
	Operator string `json:"author"`
}

type TopicHistory struct {
	ginp.Model
	Queue         string `json:"queue" gorm:"unique_index:uix_queue_topic"`
	Topic         string `json:"topic" gorm:"unique_index:uix_queue_topic"`
	Length        int64  `json:"length"`
	RetryLength   int64  `json:"retry_length"`
	TimeoutLength int64  `json:"timeout_length"`

	//
	DataType int `binding:"required" json:"type" form:"type" gorm:"-"`
}

type TransModelQueue struct {
	Name     string `json:"name"`
	Desc     string `json:"desc"`
	Password string `json:"password"`
	Comment  string `json:"comment"`
	Topics   []TransModelTopic
}

type TransModelStorage struct {
	SType string `json:"type"`
	Host  string `json:"host"`
	Port  string `json:"port"`
}

type TransModelTopic struct {
	System   string            `json:"system"`
	Queue    string            `json:"queue"`
	Name     string            `json:"name"`
	Desc     string            `json:"desc"`
	Password string            `json:"password"`
	Consume  string            `json:"consume"`
	Comment  string            `json:"comment"`
	Status   string            `json:"status"`
	Storage  TransModelStorage `json:"storage"`
}

type User struct {
	ginp.Model

	Name     string `binding:"required" json:"username" gorm:"unique_index"`
	Password string `json:"password"`
	Email    string `json:"email"`
	Avatar   string `json:"avatar"`
	Type     int    `json:"type"`
	Roles    string `json:"roles"`

	AuthSrc int `json:"-"`
}