cronjob

type CronJob struct {
	// 任务Id
	Id string `json:"id" gorm:"column:id;type:string;primary_key;" unique:"true" description:"Id"`
	// 创建时间
	CreatedAt time.Time `` /* 126-byte string literal not displayed */

	// Cronjob参数
	CronJobSpec
	// 状态
	CronJobStatus
}

type CronJobSpec struct {
	// 定时任务名称
	Name string `json:"name" gorm:"column:name;type:varchar(120)" description:"定时任务名称"`
	// 定时任务名称
	Description string `json:"description" gorm:"column:description;type:text" description:"定时任务描述"`
	// Cron表达式
	Cron string `json:"cron" gorm:"column:cron;type:varchar(120)" description:"Cron表达式"`
	// 是否启用改Cron
	Enabled *bool `json:"enabled" gorm:"column:enabled;type:bool" description:"是否启用改Cron"`
	// Task执行参数
	task.TaskSpec
}

type CronJobStatus struct {
	// 关联的cron实例Id
	RefInstanceId int `json:"ref_instance_id" gorm:"column:ref_instance_id;" description:"关联的cron实例Id"`
	// CronJob执行的Node节点信息
	Node string `json:"node" gorm:"column:node;" description:"CronJob执行的Node节点信息"`
	// 状态更新时间
	UpdateAt *time.Time `json:"update_at" gorm:"column:update_at;type:timestamp;;" description:"状态更新时间"`
	// 最新一次允许时间
	LatestRunAt *time.Time `json:"latest_run_at" gorm:"column:latest_run_at;type:timestamp;;" description:"最新一次允许时间"`
	// 最新一次执行的任务
	LatestTaskId string `json:"latest_task_id" gorm:"column:latest_task_id;" description:"最新一次执行的任务"`
	// 状态
	Status STATUS `json:"statsu" gorm:"column:statsu;" description:"CronJob状态"`
	// 状态
	Message string `json:"message" gorm:"column:message;" description:"状态的消息"`
}

type DeleteCronJobRequest struct {
	DescribeCronJobRequest
}

type DescribeCronJobRequest struct {
	// 任务Id
	Id string `json:"id" description:"Id"`
}

type QUEUE_EVENT_TYPE string

type QueryCronJobRequest struct {
	// 分页参数
	*request.PageRequest
	// 任务名称
	Name string `json:"name"`
}

type QueueEvent struct {
	// 事件类型
	Type QUEUE_EVENT_TYPE `json:"type"`
	// 事件值
	CronJobId string `json:"cron_job_id"`
}

type STATUS string

type Service interface {
	// 添加CronJob
	AddCronJob(context.Context, *CronJobSpec) (*CronJob, error)
	// 查询列表
	QueryCronJob(context.Context, *QueryCronJobRequest) (*types.Set[*CronJob], error)
	// 查询详情
	DescribeCronJob(context.Context, *DescribeCronJobRequest) (*CronJob, error)
	// 更新Cronjob
	UpdateCronJob(context.Context, *UpdateCronJobRequest) (*CronJob, error)
	// 删除Cronjob
	DeleteCronJob(context.Context, *DeleteCronJobRequest) (*CronJob, error)
}

type UpdateCronJobRequest struct {
	DescribeCronJobRequest
	CronJobSpec
}