更新用户统计信息逻辑

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

@@ -120,33 +120,32 @@ public class UserStatisticsListener implements DataItemChangeListener {
             messageQueueService.sendDataItemChangeMessage(DataItemChangeMessage.updateMessage(DataItemType.USER_STATISTICS, followerUserId, followerUserId));
 
         } else {
-            // 发布博客
             if (itemType.equals(DataItemType.BLOG)) {
                 // 更新博客发布量
                 QueryWrapper<Blog> blogQueryWrapper = new QueryWrapper<>();
                 blogQueryWrapper.eq("user_id", operatorId);
                 long blogCount = blogService.count(blogQueryWrapper);
                 log.debug("blog count is : {}", blogCount);
-                updateUserStatisticValue((String) itemId, "blog_num", blogCount);
+                updateUserStatisticValue(operatorId, "blog_num", blogCount);
             }
 
-            // 发布项目
             if (itemType.equals(DataItemType.PROJECT)) {
                 // 更新项目发布量
                 QueryWrapper<Project> projectQueryWrapper = new QueryWrapper<>();
                 projectQueryWrapper.eq("user_id", operatorId);
-                updateUserStatisticValue((String) itemId, "project_num", projectService.count(projectQueryWrapper));
+                long projectCount = projectService.count(projectQueryWrapper);
+                log.debug("project count is : {}", projectCount);
+                updateUserStatisticValue(operatorId, "project_num", projectCount);
             }
 
-            // 发布动态
             if (itemType.equals(DataItemType.POST)) {
                 // 更新动态发布量
                 QueryWrapper<Post> postQueryWrapper = new QueryWrapper<>();
-                postQueryWrapper.eq("user_id", operatorId);
-                updateUserStatisticValue((String) itemId, "post_num", postService.count(postQueryWrapper));
+                long postCount = postService.count(postQueryWrapper);
+                log.debug("post count is : {}", postCount);
+                updateUserStatisticValue(operatorId, "post_num", postCount);
             }
 
-            // 发布问答
             if (itemType.equals(DataItemType.QUESTION)) {
                 // 更新问答发布量
                 QueryWrapper<Question> questionQueryWrapper = new QueryWrapper<>();