提交

src/main/java/cn/ezhizao/framework/task/RyTask.java

@@ -128,14 +128,14 @@ public class RyTask {
     @Resource
     IBizMessageService messageService;
 
-//    public void checkMessage() throws IOException {
-//        List<BizMessage> messages = messageService.query().eq("msg_read", 0).list();
-//        Map<Long, List<BizMessage>> groupById = messages.stream().collect(Collectors.groupingBy(BizMessage::getToUserId, Collectors.toList()));
-//        for (Map.Entry<Long, List<BizMessage>> entry : groupById.entrySet()) {
-//            WebSocketUser.sendInfo(String.valueOf(entry.getValue().size()), String.valueOf(entry.getKey()));
-//        }
-//        WebSocketUser.sendEmptyMessage(messages.stream().map(BizMessage::getToUserId).collect(Collectors.toList()));
-//    }
+    public void checkMessage() throws IOException {
+        List<BizMessage> messages = messageService.query().eq("msg_read", 0).list();
+        Map<Long, List<BizMessage>> groupById = messages.stream().collect(Collectors.groupingBy(BizMessage::getToUserId, Collectors.toList()));
+        for (Map.Entry<Long, List<BizMessage>> entry : groupById.entrySet()) {
+            WebSocketUser.sendInfo(String.valueOf(entry.getValue().size()), String.valueOf(entry.getKey()));
+        }
+        WebSocketUser.sendEmptyMessage(messages.stream().map(BizMessage::getToUserId).collect(Collectors.toList()));
+    }
 
     /** 原始二维码生成方法，生成JSON格式
      * public <T> void  GenerateQcCode(T t) throws JsonProcessingException {