feat:调度中心 自动注册
This commit is contained in:
@@ -1,5 +1,7 @@
|
|||||||
package com.xiang.app.quartz.admin.server;
|
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 com.xiang.xservice.basic.common.resp.Result;
|
||||||
import lombok.RequiredArgsConstructor;
|
import lombok.RequiredArgsConstructor;
|
||||||
import org.springframework.web.bind.annotation.PostMapping;
|
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 org.springframework.web.bind.annotation.RestController;
|
||||||
|
|
||||||
import javax.validation.Valid;
|
import javax.validation.Valid;
|
||||||
|
import javax.validation.constraints.NotEmpty;
|
||||||
import javax.validation.constraints.NotNull;
|
import javax.validation.constraints.NotNull;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @Author: xiang
|
* @Author: xiang
|
||||||
@@ -19,7 +23,18 @@ import javax.validation.constraints.NotNull;
|
|||||||
@RequestMapping("/open/quartz/register")
|
@RequestMapping("/open/quartz/register")
|
||||||
public class XxzJobRegisterController {
|
public class XxzJobRegisterController {
|
||||||
|
|
||||||
|
private final ITaskConfigService taskConfigService;
|
||||||
|
|
||||||
@PostMapping("/single")
|
@PostMapping("/single")
|
||||||
public Result<Void> registerSingle(@NotNull(message = "单个注册") @Valid )
|
public Result<Void> registerSingle(@NotNull(message = "单个注册") @Valid TaskRegisterRequest request){
|
||||||
|
taskConfigService.registerTask(request);
|
||||||
|
return Result.success();
|
||||||
|
}
|
||||||
|
|
||||||
|
@PostMapping("/batch")
|
||||||
|
public Result<Void> batch(@NotEmpty(message = "请求参数不能为空") @Valid List<TaskRegisterRequest> request) {
|
||||||
|
taskConfigService.registerTasks(request);
|
||||||
|
return Result.success();
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user