model

Documentation

Index

• func GetJobDB(db *gorm.DB) *gorm.DB
• type Job
  • func (m *Job) BatchDelete(db *gorm.DB, ids []int) error
  • func (m *Job) Create(db *gorm.DB, item Job) error
  • func (m *Job) Delete(db *gorm.DB, id int) error
  • func (m *Job) Get(db *gorm.DB) (*Job, error)
  • func (m *Job) GetWithStatus(db *gorm.DB, status int) ([]*Job, error)
  • func (m *Job) Query(db *gorm.DB, params param.JobParam) (*pagination.Result, error)
  • func (m *Job) RemoveAllEntryID(db *gorm.DB) error
  • func (m *Job) RemoveJob(db *gorm.DB) error
  • func (m *Job) StartJob(db *gorm.DB) error
  • func (m *Job) Update(db *gorm.DB, item Job) error

Functions

func GetJobDB

func GetJobDB(db *gorm.DB) *gorm.DB

GetJobDB 获取定时任务存储

Types

type Job

type Job struct {
	JobID          uint   `json:"jobId" gorm:"primary_key;AUTO_INCREMENT;"`    // 编码
	JobName        string `json:"jobName" gorm:"size:255;"`                    // 名称
	JobGroup       string `json:"jobGroup" gorm:"size:255;"`                   // 任务分组
	JobType        int    `json:"jobType" gorm:"size:1;"`                      // 任务类型
	CronExpression string `json:"cronExpression" gorm:"size:255;"`             // cron表达式
	InvokeTarget   string `json:"invokeTarget" gorm:"size:255;"`               // 调用目标
	Args           string `json:"args" gorm:"size:255;"`                       // 目标参数
	MisfirePolicy  int    `json:"misfirePolicy" gorm:"size:255;"`              // 执行策略
	Concurrent     int    `json:"concurrent" gorm:"size:1;"`                   // 是否并发
	Status         int    `json:"status" gorm:"size:1;"`                       // 状态
	EntryID        int    `json:"entry_id" gorm:"size:11;index:idx_entry_id;"` // job启动时返回的id
	CreateBy       string `json:"createBy" gorm:"size:128;"`                   // 创建人
	UpdateBy       string `json:"updateBy" gorm:"size:128;"`                   // 更新人
	models.AtModel

	DataScope string `json:"dataScope" gorm:"-"`
}

Job 定时任务实体

func (*Job) BatchDelete

func (m *Job) BatchDelete(db *gorm.DB, ids []int) error

BatchDelete 批量删除

func (*Job) Create

func (m *Job) Create(db *gorm.DB, item Job) error

Create 创建数据

func (*Job) Delete

func (m *Job) Delete(db *gorm.DB, id int) error

Delete 删除数据

func (*Job) Get

func (m *Job) Get(db *gorm.DB) (*Job, error)

Get 查询指定数据

func (*Job) GetWithStatus

func (m *Job) GetWithStatus(db *gorm.DB, status int) ([]*Job, error)

GetWithStatus 根据状态获取任务

func (*Job) Query

func (m *Job) Query(db *gorm.DB, params param.JobParam) (*pagination.Result, error)

Query 查询数据

func (*Job) RemoveAllEntryID

func (m *Job) RemoveAllEntryID(db *gorm.DB) error

RemoveAllEntryID 移除所有任务EntryID

func (*Job) RemoveJob

func (m *Job) RemoveJob(db *gorm.DB) error

RemoveJob 移除job

func (*Job) StartJob

func (m *Job) StartJob(db *gorm.DB) error

StartJob 启动job

func (*Job) Update

func (m *Job) Update(db *gorm.DB, item Job) error

Update 更新数据