|
@ -2438,6 +2438,8 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi |
|
|
List<UserInfoResultDTO> userInfos = this.disPoseUserInfo(resiGroup.getGroupType(), userIds); |
|
|
List<UserInfoResultDTO> userInfos = this.disPoseUserInfo(resiGroup.getGroupType(), userIds); |
|
|
// 根据用户ID和【活动、通知ID】查询阅读状态
|
|
|
// 根据用户ID和【活动、通知ID】查询阅读状态
|
|
|
List<ReadStatusResultDTO> readStatus = resiGroupDao.selectReadFlagByUserAndId(ids, userIds); |
|
|
List<ReadStatusResultDTO> readStatus = resiGroupDao.selectReadFlagByUserAndId(ids, userIds); |
|
|
|
|
|
// 查询小组下的 通知或活动 未读人数
|
|
|
|
|
|
List<UserUnReadResultDTO> userUnReadCount = resiGroupDao.selectUserUnReadById(formDTO.getGroupId(), ids); |
|
|
// 查询用户徽章信息
|
|
|
// 查询用户徽章信息
|
|
|
Result<List<UserBadgesResultDTO>> badgeResult = epmetUserOpenFeignClient.userBadges(new UserBadgesFormDTO(formDTO.getCustomerId(),userIds)); |
|
|
Result<List<UserBadgesResultDTO>> badgeResult = epmetUserOpenFeignClient.userBadges(new UserBadgesFormDTO(formDTO.getCustomerId(),userIds)); |
|
|
if (!badgeResult.success()){ |
|
|
if (!badgeResult.success()){ |
|
@ -2479,6 +2481,14 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi |
|
|
} |
|
|
} |
|
|
}); |
|
|
}); |
|
|
} |
|
|
} |
|
|
|
|
|
//
|
|
|
|
|
|
if (!CollectionUtils.isEmpty(userUnReadCount)){ |
|
|
|
|
|
userUnReadCount.forEach(u -> { |
|
|
|
|
|
if (i.getId().equals(u.getId())){ |
|
|
|
|
|
i.setUnReadCount(u.getUnRead()); |
|
|
|
|
|
} |
|
|
|
|
|
}); |
|
|
|
|
|
} |
|
|
}); |
|
|
}); |
|
|
return infos; |
|
|
return infos; |
|
|
} |
|
|
} |
|
|