Commit 302ff931 by 段启岩

统计信息修复

parent 0d0a37e8
......@@ -115,7 +115,7 @@ public class UserStatisticsListener implements DataItemChangeListener {
QueryWrapper<UserFollow> followerUserFollowedNumQueryWrapper = new QueryWrapper<>();
followerUserFollowedNumQueryWrapper.eq("follower_id", userFollow.getFollowerId());
long followerUserFollowedNum = userFollowService.count(followerUserFollowedNumQueryWrapper);
updateUserStatisticValue(userFollow.getFollowerId(), "fans_num", followerUserFollowedNum);
updateUserStatisticValue(userFollow.getFollowerId(), "followed_num", followerUserFollowedNum);
// 发送关注者统计信息修改的消息
messageQueueService.sendDataItemChangeMessage(DataItemChangeMessage.updateMessage(DataItemType.USER_STATISTICS, followerUserId, followerUserId));
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment