IOT/SERVER/IotAdmin/app/schedule/service/dto/job.go

package dto

import (
	"IotAdmin/app/schedule/models"
	"IotAdmin/common/dto"
	comModels "IotAdmin/common/models"

	"time"
)

type SysJobGetPageReq struct {
	dto.Pagination `search:"-"`
	JobName        string `form:"jobName"  search:"type:icontains;column:job_name;table:sys_job" comment:"名称"`
	JobGroup       string `form:"jobGroup"  search:"type:exact;column:job_group;table:sys_job" comment:"任务分组"`
	JobType        int    `form:"jobType"  search:"type:exact;column:job_type;table:sys_job" comment:"调用类型"`
	InvokeTarget   string `form:"invokeTarget"  search:"type:icontains;column:invoke_target;table:sys_job" comment:"调用目标"`
	Status         int    `form:"status"  search:"type:exact;column:status;table:sys_job" comment:"状态"`
	SysJobOrder
}

type SysJobOrder struct {
	JobGroup     string `form:"jobGroupOrder"  search:"type:order;column:job_group;table:sys_job"`
	JobType      string `form:"jobTypeOrder"  search:"type:order;column:job_type;table:sys_job"`
	ExecCount    string `form:"execCountOrder"  search:"type:order;column:exec_count;table:sys_job"`
	FailCount    string `form:"failCountOrder"  search:"type:order;column:fail_count;table:sys_job"`
	LastExecTime string `form:"lastExecTimeOrder"  search:"type:order;column:last_exec_time;table:sys_job"`
	NextExecTime string `form:"nextExecTimeOrder"  search:"type:order;column:next_exec_time;table:sys_job"`
	CreatedAt    string `form:"createdAtOrder"  search:"type:order;column:created_at;table:sys_job"`
	Status       string `form:"statusOrder"  search:"type:order;column:status;table:sys_job"`
}

func (m *SysJobGetPageReq) GetNeedSearch() interface{} {
	return *m
}

// SysJobInsertReq 添加定时任务请求参数
type SysJobInsertReq struct {
	JobId          int    `json:"-" comment:"编码"` // 编码
	JobName        string `json:"jobName" comment:"名称"`
	JobGroup       string `json:"jobGroup" comment:"任务分组"`
	JobType        int    `json:"jobType" comment:"调用类型"`
	CronExpression string `json:"cronExpression" comment:"Cron表达式"`
	InvokeTarget   string `json:"invokeTarget" comment:"调用目标"`
	Args           string `json:"args" comment:"目标参数"`
	MisfirePolicy  int    `json:"misfirePolicy" comment:"执行策略"`
	Concurrent     int    `json:"concurrent" comment:"是否并发"`
	Status         int    `json:"status" comment:"状态"`
	comModels.ControlBy
}

func (s *SysJobInsertReq) Generate(model *models.SysJob) {
	if s.JobId == 0 {
		model.JobId = s.JobId
	}
	model.JobName = s.JobName
	model.JobGroup = s.JobGroup
	model.JobType = s.JobType
	model.CronExpression = s.CronExpression
	model.InvokeTarget = s.InvokeTarget
	model.Args = s.Args
	model.MisfirePolicy = s.MisfirePolicy
	model.Concurrent = s.Concurrent
	model.Status = 1
	model.CreateBy = s.CreateBy // 添加这而，需要记录是被谁创建的
}

func (s *SysJobInsertReq) GetId() interface{} {
	return s.JobId
}

// SysJobUpdateReq 修改定时任务请求参数
type SysJobUpdateReq struct {
	JobId          int    `uri:"jobId" comment:"编码"` // 编码
	JobName        string `json:"jobName" comment:"名称"`
	JobGroup       string `json:"jobGroup" comment:"任务分组"`
	JobType        int    `json:"jobType" comment:"调用类型"`
	CronExpression string `json:"cronExpression" comment:"Cron表达式"`
	InvokeTarget   string `json:"invokeTarget" comment:"调用目标"`
	Args           string `json:"args" comment:"目标参数"`
	MisfirePolicy  int    `json:"misfirePolicy" comment:"执行策略"`
	Concurrent     int    `json:"concurrent" comment:"是否并发"`
	Status         int    `json:"status" comment:"状态"`
	comModels.ControlBy
}

func (s *SysJobUpdateReq) Generate(model *models.SysJob) {
	if s.JobId == 0 {
		model.JobId = s.JobId
	}
	model.JobName = s.JobName
	model.JobGroup = s.JobGroup
	model.JobType = s.JobType
	model.CronExpression = s.CronExpression
	model.InvokeTarget = s.InvokeTarget
	model.Args = s.Args
	model.MisfirePolicy = s.MisfirePolicy
	model.Concurrent = s.Concurrent
	model.Status = s.Status
	model.UpdateBy = s.UpdateBy // 添加这而，需要记录是被谁更新的
}

func (s *SysJobUpdateReq) GetId() interface{} {
	return s.JobId
}

// SysJobGetReq 获取定时任务请求参数
type SysJobGetReq struct {
	Id int `uri:"id"`
}

func (s *SysJobGetReq) GetId() interface{} {
	return s.Id
}

// SysJobDeleteReq 删除定时任务请求参数
type SysJobDeleteReq struct {
	Ids []int `json:"ids"`
}

func (s *SysJobDeleteReq) GetId() interface{} {
	return s.Ids
}

// SysJobResp 获取定时任务响应参数
type SysJobResp struct {
	JobId          int       `uri:"jobId" comment:"编码"` // 编码
	JobName        string    `json:"jobName" comment:"名称"`
	JobGroup       string    `json:"jobGroup" comment:"任务分组"`
	JobType        int       `json:"jobType" comment:"调用类型"`
	CronExpression string    `json:"cronExpression" comment:"Cron表达式"`
	InvokeTarget   string    `json:"invokeTarget" comment:"调用目标"`
	Args           string    `json:"args" comment:"目标参数"`
	MisfirePolicy  int       `json:"misfirePolicy" comment:"执行策略"`
	Concurrent     int       `json:"concurrent" comment:"是否并发"`
	Status         int       `json:"status" comment:"状态"`
	CreateBy       int       `json:"createBy" comment:"创建者"`
	CreatedAt      time.Time `json:"createdAt" comment:"创建时间"`
}

func (s *SysJobResp) Generate(model *models.SysJob) {
	s.JobName = model.JobName
	s.JobGroup = model.JobGroup
	s.JobType = model.JobType
	s.CronExpression = model.CronExpression
	s.InvokeTarget = model.InvokeTarget
	s.Args = model.Args
	s.MisfirePolicy = model.MisfirePolicy
	s.Concurrent = model.Concurrent
	s.Status = model.Status
	s.CreateBy = model.CreateBy
	s.CreatedAt = model.CreatedAt
}