REM:
1. 停止任务接口支持处理type=-1的全部类型处置任务
2. 增加根据节点停止处置任务接口
3. 增加停止所有处置任务接口
4. 更新停止任务相关接口,返回停止的各个处置任务的详细信息
5. 更新停止任务接口实现方法
6. 更新停止处置任务相关单元测试接口
7. 按照字母序执行单元测试用例
8. 更新处置任务处置时间计算方法
This commit is contained in:
HuangXin 2020-05-06 11:25:59 +08:00
parent 6931499342
commit f719194d46
3 changed files with 3 additions and 12 deletions

View File

@ -257,7 +257,7 @@ public class DisposeTaskController {
TaskInfoRsp rspInfo = new TaskInfoRsp(); TaskInfoRsp rspInfo = new TaskInfoRsp();
reqInfo.getItems().forEach(v -> { reqInfo.getItems().forEach(v -> {
TaskInfoData taskData = TaskInfoData.builder().type(v.getType()).build(); TaskInfoData taskData = TaskInfoData.builder().type(v.getType()).build();
List<MReturnType<ErrorCode, TaskInfoDetail>> ret = taskService.stopTaskByDisposeNode(Long.parseLong(v.getId()), v.getType()); List<MReturnType<ErrorCode, TaskInfoDetail>> ret = taskService.stopTaskByDisposeNode(Long.parseLong(v.getId()), v.getType());

View File

@ -35,9 +35,8 @@ public interface TaskCacheManager {
* Remove task error code. * Remove task error code.
* *
* @param id the id * @param id the id
* @return the error code
*/ */
ErrorCode removeTask(Long id); void removeTask(Long id);
/** /**
* Upgrade task status error code. * Upgrade task status error code.

View File

@ -72,18 +72,10 @@ public class TaskCacheManagerImpl implements TaskCacheManager {
* Remove task error code. * Remove task error code.
* *
* @param id the id * @param id the id
* @return the error code
*/ */
@Override @Override
public ErrorCode removeTask(Long id) { public void removeTask(Long id) {
if (!taskCacheMap.containsKey(id)) {
return ErrorCode.ERR_OK;
}
taskCacheMap.remove(id); taskCacheMap.remove(id);
return ErrorCode.ERR_OK;
} }
/** /**