aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/com/juick/service/SubscriptionServiceImpl.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/com/juick/service/SubscriptionServiceImpl.java')
-rw-r--r--src/main/java/com/juick/service/SubscriptionServiceImpl.java6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/main/java/com/juick/service/SubscriptionServiceImpl.java b/src/main/java/com/juick/service/SubscriptionServiceImpl.java
index fae1b824..4aa5b5ac 100644
--- a/src/main/java/com/juick/service/SubscriptionServiceImpl.java
+++ b/src/main/java/com/juick/service/SubscriptionServiceImpl.java
@@ -62,8 +62,8 @@ public class SubscriptionServiceImpl extends BaseJdbcService implements Subscrip
.filter(u -> !userService.isInBL(u.getUid(), msg.getUser().getUid()))
.toList();
List<User> users = ListUtils.union(subscribers, mentionedUsers);
- List<Integer> tags = tagService.getMessageTagsIDs(mid);
- List<String> tagsStr = tagService.getMessageTags(mid).stream().map(t -> t.getTag().getName())
+ var tags = tagService.getMessageTags(mid);
+ List<String> tagsStr = tags.stream().map(t -> t.getTag().getName())
.toList();
Set<Integer> set = users.stream()
@@ -80,7 +80,7 @@ public class SubscriptionServiceImpl extends BaseJdbcService implements Subscrip
+
" AND NOT EXISTS (SELECT 1 FROM bl_tags bt WHERE bt.tag_id IN (:ids) and st.suser_id = bt.user_id)",
new MapSqlParameterSource()
- .addValue("ids", tags)
+ .addValue("ids", tags.stream().map(t -> t.getTag().getId()).collect(Collectors.toList()))
.addValue("uid", uid)
.addValue("authorUid", author.getUid()),
Integer.class);