Merge pull request 'f_paush' (#6) from f_paush into test

Reviewed-on: http://th.local.t-aaron.com:13000/THENG/a-cloud-all/pulls/6
This commit is contained in:
sunpeng 2026-03-28 14:08:50 +08:00
commit 1cf5e55725
6 changed files with 128 additions and 1 deletions

View File

@ -3,6 +3,9 @@ package com.ruoyi.task.api;
import com.ruoyi.common.core.constant.SecurityConstants; import com.ruoyi.common.core.constant.SecurityConstants;
import com.ruoyi.common.core.constant.ServiceNameConstants; import com.ruoyi.common.core.constant.ServiceNameConstants;
import com.ruoyi.common.core.domain.R; import com.ruoyi.common.core.domain.R;
import com.ruoyi.task.api.domain.TaskDeleteVO;
import com.ruoyi.task.api.domain.TaskPauseVO;
import com.ruoyi.task.api.domain.TaskResumeVO;
import com.ruoyi.task.api.domain.TaskResultVO; import com.ruoyi.task.api.domain.TaskResultVO;
import com.ruoyi.task.api.domain.TaskVO; import com.ruoyi.task.api.domain.TaskVO;
import com.ruoyi.task.api.domain.TaskTempVO; import com.ruoyi.task.api.domain.TaskTempVO;
@ -145,4 +148,37 @@ public interface RemoteTaskService
*/ */
@GetMapping("/task/pending-auto") @GetMapping("/task/pending-auto")
R<List<TaskVO>> getPendingTasksForAutoExecute(@RequestHeader(SecurityConstants.FROM_SOURCE) String source); R<List<TaskVO>> getPendingTasksForAutoExecute(@RequestHeader(SecurityConstants.FROM_SOURCE) String source);
/**
* 删除任务或计划逻辑删除设置 valid false
*
* @param deleteVO 删除请求参数
* @param source 请求来源
* @return 结果
*/
@PostMapping("/task/delete")
R<Boolean> deleteTaskOrPlan(@RequestBody TaskDeleteVO deleteVO,
@RequestHeader(SecurityConstants.FROM_SOURCE) String source);
/**
* 暂停任务或计划
*
* @param pauseVO 暂停请求参数
* @param source 请求来源
* @return 结果
*/
@PostMapping("/task/pause")
R<Boolean> pauseTaskOrPlan(@RequestBody TaskPauseVO pauseVO,
@RequestHeader(SecurityConstants.FROM_SOURCE) String source);
/**
* 恢复任务或计划
*
* @param resumeVO 恢复请求参数
* @param source 请求来源
* @return 结果
*/
@PostMapping("/task/resume")
R<Boolean> resumeTaskOrPlan(@RequestBody TaskResumeVO resumeVO,
@RequestHeader(SecurityConstants.FROM_SOURCE) String source);
} }

View File

@ -0,0 +1,24 @@
package com.ruoyi.task.api.domain;
public class TaskDeleteVO {
private Long planId;
private Long taskId;
public Long getPlanId() {
return planId;
}
public void setPlanId(Long planId) {
this.planId = planId;
}
public Long getTaskId() {
return taskId;
}
public void setTaskId(Long taskId) {
this.taskId = taskId;
}
}

View File

@ -0,0 +1,24 @@
package com.ruoyi.task.api.domain;
public class TaskPauseVO {
private Long planId;
private Long taskId;
public Long getPlanId() {
return planId;
}
public void setPlanId(Long planId) {
this.planId = planId;
}
public Long getTaskId() {
return taskId;
}
public void setTaskId(Long taskId) {
this.taskId = taskId;
}
}

View File

@ -0,0 +1,24 @@
package com.ruoyi.task.api.domain;
public class TaskResumeVO {
private Long planId;
private Long taskId;
public Long getPlanId() {
return planId;
}
public void setPlanId(Long planId) {
this.planId = planId;
}
public Long getTaskId() {
return taskId;
}
public void setTaskId(Long taskId) {
this.taskId = taskId;
}
}

View File

@ -9,7 +9,8 @@ public enum StatusEnum {
RUNNING("running", "执行中"), RUNNING("running", "执行中"),
COMPLETED("completed", "已完成"), COMPLETED("completed", "已完成"),
FAILED("failed", "失败"), FAILED("failed", "失败"),
CANCELED("canceled", "已取消"); CANCELED("canceled", "已取消"),
PAUSE("pause", "已暂停");
private final String code; private final String code;
private final String name; private final String name;

View File

@ -2,6 +2,9 @@ package com.ruoyi.task.api.factory;
import com.ruoyi.common.core.domain.R; import com.ruoyi.common.core.domain.R;
import com.ruoyi.task.api.RemoteTaskService; import com.ruoyi.task.api.RemoteTaskService;
import com.ruoyi.task.api.domain.TaskDeleteVO;
import com.ruoyi.task.api.domain.TaskPauseVO;
import com.ruoyi.task.api.domain.TaskResumeVO;
import com.ruoyi.task.api.domain.TaskResultVO; import com.ruoyi.task.api.domain.TaskResultVO;
import com.ruoyi.task.api.domain.TaskVO; import com.ruoyi.task.api.domain.TaskVO;
import com.ruoyi.task.api.domain.TaskTempVO; import com.ruoyi.task.api.domain.TaskTempVO;
@ -93,6 +96,21 @@ public class RemoteTaskFallbackFactory implements FallbackFactory<RemoteTaskServ
public R<List<TaskVO>> getPendingTasksForAutoExecute(String source) { public R<List<TaskVO>> getPendingTasksForAutoExecute(String source) {
return R.ok(Collections.emptyList()); return R.ok(Collections.emptyList());
} }
@Override
public R<Boolean> deleteTaskOrPlan(TaskDeleteVO deleteVO, String source) {
return R.fail("删除任务或计划失败");
}
@Override
public R<Boolean> pauseTaskOrPlan(TaskPauseVO pauseVO, String source) {
return R.fail("暂停任务或计划失败");
}
@Override
public R<Boolean> resumeTaskOrPlan(TaskResumeVO resumeVO, String source) {
return R.fail("恢复任务或计划失败");
}
}; };
} }
} }