Просмотр исходного кода

【功能完善】【修改数据库链接】

koul 4 лет назад
Родитель
Сommit
551c4380aa
1 измененных файлов с 27 добавлено и 15 удалено
  1. 27 15
      src/main/java/com/uas/service/Impl/CustomerServiceImpl.java

+ 27 - 15
src/main/java/com/uas/service/Impl/CustomerServiceImpl.java

@@ -103,23 +103,35 @@ public class CustomerServiceImpl implements CustomerService {
      */
     @Override
     public List<String> getFollowingByGroup(){
-        Map<String, String> param = new HashMap<>();
-        param.put("apikey",apikey);
-        param.put("from",Integer.toString(0));
-        param.put("size",Integer.toString(1000));
-        List<Group> groupAll = getGroupAll();
-        if (groupAll!=null){
-            List<String> list = new ArrayList<>();
-            for (Group group:groupAll) {
-                param.put("group_id",Long.toString(group.getId()));
-                Map map = httpResponseBySize(url + httpConfig.get("following"), apikey, 0,1000, hender, param);
-                if (map!=null&&map.get("data")!=null){
-                    List<String> strings = JSON.parseArray(map.get("data").toString(), String.class);
-                    list.addAll(strings);
+        try {
+            Map<String, String> param = new HashMap<>();
+            param.put("apikey",apikey);
+            param.put("from",Integer.toString(0));
+            param.put("size",Integer.toString(1000));
+            List<Group> groupAll = getGroupAll();
+            if (groupAll!=null){
+                List<String> list = new ArrayList<>();
+                for (Group group:groupAll) {
+                    param.put("group_id",Long.toString(group.getId()));
+                    HttpUtil.Response response = HttpUtil.sendGetRequest(url + httpConfig.get("following"), hender, param);
+                    int statusCode = response.getStatusCode();
+                    if (statusCode == 200) {
+                        String responseText = response.getResponseText();
+                        if (responseText != null&&!"[]\n".equals(responseText)) {
+                            JSONObject jsonObject = JSON.parseObject(responseText);
+                            Object hits = jsonObject.get("hits");
+                            List<String> strings = JSON.parseArray(JSON.parseArray(hits.toString()).toString(), String.class);
+                            list.addAll(strings);
+
+                        }
+                    }
                 }
+                return list;
             }
-            return list;
+        }catch (Exception e){
+            e.printStackTrace();
         }
+
         return null;
     }
 
@@ -978,7 +990,7 @@ public class CustomerServiceImpl implements CustomerService {
                             int status = response1.getStatusCode();
                             if (status == 200) {
                                 String s = response1.getResponseText();
-                                if (s != null) {
+                                if (s != null&&!"[]\n".equals(s)) {
                                     Object hits = JSON.parseObject(s).get("hits");
                                     jsonArray = JSON.parseArray(hits.toString());
                                 }