pay/dax-pay
1
0
Fork 0
mirror of https://gitee.com/dromara/dax-pay synced 2026-08-11 15:15:33 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat 同步商业版代码

Browse Source
This commit is contained in:
bootx
2025-04-27 21:46:54 +08:00
parent 36a6901f8e
commit 3ec34a191c
1067 changed files with 19660 additions and 26251 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
bootx-platform/bootx-platform-starter/starter-delay-queue/src/main/java/cn/bootx/platform/starter/redis/delay/controller/DelayQueueController.java
View File

@@ -12,6 +12,7 @@ import cn.bootx.platform.starter.redis.delay.result.DelayJobResult;
import cn.bootx.platform.starter.redis.delay.result.TopicResult;
import cn.bootx.platform.starter.redis.delay.service.DelayQueueService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.Parameter;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.validation.constraints.NotBlank;
import lombok.RequiredArgsConstructor;
@@ -47,7 +48,7 @@ public class DelayQueueController {
@RequestPath("获取死信主题列表")
@Operation(summary = "获取死信主题列表")
@GetMapping("/pageBucketJob")
public Result<PageResult<DelayJobResult>> pageBucketJob(@NotBlank(message = "死信主题不可为空") String bucketName, PageParam pageParam) {
public Result<PageResult<DelayJobResult>> pageBucketJob(@NotBlank(message = "死信主题不可为空") @Parameter(description = "死信主题") String bucketName, PageParam pageParam) {
return Res.ok(delayQueueService.pageBucketJob(bucketName, pageParam));
}
@@ -58,17 +59,17 @@ public class DelayQueueController {
return Res.ok(delayQueueService.getDelayTopic());
}
@RequestPath("获取就绪主题任务分页")
@RequestPath("获取就绪任务分页")
@Operation(summary = "获取就绪任务分页")
@GetMapping("/pageReadyJob")
public Result<PageResult<DelayJobResult>> pageReadyJob(@NotBlank(message = "就绪主题不可为空") String topic, PageParam pageParam) {
public Result<PageResult<DelayJobResult>> pageReadyJob(@NotBlank(message = "就绪主题不可为空") @Parameter(description = "就绪主题") String topic, PageParam pageParam) {
return Res.ok(delayQueueService.pageReadyJob(topic, pageParam));
}
@RequestPath("获取任务详情")
@Operation(summary = "获取任务详情")
@PostMapping("/getJobDetail")
public Result<DelayJobResult> getJobDetail(@NotBlank(message = "任务ID不可为空") String jobId) {
public Result<DelayJobResult> getJobDetail(@NotBlank(message = "任务ID不可为空") @Parameter(description = "任务ID") String jobId) {
return Res.ok(delayQueueService.getJobDetail(jobId));
}
@@ -79,17 +80,17 @@ public class DelayQueueController {
return Res.ok(delayQueueService.getDeadTopic());
}
@RequestPath("获取死信主题任务分页")
@Operation(summary = "获取死信主题任务分页")
@RequestPath("获取死信任务分页")
@Operation(summary = "获取主题任务分页")
@GetMapping("/pageDeadJob")
public Result<PageResult<DelayJobResult>> pageDeadJob(@NotBlank(message = "主题不可为空") String topic, PageParam pageParam) {
public Result<PageResult<DelayJobResult>> pageDeadJob(@NotBlank(message = "主题不可为空") @Parameter(description = "主题") String topic, PageParam pageParam) {
return Res.ok(delayQueueService.pageDeadJob(topic, pageParam));
}
@RequestPath("获取死信任务详情")
@Operation(summary = "获取死信任务详情")
@PostMapping("/getDeadJobDetail")
public Result<DelayJobResult> resetDeadJob(@NotBlank(message = "死信任务Id不可为空") String jobId) {
public Result<DelayJobResult> resetDeadJob(@NotBlank(message = "死信任务Id不可为空") @Parameter(description = "死信任务Id") String jobId) {
return Res.ok(delayQueueService.getDeadJobDetail(jobId));
}

1
bootx-platform/bootx-platform-starter/starter-delay-queue/src/main/java/cn/bootx/platform/starter/redis/delay/service/DelayQueueService.java
View File

@@ -112,7 +112,6 @@ public class DelayQueueService {
.map(rangeWithScore -> new TopicResult().setName(rangeWithScore.getValue()).setCount(Optional.ofNullable(rangeWithScore.getScore()).map(Double::intValue).orElse(0))).toList();
}
/**
* 获取死信主题任务分页
*/