diff --git a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/PushApplicationServiceImpl.java b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/PushApplicationServiceImpl.java index 5964364d..2fa48a9c 100644 --- a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/PushApplicationServiceImpl.java +++ b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/PushApplicationServiceImpl.java @@ -96,7 +96,7 @@ public class PushApplicationServiceImpl extends ServiceImpl pushConcernFanList = iPushConcernFanService.list(Wrappers.lambdaQuery() .eq(PushConcernFan::getConcernUserId, pushChatMessage.getUserId()) .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(","))); } // 过滤黑名单,根据谁拉黑了推送方用户进行过滤推送用户 diff --git a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/PushConcernFanServiceImpl.java b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/PushConcernFanServiceImpl.java index 98ad8521..f584639b 100644 --- a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/PushConcernFanServiceImpl.java +++ b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/PushConcernFanServiceImpl.java @@ -98,7 +98,7 @@ public class PushConcernFanServiceImpl extends ServiceImpl pushConcernFanList = super.list(Wrappers.lambdaQuery() .eq(PushConcernFan::getConcernUserId, pushChatMessage.getUserId()) .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(","))); } // 查询粉丝设置的推送类型,如果参数中没有指定则采用默认的推送类型 pushConcernFanTypeList = iPushConcernFanTypeService.list(Wrappers.lambdaQuery() @@ -110,7 +110,7 @@ public class PushConcernFanServiceImpl extends ServiceImpl pushConcernFanList = super.list(Wrappers.lambdaQuery() .eq(PushConcernFan::getConcernUserId, pushChatMessage.getUserId()) .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(","))); } }