Compare commits

..

2 Commits

View File

@@ -353,6 +353,19 @@ public class TaskServiceImpl implements ITaskService {
task.setAttentionFlag(CollectionUtils.isEmpty(eachAttention) ? 0 :
(eachAttention.stream().map(SpdmTaskAttentionMemberVo::getUserId).collect(Collectors.toList()).contains(userId) ? 1 : 0));
}
// 兼容老逻辑
List<SpdmTaskMemberVo> attentionList = taskMemberVoList.stream().filter(member -> MemberTypeEnum.ATTENTION.getCode().equals(member.getType())).toList();
if (CollectionUtils.isNotEmpty(attentionList)) {
Map<String, List<SpdmTaskMemberVo>> aMap = attentionList.stream().collect(Collectors.groupingBy(SpdmTaskMemberVo::getTaskId));
for (SpdmTaskVo task : taskList) {
if (task.getAttentionFlag() == 1) {
continue;
}
List<SpdmTaskMemberVo> eachAttention = aMap.get(task.getUuid());
task.setAttentionFlag(CollectionUtils.isEmpty(eachAttention) ? 0 :
(eachAttention.stream().map(SpdmTaskMemberVo::getUserId).collect(Collectors.toList()).contains(userId) ? 1 : 0));
}
}
return taskList;
}