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
	CreatedBy      string `json:"createdBy" gorm:"size:64;index;comment:'创建人'"` // 创建人
	UpdatedBy      string `json:"updatedBy" gorm:"size:64;index;comment:'更新人'"` // 更新人
	gormx.Model

	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 更新数据