From e6920372f4aecf41010467c05a681f9e22f21712 Mon Sep 17 00:00:00 2001 From: wangxiang <1827945911@qq.com> Date: Mon, 3 Jul 2023 14:07:40 +0800 Subject: [PATCH] =?UTF-8?q?chore:=20=E4=BF=AE=E5=A4=8D=E5=8F=91=E9=80=81?= =?UTF-8?q?=E5=A4=9A=E4=BA=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../commonbiz/service/impl/PushApplicationServiceImpl.java | 2 +- .../commonbiz/service/impl/PushConcernFanServiceImpl.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) 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(","))); } }