diff options
Diffstat (limited to 'server-core/src/main/java/com/juick/service/SubscriptionServiceImpl.java')
| -rw-r--r-- | server-core/src/main/java/com/juick/service/SubscriptionServiceImpl.java | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/server-core/src/main/java/com/juick/service/SubscriptionServiceImpl.java b/server-core/src/main/java/com/juick/service/SubscriptionServiceImpl.java index 2bf05796..f6ecb658 100644 --- a/server-core/src/main/java/com/juick/service/SubscriptionServiceImpl.java +++ b/server-core/src/main/java/com/juick/service/SubscriptionServiceImpl.java @@ -61,7 +61,7 @@ public class SubscriptionServiceImpl extends BaseJdbcService implements Subscrip List<User> userids = userService.getUserReaders(uid); Set<Integer> set = new HashSet<>(); - set.addAll(userids.stream().map(User::getUID).collect(Collectors.toList())); + set.addAll(userids.stream().map(User::getUid).collect(Collectors.toList())); List<Integer> tags = messagesService.getMessageTagsIDs(mid); if (tags.size() > 0) { List<Integer> tagUsers = getJdbcTemplate().queryForList( @@ -70,7 +70,7 @@ public class SubscriptionServiceImpl extends BaseJdbcService implements Subscrip " AND suser_id NOT IN (SELECT user_id FROM bl_users WHERE bl_user_id=?)", Integer.class, uid, - author.getUID()); + author.getUid()); set.addAll(tagUsers); } return userService.getUsersByID(new ArrayList<>(set)); @@ -134,7 +134,7 @@ public class SubscriptionServiceImpl extends BaseJdbcService implements Subscrip public boolean subscribeUser(final User user, final User toUser) { return getJdbcTemplate().update( "INSERT IGNORE INTO subscr_users(user_id,suser_id) VALUES (?,?)", - toUser.getUID(), user.getUID()) == 1; + toUser.getUid(), user.getUid()) == 1; } @Transactional @@ -142,7 +142,7 @@ public class SubscriptionServiceImpl extends BaseJdbcService implements Subscrip public boolean unSubscribeUser(final User user, final User fromUser) { return getJdbcTemplate().update( "DELETE FROM subscr_users WHERE suser_id=? AND user_id=?", - user.getUID(), fromUser.getUID()) > 0; + user.getUid(), fromUser.getUid()) > 0; } @Transactional @@ -150,7 +150,7 @@ public class SubscriptionServiceImpl extends BaseJdbcService implements Subscrip public boolean subscribeTag(final User user, final Tag toTag) { return getJdbcTemplate().update( "INSERT IGNORE INTO subscr_tags(tag_id,suser_id) VALUES (?,?)", - toTag.TID, user.getUID()) == 1; + toTag.TID, user.getUid()) == 1; } @Transactional @@ -158,7 +158,7 @@ public class SubscriptionServiceImpl extends BaseJdbcService implements Subscrip public boolean unSubscribeTag(final User user, final Tag toTag) { return getJdbcTemplate().update( "DELETE FROM subscr_tags WHERE tag_id=? AND suser_id=?", - toTag.TID, user.getUID()) > 0; + toTag.TID, user.getUid()) > 0; } @Transactional(readOnly = true) @@ -174,7 +174,7 @@ public class SubscriptionServiceImpl extends BaseJdbcService implements Subscrip options.setRecommendationsEnabled(rs.getInt(3) > 0); return options; }, - user.getUID()); + user.getUid()); } catch (EmptyResultDataAccessException e) { return new NotifyOpts(); } @@ -185,12 +185,12 @@ public class SubscriptionServiceImpl extends BaseJdbcService implements Subscrip public boolean setNotifyOptions(final User user, final NotifyOpts options) { return getJdbcTemplate().update( "UPDATE useroptions SET jnotify=? WHERE user_id=?", options.isRepliesEnabled() ? 1 : 0, - user.getUID()) > 0 && + user.getUid()) > 0 && getJdbcTemplate().update( "UPDATE useroptions SET subscr_notify=? WHERE user_id=?", options.isSubscriptionsEnabled() ? 1 : 0, - user.getUID()) > 0 && + user.getUid()) > 0 && getJdbcTemplate().update( "UPDATE useroptions SET recommendations=? WHERE user_id=?", options.isRecommendationsEnabled() ? 1 : 0, - user.getUID()) > 0; + user.getUid()) > 0; } } |