git-sync/crawlab
1
0
Fork 0
mirror of https://github.com/crawlab-team/crawlab.git synced 2026-01-22 17:31:03 +01:00
Code Issues Packages Projects Releases Wiki Activity

added batch enable/disable schedules

Browse Source
This commit is contained in:
marvzhang
2020-07-18 21:16:28 +08:00
parent a6e94b553d
commit 5bcf2b13d8
3 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
backend/main.go
View File

@@ -256,16 +256,16 @@ func main() {
}
// 定时任务
{
authGroup.GET("/schedules", routes.GetScheduleList) // 定时任务列表
authGroup.GET("/schedules/:id", routes.GetSchedule) // 定时任务详情
authGroup.PUT("/schedules", routes.PutSchedule) // 创建定时任务
authGroup.PUT("/schedules/batch", routes.PutBatchSchedules) // 批量创建定时任务
authGroup.POST("/schedules/:id", routes.PostSchedule) // 修改定时任务
authGroup.DELETE("/schedules/:id", routes.DeleteSchedule) // 删除定时任务
authGroup.DELETE("/schedules", routes.DeleteBatchSchedules) // 批量删除定时任务
authGroup.POST("/schedules/:id/disable", routes.DisableSchedule) // 禁用定时任务
authGroup.POST("/schedules/:id/enable", routes.EnableSchedule) // 启用定时任务
authGroup.POST("/schedules-set-status", routes.SetStatusSchedules) // 批量设置定时任务状态
authGroup.GET("/schedules", routes.GetScheduleList) // 定时任务列表
authGroup.GET("/schedules/:id", routes.GetSchedule) // 定时任务详情
authGroup.PUT("/schedules", routes.PutSchedule) // 创建定时任务
authGroup.PUT("/schedules/batch", routes.PutBatchSchedules) // 批量创建定时任务
authGroup.POST("/schedules/:id", routes.PostSchedule) // 修改定时任务
authGroup.DELETE("/schedules/:id", routes.DeleteSchedule) // 删除定时任务
authGroup.DELETE("/schedules", routes.DeleteBatchSchedules) // 批量删除定时任务
authGroup.POST("/schedules/:id/disable", routes.DisableSchedule) // 禁用定时任务
authGroup.POST("/schedules/:id/enable", routes.EnableSchedule) // 启用定时任务
authGroup.POST("/schedules-set-enabled", routes.SetEnabledSchedules) // 批量设置定时任务状态
}
// 用户
{

2
backend/routes/schedule.go
View File

@@ -283,7 +283,7 @@ func DeleteBatchSchedules(c *gin.Context) {
HandleSuccess(c)
}
func SetStatusSchedules(c *gin.Context) {
func SetEnabledSchedules(c *gin.Context) {
type ReqBody struct {
ScheduleIds []bson.ObjectId `json:"schedule_ids"`
Enabled bool `json:"enabled"`

2
backend/services/schedule.go
View File

@@ -220,7 +220,7 @@ func (s *Scheduler) Update() error {
s.RemoveAll()
// 获取所有定时任务
sList, err := model.GetScheduleList(nil)
sList, err := model.GetScheduleList(bson.M{"enabled": true})
if err != nil {
log.Errorf("get scheduler list error: %s", err.Error())
debug.PrintStack()