diff --git a/business/jxstore/cms/job.go b/business/jxstore/cms/job.go index eb0133cfc..7d0f47024 100644 --- a/business/jxstore/cms/job.go +++ b/business/jxstore/cms/job.go @@ -1072,3 +1072,19 @@ func ResetJobTimers() { tasksch.HandleTask(task, nil, true).Run() task.GetID() } + +func UpdateJobSpan(ctx *jxcontext.Context, jobIDs []int, span int) (err error) { + var ( + db = dao.GetDB() + ) + for _, v := range jobIDs { + job := &model.Job{} + job.ID = v + err = dao.GetEntity(db, job) + if job != nil { + job.JobSpan = job.JobSpan | span + dao.UpdateEntity(db, job, "JobSpan") + } + } + return err +} diff --git a/controllers/job_controller.go b/controllers/job_controller.go index 29b5153fb..0e7ebb5f5 100644 --- a/controllers/job_controller.go +++ b/controllers/job_controller.go @@ -395,3 +395,23 @@ func (c *JobController) RefreshJobStatus() { return retVal, "", err }) } + +// @Title 修改任务标签 +// @Description 修改任务标签 +// @Param token header string true "认证token" +// @Param jobIDs formData string true "任务IDs" +// @Param span formData int true "标签,1为置顶,2为推荐" +// @Success 200 {object} controllers.CallResult +// @Failure 200 {object} controllers.CallResult +// @router /UpdateJobSpan [post] +func (c *JobController) UpdateJobSpan() { + c.callUpdateJobSpan(func(params *tJobUpdateJobSpanParams) (retVal interface{}, errCode string, err error) { + var ( + jobIDs []int + ) + if err = jxutils.Strings2Objs(params.JobIDs, &jobIDs); err == nil { + err = cms.UpdateJobSpan(params.Ctx, jobIDs, params.Span) + } + return retVal, "", err + }) +} diff --git a/routers/commentsRouter_controllers.go b/routers/commentsRouter_controllers.go index 6f84e7cca..3aa8f1b05 100644 --- a/routers/commentsRouter_controllers.go +++ b/routers/commentsRouter_controllers.go @@ -511,6 +511,15 @@ func init() { Filters: nil, Params: nil}) + beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"], + beego.ControllerComments{ + Method: "UpdateJobSpan", + Router: `/UpdateJobSpan`, + AllowHTTPMethods: []string{"post"}, + MethodParams: param.Make(), + Filters: nil, + Params: nil}) + beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"], beego.ControllerComments{ Method: "UserRefundEjy",