backup

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

@@ -10,6 +10,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.quartz.DisallowConcurrentExecution;
 import org.quartz.JobExecutionContext;
 
+import static java.util.Objects.nonNull;
 import static java.util.Objects.requireNonNull;
 
 /**
@@ -39,7 +40,7 @@ public class BiliBiliCreateTaskJob extends CreateTaskJob {
                     try {
                         Map<?, ?> roomMap = (Map<?, ?>) room;
                         BarrageCollectionTestTask collectionTask = BiliBiliCreateTaskJob.super.createCollectionTask(baseUrl + roomMap.get("link"), currentTime);
-                        BiliBiliCreateTaskJob.super.createExportTask(collectionTask);
+                        if (nonNull(collectionTask)) BiliBiliCreateTaskJob.super.createExportTask(collectionTask);
                     } catch (Exception e) {
                         log.error(e.getMessage(), e);
                     }

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

@@ -17,6 +17,7 @@ import org.apache.http.entity.ByteArrayEntity;
 import org.apache.http.entity.ContentType;
 import org.apache.ibatis.session.SqlSession;
 import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
 import org.quartz.Job;
 import org.quartz.JobBuilder;
 import org.quartz.JobDataMap;
@@ -31,6 +32,7 @@ import static com.zhiweidata.automatictest.publics.BeanContainer.HTTP_CLIENT;
 import static com.zhiweidata.automatictest.publics.BeanContainer.SCHEDULER;
 import static com.zhiweidata.automatictest.publics.BeanContainer.SQL_SESSION_FACTORY;
 import static com.zhiweidata.automatictest.publics.BeanContainer.STANDARD_DATE_FORMAT;
+import static java.util.Objects.nonNull;
 
 /**
  * @author aszswaz
@@ -48,7 +50,7 @@ public abstract class CreateTaskJob implements Job {
         liveUrls.forEach(liveUrl -> {
             try {
                 BarrageCollectionTestTask collectionTask = this.createCollectionTask(liveUrl, currentTime);
-                this.createExportTask(collectionTask);
+                if (nonNull(collectionTask)) this.createExportTask(collectionTask);
             } catch (Exception e) {
                 log.error(e.getMessage(), e);
             }
@@ -58,7 +60,7 @@ public abstract class CreateTaskJob implements Job {
     /**
      * 请求弹幕采集服务器创建采集任务
      */
-    @NotNull
+    @Nullable
     protected final BarrageCollectionTestTask createCollectionTask(String liveUrl, long currentTime) throws IOException {
         final String liveName = UUID.randomUUID().toString();
         BarrageCollectionTestTask collectionTask = new BarrageCollectionTestTask(liveUrl, liveName, currentTime);
@@ -73,6 +75,7 @@ public abstract class CreateTaskJob implements Job {
         HttpResponse response = HTTP_CLIENT.execute(post);
         ServerResponseMessage responseMessage = objectMapper.readValue(response.getEntity().getContent(), ServerResponseMessage.class);
         responseMessage.setName(collectionTask.getName());
+        if (responseMessage.getCode() != 200) return null;
 
         try (SqlSession session = SQL_SESSION_FACTORY.openSession(true)) {
             BarrageCollectionTestTaskMapper testTaskMapper = session.getMapper(BarrageCollectionTestTaskMapper.class);