Implement fetUserInfos

Author: yanyin1986

src/main/java/org/mushare/pluto/Pluto.java

@@ -1,13 +1,20 @@
 package org.mushare.pluto;
 
+import com.github.kevinsawicki.http.HttpRequest;
+import net.sf.json.JSONArray;
 import net.sf.json.JSONObject;
 import org.mushare.pluto.exception.PlutoErrorCode;
 import org.mushare.pluto.exception.PlutoException;
 
 import java.io.UnsupportedEncodingException;
 import java.security.Signature;
+import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.Base64;
 import java.util.List;
+import java.util.stream.Collectors;
+import java.util.stream.IntStream;
+import java.util.stream.Stream;
 
 public class Pluto {
 
@@ -71,9 +78,31 @@ public static PlutoUser auth(String token) throws PlutoException {
         return new PlutoUser(payload);
     }
 
-    public static List<PlutoUserInfo> fetUserInfos(long[] userIds) {
-
-        return null;
+    public static List<PlutoUserInfo> fetUserInfos(List<Long> userIds) {
+        if (userIds == null || userIds.size() == 0) {
+            return new ArrayList<>();
+        }
+        String ids = userIds.stream()
+                .map(userId -> userId + "-")
+                .reduce("", (s1, s2) -> {
+                    return s1 + s2;
+                });
+        ids = ids.substring(0, ids.length() - 1);
+        String response = HttpRequest.get(shared.server + "api/user/info/" + ids).body();
+        JSONArray body = JSONObject.fromObject(response).getJSONArray("body");
+        return IntStream.range(0, body.size())
+                .mapToObj(index -> {
+                    JSONObject object = body.getJSONObject(index);
+                    PlutoUserInfo info = new PlutoUserInfo();
+                    info.setUserId(object.getLong("id"));
+                    if (object.containsKey("err_code") && object.getInt("err_code") == 403) {
+                        return info;
+                    }
+                    info.setAvatar(object.getString("avatar"));
+                    info.setName(object.getString("name"));
+                    return info;
+                })
+                .collect(Collectors.toList());
     }
 
 }

src/main/java/org/mushare/pluto/PlutoUserInfo.java

@@ -28,4 +28,13 @@ public String getAvatar() {
     public void setAvatar(String avatar) {
         this.avatar = avatar;
     }
+
+    @Override
+    public String toString() {
+        return "PlutoUserInfo{" +
+                "userId=" + userId +
+                ", name='" + name + '\'' +
+                ", avatar='" + avatar + '\'' +
+                '}';
+    }
 }

src/test/java/org/mushare/pluto/PlutoTest.java

@@ -6,6 +6,9 @@
 import org.mushare.pluto.exception.PlutoErrorCode;
 import org.mushare.pluto.exception.PlutoException;
 
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
 import static org.junit.Assert.assertTrue;
 
 public class PlutoTest {
@@ -41,5 +44,13 @@ public void testScopes() throws PlutoException {
         String token = "eyJ0eXBlIjoiand0IiwiYWxnIjoicnNhIn0.eyJ0eXBlIjoiYWNjZXNzIiwiY3JlYXRlX3RpbWUiOjE1ODU0NDg1MTcsImV4cGlyZV90aW1lIjoxNTg1NDUyMTE3LCJ1c2VySWQiOjQ4LCJkZXZpY2VJZCI6IkM5QTExQTIzLTg1QTMtNEMwRC04RjQxLTE5QURBNEIwOTJFRSIsImFwcElkIjoib3JnLm11c2hhcmUuZWFzeWphcGFuZXNlIiwic2NvcGVzIjpudWxsLCJsb2dpbl90eXBlIjoiZ29vZ2xlIn0.LyYEgEIxc1ghirESmvvpDE/EEd9B0U10BRgbKt3YdfiCb6L3URizHIqJVoc6IhPZOOBNy2x2Dk/sCZ5JV1rtaZ8niMdAb7VL7PwObZiWuWT8TieuV+7DaPxcJrPdzgz46GOOX7o3+fWRr64ucOYZeiY/g0PBCL07dMPRHYyzHK7e8Wrb/59rUjO4GCad5vM5qny9jTXihB+IokBPOYDkhKCinOfMAqOOFOtVRVdxt/mCLhnjkxexwWM/a7vmJQ4qOZYHxAB9mbgDq+mbBfzWafFWhbADdZdSqyKnKUDguBE1fPRODLqTIqB0KL4cttgSHKivlwwiVaaxZUEkwGN4GQ";
         Pluto.auth(token);
     }
+
+    @Test
+    public void testFetchUserInfos() {
+        Pluto.setup("https://staging.easyjapanese-api-gateway.mushare.cn/pluto/", "org.mushare.easyjapanese");
+        Pluto.fetUserInfos(Stream.of(1L, 2L, 3L).collect(Collectors.toList())).forEach(plutoUserInfo -> {
+            System.out.println(plutoUserInfo);
+        });
+    }
 
 }