1 files changed, 21 insertions, 2 deletions
diff --git a/src/main/java/com/juick/server/TopManager.java b/src/main/java/com/juick/server/TopManager.java
index fe3d605d..ff7ae9fd 100644
--- a/src/main/java/com/juick/server/TopManager.java
+++ b/src/main/java/com/juick/server/TopManager.java
@@ -19,15 +19,21 @@ package com.juick.server;
 
 import com.juick.Message;
 import com.juick.Tag;
+import com.juick.User;
+import com.juick.server.api.SystemActivity;
 import com.juick.service.MessagesService;
-import com.juick.service.component.TopEvent;
+import com.juick.service.UserService;
+import com.juick.service.component.SystemEvent;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.PostConstruct;
 import javax.inject.Inject;
+import java.util.Collections;
 import java.util.List;
 import java.util.stream.Collectors;
 
@@ -37,8 +43,20 @@ public class TopManager {
     @Inject
     private MessagesService messagesService;
     @Inject
+    private UserService userService;
+    @Inject
     private ApplicationEventPublisher applicationEventPublisher;
 
+    @Value("${service_user:juick}")
+    private String serviceUsername;
+
+    private User serviceUser;
+
+    @PostConstruct
+    public void init() {
+        serviceUser = userService.getUserByName(serviceUsername);
+    }
+
     @Scheduled(fixedRate = 3600000)
     public void updateTop() {
         messagesService.getPopularCandidates().forEach(m -> {
@@ -47,7 +65,8 @@ public class TopManager {
             messagesService.setMessagePopular(m, 1);
             List<String> tags = jmsg.getTags().stream().map(Tag::getName).map(String::toLowerCase).collect(Collectors.toList());
             if (!tags.contains("juick")) {
-                applicationEventPublisher.publishEvent(new TopEvent(this, jmsg));
+                applicationEventPublisher.publishEvent(new SystemEvent(this,
+                        SystemActivity.like(serviceUser, jmsg, Collections.emptyList())));
             }
         });
     }