backup

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

@@ -19,10 +19,12 @@ import org.bson.Document;
 import org.jetbrains.annotations.NotNull;
 import org.quartz.Job;
 import org.quartz.JobBuilder;
+import org.quartz.JobDataMap;
 import org.quartz.SchedulerException;
 import org.quartz.Trigger;
 import org.quartz.TriggerBuilder;
 
+import static com.zhiweidata.automatictest.barragecrawlerserver.config.BaseConfig.BARRAGE_COLLECTION_TASK_JOB_KEY;
 import static com.zhiweidata.automatictest.barragecrawlerserver.config.BaseConfig.EXPORT_START_MAX_DELAY;
 import static com.zhiweidata.automatictest.barragecrawlerserver.config.BaseConfig.MONGO_LIVE_COLLECTION;
 import static com.zhiweidata.automatictest.barragecrawlerserver.config.BaseConfig.TASK_URL;
@@ -80,6 +82,9 @@ public abstract class CreateTaskJob implements Job {
         String name = tClass.getSimpleName(), group = "export";
         jobBuilder.withIdentity(name, group);
         jobBuilder.withDescription("弹幕导出，以及导出的excel文件的分析");
+        JobDataMap dataMap = new JobDataMap();
+        dataMap.put(BARRAGE_COLLECTION_TASK_JOB_KEY, collectionTask);
+        jobBuilder.usingJobData(dataMap);
 
         TriggerBuilder<Trigger> triggerBuilder = TriggerBuilder.newTrigger();
         triggerBuilder.withIdentity(name, group);