|
@@ -149,7 +149,7 @@ public class TaskController {
|
|
|
}
|
|
|
List<TaskExecutor> oldExeList = taskExecutorMapper.selectList(new QueryWrapper<TaskExecutor>().eq("task_id", task.getId()));
|
|
|
//计算需要移除的执行人
|
|
|
- List<Integer> ids = oldExeList.stream().filter(old->!task.getExecutorList().stream().anyMatch(newT->newT.getExecutorId().equals(old.getExecutorId())))
|
|
|
+ List<Integer> ids = oldExeList.stream().filter(old->!task.getExecutorList().stream().anyMatch(newT->newT.getId()!=null&&newT.getId().equals(old.getId())))
|
|
|
.map(TaskExecutor::getId).collect(Collectors.toList());
|
|
|
if (ids.size() > 0) {
|
|
|
taskExecutorService.removeByIds(ids);
|