job

type Config struct {
	// Enabled 是否启用定时任务模块
	Enabled bool
	// DbName 多库(multidb)模式下指定使用的库名，单库模式留空
	DbName string
	// Initdb 是否自动建表（AutoMigrate），默认 true
	Initdb bool
	// TablePrefix 表名前缀，默认 mgin_
	TablePrefix string
	// ScanInterval 调度扫描间隔（秒），默认 1
	ScanInterval int
	// RefreshInterval 从数据库同步任务配置的间隔（秒），默认 30
	RefreshInterval int
	// LogRetainDays 执行日志保留天数，0 表示不清理，默认 30
	LogRetainDays int
	// MaxConcurrent 全局最大并发执行任务数，默认 50
	MaxConcurrent int
	// MaxSerialQueue serial 阻塞策略下的最大排队数，超出则丢弃，默认 10
	MaxSerialQueue int
	// Timezone 调度时区，默认 Local，例如 Asia/Shanghai
	Timezone string
}

type Context struct {

	// JobId 任务 ID
	JobId int64
	// JobName 任务名称
	JobName string
	// JobGroup 任务分组
	JobGroup string
	// HandlerName 执行器名称
	HandlerName string
	// Param 任务参数，来自任务配置的 JobParam 或手动触发时传入的参数
	Param map[string]interface{}
	// LogId 本次执行的日志 ID
	LogId int64
	// TriggerType 触发类型：cron / manual / retry / misfire
	TriggerType string
	// RetryNum 当前重试次数，0 表示首次执行
	RetryNum int
	// contains filtered or unexported fields
}

type HandlerFunc func(ctx *Context) error

type JobInfo struct {
	ID          int64  `gorm:"primaryKey;autoIncrement;comment:任务ID" json:"id" form:"id"`
	JobName     string `` /* 136-byte string literal not displayed */
	JobGroup    string `gorm:"column:job_group;size:50;index;default:DEFAULT;comment:任务分组" json:"jobGroup" form:"jobGroup"`
	Description string `gorm:"column:description;size:255;comment:任务描述" json:"description" form:"description"`

	ScheduleType string `` /* 151-byte string literal not displayed */
	ScheduleConf string `` /* 165-byte string literal not displayed */

	HandlerName string                 `` /* 178-byte string literal not displayed */
	JobParam    map[string]interface{} `gorm:"column:job_param;type:text;serializer:json;comment:任务执行参数" json:"jobParam" form:"jobParam"`

	Timeout         int    `gorm:"column:timeout;default:0;comment:执行超时时间(秒)，0为不限制" json:"timeout" form:"timeout"`
	RetryCount      int    `gorm:"column:retry_count;default:0;comment:失败重试次数" json:"retryCount" form:"retryCount"`
	RetryInterval   int    `gorm:"column:retry_interval;default:0;comment:失败重试间隔(秒)" json:"retryInterval" form:"retryInterval"`
	BlockStrategy   string `` /* 146-byte string literal not displayed */
	MisfireStrategy string `` /* 150-byte string literal not displayed */

	Status int `gorm:"column:status;default:0;index;comment:任务状态 1运行中 0已停止" json:"status" form:"status"`

	LastFireTime *time.Time `gorm:"column:last_fire_time;comment:上次调度时间" json:"lastFireTime"`
	NextFireTime *time.Time `gorm:"column:next_fire_time;comment:下次调度时间" json:"nextFireTime"`
	TriggerCount int64      `gorm:"column:trigger_count;default:0;comment:累计调度次数" json:"triggerCount"`
	SuccessCount int64      `gorm:"column:success_count;default:0;comment:累计成功次数" json:"successCount"`
	FailCount    int64      `gorm:"column:fail_count;default:0;comment:累计失败次数" json:"failCount"`

	Remark   string    `gorm:"column:remark;size:255;comment:备注" json:"remark" form:"remark"`
	CreateAt time.Time `gorm:"column:create_at;autoCreateTime;comment:创建时间" json:"createAt"`
	UpdateAt time.Time `gorm:"column:update_at;autoUpdateTime;comment:更新时间" json:"updateAt"`
}

type JobLog struct {
	ID       int64  `gorm:"primaryKey;autoIncrement;comment:日志ID" json:"id" form:"id"`
	JobId    int64  `gorm:"column:job_id;index;not null;comment:任务ID" json:"jobId" form:"jobId"`
	JobName  string `gorm:"column:job_name;size:100;index;comment:任务名称" json:"jobName" form:"jobName"`
	JobGroup string `gorm:"column:job_group;size:50;index;comment:任务分组" json:"jobGroup" form:"jobGroup"`

	HandlerName string                 `gorm:"column:handler_name;size:100;comment:执行器名称" json:"handlerName"`
	JobParam    map[string]interface{} `gorm:"column:job_param;type:text;serializer:json;comment:本次执行参数" json:"jobParam"`
	TriggerType string                 `gorm:"column:trigger_type;size:20;comment:触发类型 cron|manual|retry|misfire" json:"triggerType"`

	Status   int        `` /* 145-byte string literal not displayed */
	StartAt  time.Time  `gorm:"column:start_at;index;comment:开始执行时间" json:"startAt"`
	EndAt    *time.Time `gorm:"column:end_at;comment:执行结束时间" json:"endAt"`
	CostMs   int64      `gorm:"column:cost_ms;default:0;comment:执行耗时(毫秒)" json:"costMs"`
	RetryNum int        `gorm:"column:retry_num;default:0;comment:当前为第几次重试，0表示首次执行" json:"retryNum"`

	Message   string `gorm:"column:message;type:text;comment:执行结果信息或错误原因" json:"message"`
	LogDetail string `gorm:"column:log_detail;type:text;comment:任务内通过 ctx.Log 输出的执行明细" json:"logDetail"`
	Hostname  string `gorm:"column:hostname;size:100;comment:执行该任务的实例主机名" json:"hostname"`

	CreateAt time.Time `gorm:"column:create_at;autoCreateTime;index;comment:创建时间" json:"createAt"`
}

type Manager struct {
	// contains filtered or unexported fields
}