Преглед на файлове

1、缓存获取企业及用户数据接口调整

zk преди 2 години
родител
ревизия
ee675e8256
променени са 1 файла, в които са добавени 12 реда и са изтрити 4 реда
  1. 12 4
      sckw-modules/sckw-system/src/main/java/com/sckw/system/dubbo/RemoteSystemServiceImpl.java

+ 12 - 4
sckw-modules/sckw-system/src/main/java/com/sckw/system/dubbo/RemoteSystemServiceImpl.java

@@ -227,12 +227,16 @@ public class RemoteSystemServiceImpl implements RemoteSystemService {
     }
 
     @Override
-    public Map<Long, List<EntCacheResDto>> queryEntCacheMapByIds(List<Long> entIds) {
+    public Map<Long, EntCacheResDto> queryEntCacheMapByIds(List<Long> entIds) {
         List<EntCacheResDto> entCacheResDtos = queryEntCacheByIds(entIds);
         if (CollectionUtils.isEmpty(entCacheResDtos)) {
             return null;
         }
-        return entCacheResDtos.stream().collect(Collectors.groupingBy(EntCacheResDto::getId));
+        Map<Long, EntCacheResDto> entMap = new HashMap<>();
+        for (EntCacheResDto ent:entCacheResDtos) {
+            entMap.put(ent.getId(), ent);
+        }
+        return entMap;
     }
 
     @Override
@@ -295,12 +299,16 @@ public class RemoteSystemServiceImpl implements RemoteSystemService {
     }
 
     @Override
-    public Map<Long, List<UserCacheResDto>> queryUserCacheMapByIds(List<Long> userIds) {
+    public Map<Long, UserCacheResDto> queryUserCacheMapByIds(List<Long> userIds) {
         List<UserCacheResDto> userCacheResDtos = queryUserCacheByIds(userIds);
         if (CollectionUtils.isEmpty(userCacheResDtos)) {
             return null;
         }
-        return userCacheResDtos.stream().collect(Collectors.groupingBy(UserCacheResDto::getId));
+        Map<Long, UserCacheResDto> entMap = new HashMap<>();
+        for (UserCacheResDto ent:userCacheResDtos) {
+            entMap.put(ent.getId(), ent);
+        }
+        return entMap;
     }
 
     @Override