Commit d9153fd2 authored by pengxin's avatar pengxin

暂停更新状态。

parent 97a9b122
...@@ -81,8 +81,8 @@ public class DatasetCleanController { ...@@ -81,8 +81,8 @@ public class DatasetCleanController {
* @return 应答结果对象,包含新增对象主键Id。 * @return 应答结果对象,包含新增对象主键Id。
*/ */
@OperationLog(type = SysOperationLogType.STOP_CLEAN) @OperationLog(type = SysOperationLogType.STOP_CLEAN)
@PostMapping("/stopClean") @GetMapping("/stopClean")
public ResponseResult<Void> stopClean(@RequestBody Long cleanId) { public ResponseResult<Void> stopClean(@RequestParam Long cleanId) {
if (MyCommonUtil.existBlankArgument(cleanId)) { if (MyCommonUtil.existBlankArgument(cleanId)) {
return ResponseResult.error(ErrorCodeEnum.ARGUMENT_NULL_EXIST); return ResponseResult.error(ErrorCodeEnum.ARGUMENT_NULL_EXIST);
} }
...@@ -97,8 +97,8 @@ public class DatasetCleanController { ...@@ -97,8 +97,8 @@ public class DatasetCleanController {
* @return 应答结果对象,包含新增对象主键Id。 * @return 应答结果对象,包含新增对象主键Id。
*/ */
@OperationLog(type = SysOperationLogType.RESTART_CLEAN) @OperationLog(type = SysOperationLogType.RESTART_CLEAN)
@PostMapping("/restartClean") @GetMapping("/restartClean")
public ResponseResult<Void> restartClean(@RequestBody Long cleanId) { public ResponseResult<Void> restartClean(@RequestParam Long cleanId) {
if (MyCommonUtil.existBlankArgument(cleanId)) { if (MyCommonUtil.existBlankArgument(cleanId)) {
return ResponseResult.error(ErrorCodeEnum.ARGUMENT_NULL_EXIST); return ResponseResult.error(ErrorCodeEnum.ARGUMENT_NULL_EXIST);
} }
......
...@@ -175,14 +175,13 @@ public class DatasetCleanServiceImpl extends BaseService<DatasetClean, Long> imp ...@@ -175,14 +175,13 @@ public class DatasetCleanServiceImpl extends BaseService<DatasetClean, Long> imp
Future<?> future = futures.remove(cleanId); Future<?> future = futures.remove(cleanId);
if (future != null && !future.isDone()) { if (future != null && !future.isDone()) {
future.cancel(true); future.cancel(true);
//暂停清洗
DatasetClean filter = new DatasetClean();
filter.setCleanStatus(DatasetConstant.PAUSE_FINISHED);
filter.setFinishTime(null);
filter.setCleanId(cleanId);
this.updateById(filter);
} }
//暂停清洗
DatasetClean filter = new DatasetClean();
filter.setCleanStatus(DatasetConstant.PAUSE_FINISHED);
filter.setFinishTime(null);
filter.setCleanId(cleanId);
this.updateById(filter);
} }
/** /**
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment