job

Documentation

Index

• func InitDB(db *gorm.DB) error
• func RegistryCronFunc(db *gorm.DB, spec string, purpose string, taskFunc func() (string, error))
• type AsyncJob
  • func (AsyncJob) TableName() string
• type ExportJob
  • func (ExportJob) TableName() string
• type Job
  • func (j *Job) TableName() string
• type JobStatus

Functions

func InitDB

func InitDB(db *gorm.DB) error

InitDB 初始化数据库

func RegistryCronFunc

func RegistryCronFunc(db *gorm.DB, spec string, purpose string, taskFunc func() (string, error))

RegistryCronFunc 通用任务注册

Types

type AsyncJob

type AsyncJob struct {
	gorm.Model
	// JobUUID
	JobUUID string `gorm:"column:job_uuid;type:varchar(36);not null;index"`
	// CompanyID uint   `gorm:"column:company_id;type:int;not null;index"`
	Uin uint `gorm:"column:uin;type:int;not null;index"`
	// Purpose 任务类型
	Purpose string `gorm:"column:purpose;type:varchar(255);not null;index"`
	// JobStatus 导出状态
	JobStatus JobStatus `gorm:"column:job_status;type:varchar(20);not null;index"`
	// ErrorMsg 错误信息
	ErrorMsg string `gorm:"column:error_msg;type:varchar(255)"`
	// CostSeconds 耗时
	CostSeconds int `gorm:"column:cost_seconds;type:int;not null"`
	// Output 输出内容
	Output string `gorm:"column:output;type:text"`
	// Extra 扩展字段
	Extra string `gorm:"column:extra;type:text"`
}

AsyncJob 异步任务

func (AsyncJob) TableName

func (AsyncJob) TableName() string

TableName 表名

type ExportJob

type ExportJob struct {
	gorm.Model
	// JobUUID
	JobUUID   string `gorm:"column:job_uuid;type:varchar(36);not null;index"`
	CompanyID uint   `gorm:"column:company_id;type:int;not null;index"`
	Uin       uint   `gorm:"column:uin;type:int;not null;index"`
	// Purpose 导出类型,按业务分类，需要和导出文件上传 storage.Storager 的类型一致
	Purpose config.FilePurpose `gorm:"column:purpose;type:varchar(255);not null;index"`
	// ExportStatus 导出状态
	ExportStatus JobStatus `gorm:"column:export_status;type:varchar(20);not null;index"`
	// CostSeconds 耗时
	CostSeconds int `gorm:"column:cost_seconds;type:int;not null"`
	// TimeoutSeconds 超时时间
	TimeoutSeconds int `gorm:"column:timeout_seconds;type:int;not null"`
	// Output 输出路径, 使用 storage.FileInfo.StoragePath 获取
	Output string `gorm:"column:output;type:varchar(255);not null"`
	// ErrorMsg 错误信息
	ErrorMsg string `gorm:"column:error_msg;type:varchar(255)"`
}

ExportJob 导出任务

func (ExportJob) TableName

func (ExportJob) TableName() string

TableName 表名

type Job

type Job struct {
	gorm.Model
	// JobUUID 任务的唯一标识符
	JobUUID string `gorm:"column:job_uuid;type:varchar(36);not null;index"`
	// CompanyID 公司 ID
	CompanyID uint `gorm:"column:company_id;type:int;not null;index"`
	// Uin 用户 ID
	Uin uint `gorm:"column:uin;type:int;not null;index"`
	// Purpose 目的
	Purpose string `gorm:"column:purpose;type:varchar(255);not null;index"`
	// JobStatus 状态
	JobStatus JobStatus `gorm:"column:job_status;type:varchar(20);not null;index"`
	// CostSeconds 耗时
	CostSeconds int `gorm:"column:cost_seconds;type:int;not null"`
	// Output 结果
	Output string `gorm:"column:output;type:varchar(255);not null"`
	// ErrorMsg 错误信息
	ErrorMsg types.StringArray `gorm:"column:error_msg;type:varchar(1024)"`
	// Extra 扩展字段
	Extra string `gorm:"column:extra;type:text"`
}

Job 导出任务

func (*Job) TableName

func (j *Job) TableName() string

TableName 表名

type JobStatus

type JobStatus = string

JobStatus 导出状态

const (
	// JobStatusPending 等待导出
	JobStatusPending JobStatus = "pending"
	// JobStatusSuccess 成功
	JobStatusSuccess JobStatus = "success"
	// JobStatusFailed 失败
	JobStatusFailed JobStatus = "failed"
)