backup

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

 package com.zhiweidata.automatictest.barragecrawlerserver.createtasks;
 
-import org.apache.poi.ss.usermodel.CellRange;
-import org.quartz.Job;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import java.net.URL;
+import java.util.Map;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.http.HttpException;
+import org.apache.http.HttpResponse;
+import org.apache.http.StatusLine;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.util.EntityUtils;
 import org.quartz.JobExecutionContext;
 
+import static com.zhiweidata.automatictest.publics.BeanContainer.HTTP_CLIENT;
+
 /**
  * 从B站直播的首页获得直播间的地址，并发送到弹幕采集服务器进行测试
  *
@@ -11,14 +20,22 @@ import org.quartz.JobExecutionContext;
  * @createTime 2021-08-23 17:43:24
  * @ide IntelliJ IDEA
  */
+@Slf4j
 @SuppressWarnings("JavaDoc")
 public class BiliBiliCreateTaskJob extends CreateTaskJob {
+    private String liveTitle;
+
     @Override
     public void execute(JobExecutionContext jobExecutionContext) {
+        try {
+            Map<?, ?> liveJson = new ObjectMapper().readValue(new URL("https://api.live.bilibili.com/xlive/web-interface/v1/index/getList?platform=web"), Map.class);
+        } catch (Exception e) {
+            log.error(e.getMessage(), e);
+        }
     }
 
     @Override
-    public String getLiveName(String liveUrl) {
-        return null;
+    protected String getLiveName(String liveUrl) {
+        return this.liveTitle;
     }
 }

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

@@ -7,7 +7,6 @@ import java.io.IOException;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
-import java.util.Set;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.http.HttpResponse;
 import org.apache.http.client.methods.HttpPost;
@@ -15,8 +14,6 @@ import org.apache.http.entity.ByteArrayEntity;
 import org.apache.http.entity.ContentType;
 import org.bson.Document;
 import org.quartz.Job;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import static com.zhiweidata.automatictest.barragecrawlerserver.config.BaseConfig.MONGO_LIVE_COLLECTION;
 import static com.zhiweidata.automatictest.barragecrawlerserver.config.BaseConfig.TASK_URL;
@@ -55,7 +52,6 @@ public abstract class CreateTaskJob implements Job {
             post.setEntity(new ByteArrayEntity(objectMapper.writeValueAsBytes(collectionTask), ContentType.APPLICATION_JSON));
             HttpResponse response = HTTP_CLIENT.execute(post);
             Map<?, ?> jsonMap = objectMapper.readValue(response.getEntity().getContent(), Map.class);
-            int code = (Integer) jsonMap.get("code");
             Document document = new Document("liveUrl", liveUrl);
             jsonMap.forEach((key, value) -> document.put((String) key, value));
             this.liveUrls.add(document);

barrage-crawler-server/src/test/java/com/zhiweidata/automatictest/barragecrawlerserver/createtasks/BiliBiliCreateTaskJobTest.java

+package com.zhiweidata.automatictest.barragecrawlerserver.createtasks;
+
+import org.junit.jupiter.api.Test;
+
+/**
+ * @author aszswaz
+ * @createTime 2021-08-24 18:21:37
+ * @ide IntelliJ IDEA
+ */
+@SuppressWarnings("JavaDoc")
+class BiliBiliCreateTaskJobTest {
+
+    @Test
+    void execute() {
+        BiliBiliCreateTaskJob createTaskJob = new BiliBiliCreateTaskJob();
+        createTaskJob.execute(null);
+    }
+}
\ No newline at end of file