diff --git a/xservice-quartz-admin/src/main/java/com/xiang/app/quartz/admin/server/XxzJobRegisterController.java b/xservice-quartz-admin/src/main/java/com/xiang/app/quartz/admin/server/XxzJobRegisterController.java index 4526518..cd58df8 100644 --- a/xservice-quartz-admin/src/main/java/com/xiang/app/quartz/admin/server/XxzJobRegisterController.java +++ b/xservice-quartz-admin/src/main/java/com/xiang/app/quartz/admin/server/XxzJobRegisterController.java @@ -1,5 +1,7 @@ package com.xiang.app.quartz.admin.server; +import com.xiang.app.quartz.admin.domain.req.TaskRegisterRequest; +import com.xiang.app.quartz.admin.service.ITaskConfigService; import com.xiang.xservice.basic.common.resp.Result; import lombok.RequiredArgsConstructor; import org.springframework.web.bind.annotation.PostMapping; @@ -7,7 +9,9 @@ import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import javax.validation.Valid; +import javax.validation.constraints.NotEmpty; import javax.validation.constraints.NotNull; +import java.util.List; /** * @Author: xiang @@ -19,7 +23,18 @@ import javax.validation.constraints.NotNull; @RequestMapping("/open/quartz/register") public class XxzJobRegisterController { + private final ITaskConfigService taskConfigService; + @PostMapping("/single") - public Result registerSingle(@NotNull(message = "单个注册") @Valid ) + public Result registerSingle(@NotNull(message = "单个注册") @Valid TaskRegisterRequest request){ + taskConfigService.registerTask(request); + return Result.success(); + } + + @PostMapping("/batch") + public Result batch(@NotEmpty(message = "请求参数不能为空") @Valid List request) { + taskConfigService.registerTasks(request); + return Result.success(); + } }