fix: unapproved replies are included in the reply count of comments (#3578)

#### What type of PR is this?
/kind improvement
/area core
/milestone 2.4.x
/kind api-change

#### What this PR does / why we need it:
修复未审核过的回复包含在了评论的回复数量中的问题

此改动需要评论组件修改回复数量取值为 `status.visibleReplyCount`

how to test it?
1. 创建评论，并在评论下回复
2. 评论的所有回复被计数在 `status.replyCount` 中
3. 而 `status.visibleReplyCount` 数量不包含 `spec.hiden=true` 或 `spec.approved = false` 的

#### Which issue(s) this PR fixes:
Fixes #3165

#### Does this PR introduce a user-facing change?

```release-note
修复未审核过的回复包含在了评论的回复数量中的问题
```

api/src/main/java/run/halo/app/core/extension/content/Comment.java

@@ -123,6 +123,8 @@ public class Comment extends AbstractExtension {
 
         private Integer replyCount;
 
+        private Integer visibleReplyCount;
+
         private Integer unreadReplyCount;
 
         private Boolean hasNewReply;

application/src/main/java/run/halo/app/core/extension/reconciler/ReplyReconciler.java

@@ -6,7 +6,7 @@ import lombok.AllArgsConstructor;
 import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.stereotype.Component;
 import run.halo.app.core.extension.content.Reply;
-import run.halo.app.event.post.ReplyCreatedEvent;
+import run.halo.app.event.post.ReplyChangedEvent;
 import run.halo.app.event.post.ReplyDeletedEvent;
 import run.halo.app.extension.ExtensionClient;
 import run.halo.app.extension.controller.Controller;
@@ -36,10 +36,9 @@ public class ReplyReconciler implements Reconciler<Reconciler.Request> {
                     return;
                 }
 
-                if (addFinalizerIfNecessary(reply)) {
-                    // on reply created
-                    eventPublisher.publishEvent(new ReplyCreatedEvent(this, reply));
-                }
+                addFinalizerIfNecessary(reply);
+                // on reply created
+                eventPublisher.publishEvent(new ReplyChangedEvent(this, reply));
             });
         return new Result(false, null);
     }
@@ -56,10 +55,10 @@ public class ReplyReconciler implements Reconciler<Reconciler.Request> {
         });
     }
 
-    private boolean addFinalizerIfNecessary(Reply oldReply) {
+    private void addFinalizerIfNecessary(Reply oldReply) {
         Set<String> finalizers = oldReply.getMetadata().getFinalizers();
         if (finalizers != null && finalizers.contains(FINALIZER_NAME)) {
-            return false;
+            return;
         }
         client.fetch(Reply.class, oldReply.getMetadata().getName())
             .ifPresent(reply -> {
@@ -71,7 +70,6 @@ public class ReplyReconciler implements Reconciler<Reconciler.Request> {
                 newFinalizers.add(FINALIZER_NAME);
                 client.update(reply);
             });
-        return true;
     }
 
     @Override

application/src/main/java/run/halo/app/event/post/ReplyChangedEvent.java

@@ -6,9 +6,9 @@ import run.halo.app.core.extension.content.Reply;
  * @author guqing
  * @since 2.0.0
  */
-public class ReplyCreatedEvent extends ReplyEvent {
+public class ReplyChangedEvent extends ReplyEvent {
 
-    public ReplyCreatedEvent(Object source, Reply reply) {
+    public ReplyChangedEvent(Object source, Reply reply) {
         super(source, reply);
     }
 }

application/src/main/java/run/halo/app/metrics/ReplyEventReconciler.java

@@ -1,5 +1,7 @@
 package run.halo.app.metrics;
 
+import static org.apache.commons.lang3.BooleanUtils.isFalse;
+import static org.apache.commons.lang3.BooleanUtils.isTrue;
 import static org.apache.commons.lang3.ObjectUtils.defaultIfNull;
 
 import java.time.Duration;
@@ -8,6 +10,7 @@ import java.util.List;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.context.SmartLifecycle;
 import org.springframework.context.event.EventListener;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Component;
 import run.halo.app.content.comment.ReplyService;
 import run.halo.app.core.extension.content.Comment;
@@ -62,6 +65,13 @@ public class ReplyEventReconciler implements Reconciler<ReplyEvent>, SmartLifecy
                 // total reply count
                 status.setReplyCount(replies.size());
 
+                long visibleReplyCount = replies.stream()
+                    .filter(reply -> isTrue(reply.getSpec().getApproved())
+                        && isFalse(reply.getSpec().getHidden())
+                    )
+                    .count();
+                status.setVisibleReplyCount((int) visibleReplyCount);
+
                 // calculate last reply time
                 Instant lastReplyTime = replies.stream()
                     .findFirst()
@@ -73,6 +83,7 @@ public class ReplyEventReconciler implements Reconciler<ReplyEvent>, SmartLifecy
 
                 Instant lastReadTime = comment.getSpec().getLastReadTime();
                 status.setUnreadReplyCount(Comment.getUnreadReplyCount(replies, lastReadTime));
+                status.setHasNewReply(defaultIfNull(status.getUnreadReplyCount(), 0) > 0);
 
                 client.update(comment);
             });
@@ -107,8 +118,13 @@ public class ReplyEventReconciler implements Reconciler<ReplyEvent>, SmartLifecy
         return this.running;
     }
 
-    @EventListener(ReplyEvent.class)
-    public void onReplyAdded(ReplyEvent replyEvent) {
-        replyEventQueue.addImmediately(replyEvent);
+    @Component
+    public class ReplyEventListener {
+
+        @Async
+        @EventListener(ReplyEvent.class)
+        public void onReplyEvent(ReplyEvent replyEvent) {
+            replyEventQueue.addImmediately(replyEvent);
+        }
     }
 }