parent
297c8eef72
commit
380d7756b1
|
@ -257,7 +257,9 @@ public class TaskServiceImpl implements TaskService {
|
|||
TaskInfo taskInfo = taskInfoMapper.getTaskInfo(taskId, k.getId());
|
||||
|
||||
// 异步启动处置任务
|
||||
CompletableFuture.supplyAsync(() -> dp.stopDispose(task.getDisposeIp(), DeviceCapacity.values()[task.getType()], taskInfo.getExternId()))
|
||||
CompletableFuture.supplyAsync(() -> dp.stopDispose(task.getDisposeIp(),
|
||||
DeviceCapacity.values()[task.getType()],
|
||||
(taskInfo == null || taskInfo.getExternId() == null) ? -1 :taskInfo.getExternId()))
|
||||
.whenComplete((v, ex) -> {
|
||||
if (ex != null) {
|
||||
// 恢复缓存中任务状态到先前状态
|
||||
|
|
Loading…
Reference in New Issue