backup

barrage-crawler-server/src/main/java/com/zhiweidata/automatictest/barragecrawlerserver/createtasks/BiliBiliCreateTaskJob.java

@@ -26,11 +26,15 @@ public class BiliBiliCreateTaskJob extends CreateTaskJob {
         try {
             Map<?, ?> liveJson = new ObjectMapper().readValue(new URL("https://api.live.bilibili.com/xlive/web-interface/v1/index/getList?platform=web"), Map.class);
             liveJson = (Map<?, ?>) requireNonNull(liveJson.get("data"));
-            final List<?> roomList = (List<?>) liveJson.get("room_list");
-            roomList.forEach(liveRoom -> {
-                Map<?, ?> roomMap = (Map<?, ?>) liveRoom;
-                this.liveTitle = (String) roomMap.get("title");
-                super.createCollectionTask((String) roomMap.get("link"));
+            final List<?> moduleList = (List<?>) liveJson.get("room_list");
+            moduleList.forEach(liveModule -> {
+                Map<?, ?> liveModuleMap = (Map<?, ?>) liveModule;
+                List<?> roomList = (List<?>) liveModuleMap.get("list");
+                roomList.forEach(room -> {
+                    Map<?, ?> roomMap = (Map<?, ?>) room;
+                    this.liveTitle = (String) roomMap.get("title");
+                    BiliBiliCreateTaskJob.super.createCollectionTask((String) roomMap.get("link"));
+                });
             });
         } catch (Exception e) {
             log.error(e.getMessage(), e);