博客浏览量修复

src/main/java/cn/meteor/beyondclouds/modules/user/listener/UserStatisticsListener.java

@@ -22,6 +22,7 @@ import cn.meteor.beyondclouds.util.SubjectUtils;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.kafka.common.protocol.types.Field;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -160,8 +161,10 @@ public class UserStatisticsListener implements DataItemChangeListener {
             }
 
             if (itemType.equals(DataItemType.BLOG_VIEW_NUM)) {
+                Blog blog = blogService.getById(itemId);
+                String userId = blog.getUserId();
                 // 更新博客浏览量
-                updateUserStatisticValue(operatorId, "blog_view_num", blogService.allBlogViewCount(operatorId));
+                updateUserStatisticValue(userId, "blog_view_num", blogService.allBlogViewCount(userId));
             }
 
             if (itemType.equals(DataItemType.PROJECT)) {