diff --git a/backend/routes/task.go b/backend/routes/task.go index a11f197f..81c8cfa1 100644 --- a/backend/routes/task.go +++ b/backend/routes/task.go @@ -131,10 +131,6 @@ func PutTask(c *gin.Context) { // 绑定数据 var reqBody TaskRequestBody - if err := c.ShouldBindJSON(&reqBody); err != nil { - HandleError(http.StatusInternalServerError, c, err) - return - } // 任务ID var taskIds []string @@ -276,10 +272,6 @@ func DeleteSelectedTask(c *gin.Context) { // @Router /task/{id} [delete] func DeleteTask(c *gin.Context) { id := c.Param("id") - if !bson.IsObjectIdHex(id) { - HandleErrorF(http.StatusBadRequest, c, "invalid id") - return - } // 删除日志文件 if err := services.RemoveLogByTaskId(id); err != nil { HandleError(http.StatusInternalServerError, c, err) @@ -309,10 +301,6 @@ func GetTaskLog(c *gin.Context) { Keyword string `form:"keyword"` } id := c.Param("id") - if !bson.IsObjectIdHex(id) { - HandleErrorF(http.StatusBadRequest, c, "invalid id") - return - } var reqData RequestData if err := c.ShouldBindQuery(&reqData); err != nil { HandleErrorF(http.StatusBadRequest, c, "invalid request") @@ -342,10 +330,6 @@ func GetTaskLog(c *gin.Context) { // @Router /tasks/{id}/error-log [delete] func GetTaskErrorLog(c *gin.Context) { id := c.Param("id") - if !bson.IsObjectIdHex(id) { - HandleErrorF(http.StatusBadRequest, c, "invalid id") - return - } u := services.GetCurrentUser(c) errLogItems, err := services.GetTaskErrorLog(id, u.Setting.MaxErrorLog) if err != nil { @@ -371,10 +355,6 @@ func GetTaskErrorLog(c *gin.Context) { // @Router /tasks/{id}/results [get] func GetTaskResults(c *gin.Context) { id := c.Param("id") - if !bson.IsObjectIdHex(id) { - HandleErrorF(http.StatusBadRequest, c, "invalid id") - return - } // 绑定数据 data := TaskResultsRequestData{} if err := c.ShouldBindQuery(&data); err != nil { @@ -415,10 +395,6 @@ func GetTaskResults(c *gin.Context) { // @Router /tasks/{id}/results/download [get] func DownloadTaskResultsCsv(c *gin.Context) { id := c.Param("id") - if !bson.IsObjectIdHex(id) { - HandleErrorF(http.StatusBadRequest, c, "invalid id") - return - } // 获取任务 task, err := model.GetTask(id) if err != nil { @@ -496,10 +472,6 @@ func DownloadTaskResultsCsv(c *gin.Context) { // @Router /tasks/{id}/cancel [post] func CancelTask(c *gin.Context) { id := c.Param("id") - if !bson.IsObjectIdHex(id) { - HandleErrorF(http.StatusBadRequest, c, "invalid id") - return - } if err := services.CancelTask(id); err != nil { HandleError(http.StatusInternalServerError, c, err) return @@ -518,10 +490,6 @@ func CancelTask(c *gin.Context) { // @Router /tasks/{id}/restart [post] func RestartTask(c *gin.Context) { id := c.Param("id") - if !bson.IsObjectIdHex(id) { - HandleErrorF(http.StatusBadRequest, c, "invalid id") - return - } uid := services.GetCurrentUserId(c) if err := services.RestartTask(id, uid); err != nil {