Kaynağa Gözat

获取用户

linxk 3 hafta önce
ebeveyn
işleme
e83c5777b3

+ 8 - 3
cif-service/src/main/java/com/txz/cif/dubbo/impl/UserDubboServiceImpl.java

@@ -1,8 +1,10 @@
 package com.txz.cif.dubbo.impl;
 
 import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.core.date.DateUtil;
+import com.google.common.base.Joiner;
 import com.txz.cif.core.RedisUtil;
 import com.txz.cif.core.cache.CacheKey;
 import com.txz.cif.core.cache.CacheType;
@@ -22,6 +24,7 @@ import javax.annotation.Resource;
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
+import java.util.stream.Collectors;
 
 @Slf4j
 @DubboService(timeout = 1200000)
@@ -78,9 +81,11 @@ public class UserDubboServiceImpl implements UserDubboService {
         if (CollectionUtil.isEmpty(userIds)) {
             return new ArrayList<>();
         }
-
-        List<UserDTO> usersByIds = userService.getUsersByIds(userIds);
-        return usersByIds;
+        List<User> users = userService.findByIds(Joiner.on(",").join(userIds));
+        if (CollUtil.isNotEmpty(users)){
+            return users.stream().map(u -> BeanUtil.toBean(u,UserDTO.class)).collect(Collectors.toList());
+        }
+        return CollUtil.newArrayList();
     }
 
     @Override