浏览代码

消息同步报错解决

fuyuchuan 6 天之前
父节点
当前提交
c797db68a6
共有 1 个文件被更改,包括 6 次插入1 次删除
  1. 6 1
      flow-im/flow-im-entity/src/main/java/com/flow/job/SendUskyJob.java

+ 6 - 1
flow-im/flow-im-entity/src/main/java/com/flow/job/SendUskyJob.java

@@ -103,7 +103,12 @@ public class SendUskyJob {
             }
 
             List<String> userNames = unSend.stream().map(Notify::getSender).collect(Collectors.toList());
-            Map<String, String> userNamesMap = unSendUser(userNames).stream()
+            // Map<String, String> userNamesMap = unSendUser(userNames).stream()
+            //         .collect(Collectors.toMap(User::getUsername, User::getName));
+
+            List<User> unSendUsers = unSendUser(userNames);
+            log.info("查询到未发送的用户信息: {}", unSendUsers);
+            Map<String, String> userNamesMap = unSendUsers.stream()
                     .collect(Collectors.toMap(User::getUsername, User::getName));
             log.info("查询到的用户映射: {}", userNamesMap);