添加状态修改接口
This commit is contained in:
parent
097682d1b9
commit
b2f2601f37
|
|
@ -113,4 +113,14 @@ public interface RemoteTaskService
|
|||
*/
|
||||
@PutMapping("/task/status/{taskId}")
|
||||
R<Boolean> updateTaskStatus(@PathVariable("taskId") Long taskId, @RequestParam("status") StatusEnum status, @RequestHeader(SecurityConstants.FROM_SOURCE) String source);
|
||||
|
||||
/**
|
||||
* 设置 recovery 为 true
|
||||
*
|
||||
* @param taskId 任务ID
|
||||
* @param source 请求来源
|
||||
* @return 结果
|
||||
*/
|
||||
@PutMapping("/task/recovery/{taskId}")
|
||||
R<Boolean> updateTaskRecovery(@PathVariable("taskId") Long taskId, @RequestHeader(SecurityConstants.FROM_SOURCE) String source);
|
||||
}
|
||||
|
|
@ -77,6 +77,11 @@ public class RemoteTaskFallbackFactory implements FallbackFactory<RemoteTaskServ
|
|||
public R<Boolean> updateTaskStatus(Long taskId, StatusEnum status, String source) {
|
||||
return R.fail("修改执行状态失败");
|
||||
}
|
||||
|
||||
@Override
|
||||
public R<Boolean> updateTaskRecovery(Long taskId, String source) {
|
||||
return R.fail("设置recovery失败");
|
||||
}
|
||||
};
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue