|
|
@ -78,7 +78,7 @@ public class PushConcernFanServiceImpl extends ServiceImpl<PushConcernFanMapper, |
|
|
|
PushConcernFan pushConcernFan = super.getOne(Wrappers.<PushConcernFan>lambdaQuery() |
|
|
|
PushConcernFan pushConcernFan = super.getOne(Wrappers.<PushConcernFan>lambdaQuery() |
|
|
|
.eq(PushConcernFan::getConcernUserId, pushChatMessage.getUserId()) |
|
|
|
.eq(PushConcernFan::getConcernUserId, pushChatMessage.getUserId()) |
|
|
|
.eq(PushConcernFan::getFanUserId, pushChatMessage.getAlias()) |
|
|
|
.eq(PushConcernFan::getFanUserId, pushChatMessage.getAlias()) |
|
|
|
.eq(PushConcernFan::getStatus, PushAuditStatusEnum.APPROVED)); |
|
|
|
.eq(PushConcernFan::getStatus, PushAuditStatusEnum.APPROVED.getValue())); |
|
|
|
// 推送限制关注用户只能推送一条消息,需要双向关注后才能解锁限制
|
|
|
|
// 推送限制关注用户只能推送一条消息,需要双向关注后才能解锁限制
|
|
|
|
if (ObjectUtil.isEmpty(pushConcernFan)) { |
|
|
|
if (ObjectUtil.isEmpty(pushConcernFan)) { |
|
|
|
Optional<PushChatMessage> optionalPushChatMessage = iPushChatMessageService.list(Wrappers.<PushChatMessage>lambdaQuery() |
|
|
|
Optional<PushChatMessage> optionalPushChatMessage = iPushChatMessageService.list(Wrappers.<PushChatMessage>lambdaQuery() |
|
|
@ -97,7 +97,7 @@ public class PushConcernFanServiceImpl extends ServiceImpl<PushConcernFanMapper, |
|
|
|
if (StrUtil.isBlank(pushChatMessage.getAlias())) { |
|
|
|
if (StrUtil.isBlank(pushChatMessage.getAlias())) { |
|
|
|
List<PushConcernFan> pushConcernFanList = super.list(Wrappers.<PushConcernFan>lambdaQuery() |
|
|
|
List<PushConcernFan> pushConcernFanList = super.list(Wrappers.<PushConcernFan>lambdaQuery() |
|
|
|
.eq(PushConcernFan::getConcernUserId, pushChatMessage.getUserId()) |
|
|
|
.eq(PushConcernFan::getConcernUserId, pushChatMessage.getUserId()) |
|
|
|
.eq(PushConcernFan::getStatus, PushAuditStatusEnum.APPROVED)); |
|
|
|
.eq(PushConcernFan::getStatus, PushAuditStatusEnum.APPROVED.getValue())); |
|
|
|
pushChatMessage.setAlias(pushConcernFanList.stream().map(item -> item.getConcernUserId()).collect(Collectors.joining())); |
|
|
|
pushChatMessage.setAlias(pushConcernFanList.stream().map(item -> item.getConcernUserId()).collect(Collectors.joining())); |
|
|
|
} |
|
|
|
} |
|
|
|
// 查询粉丝设置的推送类型,如果参数中没有指定则采用默认的推送类型
|
|
|
|
// 查询粉丝设置的推送类型,如果参数中没有指定则采用默认的推送类型
|
|
|
|