backup

barrage-crawler-server/src/main/java/com/zhiweidata/automatictest/barragecrawlerserver/entity/BarrageTaskResponse.java

 package com.zhiweidata.automatictest.barragecrawlerserver.entity;
 
+import com.fasterxml.jackson.annotation.JsonProperty;
 import com.zhiweidata.automatictest.barragecrawlerserver.enums.BarrageStatusEnums;
 import com.zhiweidata.automatictest.barragecrawlerserver.enums.PlatformEnum;
 import java.io.Serializable;
@@ -15,14 +16,24 @@ import lombok.Data;
 @SuppressWarnings("JavaDoc")
 @Data
 public class BarrageTaskResponse implements Serializable {
+    @JsonProperty(value = "id")
     private String id;
+    @JsonProperty(value = "name")
     private String name;
+    @JsonProperty(value = "url")
     private String url;
+    @JsonProperty(value = "roomId")
     private String roomId;
+    @JsonProperty(value = "startTime")
     private int startTime;
+    @JsonProperty(value = "endTime")
     private int endTime;
+    @JsonProperty(value = "status")
     private BarrageStatusEnums status;
+    @JsonProperty(value = "platform")
     private PlatformEnum platform;
+    @JsonProperty(value = "createTime")
     private int createTime;
+    @JsonProperty(value = "collectionCount")
     private int collectionCount;
 }

barrage-crawler-server/src/main/java/com/zhiweidata/automatictest/barragecrawlerserver/exporttasks/BiliBiliExportTaskJob.java

@@ -2,7 +2,9 @@ package com.zhiweidata.automatictest.barragecrawlerserver.exporttasks;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.zhiweidata.automatictest.barragecrawlerserver.entity.BarrageCollectionTask;
+import com.zhiweidata.automatictest.barragecrawlerserver.entity.BarrageTaskResponse;
 import com.zhiweidata.automatictest.barragecrawlerserver.util.JsonPretty;
+import java.util.List;
 import java.util.Map;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.http.HttpResponse;
@@ -37,8 +39,8 @@ public class BiliBiliExportTaskJob implements BarrageExportTaskJob {
     @Override
     public void execute(JobExecutionContext context) {
         try {
-            JobDataMap dataMap = requireNonNull(context.getMergedJobDataMap());
-            BarrageCollectionTask collectionTask = (BarrageCollectionTask) requireNonNull(dataMap.get(BARRAGE_COLLECTION_TASK_JOB_KEY));
+            JobDataMap jobDataMap = requireNonNull(context.getMergedJobDataMap());
+            BarrageCollectionTask collectionTask = (BarrageCollectionTask) requireNonNull(jobDataMap.get(BARRAGE_COLLECTION_TASK_JOB_KEY));
             String url = BASE_URL + "tasks?limit=20&page=1&name=" + collectionTask.getName();
             HttpResponse response = HTTP_CLIENT.execute(new HttpGet(url));
 
@@ -50,7 +52,10 @@ public class BiliBiliExportTaskJob implements BarrageExportTaskJob {
                 return;
             }
 
-            log.info("{}{}", System.lineSeparator(), jsonMapper.writer(new JsonPretty()).writeValueAsString(jsonMap));
+            Map<?, ?> dataMap = (Map<?, ?>) requireNonNull(jsonMap.get("data"));
+            List<?> dataList = (List<?>) requireNonNull(dataMap.get("list"));
+            BarrageTaskResponse taskResponse = jsonMapper.convertValue(dataList.get(0), BarrageTaskResponse.class);
+            System.out.println(taskResponse);
         } catch (Exception e) {
             log.error(e.getMessage(), e);
         }