|
|
@ -103,6 +103,8 @@ public class PushApplicationServiceImpl extends ServiceImpl<PushApplicationMappe |
|
|
|
.eq(PushConcernFan::getStatus, PushAuditStatusEnum.APPROVED.getValue())); |
|
|
|
.eq(PushConcernFan::getStatus, PushAuditStatusEnum.APPROVED.getValue())); |
|
|
|
pushChatMessage.setAlias(pushConcernFanList.stream().map(PushConcernFan::getFanUserId).collect(Collectors.joining(","))); |
|
|
|
pushChatMessage.setAlias(pushConcernFanList.stream().map(PushConcernFan::getFanUserId).collect(Collectors.joining(","))); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
if (StrUtil.isBlank(pushChatMessage.getAlias())) throw new CheckedException("推送用户别名ID找不到!"); |
|
|
|
|
|
|
|
|
|
|
|
// 过滤黑名单,根据谁拉黑了推送方用户进行过滤推送用户
|
|
|
|
// 过滤黑名单,根据谁拉黑了推送方用户进行过滤推送用户
|
|
|
|
List<PushBlacklist> pushBlacklists = iPushBlacklistService.list(Wrappers.<PushBlacklist>lambdaQuery().eq(PushBlacklist::getFanUserId, pushChatMessage.getUserId())); |
|
|
|
List<PushBlacklist> pushBlacklists = iPushBlacklistService.list(Wrappers.<PushBlacklist>lambdaQuery().eq(PushBlacklist::getFanUserId, pushChatMessage.getUserId())); |
|
|
|
pushBlacklists.forEach(item -> pushChatMessage.setAlias(pushChatMessage.getAlias().replaceAll(item.getConcernUserId() + ",?", ""))); |
|
|
|
pushBlacklists.forEach(item -> pushChatMessage.setAlias(pushChatMessage.getAlias().replaceAll(item.getConcernUserId() + ",?", ""))); |
|
|
|