|
@@ -32,16 +32,14 @@ public class WuKongSessionServiceImpl implements WuKongSessionService{
|
|
|
for (ConversationSyncRespVo conversationSyncRespVo : conversationSyncRespVos) {
|
|
|
conversationSyncRespVo.getRecents().forEach(item->uids.add(item.get("from_uid").toString()));
|
|
|
}
|
|
|
- Map<String, ImUserInfoVo> imUserInfoVoMap = userService.getUserByUids(uids).getData().stream().collect(Collectors.toMap(item -> item.getUid(), item -> item));
|
|
|
- System.out.println(JSON.toJSONString(imUserInfoVoMap));
|
|
|
+ Map<String, ImUserInfoVo> imUserInfoVoMap = userService.getUserByUids(uids).getData().stream().collect(Collectors.toMap(ImUserInfoVo::getUid, item -> item));
|
|
|
+// System.out.println(JSON.toJSONString(imUserInfoVoMap));
|
|
|
for (ConversationSyncRespVo conversationSyncRespVo : conversationSyncRespVos) {
|
|
|
- String fromUid = conversationSyncRespVo.getChannelId().toString();
|
|
|
-
|
|
|
-
|
|
|
+ String fromUid = conversationSyncRespVo.getChannelId();
|
|
|
conversationSyncRespVo.setUserInfoVo(imUserInfoVoMap.get(fromUid));
|
|
|
}
|
|
|
|
|
|
- return CommonResult.success(wuKongApiService.conversationSync(reqVo));
|
|
|
+ return CommonResult.success(conversationSyncRespVos);
|
|
|
}
|
|
|
|
|
|
@Override
|