chore: 修复发送多人

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<PushApplicationMappe
             List<PushConcernFan> pushConcernFanList = iPushConcernFanService.list(Wrappers.<PushConcernFan>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(",")));
         }
 
         // 过滤黑名单，根据谁拉黑了推送方用户进行过滤推送用户

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<PushConcernFanMapper,
                 List<PushConcernFan> pushConcernFanList = super.list(Wrappers.<PushConcernFan>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.<PushConcernFanType>lambdaQuery()
@@ -110,7 +110,7 @@ public class PushConcernFanServiceImpl extends ServiceImpl<PushConcernFanMapper,
                 List<PushConcernFan> pushConcernFanList = super.list(Wrappers.<PushConcernFan>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(",")));
             }
         }